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 | 15 ++++++++++++---
1 files changed, 12 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 e158ed7..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"));
@@ -102,6 +102,11 @@
stockRealTimeBean.setOpen(stringObjectMap.get("Open"));
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"));
@@ -127,7 +132,11 @@
realtime.setChangeRatio(new BigDecimal(stringObjectMap.get("ChgPct")).doubleValue());
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);
@@ -136,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