From af2d5942652584c65579894c4a4a680bc37dad20 Mon Sep 17 00:00:00 2001 From: dongyukun <1208714201@qq.com> Date: 星期六, 08 二月 2025 15:29:39 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java | 27 +++++++++++++++++---------- 1 files changed, 17 insertions(+), 10 deletions(-) diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java index 365de8a..f33f03d 100644 --- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java +++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java @@ -82,14 +82,13 @@ } schemeMap.clear(); Map<String, MdkScheduleRespDTO> resultMap = new HashMap<String, MdkScheduleRespDTO>(); - schemeList.forEach(item -> { - schemeMap.put(item.getCode(), item); - StScheduleSchemeDTO scheme = schemeList.get(0); + schemeList.forEach(scheme -> { + schemeMap.put(scheme.getCode(), scheme); MdkScheduleReqDTO dto = new MdkScheduleReqDTO(); dto.setScheduleTime(scheduleTime); dto.setScheduleCode(scheme.getCode()); MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto); - resultMap.put(item.getCode(), mdkScheduleRespDTO); + resultMap.put(scheme.getCode(), mdkScheduleRespDTO); }); if (CollectionUtils.isEmpty(resultMap)) { logger.info("resultMap为空"); @@ -104,17 +103,25 @@ if (entry.getKey().equals(CODE06)) { // 氧气班平衡计划,建议值写入测点 mdkApi.scheduleModelOut(entry.getValue()); + logger.info("氧气班平衡计划下发参数: {}", entry.getValue()); } else if (entry.getKey().equals(CODE05)) { String scheduleObj = schemeMap.get(CODE05).getScheduleObj(); - // double[] adviceValues = (double[]) entry.getValue().getResult().get("adviceValues"); - String yingdiAdvice = entry.getValue().getResult().get("yingdiAdvice").toString(); - saveScheduleSuggest("盈德中压建议调整量", yingdiAdvice, scheduleObj, scheduleTime); String faAdvice = entry.getValue().getResult().get("faAdvice").toString(); - saveScheduleSuggest("法夜空建议调整量", faAdvice, scheduleObj, scheduleTime); String hongAdvice = entry.getValue().getResult().get("hongAdvice").toString(); - saveScheduleSuggest("宏昌建议调整量", hongAdvice, scheduleObj, scheduleTime); String runAdvice = entry.getValue().getResult().get("RunAdvice").toString(); - saveScheduleSuggest("宏昌建议调整量", runAdvice, scheduleObj, scheduleTime); + String yingdiAdvice = entry.getValue().getResult().get("yingdiAdvice").toString(); + if(!yingdiAdvice.equals("压力正常")){ + saveScheduleSuggest("盈德中压建议调整量", yingdiAdvice, scheduleObj, scheduleTime); + } + if(!faAdvice.equals("压力正常")){ + saveScheduleSuggest("法夜空建议调整量", faAdvice, scheduleObj, scheduleTime); + } + if(!hongAdvice.equals("压力正常")){ + saveScheduleSuggest("宏昌建议调整量", hongAdvice, scheduleObj, scheduleTime); + } + if(!runAdvice.equals("压力正常")){ + saveScheduleSuggest("润忠建议调整量", runAdvice, scheduleObj, scheduleTime); + } } else if (entry.getKey().equals(CODE01)) { String scheduleObj = schemeMap.get(CODE01).getScheduleObj(); String advice = entry.getValue().getResult().get("advice").toString(); -- Gitblit v1.9.3