From 6fb7534adeaffd1caf325210a2353a85ab79a454 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期二, 21 一月 2025 10:59:18 +0800
Subject: [PATCH] 预警消息过滤
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java | 23 +++--------------------
1 files changed, 3 insertions(+), 20 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java
index 40a9537..10aa293 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java
@@ -1,6 +1,5 @@
package com.iailab.module.shasteel.mq.consumer;
-import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.iailab.framework.common.util.date.DateUtils;
import com.iailab.module.model.api.mcs.McsApi;
@@ -20,8 +19,9 @@
import org.springframework.util.CollectionUtils;
import javax.annotation.Resource;
-import java.util.*;
-import java.util.stream.Collectors;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
/**
* 监听报警信息
@@ -144,23 +144,6 @@
break;
default:
break;
- }
- }
- // 电力预测完成，执行电力调度模型
- String moduleType = messageJson.get("moduleType").toString();
- if (null != moduleType && moduleType.equals(CommonConstant.TRIGGER_CONDITION_ELEC)) {
- List<StScheduleSchemeDTO> elecSche = scheduleSchemeList.stream().filter(e -> e.getTriggerCondition().equals(CommonConstant.TRIGGER_CONDITION_ELEC)).collect(Collectors.toList());
- Calendar calendar = Calendar.getInstance();
- calendar.set(Calendar.MILLISECOND, 0);
- calendar.set(Calendar.SECOND, 0);
- calendar.set(Calendar.MINUTE, 0);
- calendar.set(Calendar.HOUR_OF_DAY, 0);
- Date scheduleTime = calendar.getTime();
- for (StScheduleSchemeDTO stScheduleSchemeDTO : elecSche) {
- MdkScheduleReqDTO mdkScheduleReqDTO = new MdkScheduleReqDTO();
- mdkScheduleReqDTO.setScheduleCode(stScheduleSchemeDTO.getCode());
- mdkScheduleReqDTO.setScheduleTime(scheduleTime);
- mdkApi.doSchedule(mdkScheduleReqDTO);
}
}
}
--
Gitblit v1.9.3