1

zj

2025-10-14 2cfba883471ec6dabd94ae07e5f7df5dc9df6912

 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;
    /**
     * 交割合约持仓单盈亏计算线程启动
     */
@@ -112,6 +112,7 @@
        // todo 先注释观察报错
//      futuresRecomConsumeServer.start();
        log.info("开始Data初始化........");
        contractOrderCalculationJob.start();
        List<Item> items = itemService.list();
        for (Item item : items) {
            AdjustmentValueCache.getCurrentValue().put(item.getSymbol(), item.getAdjustmentValue());
@@ -135,10 +136,10 @@
         klineInitService.klineInit(symbols);
        // 高低修正
        highLowHandleJob.start();
        stockGetMarketJob.start();
        // 获取realtime实时数据
        stockGetDataJob.start();
        forexGetDataJob.start();
//        stockGetMarketJob.start();
//        // 获取realtime实时数据
//        stockGetDataJob.start();
//        forexGetDataJob.start();
        cryptosGetDataJob.start();
        fakeSymbolGetDataJob.start();
        // 实时数据批量保存线程
@@ -160,7 +161,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());
        contractOrderCalculationJob.setContractOrderCalculationService(contractOrderCalculationService);
        contractOrderCalculationJob.start();


        // todo 做模块判断,后续打开
        futuresOrderCalculationJob.start();