From 2e8e55dfde02fcecffad7bfd129612ede95c0a5f Mon Sep 17 00:00:00 2001
From: Jay <csj123456>
Date: 星期五, 13 六月 2025 14:31:48 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleGasTask.java | 17 +++++++++++++++++
1 files changed, 17 insertions(+), 0 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleGasTask.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleGasTask.java
index e1b34fe..3deb8fb 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleGasTask.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleGasTask.java
@@ -9,6 +9,8 @@
import com.iailab.module.model.api.mdk.dto.MdkScheduleRespDTO;
import com.iailab.module.model.enums.CommonConstant;
import com.iailab.module.model.enums.ScheduleTriggerMethodEnum;
+import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
+import com.iailab.module.shasteel.job.service.MessageInfoService;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -44,6 +46,9 @@
@Autowired
private MdkApi mdkApi;
+
+ @Autowired
+ private MessageInfoService messageInfoService;
/**
* 煤气调度调整方向
@@ -114,6 +119,18 @@
saveScheduleSuggest("宏发12W煤气柜预警", result.get("LDG_2_warning_advice"), "LDG2_ALARM", predictTime, result.get("adjustValueLDG12W"), scheme.getAdjustRate(), scheme.getModelId(), scheme.getId());
saveScheduleSuggest("转炉特钢12W煤气柜预警", result.get("LDG_3_warning_advice"), "LDGt_ALARM", predictTime, result.get("adjustValueLDG12WT"), scheme.getAdjustRate(), scheme.getModelId(), scheme.getId());
+ // BFG应急预案
+ if(!Objects.equals(result.get("BFG_Emergency_plan").toString(), "")){
+ MessageInfoEntity messageInfoEntity = new MessageInfoEntity();
+ messageInfoEntity.setTitle("BFG应急预案");
+ messageInfoEntity.setContent(mdkScheduleRespDTO.getResult().get("BFG_Emergency_plan").toString());
+ messageInfoEntity.setSendTime(mdkScheduleRespDTO.getScheduleTime());
+ messageInfoEntity.setBusinessKey(mdkScheduleRespDTO.getScheduleCode());
+ messageInfoEntity.setMessageSource("系统运行预警");
+ messageInfoEntity.setCreateDate(new Date());
+ messageInfoService.create(messageInfoEntity);
+ }
+
// 模拟调整
MdkPredictSimAdjustReqDTO simAdjustReqDTO = new MdkPredictSimAdjustReqDTO();
simAdjustReqDTO.setPredictTime(predictTime);
--
Gitblit v1.9.3