From cdea0d3b6412b5d81eea26add488f0a8caa83f6a Mon Sep 17 00:00:00 2001
From: liriming <1343021927@qq.com>
Date: 星期三, 23 四月 2025 13:31:17 +0800
Subject: [PATCH] RunMachineStateTask
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelAlarmConsumer.java | 121 +++++++++++++++++++++++++++++++++++-----
1 files changed, 105 insertions(+), 16 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelAlarmConsumer.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelAlarmConsumer.java
index 9424085..abde570 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelAlarmConsumer.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelAlarmConsumer.java
@@ -22,6 +22,7 @@
import org.springframework.util.CollectionUtils;
import javax.annotation.Resource;
+import java.math.BigDecimal;
import java.util.*;
/**
@@ -43,10 +44,16 @@
private static String lastRunGasSchedule = "";
- // 最早调度时间
- private static Date earliestScheduleTime = null;
+ /**
+ * 煤气调度调整方向
+ * 1：调整值为正数；-1：调整值为负数
+ */
+ private static Map<String, Integer> gasAdjustMode = new HashMap<>();
- private static Date lastScheduleTime = null;
+ /**
+ * 煤气调度建议时间
+ */
+ private static Map<String, Date> gasLastSugTime = new HashMap<>();
/**
* 监听报警信息，执行煤气调度
@@ -87,6 +94,12 @@
log.info("已全部预测完成，清空finishModuleMap");
ModelPredictFinishConsumer.finishModuleMap.clear();
+ if (!ModelPredictFinishConsumer.finishAlarmMap.contains(predictTime.getTime())) {
+ log.info("已全部预测完成，预警消息为空");
+ return;
+ }
+ ModelPredictFinishConsumer.finishAlarmMap.clear();
+
log.info("查找需要执行的调度方案");
List<StScheduleSchemeDTO> scheduleSchemeList = mcsApi.listScheduleScheme(ScheduleTriggerMethodEnum.EVENT.getCode(), routingKey);
if (CollectionUtils.isEmpty(scheduleSchemeList)) {
@@ -94,11 +107,6 @@
return;
}
for (StScheduleSchemeDTO stScheduleSchemeDTO : scheduleSchemeList) {
- if (lastScheduleTime != null && stScheduleSchemeDTO.getAdjustRate() != null && stScheduleSchemeDTO.getAdjustRate() > 0 &&
- (predictTime.getTime() - lastScheduleTime.getTime() > 1000 * 60 * stScheduleSchemeDTO.getAdjustRate().longValue()) ) {
- log.info("调整速率有效期内，跳过执行");
- continue;
- }
String runKey = "GasSchedule_" + stScheduleSchemeDTO.getCode() + "_" + predictTime.getTime();
log.info("runKey:" + runKey);
log.info("lastRunGasSchedule:" + lastRunGasSchedule);
@@ -130,11 +138,17 @@
mdkApi.scheduleModelOut(mdkScheduleRespDTO);
// 保存调度建议
- saveScheduleSuggest("高炉煤气", result.get("adviceBFG"), "BFG", predictTime);
- saveScheduleSuggest("焦炉煤气", result.get("adviceCOG"), "COG", predictTime);
- saveScheduleSuggest("转炉5W+8W煤气柜", result.get("adviceLDG13W"), "LDG1", predictTime);
- saveScheduleSuggest("宏发12W煤气柜", result.get("adviceLDG12W"), "LDG2", predictTime);
- saveScheduleSuggest("转炉特钢煤气柜", result.get("adviceLDG12WT"), "LDGt", predictTime);
+ saveScheduleSuggest("高炉煤气", result.get("adviceBFG"), "BFG", predictTime, result.get("adjustValueBFG"), stScheduleSchemeDTO.getAdjustRate());
+ saveScheduleSuggest("焦炉煤气", result.get("adviceCOG"), "COG", predictTime, result.get("adjustValueCOG"), stScheduleSchemeDTO.getAdjustRate());
+ saveScheduleSuggest("转炉5W+8W煤气柜", result.get("adviceLDG13W"), "LDG1", predictTime, result.get("adjustValueLDG13W"), stScheduleSchemeDTO.getAdjustRate());
+ saveScheduleSuggest("宏发12W煤气柜", result.get("adviceLDG12W"), "LDG2", predictTime, result.get("adjustValueLDG12W"), stScheduleSchemeDTO.getAdjustRate());
+ saveScheduleSuggest("转炉特钢煤气柜", result.get("adviceLDG12WT"), "LDGt", predictTime, result.get("adjustValueLDG12WT"), stScheduleSchemeDTO.getAdjustRate());
+
+ saveScheduleSuggest("高炉煤气预警", result.get("BFG_warning_advice"), "BFG_ALARM", predictTime, result.get("adjustValueBFG"), stScheduleSchemeDTO.getAdjustRate());
+ saveScheduleSuggest("焦炉煤气预警", result.get("COG_warning_advice"), "COG_ALARM", predictTime, result.get("adjustValueCOG"), stScheduleSchemeDTO.getAdjustRate());
+ saveScheduleSuggest("转炉5W+8W煤气柜预警", result.get("LDG_1_warning_advice"), "LDG1_ALARM", predictTime, result.get("adjustValueLDG13W"), stScheduleSchemeDTO.getAdjustRate());
+ saveScheduleSuggest("宏发12W煤气柜预警", result.get("LDG_2_warning_advice"), "LDG2_ALARM", predictTime, result.get("adjustValueLDG12W"), stScheduleSchemeDTO.getAdjustRate());
+ saveScheduleSuggest("转炉特钢12W煤气柜预警", result.get("LDG_3_warning_advice"), "LDGt_ALARM", predictTime, result.get("adjustValueLDG12WT"), stScheduleSchemeDTO.getAdjustRate());
// 模拟调整
MdkPredictSimAdjustReqDTO simAdjustReqDTO = new MdkPredictSimAdjustReqDTO();
@@ -234,18 +248,93 @@
break;
}
}
-
- lastScheduleTime = predictTime;
}
- private void saveScheduleSuggest(String title, Object content, String scheduleObj, Date scheduleTime) {
+ /**
+ * 建议保持逻辑
+ * <p>
+ * <p>
+ * BFG建议：
+ * 若触发第一条：
+ * 当前BFG建议 = adviceBFG
+ * 若后续BFG建议出现时间与当前BFG建议相差15分钟之内：
+ * 所后续BFG建议方向与当前BFG建议方向相反：
+ * 当前建议 = 后续BFG建议
+ * 若不是：
+ * 当前建议保持不变
+ * 若不是则：
+ * 当前建议 = 后续BFG建议
+ * <p>
+ * COG建议：
+ * 若触发第一条：
+ * 当前COG建议 = adviceCOG
+ * 若后续COG建议出现时间与当前COG建议相差15分钟之内：
+ * 所后续COG建议方向与当前COG建议方向相反：
+ * 当前建议 = 后续COG建议
+ * 若不是：
+ * 当前建议保持不变
+ * 若不是则：
+ * 当前建议 = 后续COG建议
+ * <p>
+ * LDG13W建议：
+ * 若触发第一条：
+ * 当前LDG13W建议 = adviceLDG13W
+ * 若后续LDG13W建议出现时间与当前LDG13W建议相差15分钟之内：
+ * 所后续LDG13W建议方向与当前LDG13W建议方向相反：
+ * 当前建议 = 后续LDG13W建议
+ * 若不是：
+ * 当前建议保持不变
+ * 若不是则：
+ * 当前建议 = 后续LDG13W建议
+ * <p>
+ * LDG12W建议：
+ * 若触发第一条：
+ * 当前LDG12W建议 = adviceLDG12W
+ * 若后续LDG12W建议出现时间与当前LDG12W建议相差15分钟之内：
+ * 所后续LDG12W建议方向与当前LDG12W建议方向相反：
+ * 当前建议 = 后续LDG12W建议
+ * 若不是：
+ * 当前建议保持不变
+ * 若不是则：
+ * 当前建议 = 后续LDG12W建议
+ * <p>
+ * LDG12WT建议：
+ * 若触发第一条：
+ * 当前LDG12WT建议 = adviceLDG12WT
+ * 若后续LDG12WT建议出现时间与当前LDG12WT建议相差15分钟之内：
+ * 所后续LDG12WT建议方向与当前LDG12WT建议方向相反：
+ * 当前建议 = 后续LDG12WT建议
+ * 若不是：
+ * 当前建议保持不变
+ * 若不是则：
+ * 当前建议 = 后续LDG12WT建议
+ *
+ * @param title
+ * @param content
+ * @param scheduleObj
+ * @param scheduleTime
+ */
+ private void saveScheduleSuggest(String title, Object content, String scheduleObj, Date scheduleTime, Object adjustObj, int adjustRate) {
if (content == null || StringUtils.isBlank(content.toString()) || "0".equals(content.toString())) {
log.info(title + "content为空");
return;
}
+ if (!title.contains("预警") && (adjustObj == null || StringUtils.isBlank(adjustObj.toString()) || "0".equals(adjustObj.toString()))) {
+ log.info(title + "调整值为空，不产生建议");
+ return;
+ }
+ BigDecimal adjustValue = new BigDecimal(adjustObj.toString());
+ if (gasAdjustMode.containsKey(scheduleObj) && gasAdjustMode.get(scheduleObj).equals(adjustValue.compareTo(BigDecimal.ZERO)) &&
+ gasLastSugTime.containsKey(scheduleObj) && (scheduleTime.getTime() - gasLastSugTime.get(scheduleObj).getTime() <= Integer.valueOf(adjustRate).longValue() * 60 * 1000)) {
+ log.info(title + "调整建议在有效期内");
+ return;
+ }
+ gasAdjustMode.put(scheduleObj, adjustValue.compareTo(BigDecimal.ZERO));
+ gasLastSugTime.put(scheduleObj, scheduleTime);
ScheduleSuggestRespDTO suggest = new ScheduleSuggestRespDTO();
suggest.setTitle(title);
suggest.setContent(content.toString());
+ suggest.setAdjustValue(adjustValue);
suggest.setScheduleObj(scheduleObj);
suggest.setScheduleTime(scheduleTime);
suggest.setSort(0);
--
Gitblit v1.9.3