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