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/producer/OtcProducter.java | 7 +++++++
src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java | 15 +++++++++++++++
src/main/java/com/xcong/excoin/rabbit/consumer/OtcConsumer.java | 10 ++++++++++
3 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
index d43efca..084d625 100644
--- a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
+++ b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
@@ -134,6 +134,10 @@
public static final String QUEUE_TRC20_BLOCK = "QUEUE_TRC20_BLOCK";
public static final String ROUTING_TRC20_BLOCK = "ROUTING_TRC20_BLOCK";
+
+ public static final String QUEUE_ORDER_RETURN = "QUEUE_ORDER_RETURN";
+ public static final String ROUTING_ORDER_RETURN = "ROUTING_ORDER_RETURN";
+
@Resource
private ConnectionFactory connectionFactory;
@@ -199,6 +203,17 @@
}
@Bean
+ public Queue orderReturnQueue() {
+ return new Queue(QUEUE_ORDER_RETURN);
+ }
+
+ @Bean
+ public Binding orderReturnBinding() {
+ return BindingBuilder.bind(orderReturnQueue()).to(defaultExchange()).with(ROUTING_ORDER_RETURN);
+ }
+
+
+ @Bean
public Queue trc20Queue() {
return new Queue(QUEUE_TRC20_BLOCK);
}
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);
+
+
+
+ }
}
diff --git a/src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java b/src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java
index e52c731..c271571 100644
--- a/src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java
+++ b/src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java
@@ -54,6 +54,13 @@
});
}
+ public void sendOrderReturn(String content) {
+ log.info("发送返佣消息");
+ CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
+ rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_ONE, RabbitMqConfig.ROUTING_ORDER_RETURN, content, correlationData);
+
+ }
+
@Override
public void confirm(CorrelationData correlationData, boolean b, String s) {
--
Gitblit v1.9.1