| | |
| | | |
| | | // 保存调度建议 |
| | | this.saveScheduleSuggest("空压机启动调度建议", mdkScheduleRespDTO.getResult().get("dispatchStart"), scheme.getScheduleObj(), |
| | | scheduleTime, scheme.getAdjustRate()); |
| | | scheduleTime, scheme.getAdjustRate(), scheme.getModelId(), scheme.getId()); |
| | | this.saveScheduleSuggest("空压机关停调度建议", mdkScheduleRespDTO.getResult().get("dispatchClose"), scheme.getScheduleObj(), |
| | | scheduleTime, scheme.getAdjustRate()); |
| | | scheduleTime, scheme.getAdjustRate(), scheme.getModelId(), scheme.getId()); |
| | | logger.info(params + "调度方案执行完成"); |
| | | } catch (Exception ex) { |
| | | logger.error("RunScheduleAirDispatchTask运行异常"); |
| | |
| | | logger.info("RunScheduleAirDispatchTask运行完成"); |
| | | } |
| | | |
| | | private void saveScheduleSuggest(String title, Object content, String scheduleObj, Date scheduleTime, int adjustRate) { |
| | | private void saveScheduleSuggest(String title, Object content, String scheduleObj, Date scheduleTime, int adjustRate, String modelId, String schemeId) { |
| | | if (content == null) { |
| | | logger.info(title + "调整值为空,不产生建议"); |
| | | return; |
| | |
| | | suggest.setContent(content.toString()); |
| | | suggest.setScheduleObj(scheduleObj); |
| | | suggest.setScheduleTime(scheduleTime); |
| | | suggest.setModelId(modelId); |
| | | suggest.setSchemeId(schemeId); |
| | | suggest.setSort(0); |
| | | mcsApi.createScheduleSuggest(suggest); |
| | | } |