From 00f42b535ae2001903ef18168f16fbe477e59a23 Mon Sep 17 00:00:00 2001
From: zyy3 <zyy3@zy.com>
Date: Thu, 06 Nov 2025 16:40:30 +0800
Subject: [PATCH] 1
---
trading-order-huobi/src/main/java/com/yami/trading/huobi/task/InitHandle.java | 163 ++++++++++++++++++++++++++++--------------------------
1 files changed, 84 insertions(+), 79 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/InitHandle.java b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/InitHandle.java
index 0fe3335..4d672af 100644
--- a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/InitHandle.java
+++ b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/InitHandle.java
@@ -30,6 +30,7 @@
import org.springframework.stereotype.Component;
import java.util.ArrayList;
+import java.util.Date;
import java.util.List;
@Slf4j
@@ -111,90 +112,94 @@
@Override
public void run(String... args) {
- // 初始化缓存
- //loadCacheService.loadcache();
- cryptosGetDataJob.start();
- tipService.init();
- futuresLoadCacheService.loadcache();
- financeLoadCacheService.loadcache();
- // 已经加了注解
+ try {
+ // 初始化缓存
+ //loadCacheService.loadcache();
+ cryptosGetDataJob.start();
+ tipService.init();
+ futuresLoadCacheService.loadcache();
+ financeLoadCacheService.loadcache();
+ // 已经加了注解
// minerLoadCacheService.loadcache();
- // todo 先注释观察报错
+ // todo 先注释观察报错
// futuresRecomConsumeServer.start();
- contractOrderCalculationJob.start();
- //启动huobi wss行情
+ contractOrderCalculationJob.start();
+ //启动huobi wss行情
- log.info("开始Data初始化........");
- List<Item> items = new ArrayList<>(itemService.listWithOutCache());
- for (Item item : items) {
- AdjustmentValueCache.getCurrentValue().put(item.getSymbol(), item.getAdjustmentValue());
- }
-
- for (Item item : items) {
- Realtime realtime = dataDBService.get(item.getSymbol());
- if (realtime != null) {
- DataCache.putRealtime(item.getSymbol(), realtime);
+ log.info("开始Data初始化........ {}");
+ List<Item> items = new ArrayList<>(itemService.listWithOutCache());
+ for (Item item : items) {
+ AdjustmentValueCache.getCurrentValue().put(item.getSymbol(), item.getAdjustmentValue());
}
- }
-
- for (Item item : items) {
- if(Item.cryptos.equalsIgnoreCase(item.getType())){
- List<Realtime> list = this.dataDBService.findRealtimeOneDay(item.getSymbol());
- DataCache.putCryptosRealtimeHistory(item.getSymbol(), list);
+ log.info("开始Data初始化1");
+ for (Item item : items) {
+ Realtime realtime = dataDBService.get(item.getSymbol());
+ if (realtime != null) {
+ DataCache.putRealtime(item.getSymbol(), realtime);
+ }
}
+ log.info("开始Data初始化2");
+ for (Item item : items) {
+ if(Item.cryptos.equalsIgnoreCase(item.getType())){
+ List<Realtime> list = this.dataDBService.findRealtimeOneDay(item.getSymbol());
+ DataCache.putCryptosRealtimeHistory(item.getSymbol(), list);
+ }
+ }
+ log.info("开始Data初始化3");
+ tradingViewJob.start();
+
+ /**
+ * 实时行情价格
+ */
+
+ // 极度证券 wss行情，包含 A股，美股，港股，台股
+ stockGetDataJob.start();
+ //外汇实时行情
+ forexGetDataJob.start();
+ log.info("开始Data初始化4");
+ //初始化雪球Cookies
+ //xueQiuDataService.initXueQiuCookies();
+
+ klineLoadCache.loadCache();
+ // 高低修正
+ highLowHandleJob.start();
+ highLowHandleJob.bulidHighLow();
+ log.info("开始Data初始化5");
+ stockGetMarketJob.start();
+ //fakeSymbolGetDataJob.start();
+ // 实时数据批量保存线程
+ saveRealtimeServer.start();
+ klineCacheJob.start();
+
+ /**
+ * 委托单处理线程启动
+ */
+ contractApplyOrderHandleJob.start();
+ /**
+ * 持仓单盈亏计算线程启动
+ */
+ contractOrderCalculationService.setOrder_close_line(this.sysparaService.find("order_close_line").getBigDecimal());
+ contractOrderCalculationService.setOrder_close_line_type(this.sysparaService.find("order_close_line_type").getInteger());
+ log.info("开始Data初始化6");
+
+ // todo 做模块判断,后续打开
+ futuresOrderCalculationJob.start();
+
+ realtimePushJob.start();
+ depthPushJob.start();
+ tradePushJob.start();
+ dataFrequencyServer.start();
+ cleanDataJob.taskJob();
+ log.info("完成Data初始化。{}");
+
+ /**
+ * 币币委托单处理线程启动
+ */
+ exchangeApplyOrderHandleJob.start();
+ exchangeLeverApplyOrderHandleJob.start();
+ //klineService.clean();
+ }catch (Exception e) {
+ log.error("Data初始化异常{}" , e.getMessage());
}
-
- tradingViewJob.start();
-
- /**
- * 实时行情价格
- */
-
- // 极度证券 wss行情，包含 A股，美股，港股，台股
- stockGetDataJob.start();
- //外汇实时行情
- forexGetDataJob.start();
-
- //初始化雪球Cookies
- //xueQiuDataService.initXueQiuCookies();
-
- klineLoadCache.loadCache();
- // 高低修正
- highLowHandleJob.start();
- highLowHandleJob.bulidHighLow();
-
- stockGetMarketJob.start();
- //fakeSymbolGetDataJob.start();
- // 实时数据批量保存线程
- saveRealtimeServer.start();
- klineCacheJob.start();
-
- /**
- * 委托单处理线程启动
- */
- contractApplyOrderHandleJob.start();
- /**
- * 持仓单盈亏计算线程启动
- */
- contractOrderCalculationService.setOrder_close_line(this.sysparaService.find("order_close_line").getBigDecimal());
- contractOrderCalculationService.setOrder_close_line_type(this.sysparaService.find("order_close_line_type").getInteger());
-
-
- // todo 做模块判断,后续打开
- futuresOrderCalculationJob.start();
-
- realtimePushJob.start();
- depthPushJob.start();
- tradePushJob.start();
- dataFrequencyServer.start();
- cleanDataJob.taskJob();
- log.info("完成Data初始化。");
-
- /**
- * 币币委托单处理线程启动
- */
- exchangeApplyOrderHandleJob.start();
- exchangeLeverApplyOrderHandleJob.start();
- //klineService.clean();
}
}
--
Gitblit v1.9.3