提现，限额

xiaoyong931011

2023-04-18 bd8eb594b0bd5c08a261c6930ddc2bd1736695ef

 src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java

@@ -1,6 +1,7 @@
package cc.mrbird.febs.mall.service.impl;

import cc.mrbird.febs.common.enumerates.*;
import cc.mrbird.febs.common.utils.AppContants;
import cc.mrbird.febs.common.utils.MallUtils;
import cc.mrbird.febs.mall.entity.*;
import cc.mrbird.febs.mall.mapper.*;
@@ -9,6 +10,7 @@
import cc.mrbird.febs.mall.vo.AdminTeamEqualsPerkVo;
import cc.mrbird.febs.system.mapper.UserMapper;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.math.MathUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
@@ -39,6 +41,7 @@

    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
    private final MallMemberMapper memberMapper;
    private final MallAchieveRecordMapper mallAchieveRecordMapper;
    private final MallOrderInfoMapper mallOrderInfoMapper;

    private final IApiMallMemberWalletService iApiMallMemberWalletService;
@@ -184,9 +187,9 @@
        if(ObjectUtil.isEmpty(mallOrderInfo)){
            return;
        }
        if(2 != mallOrderInfo.getStatus()){
            return;
        }
//        if(2 != mallOrderInfo.getStatus()){
//            return;
//        }
        /**
         * 分享补贴 直推消费额10%
         */
@@ -355,9 +358,15 @@
            List<Long> mallMemberStarIds = mallMemberStars.stream().map(MallMember::getId).collect(Collectors.toList());
            //排除掉本身
            mallMemberStarIds.remove(memberId);
            if(CollUtil.isEmpty(mallMemberStarIds)){
                return mallMemberStars;
            }
            //当前等级的总贡献点
            List<MallMemberWallet> mallMemberWallets = mallMemberWalletMapper.selectMemberWalletsByIds(mallMemberStarIds);
            Integer starSum = mallMemberWallets.stream().mapToInt(MallMemberWallet::getStar).sum();
            if(starSum <= 0){
                return mallMemberStars;
            }
            //星级补贴比例
            DataDictionaryCustom starPerkDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                    "AGENT_LEVEL_REQUIRE",
@@ -574,5 +583,47 @@
        }
    }

    @Override
    public void achieveReleasePercent() {
        DataDictionaryCustom jobAchieveReleasePercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                GreenScoreEnum.JOB_ACHIEVE_RELEASE_PERCENT.getType(),
                GreenScoreEnum.JOB_ACHIEVE_RELEASE_PERCENT.getCode()
        );

        List<MallMember> mallMembers = memberMapper.selectByLevel(MemberLevelEnum.SECOND_LEVEL.getType());
        if(CollUtil.isNotEmpty(mallMembers)){
            for(MallMember mallMember : mallMembers){
                //总业绩
                BigDecimal sumAchieve = mallAchieveRecordMapper.selectSumAchieveByMemberId(mallMember.getId());
                BigDecimal jobAchieveReleasePercent = new BigDecimal(jobAchieveReleasePercentDic.getValue())
                        .multiply(new BigDecimal(0.001));
                //每个人的补贴额度
                BigDecimal multiply = sumAchieve.multiply(jobAchieveReleasePercent);
                MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(mallMember.getId());
                BigDecimal totalScore = mallMemberWallet.getTotalScore();
                if(BigDecimal.ZERO.compareTo(multiply) < 0){
                    if(BigDecimal.ZERO.compareTo(totalScore) < 0){
                        if(totalScore.compareTo(multiply) < 0){
                            multiply = totalScore;
                        }
                        //减少补贴额度
                        mallMemberWalletMapper.reduceTotalScoreById(multiply, mallMemberWallet.getId());

                        reduceStar(mallMember.getId(),multiply);

                        mallMemberWalletMapper.addBalanceById(multiply, mallMemberWallet.getId());

                        mallMoneyFlowService.addMoneyFlow(
                                mallMember.getId(),
                                multiply,
                                MoneyFlowTypeEnum.STATIC_BONUS.getValue(),
                                MallUtils.getOrderNum(),
                                FlowTypeEnum.BALANCE.getValue());
                    }
                }
            }
        }
    }


}