1

zj

2025-09-30 d4be4cc69f18b01cc39bd3f9dc9497a828848ca8

 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();
        // 实时数据批量保存线程