后台矩阵列表

KKSU

2024-06-24 f5cf516fdec9ae5207a8502505b0567110fe031c

后台矩阵列表

 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()){
            //更新父节点的右节点

 src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java

@@ -85,6 +85,7 @@
        QueryWrapper<DbMemberNode> objectQueryWrapper = new QueryWrapper<>();
        objectQueryWrapper.eq("count_fund", 1);
        objectQueryWrapper.eq("work_state", 1);
        objectQueryWrapper.eq("type", 1);
        objectQueryWrapper.eq("member_id", id);
        List<DbMemberNode> dbMemberNodes = dbMemberNodeMapper.selectList(objectQueryWrapper);
        if(CollUtil.isEmpty(dbMemberNodes)){