项目提交

zj

2025-02-08 75018b2f492444248d8b476d9703bb312d2befc3

 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
    private StockGetMarketJob stockGetMarketJob;
//    @Autowired etf
//    private StockGetMarketJob stockGetMarketJob;
    /**
     * 交割合约持仓单盈亏计算线程启动
     */
@@ -130,15 +130,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();
//        stockGetMarketJob.start();
//        // 获取realtime实时数据
//        stockGetDataJob.start();
//        forexGetDataJob.start();
        cryptosGetDataJob.start();
        fakeSymbolGetDataJob.start();
        // 实时数据批量保存线程