src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -56,4 +56,10 @@ log.info("消费节点投资,流水ID:{}", id); dappSystemService.nodePerkMsg(id); } @RabbitListener(queues = QueueConstants.TFC_NODE_AGAIN) public void nodeMsg(Long id) { log.info("复投:{}", id); dappSystemService.achieveTreeV2(id); } }