shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java

@@ -27,13 +27,17 @@
 * 宏昌建议送出量   hongAdvice
 * 润忠建议送出量   RunAdvice
 * 调整值   adviceValues
 * <p>
 *
 * 05
 * 氧气系统优化调度决策
 * 盈德中压建议调整量   yingdiAdvice
 * 法夜空建议调整量   faAdvice
 * 宏昌建议调整量   hongAdvice
 * 润忠建议调整量   RunAdvice
 *
 * 01
 * 氮气预警模型
 * 预警信号   advice
 *
 * @author PanZhibao
 * @Description
@@ -54,6 +58,8 @@
    private static final String CODE06 = "06";

    private static final String CODE05 = "05";

    private static final String CODE01 = "01";

    @Override
    public void run(String params) {
@@ -90,7 +96,7 @@
                return;
            }
            for (Map.Entry<String, MdkScheduleRespDTO> entry : resultMap.entrySet()) {
                if (CommonConstant.MDK_STATUS_100.equals(entry.getValue().getStatusCode())) {
                if (!CommonConstant.MDK_STATUS_100.equals(entry.getValue().getStatusCode())) {
                    logger.info("调度结果异常，STATUS=" + entry.getValue().getStatusCode());
                    continue;
                }
@@ -109,9 +115,12 @@
                    saveScheduleSuggest("宏昌建议调整量", hongAdvice, scheduleObj, scheduleTime);
                    String runAdvice = entry.getValue().getResult().get("RunAdvice").toString();
                    saveScheduleSuggest("宏昌建议调整量", runAdvice, scheduleObj, scheduleTime);
                } else if (entry.getKey().equals(CODE01)) {
                    String scheduleObj = schemeMap.get(CODE01).getScheduleObj();
                    String advice = entry.getValue().getResult().get("advice").toString();
                    saveScheduleSuggest("氮气预警", advice, scheduleObj, scheduleTime);
                }
            }

            logger.info(params + "调度方案执行完成");
        } catch (Exception ex) {
            logger.error("RunScheduleOnaOptTask运行异常");