From a90560389789f6f9a175d2d282f822e4b25990c6 Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期三, 11 六月 2025 16:39:08 +0800
Subject: [PATCH] 系统运行预警
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleModuleTask.java | 27 ++++++++++++++++++++++++++-
1 files changed, 26 insertions(+), 1 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 8394f8a..41a10cf 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
@@ -3,12 +3,15 @@
import com.iailab.module.model.api.mdk.MdkApi;
import com.iailab.module.model.api.mdk.dto.MdkScheduleReqDTO;
import com.iailab.module.model.api.mdk.dto.MdkScheduleRespDTO;
+import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
+import com.iailab.module.shasteel.job.service.MessageInfoService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Calendar;
+import java.util.Date;
/**
* 执行调度方案定时任务
@@ -21,7 +24,8 @@
@Autowired
private MdkApi mdkApi;
-
+@Autowired
+private MessageInfoService messageInfoService;
@Override
public void run(String params) {
logger.info("runScheduleModuleTask定时任务正在执行，参数为：{}",params );
@@ -36,7 +40,28 @@
MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
logger.info("调度方案结果开始下发");
+ if(params.equals("shaNitrogenSos")&&Integer.parseInt(mdkScheduleRespDTO.getResult().get("adviceValues").toString())>0){
+ MessageInfoEntity messageInfoEntity = new MessageInfoEntity();
+ messageInfoEntity.setTitle("氮气应急预案");
+ messageInfoEntity.setContent(mdkScheduleRespDTO.getResult().get("advice").toString());
+ messageInfoEntity.setSendTime(mdkScheduleRespDTO.getScheduleTime());
+ 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){
+ MessageInfoEntity messageInfoEntity = new MessageInfoEntity();
+ messageInfoEntity.setTitle("氧气应急预案");
+ messageInfoEntity.setContent(mdkScheduleRespDTO.getResult().get("advice").toString());
+ messageInfoEntity.setSendTime(mdkScheduleRespDTO.getScheduleTime());
+ messageInfoEntity.setBusinessKey(mdkScheduleRespDTO.getScheduleCode());
+ messageInfoEntity.setMessageSource("系统运行预警");
+ messageInfoEntity.setCreateDate(new Date());
+ messageInfoService.create(messageInfoEntity);
+ }
if (mdkApi.scheduleModelOut(mdkScheduleRespDTO)) {
+
logger.info("调度方案结果下发成功");
}else {
logger.error("调度方案结果下发失败");
--
Gitblit v1.9.3