KKSU
2024-06-11 783a06c84f8934e59a7e45e3c948727520e3cd4f
src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -42,4 +42,18 @@
    public void feeDistribute(String data) {
        dappSystemService.feeDistribute(data);
    }
    @RabbitListener(queues = QueueConstants.TFC_INVITE_PERK_QUEEN)
    public void invitePerkMsg(Long id) {
        log.info("消费推荐规则奖励,流水ID:{}", id);
        dappSystemService.invitePerkMsg(id);
    }
    @RabbitListener(queues = QueueConstants.TFC_NODE_PERK_QUEEN)
    public void nodePerkMsg(Long id) {
        log.info("消费节点投资,流水ID:{}", id);
        dappSystemService.nodePerkMsg(id);
    }
}