将监听充值新建一个项目

KKSU

2024-06-07 c7720fa1218e18a768b83eb154b2c4f0909b1b81

将监听充值新建一个项目

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

@@ -14,6 +14,7 @@
import cc.mrbird.febs.dapp.service.DappWalletService;
import cc.mrbird.febs.dapp.utils.OnlineTransferUtil;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cc.mrbird.febs.tree.TreeConstants;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -194,9 +195,20 @@
                    // 更改状态为已同步
                    fundFlow.setStatus(2);
                    dappFundFlowDao.updateById(fundFlow);
                    //激动用户
                    //激活用户
                    fromMember.setActiveStatus(1);
                    dappMemberDao.updateById(fromMember);
                    //给上级直推奖励
                    DappMemberEntity member = dappMemberDao.selectById(fromMember.getId());
                    DappMemberEntity parent = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId());

                    if (ObjectUtil.isNotEmpty(parent)) {
                        BigDecimal directProfit = TreeConstants.PUT_IN_AMOUNT.multiply(new BigDecimal("0.1"));
                        dappWalletService.updateWalletCoinWithLock(directProfit, parent.getId(), 1);

                        DappFundFlowEntity fundFlowPerk = new DappFundFlowEntity(parent.getId(), directProfit, 3, 2, null, null);
                        dappFundFlowDao.insert(fundFlowPerk);
                    }
                    //生成业绩数
                    chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId());
                    //分发手续费给节点

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

@@ -103,7 +103,7 @@
//        dappMemberDao.updateById(member);
//        dappMemberDao.updateMemberActiveV2(member.getId());

        putIntoProfit(memberId, 2);
//        putIntoProfit(memberId, 2);
        if (parentNode == null) {
            return;
        }

 src/test/java/cc/mrbird/febs/TreeTest.java

@@ -45,7 +45,7 @@

    @Test
    public void resetMatrix() {
        dappSystemService.achieveTree(Long.parseLong("133"));
        dappSystemService.achieveTree(Long.parseLong("134"));
//        dappSystemService.resetMatrix();
//        dappAchieveMemberTreeDao.emptyTable();
    }