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

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

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

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

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