From 3446c284c744bd6b1fb082a2a33aa263b2d475fe Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Fri, 10 Apr 2026 17:55:12 +0800
Subject: [PATCH] 1
---
trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java | 13 ++++++++++---
1 files changed, 10 insertions(+), 3 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java b/trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java
index 59bbfbf..7e1a25c 100644
--- a/trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java
+++ b/trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java
@@ -88,7 +88,7 @@
if (item == null || !item.getType().equalsIgnoreCase(Item.US_STOCKS)) {
return;
}
- //System.out.println(s);
+ System.out.println(s);
StockWSBean stockRealTimeBean = new StockWSBean();
stockRealTimeBean.setPid(stringObjectMap.get("Id"));
stockRealTimeBean.setLast(stringObjectMap.get("Last"));
@@ -103,6 +103,10 @@
stockRealTimeBean.setPrevClose(stringObjectMap.get("PrevClose"));
stockRealTimeBean.setSymbol(stringObjectMap.get("Symbol"));
stockRealTimeBean.setVolume(stringObjectMap.get("Volume"));
+ stockRealTimeBean.setPrevLast(stringObjectMap.get("PrevLast"));
+ stockRealTimeBean.setPrevChg(stringObjectMap.get("PrevChg"));
+ stockRealTimeBean.setPrevChgPct(stringObjectMap.get("PrevChgPct"));
+ stockRealTimeBean.setPrevPrevClose(stringObjectMap.get("PrevPrevClose"));
Realtime realtime = new Realtime();
/*realtime.setUuid(stringObjectMap.get("pid"));
realtime.setSymbol(stringObjectMap.get("symbol"));
@@ -129,7 +133,10 @@
realtime.setBid(new BigDecimal(stringObjectMap.get("Bid")).doubleValue());
realtime.setAsk(new BigDecimal(stringObjectMap.get("Ask")).doubleValue());
realtime.setVolume(new BigDecimal(stringObjectMap.get("Volume")).doubleValue());
-
+ realtime.setPrevLast(new BigDecimal(stringObjectMap.get("PrevLast")).doubleValue());
+ realtime.setPrevChg(new BigDecimal(stringObjectMap.get("PrevChg")).doubleValue());
+ realtime.setPrevChgPct(new BigDecimal(stringObjectMap.get("PrevChgPct")).doubleValue());
+ realtime.setPrevPrevClose(new BigDecimal(stringObjectMap.get("PrevPrevClose")).doubleValue());
DataCache.putRealtime(realtime.getSymbol(), realtime);
@@ -138,7 +145,7 @@
sendLoca(json);
} catch (Exception e) {
- log.error("处理WebSocket消息时发生错误: {}", e);
+ //log.error("处理WebSocket消息时发生错误: {}", e);
}
} else {
log.info("WebSocket心跳或认证响应: {}", s);
--
Gitblit v1.9.3