From 16479558108f8da4be9fc37f084167b2d7a0fd38 Mon Sep 17 00:00:00 2001
From: zyy3 <zyy3@zy.com>
Date: Fri, 26 Sep 2025 23:19:07 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/9.17' into 9.17
---
trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/CryptosKlineServiceImpl.java | 30 ++++++++++++++++++++++++++++++
1 files changed, 30 insertions(+), 0 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/CryptosKlineServiceImpl.java b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/CryptosKlineServiceImpl.java
index 2c4e4c7..bf74cac 100644
--- a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/CryptosKlineServiceImpl.java
+++ b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/CryptosKlineServiceImpl.java
@@ -38,6 +38,19 @@
private NamedParameterJdbcOperations namedParameterJdbcTemplate;
@Override
+ public void initBySql(String symbol) {
+ this.bulidBySql(symbol, Kline.PERIOD_1MIN);
+ this.bulidBySql(symbol, Kline.PERIOD_5MIN);
+ this.bulidBySql(symbol, Kline.PERIOD_15MIN);
+ this.bulidBySql(symbol, Kline.PERIOD_30MIN);
+ this.bulidBySql(symbol, Kline.PERIOD_60MIN);
+ this.bulidBySql(symbol, Kline.PERIOD_4HOUR);
+ this.bulidBySql(symbol, Kline.PERIOD_1DAY);
+ this.bulidBySql(symbol, Kline.PERIOD_1MON);
+ this.bulidBySql(symbol, Kline.PERIOD_1WEEK);
+ }
+
+ @Override
public void init(String symbol) {
this.bulid(symbol, Kline.PERIOD_1MIN);
this.bulid(symbol, Kline.PERIOD_5MIN);
@@ -70,6 +83,23 @@
}
+ public void bulidBySql(String symbol, String line) {
+ RequestDataHelper.set("symbol", symbol);
+ LambdaQueryWrapper<Kline> queryWrapper = new LambdaQueryWrapper<Kline>()
+ .eq(Kline::getSymbol, symbol)
+ .eq(Kline::getPeriod, line)
+ .orderByAsc(Kline::getTs);
+ List<Kline> list = klineDBService.list(queryWrapper);
+
+ KlineTimeObject model = new KlineTimeObject();
+ Collections.sort(list); // 按时间升序
+ model.setKline(list);
+ model.setLastTime(new Date());
+ DataCache.putKline(symbol, line, model);
+ RequestDataHelper.clear();
+
+ }
+
public void bulid(String symbol, String line) {
RequestDataHelper.set("symbol", symbol);
List<Kline> list = hobiDataService.kline(itemService.findBySymbol(symbol).getSymbol(), line, null,
--
Gitblit v1.9.3