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 ++--
 1 files changed, 2 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 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