日平衡调度建议保存

 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunScheduleModuleTask.java

@@ -50,25 +50,55 @@
            } else {
                logger.error("调度方案结果下发失败");
            }


            //日平衡调度建议保存
            Object time8 =  mdkScheduleRespDTO.getResult().get("Time8");
            Object time16 = mdkScheduleRespDTO.getResult().get("Time16");
            Object time24 =  mdkScheduleRespDTO.getResult().get("Time24");
            if (GasCode.equals(params)) {
                Map<String, Object> result = mdkScheduleRespDTO.getResult();
                result.entrySet().stream().forEach(entry -> {
                if(time8!=null) {
                    ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                    suggestDto.setTitle("日平衡建议");
                    suggestDto.setContent(entry.getValue().toString());
                    suggestDto.setContent(time8.toString());
                    suggestDto.setScheduleObj("GAS");
                    suggestDto.setScheduleTime(dto.getScheduleTime());
                    suggestDto.setCreateTime(calendar.getTime());
                    if (mcsApi.createScheduleSuggest(suggestDto)) {
                        logger.info("日平衡建议{" + entry.getValue().toString() + "}保存成功");
                        logger.info("日平衡建议{" + time8 + "}保存成功");
                    } else {
                        logger.error("日平衡建议保存失败");
                    }
                });
                }
                if(time16!=null) {
                    ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                    suggestDto.setTitle("日平衡建议");
                    suggestDto.setContent(time16.toString());
                    suggestDto.setScheduleObj("GAS");
                    suggestDto.setScheduleTime(dto.getScheduleTime());
                    suggestDto.setCreateTime(calendar.getTime());
                    if (mcsApi.createScheduleSuggest(suggestDto)) {
                        logger.info("日平衡建议{" + time16 + "}保存成功");
                    } else {
                        logger.error("日平衡建议保存失败");
                    }
                }
                if(time24!=null) {
                    ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                    suggestDto.setTitle("日平衡建议");
                    suggestDto.setContent(time24.toString());
                    suggestDto.setScheduleObj("GAS");
                    suggestDto.setScheduleTime(dto.getScheduleTime());
                    suggestDto.setCreateTime(calendar.getTime());
                    if (mcsApi.createScheduleSuggest(suggestDto)) {
                        logger.info("日平衡建议{" + time24 + "}保存成功");
                    } else {
                        logger.error("日平衡建议保存失败");
                    }
                }
            }
            //转炉实时调度建议保存
            Object LDG = mdkScheduleRespDTO.getResult().get("suggestions");
            Object LDG = mdkScheduleRespDTO.getResult().get("suggestion");
            if (LdgCode.equals(params) && LDG != null) {
                ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                suggestDto.setTitle("转炉实时调度建议");
@@ -83,7 +113,7 @@
                }
            }
            //焦炉实时调度建议保存
            Object COG = mdkScheduleRespDTO.getResult().get("suggestions");
            Object COG = mdkScheduleRespDTO.getResult().get("suggestion");
            if (CogCode.equals(params) && COG != null) {
                ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                suggestDto.setTitle("焦炉实时调度建议");
@@ -98,7 +128,7 @@
                }
            }
            //高炉实时调度建议保存
            Object BFG = mdkScheduleRespDTO.getResult().get("suggestions");
            Object BFG = mdkScheduleRespDTO.getResult().get("suggestion");
            if (BfgCode.equals(params) && BFG != null) {
                ScheduleSuggestRespDTO suggestDto = new ScheduleSuggestRespDTO();
                suggestDto.setTitle("高炉实时调度建议");