From 6b0c10dfb1b67a658648b08f0130ffda94caeebd Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期一, 23 六月 2025 19:38:51 +0800
Subject: [PATCH] 系统运行预警

---
 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleModuleTask.java |    6 ++++--
 1 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleModuleTask.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleModuleTask.java
index 41a10cf..59dfd77 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleModuleTask.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleModuleTask.java
@@ -40,21 +40,23 @@
             MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
             logger.info(params + "调度方案执行完成," + mdkScheduleRespDTO);
             logger.info("调度方案结果开始下发");
-            if(params.equals("shaNitrogenSos")&&Integer.parseInt(mdkScheduleRespDTO.getResult().get("adviceValues").toString())>0){
+            if(params.equals("shaNitrogenSos")&&Integer.parseInt(mdkScheduleRespDTO.getResult().get("adviceValues").toString())>0&&!messageInfoService.getIsSuggestKeep("氮气应急预案")){
                 MessageInfoEntity messageInfoEntity = new MessageInfoEntity();
                 messageInfoEntity.setTitle("氮气应急预案");
                 messageInfoEntity.setContent(mdkScheduleRespDTO.getResult().get("advice").toString());
                 messageInfoEntity.setSendTime(mdkScheduleRespDTO.getScheduleTime());
+                messageInfoEntity.setReadStatus("0");
                 messageInfoEntity.setBusinessKey(mdkScheduleRespDTO.getScheduleCode());
                 messageInfoEntity.setMessageSource("系统运行预警");
                 messageInfoEntity.setCreateDate(new Date());
                 messageInfoService.create(messageInfoEntity);
             }
-            if(params.equals("oxygenSos")&&Integer.parseInt(mdkScheduleRespDTO.getResult().get("adviceValues").toString())>0){
+            if(params.equals("oxygenSos")&&Integer.parseInt(mdkScheduleRespDTO.getResult().get("adviceValues").toString())>0&&!messageInfoService.getIsSuggestKeep("氧气应急预案")){
                 MessageInfoEntity messageInfoEntity = new MessageInfoEntity();
                 messageInfoEntity.setTitle("氧气应急预案");
                 messageInfoEntity.setContent(mdkScheduleRespDTO.getResult().get("advice").toString());
                 messageInfoEntity.setSendTime(mdkScheduleRespDTO.getScheduleTime());
+                messageInfoEntity.setReadStatus("0");
                 messageInfoEntity.setBusinessKey(mdkScheduleRespDTO.getScheduleCode());
                 messageInfoEntity.setMessageSource("系统运行预警");
                 messageInfoEntity.setCreateDate(new Date());

--
Gitblit v1.9.3