diff --git a/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordAlarmDataController.java b/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordAlarmDataController.java index 4dbddf5..ef5d3b7 100644 --- a/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordAlarmDataController.java +++ b/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordAlarmDataController.java @@ -116,7 +116,7 @@ public class EmsRecordAlarmDataController extends BaseController } /** - * 获取数据表总数(alarm_type = 0) + * 获取异常数据表总数(包含所有告警类型) */ @GetMapping("/getAlarmDataTotalCount") public int getAlarmDataTotalCount() diff --git a/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAlarmData.java b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAlarmData.java index 5335321..16b748c 100644 --- a/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAlarmData.java +++ b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAlarmData.java @@ -41,8 +41,8 @@ public class EmsRecordAlarmData extends BaseEntity @Excel(name = "记录时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") private Date collectTime; - /** 异常类型(0超过阈值 1低于阈值) */ -// @Excel(name = "异常类型", readConverterExp = "0=超过阈值,1=设备离线") + /** 异常类型(0超过阈值 1小于阈值)) */ +// @Excel(name = "异常类型", readConverterExp = "0=超过阈值,1=小于阈值") private Long alarmType; /** 异常状态(0已处理 1未处理) */ diff --git a/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAlarmRule.java b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAlarmRule.java index 442958f..14af4b0 100644 --- a/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAlarmRule.java +++ b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAlarmRule.java @@ -44,8 +44,8 @@ public class EmsRecordAlarmRule extends BaseEntity @Excel(name = "能源类型") private Long energyType; - /** 触发规则(0超过阈值 1设备报警) */ - @Excel(name = "触发规则", readConverterExp = "0=超过阈值,1=设备报警") + /** 触发规则(0大于 1小于) */ + @Excel(name = "触发规则", readConverterExp = "0=超过阈值,1=小于阈值") private Long triggerRule; /** 监测字段 */ diff --git a/os-ems/src/main/java/com/os/ems/record/domain/RecordIotenvInstant.java b/os-ems/src/main/java/com/os/ems/record/domain/RecordIotenvInstant.java index 0cfb0ef..b960b12 100644 --- a/os-ems/src/main/java/com/os/ems/record/domain/RecordIotenvInstant.java +++ b/os-ems/src/main/java/com/os/ems/record/domain/RecordIotenvInstant.java @@ -86,6 +86,10 @@ public class RecordIotenvInstant extends BaseEntity @Excel(name = "计量设备编号") private String monitorCode; + /** 能源类型 */ + private Long monitorType; + private String energyName; + // // public void setObjid(Long objid) diff --git a/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordAlarmDataMapper.java b/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordAlarmDataMapper.java index 9e74793..010c737 100644 --- a/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordAlarmDataMapper.java +++ b/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordAlarmDataMapper.java @@ -84,7 +84,7 @@ public interface EmsRecordAlarmDataMapper @Param("endTime") Date endTime); /** - * 获取数据表总数(alarm_type = 0 + * 获取异常数据表总数(包含所有告警类型) */ Integer getAlarmDataTotalCount(); } diff --git a/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordAlarmDataService.java b/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordAlarmDataService.java index 7f76bce..51083e4 100644 --- a/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordAlarmDataService.java +++ b/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordAlarmDataService.java @@ -72,7 +72,7 @@ public interface IEmsRecordAlarmDataService void checkIotenvThresholdAlarms(); /** - * 获取数据表总数(alarm_type = 0) + * 获取异常数据表总数(包含所有告警类型) */ public int getAlarmDataTotalCount(); } diff --git a/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java index 1925ee7..bcdc0bf 100644 --- a/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java @@ -744,7 +744,7 @@ public class EmsRecordAlarmDataServiceImpl implements IEmsRecordAlarmDataService } /** - * 获取数据表总数(alarm_type = 0 + * 获取异常数据表总数(包含所有告警类型) */ @Override public int getAlarmDataTotalCount() { diff --git a/os-ems/src/main/java/com/os/ems/record/service/impl/RecordIotenvInstantServiceImpl.java b/os-ems/src/main/java/com/os/ems/record/service/impl/RecordIotenvInstantServiceImpl.java index 89da9d5..e92212f 100644 --- a/os-ems/src/main/java/com/os/ems/record/service/impl/RecordIotenvInstantServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/record/service/impl/RecordIotenvInstantServiceImpl.java @@ -330,6 +330,7 @@ public class RecordIotenvInstantServiceImpl implements IRecordIotenvInstantServi String monitorCode = baseMonitorInfo.getMonitorCode(); String monitorName = baseMonitorInfo.getMonitorName(); Long monitorType = baseMonitorInfo.getMonitorType(); + String energyName = baseMonitorInfo.getEnergyName(); RecordIotenvInstant iotenvInstant = recordMap.get(monitorCode); if (iotenvInstant == null) { @@ -341,6 +342,8 @@ public class RecordIotenvInstantServiceImpl implements IRecordIotenvInstantServi // 设置设备基本信息 iotenvInstant.setMonitorName(monitorName); iotenvInstant.setMonitorCode(monitorCode); + iotenvInstant.setEnergyName(energyName); + iotenvInstant.setMonitorType(monitorType); result.add(iotenvInstant); } @@ -351,6 +354,8 @@ public class RecordIotenvInstantServiceImpl implements IRecordIotenvInstantServi iotenvInstant.setMonitorId(baseMonitorInfo.getMonitorCode()); iotenvInstant.setMonitorName(baseMonitorInfo.getMonitorName()); iotenvInstant.setMonitorCode(baseMonitorInfo.getMonitorCode()); + iotenvInstant.setEnergyName(baseMonitorInfo.getEnergyName()); + iotenvInstant.setMonitorType(baseMonitorInfo.getMonitorType()); // 数据值字段保持null,前端会显示"无最新数据" result.add(iotenvInstant); } diff --git a/os-ems/src/main/resources/mapper/ems/record/EmsRecordAlarmDataMapper.xml b/os-ems/src/main/resources/mapper/ems/record/EmsRecordAlarmDataMapper.xml index f222af6..256ab02 100644 --- a/os-ems/src/main/resources/mapper/ems/record/EmsRecordAlarmDataMapper.xml +++ b/os-ems/src/main/resources/mapper/ems/record/EmsRecordAlarmDataMapper.xml @@ -53,23 +53,24 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" @@ -159,8 +160,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" rad.notify_user FROM ems_record_alarm_data rad WHERE rad.alarm_status = 1 - AND rad.alarm_type = 0 AND rad.create_time >= #{startTime} + ORDER BY rad.obj_id DESC @@ -170,16 +171,14 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" FROM ems_record_alarm_data WHERE monitor_id = #{monitorId} AND cause = #{cause} - AND alarm_type = 0 AND alarm_status = 1 AND collect_time BETWEEN #{startTime} AND #{endTime} - +