From 6e09aa2c20ff596c2dfae165d94a9af8ce281030 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Fri, 05 Jun 2026 10:12:12 +0800
Subject: [PATCH] 1
---
trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/KlineInitServiceImpl.java | 31 +++++++++++++------------------
1 files changed, 13 insertions(+), 18 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/KlineInitServiceImpl.java b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/KlineInitServiceImpl.java
index f487b7f..52a6b80 100644
--- a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/KlineInitServiceImpl.java
+++ b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/KlineInitServiceImpl.java
@@ -35,32 +35,27 @@
public void klineInit(String symbols) {
logger.info("当前开始初始化币对k线图: {}", symbols);
if (!symbols.contains(",")) {
- Item bySymbol = itemService.findBySymbol(symbols);
- if (Item.cryptos.equalsIgnoreCase(bySymbol.getType())) {
- cryptosKlineService.init(symbols);
- } else if ("1".equalsIgnoreCase(bySymbol.getFake())) {
- fakeKlineInitService.saveInit(symbols);
- } else {
- saveInit(symbols);
- }
+ initOne(symbols);
} else {
String[] symbolsArrays = symbols.split(",");
for (String symbol : symbolsArrays) {
threadPoolComponent.getExecutor().submit(() -> {
logger.info("当前开始初始化币对单个k线图: {}", symbol);
- Item bySymbol = itemService.findBySymbol(symbol);
- if (Item.cryptos.equalsIgnoreCase(bySymbol.getType())) {
- cryptosKlineService.init(symbol);
- } else if ("1".equalsIgnoreCase(bySymbol.getFake())) {
- fakeKlineInitService.saveInit(symbols);
- } else {
- saveInit(symbol);
- }
+ initOne(symbol);
logger.info("当前开始初始化完成币对k线图: {}", symbol);
});
-
}
+ }
+ }
+ private void initOne(String symbol) {
+ Item bySymbol = itemService.findBySymbol(symbol);
+ if (bySymbol.isFake()) {
+ fakeKlineInitService.saveInit(symbol);
+ } else if (Item.cryptos.equalsIgnoreCase(bySymbol.getType())) {
+ cryptosKlineService.init(symbol);
+ } else {
+ saveInit(symbol);
}
}
@@ -68,7 +63,7 @@
private final void saveInit(String symbol) {
Item bySymbol = itemService.findBySymbol(symbol);
// 机器人的价格，无需初始化
- if ("1".equalsIgnoreCase(bySymbol.getFake())) {
+ if (bySymbol.isFake()) {
return;
}
Map<String, List<Kline>> dailyWeekMonthHistoryMap = hobiDataService.getDailyWeekMonthHistory(symbol);
--
Gitblit v1.9.3