From ad25e504e0b0f0ad3ab955191e0d426661ef7b24 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期二, 21 一月 2025 08:30:51 +0800
Subject: [PATCH] 煤气模型调度

---
 shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java |    4 ++--
 shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/common/constant/CommonConstant.java      |    3 +++
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/common/constant/CommonConstant.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/common/constant/CommonConstant.java
index 25ca993..26e2d11 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/common/constant/CommonConstant.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/common/constant/CommonConstant.java
@@ -20,6 +20,9 @@
     //氧气系统优化调度决策方案code
     String OXYGEN_TWO_CODE = "oxygen02";
 
+    //煤气调度code
+    String GAS_MODEL_CODE = "GAS01";
+
     //超上限
     String EXCEEDING_UPPER_LIMIT = "超上限";
 
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 d042091..692fe36 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
@@ -152,9 +152,9 @@
             if (!CollectionUtils.isEmpty(alarmList)) {
                 log.info("发送预警消息");
                 Map<String, Object> msg = new HashMap<>(2);
-                msg.put("predictTime", predictTime);
+                msg.put("predictTime", DateUtils.format(predictTime, DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
                 msg.put("alarmList", alarmList);
-                rabbitTemplate.convertAndSend(RoutingConstant.EXCHANGE, RoutingConstant.Iailab_Model_Alarm, alarmList);
+                rabbitTemplate.convertAndSend(RoutingConstant.EXCHANGE, RoutingConstant.Iailab_Model_Alarm, msg);
             }
         } catch (Exception e) {
             e.printStackTrace();

--
Gitblit v1.9.3