1

zyy3

2025-11-06 00f42b535ae2001903ef18168f16fbe477e59a23

 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,6 +112,7 @@

    @Override
    public void run(String... args) {
        try {
        // 初始化缓存
        //loadCacheService.loadcache();
        cryptosGetDataJob.start();
@@ -124,26 +126,26 @@
        contractOrderCalculationJob.start();
        //启动huobi wss行情

        log.info("开始Data初始化........");
            log.info("开始Data初始化........ {}");
        List<Item> items = new ArrayList<>(itemService.listWithOutCache());
        for (Item item : items) {
            AdjustmentValueCache.getCurrentValue().put(item.getSymbol(), item.getAdjustmentValue());
        }

            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();

        /**
@@ -154,7 +156,7 @@
        stockGetDataJob.start();
        //外汇实时行情
        forexGetDataJob.start();

            log.info("开始Data初始化4");
        //初始化雪球Cookies
        //xueQiuDataService.initXueQiuCookies();

@@ -162,7 +164,7 @@
        // 高低修正
        highLowHandleJob.start();
        highLowHandleJob.bulidHighLow();

            log.info("开始Data初始化5");
        stockGetMarketJob.start();
        //fakeSymbolGetDataJob.start();
        // 实时数据批量保存线程
@@ -178,7 +180,7 @@
         */
        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();
@@ -188,7 +190,7 @@
        tradePushJob.start();
        dataFrequencyServer.start();
        cleanDataJob.taskJob();
        log.info("完成Data初始化。");
            log.info("完成Data初始化。{}");

        /**
         * 币币委托单处理线程启动
@@ -196,5 +198,8 @@
        exchangeApplyOrderHandleJob.start();
        exchangeLeverApplyOrderHandleJob.start();
        //klineService.clean();
        }catch (Exception e) {
            log.error("Data初始化异常{}" , e.getMessage());
        }
    }
}