From fab65dab174e035785c06357b4818c1588d4f4a9 Mon Sep 17 00:00:00 2001
From: dengzedong <dengzedong@email>
Date: 星期三, 25 六月 2025 18:22:53 +0800
Subject: [PATCH] 焦炉煤气柜柜位 焦炉煤气富余量
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunScheduleModuleTask.java | 23 ++++++++++++++++++-----
1 files changed, 18 insertions(+), 5 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 0d2400c..649f02e 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
@@ -131,7 +131,9 @@
// 调整速率
String scheduleObjLDG = "LDG";
BigDecimal adjustValue = new BigDecimal(mdkScheduleRespDTO.getResult().get(flag).toString());
- if (gasAdjustMode.containsKey(scheduleObjLDG) && gasAdjustMode.get(scheduleObjLDG).equals(adjustValue) &&
+ if (adjustValue.compareTo(BigDecimal.ZERO) == 0) {
+ logger.info("转炉实时调度建议 flag为0");
+ }else if (gasAdjustMode.containsKey(scheduleObjLDG) && gasAdjustMode.get(scheduleObjLDG).equals(adjustValue) &&
gasLastSugTime.containsKey(scheduleObjLDG) && (calendar.getTime().getTime() - gasLastSugTime.get(scheduleObjLDG).getTime() <= mdkScheduleRespDTO.getAdjustRate().longValue() * 60 * 1000)) {
logger.info("转炉实时调度建议在有效期内");
} else {
@@ -150,9 +152,10 @@
logger.error("转炉实时调度建议保存失败");
}
}
+ // 更新调整速率
+ gasAdjustMode.put(scheduleObjLDG, adjustValue);
+ gasLastSugTime.put(scheduleObjLDG, calendar.getTime());
}
- gasAdjustMode.put(scheduleObjLDG, adjustValue);
- gasLastSugTime.put(scheduleObjLDG, calendar.getTime());
// 预警
Object earlywarning = mdkScheduleRespDTO.getResult().get(warningKey);
if (earlywarning != null && StringUtils.isNotBlank(earlywarning.toString())) {
@@ -175,7 +178,9 @@
// 调整速率
String scheduleObjCOG = "COG";
BigDecimal adjustValue = new BigDecimal(mdkScheduleRespDTO.getResult().get(flag).toString());
- if (gasAdjustMode.containsKey(scheduleObjCOG) && gasAdjustMode.get(scheduleObjCOG).equals(adjustValue) &&
+ if (adjustValue.compareTo(BigDecimal.ZERO) == 0) {
+ logger.info("焦炉实时调度建议 flag为0");
+ }else if (gasAdjustMode.containsKey(scheduleObjCOG) && gasAdjustMode.get(scheduleObjCOG).equals(adjustValue) &&
gasLastSugTime.containsKey(scheduleObjCOG) && (calendar.getTime().getTime() - gasLastSugTime.get(scheduleObjCOG).getTime() <= mdkScheduleRespDTO.getAdjustRate().longValue() * 60 * 1000)) {
logger.info("焦炉实时调度建议在有效期内");
}else {
@@ -225,6 +230,9 @@
logger.error("焦炉实时调度建议保存失败");
}
}
+ // 更新调整速率
+ gasAdjustMode.put(scheduleObjCOG, adjustValue);
+ gasLastSugTime.put(scheduleObjCOG, calendar.getTime());
}
// 预警
@@ -267,7 +275,9 @@
// 调整速率
String scheduleObjBFG = "BFG";
BigDecimal adjustValue = new BigDecimal(mdkScheduleRespDTO.getResult().get(flag).toString());
- if (gasAdjustMode.containsKey(scheduleObjBFG) && gasAdjustMode.get(scheduleObjBFG).equals(adjustValue) &&
+ if (adjustValue.compareTo(BigDecimal.ZERO) == 0) {
+ logger.info("高炉实时调度建议 flag为0");
+ }else if (gasAdjustMode.containsKey(scheduleObjBFG) && gasAdjustMode.get(scheduleObjBFG).equals(adjustValue) &&
gasLastSugTime.containsKey(scheduleObjBFG) && (calendar.getTime().getTime() - gasLastSugTime.get(scheduleObjBFG).getTime() <= mdkScheduleRespDTO.getAdjustRate().longValue() * 60 * 1000)) {
logger.info("高炉实时调度建议在有效期内");
}else {
@@ -317,6 +327,9 @@
logger.error("高炉实时调度建议保存失败");
}
}
+ // 更新调整速率
+ gasAdjustMode.put(scheduleObjBFG, adjustValue);
+ gasLastSugTime.put(scheduleObjBFG, calendar.getTime());
}
// 预警
Object earlywarning = mdkScheduleRespDTO.getResult().get(warningKey);
--
Gitblit v1.9.3