From 5e57de9b12ee136e45ce5754c7fe2e7eb12af05a Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Fri, 12 Jun 2026 18:35:45 +0800
Subject: [PATCH] 1
---
trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java
index e1553ca..2790de2 100644
--- a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java
+++ b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/RealtimePushJob.java
@@ -12,6 +12,7 @@
import com.yami.trading.huobi.data.TimeZoneConverterService;
import com.yami.trading.huobi.websocket.WebSocketServer;
import com.yami.trading.huobi.websocket.WebSocketSession;
+import com.yami.trading.service.item.ItemPreMarketService;
import com.yami.trading.service.item.ItemService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -34,6 +35,9 @@
public class RealtimePushJob implements Runnable {
@Autowired
private ItemService itemService;
+
+ @Autowired
+ private ItemPreMarketService itemPreMarketService;
@Autowired
private TimeZoneConverterService timeZoneConverterService;
@@ -76,6 +80,13 @@
Realtime realtimeData = DataCache.getRealtime(symbol);
if (realtimeData == null) {
log.error("realtimeHandle 获取{} 数据为空", symbol);
+ } else if (itemPreMarketService != null) {
+ try {
+ Realtime copy = (Realtime) realtimeData.clone();
+ realtimeData = itemPreMarketService.applyPreMarketPrice(copy);
+ } catch (CloneNotSupportedException e) {
+ log.warn("clone realtime failed, symbol={}", symbol, e);
+ }
}
this.realtimeRevise(realtimeResultMap, realtimeData, symbol);
}
--
Gitblit v1.9.3