From b45ac04dddbb71a691c29accb96bfe82c798f915 Mon Sep 17 00:00:00 2001
From: dengzedong <dengzedong@email>
Date: 星期四, 16 一月 2025 17:36:22 +0800
Subject: [PATCH] 电力预测完成，执行电力调度模型
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java | 23 +++++++++++++++++++----
1 files changed, 19 insertions(+), 4 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 8b11383..40a9537 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
@@ -20,10 +20,8 @@
import org.springframework.util.CollectionUtils;
import javax.annotation.Resource;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
+import java.util.*;
+import java.util.stream.Collectors;
/**
* 监听报警信息
@@ -148,5 +146,22 @@
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);
+ }
+ }
}
}
\ No newline at end of file
--
Gitblit v1.9.3