From 0a2309483b770d448d2f011628d7cc436c322a2e Mon Sep 17 00:00:00 2001 From: dongyukun <1208714201@qq.com> Date: 星期二, 10 六月 2025 10:25:36 +0800 Subject: [PATCH] Merge branch 'yukun' --- 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 852e61d..cdec480 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<>(); @@ -261,5 +266,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