From 8ed83e01ffb5f68b90e5fd13fc2008e608c265f7 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期二, 25 三月 2025 07:11:12 +0800
Subject: [PATCH] 蒸汽调度 调整速率
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java | 26 +++++---------------------
1 files changed, 5 insertions(+), 21 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..7d4439b 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;
/**
* 监听报警信息
@@ -34,6 +34,7 @@
@Component
public class ModelPredictFinish2Consumer {
+
@Resource
private McsApi mcsApi;
@@ -45,7 +46,7 @@
*
* @param message
*/
- @RabbitListener(queues = QueuePredictFinishConfig.QUEUE_NAME)
+ @RabbitListener(queues = QueuePredictFinishConfig.QUEUE_NAME2)
public void listen(Message message) {
String routingKey = message.getMessageProperties().getReceivedRoutingKey();
log.info("routingKey:" + routingKey);
@@ -144,23 +145,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