KKSU
2024-06-24 159c4ae136e14f9bbfb28eef799b42fe59d9fd9e
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -10,6 +10,7 @@
import cc.mrbird.febs.dapp.mapper.*;
import cc.mrbird.febs.dapp.service.DappSystemService;
import cc.mrbird.febs.dapp.service.DappWalletService;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cc.mrbird.febs.tree.MatrixTree;
import cc.mrbird.febs.tree.MemberNode;
import cc.mrbird.febs.tree.TreeConstants;
@@ -50,6 +51,7 @@
    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
    private final DbMemberNodeMapper dbMemberNodeMapper;
    private final ChainProducer chainProducer;
    @Override
@@ -217,6 +219,15 @@
        dbMemberNode.setWorkState(1);
        dbMemberNodeMapper.insert(dbMemberNode);
        /**
         * 判断你的上级是否满足复投条件
         */
        DappMemberEntity dappMemberEntityDirect = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId());
        if(ObjectUtil.isNotEmpty(dappMemberEntityDirect)){
            Long id = dappMemberEntityDirect.getId();
            chainProducer.sendNodeMsgLong(id);
        }
        //如果添加的为右节点,那么进入判断
        if(DbMemberNode.STATE_TWO == dbMemberNode.getLeftRight()){
            //更新父节点的右节点
@@ -304,10 +315,21 @@
            perkSevenTeen(memberId,add,countFund);
            return;
        }else if(10 < countFund){
            return;
        }else{
            //复投
            Integer type = dbMemberNodeRoot.getType();
            futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
            Integer countFundNext = countFund + 1;
            QueryWrapper<DbMemberNode> nodeQueryWrapper = new QueryWrapper<>();
            nodeQueryWrapper.eq("member_id",memberId);
            nodeQueryWrapper.eq("type", type);
            nodeQueryWrapper.eq("count_fund", countFundNext);
            DbMemberNode dbMemberNode = dbMemberNodeMapper.selectOne(nodeQueryWrapper);
            if(ObjectUtil.isNotEmpty(dbMemberNode)){
                return;
            }
            futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFundNext);
            //产生收益
            perkSevenTeen(memberId,perkAmount,countFund);
            return;