From b39ae68459a34bf8950de5d53676d9bc08dca3da Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期三, 14 五月 2025 15:35:17 +0800
Subject: [PATCH] 日平衡调度建议保存
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunScheduleModuleTask.java | 46 ++++++++++++++++++++++++++++++++++++++--------
1 files changed, 38 insertions(+), 8 deletions(-)
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunScheduleModuleTask.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunScheduleModuleTask.java
index 0247081..1f34e28 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunScheduleModuleTask.java
+++ b/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("高炉实时调度建议");
--
Gitblit v1.9.3