From 37a3062a7e4f715d8faf8a68d05ee434ef22c56a Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期四, 10 四月 2025 10:30:38 +0800
Subject: [PATCH] 已全部预测完成，预警消息为空
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelAlarmConsumer.java | 6 ++++++
1 files changed, 6 insertions(+), 0 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 53bb9d4..e9c7e0f 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
@@ -94,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)) {
--
Gitblit v1.9.3