From fc066dd816c1badcb9bd08b526770993df36ac3c Mon Sep 17 00:00:00 2001 From: dengzedong <dengzedong@email> Date: 星期六, 18 一月 2025 11:51:06 +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