package project.web.api;

import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import kernel.exception.BusinessException;
import kernel.util.DateUtils;
import kernel.util.StringUtils;
import kernel.web.BaseAction;
import kernel.web.ResultObject;
import project.monitor.pledgegalaxy.PledgeGalaxyConfigService;
import project.party.PartyService;
import project.party.recom.UserRecomService;
import project.syspara.Syspara;
import project.syspara.SysparaService;
import project.user.ChildrenLever;
import project.user.UserData;
import project.user.UserDataService;
import util.DateUtil;

/**
 * 我的推广
 *
 */
@RestController
@CrossOrigin
public class PromoteController extends BaseAction {
	
	private Logger logger=LoggerFactory.getLogger(PromoteController.class);
	
	@Autowired
	protected UserRecomService userRecomService;
	
	@Autowired
	protected UserDataService userDataService;
	
	@Autowired
	protected PartyService partyService;
	
	@Autowired
	protected SysparaService sysparaService;
	
	@Autowired
	protected PledgeGalaxyConfigService pledgeGalaxyConfigService;
	
	private final String action = "api/promote!";

	@RequestMapping(action + "getPromote.action")
	public Object getPromote(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		
		// 层级 1为第一级 1,2,3,4总共4级代理
		String level_temp = request.getParameter("level");
		
		if (StringUtils.isNullOrEmpty(level_temp) 
				|| !StringUtils.isInteger(level_temp) || Integer.valueOf(level_temp) <= 0) {
			throw new BusinessException("代理层级错误");
		}
		
		int level = Integer.valueOf(level_temp);
		String page_no = request.getParameter("page_no");
		if (StringUtils.isNullOrEmpty(page_no) 
				|| !StringUtils.isInteger(page_no) || Integer.valueOf(page_no) <= 0) {
			page_no = "1";
		}
		
		int pageNo = Integer.valueOf(page_no);
		
		String partyId = getLoginPartyId();
		try {

			Map<String, Object> data = new HashMap<String, Object>();
			Map<String, Object> data_total = new HashMap<String, Object>();
			List<Map<String, Object>> dataChilds = new ArrayList<Map<String, Object>>();

			ChildrenLever childrenLever = userDataService.cacheChildrenLever4(partyId);

			data.put("children", childrenLever.getLever1().size() 
					+ childrenLever.getLever2().size()
					+ childrenLever.getLever3().size());

			data.put("level_1", childrenLever.getLever1().size());
			data.put("level_2", childrenLever.getLever2().size());
			data.put("level_3", childrenLever.getLever3().size());
//			data.put("level_4", childrenLever.getLever4().size());
			data_total.put("total", data);

			// 资金盘 定制化需求，后面盘口下架可以删
			dataChilds = this.userDataService.getChildrenLevelPagedForGalaxy(pageNo, 10, partyId, level);
			Map<String, UserData> map = userDataService.cacheByPartyId(partyId);
			Syspara projectType = sysparaService.find("project_type");
			if (null != projectType && projectType.getValue().equals("DAPP_EXCHANGE")) {
				double sum = 0;
				if (null != map && map.size() > 0) {
					for (UserData userData : map.values()) {
						sum += userData.getGalaxy_income();
					}
				}
				// 总绩效
				data_total.put("profit_sum", sum);
			}
			
			// safePal5
			
			if (null != projectType && projectType.getValue().equals("DAPP_EXCHANGE_SAFEPAL5")) {
				double sum = 0;
				// 自己
				if (null != map && map.size() > 0) {
					for (UserData userData : map.values()) {
						sum += userData.getGalaxy_income();
					}
				}
				// 总绩效
				DecimalFormat df2 = new DecimalFormat("#.##");
				data_total.put("profit_sum", df2.format(sum));
			}
			
			
			// 交易所
			if (null == projectType || !projectType.getValue().contains("DAPP_EXCHANGE")) {
				double sum = 0;
				if (null != map && map.size() > 0) {
					for (UserData userData : map.values()) {
						sum += userData.getRecharge();
					}
				}
				// 总充值
				data_total.put("recharge_sum", sum);
			}
			
			// 加密用户名
			handleChilds(dataChilds);
			data_total.put("list", dataChilds);
			resultObject.setData(data_total);
		} catch (BusinessException e) {
			resultObject.setCode("402");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable e) {
			resultObject.setCode("500");
			resultObject.setMsg("程序错误");
			logger.error("error:", e);
		}

		return resultObject;
	}
	
	/**
	 * 推广页面-IoeAI资金盘 定制
	 */
	@RequestMapping(action + "getPromoteIoeAi.action")
	public Object getPromoteIoeAi(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		
		String page_no = request.getParameter("page_no");
		if (StringUtils.isNullOrEmpty(page_no) 
				|| !StringUtils.isInteger(page_no) || Integer.valueOf(page_no) <= 0) {
			page_no = "1";
		}
		
		int pageNo = Integer.valueOf(page_no);
		
		String partyId = getLoginPartyId();
		try {

			Map<String, Object> data = new HashMap<String, Object>();
			List<Map<String, Object>> dataChilds = new ArrayList<Map<String, Object>>();

			// 所有下级（1-N级）
			List<String> partyLists = userRecomService.findChildren(partyId);

			// 推广总人数
			data.put("total", partyLists.size());

			dataChilds = this.userDataService.getAllChildrenPaged(pageNo, 30, partyId);
			
			// 总业绩 - 所有下级的 收益之和
			double sum = 0;
			for (String id : partyLists) {
				Map<String, UserData> map = userDataService.cacheByPartyId(id);
				if (null != map && map.size() > 0) {
					for (UserData userData : map.values()) {
						sum += userData.getGalaxy_income();
					}
				}
			}
			
			// 总绩效
			data.put("profit_sum", sum);
			
			int ioeAiLevel = pledgeGalaxyConfigService.getIoeAiLevel(partyId);
			// -1 0 青铜级 1 白银级 2 黄金级 3 铂金级 4 钻石级
			data.put("ioeAiLevel", ioeAiLevel);
			
			// 加密用户名
			handleChilds(dataChilds);
			
			// 下级列表
			data.put("list", dataChilds);
			data.put("page_no", pageNo);
			resultObject.setData(data);
		} catch (BusinessException e) {
			resultObject.setCode("402");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable e) {
			resultObject.setCode("500");
			resultObject.setMsg("程序错误");
			logger.error("error:", e);
		}

		return resultObject;
	}
	
	/**
	 * 交易所-数据总览-PC端
	 */
	@RequestMapping(action + "getPromoteData.action")
	public Object getPromoteData(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		
		String partyId = getLoginPartyId();
		Map<String, String> dataMap = new HashMap<>();
		try {
			Date date = new Date();
			Date startTime = null;
			Date endTime = null;
			String type = request.getParameter("type");
			if (type.equals("day")) {
				startTime = DateUtils.getDayStart(DateUtils.addDate(date, 1));
				endTime = DateUtils.getDayEnd(DateUtils.addDate(date, 1));
			} else if (type.equals("week")) {
				startTime = DateUtil.getFirstDateOfWeek(date);
				endTime = DateUtil.getLastDateOfWeek(date);
			} else if (type.equals("month")) {
				startTime = DateUtil.getFirstDateOfMonth(date);
				endTime = DateUtil.getLastDateOfMonth(date);
			}
			System.out.println("推广数据总览 开始时间" + startTime);
			System.out.println("推广数据总览 结束时间" + endTime);
			dataMap = userDataService.getPromoteData(partyId, dataMap, startTime, endTime);
			
			Map<String, UserData> map = userDataService.cacheByPartyId(partyId);
			double sum = 0;
			if (null != map && map.size() > 0) {
				for (UserData userData : map.values()) {
					sum += userData.getRechargeRecom();
				}
			}
			
			dataMap.put("rechargeRecom", String.valueOf(sum));

			resultObject.setData(dataMap);
		} catch (BusinessException e) {
			resultObject.setCode("402");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable e) {
			resultObject.setCode("500");
			resultObject.setMsg("程序错误");
			logger.error("error:", e);
		}
		
		return resultObject;
	}

	/**
	 * 加密用户名
	 */
	protected void handleChilds(List<Map<String, Object>> dataChilds) {
		for (Map<String, Object> data : dataChilds) {
			String username = data.get("username").toString();
			int length = username.length();
			if (username.length() > 2) {
				data.put("username", username.substring(0, 3) + "***" + username.substring(length - 3));
//				data.put("username", String.format("%s%s%s", username.substring(0, 1), securityLength(length - 2),
//						username.substring(length - 1)));
			}
		}
	}

	private String securityLength(int length) {
		if (length <= 0)
			return "";
		StringBuffer sb = new StringBuffer();
		for (int i = 0; i < length; i++) {
			sb.append("*");
		}
		return sb.toString();
	}
	
}