后台矩阵列表

KKSU

2024-06-22 cf41edf287a88574bf955bda8f4d6aa6fef27720

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

@@ -239,7 +239,7 @@
                    return;
                }
                //有，则上级节点出局复投，轮数加1，复投逻辑
                memberNodeNext(dbMemberNodeRoot);
                this.memberNodeNext(dbMemberNodeRoot);
            }else{//父节点为左节点，那么没人出局
                return;
            }
@@ -256,6 +256,7 @@
     * 有，则上级节点出局复投，轮数加1，复投逻辑
     * @param dbMemberNodeRoot
     */
    @Override
    public void memberNodeNext(DbMemberNode dbMemberNodeRoot) {
        log.info("进入复投");

@@ -320,8 +321,6 @@
                //如果是第一轮,下一个新团有投入，则产生收益
                //复投或者收益的金额
                if(1 == countFund){//第一轮
                    //复投本轮，轮数 +1
                    futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
                    //收益复投(当前的下一个星团没有已投入)，还是收益提出
                    Integer nextType = type + 1;
                    QueryWrapper<DbMemberNode> nodeQueryWrapper = new QueryWrapper<>();
@@ -334,6 +333,8 @@
                    }else{
                        perkSevenTeen(memberId,perkAmount,countFund);
                    }
                    //复投本轮，轮数 +1
                    futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
                }else{//2-9轮
                    //复投本轮，轮数 +1
                    futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
@@ -397,13 +398,34 @@
        dbMemberNode.setWorkState(1);
        dbMemberNodeMapper.insert(dbMemberNode);

        boolean flag = false;//下一级的再次复投
        if(ObjectUtil.isNotEmpty(dbMemberNodeOld)){
            if(dbMemberNode.getLeftRight() == 1){
                dbMemberNodeOld.setLeftNode(dbMemberNode.getId());
            }else{
                dbMemberNodeOld.setRightNode(dbMemberNode.getId());
                flag = true;
            }
            dbMemberNodeMapper.updateById(dbMemberNodeOld);
        }
        if(flag){
            if(ObjectUtil.isEmpty(dbMemberNodeOld.getParentNode())){
                return;
            }
            Long parentNode = dbMemberNodeOld.getParentNode();
            DbMemberNode dbMemberNodeRoot = dbMemberNodeMapper.selectById(parentNode);
            if(ObjectUtil.isEmpty(dbMemberNodeRoot)){
                return;
            }
            if(dbMemberNodeRoot.getLeftRight() == 1){
                return;
            }
            //每个星团，只复投10轮
            if(10 < dbMemberNodeRoot.getCountFund()){
                return;
            }

            this.memberNodeNext(dbMemberNodeRoot);
        }
    }

@@ -570,10 +592,11 @@
            if(ObjectUtil.isEmpty(dappMemberEntityRef)){
                return;
            }

            memberId = dappMemberEntityRef.getId();
            //如果为购买星级激活用户，则跳过
            Integer activeStatus = dappMemberEntityRef.getActiveStatus();
            if(1 != activeStatus){
                memberId = dappMemberEntityRef.getId();
                continue;
            }
            //获取上级全部的直推
@@ -584,7 +607,6 @@

            //如果没有直推，则跳过
            if(CollUtil.isEmpty(memberInviteList)){
                memberId = dappMemberEntityRef.getId();
                continue;
            }

@@ -594,10 +616,9 @@
            }
            //如果直推不满足当前规则需要的人数，则跳过
            if(memberInviteList.size() < rule.getInviteNum()){
                memberId = dappMemberEntityRef.getId();
                continue;
            }
            BigDecimal perkPercent = new BigDecimal(rule.getPerkPercent());
            BigDecimal perkPercent = new BigDecimal(rule.getPerkPercent()).multiply(new BigDecimal("0.01"));
            BigDecimal perkAmount = perkPercent.multiply(amount);
            Long perkMemberId = dappMemberEntityRef.getId();
            //生成一条流水
@@ -640,7 +661,7 @@
                DataDictionaryEnum.PERK_NUM.getType(),
                DataDictionaryEnum.PERK_NUM.getCode()
        );
        BigDecimal perKNum = new BigDecimal(ObjectUtil.isEmpty(perkPercentDic) ? "1000" : perKNumDic.getValue());
        BigDecimal perKNum = new BigDecimal(ObjectUtil.isEmpty(perKNumDic) ? "200" : perKNumDic.getValue());

        BigDecimal perkAmount = amount.multiply(perkPercent).divide(perKNum, 8, BigDecimal.ROUND_DOWN);
        if(BigDecimal.ZERO.compareTo(perkAmount) >= 0){
@@ -667,7 +688,10 @@
                return;
            }
            //奖励金额
            BigDecimal memberPerk = perkPercent.multiply(buyNode);
            BigDecimal memberPerk = perkAmount.multiply(buyNode);
            if(BigDecimal.ZERO.compareTo(memberPerk) >= 0){
                continue;
            }
            dappWalletService.updateWalletCoinWithLock(memberPerk, dappMemberEntity.getId(), 1);

            DappFundFlowEntity fundFlow = new DappFundFlowEntity(