蒸汽调度建议

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

@@ -87,20 +87,14 @@
                return;
            }
            // 用户调整量
            JSONArray adviceValues = JSONArray.parseArray(mdkScheduleRespDTO.getResult().get("user_adjust").toString());
            List<BigDecimal> adviceValueList = new ArrayList<>();
            if (!CollectionUtils.isEmpty(adviceValues)) {
                for (int i = 0; i < adviceValues.size(); i++) {
                    adviceValueList.add(new BigDecimal(adviceValues.get(i).toString()));
                }
            }
            logger.info("adviceValues=" + JSONArray.toJSONString(adviceValueList));
            double[][] adviceValues = (double[][])mdkScheduleRespDTO.getResult().get("user_adjust");
            logger.info("adviceValues=" + Arrays.toString(adviceValues));

            Object jinfengAdvice = mdkScheduleRespDTO.getResult().get("jinfengAdvice");
            saveScheduleSuggest("锦丰调度建议", jinfengAdvice, scheme.getScheduleObj(), scheduleTime, adviceValueList.get(0), scheme.getAdjustRate());
            saveScheduleSuggest("锦丰调度建议", jinfengAdvice, scheme.getScheduleObj(), scheduleTime, new BigDecimal(adviceValues[0][0]), scheme.getAdjustRate());

            Object daxinAdvice = mdkScheduleRespDTO.getResult().get("daxinAdvice");
            saveScheduleSuggest("大新调度建议", daxinAdvice, scheme.getScheduleObj(), scheduleTime, adviceValueList.get(1), scheme.getAdjustRate());
            saveScheduleSuggest("大新调度建议", daxinAdvice, scheme.getScheduleObj(), scheduleTime, new BigDecimal(adviceValues[0][1]), scheme.getAdjustRate());

            Object daxinWarning = mdkScheduleRespDTO.getResult().get("daxinWarning");
            saveAlarmMessage("大新预警", daxinWarning, scheme.getScheduleObj(), scheduleTime);