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());