| | |
| | | // todo 先注释观察报错 |
| | | // futuresRecomConsumeServer.start(); |
| | | log.info("开始Data初始化........"); |
| | | contractOrderCalculationJob.start(); |
| | | List<Item> items = itemService.list(); |
| | | for (Item item : items) { |
| | | AdjustmentValueCache.getCurrentValue().put(item.getSymbol(), item.getAdjustmentValue()); |
| | |
| | | } |
| | | |
| | | 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(); |
| | |
| | | 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(); |