| | |
|---|
| | | 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); |
|---|
| | | xchProfitService.autoBeAgent(Long.parseLong(content)); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
