package cc.mrbird.febs.mall.service.impl;

import cc.mrbird.febs.common.enumerates.FlowTypeEnum;
import cc.mrbird.febs.common.enumerates.RunVipDataDictionaryEnum;
import cc.mrbird.febs.common.enumerates.RunVipMoneyFlowTypeEnum;
import cc.mrbird.febs.common.enumerates.YesOrNoEnum;
import cc.mrbird.febs.common.utils.MallUtils;
import cc.mrbird.febs.mall.entity.DataDictionaryCustom;
import cc.mrbird.febs.mall.entity.MallMember;
import cc.mrbird.febs.mall.mapper.DataDictionaryCustomMapper;
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
import cc.mrbird.febs.mall.service.AsyncService;
import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
import cc.mrbird.febs.mall.service.IMallMoneyFlowService;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.math.RoundingMode;

@Slf4j
@Service
@RequiredArgsConstructor
public class AsyncServiceImpl extends ServiceImpl<MallMemberMapper, MallMember> implements AsyncService {

    private final IMallMoneyFlowService mallMoneyFlowService;
    private final IApiMallMemberWalletService walletService;
    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;

    /**
     * 执行直推奖励的逻辑
     * 当一个会员进行操作时，此方法会根据直推关系给予推荐人一定的奖励
     * 奖励金额计算基于操作金额和系统设定的直推奖励比例
     *
     * @param amount      操作金额，用于计算直推奖励
     * @param memberId    会员ID，用于查找会员及其推荐人信息
     */
    @Override
    public void directCoin(BigDecimal amount, Long memberId) {
        // 根据会员ID查询会员信息
        MallMember mallMember = this.baseMapper.selectById(memberId);
        // 如果会员不存在或没有推荐人，则直接返回
        if (null == mallMember || StrUtil.isBlank(mallMember.getReferrerId())){
            return;
        }
        // 根据推荐人ID查询推荐人信息
        MallMember mallRef = this.baseMapper.selectInfoByInviteId(mallMember.getReferrerId());
        // 如果推荐人不存在，则直接返回
        if(mallRef == null){
            return;
        }
        // 查询直推奖励的比例设置
        DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                RunVipDataDictionaryEnum.CHARGE_SYS_DIRECT.getType(),
                RunVipDataDictionaryEnum.CHARGE_SYS_DIRECT.getCode()
        );
        // 如果未设置直推奖励比例，则初始化一个默认值（0.1代表10%，设置成0，则不返直推）
        if(null == dataDictionaryCustom){
            dataDictionaryCustom = new DataDictionaryCustom();
            dataDictionaryCustom.setType(RunVipDataDictionaryEnum.CHARGE_SYS_DIRECT.getType());
            dataDictionaryCustom.setCode(RunVipDataDictionaryEnum.CHARGE_SYS_DIRECT.getCode());
            dataDictionaryCustom.setValue("0");
            dataDictionaryCustom.setDescription("直推奖励（0.1代表10%，设置成0，则不返直推）");
            dataDictionaryCustomMapper.insert(dataDictionaryCustom);
        }
        // 解析直推奖励比例
        BigDecimal directPercent = new BigDecimal(dataDictionaryCustom.getValue());

        // 计算直推奖励金额
        BigDecimal directAmount = amount.multiply(directPercent).setScale(2, RoundingMode.DOWN);
        // 如果直推奖励金额小于等于0，则直接返回
        if(BigDecimal.ZERO.compareTo(directAmount) >=0){
            return;
        }
        // 如果直推奖励金额大于等于操作金额，则直接返回，防止奖励金额异常
        if(directAmount.compareTo(amount) >=0){
            return;
        }

        // 调用服务增加推荐人的佣金
        walletService.addCommission(directAmount,mallRef.getId());
        // 生成订单号
        String orderNo = MallUtils.getOrderNum("DPE");
        // 记录推荐人的资金流水
        mallMoneyFlowService.runVipMoneyFlowAdd(
                mallRef.getId(),
                memberId,
                orderNo,
                FlowTypeEnum.COMMISSION.getValue(),
                RunVipMoneyFlowTypeEnum.DIRECT_USDT.getValue(),
                directAmount,
                StrUtil.format(RunVipMoneyFlowTypeEnum.DIRECT_USDT.getDescription(),directAmount),
                YesOrNoEnum.YES.getValue()
        );
    }

    @Override
    public void releaseScore(BigDecimal V3, Long memberId) {
        walletService.addScore(V3,memberId);
        String orderNo = MallUtils.getOrderNum("HD");
        mallMoneyFlowService.runVipMoneyFlowAdd(
                memberId,
                memberId,
                orderNo,
                FlowTypeEnum.SCORE.getValue(),
                RunVipMoneyFlowTypeEnum.GET_SCORE.getValue(),
                V3,
                StrUtil.format(RunVipMoneyFlowTypeEnum.GET_SCORE.getDescription(),V3),
                YesOrNoEnum.YES.getValue()
        );

    }

    @Override
    public void releaseNodeCoin(BigDecimal amount, BigDecimal percent, Long memberId) {
        //实际节点助力的碳币
        BigDecimal multiply = amount.multiply(percent).setScale(2,RoundingMode.DOWN);
        if(BigDecimal.ZERO.compareTo(multiply) >=0){
            return;
        }
        walletService.addCommission(multiply,memberId);
        String orderNo = MallUtils.getOrderNum("JD");
        mallMoneyFlowService.runVipMoneyFlowAdd(
                memberId,
                memberId,
                orderNo,
                FlowTypeEnum.COMMISSION.getValue(),
                RunVipMoneyFlowTypeEnum.NODE_COMMISSION.getValue(),
                multiply,
                StrUtil.format(RunVipMoneyFlowTypeEnum.NODE_COMMISSION.getDescription(),multiply),
                YesOrNoEnum.YES.getValue()
        );

    }
}