20210528

xiaoyong931011

2021-05-28 a7b10c7fb28552e71e980d97a6b23c21cbcb212a

 src/main/java/com/xcong/excoin/rabbit/producer/YunDingProducter.java

@@ -25,7 +25,14 @@
    }

    public void sendYunDingUsdtProfit(Long id) {
        log.info("发送购买矿机USDT返利消息:{}", id);
        CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_XCH, RabbitMqConfig.ROUTING_KEE_XCH_USDT_PRIFIT, id.toString(), correlationData);
    }

    public void sendYunDingAutoAgent(Long memberId) {
        log.info("发送自动升级代理消息:{}", memberId);
        CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_XCH, RabbitMqConfig.ROUTING_KEY_XCH_AUTO_AGENT, memberId.toString(), correlationData);
    }
}