package com.xzx.gc.user.service;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.StrUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.constant.PayEnum;
import com.xzx.gc.common.constant.UserEnum;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.entity.*;
import com.xzx.gc.model.pay.PayInfoReq;
import com.xzx.gc.model.pay.PayInfoVo;
import com.xzx.gc.model.user.MoneyDetailVo;
import com.xzx.gc.user.dto.RecycleStatistic;
import com.xzx.gc.user.mapper.PayInfoMapper;
import com.xzx.gc.user.mapper.RedPaperMapper;
import com.xzx.gc.user.mapper.UserShareInfoMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;

@Service
@Transactional
public class UserStatService{
    @Autowired
    private PayInfoMapper payInfoMapper;

    @Autowired
    private RedPaperMapper redPaperMapper;

    @Autowired
    private UserShareInfoMapper userShareInfoMapper;


    @Autowired
    private PayInfoService payInfoService;

    @Autowired
    private BusinessUtil businessUtil;

    @Autowired
    private OrderService orderService;

    @Autowired
    private AccountLogService accountLogService;

    @Autowired
    private HttpServletRequest request;

    @Autowired
    private AccountScoreLogService accountScoreLogService;

    
    public MoneyDetailVo queryMoneyDetail(PayInfoReq payInfoReq) {
        MoneyDetailVo moneyDetail = new MoneyDetailVo();

        Map map = new HashMap();
        //查询回收次数及金额
        map.put("createUserId", payInfoReq.getCreateUserId());
        map.put("payType", PayEnum.环保金收入.getValue());
        List<MoneyDetailVo> recycleList = payInfoMapper.queryUserMoneyStatInfo(map);
        map.put("payType", PayEnum.现金收入.getValue());
        List<MoneyDetailVo> recycleListMoney = payInfoMapper.queryUserMoneyStatInfo(map);
        String recycleCount=null;
        String recycleSumMoney=null;

        //环保金收入
        if (recycleList != null && recycleList.size() > 0) {
            recycleCount=recycleList.get(0).getSumCount()==null?"0":recycleList.get(0).getSumCount();
            recycleSumMoney=recycleList.get(0).getSumMoney()==null?"0":recycleList.get(0).getSumMoney();
        }

        //现金收入
        if(!CollectionUtils.isEmpty(recycleListMoney)){
            if(recycleCount==null){
                recycleCount="0";
            }else{
                String s = recycleListMoney.get(0).getSumCount() == null ? "0" : recycleListMoney.get(0).getSumCount();
                recycleCount=new BigDecimal(recycleCount).add(new BigDecimal(s)).toString();
            }

            if(recycleSumMoney==null){
                recycleSumMoney="0";
            }else{
                String s = recycleListMoney.get(0).getSumMoney() == null ? "0" : recycleListMoney.get(0).getSumMoney();
                recycleSumMoney=new BigDecimal(recycleSumMoney).add(new BigDecimal(s)).toString();
            }
        }

        moneyDetail.setRecycleCount(recycleCount);
        recycleSumMoney = recycleSumMoney == null || "".equals( recycleSumMoney )?"0":recycleSumMoney;
        moneyDetail.setRecycleSumMoney(businessUtil.changeMoney(recycleSumMoney));
        //提现累计金额
        map.put("payType", "4");
        //是否提现成功
        map.put("txFlag","1");
        List<MoneyDetailVo> withdrawList = payInfoMapper.queryUserMoneyStatInfo(map);
        if (withdrawList != null && withdrawList.size() > 0) {
            moneyDetail.setSumWithdrawCount(withdrawList.get(0).getSumCount()==null?"0":withdrawList.get(0).getSumCount());
            moneyDetail.setSumWithdrawMoney(businessUtil.changeMoney(withdrawList.get(0).getSumMoney()));
        }

        //邀请好友次数及赚取金额
        UserShareInfo userShareInfo=new UserShareInfo();
        userShareInfo.setMobilePhone(payInfoReq.getMobilePhone());
        List<UserShareInfo> select1 = userShareInfoMapper.select(userShareInfo);
        if(CollUtil.isNotEmpty(select1)){
            moneyDetail.setInviteCount(Convert.toStr(select1.size()));
            BigDecimal money=Constants.MONEY_INIT;
            for (UserShareInfo shareInfo : select1) {
                String rewardMoney = shareInfo.getRewardMoney();
                if(StrUtil.isBlank(rewardMoney)){
                    rewardMoney="0";
                }
                money=NumberUtil.add(money,Convert.toBigDecimal(rewardMoney));
            }
            moneyDetail.setInviteMoney(businessUtil.changeMoney(Convert.toStr(money)));
        }else {
            moneyDetail.setInviteCount("0");
            moneyDetail.setInviteMoney(Convert.toStr(Constants.MONEY_INIT));
        }

        //新增加的payType需要在配置表的PAY_TYPE中添加
        PageHelper.startPage(payInfoReq.getPageNo(),payInfoReq.getPageSize());
        List<PayInfoVo> payInfoList=payInfoMapper.queryUserPayAll(payInfoReq);



        //按创建时间降序
        if(CollUtil.isNotEmpty(payInfoList)) {
            payInfoList= payInfoList.stream().sorted(Comparator.comparing(PayInfoVo::getCreateTime).reversed()).collect(Collectors.toList());

            //设置金额正负
            for (PayInfoVo payInfoVo : payInfoList) {
                String money = payInfoVo.getMoney();
                money = businessUtil.changeMoney(money);
                String payType = payInfoVo.getPayType();
                if (PayEnum.环保金支出.getValue().equals(payType) || PayEnum.提现.getValue().equals(payType) || PayEnum.现金支出.getValue().equals(payType)) {
                    payInfoVo.setMoney("-" + money);
                } else if (businessUtil.isApp(request.getHeader("clientType")) && PayEnum.按重量返利.getValue().equals(payType)) {
                    payInfoVo.setMoney("-" + money);
                } else if (!businessUtil.isApp(request.getHeader("clientType")) && PayEnum.按重量返利.getValue().equals(payType)) {
                    payInfoVo.setMoney("+" + money);
                }  else if (businessUtil.isApp(request.getHeader("clientType")) && PayEnum.订单投诉.getValue().equals(payType)) {
                    payInfoVo.setMoney("-" + money);
                }  else if (!businessUtil.isApp(request.getHeader("clientType")) && PayEnum.订单投诉.getValue().equals(payType)) {
                    payInfoVo.setMoney("+" + money);
                } else if (PayEnum.充值.getValue().equals(payType) || PayEnum.环保金收入.getValue().equals(payType) || PayEnum.现金收入.getValue().equals(payType)) {
                    payInfoVo.setMoney("+" + money);
                } else {
                    payInfoVo.setMoney("+" + money);
                }

            }

            //获取每条环保金记录的变动后的余额
            for (PayInfoVo payInfoVo : payInfoList) {
                String payOrderId = payInfoVo.getPayOrderId();
                String payType = payInfoVo.getPayType();
                String createUserId = payInfoVo.getCreateUserId();
                if(PayEnum.积分收入.getValue().equals(payType)){
                    AccountScoreLog byPayIdAndUserId = accountScoreLogService.findByPayIdAndUserId(payOrderId, createUserId);
                    if(byPayIdAndUserId!=null){
                        payInfoVo.setCollectScore(businessUtil.changeMoney(byPayIdAndUserId.getNewScore()));
                    }else {
                        payInfoVo.setCollectScore(Constants.MONEY_INIT.toString());
                    }
                }else {
                    AccountLog byUserIdAndOrderId = accountLogService.findByUserIdAndOrderId(createUserId, payOrderId);
                    if (byUserIdAndOrderId != null) {
                        payInfoVo.setBalance(businessUtil.changeMoney(byUserIdAndOrderId.getNewMoney()));
                        payInfoVo.setOverdraftLimit(businessUtil.changeMoney(byUserIdAndOrderId.getNewLimit()));
                        payInfoVo.setFixedLimit(businessUtil.changeMoney(byUserIdAndOrderId.getNewFixedLimit()));
                    } else {
                        payInfoVo.setBalance(Constants.MONEY_INIT.toString());
                        payInfoVo.setOverdraftLimit(Constants.MONEY_INIT.toString());
                        payInfoVo.setFixedLimit(Constants.MONEY_INIT.toString());
                    }
                }
            }

        }
        PageInfo<PayInfoVo> pageInfo=new PageInfo<>(payInfoList);
        moneyDetail.setPayInfoList(pageInfo);


        //领取红包次数及金额
        RedPaper redPaper=new RedPaper();
        redPaper.setReceiveUserId(payInfoReq.getCreateUserId());
        redPaper.setReceiveFlag(Convert.toShort(UserEnum.红包已领取.getValue()));
        List<RedPaper> select = redPaperMapper.select(redPaper);
        if(CollUtil.isNotEmpty(select)){
            moneyDetail.setRedpaperCount(select.size());
            double sum = select.stream().mapToDouble(x -> Convert.toDouble(x.getMoney(),Convert.toDouble(Constants.MONEY_INIT))).sum();
            moneyDetail.setRedpaperMoney(businessUtil.changeMoney(Convert.toBigDecimal(sum)));
        }else{
            moneyDetail.setRedpaperCount(0);
            moneyDetail.setRedpaperMoney(Convert.toStr(Constants.MONEY_INIT));
        }

        //返利次数及金额
        String[] payTypes=new String[]{PayEnum.分享返利.getValue(),PayEnum.阶梯返利.getValue(),PayEnum.红包.getValue(),PayEnum.按重量返利.getValue()};
        List<PayInfo> platformCapitalInfo1 = payInfoService.findByUserAndTypes(payInfoReq.getCreateUserId(), Arrays.asList(payTypes));
        if(CollUtil.isNotEmpty(platformCapitalInfo1)){
            moneyDetail.setRebateCount(platformCapitalInfo1.size());
            double sum = platformCapitalInfo1.stream().mapToDouble(x -> Convert.toDouble(x.getMoney(), Convert.toDouble(Constants.MONEY_INIT))).sum();
            moneyDetail.setRebateMoney(Convert.toBigDecimal(businessUtil.changeMoney(Convert.toStr(Convert.toBigDecimal(sum)))));
        }else{
            moneyDetail.setRebateCount(0);
            moneyDetail.setRebateMoney(Constants.MONEY_INIT);
        }

        //回收员重量返利支出总金额
        List<PayInfo> byUserAndType = payInfoService.findByUserAndType(payInfoReq.getCreateUserId(), PayEnum.按重量返利.getValue());
        if(CollUtil.isNotEmpty(byUserAndType)){
            double sum = byUserAndType.stream().mapToDouble(x -> Convert.toDouble(x.getMoney(), Convert.toDouble(Constants.MONEY_INIT))).sum();
            moneyDetail.setWeightMul(businessUtil.changeMoney(Convert.toStr(sum)));
        }


        //回收的累计重量
        RecycleStatistic orderItemInfo=null;
        if(businessUtil.isApp(request.getHeader("clientType"))){
             orderItemInfo = orderService.findOrderItemInfo(payInfoReq.getCreateUserId(),2);
        }else {
            orderItemInfo = orderService.findOrderItemInfo(payInfoReq.getCreateUserId(),1);
        }

        if(orderItemInfo!=null) {
            moneyDetail.setRecycleWeight(businessUtil.changeWeight(orderItemInfo.getWeightAll()));
        }else {
            moneyDetail.setRecycleWeight(Constants.WEIGHT_INIT.toString());
        }
        return moneyDetail;

    }


}