package project.data;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.stream.Collectors;

import org.apache.commons.lang3.StringUtils;
import org.springframework.util.CollectionUtils;

import kernel.exception.BusinessException;
import kernel.util.Arith;
import kernel.util.DateUtils;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import project.Constants;
import project.contract.ContractOrder;
import project.data.DataService;
import project.data.model.Realtime;
import project.exchange.ExchangeApplyOrder;
import project.finance.FinanceOrder;
import project.futures.FuturesOrder;
import project.miner.model.MinerOrder;
import project.party.PartyService;
import project.party.model.Party;
import project.party.model.UserRecom;
import project.party.recom.UserRecomService;
import project.user.ChildrenLever;
import project.user.UserData;
import project.user.UserDataService;
import project.user.UserDataSum;
import security.Role;
import security.SecUser;
import security.internal.SecUserService;

public class UserDataServiceImpl implements UserDataService {

	private DataService dataService;
	
	private PartyService partyService;
	
	private SecUserService secUserService;
	
	private UserRecomService userRecomService;
	
	private Map<String, Map<String, UserData>> cache = new ConcurrentHashMap<String, Map<String, UserData>>();
	
	public Map<String, UserData> cacheByPartyId(String partyId) {
		return cache.get(partyId);
	}
	
	public List<Map<String, UserData>> cacheByPartyIds(List<String> partyIds) {
		if(CollectionUtils.isEmpty(partyIds)) return new LinkedList<Map<String, UserData>>();
		
		List<Map<String, UserData>> result = new LinkedList<Map<String, UserData>>();
		for(String id:partyIds) result.add(cache.get(id));
		
		return result;
	}
	
	public void init() {
		List<UserData> all = getAll();
		for (int i = 0; i < all.size(); setCache(all.get(i++)));
	}

	public List<UserData> getAll() {
		return ApplicationUtil.executeSelect(UserData.class);
	}

	private UserData findBydate(String partyId, Date date) {
		Date createTime_begin = null;
		Date createTime_end = null;
		if (date != null) {
			createTime_begin = DateUtils.toDate(DateUtils.format(date, "yyyy-MM-dd"));
			createTime_end = DateUtils.addDate(createTime_begin, 1);
		}
		
		List<UserData> list = ApplicationUtil.executeSelect(UserData.class,"WHERE PARTY_ID=? AND CREATE_TIME>=? AND CREATE_TIME<?",new Object[] {partyId,createTime_begin,createTime_end});
		return list.size()<=0?null:list.get(0);
	}

	public void updateSum(UserDataSum entity) {
		ApplicationUtil.executeUpdate(entity);
	}

	/**
	 * 根据partyId获取UserDataSum
	 */
	public UserDataSum saveBySum(String partyId) {
		List<UserDataSum> list = ApplicationUtil.executeSelect(UserDataSum.class,"WHERE PARTY_ID=?",new Object[] {partyId});
		if (list.size()>0) return list.get(0);
		
		UserDataSum userDataSum = new UserDataSum();
		userDataSum.setPartyId(partyId);
		ApplicationUtil.executeInsert(userDataSum);
		
		return userDataSum;
	}

	public void setCache(UserData entity) {
		Map<String, UserData> map_party = cache.get(entity.getPartyId().toString());
		if (map_party == null) cache.put(entity.getPartyId().toString(),map_party=new ConcurrentHashMap<String,UserData>());
		map_party.put(DateUtils.format(entity.getCreateTime(), DateUtils.DEFAULT_DATE_FORMAT), entity);
	}

	public void save(UserData entity) {
		UserData db = findBydate(entity.getPartyId().toString(), entity.getCreateTime());
		if (db != null) {
			db.setRecharge_dapp(Arith.add(db.getRecharge_dapp(), entity.getRecharge_dapp()));
			db.setWithdraw_dapp(Arith.add(db.getWithdraw_dapp(), entity.getWithdraw_dapp()));
			
			db.setRecharge(Arith.add(db.getRecharge(), entity.getRecharge()));
			db.setRecharge_eth(Arith.add(db.getRecharge_eth(), entity.getRecharge_eth()));
			db.setRecharge_usdt(Arith.add(db.getRecharge_usdt(), entity.getRecharge_usdt()));
			db.setRecharge_usdc(Arith.add(db.getRecharge_usdc(), entity.getRecharge_usdc()));
			db.setRecharge_btc(Arith.add(db.getRecharge_btc(), entity.getRecharge_btc()));
			db.setRecharge_ht(Arith.add(db.getRecharge_ht(), entity.getRecharge_ht()));
			db.setRecharge_ltc(Arith.add(db.getRecharge_ltc(), entity.getRecharge_ltc()));
			// 充值返佣
			db.setRechargeRecom(Arith.add(db.getRechargeRecom(), entity.getRechargeRecom()));

			db.setWithdraw_all(Arith.add(db.getWithdraw_all(), entity.getWithdraw_all()));
			db.setWithdraw(Arith.add(db.getWithdraw(), entity.getWithdraw()));
			db.setWithdraw_eth(Arith.add(db.getWithdraw_eth(), entity.getWithdraw_eth()));
			db.setWithdraw_btc(Arith.add(db.getWithdraw_btc(), entity.getWithdraw_btc()));
			
			db.setAmount(Arith.add(db.getAmount(), entity.getAmount()));
			db.setFee(Arith.add(db.getFee(), entity.getFee()));
			db.setOrder_income(Arith.add(db.getOrder_income(), entity.getOrder_income()));
			db.setFinance_amount(Arith.add(db.getFinance_amount(), entity.getFinance_amount()));
			db.setFinance_income(Arith.add(db.getFinance_income(), entity.getFinance_income()));
			db.setExchange_amount(Arith.add(db.getExchange_amount(), entity.getExchange_amount()));
			db.setExchange_fee(Arith.add(db.getExchange_fee(), entity.getExchange_fee()));
			db.setExchange_income(Arith.add(db.getExchange_income(), entity.getExchange_income()));
			db.setCoin_income(Arith.add(db.getCoin_income(), entity.getCoin_income()));
			db.setFurtures_amount(Arith.add(db.getFurtures_amount(), entity.getFurtures_amount()));
			db.setFurtures_fee(Arith.add(db.getFurtures_fee(), entity.getFurtures_fee()));
			db.setFurtures_income(Arith.add(db.getFurtures_income(), entity.getFurtures_income()));

			db.setReco_num(db.getReco_num() + entity.getReco_num());
			db.setRecharge_withdrawal_fee(
					Arith.add(db.getRecharge_withdrawal_fee(), entity.getRecharge_withdrawal_fee()));
			db.setGift_money(Arith.add(db.getGift_money(), entity.getGift_money()));

			db.setMiner_amount(Arith.add(db.getMiner_amount(), entity.getMiner_amount()));
			db.setMiner_income(Arith.add(db.getMiner_income(), entity.getMiner_income()));
			
			// 质押2.0
			db.setGalaxy_amount(Arith.add(db.getGalaxy_amount(), entity.getGalaxy_amount()));
			db.setGalaxy_income(Arith.add(db.getGalaxy_income(), entity.getGalaxy_income()));
			
			db.setThird_recharge_amount(Arith.add(db.getThird_recharge_amount(), entity.getThird_recharge_amount()));
			db.setHolding_money(Arith.add(db.getHolding_money(), entity.getHolding_money()));
			db.setTransfer_in_money(Arith.add(db.getTransfer_in_money(), entity.getTransfer_in_money()));
			db.setTransfer_out_money(Arith.add(db.getTransfer_out_money(), entity.getTransfer_out_money()));
			
			db.setExchange_lever_amount(Arith.add(db.getExchange_lever_amount(), entity.getExchange_lever_amount()));
			db.setExchange_lever_fee(Arith.add(db.getExchange_lever_fee(), entity.getExchange_lever_fee()));
			db.setExchange_lever_order_income(Arith.add(db.getExchange_lever_order_income(), entity.getExchange_lever_order_income()));
			
			ApplicationUtil.executeUpdate(db);
			setCache(db);
		} else {
			ApplicationUtil.executeInsert(entity);
			setCache(entity);
		}
	}

	public void saveRechargeHandle(Serializable partyId, double amount, String symbol) {
		if ("USDT_DAPP".equals(symbol)) {
			Party party = this.partyService.cachePartyBy(partyId, true);
			UserData userData = new UserData();
			userData.setRolename(party.getRolename());
			userData.setCreateTime(new Date());
			userData.setPartyId(partyId);
			userData.setRecharge_dapp(amount);
			save(userData);	
			return;
		}
		
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = this.partyService.cachePartyBy(partyId, true);
		
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		
		if ("usdt".equals(symbol)) {			
			userData.setRecharge(amount);
			userData.setRecharge_usdt(amount);
		} else {			
			List<Realtime> realtime_list = this.dataService.realtime(symbol);	
			
			Realtime realtime = null;
			if (realtime_list.size() > 0) {
				realtime = realtime_list.get(0);
			} else {
				throw new BusinessException("系统错误，请稍后重试");
			}
			if ("usdc".equals(symbol)) {
				userData.setRecharge(Arith.mul(amount, realtime.getClose()));
				userData.setRecharge_usdc(amount);
			}
			if ("btc".equals(symbol)) {
				userData.setRecharge(Arith.mul(amount, realtime.getClose()));
				userData.setRecharge_btc(amount);
			}
			if ("eth".equals(symbol)) {
				userData.setRecharge(Arith.mul(amount, realtime.getClose()));
				userData.setRecharge_eth(amount);
			}
			if ("ht".equals(symbol)) {
				userData.setRecharge(Arith.mul(amount, realtime.getClose()));
				userData.setRecharge_ht(amount);
			}
			if ("ltc".equals(symbol)) {
				userData.setRecharge(Arith.mul(amount, realtime.getClose()));
				userData.setRecharge_ltc(amount);
			}
		}
		
		save(userData);
	}

	public void saveRechargeHandleDapp(Serializable partyId, double amount,String symbol) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		if ("usdt".equals(symbol)) userData.setRecharge_dapp(amount);
		
		save(userData);
	}

	/**
	 * 更新充值返佣
	 */
	public void saveUserDataForRechargeRecom(String partyId, double amount) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		userData.setRechargeRecom(amount);
		
		save(userData);
	}
	
	public void saveWithdrawHandle(Serializable partyId, double amount, double amount_fee,String symbol) {
		System.out.println("saveWithdrawHandle -> partyId:" + partyId);
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		
		if (StringUtils.isEmpty(symbol)||"usdt".equals(symbol)) {
			userData.setWithdraw(amount);
			userData.setRecharge_withdrawal_fee(amount_fee);
			userData.setWithdraw_all(amount);
		} else {
			List<Realtime> realtime_list = this.dataService.realtime(symbol);
			Realtime realtime = null;
			if (realtime_list.size() > 0) {
				realtime = realtime_list.get(0);
			} else {
				throw new BusinessException("系统错误，请稍后重试");
			}
			if ("btc".equals(symbol)) {
				userData.setRecharge_withdrawal_fee(Arith.mul(amount_fee, realtime.getClose()));
				userData.setWithdraw_btc(amount);
				userData.setWithdraw_all(Arith.mul(amount, realtime.getClose()));
			}
			if ("eth".equals(symbol)) {
				userData.setRecharge_withdrawal_fee(Arith.mul(amount_fee, realtime.getClose()));
				userData.setWithdraw_eth(amount);
				userData.setWithdraw_all(Arith.mul(amount, realtime.getClose()));
			}
		}
		
		save(userData);
	}

	public void saveWithdrawHandleDapp(Serializable partyId, double amount, double amount_fee,String symbol) {
		System.out.println("saveWithdrawHandleDapp -> partyId:" + partyId);
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		
		if (StringUtils.isEmpty(symbol) || "usdt".equals(symbol)) {
			userData.setWithdraw_dapp(amount);
		}
		
		save(userData);
	}

	public void saveClose(ContractOrder order) {
		SecUser user = this.secUserService.findUserByPartyId(order.getPartyId());
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())||Constants.SECURITY_ROLE_TEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(order.getPartyId(), false);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(order.getPartyId());
		userData.setAmount(order.getDeposit_open());
		userData.setFee(order.getFee());
		if(order.getAmount_close()< 0) order.setAmount_close(0);
		userData.setOrder_income(Arith.sub(order.getAmount_close(), order.getDeposit_open()));
		
		save(userData);
	}	

	/**
	 * 交割奖励
	 * @param partyId
	 * @param profit
	 */
	public void saveFuturesProfit(String partyId,double profit) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		userData.setFurtures_income(profit);
		
		save(userData);
	}
	
	/**
	 * 矿机买入
	 */
	@Override
	public void saveMinerBuy(MinerOrder order) {
		SecUser user = this.secUserService.findUserByPartyId(order.getPartyId());
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())||Constants.SECURITY_ROLE_TEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(order.getPartyId(), false);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(order.getPartyId());
		userData.setMiner_amount(order.getAmount());
		
		save(userData);
	}

	/**
	 * 矿机赎回
	 */
	@Override
	public void saveMinerClose(MinerOrder order) {
		SecUser user = this.secUserService.findUserByPartyId(order.getPartyId());
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())||Constants.SECURITY_ROLE_TEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(order.getPartyId(), false);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(order.getPartyId());
		userData.setMiner_amount(Arith.sub(0, order.getAmount()));
		
		save(userData);
	}

	/**
	 * 矿机利息
	 * 
	 * @param partyId 获利人
	 * @param profit  利息
	 */
	@Override
	public void saveMinerProfit(String partyId, double profit) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		userData.setMiner_income(profit);
		
		save(userData);
	}
	
	/**
	 * 质押2.0收益
	 */
	public void saveUserDataForGalaxy(String partyId, double amount, boolean ifIncome) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		if (ifIncome) {
			System.out.println("质押2.0 更新userdata 收益 " + amount);
			userData.setGalaxy_income(amount);
		}else {
			System.out.println("质押2.0 更新userdata 下单金额 " + amount);
			userData.setGalaxy_amount(amount);
		}
		
		save(userData);
	}

	/**
	 * 矿机利息
	 * @param partyId 获利人
	 * @param profit  利息
	 */
	@Override
	public void saveGiftMoneyHandle(Serializable partyId, double amount) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;

		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		userData.setGift_money(amount);
		
		save(userData);

	}
	
	public void setUserRecomService(UserRecomService userRecomService) {
		this.userRecomService = userRecomService;
	}

	public void setSecUserService(SecUserService secUserService) {
		this.secUserService = secUserService;
	}

	@Override
	public ChildrenLever cacheChildrenLever4(Serializable partyId) {
		ChildrenLever childrenLever = new ChildrenLever();
		/**
		 * lever1
		 */
		List<UserRecom> userrecom_lever1 = userRecomService.findRecoms(partyId);
		for (int i = 0; i < userrecom_lever1.size(); i++) {
			UserRecom userRecom = userrecom_lever1.get(i);
			childrenLever.getLever1().add(userRecom.getPartyId().toString());
		}
		
		/**
		 * lever2
		 */
		if (childrenLever.getLever1().size() == 0) return childrenLever;
		
		for (int i = 0; i < childrenLever.getLever1().size(); i++) {
			List<UserRecom> userrecom_lever2 = userRecomService.findRecoms(childrenLever.getLever1().get(i));
			for (int j = 0; j < userrecom_lever2.size(); j++) {
				UserRecom userRecom = userrecom_lever2.get(j);
				childrenLever.getLever2().add(userRecom.getPartyId().toString());
			}
		}

		/**
		 * lever3
		 */
		if (childrenLever.getLever2().size() == 0) return childrenLever;
		
		for (int i = 0; i < childrenLever.getLever2().size(); i++) {
			List<UserRecom> userrecom_lever3 = userRecomService.findRecoms(childrenLever.getLever2().get(i));
			for (int j = 0; j < userrecom_lever3.size(); j++) {
				childrenLever.getLever3().add(userrecom_lever3.get(j).getPartyId().toString());
			}
		}
		
		return childrenLever;
	}

	@Override
	public void saveRegister(Serializable partyId) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		UserRecom userRecom = this.userRecomService.findByPartyId(partyId);
		if (userRecom == null) return;
		
		List<UserRecom> parents = this.userRecomService.getParents(userRecom.getPartyId());
		int loop = 4;
		for (int i = 0; i < parents.size(); i++) {
			Party party_parent = partyService.cachePartyBy(parents.get(i).getReco_id(), true);
			if (Constants.SECURITY_ROLE_MEMBER.equals(party_parent.getRolename()) && loop > 0) {
				UserData userData_reco = new UserData();
				userData_reco.setRolename(party_parent.getRolename());
				userData_reco.setCreateTime(new Date());
				userData_reco.setPartyId(parents.get(i).getReco_id());
				userData_reco.setReco_num(1);
				save(userData_reco);

				UserDataSum userDataSum = this.saveBySum(parents.get(i).getReco_id().toString());
				userDataSum.setReco_num(userDataSum.getReco_num() + 1);
				this.updateSum(userDataSum);
				loop--;
			}
		}
	}
	
	/**
	 * 资金盘定制化需求，等盘口下架可以删除
	 */
	public List<Map<String, Object>> getChildrenLevelPagedForGalaxy(int pageNo, int pageSize, String partyId, Integer levelNum) {
		if (pageNo <= 0) pageNo = 1;
		Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
		
		List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
		ChildrenLever children = cacheChildrenLever4(partyId);
		// 获取子代partyId
		List<String> level = new ArrayList<String>();
		if (levelNum == 1) {
			level = children.getLever1();
		}
		if (levelNum == 2) {
			level = children.getLever2();
		}
		if (levelNum == 3) {
			level = children.getLever3();
		}
		if (level == null || level.isEmpty()) {
			return list;
		}
		
		String inSubStatement=level.stream().filter(le->null!=le&&!le.trim().isEmpty()).map(le->"'"+le.trim()+"'").collect(Collectors.joining(",","(",") LIMIT ?,?"));
		String partySql=new StringBuilder("SELECT UUID partyId,USERNAME username FROM PAT_PARTY WHERE UUID IN").append(inSubStatement).toString();
		List<Map> element=ApplicationUtil.executeDQL(partySql,new Object[] {page.getFirstElementNumber(),pageSize},Map.class);
		page.setElements(element);
		
		Map<String, Object> element_map = new HashMap<String, Object>();
		for (int i = 0; i < element.size(); i++) {
			element_map = (Map<String, Object>) element.get(i);
			String childrenPartyId = element_map.get("partyId").toString();
			ChildrenLever childrenLever = cacheChildrenLever4(childrenPartyId);
			element_map.put("reco_sum", childrenLever.getLever1().size());
			// list里面的总业绩
			Map<String, UserData> map = cacheByPartyId(childrenPartyId);
			double sum = 0;
			if (null != map && map.size() > 0) {
				for (UserData userData : map.values()) {
					sum += userData.getGalaxy_income();
				}
			}
			
			element_map.put("recharge_sum", sum);

			list.add(element_map);
		}
		return list;
	}

	/**
	 * 交易所
	 */
	public List<Map<String, Object>> getChildrenLevelPaged(int pageNo, int pageSize, String partyId, Integer levelNum) {
		if (pageNo <= 0) pageNo = 1;
		Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
		
		List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
		ChildrenLever children = cacheChildrenLever4(partyId);
		// 获取子代partyId
		List<String> level = new ArrayList<String>();
		if (levelNum == 1) {
			level = children.getLever1();
		}
		if (levelNum == 2) {
			level = children.getLever2();
		}
		if (levelNum == 3) {
			level = children.getLever3();
		}
		
		if (level == null || level.isEmpty()) {
			return list;
		}
		
		String inSubStatement=level.stream().filter(le->null!=le&&!le.trim().isEmpty()).map(le->"'"+le.trim()+"'").collect(Collectors.joining(",","(",") LIMIT ?,?"));
		String partySql=new StringBuilder("SELECT UUID partyId,USERNAME username,KYC_AUTHORITY kyc_authority FROM PAT_PARTY WHERE UUID IN").append(inSubStatement).toString();
		List<Map> element=ApplicationUtil.executeDQL(partySql,new Object[] {page.getFirstElementNumber(),pageSize},Map.class);
		page.setElements(element);
		
		Map<String, Object> element_map = new HashMap<String, Object>();
		for (int i = 0; i < element.size(); i++) {
			element_map = (Map<String, Object>) element.get(i);
			String childrenPartyId = element_map.get("partyId").toString();
			ChildrenLever childrenLever = cacheChildrenLever4(childrenPartyId);
			// 获取子代partyId
			List<String> level_children = new ArrayList<String>();
			if (levelNum == 1) {
				level_children = childrenLever.getLever1();
			}
			if (levelNum == 2) {
				level_children = childrenLever.getLever2();
			}
			if (levelNum == 3) {
				level_children = childrenLever.getLever3();
			}
			element_map.put("reco_sum", level_children.size());
			
			// list里面的总业绩
			Map<String, UserData> map = cacheByPartyId(childrenPartyId);
			double sum = 0;
			if (null != map && map.size() > 0) {
				for (UserData userData : map.values()) {
					sum += userData.getRecharge();
				}
			}
			
			element_map.put("recharge_sum", sum);
			
			list.add(element_map);
		}
		return list;
	}
	
	/**
	 * 获取所有下级列表 - IoeAi定制需求
	 */
	public List<Map<String, Object>> getAllChildrenPaged(int pageNo, int pageSize, String partyId){
		if (pageNo <= 0) pageNo = 1;
		Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
		
		List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
		List<String> childrens = userRecomService.findChildren(partyId);
		if (null == childrens || childrens.isEmpty()) return list;
		
		String inSubStatement=childrens.stream().filter(le->null!=le&&!le.trim().isEmpty()).map(le->"'"+le.trim()+"'").collect(Collectors.joining(",","(",") LIMIT ?,?"));
		String partySql=new StringBuilder("SELECT USERNAME username,UUID partyId FROM PAT_PARTY WHERE UUID IN").append(inSubStatement).toString();
		List<Map> element=ApplicationUtil.executeDQL(partySql,new Object[] {page.getFirstElementNumber(),pageSize},Map.class);
		page.setElements(element);
		
		Map<String, Object> element_map = new HashMap<String, Object>();
		for (int i = 0; i < element.size(); i++) {
			element_map = (Map<String, Object>) element.get(i);
			String levelPartyId = element_map.get("partyId").toString();
			List<String> levelChildrens = userRecomService.findChildren(levelPartyId);
			
			// list里面的总业绩 - 所有下级的 收益之和
			double sum = 0;
			for (String id : levelChildrens) {
				Map<String, UserData> map = cacheByPartyId(id);
				if (null != map && map.size() > 0) {
					for (UserData userData : map.values()) {
						sum += userData.getGalaxy_income();
					}
				}
			}
			
			element_map.put("reco_sum", levelChildrens.size());
			element_map.put("recharge_sum", sum);
			list.add(element_map);
		}
		return list;
	}
	
	/**
	 * 交易所-推广数据汇总
	 */
	public Map<String, String> getPromoteData(String partyId, Map<String, String> data, Date startTime, Date endTime) {
		ChildrenLever children = cacheChildrenLever4(partyId);
		// 获取子代partyId
		List<String> level1 = new ArrayList<String>();
		List<String> level2 = new ArrayList<String>();
		List<String> level3 = new ArrayList<String>();
		level1 = children.getLever1();
		level2 = children.getLever2();
		level3 = children.getLever3();
		
		Map<String, String> peoples = new HashMap<>();
		double rechangeAmount = 0;
		for (String value1 : level1) {
			Map<String, UserData> map = cacheByPartyId(value1);
			if (null != map && map.size() > 0) {
				for (UserData userData : map.values()) {
					if (userData.getRecharge() <= 0) {
						continue;
					}
					if (null != startTime && null != endTime) {
						Date createTime = userData.getCreateTime();
						if (createTime.after(endTime) && createTime.before(startTime)) {
							rechangeAmount += userData.getRecharge();
							peoples.put(String.valueOf(userData.getPartyId()), "");
						}
					} else {
						rechangeAmount += userData.getRecharge();
						peoples.put(String.valueOf(userData.getPartyId()), "");
					}
				}
			}
		}
		
		for (String value2 : level2) {
			Map<String, UserData> map = cacheByPartyId(value2);
			if (null != map && map.size() > 0) {
				for (UserData userData : map.values()) {
					if (userData.getRecharge() <= 0) {
						continue;
					}
					if (null != startTime && null != endTime) {
						Date createTime = userData.getCreateTime();
						if (createTime.after(endTime) && createTime.before(startTime)) {
							rechangeAmount += userData.getRecharge();
							peoples.put(String.valueOf(userData.getPartyId()), "");
						}
					} else {
						rechangeAmount += userData.getRecharge();
						peoples.put(String.valueOf(userData.getPartyId()), "");
					}
				}
			}
		}
		
		for (String value3 : level3) {
			Map<String, UserData> map = cacheByPartyId(value3);
			if (null != map && map.size() > 0) {
				for (UserData userData : map.values()) {
					if (userData.getRecharge() <= 0) {
						continue;
					}
					if (null != startTime && null != endTime) {
						Date createTime = userData.getCreateTime();
						if (createTime.after(endTime) && createTime.before(startTime)) {
							rechangeAmount += userData.getRecharge();
							peoples.put(String.valueOf(userData.getPartyId()), "");
						}
					} else {
						rechangeAmount += userData.getRecharge();
						peoples.put(String.valueOf(userData.getPartyId()), "");
					}
				}
			}
		}
		
		data.put("peopleNum", String.valueOf(peoples.size()));
		data.put("rechangeAmount", String.valueOf(rechangeAmount));
		return data;
	}
	
	/**
	 * 三方充值
	 */
	public void saveThirdRechargeMoneyHandle(Serializable partyId, double amount) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		userData.setThird_recharge_amount(amount);
		userData.setRecharge(amount);
		
		save(userData);

	}
	/**
	 * 持有金额（钱包+扩展钱包）
	 * @param partyId
	 * @param amount
	 */
	public void saveHodingMoneyHandle(Serializable partyId, double amount) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		userData.setHolding_money(amount);
		
		save(userData);

	}
	
	/**
	 * 根据日期获取当日充值数
	 * @param date	字符串日期，"2020-01-01"
	 * @return
	 */
	public int filterRechargeByDate(String date) {
		int sum = 0;
		List<Map<String, UserData>> list = new ArrayList<>(cache.values());
		for(Map<String, UserData> ud:list) {
			UserData userData = ud.get(date);
			if(userData!=null&&userData.getRecharge()>0) {//当日有充值
				sum++;
			}
		}
		return sum;
	}
	
	/**
	 * 转账
	 * @param byPartyId		转出用户id
	 * @param toPartyId		转入用户id
	 * @param outAmountToUsdt	转出金额（USDT计价）
	 * @param inAmountToUsdt	转入金额（USDT计价）
	 */
	public void saveTransferMoneyHandle(String byPartyId,String toPartyId, double outAmountToUsdt, double inAmountToUsdt) {
		saveTransferOutMoneyHandle(byPartyId,outAmountToUsdt);
		saveTransferInMoneyHandle(toPartyId,inAmountToUsdt);
	}
	
	/**
	 * 转入金额
	 * @param partyId
	 * @param amountToUsdt
	 */
	public void saveTransferInMoneyHandle(String partyId, double amountToUsdt) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		userData.setTransfer_in_money(amountToUsdt);
		
		save(userData);
	}
	
	/**
	 * 转出金额
	 * @param partyId
	 * @param amountToUsdt
	 */
	public void saveTransferOutMoneyHandle(String partyId, double amountToUsdt) {
		SecUser user = this.secUserService.findUserByPartyId(partyId);
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(partyId, true);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(partyId);
		userData.setTransfer_out_money(amountToUsdt);
		save(userData);
	}
	
	public void setPartyService(PartyService partyService) {
		this.partyService = partyService;
	}

	public void setDataService(DataService dataService) {
		this.dataService = dataService;
	}
	
	@Override
	public void saveBuy(ExchangeApplyOrder order) {
		SecUser user = this.secUserService.findUserByPartyId(order.getPartyId());
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())||Constants.SECURITY_ROLE_TEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(order.getPartyId(), false);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(order.getPartyId());
		userData.setExchange_amount(order.getVolume());
		userData.setExchange_fee(0);
		
		save(userData);

	}
	
	public void saveSell(ExchangeApplyOrder order) {
		SecUser user = this.secUserService.findUserByPartyId(order.getPartyId());
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())||Constants.SECURITY_ROLE_TEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		List<Realtime> realtime_list = this.dataService.realtime(order.getSymbol());
		Realtime realtime = null;
		if (realtime_list.size() > 0) {
			realtime = realtime_list.get(0);
		} else {
			throw new BusinessException("系统错误，请稍后重试");
		}

		Party party = partyService.cachePartyBy(order.getPartyId(), false);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(order.getPartyId());
		userData.setExchange_amount(Arith.mul(realtime.getClose(), order.getVolume()));
		userData.setExchange_fee(Arith.mul(realtime.getClose(), order.getFee()));
		userData.setExchange_income(0);
		
		save(userData);
	}
	
	/**
	 * 理财产品平仓
	 */
	public void saveSellFinance(FinanceOrder order) {
		SecUser user = this.secUserService.findUserByPartyId(order.getPartyId());
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())||Constants.SECURITY_ROLE_TEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(order.getPartyId(), false);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(order.getPartyId());
		userData.setFinance_amount(order.getAmount());
		userData.setFinance_income(order.getProfit());
		
		save(userData);
	}


	/**
	 * 交割合约平仓
	 */
	@Override
	public void saveFuturesClose(FuturesOrder order) {
		SecUser user = this.secUserService.findUserByPartyId(order.getPartyId());
		user.getRoles();
		boolean guest = false;
		for (Role role : user.getRoles()) {
			if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())||Constants.SECURITY_ROLE_TEST.equals(role.getRoleName())) {
				guest = true;
			}
		}
		
		if (guest) return;
		
		Party party = partyService.cachePartyBy(order.getPartyId(), false);
		UserData userData = new UserData();
		userData.setRolename(party.getRolename());
		userData.setCreateTime(new Date());
		userData.setPartyId(order.getPartyId());
		userData.setFurtures_amount(order.getVolume());
		userData.setFurtures_fee(order.getFee());
		userData.setFurtures_income(order.getProfit());
		
		save(userData);
	}
}