From 8083603f27daa6840b93d36767d4e7d45ccd256e Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期一, 23 六月 2025 17:00:17 +0800
Subject: [PATCH] 系统运行预警
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleModuleTask.java | 35 ++++++++++++++++++++++++++++++++++-
1 files changed, 34 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 c9e0a62..f499f46 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 );
@@ -35,6 +39,35 @@
dto.setScheduleCode(params);
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.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){
+ 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 (mdkApi.scheduleModelOut(mdkScheduleRespDTO)) {
+
+ logger.info("调度方案结果下发成功");
+ }else {
+ logger.error("调度方案结果下发失败");
+ }
} catch (Exception ex) {
logger.error("runScheduleModuleTask运行异常");
--
Gitblit v1.9.3