package project.web.admin.controller.report;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.lang3.ObjectUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;

import kernel.exception.BusinessException;
import kernel.util.DateUtils;
import kernel.util.StringUtils;
import kernel.web.Page;
import kernel.web.PageActionSupport;
import project.party.PartyService;
import project.user.UserDataService;
import project.web.admin.service.report.AdminUserAllStatisticsService;
import project.web.admin.service.user.AdminAgentService;

/**
 * 交易所_用户收益报表
 */
@RestController
public class AdminUserAllStatisticsController extends PageActionSupport {

	private Logger logger = LoggerFactory.getLogger(AdminUserAllStatisticsController.class);

	@Autowired
	protected AdminUserAllStatisticsService adminUserAllStatisticsService;
	@Autowired
	protected AdminAgentService adminAgentService;
	@Autowired
	protected UserDataService userDataService;
	@Autowired
	protected PartyService partyService;

	private final String action = "normal/adminUserAllStatisticsAction!";

	/**
	 * 获取 用户收益报表 列表
	 */
	@RequestMapping(action + "list.action")
	public ModelAndView list(HttpServletRequest request) {
		boolean no_agent_recom = Boolean.valueOf(request.getParameter("no_agent_recom")).booleanValue();
		String para_rolename = request.getParameter("para_rolename");
		boolean para_agent_view = Boolean.valueOf(request.getParameter("para_agent_view")).booleanValue();
		String start_time = request.getParameter("start_time");
		String end_time = request.getParameter("end_time");
		String para_username = request.getParameter("para_username");
		String para_party_id = request.getParameter("para_party_id");
		String sort_column = request.getParameter("sort_column");
		String sort_type = request.getParameter("sort_type");

		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("statistics_user_all_list");
		
		int pageNo = 1;
		int pageSize = 30;
		Page page = null;
		try {
			
			pageNo = this.checkAndSetPageNo(request.getParameter("pageNo"));
			
			if (StringUtils.isEmptyString(start_time) && StringUtils.isEmptyString(end_time)) {
				end_time = DateUtils.format(new Date(), DateUtils.DF_yyyyMMdd);
				start_time = DateUtils.format(DateUtils.getMonthStart(new Date()), DateUtils.DF_yyyyMMdd);
			}
			
			para_rolename = null;
			para_agent_view = false;

			if (no_agent_recom) {
				page = this.adminUserAllStatisticsService.pagedQueryNoAgentParent(pageNo, pageSize, start_time, end_time,
						this.getLoginPartyId(), para_username, para_rolename, para_party_id, para_agent_view, sort_column, sort_type);
			} else {				
				page = this.adminUserAllStatisticsService.pagedQuery(pageNo, pageSize, start_time, end_time,
						this.getLoginPartyId(), para_username, para_rolename, para_party_id, para_agent_view, sort_column, sort_type);				
			}

		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			return modelAndView;
		}
		
		modelAndView.addObject("pageNo", pageNo);
		modelAndView.addObject("pageSize", pageSize);
		modelAndView.addObject("page", page);		
		modelAndView.addObject("no_agent_recom", no_agent_recom);
		modelAndView.addObject("para_rolename", para_rolename);
		modelAndView.addObject("para_agent_view", para_agent_view);
		modelAndView.addObject("start_time", start_time);
		modelAndView.addObject("end_time", end_time);
		modelAndView.addObject("para_username", para_username);
		modelAndView.addObject("para_party_id", para_party_id);
		modelAndView.addObject("sort_column", sort_column);
		modelAndView.addObject("sort_type", sort_type);
		return modelAndView;
	}

	/**
	 * 获取 用户收益报表 列表
	 */
	@RequestMapping(action + "exchangeList.action")
	public ModelAndView exchangeList(HttpServletRequest request) {
		String para_rolename = request.getParameter("para_rolename");
		boolean para_agent_view = Boolean.valueOf(request.getParameter("para_agent_view")).booleanValue();
		String start_time = request.getParameter("start_time");
		String end_time = request.getParameter("end_time");
		String para_username = request.getParameter("para_username");
		String para_party_id = request.getParameter("para_party_id");
		String sort_column = request.getParameter("sort_column");
		String sort_type = request.getParameter("sort_type");

		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("statistics_user_all_list");
		
		int pageNo = 1;
		int pageSize = 30;
		Page page = null;
		try {
			pageNo = this.checkAndSetPageNo(request.getParameter("pageNo"));
			
			if (StringUtils.isEmptyString(start_time) && StringUtils.isEmptyString(end_time)) {
				end_time = DateUtils.format(new Date(), DateUtils.DF_yyyyMMdd);
				start_time = DateUtils.format(DateUtils.getMonthStart(new Date()), DateUtils.DF_yyyyMMdd);
			}
			
			para_rolename = null;
			para_agent_view = false;

			page = adminUserAllStatisticsService.exchangePagedQuery(pageNo, pageSize, start_time, end_time, this.getLoginPartyId(),
					para_username, para_rolename, para_party_id, para_agent_view, sort_column, sort_type);

		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			return modelAndView;
		}
		
		modelAndView.addObject("pageNo", pageNo);
		modelAndView.addObject("pageSize", pageSize);
		modelAndView.addObject("page", page);		
		modelAndView.addObject("para_rolename", para_rolename);
		modelAndView.addObject("para_agent_view", para_agent_view);
		modelAndView.addObject("start_time", start_time);
		modelAndView.addObject("end_time", end_time);
		modelAndView.addObject("para_username", para_username);
		modelAndView.addObject("para_party_id", para_party_id);
		modelAndView.addObject("sort_column", sort_column);
		modelAndView.addObject("sort_type", sort_type);
		return modelAndView;
	}
	
	
	/**
	 * 导出数据到文件
	 */
	@RequestMapping(action + "exportData.action")
	public ModelAndView exportData(HttpServletRequest request) {
		String pageNo = request.getParameter("pageNo");
		String para_rolename = request.getParameter("para_rolename");
		boolean para_agent_view = Boolean.valueOf(request.getParameter("para_agent_view")).booleanValue();
		String start_time = request.getParameter("start_time");
		String end_time = request.getParameter("end_time");
		String para_username = request.getParameter("para_username");
		String para_party_id = request.getParameter("para_party_id");
		String sort_column = request.getParameter("sort_column");
		String sort_type = request.getParameter("sort_type");

		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("statistics_user_all_list");

		try {
			this.checkAndSetPageNo(pageNo);

			if (StringUtils.isEmptyString(start_time) && StringUtils.isEmptyString(end_time)) {
				end_time = DateUtils.format(new Date(), DateUtils.DF_yyyyMMdd);
				start_time = DateUtils.format(DateUtils.getMonthStart(new Date()), DateUtils.DF_yyyyMMdd);
			}
			
			String error = this.adminUserAllStatisticsService.loadExportData(this.getResponse(), 30, start_time,
					end_time, this.getLoginPartyId(), para_username, para_rolename, para_party_id, para_agent_view,
					sort_column, sort_type);
			if (!StringUtils.isNullOrEmpty(error)) {
				throw new BusinessException(error);
			}

		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			return modelAndView;
		} catch (IOException e) {
			logger.error("export fail:{}", e);
			modelAndView.addObject("error", "程序错误,导出异常");
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			return modelAndView;
		}

		return modelAndView;
	}

	/**
	 * 用户钱包 登录者只能看自己下面的用户钱包
	 */
	@RequestMapping(action + "walletExtendsAll.action")
	public ModelAndView walletExtendsAll(HttpServletRequest request) {
		String para_wallet_party_id = request.getParameter("para_wallet_party_id");

		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("statistics_user_all_money");

		try {
			
			List<Map<String, Object>> wallet_data = this.adminUserAllStatisticsService.getWalletExtends(this.getLoginPartyId(), para_wallet_party_id);
			List<String> types = new ArrayList<String>();
			modelAndView.addObject("wallet_data", wallet_data);
			if(ObjectUtils.isNotEmpty(wallet_data)) {
				for(Map<String, Object> walletMap :wallet_data) {
					types.add(walletMap.get("wallettype").toString());
				}
			}
			String wallettype = String.join(",", types);
			modelAndView.addObject("wallet_type_arr", wallettype);
			
		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			return modelAndView;
		}

		return modelAndView;
	}

	/**
	 * 用户资产 登录者只能看自己下面的用户资产
	 */
	@RequestMapping(action + "assetsAll.action")
	public ModelAndView assetsAll(HttpServletRequest request) {
		String para_wallet_party_id = request.getParameter("para_wallet_party_id");

		ModelAndView modelAndView = new ModelAndView();

		try {
			
			List<Map<String, Object>> asset_data = adminUserAllStatisticsService.getAssetsAll(this.getLoginPartyId(), para_wallet_party_id);

			modelAndView.addObject("asset_data", asset_data);
			
		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		}

		modelAndView.setViewName("statistics_user_all_asset");
		return modelAndView;
	}
	
	/**
	 * 用户地址
	 */
	@RequestMapping(action + "addressAll.action")
	public ModelAndView addressAll(HttpServletRequest request) {
		String para_wallet_party_id = request.getParameter("para_wallet_party_id");

		ModelAndView modelAndView = new ModelAndView();

		try {
			
			List<Map<String, Object>> asset_data = adminUserAllStatisticsService.getAddressAll(this.getLoginPartyId(), para_wallet_party_id);

			modelAndView.addObject("asset_data", asset_data);
			
		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		}

		modelAndView.setViewName("statistics_user_all_address");
		return modelAndView;
	}



}