From 04d276a07f2774c1d9c107822f34233a58802239 Mon Sep 17 00:00:00 2001 From: dongyukun <1208714201@qq.com> Date: 星期四, 13 二月 2025 17:50:47 +0800 Subject: [PATCH] 转炉管网mq --- shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java | 9 ++++----- 1 files changed, 4 insertions(+), 5 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 da50f53..b9a5bf3 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为空"); @@ -109,7 +108,7 @@ String scheduleObj = schemeMap.get(CODE05).getScheduleObj(); String faAdvice = entry.getValue().getResult().get("faAdvice").toString(); String hongAdvice = entry.getValue().getResult().get("hongAdvice").toString(); - String runAdvice = entry.getValue().getResult().get("RunAdvice").toString(); + String runAdvice = entry.getValue().getResult().get("runAdvice").toString(); String yingdiAdvice = entry.getValue().getResult().get("yingdiAdvice").toString(); if(!yingdiAdvice.equals("压力正常")){ saveScheduleSuggest("盈德中压建议调整量", yingdiAdvice, scheduleObj, scheduleTime); -- Gitblit v1.9.3