From e4930c4a9ed4bc2198209370440ec19e1e0393ef Mon Sep 17 00:00:00 2001 From: wzy <wzy19931122ai@163.com> Date: Sat, 05 Jun 2021 15:42:53 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/rabbit/consumer/OtcConsumer.java | 10 ++++++++++ 1 files changed, 10 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/xcong/excoin/rabbit/consumer/OtcConsumer.java b/src/main/java/com/xcong/excoin/rabbit/consumer/OtcConsumer.java index a99af18..5ab02e6 100644 --- a/src/main/java/com/xcong/excoin/rabbit/consumer/OtcConsumer.java +++ b/src/main/java/com/xcong/excoin/rabbit/consumer/OtcConsumer.java @@ -86,4 +86,14 @@ public void delayOrder(String content) { log.info("--{}-->{}", new Date(), content); } + + + @RabbitListener(queues = RabbitMqConfig.QUEUE_ORDER_RETURN) + public void orderReturn(String content) { + log.info("收到返佣消息:{}", content); + OtcOrder order = otcOrderDao.selectOrderByOrderNoAndType(content, OtcEntrustOrder.ORDER_TYPE_B); + + + + } } -- Gitblit v1.9.1