系统运行预警

 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/service/MessageInfoService.java

@@ -19,4 +19,6 @@
    PageResult<MessageInfoEntity> getMessagePage(Integer pageNo, Integer pageSize);

    void readMessage(List<String> ids);

    boolean getIsSuggestKeep(String title);
}

 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/service/impl/MessageInfoServiceImpl.java

@@ -8,8 +8,12 @@
import com.iailab.module.shasteel.job.dao.MessageInfoDao;
import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
import com.iailab.module.shasteel.job.service.MessageInfoService;
import com.mysql.cj.util.TimeUtil;
import org.springframework.stereotype.Service;

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

@Service
@@ -37,6 +41,20 @@
    }

    @Override
    public boolean getIsSuggestKeep(String title) {
        Date currentDate = new Date();
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(currentDate);
        calendar.add(Calendar.MINUTE, -15);
        Date keepDate = calendar.getTime();
        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        return baseDao.selectCount(new QueryWrapper<MessageInfoEntity>()
                .ge("send_time",formatter.format(keepDate))
                .eq("title",title)
        ) > 0;
    }

    @Override
    public List<MessageInfoEntity> getMessageList() {
        return baseDao.selectList(new QueryWrapper<MessageInfoEntity>());
    }

 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleGasTask.java

@@ -121,7 +121,7 @@
            saveScheduleSuggest("BFG应急预案", result.get("BFG_Emergency_plan"), "BFG_EMERGENCY_PLAN", predictTime, 1, scheme.getAdjustRate(), scheme.getModelId(), scheme.getId());

            // BFG应急预案
            if(!Objects.equals(result.get("BFG_Emergency_plan").toString(), "")){
            if(!Objects.equals(result.get("BFG_Emergency_plan").toString(), "")&&!messageInfoService.getIsSuggestKeep("BFG应急预案")){
                MessageInfoEntity messageInfoEntity = new MessageInfoEntity();
                messageInfoEntity.setTitle("BFG应急预案");
                messageInfoEntity.setContent(mdkScheduleRespDTO.getResult().get("BFG_Emergency_plan").toString());

 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleModuleTask.java

@@ -40,7 +40,7 @@
            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());
@@ -51,7 +51,7 @@
                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());