20210528

xiaoyong931011

2021-05-28 a7b10c7fb28552e71e980d97a6b23c21cbcb212a

 src/main/java/com/xcong/excoin/rabbit/consumer/YunDingConsumer.java

@@ -19,9 +19,22 @@
    private XchProfitService xchProfitService;

    @RabbitListener(queues = RabbitMqConfig.QUEUE_XCH_USDT_PRIFIT)
    public void addFollowOrder(Message message, Channel channel) {
    public void xchUsdtProfit(Message message, Channel channel) {
        String content = new String(message.getBody());
        log.info("USDT返利 : {}", content);
        xchProfitService.usdtProfitDistributorByOrderId(Long.parseLong(content));
    }

    @RabbitListener(queues = RabbitMqConfig.QUEUE_XCH_AUTO_AGENT)
    public void xchAutoAgent(Message message, Channel channel) {
        String content = new String(message.getBody());
        log.info("自动升级代理消息 : {}", content);
        try {
            xchProfitService.autoBeAgent(Long.parseLong(content));
        } catch (Exception e) {
            log.info("错误",e);
        }
    }


}