将监听充值新建一个项目

KKSU

2024-06-07 76e42bfdf66fbd49e4ed3173236b2f4b352685b2

将监听充值新建一个项目

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

@@ -14,6 +14,7 @@
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -58,6 +59,9 @@
    @Transactional(rollbackFor = Exception.class)
    public synchronized void achieveTree(Long memberId) {
        DappMemberEntity member = dappMemberDao.selectById(memberId);
        if(ObjectUtil.isEmpty(member)){
            return;
        }

        int batchNo = 0;
        DappAchieveTreeEntity newestTreeNode = dappAchieveTreeDao.selectNewestTreeNode();

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

@@ -23,9 +23,7 @@
    @RabbitListener(queues = QueueConstants.ACHIEVE_TREE)
    public void achieveTree(String id) {
        log.info("收到业绩树消息");
        return;
        // todo
//        dappSystemService.achieveTree(Long.parseLong(id));
        dappSystemService.achieveTree(Long.parseLong(id));
    }

    /**