From 5575818556096be1dadaf5ff356b5db4c832aaa2 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Wed, 26 May 2021 19:27:09 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/rabbit/consumer/OperateOrderPriceConsumer.java | 42 ++++++++++++++++++++++++++----------------
1 files changed, 26 insertions(+), 16 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/rabbit/consumer/OperateOrderPriceConsumer.java b/src/main/java/com/xcong/excoin/rabbit/consumer/OperateOrderPriceConsumer.java
index 2d2ff3d..be949a2 100644
--- a/src/main/java/com/xcong/excoin/rabbit/consumer/OperateOrderPriceConsumer.java
+++ b/src/main/java/com/xcong/excoin/rabbit/consumer/OperateOrderPriceConsumer.java
@@ -5,6 +5,8 @@
import com.xcong.excoin.configurations.RabbitMqConfig;
import com.xcong.excoin.rabbit.pricequeue.OrderModel;
import com.xcong.excoin.rabbit.pricequeue.OrderOperatePriceService;
+import com.xcong.excoin.rabbit.pricequeue.whole.WholePriceDataModel;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
@@ -14,32 +16,40 @@
/**
* 用户修改止损止盈价格、提价限价委托、下单爆仓价等消息
* 后台打包开启 APP 不开启
+ * @author helius
*/
+@Slf4j
@Component
-@ConditionalOnProperty(prefix="app",name="newest-price-update-job",havingValue="true")
+@ConditionalOnProperty(prefix = "app", name = "newest-price-update-job", havingValue = "true")
public class OperateOrderPriceConsumer {
-
- /**
- * 用户修改止损止盈价格、提价限价委托、下单爆仓价等消息
- * @date 2019年4月19日
- * @param message 消息体
- * @param channel 信道
- */
- @RabbitListener(queues = RabbitMqConfig.QUEUE_PRICEOPERATE)
- public void onMessageMorePro(Message message, Channel channel) {
+ /**
+ * 用户修改止损止盈价格、提价限价委托、下单爆仓价等消息
+ *
+ * @param message 消息体
+ * @param channel 信道
+ * @date 2019年4月19日
+ */
+ @RabbitListener(queues = RabbitMqConfig.QUEUE_PRICEOPERATE)
+ public void onMessageMorePro(Message message, Channel channel) {
String content = new String(message.getBody());
- System.out.println("我收到了用户的订单操作消息："+content);
- // 操作前的map
+ log.info("我收到了用户的订单操作消息:{}", content);
+ // 操作前的map
// 转为model
- OrderModel orderModel = JSONObject.parseObject(content, OrderModel.class);
- // 向优先队列添加
- OrderOperatePriceService.dealWithNewMq(orderModel);
+ OrderModel orderModel = JSONObject.parseObject(content, OrderModel.class);
+ // 向优先队列添加
+ OrderOperatePriceService.dealWithNewMq(orderModel);
- }
+ }
+ @RabbitListener(queues = RabbitMqConfig.QUEUE_WHOLE_PRICE)
+ public void onMessageWholePrice(Message message, Channel channel) {
+ String content = new String(message.getBody());
+ log.info("我收到了用户的全仓价格消息 : {}", content);
+ OrderOperatePriceService.wholePriceDataOperation(Long.parseLong(content));
+ }
}
--
Gitblit v1.9.1