From 74ca5bc0f40e3b91464c8972392271d24dd5f066 Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Mon, 14 Sep 2020 11:05:48 +0800
Subject: [PATCH] 撮合交易代码提交
---
src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java | 12 ++++++++++--
1 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java b/src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java
index 9b03546..9c9793a 100644
--- a/src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java
+++ b/src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java
@@ -14,6 +14,7 @@
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
+import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
@@ -44,8 +45,8 @@
*/
@RabbitListener(queues = RabbitMqConfig.QUEUE_TRADE_PLATE)
public void tradePlate(String content) {
- log.info("#---->{}#", content);
- tradePlateSendWebSocket.sendMessagePlate(content,null);
+ log.info("#盘口信息消费者---->{}#", content);
+ tradePlateSendWebSocket.sendMessagePlate("NEKK/USDT",content,null);
}
/**
@@ -56,6 +57,13 @@
public void handleTradeExchange(String content) {
log.info("#---->{}#", content);
List<ExchangeTrade> exchangeTrades = JSONObject.parseArray(content, ExchangeTrade.class);
+ // 去掉空的 暂时这样
+ Iterator<ExchangeTrade> iterator = exchangeTrades.iterator();
+ while (iterator.hasNext()){
+ if(iterator.next()==null){
+ iterator.remove();
+ }
+ }
// 处理K线 并更新最新价
handleKlineService.handleExchangeOrderToKline(exchangeTrades);
// 推送最新K线
--
Gitblit v1.9.1