getNotCheckAlarmCount(String stationId);
+
+
+ /**********************************
+ * 用途说明: 生成报警记录
+ * 参数说明
+ * from 'IEC104','IEC61850'
+ * type 'yx','yc'
+ * slave_ip 服务器IP
+ * address 地址
+ * value 值
+ * 返回值说明: 无返回值
+ ***********************************/
+ void doAlaramRecord(String from,String type,String slaveIp,String address,String value);
+
}
diff --git a/riis-system/src/main/java/com/yfd/platform/modules/patroltask/service/impl/AlarmLogServiceImpl.java b/riis-system/src/main/java/com/yfd/platform/modules/patroltask/service/impl/AlarmLogServiceImpl.java
index 9b02cac..18fac76 100644
--- a/riis-system/src/main/java/com/yfd/platform/modules/patroltask/service/impl/AlarmLogServiceImpl.java
+++ b/riis-system/src/main/java/com/yfd/platform/modules/patroltask/service/impl/AlarmLogServiceImpl.java
@@ -2,9 +2,7 @@ package com.yfd.platform.modules.patroltask.service.impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
-import cn.hutool.core.collection.ListUtil;
import cn.hutool.core.date.DatePattern;
-import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.date.LocalDateTimeUtil;
import cn.hutool.core.util.*;
@@ -12,6 +10,7 @@ import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -22,8 +21,11 @@ import com.yfd.platform.component.nettyclient.*;
import com.yfd.platform.config.AlarmTemplateConfig;
import com.yfd.platform.config.HttpServerConfig;
import com.yfd.platform.config.ParentConfig;
-import com.yfd.platform.config.ResponseResult;
-import com.yfd.platform.modules.auxcontrol.mapper.DeviceAlarmRecordMapper;
+import com.yfd.platform.modules.auxcontrol.domain.DeviceAlarmParameter;
+import com.yfd.platform.modules.auxcontrol.domain.MeterDevice;
+import com.yfd.platform.modules.auxcontrol.mapper.DeviceAlarmParameterMapper;
+import com.yfd.platform.modules.auxcontrol.mapper.DeviceSignalMapper;
+import com.yfd.platform.modules.auxcontrol.mapper.MeterDeviceMapper;
import com.yfd.platform.modules.basedata.domain.LinkageSignal;
import com.yfd.platform.modules.basedata.domain.Substation;
import com.yfd.platform.modules.basedata.domain.SubstationDevice;
@@ -42,6 +44,7 @@ import com.yfd.platform.modules.patroltask.service.IAlarmLogService;
import com.yfd.platform.modules.patroltask.service.ITaskTodoService;
import com.yfd.platform.modules.robotapi.service.IStationRobotService;
import com.yfd.platform.system.domain.Message;
+import com.yfd.platform.system.domain.SysDictionaryItems;
import com.yfd.platform.system.domain.SysOrganization;
import com.yfd.platform.system.mapper.SysOrganizationMapper;
import com.yfd.platform.system.service.IMessageService;
@@ -50,15 +53,11 @@ import com.yfd.platform.utils.FileUtil;
import com.yfd.platform.utils.SecurityUtils;
import io.netty.util.CharsetUtil;
import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
-import javax.imageio.ImageIO;
import java.awt.*;
-import java.io.File;
-import java.io.FileWriter;
-import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.net.URLDecoder;
@@ -66,10 +65,12 @@ import java.net.URLEncoder;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
+import java.time.LocalTime;
import java.util.*;
import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
import java.util.stream.Collectors;
-import java.util.stream.Stream;
/**
*
@@ -120,11 +121,19 @@ public class AlarmLogServiceImpl extends ServiceImpl i
@Resource
private ISysDictionaryItemsService sysDictionaryItemsService;
- @Resource
- private DeviceAlarmRecordMapper deviceAlarmRecordMapper;
+
@Resource
private MqttGateway mqttGateway;
+ @Resource
+ private DeviceSignalMapper deviceSignalMapper;
+
+ @Resource
+ private MeterDeviceMapper meterDeviceMapper;
+
+ @Resource
+ private DeviceAlarmParameterMapper deviceAlarmParameterMapper;
+
@Override
public synchronized boolean updateTaskResult(JSONObject jsonObject) throws Exception {
JSONArray resultList = jsonObject.getJSONArray("resultList");
@@ -415,6 +424,11 @@ public class AlarmLogServiceImpl extends ServiceImpl i
return alarmLogMapper.getAlarmLogList(stationId);
}
+ @Override
+ public List getNotCheckAlarmCount(String stationId) {
+ return alarmLogMapper.getNotCheckAlarmCount(stationId);
+ }
+
/**********************************
* 用途说明: 设置任务结果数据
* 参数说明 taskResult
@@ -1179,16 +1193,8 @@ public class AlarmLogServiceImpl extends ServiceImpl i
* 返回值说明: java.util.Map
***********************************/
@Override
- public Map getAlarmLogById(String id, String systemType) {
-
- if ("01".equals(systemType)) {
- Map map = deviceAlarmRecordMapper.getAlarmLogById(id);
- }
- if ("02".equals(systemType)) {
- Map map = alarmLogMapper.getAlarmLogById(id);
- return ResponseResult.successData(map);
- }
- return ResponseResult.successData(null);
+ public Map getAlarmLogById(String id) {
+ return alarmLogMapper.getAlarmLogById(id);
}
private String getSlienceType(String type) {
@@ -1949,4 +1955,338 @@ public class AlarmLogServiceImpl extends ServiceImpl i
}
}
+ /**********************************
+ * 用途说明: 生成报警记录（IEC104）
+ * 参数说明
+ * from 'IEC104','IEC61850'
+ * type 'yx','yc'
+ * slave_ip IP
+ * address 遥信、要测地址
+ * value 值
+ * 返回值说明: 无返回值
+ ***********************************/
+ @Override
+ @Transactional
+ public void doAlaramRecord(String from, String type, String slaveIp, String address, String value) {
+ String sinnalType = type;
+ if ("IEC104".equals(from)) {
+ sinnalType = "yc";
+ } else if ("IEC61850".equals(from)) {
+ slaveIp = null;
+ }
+ Map map = deviceSignalMapper.selectDeviceSignalMap(slaveIp, sinnalType, address);
+ if (map == null || ObjUtil.isEmpty(map)) {
+ return;
+ }
+ //如果是yx 遥信 （设备自身报警记录）
+ if ("yx".equals(type)) {
+ //如果信号类型是1 设备告警
+ if ("1".equals(map.get("signalType").toString())) {
+ //紧接者判断 value （1是告警 0是正常） status
+ if ("1".equals(value)) {
+ //填充告警记录信息接口
+ AlarmLog alarmLog = FillingDeviceAlarmRecord(type, null, map, value);
+ //首先判断 在不在时间范围之内 判断时间在不在时间范围之内接口
+ Map timeInterval = getTimeInterval(7);
+ //查询表中是否存在该报警记录
+ List alarmRecords = queryDeviceAlarmRecord(alarmLog, timeInterval);
+ //如果没有有报警记录 新增记录
+ if (alarmRecords.size() == 0) {
+ doAlarmAction(alarmLog);
+ } else if (alarmRecords.size() > 1) {
+ this.removeById(alarmRecords.get(0).getId());
+ }
+ }
+ }
+ } else if ("yc".equals(type)) {
+ //1.通过设备id 和信号id 查询告警参数设置表（告警规则）
+ LambdaQueryWrapper querywrapperdap = new LambdaQueryWrapper<>();
+ if (StrUtil.isNotEmpty(map.get("meterDeviceId").toString())) {
+ querywrapperdap.eq(DeviceAlarmParameter::getDeviceId, map.get("meterDeviceId").toString());
+ }
+ if (StrUtil.isNotEmpty(map.get("signalId").toString())) {
+ querywrapperdap.eq(DeviceAlarmParameter::getSignalId, map.get("signalId").toString());
+ }
+ List deviceAlarmParameters = deviceAlarmParameterMapper.selectList(querywrapperdap);
+ if (deviceAlarmParameters != null && deviceAlarmParameters.size() > 0) {
+ for (DeviceAlarmParameter deviceAlarmParameter : deviceAlarmParameters) {
+ //如果告警触发条件 不为空 1<=value<=100
+ if (deviceAlarmParameter.getAlarmCondition() != null) {
+ //根据告警规则 判断是否触发告警
+ boolean alarmTrigger = TriggerAlarm(deviceAlarmParameter, value);
+
+ //2.通过告警触发条件 和 value比较 满足条件 触发告警
+ if (alarmTrigger) {
+ AlarmLog alarmLog = FillingDeviceAlarmRecord(type, deviceAlarmParameter
+ , map, value);
+ //首先判断 在不在时间范围之内 判断时间在不在时间范围之内接口
+ Map timeInterval = getTimeInterval(7);
+ //如果在时间范围内
+ //查询表中是否存在该报警记录
+ List alarmRecords = queryDeviceAlarmRecord(alarmLog,
+ timeInterval);
+ //如果没有有报警记录 新增记录
+ if (alarmRecords.size() == 0) {
+ // 新增
+ alarmLogMapper.insert(alarmLog);
+ //TODO 邮件推送暂时删除了
+ }
+ }
+ }
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 填充告警记录表
+ *
+ * @return 返回告警记录信息
+ */
+ public AlarmLog FillingDeviceAlarmRecord(String type, DeviceAlarmParameter deviceAlarmParameter,
+ Map signalDate, String value) {
+ AlarmLog alarmLog = new AlarmLog();
+ MeterDevice meterDevice = meterDeviceMapper.selectById(signalDate.get("meterDeviceId").toString());
+ alarmLog.setCheckFlag("0");
+ alarmLog.setAlarmSourceType("2");
+ // 创建 SimpleDateFormat 对象，指定日期格式
+ if ("yx".equals(type)) {
+ alarmLog.setId(IdUtil.fastSimpleUUID());
+
+ alarmLog.setStationId(signalDate.get("stationId").toString());
+ alarmLog.setStationName(signalDate.get("stationName").toString());
+ alarmLog.setStationCode(signalDate.get("stationCode").toString());
+ alarmLog.setAreaId(signalDate.get("areaId").toString());
+ alarmLog.setAreaName(signalDate.get("areaName").toString());
+ alarmLog.setBayId(signalDate.get("bayId").toString());
+ alarmLog.setBayName(signalDate.get("bayName").toString());
+ alarmLog.setMainDeviceName(signalDate.get("mainDeviceName").toString());
+ alarmLog.setComponentName(signalDate.get("componentName").toString());
+
+ //所属系统
+ alarmLog.setSystemcode(signalDate.get("systemcode").toString());
+ //告警时间
+ alarmLog.setAlarmDate(DateUtil.now());
+ //告警设备ID
+ alarmLog.setPatroldeviceId(meterDevice.getDeviceId());
+ alarmLog.setPatroldeviceName(meterDevice.getDeviceName());
+
+ //告警设名称
+ alarmLog.setDeviceId(signalDate.get("signalId").toString());
+ //告警信号id
+ alarmLog.setDeviceName(signalDate.get("signalName").toString());
+ //告警信号名称
+ alarmLog.setValue(value);
+ //告警值
+ alarmLog.setUnit("");
+ //值单位
+ String alarmMessage = String.format("[%s]发生了%s！", signalDate.get("deviceName").toString(),
+ signalDate.get("signalName").toString());
+ alarmLog.setContent(alarmMessage);
+ //状态
+ alarmLog.setAlarmLevel("4");
+ alarmLog.setAlarmClass("2");
+ //2-设备报警
+ alarmLog.setRegion(meterDevice.getRegion());
+ //区域标识
+ }
+ if ("yc".equals(type)) {
+ alarmLog.setId(IdUtil.fastSimpleUUID());
+ //变电站id
+ alarmLog.setStationId(signalDate.get("stationId").toString());
+ alarmLog.setStationName(signalDate.get("stationName").toString());
+ alarmLog.setStationCode(signalDate.get("stationCode").toString());
+ alarmLog.setAreaId(signalDate.get("areaId").toString());
+ alarmLog.setAreaName(signalDate.get("areaName").toString());
+ alarmLog.setBayId(signalDate.get("bayId").toString());
+ alarmLog.setBayName(signalDate.get("bayName").toString());
+ alarmLog.setMainDeviceName(signalDate.get("mainDeviceName").toString());
+ alarmLog.setComponentName(signalDate.get("componentName").toString());
+ //所属系统
+ alarmLog.setSystemcode(signalDate.get("systemcode").toString());
+ //告警时间
+ alarmLog.setAlarmDate(DateUtil.now());
+ //告警设备ID
+ alarmLog.setPatroldeviceId(meterDevice.getDeviceId());
+ //告警设备名称
+ alarmLog.setPatroldeviceName(meterDevice.getDeviceName());
+ //告警信号id
+ alarmLog.setDeviceId(signalDate.get("signalId").toString());
+ //告警信号名称
+ alarmLog.setDeviceName(signalDate.get("signalName").toString());
+ //告警类型
+ alarmLog.setAlarmType(deviceAlarmParameter.getAlarmType());
+ //告警等级
+ alarmLog.setAlarmLevel(deviceAlarmParameter.getAlarmLevel());
+ //告警值
+ alarmLog.setValue(value);
+ String sinalUnit = ObjUtil.isNotEmpty(signalDate.get("signalUnit")) ?
+ signalDate.get("signalUnit").toString() : "";
+ //值单位
+ alarmLog.setUnit(sinalUnit);
+ //正常范围
+ alarmLog.setNormalRange(deviceAlarmParameter.getAlarmCondition());
+
+ String alarmLevelname = getDictName(deviceAlarmParameter.getAlarmLevel(), "alarmLevel");
+ String alarmMessage = String.format("信号[%s]监测值为[%s]%s,达到了设置的报警阈值范围[%s]，发生告警，告警级别为[%s]！",
+ signalDate.get("signal_name").toString(), value, sinalUnit,
+ deviceAlarmParameter.getAlarmCondition(), alarmLevelname
+ );
+ //告警信息
+ alarmLog.setContent(alarmMessage);
+ //告警方式
+ alarmLog.setNoticeAction(deviceAlarmParameter.getNoticeType());
+ //邮件通知
+ alarmLog.setNoticeEmails(deviceAlarmParameter.getNoticeEmails());
+ //触发联动
+ alarmLog.setNoticeLinkages(deviceAlarmParameter.getNoticeLinkages());
+ //1-越限报警
+ alarmLog.setAlarmClass("1");
+ //区域标识
+ alarmLog.setRegion(meterDevice.getRegion());
+
+ }
+ return alarmLog;
+ }
+
+ //获取字典名称 根据项目编码和父项编码
+ public String getDictName(String itemcode, String parentcode) {
+ QueryWrapper queryWrapperSysDictionaryItems = new QueryWrapper<>();
+ String dictname = "";
+ queryWrapperSysDictionaryItems.eq("itemcode", itemcode);
+ queryWrapperSysDictionaryItems.eq("parentcode", parentcode);
+ SysDictionaryItems sysDictionaryItems = sysDictionaryItemsService.getOne(queryWrapperSysDictionaryItems);
+ if (sysDictionaryItems != null) {
+ dictname = sysDictionaryItems.getDictName();
+ }
+ return dictname;
+ }
+
+ /**
+ * 根据告警规则 判断是否触发告警
+ *
+ * @return true 触发恭敬规则
+ * false 没有触发告警规则
+ */
+ public boolean TriggerAlarm(DeviceAlarmParameter deviceAlarmParameter, String value) {
+
+ // //获取告警触发条件
+ String str = deviceAlarmParameter.getAlarmCondition();
+ // 定义正则表达式
+ String regex = "(\\d+)\\s*((?:==?|!=|<=?|>=?))\\s*value\\s*((?:==?|!=|<=?|>=?))\\s*(\\d+)";
+ Pattern pattern = Pattern.compile(regex);
+ Matcher matcher = pattern.matcher(str);
+
+ // 查找并输出比较符号和数值
+ if (matcher.find()) {
+ try {
+ // 第一个数字
+ String number1 = matcher.group(1);
+ // 第一个比较符
+ String operator1 = matcher.group(2);
+ // 第二个比较符
+ String operator2 = matcher.group(3);
+ // 第二个数字
+ String number2 = matcher.group(4);
+ Double aDouble = Double.valueOf(value);
+ boolean result = compare(Double.valueOf(number1), operator1, aDouble);
+ boolean resultTwo = compare(aDouble, operator2, Double.valueOf(number2));
+ return result && resultTwo;
+ } catch (Exception e) {
+ log.error(e.getMessage());
+ return false;
+ }
+
+ }
+ return false;
+
+ }
+
+ private static boolean compare(Double value1, String operator, Double value2) {
+ switch (operator) {
+ case "<":
+ return value1.compareTo(value2) < 0;
+ case "<=":
+ return value1.compareTo(value2) < 0 || value1.compareTo(value2) == 0;
+ case ">":
+ return value1.compareTo(value2) > 0;
+ case ">=":
+ return value1.compareTo(value2) > 0 || value1.compareTo(value2) == 0;
+ case "==":
+ case "=":
+ return value1.compareTo(value2) == 0;
+ case "!=":
+ return value1.compareTo(value2) != 0;
+ default:
+ throw new IllegalArgumentException("错误的告警规则: " + operator);
+ }
+ }
+
+ //执行告警相关动作 插入数据库
+ private void doAlarmAction(AlarmLog alarmLog) {
+ //1.通过设备id 和信号id 查询告警参数设置表（告警规则）
+ LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>();
+ queryWrapper.eq(DeviceAlarmParameter::getDeviceId, alarmLog.getPatroldeviceId());
+ queryWrapper.eq(DeviceAlarmParameter::getSignalId, alarmLog.getDeviceId());
+ List alarmParameters = deviceAlarmParameterMapper.selectList(queryWrapper);
+ for (DeviceAlarmParameter alarmParameter : alarmParameters) {
+ alarmLog.setFkAlarmType(alarmParameter.getAlarmType());
+ alarmLog.setNoticeAction(alarmParameter.getNoticeType());
+ alarmLog.setNoticeLinkages(alarmParameter.getNoticeLinkages());
+ //todo 发送邮件
+ // pushEmail(alarmRecord,alarmParameter);
+ }
+ this.saveOrUpdate(alarmLog);
+ }
+
+ /**
+ * 判断当前时间在不在区间范围之内
+ *
+ * @return true 在区间范围之内
+ * false 不在时间范围之内
+ */
+ public Map getTimeInterval(int clockHour) {
+ int beforeclock = 0;
+ Map map = new HashMap<>(10);
+ // 获取当前时间
+ LocalDateTime now = LocalDateTime.now();
+
+ // 获取昨天的 7 点
+ LocalDateTime yesterdayClockAM = LocalDateTime.of(now.minusDays(1).toLocalDate(), LocalTime.of(clockHour, 0));
+ map.put("starttime", yesterdayClockAM);
+ // 获取今天的 7 点
+ LocalDateTime todayClockAM = LocalDateTime.of(now.toLocalDate(), LocalTime.of(clockHour, 0));
+ LocalDateTime nextdayClockAM = LocalDateTime.of(now.plusDays(1).toLocalDate(), LocalTime.of(clockHour, 0));
+
+ map.put("endtime", todayClockAM);
+ // 判断时间是否在范围内
+ if (now.isAfter(yesterdayClockAM) && now.isBefore(todayClockAM)) {
+ beforeclock = 1;
+ } else {
+ map.put("starttime", todayClockAM);
+ map.put("endtime", nextdayClockAM);
+ }
+ map.put("beforeclock", beforeclock);
+ return map;
+ }
+
+ /**
+ * 根据条件查询告警记录表 判断是否存在告警记录
+ *
+ * @return true 存在告警记录
+ * false 不存在告警记录
+ */
+ public List queryDeviceAlarmRecord(AlarmLog alarmLog,
+ Map timeInterval) {
+ LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>();
+ queryWrapper.eq(AlarmLog::getDeviceId, alarmLog.getDeviceId());
+ queryWrapper.eq(AlarmLog::getAlarmLevel, alarmLog.getAlarmLevel());
+ LocalDateTime starttime = (LocalDateTime) timeInterval.get("starttime");
+ LocalDateTime endtime = (LocalDateTime) timeInterval.get("endtime");
+ queryWrapper.between(AlarmLog::getAlarmDate, starttime, endtime);
+ return this.list(queryWrapper);
+
+ }
+
}
diff --git a/riis-system/src/main/resources/mapper/auxcontrol/DeviceAlarmRecordMapper.xml b/riis-system/src/main/resources/mapper/auxcontrol/DeviceAlarmRecordMapper.xml
deleted file mode 100644
index 47230af..0000000
--- a/riis-system/src/main/resources/mapper/auxcontrol/DeviceAlarmRecordMapper.xml
+++ /dev/null
@@ -1,74 +0,0 @@
-
-
-
-
-
-
-
-
diff --git a/riis-system/src/main/resources/mapper/auxcontrol/DeviceSignalMapper.xml b/riis-system/src/main/resources/mapper/auxcontrol/DeviceSignalMapper.xml
index a89a636..b512930 100644
--- a/riis-system/src/main/resources/mapper/auxcontrol/DeviceSignalMapper.xml
+++ b/riis-system/src/main/resources/mapper/auxcontrol/DeviceSignalMapper.xml
@@ -5,14 +5,24 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+