逻辑

KKSU

2024-07-08 f0922bc416fad3aa6121ffdbdd217bffb94f518f

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

@@ -606,18 +606,23 @@
         *      *      21-25代奖励4%
         *      *      26-30代奖励7%
         */
        DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(id);
        if(ObjectUtil.isEmpty(dappFundFlowEntity)){
//        DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(id);
//        if(ObjectUtil.isEmpty(dappFundFlowEntity)){
//            return;
//        }
//        if(DappFundFlowEntity.WITHDRAW_STATUS_AGREE != dappFundFlowEntity.getStatus()){
//            return;
//        }
        DappStorage dappStorage = dappStorageMapper.selectById(id);

        if(ObjectUtil.isEmpty(dappStorage)){
            return;
        }
        if(DappFundFlowEntity.WITHDRAW_STATUS_AGREE != dappFundFlowEntity.getStatus()){
            return;
        }
        BigDecimal amount = dappFundFlowEntity.getAmount().abs();
        BigDecimal amount = dappStorage.getReleaseAmount().abs();
        /**
         * 往上循环30层，判断每一层是否有见点奖
         */
        Long memberId = dappFundFlowEntity.getMemberId();
        Long memberId = dappStorage.getMemberId();
        for(int i = 1;i <= 30;i++){
            DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
            String refererId = dappMemberEntity.getRefererId();
@@ -835,34 +840,34 @@
        }

        //减少用户的总额度
        BigDecimal usdtBalance = dappMemberEntity.getUsdtBalance();
        if(BigDecimal.ZERO.compareTo(usdtBalance) >= 0){
            return;
        }
        if(daoNodeAmount.compareTo(usdtBalance) >= 0){
            daoNodeAmount = usdtBalance;
            usdtBalance = BigDecimal.ZERO;
        }else{
            usdtBalance = usdtBalance.subtract(daoNodeAmount);
        }
//        BigDecimal usdtBalance = dappMemberEntity.getUsdtBalance();
//        if(BigDecimal.ZERO.compareTo(usdtBalance) >= 0){
//            return;
//        }
//        if(daoNodeAmount.compareTo(usdtBalance) >= 0){
//            daoNodeAmount = usdtBalance;
//            usdtBalance = BigDecimal.ZERO;
//        }else{
//            usdtBalance = usdtBalance.subtract(daoNodeAmount);
//        }

        //总额度为0，用户变成未激活
        if(BigDecimal.ZERO.compareTo(usdtBalance) >= 0){
            dappMemberEntity.setActiveStatus(2);
            //更新用户所有的业绩为已失效
            QueryWrapper<DappStorage> objectQueryWrapper = new QueryWrapper<>();
            objectQueryWrapper.eq("member_id",memberId);
            objectQueryWrapper.eq("state",1);
            List<DappStorage> dappStorages = dappStorageMapper.selectList(objectQueryWrapper);
            if(CollUtil.isNotEmpty(dappStorages)){
                for(DappStorage dappStorage : dappStorages){
                    dappStorage.setState(2);
                    dappStorageMapper.updateById(dappStorage);
                }
            }
        }
        dappMemberEntity.setUsdtBalance(usdtBalance);
        dappMemberDao.updateById(dappMemberEntity);
//        if(BigDecimal.ZERO.compareTo(usdtBalance) >= 0){
//            dappMemberEntity.setActiveStatus(2);
//            //更新用户所有的业绩为已失效
//            QueryWrapper<DappStorage> objectQueryWrapper = new QueryWrapper<>();
//            objectQueryWrapper.eq("member_id",memberId);
//            objectQueryWrapper.eq("state",1);
//            List<DappStorage> dappStorages = dappStorageMapper.selectList(objectQueryWrapper);
//            if(CollUtil.isNotEmpty(dappStorages)){
//                for(DappStorage dappStorage : dappStorages){
//                    dappStorage.setState(2);
//                    dappStorageMapper.updateById(dappStorage);
//                }
//            }
//        }
//        dappMemberEntity.setUsdtBalance(usdtBalance);
//        dappMemberDao.updateById(dappMemberEntity);

        dappWalletService.updateWalletCoinWithLock(daoNodeAmount, memberId, 1);
        DappFundFlowEntity nodeFlow = new DappFundFlowEntity(
@@ -1002,6 +1007,7 @@
            for(DappMemberEntity directMember : directMembers){
                //每一个直推的团队
                List<DappMemberEntity> direct = dappMemberDao.selectChildMemberDirectOrNot(directMember.getInviteId(), 2, null);
                direct.add(directMember);
                if(CollUtil.isEmpty(direct)){
                    continue;
                }
@@ -1009,7 +1015,7 @@
                List<Long> collect = direct.stream().map(DappMemberEntity::getId).collect(Collectors.toList());
                QueryWrapper<DappStorage> storageQueryWrapper = new QueryWrapper<>();
                storageQueryWrapper.in("member_id",collect);
                storageQueryWrapper.eq("state",1);
//                storageQueryWrapper.eq("state",1);
                List<DappStorage> dappStorages = dappStorageMapper.selectList(storageQueryWrapper);
                if(CollUtil.isEmpty(dappStorages)){
                    continue;