每人每日质押设置

KKSU

2024-04-07 ee1667b3e8faa9c7f3cbc921ea7bb87c2e3f4358

 src/main/java/cc/mrbird/febs/dapp/service/impl/AsyncCjServiceImpl.java

@@ -310,17 +310,17 @@
        //可以获取奖励的用户
        Map<Long, BigDecimal> memberPerkMap = new HashMap<>();
        //总团队业绩
//        BigDecimal memberPerkTotal = BigDecimal.ZERO;
        BigDecimal memberPerkTotal = dappAchieves.stream().map(DappAchieve::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
        if(BigDecimal.ZERO.compareTo(memberPerkTotal) >= 0){
            return;
        }
        BigDecimal memberPerkTotal = BigDecimal.ZERO;
//        BigDecimal memberPerkTotal = dappAchieves.stream().map(DappAchieve::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
//        if(BigDecimal.ZERO.compareTo(memberPerkTotal) >= 0){
//            return;
//        }
        //获取全部会员
        Set<Long> allMembers = dappMemberEntities.stream().map(DappMemberEntity::getId).collect(Collectors.toSet());
        //获取正在质押的会员ID
        Set<Long> achieveMembers = dappAchieves.stream().map(DappAchieve::getMemberId).collect(Collectors.toSet());
        Collection<Long> intersection = CollUtil.intersection(allMembers, achieveMembers);
        for(Long memberId : intersection){
//        Set<Long> achieveMembers = dappAchieves.stream().map(DappAchieve::getMemberId).collect(Collectors.toSet());
//        Collection<Long> intersection = CollUtil.intersection(allMembers, achieveMembers);
        for(Long memberId : allMembers){
            /**
             * 获取每一个成员的四级直推
             */
@@ -356,7 +356,7 @@
            if(BigDecimal.ZERO.compareTo(teamAchieveMemberSum) >= 0){
                continue;
            }
//            memberPerkTotal = memberPerkTotal.add(teamAchieveMemberSum);
            memberPerkTotal = memberPerkTotal.add(teamAchieveMemberSum);
            memberPerkMap.put(memberId,teamAchieveMemberSum);
        }

@@ -374,6 +374,21 @@
            if(ObjectUtil.isEmpty(dappMemberEntityExit)){
                continue;
            }
            //如果没有进行中的质押，直接返回
            QueryWrapper<DappAchieve> objectQueryWrappereq = new QueryWrapper<>();
            objectQueryWrappereq.eq("state",DappAchieve.STATUS_ING);
            objectQueryWrappereq.eq("member_id",memberId);
            List<DappAchieve> dappAchieveseq = dappAchieveMapper.selectList(objectQueryWrappereq);
            if(CollUtil.isEmpty(dappAchieveseq)){
                DappFundFlowEntity fundFlowTuiJian = new DappFundFlowEntity(
                        memberId,
                        multiplyUsdt,
                        FlowTypeEnum.TUAN_DUI_FAIL.getValue(),
                        DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
                        StrUtil.format(FlowTypeEnum.TUAN_DUI_FAIL_DES.getDescrition(), amountMember));
                dappFundFlowDao.insert(fundFlowTuiJian);
                continue;
            }
            createFlow(
                    multiplyUsdt,
                    memberId,