星级矩阵

KKSU

2024-06-14 d452f7803fde490d3b9bb96b9edbd7935127d480

 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));
    }

    /**
@@ -44,4 +42,24 @@
    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);
    }

    @RabbitListener(queues = QueueConstants.TFC_NODE_AGAIN)
    public void nodeMsg(Long id) {
        log.info("复投:{}", id);
        dappSystemService.achieveTreeV2(id);
    }
}