From 7da82857c099c2d704a85c3b756ef61a732e4bee Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期五, 13 六月 2025 11:46:51 +0800
Subject: [PATCH] BFG应急预案

---
 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 edc415f..caa089f 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