| | |
| | | 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 |
| | |
| | | private RealtimePushJob realtimePushJob; |
| | | @Autowired |
| | | private CleanDataJob cleanDataJob; |
| | | // @Autowired etf |
| | | // private StockGetMarketJob stockGetMarketJob; |
| | | @Autowired |
| | | private StockGetMarketJob stockGetMarketJob; |
| | | /** |
| | | * 交割合约持仓单盈亏计算线程启动 |
| | | */ |
| | |
| | | // todo 先注释观察报错 |
| | | // futuresRecomConsumeServer.start(); |
| | | log.info("开始Data初始化........"); |
| | | stockGetDataJob.start(); |
| | | List<Item> items = itemService.list(); |
| | | for (Item item : items) { |
| | | AdjustmentValueCache.getCurrentValue().put(item.getSymbol(), item.getAdjustmentValue()); |
| | |
| | | highLowHandleJob.start(); |
| | | // stockGetMarketJob.start(); |
| | | // // 获取realtime实时数据 |
| | | // stockGetDataJob.start(); |
| | | // forexGetDataJob.start(); |
| | | |
| | | // forexGetDataJob.start(); 外汇 |
| | | cryptosGetDataJob.start(); |
| | | fakeSymbolGetDataJob.start(); |
| | | // 实时数据批量保存线程 |