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.*;
import com.xzx.gc.common.exception.RestException;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.common.utils.IdUtils;
import com.xzx.gc.entity.AccountInfo;
import com.xzx.gc.entity.AccountLog;
import com.xzx.gc.entity.RedPaper;
import com.xzx.gc.entity.SysMessage;
import com.xzx.gc.model.comon.account.AllAcountParamDto;
import com.xzx.gc.order.mapper.*;
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 RedpaperRebateService extends BaseAccountService {

    @Autowired
    private RedPaperRuleService redPaperRuleService;
    @Autowired
    private AccountService accountService;
    @Autowired
    private BusinessUtil businessUtil;

    @Autowired
    private PayInfoMapper payInfoMapper;

    @Autowired
    private SysMessageMapper sysMessageMapper;

    @Autowired
    private AccountLogMapper accountLogMapper;

    @Autowired
    private IdUtils idUtils;


    @Autowired
    private RedPaperMapper redPaperMapper;



    @Override
    public Object account(AllAcountParamDto allAcountParamDto) {

        String now=DateUtil.now();
        //判断红包已被领取
        RedPaper redPaper3=new RedPaper();
        redPaper3.setRuleId(Convert.toInt(allAcountParamDto.getRuleId()));
        redPaper3.setReceiveUserId(allAcountParamDto.getUserId());
        int i = redPaperMapper.selectCount(redPaper3);
        if(i>0){
            throw new RestException(-1,"红包已被领取");
        }
        RedPaper redPaper = redPaperMapper.getOne(Convert.toInt(allAcountParamDto.getRuleId()));
        if(redPaper==null||redPaper.getMoney()==null||redPaper.getMoney().compareTo(BigDecimal.ZERO)==0){
            throw new RestException(-1,"红包已被领完");
        }
        boolean isvalid = redPaperRuleService.isvalid(Convert.toInt(allAcountParamDto.getRuleId()));
        if(!isvalid){
            throw new RestException(-1,"红包已失效");
        }

        //添加账户记录
        AccountInfo accountInfo1 = accountService.findByUserId(allAcountParamDto.getUserId());
        if(accountInfo1==null){
            throw new RestException(-3,"账户不存在");
        }
        allAcountParamDto.setAccountId(accountInfo1.getAccountId());
        allAcountParamDto.setOldMoney(Convert.toBigDecimal(accountInfo1.getMoney(),Constants.MONEY_INIT));
        allAcountParamDto.setMoney(redPaper.getMoney());
        allAcountParamDto.setFlowNo(redPaper.getId().toString());


        log.debug("准备进行领取红包操作:{}",JSONUtil.toJsonPrettyStr(allAcountParamDto));
        //合伙人扣钱(在红包生成后已经在后台扣除了)，用户加钱
        String payOrderId=idUtils.generate("ZF",0);

        AccountLog accountLog=new AccountLog();
        accountLog.setCreateTime(now);
        accountLog.setAccountId(allAcountParamDto.getAccountId());
        accountLog.setOldMoney(allAcountParamDto.getOldMoney().toString());
        String newMoney=businessUtil.changeMoney(Convert.toStr(NumberUtil.add(Convert.toBigDecimal(accountLog.getOldMoney()),allAcountParamDto.getMoney())));
        accountLog.setNewMoney(newMoney);
        accountLog.setCreateUserId(allAcountParamDto.getUserId());
        accountLog.setChannelType(Convert.toShort(CommonEnum.领取红包操作.getValue()));
        accountLog.setOrderId(payOrderId);
        accountLogMapper.insertSelective(accountLog);

        //更新账户余额
        AccountInfo accountInfo2=new AccountInfo();
        accountInfo2.setAccountId(allAcountParamDto.getAccountId());
        accountInfo2.setMoney(newMoney);
        accountInfo2.setUpdateTime(DateUtil.now());
        accountService.update(accountInfo2);

        //更新红包领取状态
        RedPaper redPaper2=new RedPaper();
        redPaper2.setId(Convert.toInt(allAcountParamDto.getFlowNo()));
        redPaper2.setReceiveFlag(Convert.toShort(OrderEnum.已领取红包.getValue()));
        redPaper2.setReceiveTime(now);
        redPaper2.setReceiveUserId(allAcountParamDto.getUserId());
        redPaperMapper.updateByPrimaryKeySelective(redPaper2);

        //添加操作记录 我的环保金明细展示
        Map<String,Object>  payMap = new HashMap();

        payMap.put("payOrderId",payOrderId);
        payMap.put("orderId",allAcountParamDto.getFlowNo());
        payMap.put("createUserId",allAcountParamDto.getUserId());
        payMap.put("money",allAcountParamDto.getMoney());
        payMap.put("accountId",allAcountParamDto.getAccountId());
        payMap.put("payType", PayEnum.红包.getValue());
        payMap.put("status",PayEnum.已支付.getValue());
        payMap.put("createTime",now);
        payInfoMapper.payInfoAdd(payMap);

        //消息记录
        SysMessage sysMessage = new SysMessage();
        sysMessage.setCreateTime(now);
        sysMessage.setCreateUserId(allAcountParamDto.getUserId());
        sysMessage.setFlag(SysEnum.未读.getValue());
        sysMessage.setMessage("您收到红包" + allAcountParamDto.getMoney().toString() + "元");
        sysMessage.setMessageSubTypeName("红包");
        sysMessage.setMessageType(SysEnum.红包.getValue());
        sysMessage.setUserId(allAcountParamDto.getUserId());
        sysMessageMapper.insertSelective(sysMessage);
        log.debug("领取红包操作已完成：用户：{},金额：{}",allAcountParamDto.getUserId(),allAcountParamDto.getMoney().toString());
        return redPaper;
    }
}