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-admin/src/main/java/com/yami/trading/api/controller/KlineController.java | 6 ++++++
1 files changed, 6 insertions(+), 0 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/api/controller/KlineController.java b/trading-order-admin/src/main/java/com/yami/trading/api/controller/KlineController.java
index e9e33e8..621ea34 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/api/controller/KlineController.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/api/controller/KlineController.java
@@ -10,6 +10,7 @@
import com.yami.trading.huobi.data.TimeZoneConverterService;
import com.yami.trading.huobi.tradingview.service.TradingViewService;
import com.yami.trading.service.data.DataService;
+import com.yami.trading.service.item.ItemPreMarketService;
import com.yami.trading.service.item.ItemService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
@@ -37,6 +38,8 @@
public class KlineController {
@Autowired
private ItemService itemService;
+ @Autowired
+ private ItemPreMarketService itemPreMarketService;
@Autowired
@Qualifier("dataService")
private DataService dataService;
@@ -69,6 +72,7 @@
// Fetch Kline data from service (for cryptos)
List<Kline> data = this.dataService.kline(symbol, line);
+ itemPreMarketService.applyPreMarketToLatestKline(symbol, data);
// Return an empty response if no data is found
if (Objects.isNull(data)) {
@@ -109,6 +113,7 @@
if (cachedData != null && lastUpdateTime != null) {
long currentTime = System.currentTimeMillis();
if ((currentTime - lastUpdateTime) <= TimeUnit.MINUTES.toMillis(5)) {
+ itemPreMarketService.applyPreMarketToLatestKline(symbol, cachedData);
return Result.succeed(this.build(cachedData, twForLine, symbol));
}
}
@@ -122,6 +127,7 @@
// Format Kline data timestamps
formatKlineTimestamps(data, line);
+ itemPreMarketService.applyPreMarketToLatestKline(symbol, data);
return Result.succeed(this.build(data, line, symbol));
}
--
Gitblit v1.9.3