package com.yami.trading.service.user.impl;

import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yami.trading.bean.contract.domain.ContractOrder;
import com.yami.trading.bean.data.domain.Realtime;
import com.yami.trading.bean.exchange.ExchangeApplyOrder;
import com.yami.trading.bean.finance.FinanceOrder;
import com.yami.trading.bean.future.domain.FuturesOrder;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.miner.MinerOrder;
import com.yami.trading.bean.model.*;
import com.yami.trading.bean.syspara.domain.Syspara;
import com.yami.trading.bean.user.dto.ChildrenLever;
import com.yami.trading.bean.user.dto.UserBenefitsDto;
import com.yami.trading.bean.user.dto.UserDataWithdrawLimitDto;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.exception.YamiShopBindException;
import com.yami.trading.common.util.ApplicationUtil;
import com.yami.trading.common.util.Arith;
import com.yami.trading.common.util.DateUtil;
import com.yami.trading.common.util.DateUtils;
import com.yami.trading.dao.user.UserDataMapper;
import com.yami.trading.service.MoneyLogService;
import com.yami.trading.service.WalletService;
import com.yami.trading.service.contract.ContractOrderService;
import com.yami.trading.service.data.DataService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.user.UserDataService;
import com.yami.trading.service.user.UserDataSumService;
import com.yami.trading.service.user.UserRecomService;
import com.yami.trading.service.user.UserService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcOperations;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.DecimalFormat;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;

@Service
@Slf4j
public class UserDataServiceImpl extends ServiceImpl<UserDataMapper, UserData> implements UserDataService {
    @Autowired
    UserService userService;
    @Autowired
    UserRecomService userRecomService;
    @Autowired
    UserDataSumService userDataSumService;
    @Autowired
    UserService secUserService;
    @Autowired
    DataService dataService;
    @Resource
    NamedParameterJdbcOperations namedParameterJdbcTemplate;
    @Autowired
    RedisTemplate<String, Object> redisTemplate;

    @Autowired
    SysparaService sysparaService;
    String REDIS_KEY = "userdata:";
    @Autowired
    private ItemService itemService;
    private Map<String, Map<String, UserData>> cache = new ConcurrentHashMap<>();

    @Autowired
    WalletService walletService;

    @Autowired
    MoneyLogService moneyLogService;

    @PostConstruct
    public void init() {
        List<UserData> all = list();
        if(null == all) all = new ArrayList<>();
        for (UserData item : all) {
            if(null == item) continue;
            this.setCache(item);
        }
    }

    private UserData findBydate(String userId, Date date) {

        Date startDate = DateUtil.minDate(date);
        ;
        Date endDate = DateUtil.maxDate(date);
        return getOne(Wrappers.<UserData>query().lambda().between(UserData::getCreateTime, startDate, endDate)
                .eq(UserData::getUserId, userId));
    }

    @Override
    public Map<String, UserData> cacheByPartyId(String partyId) {
        return cache.get(partyId);
    }

    @Override
    public Page listUserGenefits(Page page, Date startTime, Date endTime, String userName, List<String> children) {
        baseMapper.listUserGenefits(page, startTime, endTime, userName, children);
        compute(page.getRecords());
        return page;
    }

    /**
     * COM盘（首页统计模板）定制需求 下盘后删除
     */
    @Override
    public Map<String, BigDecimal> queryUserDataByUserId(String userId) {
        List<UserData> list = baseMapper.selectList(new QueryWrapper<UserData>().eq("user_id", userId));
        return buildData(list);
    }

    /**
     * 获取今日充值的人数
     *
     * @return
     */
    @Override
    public long countTodayRechargeUser(List<String> userIds) {
        Date now = new Date();
        LambdaQueryWrapper<UserData> lambdaQueryWrapper = Wrappers.<UserData>query().lambda().between(UserData::getCreateTime, DateUtil.minDate(now),
                DateUtil.maxDate(now)).gt(UserData::getRecharge, 0);
        if (CollectionUtil.isNotEmpty(userIds)) {
            lambdaQueryWrapper.in(UserData::getUserId, userIds);
        }
        return count(lambdaQueryWrapper);
    }

    @Override
    public UserBenefitsDto daySumData(Date startTime, Date endTime, List<String> userIds) {

        return baseMapper.daySumData(startTime, endTime, userIds);
    }

    @Override
    public Map<String, Object> daySumDataOld(String day, List<String> userIds) {
        Map<String,Object> parameters = new HashMap<String,Object>();
        StringBuffer queryString = new StringBuffer("select ");
//		queryString.append("DATE_FORMAT(ud.CREATE_TIME,\"%Y-%m-%d\") AS date, ");//日期
        queryString.append("ifnull(sum(ud.recharge),0) as recharge,ifnull(sum(ud.recharge_usdt),0) as recharge_usdt,ifnull(sum(ud.recharge_eth),0) as recharge_eth,ifnull(sum(ud.recharge_btc),0) as recharge_btc,ifnull(sum(ud.recharge_ht),0) as recharge_ht,ifnull(sum(ud.recharge_ltc),0) as recharge_ltc,"
                + "ifnull(sum(ud.withdraw),0) as withdraw,ifnull(sum(ud.recharge_withdrawal_fee),0) as recharge_withdrawal_fee,ifnull(sum(ud.recharge_usdt)-sum(ud.withdraw),0) as balance_amount, ");//充提
        queryString.append("ifnull(sum(ud.fee),0) as fee,ifnull(sum(ud.order_income),0) as order_income, ");//永续
        queryString.append("ifnull(sum(ud.finance_amount),0) as finance_amount,ifnull(sum(ud.finance_income),0) as finance_income, ");//理财
        queryString.append("ifnull(sum(ud.exchange_fee),0) as exchange_fee,ifnull(sum(ud.exchange_income),0) as exchange_income, ");//币币
        queryString.append("ifnull(sum(ud.furtures_fee),0) as furtures_fee,ifnull(sum(ud.furtures_income),0) as furtures_income, ");//交割
        queryString.append("ifnull(sum(ud.miner_amount),0) as miner_amount,ifnull(sum(ud.miner_income),0) as miner_income, ");//矿机
        queryString.append("ifnull(sum(ud.third_recharge_amount),0) as third_recharge_amount, ");//三方充值
        queryString.append("ifnull(sum(ud.exchange_lever_amount),0) as exchange_lever_amount,ifnull(sum(ud.exchange_lever_fee),0) as exchange_lever_fee,ifnull(sum(ud.exchange_lever_order_income),0) as exchange_lever_order_income ");//币币杠杆
        queryString.append("from t_userdata ud ");
        queryString.append("where 1=1 ");
        queryString.append("and ud.rolename ='"+Constants.SECURITY_ROLE_MEMBER+"' ");
        if (CollectionUtil.isNotEmpty(userIds)) {
            queryString.append(" and ud.user_id in (:children) ");
            parameters.put("children", userIds);
        }
        if (StringUtils.isNotEmpty(day)) {
            queryString.append("and date(ud.create_time) = date(:day)  ");
            parameters.put("day", DateUtils.toDate(day));
        }
        List<Map<String, Object>> queryForList = this.namedParameterJdbcTemplate.queryForList( queryString.toString(), parameters);
        computeSum(queryForList,false);
        return queryForList.get(0);
    }
    private void computeSum(List<Map<String,Object>> datas,boolean isSum) {
        if(CollectionUtils.isEmpty(datas)) return;
        Double totle_income=0d;
        Double totle_fee = 0d;
        Double business_profit = 0d;//交易盈亏
        Double fin_miner_amount = 0d;//理财 矿机 交易额
        Double fin_miner_income = 0d;//理财 矿机 收益
        for(Map<String,Object> data:datas) {

            totle_income=0d;
            totle_fee = 0d;
            business_profit = 0d;
            fin_miner_amount = 0d;
            fin_miner_income = 0d;
            if(null != data.get("order_income"))
                data.put("order_income", Arith.sub(0, new Double(data.get("order_income").toString())));//订单收益负数
            if(null != data.get("finance_income"))
                data.put("finance_income", Arith.sub(0, new Double(data.get("finance_income").toString())));//理财收益负数
            if(null != data.get("exchange_income"))
//			data.put("exchange_income", Arith.sub(0, new Double(data.get("exchange_income").toString())));//币币收益负数
                data.put("exchange_income",0);//币币收益负数
            if(null != data.get("furtures_income"))
                data.put("furtures_income", Arith.sub(0, new Double(data.get("furtures_income").toString())));//交割收益负数
            if (null != data.get("miner_income"))
                data.put("miner_income", Arith.sub(0, new Double(data.get("miner_income").toString())));// 矿机收益负数
            if (null != data.get("exchange_lever_order_income"))
                data.put("exchange_lever_order_income", Arith.sub(0, new Double(data.get("exchange_lever_order_income").toString())));// 币币收益负数

            if(!dataExistNull(data)) continue;
            totle_income = Arith.add(totle_income,new Double(data.get("recharge_withdrawal_fee").toString()));
            totle_income = Arith.add(totle_income,new Double(data.get("order_income").toString()));
            totle_income = Arith.add(totle_income,new Double(data.get("fee").toString()));
            totle_income = Arith.add(totle_income,new Double(data.get("finance_income").toString()));
            totle_income = Arith.add(totle_income,new Double(data.get("exchange_fee").toString()));
            totle_income = Arith.add(totle_income,new Double(0));
//			totle_income = Arith.add(totle_income,new Double(data.get("exchange_income").toString()));
            totle_income = Arith.add(totle_income,new Double(data.get("furtures_fee").toString()));
            totle_income = Arith.add(totle_income,new Double(data.get("furtures_income").toString()));
            totle_income = Arith.add(totle_income,new Double(data.get("miner_income").toString()));
            totle_income = Arith.add(totle_income,new Double(data.get("exchange_lever_order_income").toString()));
            data.put("totle_income", totle_income);

            totle_fee = Arith.add(totle_fee, new Double(data.get("recharge_withdrawal_fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("furtures_fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_lever_fee").toString()));
            data.put("totle_fee", totle_fee);

            business_profit = Arith.add(business_profit, new Double(data.get("order_income").toString()));
            business_profit = Arith.add(business_profit, new Double(data.get("exchange_income").toString()));
            business_profit = Arith.add(business_profit, new Double(data.get("furtures_income").toString()));
            business_profit = Arith.add(business_profit, new Double(data.get("exchange_lever_order_income").toString()));
            data.put("business_profit", business_profit);

            fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("finance_amount").toString()));
            fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("miner_amount").toString()));
            data.put("fin_miner_amount", fin_miner_amount);

            fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("finance_income").toString()));
            fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("miner_income").toString()));
            data.put("fin_miner_income",  fin_miner_income);

            data.put("recharge_btc", new BigDecimal(data.get("recharge_btc").toString()).setScale(8, RoundingMode.FLOOR).toPlainString());//订单收益负数
//			data.put("recharge_usdt", new BigDecimal(data.get("recharge_usdt").toString()).setScale(4, RoundingMode.FLOOR).toPlainString());
        }
    }

    /**
     * 矿机利息
     */
    @Override
    public void saveGiftMoneyHandle(String partyId, double amount) {

        User user = userService.getById(partyId);
        boolean guest = false;
        if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName())) {
            guest = true;
        }
        if (guest) {
            return;
        }

        Date now = new Date();
        UserData userData = new UserData();
        userData.setRolename(user.getRoleName());
        userData.setCreateTime(now);
        userData.setUserId(user.getUserId());
        userData.setGiftMoney(amount);

        saveUserData(userData);
    }

    @Override
    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;
    }

    @Override
    public void saveRegister(String userId) {

        User user = userService.getById(userId);
        boolean guest = false;
        if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName())) {
            guest = true;
        }
        if (guest) {
            return;
        }
        UserRecom userRecom = userRecomService.findByPartyId(userId);
        if (userRecom == null) {
            return;
        }
        List<UserRecom> parents = this.userRecomService.getParents(userId);
        int loop = 4;
        for (int i = 0; i < parents.size(); i++) {
            // 找到推荐人
            User party_parent = userService.getById(parents.get(i).getUserId());
            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.setUserId(parents.get(i).getUserId());
                userData_reco.setRecoNum(1);
                save(userData_reco);
                UserDataSum userDataSum = saveBySum(parents.get(i).getUserId());
                log.info(">>>> saveRegister前 推荐前人数为{}-> {}", userService.getById(userDataSum.getUserId()).getUserName(), userDataSum.getRecoNum());
                userDataSum.setRecoNum(userDataSum.getRecoNum() + 1);
                userDataSumService.updateById(userDataSum);
                log.info(">>>> saveRegister后 推荐前人数为{}-> {}", userService.getById(userDataSum.getUserId()).getUserName(), userDataSum.getRecoNum());

                loop--;
            }
//            if (Constants.SECURITY_ROLE_AGENT.equals(party_parent.getRoleName())) {
//                List<UserDataSum> userDataSums = userDataSumService.getByUserId(parents.get(i).getRecomUserId().toString());
//                UserDataSum userDataSum = new UserDataSum();
//                if (userDataSums.size() > 0) {
//                    userDataSum = userDataSums.get(0);
//                }
//                userDataSum.setRecoNum(userDataSum.getRecoNum() + 1);
//                userDataSumService.saveOrUpdate(userDataSum);
//            }
        }
    }

    /**
     * 根据partyId获取UserDataSum
     */
    public UserDataSum saveBySum(String partyId) {

        List list = userDataSumService.getByUserId(partyId);
        if (list.size() > 0) {
            return (UserDataSum) list.get(0);
        }
        UserDataSum userDataSum = new UserDataSum();
        userDataSum.setUserId(partyId);
        userDataSumService.save(userDataSum);
        return userDataSum;
    }

    @Override
    public Page userAll(Page page, Date startTime, Date endTime, List<String> userIds) {

        Page page1 = baseMapper.userAll(page, startTime, endTime,userIds);
        compute(page1.getRecords(), false);
        return page1;
    }

    @Override
    public Map sumAll(Date startTime, Date endTime, List<String> userIds) {

        Map map = baseMapper.sumAll(startTime, endTime,userIds);
        List<Map> maps = new ArrayList<>();
        maps.add(map);
        compute(maps, true);
        return maps.get(0);
    }

    /**
     * 统计的数据存在空时，不统计总额
     *
     * @param data
     * @return
     */
    private boolean dataExistNull(Map<String, Object> data) {

        if (null == data.get("recharge_withdrawal_fee")) return false;
        if (null == data.get("order_income")) return false;
        if (null == data.get("fee")) return false;
        if (null == data.get("finance_income")) return false;
        if (null == data.get("exchange_fee")) return false;
        if (null == data.get("exchange_income")) return false;
        if (null == data.get("furtures_fee")) return false;
        if (null == data.get("furtures_income")) return false;
        return true;
    }

    private void compute(List<Map<String, Object>> datas) {
        DecimalFormat df4 = new DecimalFormat("#.####");
        // 向下取整
        df4.setRoundingMode(RoundingMode.FLOOR);
        if (org.apache.commons.collections.CollectionUtils.isEmpty(datas)) {
            return;
        }
        Double totle_income = 0d;
        Double totle_fee = 0d;
        Double business_profit = 0d;//交易盈亏
        Double fin_miner_amount = 0d;//理财 矿机 交易额
        Double fin_miner_income = 0d;//理财 矿机 收益
        for (Map<String, Object> data : datas) {
            totle_income = 0d;
            totle_fee = 0d;
            business_profit = 0d;
            fin_miner_amount = 0d;
            fin_miner_income = 0d;
            if (null == data.get("reco_num")) {
                data.put("reco_num", 0);
            }
//			if(null!=data.get("rolename")) {
//				data.put("rolename", Constants.ROLE_MAP.get(data.get("rolename").toString()));
//			}
            if (null != data.get("order_income"))
                data.put("order_income", df4.format(Arith.sub(0, new Double(data.get("order_income").toString()))));//订单收益负数
            if (null != data.get("finance_income"))
                data.put("finance_income", df4.format(Arith.sub(0, new Double(data.get("finance_income").toString()))));//理财收益负数
            if (null != data.get("exchange_income"))
//			data.put("exchange_income", Arith.sub(0, new Double(data.get("exchange_income").toString())));//币币收益负数
                data.put("exchange_income", 0);//币币收益负数
            if (null != data.get("furtures_income"))
                data.put("furtures_income", df4.format(Arith.sub(0, new Double(data.get("furtures_income").toString()))));//交割收益负数
            if (null != data.get("miner_income"))
                data.put("miner_income", df4.format(Arith.sub(0, new Double(data.get("miner_income").toString()))));// 矿机收益负数
            if (null != data.get("exchange_lever_order_income"))
                data.put("exchange_lever_order_income",  df4.format(Arith.sub(0, new Double(data.get("exchange_lever_order_income").toString()))));// 币币收益负数
            if (!dataExistNull(data)) continue;
            totle_income = Arith.add(totle_income, new Double(data.get("recharge_withdrawal_fee").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("order_income").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("fee").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("finance_income").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("exchange_fee").toString()));
            totle_income = Arith.add(totle_income, new Double(0));
//			totle_income = Arith.add(totle_income,new Double(data.get("exchange_income").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("furtures_fee").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("furtures_income").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("miner_income").toString()));
            data.put("totle_income",  df4.format(totle_income));
            totle_fee = Arith.add(totle_fee, new Double(data.get("recharge_withdrawal_fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("furtures_fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_lever_fee").toString()));
            data.put("totle_fee",  df4.format(totle_fee));
            business_profit = Arith.add(business_profit, new Double(data.get("order_income").toString()));
            business_profit = Arith.add(business_profit, new Double(data.get("exchange_income").toString()));
            business_profit = Arith.add(business_profit, new Double(data.get("furtures_income").toString()));
            business_profit = Arith.add(business_profit, new Double(data.get("exchange_lever_order_income").toString()));
            data.put("business_profit",  df4.format(business_profit));
            fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("finance_amount").toString()));
            fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("miner_amount").toString()));
            data.put("fin_miner_amount", df4.format(fin_miner_amount));
            fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("finance_income").toString()));
            fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("miner_income").toString()));
            data.put("fin_miner_income", df4.format(fin_miner_income));
        }
    }

    private Map<String, BigDecimal> buildData(List<UserData> list) {
        Map<String, BigDecimal> map = new HashMap<>();
        BigDecimal totalIncome = BigDecimal.ZERO;
        BigDecimal todayIncome = BigDecimal.ZERO;
        String today = DateUtils.format(new Date(), DateUtils.DF_yyyyMMdd);
        for (UserData data : list) {
            totalIncome = totalIncome
                    // 充提手续费
                    .add(BigDecimal.valueOf(data.getRechargeWithdrawalFee()))
                    // 永续合约收益
                    .add(BigDecimal.valueOf(data.getOrderIncome()))
                    // 永续合约手续费
                    .add(BigDecimal.valueOf(data.getFee()))
                    // 理财收益
                    .add(BigDecimal.valueOf(data.getFinanceIncome()))
                    // 币币手续费
                    .add(BigDecimal.valueOf(data.getExchangeFee()))
                    // 交割合约手续费
                    .add(BigDecimal.valueOf(data.getFurturesFee()))
                    // 交割合约收益
                    .add(BigDecimal.valueOf(data.getFurturesIncome()))
                    // 矿机收益
                    .add(BigDecimal.valueOf(data.getMinerIncome()));
            if (today.equals(DateUtils.format(data.getCreateTime(), DateUtils.DF_yyyyMMdd))) {
                todayIncome = todayIncome
                        // 充提手续费
                        .add(BigDecimal.valueOf(data.getRechargeWithdrawalFee()))
                        // 永续合约收益
                        .add(BigDecimal.valueOf(data.getOrderIncome()))
                        // 永续合约手续费
                        .add(BigDecimal.valueOf(data.getFee()))
                        // 理财收益
                        .add(BigDecimal.valueOf(data.getFinanceIncome()))
                        // 币币手续费
                        .add(BigDecimal.valueOf(data.getExchangeFee()))
                        // 交割合约手续费
                        .add(BigDecimal.valueOf(data.getFurturesFee()))
                        // 交割合约收益
                        .add(BigDecimal.valueOf(data.getFurturesIncome()))
                        // 矿机收益
                        .add(BigDecimal.valueOf(data.getMinerIncome()));
            }
        }
        map.put("totalIncome", totalIncome.setScale(2, RoundingMode.HALF_DOWN));
        map.put("todayIncome", todayIncome.setScale(2, RoundingMode.HALF_DOWN));
        return map;
    }

    /**
     * 计算 统计时
     *
     * @param datas
     * @param isSum
     */
    private void compute(List<Map> datas, boolean isSum) {

        if (org.apache.commons.collections.CollectionUtils.isEmpty(datas)) return;
        Double totle_income = 0d;
        Double totle_fee = 0d;
        Double business_profit = 0d;//交易盈亏
        Double fin_miner_amount = 0d;//理财 矿机 交易额
        Double fin_miner_income = 0d;//理财 矿机 收益
        for (Map<String, Object> data : datas) {
            totle_income = 0d;
            totle_fee = 0d;
            business_profit = 0d;
            fin_miner_amount = 0d;
            fin_miner_income = 0d;
            if (null != data.get("order_income"))
                data.put("order_income", new BigDecimal(Arith.sub(0, new Double(data.get("order_income").toString()))) .setScale(8, RoundingMode.FLOOR).toPlainString());//订单收益负数
            if (null != data.get("finance_income"))
                data.put("finance_income",new BigDecimal( Arith.sub(0, new Double(data.get("finance_income").toString()))) .setScale(8, RoundingMode.FLOOR).toPlainString());//理财收益负数
            if (null != data.get("exchange_income"))
//			data.put("exchange_income", Arith.sub(0, new Double(data.get("exchange_income").toString())));//币币收益负数
                data.put("exchange_income", 0);//币币收益负数
            if (null != data.get("furtures_income"))
                data.put("furtures_income", new BigDecimal(Arith.sub(0, new Double(data.get("furtures_income").toString()))) .setScale(8, RoundingMode.FLOOR).toPlainString());//交割收益负数
            if (null != data.get("miner_income"))
                data.put("miner_income", new BigDecimal(Arith.sub(0, new Double(data.get("miner_income").toString()))).setScale(8, RoundingMode.FLOOR).toPlainString());// 矿机收益负数
            if (null != data.get("exchange_lever_order_income"))
                data.put("exchange_lever_order_income",new BigDecimal( Arith.sub(0, new Double(data.get("exchange_lever_order_income").toString()))).setScale(8, RoundingMode.FLOOR).toPlainString());// 币币收益负数
            if (!dataExistNull(data)) continue;
            totle_income = Arith.add(totle_income, new Double(data.get("recharge_withdrawal_fee").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("order_income").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("fee").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("finance_income").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("exchange_fee").toString()));
            totle_income = Arith.add(totle_income, new Double(0));
//			totle_income = Arith.add(totle_income,new Double(data.get("exchange_income").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("furtures_fee").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("furtures_income").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("miner_income").toString()));
            totle_income = Arith.add(totle_income, new Double(data.get("exchange_lever_order_income").toString()));
            data.put("totle_income", new BigDecimal(totle_income).setScale(8, RoundingMode.FLOOR).toPlainString() );
            totle_fee = Arith.add(totle_fee, new Double(data.get("recharge_withdrawal_fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("furtures_fee").toString()));
            totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_lever_fee").toString()));
            data.put("totle_fee",   new BigDecimal(totle_fee).setScale(8, RoundingMode.FLOOR).toPlainString());
            business_profit = Arith.add(business_profit, new Double(data.get("order_income").toString()));
            business_profit = Arith.add(business_profit, new Double(data.get("exchange_income").toString()));
            business_profit = Arith.add(business_profit, new Double(data.get("furtures_income").toString()));
            business_profit = Arith.add(business_profit, new Double(data.get("exchange_lever_order_income").toString()));
            data.put("business_profit", new BigDecimal(business_profit).setScale(8, RoundingMode.FLOOR).toPlainString());
            fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("finance_amount").toString()));
            fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("miner_amount").toString()));
            data.put("fin_miner_amount", new BigDecimal(fin_miner_amount).setScale(8, RoundingMode.FLOOR).toPlainString());
            fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("finance_income").toString()));
            fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("miner_income").toString()));
            data.put("fin_miner_income",new BigDecimal( fin_miner_income).setScale(8, RoundingMode.FLOOR).toPlainString());
            data.put("recharge_btc", new BigDecimal(data.get("recharge_btc").toString()).setScale(8, RoundingMode.FLOOR).toPlainString());//订单收益负数
        }
    }

    @Override
    public void saveUserData(UserData entity) {
        try {
            UserData db = findBydate(entity.getUserId(), entity.getCreateTime());
            if (db != null) {
                db.setRechargeDapp(Arith.add(db.getRechargeDapp(), entity.getRechargeDapp()));
                db.setWithdrawDapp(Arith.add(db.getWithdrawDapp(), entity.getWithdrawDapp()));
                db.setRecharge(Arith.add(db.getRecharge(), entity.getRecharge()));
                db.setRechargeEth(Arith.add(db.getRechargeEth(), entity.getRechargeEth()));
                db.setRechargeUsdt(Arith.add(db.getRechargeUsdt(), entity.getRechargeUsdt()));
                db.setRechargeBtc(Arith.add(db.getRechargeBtc(), entity.getRechargeBtc()));
                db.setRechargeHt(Arith.add(db.getRechargeHt(), entity.getRechargeHt()));
                db.setRechargeLtc(Arith.add(db.getRechargeLtc(), entity.getRechargeLtc()));
                // 充值返佣
                db.setRechargeRecom(Arith.add(db.getRechargeRecom(), entity.getRechargeRecom()));
                db.setWithdrawAll(Arith.add(db.getWithdrawAll(), entity.getWithdrawAll()));
                db.setWithdraw(Arith.add(db.getWithdraw(), entity.getWithdraw()));
                db.setWithdrawEth(Arith.add(db.getWithdrawEth(), entity.getWithdrawEth()));
                db.setWithdrawBtc(Arith.add(db.getWithdrawBtc(), entity.getWithdrawBtc()));
                db.setAmount(Arith.add(db.getAmount(), entity.getAmount()));
                db.setFee(Arith.add(db.getFee(), entity.getFee()));
                db.setOrderIncome(Arith.add(db.getOrderIncome(), entity.getOrderIncome()));
                db.setFinanceAmount(Arith.add(db.getFinanceAmount(), entity.getFinanceAmount()));
                db.setFinanceIncome(Arith.add(db.getFinanceIncome(), entity.getFinanceIncome()));
                db.setExchangeAmount(Arith.add(db.getExchangeAmount(), entity.getExchangeAmount()));
                db.setExchangeFee(Arith.add(db.getExchangeFee(), entity.getExchangeFee()));
                db.setExchangeIncome(Arith.add(db.getExchangeIncome(), entity.getExchangeIncome()));
                db.setCoinIncome(Arith.add(db.getCoinIncome(), entity.getCoinIncome()));
                db.setFurturesAmount(Arith.add(db.getFurturesAmount(), entity.getFurturesAmount()));
                db.setFurturesFee(Arith.add(db.getFurturesFee(), entity.getFurturesFee()));
                db.setFurturesIncome(Arith.add(db.getFurturesIncome(), entity.getFurturesIncome()));
                db.setRecoNum(db.getRecoNum() + entity.getRecoNum());
                db.setRechargeWithdrawalFee(
                        Arith.add(db.getRechargeWithdrawalFee(), entity.getRechargeWithdrawalFee()));
                db.setGiftMoney(Arith.add(db.getGiftMoney(), entity.getGiftMoney()));
                db.setMinerAmount(Arith.add(db.getMinerAmount(), entity.getMinerAmount()));
                db.setMinerIncome(Arith.add(db.getMinerIncome(), entity.getMinerIncome()));
                // 质押2.0
                db.setGalaxyAmount(Arith.add(db.getGalaxyAmount(), entity.getGalaxyAmount()));
                db.setGalaxyIncome(Arith.add(db.getGalaxyIncome(), entity.getGalaxyIncome()));
                db.setThirdRechargeAmount(Arith.add(db.getThirdRechargeAmount(), entity.getThirdRechargeAmount()));
                db.setHoldingMoney(Arith.add(db.getHoldingMoney(), entity.getHoldingMoney()));
                db.setTransferInMoney(Arith.add(db.getTransferInMoney(), entity.getTransferInMoney()));
                db.setTransferOutMoney(Arith.add(db.getTransferOutMoney(), entity.getTransferOutMoney()));
                db.setExchangeLeverAmount(Arith.add(db.getExchangeLeverAmount(), entity.getExchangeLeverAmount()));
                db.setExchangeLeverFee(Arith.add(db.getExchangeLeverFee(), entity.getExchangeLeverFee()));
                db.setExchangeLeverOrderIncome(Arith.add(db.getExchangeLeverOrderIncome(), entity.getExchangeLeverOrderIncome()));
                updateById(db);
                setCache(db);

//                log.info("saveUserData 00 => "+ JSONObject.toJSONString(db));
            } else {
                save(entity);
                setCache(entity);


//                log.info("saveUserData 00 => "+ JSONObject.toJSONString(entity));
            }
        } catch (Exception e) {
            log.error("saveUserData 异常", e);
        }
    }

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

    public void put(String userId, Map<String, UserData> map_party) {
        redisTemplate.opsForValue().set(REDIS_KEY + userId, map_party);
    }

    @Override
    public List<Map<String, UserData>> findByPartyIds(List<String> children) {
        List<UserData> users = list(Wrappers.<UserData>query().lambda().in(UserData::getUserId, children));
        List<Map<String, UserData>> mapList = new ArrayList<>();
        for (UserData userData : users) {
            Map<String, UserData> map = new HashMap<>();
            map.put(userData.getUserId(), userData);
            mapList.add(map);
        }
        return mapList;
    }




    /**
     * 资金盘定制化需求，等盘口下架可以删除
     */

    @Override
    public List<Map<String, Object>> getChildrenLevelPagedForGalaxy(int pageNo, int pageSize, String partyId, Integer levelNum) {

        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 (levelNum == 4) {
//			level = children.getLever4();
//		}
        if (level == null || level.isEmpty()) {
            return list;
        }
        Page<User> page = new Page(pageNo, pageSize);
        userService.page(page, Wrappers.<User>query().lambda().in(User::getUserId, level));
        for (int i = 0; i < page.getRecords().size(); i++) {
            Map<String, Object> element_map = new HashMap<String, Object>();
            User user = page.getRecords().get(i);
            element_map.put("username", user.getUserName());
            element_map.put("partyId", user.getUserId());


            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();
            }
//			if (levelNum == 4) {
//				level_children = childrenLever.getLever4();
//			}
            element_map.put("reco_sum", level_children.size());
            // list里面的总业绩
            Map<String, UserData> map = cacheByPartyId(childrenPartyId);
            double sum = 0;
            double sumRechargeRecom = 0;
            if (null != map && map.size() > 0) {
                for (UserData userData : map.values()) {
                    sum += userData.getRecharge();
                    sumRechargeRecom += userData.getRechargeRecom();
                }
            }
            element_map.put("recharge_sum", sum);
            element_map.put("recharge_recom",sumRechargeRecom);
            list.add(element_map);
        }
        return list;
    }

    @Override
    public ChildrenLever cacheChildrenLever4(String partyId) {

        ChildrenLever childrenLever = new ChildrenLever();
        /**
         * lever1
         */
        List<UserRecom> userrecom_lever1 = userRecomService.findRecoms(partyId);
        for (int i = 0; i < userrecom_lever1.size(); i++) {
            childrenLever.getLever1().add(userrecom_lever1.get(i).getRecomUserId().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++) {
                childrenLever.getLever2().add(userrecom_lever2.get(j).getRecomUserId().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).getRecomUserId().toString());
            }
        }
//		/**
//		 * lever4
//		 */
//		if (childrenLever.getLever3().size() == 0) {
//			return childrenLever;
//		}
//		for (int i = 0; i < childrenLever.getLever3().size(); i++) {
//			List<UserRecom> userrecom_lever4 = userRecomService.findRecoms(childrenLever.getLever3().get(i));
//			for (int j = 0; j < userrecom_lever4.size(); j++) {
//				childrenLever.getLever4().add(userrecom_lever4.get(j).getPartyId().toString());
//			}
//
//		}
        return childrenLever;
    }

    @Override
    public void saveWithdrawHandle(String partyId, double amount, double amount_fee, String symbol) {

        System.out.println("saveWithdrawHandle -> partyId:" + partyId);
        User user = userService.getById(partyId);
        boolean guest = false;
        if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName())) {
            guest = true;
        }
        if (guest) {
            return;
        }
        UserData userData = new UserData();
        userData.setRolename(user.getRoleName());
        userData.setCreateTime(new Date());
        userData.setUserId(partyId);
        if (StringUtils.isEmpty(symbol) || "usdt".equals(symbol)) {
            userData.setWithdraw(amount);
            userData.setRechargeWithdrawalFee(amount_fee);
            userData.setWithdrawAll(amount);
        } else {
            // TODO: 2023/4/21  = this.dataService.realtime(symbol);
            List<Realtime> realtime_list = dataService.realtime(symbol);
            Realtime realtime = null;
            if (realtime_list.size() > 0) {
                realtime = realtime_list.get(0);
            } else {
                throw new YamiShopBindException("系统错误，请稍后重试");
            }
            if ("btc".equals(symbol)) {
                userData.setRechargeWithdrawalFee(Arith.mul(amount_fee, realtime.getClose()));
                userData.setWithdrawBtc(amount);
                userData.setWithdrawAll(Arith.mul(amount, realtime.getClose()));
            }
            if ("eth".equals(symbol)) {
                userData.setRechargeWithdrawalFee(Arith.mul(amount_fee, realtime.getClose()));
                userData.setWithdrawEth(amount);
                userData.setWithdrawAll(Arith.mul(amount, realtime.getClose()));
            }
        }
        saveUserData(userData);
    }

    @Override
    public void saveRechargeHandle(String partyId, double amount, String symbol) {

        User party = userService.getById(partyId);
        boolean guest = false;
        if (Constants.SECURITY_ROLE_GUEST.equals(party.getRoleName())) {
            guest = true;
        }
        if (guest) {
            return;
        }
        UserData userData = new UserData();
        userData.setRolename(party.getRoleName());
        userData.setCreateTime(new Date());
        userData.setUserId(partyId);
        if ("usdt".equals(symbol)) {
            userData.setRecharge(amount);
            userData.setRechargeUsdt(amount);
        } else {
            List<Realtime> realtime_list = this.dataService.realtime(symbol);
            Realtime realtime = null;
            if (realtime_list.size() > 0) {
                realtime = realtime_list.get(0);
            } else {
                log.info("symbol :{} 获取失败!",symbol);
                throw new YamiShopBindException("系统错误，请稍后重试");
            }
            if ("btc".equals(symbol)) {
                userData.setRecharge(Arith.mul(amount, realtime.getClose()));
                userData.setRechargeBtc(amount);
            }
            if ("eth".equals(symbol)) {
                userData.setRecharge(Arith.mul(amount, realtime.getClose()));
                userData.setRechargeEth(amount);
            }
            if ("ht".equals(symbol)) {
                userData.setRecharge(Arith.mul(amount, realtime.getClose()));
                userData.setRechargeHt(amount);
            }
            if ("ltc".equals(symbol)) {
                userData.setRecharge(Arith.mul(amount, realtime.getClose()));
                userData.setRechargeLtc(amount);
            }

            if ("usdc".equals(symbol)) {
                userData.setRecharge(Arith.mul(amount, realtime.getClose()));
                userData.setRechargeUsdc(amount);
            }
        }
        saveUserData(userData);
    }

    @Override
    public void saveClose(ContractOrder order) {
        ApplicationUtil.getBean(ContractOrderService.class).wrapProfit(order);

        User user = userService.getById(order.getPartyId());
        boolean guest = false;
        if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName()) || Constants.SECURITY_ROLE_TEST.equals(user.getRoleName())) {
            guest = true;
        }
        if (guest) {
            return;
        }
        UserData userData = new UserData();
        userData.setRolename(user.getRoleName());
        userData.setCreateTime(new Date());
        userData.setUserId(order.getPartyId());
        userData.setAmount(order.getDepositOpen().doubleValue());
        if (order.getAmountClose() == null) {
            order.setAmountClose(BigDecimal.ZERO);
        }
        if (order.getAmountClose().compareTo(BigDecimal.ZERO) < 0) {
            order.setAmountClose(BigDecimal.ZERO);
        }
        userData.setFee(order.getFee().doubleValue());
        // 直接用profit保证一直
        userData.setOrderIncome(order.getProfit().doubleValue());
        Item bySymbol = itemService.findBySymbol(order.getSymbol());
        if(bySymbol != null){
            userData.setItemType(bySymbol.getType());
        }
        saveUserData(userData);

    }

    //基础反水
    @Transactional
    public void saveBackwaterBasicTrading(String userId,double exchangeAmount,double fee) {
        log.info(userId+"========>"+exchangeAmount+"======"+fee);

        if (fee==0){
            return;
        }
        Syspara syspara= sysparaService.find("backwater_basic_tradin");
        if (syspara==null){
            return;
        }
        boolean flag=  Boolean.valueOf(syspara.getSvalue());
        if (!flag){
            return;
        }
        long sumExchangeAmount =sumExchangeAmount(userId);
        double commission=0;
        //对于月交易量超过500000美元的用户，返还15%。
        if (sumExchangeAmount>500000){
            commission=fee*0.15;
        }
        //对于月交易量超过1000000美元的用户，返还20%
        else if (sumExchangeAmount>1000000){
            commission=fee*0.2;
        }
        else {//所有用户对每笔交易的手续费，返还10%作为返佣
            commission=fee*0.1;
        }
        if (commission>0){
            Wallet wallet =walletService.saveWalletByPartyId(userId);
            double   amountBefore = wallet.getMoney().doubleValue();
            walletService.update(wallet.getUserId(), commission);
            MoneyLog moneylog = new MoneyLog();
            moneylog.setCategory(Constants.WALLET_USDT);
            moneylog.setAmountBefore(new BigDecimal(amountBefore));
            moneylog.setAmount(new BigDecimal(commission));
            moneylog.setAmountAfter(new BigDecimal(Arith.add(amountBefore, commission)));
            moneylog.setLog("基础交易反水usdt"+commission);
            moneylog.setUserId(userId);
            moneylog.setWalletType("usdt");
            moneylog.setContentType(Constants.MONEYLOG_WAllET_EXCHANGE_COMMISSION);
            moneyLogService.save(moneylog);

            User user = userService.findByUserId(userId);
            UserData userData = new UserData();
            userData.setRolename(user.getRoleName());
            userData.setCreateTime(new Date());
            userData.setUserId(userId);
            saveUserData(userData);
        }
    }

    @Override
    public void saveSell(ExchangeApplyOrder order) {

        User user = userService.getById(order.getPartyId());
        boolean guest = false;
        if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName()) || Constants.SECURITY_ROLE_TEST.equals(user.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 YamiShopBindException("系统错误，请稍后重试");
        }
        UserData userData = new UserData();
        userData.setRolename(user.getRoleName());
        userData.setCreateTime(new Date());
        userData.setUserId(order.getPartyId());
        userData.setExchangeAmount(Arith.mul(realtime.getClose(), order.getVolume()));
        userData.setExchangeFee(Arith.mul(realtime.getClose(), order.getFee()));
        userData.setExchangeIncome(0);
        saveUserData(userData);
        // ICE 问盘口 未回复 暂时不上
        // saveBackwaterBasicTrading(order.getPartyId(), userData.getExchangeAmount(),userData.getExchangeFee());
    }





    @Override
    public void saveBuy(ExchangeApplyOrder order) {

        User user = userService.getById(order.getPartyId());
        boolean guest = false;
        if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName()) || Constants.SECURITY_ROLE_TEST.equals(user.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 YamiShopBindException("系统错误，请稍后重试");
        }
        UserData userData = new UserData();
        userData.setRolename(user.getRoleName());
        userData.setCreateTime(new Date());
        userData.setUserId(order.getPartyId());
        userData.setExchangeAmount(order.getVolume());
        userData.setExchangeFee(order.getFee());
        saveUserData(userData);
        // saveBackwaterBasicTrading(order.getPartyId(), userData.getExchangeAmount(),userData.getExchangeFee());
    }

    /**
     * 交割合约平仓
     */
    @Override
    public void saveFuturesClose(FuturesOrder order) {

        User user = userService.getById(order.getPartyId());
        String roleName = user.getRoleName();
        boolean guest = false;
        if (Constants.SECURITY_ROLE_GUEST.equals(roleName) || Constants.SECURITY_ROLE_TEST.equals(roleName)) {
            guest = true;
        }
        if (guest) {
            return;
        }
        User party = userService.getById(order.getPartyId());
        UserData userData = new UserData();
        userData.setRolename(party.getRoleName());
        userData.setCreateTime(new Date());
        userData.setUserId(order.getPartyId());
        userData.setFurturesAmount(order.getVolume());
        userData.setFurturesFee(order.getFee());
        userData.setFurturesIncome(order.getProfit());
        saveUserData(userData);
//		UserRecom userRecom = this.userRecomService.findByPartyId(order.getPartyId());
//		if (userRecom == null) {
//			return;
//		}
//		List<UserRecom> parents = this.userRecomService.getParents(userRecom.getPartyId());
//
//		for (int i = 0; i < parents.size(); i++) {
//			Party party_parent = partyService.cachePartyBy(parents.get(i).getReco_id());
//
//			if (Constants.SECURITY_ROLE_AGENT.equals(party_parent.getRolename())) {
//				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.setFurtures_amount(order.getVolume());
//				userData_reco.setFurtures_fee(order.getFee());
//				userData_reco.setFurtures_income(order.getProfit());
//				save(userData_reco);
//			}
    }

    /**
	 * 理财产品平仓
	 */
	@Override
    public void saveSellFinance(FinanceOrder order) {
        User user = this.secUserService.findUserByUserCode(order.getFinanceId());
//		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;
		}

		User party = userService.cacheUserBy(order.getPartyId().toString());
		UserData userData = new UserData();

		userData.setRolename(party.getRoleName());
		userData.setCreateTime(new Date());
        userData.setUserId(order.getPartyId().toString());
		userData.setFinanceAmount(order.getAmount());
		userData.setFinanceIncome(order.getProfit());
		save(userData);

//		UserRecom userRecom = this.userRecomService.findByPartyId(order.getPartyId());
//		if (userRecom == null) {
//			return;
//		}
//		List<UserRecom> parents = this.userRecomService.getParents(userRecom.getPartyId());
//
//		for (int i = 0; i < parents.size(); i++) {
//			Party party_parent = partyService.cachePartyBy(parents.get(i).getReco_id());
//
//			if (Constants.SECURITY_ROLE_AGENT.equals(party_parent.getRolename())) {
//				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.setFinance_amount(order.getAmount());
//				userData_reco.setFinance_income(order.getProfit());
//				save(userData_reco);
//			}
//		}
	}

    /**
     * 矿机买入
     */
    @Override
    public void saveMinerBuy(MinerOrder order) {

        User user = this.secUserService.cacheUserBy(order.getPartyId().toString());
//        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;
        }

        UserData userData = new UserData();
        userData.setRolename(user.getRoleName());
        userData.setCreateTime(new Date());
        userData.setUserId(order.getPartyId().toString());
        userData.setMinerAmount(order.getAmount());
        save(userData);
    }

    /**
     * 矿机赎回
     */
    @Override
    public void saveMinerClose(MinerOrder order) {
        User user = this.secUserService.cacheUserBy(order.getPartyId().toString());
//        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(user.getRoleName());
        userData.setCreateTime(new Date());
        userData.setUserId(order.getPartyId().toString());
        userData.setMinerAmount(Arith.sub(0, order.getAmount()));
        save(userData);
    }

    /**
     * 矿机利息
     *
     * @param partyId 获利人
     * @param profit  利息
     */
    @Override
    public void saveMinerProfit(String partyId, double profit) {
        User user = this.secUserService.cacheUserBy(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(user.getRoleName());
        userData.setCreateTime(new Date());
        userData.setUserId(partyId);
        userData.setMinerIncome(profit);
        save(userData);
    }

    @Override
    public List<UserDataWithdrawLimitDto> withdrawLimit(Date startTime, Date endTime, List<String> userIds) {
        return baseMapper.withdrawLimit(startTime, endTime, userIds);
    }

    @Override
    public long sumExchangeAmount(String userId) {
        return baseMapper.sumExchangeAmount(userId);
    }

    @Override
    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.getUserId()), "");
                        }
                    } else {
                        rechangeAmount += userData.getRecharge();
                        peoples.put(String.valueOf(userData.getUserId()), "");
                    }
                }
            }
        }

        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.getUserId()), "");
                        }
                    } else {
                        rechangeAmount += userData.getRecharge();
                        peoples.put(String.valueOf(userData.getUserId()), "");
                    }
                }
            }
        }

        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.getUserId()), "");
                        }
                    } else {
                        rechangeAmount += userData.getRecharge();
                        peoples.put(String.valueOf(userData.getUserId()), "");
                    }
                }
            }
        }

        data.put("peopleNum", String.valueOf(peoples.size()));
        data.put("rechangeAmount", String.valueOf(rechangeAmount));
        return data;
    }
}