From dbfc66aafc614f4ec5459247bb219db4ceb321ee Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期二, 10 六月 2025 10:08:51 +0800
Subject: [PATCH] 消息系统模型预警
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java | 13 +++++++++++++
1 files changed, 13 insertions(+), 0 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java
index 781a1fa..21ed086 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java
@@ -9,6 +9,8 @@
import com.iailab.module.model.api.mdk.dto.MdkScheduleRespDTO;
import com.iailab.module.model.enums.CommonConstant;
import com.iailab.module.model.enums.ScheduleTriggerMethodEnum;
+import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
+import com.iailab.module.shasteel.job.service.MessageInfoService;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -57,6 +59,9 @@
@Autowired
private MdkApi mdkApi;
+
+ @Autowired
+ private MessageInfoService messageInfoService;
private Map<String, StScheduleSchemeDTO> schemeMap = new HashMap<>();
@@ -259,5 +264,13 @@
alarm.setAlarmType(adjustValue.compareTo(BigDecimal.ZERO) > 0 ? "超上限" : "超下限");
alarm.setAlarmTime(scheduleTime);
mcsApi.createAlarmMessage(alarm);
+ MessageInfoEntity messageInfoEntity = new MessageInfoEntity();
+ messageInfoEntity.setTitle(title);
+ messageInfoEntity.setContent(content);
+ messageInfoEntity.setSendTime(scheduleTime);
+ messageInfoEntity.setBusinessKey(alarm.getId());
+ messageInfoEntity.setMessageSource("模型预警");
+ messageInfoEntity.setCreateDate(new Date());
+ messageInfoService.create(messageInfoEntity);
}
}
\ No newline at end of file
--
Gitblit v1.9.3