ipo

zyy

2026-01-09 7d9bf660d08d1b39af670e54dedf784e32080dc2

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