From d4be4cc69f18b01cc39bd3f9dc9497a828848ca8 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Tue, 30 Sep 2025 11:18:44 +0800
Subject: [PATCH] 1
---
trading-order-admin/src/main/java/com/yami/trading/admin/task/InitHandle.java | 21 +++++++++++----------
1 files changed, 11 insertions(+), 10 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/admin/task/InitHandle.java b/trading-order-admin/src/main/java/com/yami/trading/admin/task/InitHandle.java
index 8ea6c61..65c5759 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/admin/task/InitHandle.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/admin/task/InitHandle.java
@@ -48,10 +48,10 @@
protected KlineService klineService;
@Autowired
protected HighLowHandleJob highLowHandleJob;
-// @Autowired 外汇
-// protected StockGetDataJob stockGetDataJob;
-// @Autowired
-// protected ForexGetDataJob forexGetDataJob;
+ @Autowired
+ protected StockGetDataJob stockGetDataJob;
+ @Autowired
+ protected ForexGetDataJob forexGetDataJob;
@Autowired
protected CryptosGetDataJob cryptosGetDataJob;
@Autowired
@@ -77,8 +77,8 @@
private RealtimePushJob realtimePushJob;
@Autowired
private CleanDataJob cleanDataJob;
-// @Autowired etf
-// private StockGetMarketJob stockGetMarketJob;
+ @Autowired
+ private StockGetMarketJob stockGetMarketJob;
/**
* 交割合约持仓单盈亏计算线程启动
*/
@@ -112,6 +112,7 @@
// todo 先注释观察报错
// futuresRecomConsumeServer.start();
log.info("开始Data初始化........");
+ stockGetDataJob.start();
List<Item> items = itemService.list();
for (Item item : items) {
AdjustmentValueCache.getCurrentValue().put(item.getSymbol(), item.getAdjustmentValue());
@@ -130,15 +131,15 @@
}
klineLoadCache.loadCache();
-// String symbols = items.stream().map(Item::getSymbol).collect(Collectors.joining(","));
+ String symbols = items.stream().map(Item::getSymbol).collect(Collectors.joining(","));
// 数据有问题初始化一下
-// klineInitService.klineInit(symbols); 外汇
+ klineInitService.klineInit(symbols);
// 高低修正
highLowHandleJob.start();
// stockGetMarketJob.start();
// // 获取realtime实时数据
-// stockGetDataJob.start();
-// forexGetDataJob.start();
+
+// forexGetDataJob.start(); 外汇
cryptosGetDataJob.start();
fakeSymbolGetDataJob.start();
// 实时数据批量保存线程
--
Gitblit v1.9.3