package com.xzx.gc.order.service;

import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.NumberUtil;
import cn.hutool.json.JSONUtil;
import com.xzx.gc.common.constant.CommonEnum;
import com.xzx.gc.common.constant.OrderEnum;
import com.xzx.gc.common.constant.PayEnum;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.common.utils.IdUtils;
import com.xzx.gc.entity.AccountLog;
import com.xzx.gc.entity.PartnerAccountLog;
import com.xzx.gc.model.comon.account.AllAcountParamDto;
import com.xzx.gc.order.mapper.AccountLogMapper;
import com.xzx.gc.order.mapper.PayInfoMapper;
import com.xzx.gc.order.mapper.RedPaperMapper;
import com.xzx.gc.service.BaseAccountService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;

@Service
@Transactional
@Slf4j
public class WeightRebateService extends BaseAccountService {

    @Autowired
    private PartnerAccountService partnerAccountService;


    @Autowired
    private AccountService accountService;


    @Autowired
    private PartnerAccountLogService partnerAccountLogService;


    @Autowired
    private AccountLogService accountLogService;

    @Autowired
    private PayInfoMapper payInfoMapper;


    @Autowired
    private IdUtils idUtils;


    @Autowired
    private BusinessUtil businessUtil;



    @Override
    public Object account(AllAcountParamDto allAcountParamDto) {
        String now=DateUtil.now();

        //无返利
        if (allAcountParamDto.getOtherMoney().compareTo(BigDecimal.ZERO) == 0&&allAcountParamDto.getMoney().compareTo(BigDecimal.ZERO)==0) {
               return null;
        }

        log.debug("准备进行重量返利支出操作:{}",JSONUtil.toJsonPrettyStr(allAcountParamDto));
        //重量支出返利 回收员和合伙人扣钱，用户加钱  自助下单回收员需要帮合伙人垫付支出

        Map<String,Object>  payMap = new HashMap();
        //正常下单
        if(allAcountParamDto.getOrderType()==0) {
            /**
             * 回收员
             * otherMoney  回收员返利
             */
            if (allAcountParamDto.getOtherMoney().compareTo(BigDecimal.ZERO) > 0) {
                String otherPayOrderId = idUtils.generate("ZF", 0);
                payMap.put("payOrderId", otherPayOrderId);
                payMap.put("orderId", allAcountParamDto.getFlowNo());
                payMap.put("createUserId", allAcountParamDto.getOtherUserId());
                payMap.put("money", allAcountParamDto.getOtherMoney());
                payMap.put("accountId", allAcountParamDto.getOtherAccountId());
                payMap.put("payType", PayEnum.按重量返利.getValue());
                payMap.put("status", PayEnum.已支付.getValue());
                payMap.put("createTime", now);
                payInfoMapper.payInfoAdd(payMap);

                AccountLog accountLog = new AccountLog();
                accountLog.setAccountId(allAcountParamDto.getOtherAccountId());
                accountLog.setCreateUserId(allAcountParamDto.getOtherUserId());
                if (allAcountParamDto.getOtherMoneyType() == 1) {
                    accountLog.setOldLimit(Convert.toStr(allAcountParamDto.getOtherOldMoney()));
                    accountLog.setNewLimit(Convert.toStr(NumberUtil.sub(Convert.toBigDecimal(accountLog.getOldLimit()), allAcountParamDto.getOtherMoney())));
                } else if(allAcountParamDto.getOtherMoneyType()==2){
                    accountLog.setOldMoney(Convert.toStr(allAcountParamDto.getOtherOldMoney()));
                    accountLog.setNewMoney(Convert.toStr(NumberUtil.sub(Convert.toBigDecimal(accountLog.getOldMoney()), allAcountParamDto.getOtherMoney())));
                }
                accountLog.setChannelType(Convert.toShort(CommonEnum.重量返利支出.getValue()));
                accountLog.setOrderId(otherPayOrderId);
                accountLogService.add(accountLog);
            }


            /**
             * 用户
             * money 合伙人返利
             * otherMoney  回收员返利
             * oldmoney 用户增加了回收订单金额的金额
             */
            BigDecimal sub2 = NumberUtil.add(allAcountParamDto.getOtherMoney(), allAcountParamDto.getMoney());
            if (sub2.compareTo(BigDecimal.ZERO) > 0) {
                payMap.clear();
                String payOrderId = idUtils.generate("ZF", 0);
                payMap.put("payOrderId", payOrderId);
                payMap.put("orderId", allAcountParamDto.getFlowNo());
                payMap.put("createUserId", allAcountParamDto.getUserId());
                payMap.put("money", Convert.toStr(sub2));
                payMap.put("accountId", allAcountParamDto.getAccountId());
                payMap.put("payType", PayEnum.按重量返利.getValue());
                payMap.put("status", PayEnum.已支付.getValue());
                payMap.put("createTime", now);
                payInfoMapper.payInfoAdd(payMap);

                AccountLog accountLog = new AccountLog();
                accountLog.setAccountId(allAcountParamDto.getAccountId());
                accountLog.setCreateUserId(allAcountParamDto.getUserId());
                accountLog.setChannelType(Convert.toShort(CommonEnum.重量返利支出.getValue()));
                accountLog.setOldMoney(Convert.toStr(allAcountParamDto.getOldMoney()));
                accountLog.setNewMoney(Convert.toStr(NumberUtil.add(Convert.toBigDecimal(accountLog.getOldMoney()), sub2)));
                accountLog.setOrderId(payOrderId);
                accountLogService.add(accountLog);
            }
            //自助下单
        }else if(allAcountParamDto.getOrderType()==1) {

            /**
             * 回收员
             */
            if (allAcountParamDto.getOtherMoney().compareTo(BigDecimal.ZERO) > 0) {
                payMap.clear();
                String otherPayOrderId = idUtils.generate("ZF", 0);
                payMap.put("payOrderId", otherPayOrderId);
                payMap.put("orderId", allAcountParamDto.getFlowNo());
                payMap.put("createUserId", allAcountParamDto.getOtherUserId());
                payMap.put("money", allAcountParamDto.getOtherMoney());
                payMap.put("accountId", allAcountParamDto.getOtherAccountId());
                payMap.put("payType", PayEnum.按重量返利.getValue());
                payMap.put("status", PayEnum.已支付.getValue());
                payMap.put("createTime", now);
                payInfoMapper.payInfoAdd(payMap);
            }

            if (allAcountParamDto.getMoney().compareTo(BigDecimal.ZERO) > 0) {

                //发送环保金明细
                payMap.clear();
                String otherPayOrderId = idUtils.generate("ZF", 0);
                payMap.put("payOrderId", otherPayOrderId);
                payMap.put("orderId", allAcountParamDto.getFlowNo());
                payMap.put("createUserId", allAcountParamDto.getOtherUserId());
                payMap.put("money", Convert.toStr(allAcountParamDto.getMoney()));
                payMap.put("accountId", allAcountParamDto.getOtherAccountId());
                payMap.put("payType", PayEnum.垫付合伙人.getValue());
                payMap.put("status", PayEnum.已支付.getValue());
                payMap.put("createTime", now);
                payInfoMapper.payInfoAdd(payMap);

                //添加日志
                accountService.updateMoneyByUserId( allAcountParamDto.getOtherUserId(),allAcountParamDto.getMoney());
                AccountLog log = new AccountLog();
                log.setCreateTime(now);
                log.setAccountId(allAcountParamDto.getOtherAccountId());
                log.setCreateUserId(allAcountParamDto.getOtherUserId());
                log.setChannelType(Convert.toShort(CommonEnum.垫付合伙人.getValue()));
                log.setOldMoney(Convert.toStr(allAcountParamDto.getOtherOldMoney()));
                log.setNewMoney(Convert.toStr(NumberUtil.add(Convert.toBigDecimal(log.getOldMoney()), allAcountParamDto.getMoney())));
                log.setOrderId(otherPayOrderId);
                accountLogService.add(log);
            }
        }

        /**
         * 合伙人
         */
        if(allAcountParamDto.getMoney().compareTo(BigDecimal.ZERO) > 0) {
            PartnerAccountLog partnerAccountLog = new PartnerAccountLog();
            partnerAccountLog.setPartnerId(allAcountParamDto.getPartnerId());
            partnerAccountLog.setFlowNo(allAcountParamDto.getFlowNo());
            partnerAccountLog.setType(OrderEnum.重量返利支出.getValue());
            partnerAccountLog.setMoney("-" + businessUtil.changeMoney(allAcountParamDto.getMoney()));
            partnerAccountLog.setRuleId(allAcountParamDto.getRuleId());
            partnerAccountLogService.add(partnerAccountLog);
            //修改合伙人账户
            partnerAccountService.updateReduceMoneyByPartnerId(allAcountParamDto.getPartnerId(), allAcountParamDto.getMoney());
        }

        log.debug("重量返利支出操作已完成");
        return null;
    }
}