From 4e08228935a5c636da5281c47cf65ce91bc02a65 Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Wed, 06 Dec 2023 16:39:55 +0800
Subject: [PATCH] 告警处理
---
skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/alarmRule/service/impl/AlarmRecordServiceImpl.java | 35 +++++++++++++++++++++++++++++++++++
1 files changed, 35 insertions(+), 0 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/alarmRule/service/impl/AlarmRecordServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/alarmRule/service/impl/AlarmRecordServiceImpl.java
index fc98fa7..c35758c 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/alarmRule/service/impl/AlarmRecordServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/alarmRule/service/impl/AlarmRecordServiceImpl.java
@@ -9,12 +9,16 @@
import cn.gistack.alerts.alarmRule.vo.StatisticAlarmRecord;
import cn.gistack.alerts.sms.vo.Temp;
import cn.gistack.sm.intelligentCall.entity.Scene;
+import cn.gistack.sm.patrol.feign.PatrolTaskClient;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springblade.core.secure.utils.AuthUtil;
+import org.springblade.core.tool.utils.DateUtil;
+import org.springblade.core.tool.utils.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList;
import java.util.HashMap;
@@ -32,6 +36,9 @@
@Autowired
private AlarmRuleService alarmRuleService;
+
+ @Autowired
+ private PatrolTaskClient patrolTaskClient;
/**
* 自定义分页列表查询
@@ -111,4 +118,32 @@
// 返回数据
return objects;
}
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public Boolean updateStatus(AlarmRecord alarmRecord) {
+
+ AlarmRecordVO vo = baseMapper.getVODetail(alarmRecord.getId());
+ String processDefinitionId = "c2d5326e-e27b-11ed-a04e-00ff0b362ee4";
+
+ //日常巡查
+ String taskType = "1641037874390999041";
+ String title = StringUtil.format("{}{}巡查",
+ vo.getReservoirName(),vo.getAlarmRuleType());
+
+ String tm = DateUtil.format(vo.getCreateTime(),"MM月dd日HH时mm分");
+
+ //杨树堰水库在20231206 080005时近1h水位陡降
+ String content = StringUtil.format("{}在{}时{}",
+ vo.getReservoirName(),tm,vo.getRuleName());
+
+ //创建新任务
+ String taskId = patrolTaskClient.createTask(processDefinitionId, taskType, title, content, vo.getReservoirNumber());
+
+ //更新状态
+ alarmRecord.setTaskId(taskId);
+ boolean b = updateById(alarmRecord);
+
+ return b;
+ }
}
--
Gitblit v1.9.3