From 2ee54ad8c0b9b081479b178fdcf3105cc2865b76 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期一, 20 一月 2025 23:54:39 +0800
Subject: [PATCH] 煤气模型调度
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java | 7 +++++--
1 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java
index 062e42e..d042091 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java
@@ -57,7 +57,6 @@
}
Date predictTime = DateUtils.parse(messageJson.get("predictTime").toString(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
-
// 查询相关预警配置
List<AlarmConfigRespDTO> configList = mcsApi.listAlarmConfig(new HashMap<String, Object>());
if (CollectionUtils.isEmpty(configList)) {
@@ -102,6 +101,7 @@
alarmMessage.setConfigId(configItem.getId());
alarmMessage.setTitle(configItem.getTitle());
alarmMessage.setAlarmObj(configItem.getAlarmObj());
+ alarmMessage.setAlarmTime(predictTime);
log.info("对比累计值是否超限");
StringBuilder content = new StringBuilder();
if (configItem.getCulUpper() != null && culValue.compareTo(configItem.getCulUpper()) > 0) {
@@ -113,7 +113,7 @@
continue;
}
if (configItem.getCulLower() != null && culValue.compareTo(configItem.getCulLower()) < 0) {
- content.append("即将低于累计值上限");
+ content.append("即将低于累计值下限");
alarmMessage.setAlarmType(CommonConstant.EXCEEDING_LOWER_LIMIT);
alarmMessage.setContent(content.toString());
mcsApi.createAlarmMessage(alarmMessage);
@@ -151,6 +151,9 @@
}
if (!CollectionUtils.isEmpty(alarmList)) {
log.info("发送预警消息");
+ Map<String, Object> msg = new HashMap<>(2);
+ msg.put("predictTime", predictTime);
+ msg.put("alarmList", alarmList);
rabbitTemplate.convertAndSend(RoutingConstant.EXCHANGE, RoutingConstant.Iailab_Model_Alarm, alarmList);
}
} catch (Exception e) {
--
Gitblit v1.9.3