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