直推奖励，冻结的用户，则直推奖励销毁，用户未冻结才能领取成功

KKSU

2023-12-28 dd69dbc31beed85d66c319a26331a51d7437fcb2

直推奖励，冻结的用户，则直推奖励销毁，用户未冻结才能领取成功

 src/main/java/cc/mrbird/febs/mall/dto/TeamPerkDto.java

@@ -2,6 +2,14 @@

import lombok.Data;

/**
 * {"directCnt":5,"PerkPercent":"0","equalsPerkPercent":"10"}
 * {"directCnt":15,"PerkPercent":"1","equalsPerkPercent":"10"}
 * {"directCnt":40,"PerkPercent":"2","equalsPerkPercent":"10"}
 * {"directCnt":100,"PerkPercent":"3","equalsPerkPercent":"10"}
 * {"directCnt":300,"PerkPercent":"4","equalsPerkPercent":"10"}
 * {"directCnt":1000,"PerkPercent":"5","equalsPerkPercent":"10"}
 */
@Data
public class TeamPerkDto {
    //直推人数

 src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java

@@ -125,6 +125,15 @@
        agentService.BuyToSell();
    }


    /**
     * 用户等级升级
     */
    @Scheduled(cron = "0 0 0 * * ?")
    public void memberLevelUp() {
        agentService.memberLevelUp();
    }

    /**
     * 买单
     * 看是否是开始显示订单的时间段,超出结束时间的买单，全部超时失败

 src/main/java/cc/mrbird/febs/mall/service/IAgentService.java

@@ -53,4 +53,6 @@
    void teamMemberPerk();

    void equalsMemberPerk();

    void memberLevelUp();
}

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

@@ -20,6 +20,7 @@
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -914,46 +915,49 @@
                        while (!flag) {
                            MallMember mallMemberRef = memberMapper.selectInfoByInviteId(parentId);
                            String levelRef = mallMemberRef.getLevel();
                            int compareLevel = MemberLevelNewEnum.ZERO_LEVEL.compareLevel(level, levelRef);
                            DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                                    levelRef, levelRef
                            );
                            TeamPerkDto teamPerkDto = JSONObject.parseObject(dataDictionaryCustom.getValue(), TeamPerkDto.class);
                            if(compareLevel == 0){//团队奖励
                                BigDecimal PerkPercent = new BigDecimal(teamPerkDto.getPerkPercent());
                                BigDecimal teamPerk = PerkPercent.multiply(profit).setScale(2,BigDecimal.ROUND_DOWN);
                                /**
                                 * 先插入流水记录，然后定时器循环,找寻对应的数据执行
                                 */
                                String orderNo = MallUtils.getOrderNum("TNFT");
                            //会员等级为ZERO_LEVEL，则不参与团队返佣
                            if(!MemberLevelNewEnum.ZERO_LEVEL.getType().equals(levelRef)){
                                int compareLevel = MemberLevelNewEnum.ZERO_LEVEL.compareLevel(level, levelRef);
                                DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                                        levelRef, levelRef
                                );
                                TeamPerkDto teamPerkDto = JSONObject.parseObject(dataDictionaryCustom.getValue(), TeamPerkDto.class);
                                if(compareLevel == 0){//团队奖励
                                    BigDecimal PerkPercent = new BigDecimal(teamPerkDto.getPerkPercent());
                                    BigDecimal teamPerk = PerkPercent.multiply(profit).setScale(2,BigDecimal.ROUND_DOWN);
                                    /**
                                     * 先插入流水记录，然后定时器循环,找寻对应的数据执行
                                     */
                                    String orderNo = MallUtils.getOrderNum("TNFT");

                                if(teamPerk.compareTo(BigDecimal.ZERO) > 0){
                                    insertFlowUpdateFrozenNft(
                                            orderNo,
                                            mallMemberRef.getId(),
                                            teamPerk,
                                            MoneyFlowTypeNewEnum.TEAM_PERK_DIRECT.getValue(),
                                            FlowTypeNewEnum.NFT.getValue(),
                                            MoneyFlowTypeNewEnum.TEAM_PERK_DIRECT.getDescrition(),
                                            AppContants.MEMBER_FLOW_ING);
                                    if(teamPerk.compareTo(BigDecimal.ZERO) > 0){
                                        insertFlowUpdateFrozenNft(
                                                orderNo,
                                                mallMemberRef.getId(),
                                                teamPerk,
                                                MoneyFlowTypeNewEnum.TEAM_PERK_DIRECT.getValue(),
                                                FlowTypeNewEnum.NFT.getValue(),
                                                MoneyFlowTypeNewEnum.TEAM_PERK_DIRECT.getDescrition(),
                                                AppContants.MEMBER_FLOW_ING);
                                    }
                                    equalsPerkBasic = teamPerk;
                                    level = levelRef;
                                }else if(compareLevel == 2){//平级奖励
                                    BigDecimal equalsPerkPercent = new BigDecimal(teamPerkDto.getEqualsPerkPercent());
                                    BigDecimal equalsPerk = equalsPerkPercent.multiply(equalsPerkBasic).setScale(2,BigDecimal.ROUND_DOWN);
                                    String orderNo = MallUtils.getOrderNum("PJNFT");
                                    if(equalsPerk.compareTo(BigDecimal.ZERO) > 0){
                                        insertFlowUpdateFrozenNft(
                                                orderNo,
                                                mallMemberRef.getId(),
                                                equalsPerk,
                                                MoneyFlowTypeNewEnum.TEAM_PERK_EQUALS.getValue(),
                                                FlowTypeNewEnum.NFT.getValue(),
                                                MoneyFlowTypeNewEnum.TEAM_PERK_EQUALS.getDescrition(),
                                                AppContants.MEMBER_FLOW_ING);
                                    }
                                    equalsPerkBasic = equalsPerk;
                                }
                                equalsPerkBasic = teamPerk;
                                level = levelRef;
                            }else if(compareLevel == 2){//平级奖励
                                BigDecimal equalsPerkPercent = new BigDecimal(teamPerkDto.getEqualsPerkPercent());
                                BigDecimal equalsPerk = equalsPerkPercent.multiply(equalsPerkBasic).setScale(2,BigDecimal.ROUND_DOWN);
                                String orderNo = MallUtils.getOrderNum("PJNFT");
                                if(equalsPerk.compareTo(BigDecimal.ZERO) > 0){
                                    insertFlowUpdateFrozenNft(
                                            orderNo,
                                            mallMemberRef.getId(),
                                            equalsPerk,
                                            MoneyFlowTypeNewEnum.TEAM_PERK_EQUALS.getValue(),
                                            FlowTypeNewEnum.NFT.getValue(),
                                            MoneyFlowTypeNewEnum.TEAM_PERK_EQUALS.getDescrition(),
                                            AppContants.MEMBER_FLOW_ING);
                                }
                                equalsPerkBasic = equalsPerk;
                            }
                            parentId = mallMemberRef.getReferrerId();
                            if (StrUtil.isBlank(mallMemberRef.getReferrerId())) {
@@ -1345,6 +1349,71 @@
        }
    }

    @Override
    public void memberLevelUp() {
        /**
         * 获取当前所有的已完成、未转换的买单的用户
         */
        QueryWrapper<MallProductBuy> query = new QueryWrapper<>();
        query.eq("state",ProductEnum.PRODUCT_BUY_SUCCESS.getValue());
        query.eq("mate_state",ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
        List<MallProductBuy> mallProductBuys = mallProductBuyMapper.selectList(query);
        if(CollUtil.isEmpty(mallProductBuys)){
            return;
        }

        Set<Long> collect = mallProductBuys.stream().map(MallProductBuy::getMemberId).collect(Collectors.toSet());
        if(CollUtil.isEmpty(collect)){
            return;
        }
        for(Long memberId : collect){
            MallMember mallMember = memberMapper.selectById(memberId);
            if(ObjectUtil.isEmpty(mallMember)){
                continue;
            }
            //上级
            String referrerId = mallMember.getReferrerId();
            MallMember mallMemberRef = memberMapper.selectInfoByInviteId(referrerId);

            List<MallMember> mallMembers = memberMapper.selectByRefererId(referrerId);
            Set<Long> mallMembersSet = mallMembers.stream().map(MallMember::getId).collect(Collectors.toSet());
            mallMembersSet.retainAll(collect);
            List<Long> intersection = new ArrayList<>(mallMembersSet);//上级直推有效人数
            if(CollUtil.isEmpty(intersection)){
                mallMemberRef.setLevel(MemberLevelNewEnum.ZERO_LEVEL.getType());
                memberMapper.updateById(mallMemberRef);
                continue;
            }
            /**
             * 从会员等级最低到最高，比较intersection与会员设置的直推人数directCntLevel比较
             * directCntLevel >= intersection.size()，则满足升级会员等级条件，跳出循环
             * 达到最高级别后，升级会员等级，跳出循环
             */
            String level = MemberLevelNewEnum.ZERO_LEVEL.getType();
            boolean flag = false;
            while (!flag){
                DataDictionaryCustom levelDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                        level, level
                );
                TeamPerkDto teamPerkDto = JSONObject.parseObject(levelDic.getValue(), TeamPerkDto.class);
                Integer directCntLevel = teamPerkDto.getDirectCnt();
                if(directCntLevel >= intersection.size()){
                    mallMemberRef.setLevel(level);
                    memberMapper.updateById(mallMemberRef);
                    flag = true;
                }
                String nextLevel = MemberLevelNewEnum.ZERO_LEVEL.getNextLevel(level);
                level = nextLevel;
                if(level.equals(MemberLevelNewEnum.WU_LEVEL.getType()) &&
                        nextLevel.equals(MemberLevelNewEnum.WU_LEVEL.getType()) ){
                    mallMemberRef.setLevel(level);
                    memberMapper.updateById(mallMemberRef);
                    flag = true;
                }
            }
        }
    }

    public void insertSell(Long memberId,BigDecimal nftCnt,BigDecimal nftCntAva,
                           BigDecimal nftFee,BigDecimal fcmFeeCnt){
        String orderNo = MallUtils.getOrderNum("NFT");