diff --git a/ems-system/src/main/java/com/xzzn/ems/domain/vo/AlarmRecordListRequestVo.java b/ems-system/src/main/java/com/xzzn/ems/domain/vo/AlarmRecordListRequestVo.java index a6179f3..b334c00 100644 --- a/ems-system/src/main/java/com/xzzn/ems/domain/vo/AlarmRecordListRequestVo.java +++ b/ems-system/src/main/java/com/xzzn/ems/domain/vo/AlarmRecordListRequestVo.java @@ -26,6 +26,9 @@ public class AlarmRecordListRequestVo { /** 设备id */ private String deviceId; + /** 告警状态 */ + private String status; + public String getSiteId() { return siteId; } @@ -73,4 +76,12 @@ public class AlarmRecordListRequestVo { public void setDeviceId(String deviceId) { this.deviceId = deviceId; } + + public String getStatus() { + return status; + } + + public void setStatus(String status) { + this.status = status; + } } diff --git a/ems-system/src/main/java/com/xzzn/ems/domain/vo/SiteDeviceListVo.java b/ems-system/src/main/java/com/xzzn/ems/domain/vo/SiteDeviceListVo.java index dab2423..5ddddf8 100644 --- a/ems-system/src/main/java/com/xzzn/ems/domain/vo/SiteDeviceListVo.java +++ b/ems-system/src/main/java/com/xzzn/ems/domain/vo/SiteDeviceListVo.java @@ -25,6 +25,8 @@ public class SiteDeviceListVo { private String id; /** 父类id */ private String parentId; + /** 单体电池个数-仅stack设备下有 */ + private int batteryNum; public String getSiteId() { return siteId; @@ -105,4 +107,12 @@ public class SiteDeviceListVo { public void setParentId(String parentId) { this.parentId = parentId; } + + public int getBatteryNum() { + return batteryNum; + } + + public void setBatteryNum(int batteryNum) { + this.batteryNum = batteryNum; + } } diff --git a/ems-system/src/main/java/com/xzzn/ems/mapper/EmsBatteryDataDayMapper.java b/ems-system/src/main/java/com/xzzn/ems/mapper/EmsBatteryDataDayMapper.java index 45f7da2..1928e99 100644 --- a/ems-system/src/main/java/com/xzzn/ems/mapper/EmsBatteryDataDayMapper.java +++ b/ems-system/src/main/java/com/xzzn/ems/mapper/EmsBatteryDataDayMapper.java @@ -4,6 +4,8 @@ import java.time.LocalDateTime; import java.util.List; import com.xzzn.ems.domain.EmsBatteryDataDay; import com.xzzn.ems.domain.EmsBatteryDataHour; +import com.xzzn.ems.domain.vo.BatteryDataStatsListVo; +import com.xzzn.ems.domain.vo.DateSearchRequest; import org.apache.ibatis.annotations.Param; /** @@ -69,4 +71,6 @@ public interface EmsBatteryDataDayMapper * 批量插入或更新天级数据(存在则更新,不存在则插入) */ void batchInsertOrUpdate(@Param("list") List dayDataList); + + public List getBatteryDayData(DateSearchRequest requestVo); } diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/DDSDataProcessServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/DDSDataProcessServiceImpl.java index cec9755..04d81d3 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/DDSDataProcessServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/DDSDataProcessServiceImpl.java @@ -815,13 +815,13 @@ public class DDSDataProcessServiceImpl extends AbstractBatteryDataProcessor impl dataMete.setCurrentCombActiveFlat(StringUtils.getBigDecimal(obj.get("DQZHYGPDN"))); dataMete.setCurrentCombActiveValley(StringUtils.getBigDecimal(obj.get("DQZHYGGDN"))); // 电能设置-正向有功 - dataMete.setCurrentForwardActiveTotal(StringUtils.getBigDecimal(obj.get("DQZXYGZDN"))); + dataMete.setCurrentForwardActiveTotal(StringUtils.getBigDecimal(obj.get("DQZXZYGDN"))); dataMete.setCurrentForwardActivePeak(StringUtils.getBigDecimal(obj.get("DQZXYGJDN"))); dataMete.setCurrentForwardActiveHigh(StringUtils.getBigDecimal(obj.get("DQZXYGFDN"))); dataMete.setCurrentForwardActiveFlat(StringUtils.getBigDecimal(obj.get("DQZXYGPDN"))); dataMete.setCurrentForwardActiveValley(StringUtils.getBigDecimal(obj.get("DQZXYGGDN"))); // 电能设置-反向有功 - dataMete.setCurrentReverseActiveTotal(StringUtils.getBigDecimal(obj.get("DQFXYGZDN"))); + dataMete.setCurrentReverseActiveTotal(StringUtils.getBigDecimal(obj.get("DQFXZYGDN"))); dataMete.setCurrentReverseActivePeak(StringUtils.getBigDecimal(obj.get("DQFXYGJDN"))); dataMete.setCurrentReverseActiveHigh(StringUtils.getBigDecimal(obj.get("DQFXYGFDN"))); dataMete.setCurrentReverseActiveFlat(StringUtils.getBigDecimal(obj.get("DQFXYGPDN"))); diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsSiteServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsSiteServiceImpl.java index d88adfe..cadf8d7 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsSiteServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsSiteServiceImpl.java @@ -1,6 +1,9 @@ package com.xzzn.ems.service.impl; +import com.xzzn.common.constant.RedisKeyConstants; +import com.xzzn.common.core.redis.RedisCache; import com.xzzn.common.enums.DeviceCategory; +import com.xzzn.ems.domain.EmsBatteryData; import com.xzzn.ems.domain.EmsSiteSetting; import com.xzzn.ems.domain.vo.SiteDeviceListVo; import com.xzzn.ems.domain.vo.SiteTotalInfoVo; @@ -25,6 +28,8 @@ public class EmsSiteServiceImpl implements IEmsSiteService private EmsSiteSettingMapper emsSiteMapper; @Autowired private EmsDevicesSettingMapper emsDevicesMapper; + @Autowired + private RedisCache redisCache; @Override public List getAllSites() { @@ -76,7 +81,20 @@ public class EmsSiteServiceImpl implements IEmsSiteService */ @Override public List getAllDeviceList(String siteId) { - return emsSiteMapper.getAllSiteDeviceList(siteId); + List resultData = emsSiteMapper.getAllSiteDeviceList(siteId); + if(resultData == null || resultData.size() == 0){ + return resultData; + } + for (SiteDeviceListVo siteDeviceListVo : resultData) { + String clusterId = siteDeviceListVo.getDeviceId(); + String deviceCategory = siteDeviceListVo.getDeviceCategory(); + if(DeviceCategory.CLUSTER.getCode().equals(deviceCategory)){ + // 获取该stack下面有多少单体电池 + List batteryDataList = redisCache.getCacheList(RedisKeyConstants.BATTERY + siteId + "_" + clusterId); + siteDeviceListVo.setBatteryNum(batteryDataList == null ? 0 : batteryDataList.size()); + } + } + return resultData; } /** diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsStatsReportServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsStatsReportServiceImpl.java index 2cdb178..c1a10d7 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsStatsReportServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsStatsReportServiceImpl.java @@ -39,6 +39,8 @@ public class EmsStatsReportServiceImpl implements IEmsStatsReportService private EmsBatteryDataMapper emsBatteryDataMapper; @Autowired private EmsBatteryDailyLatestMapper emsBatteryDailyLatestMapper; + @Autowired + private EmsBatteryDataDayMapper emsBatteryDataDayMapper; // 电量指标 @Override @@ -295,6 +297,6 @@ public class EmsStatsReportServiceImpl implements IEmsStatsReportService public List getSingleBatteryData(DateSearchRequest requestVo) { // 默认时间-7天 dealRequestTime(requestVo); - return emsBatteryDailyLatestMapper.getBatteryDailyLatest(requestVo); + return emsBatteryDataDayMapper.getBatteryDayData(requestVo); } } diff --git a/ems-system/src/main/resources/mapper/ems/EmsAlarmRecordsMapper.xml b/ems-system/src/main/resources/mapper/ems/EmsAlarmRecordsMapper.xml index 9e8ed76..e47c236 100644 --- a/ems-system/src/main/resources/mapper/ems/EmsAlarmRecordsMapper.xml +++ b/ems-system/src/main/resources/mapper/ems/EmsAlarmRecordsMapper.xml @@ -162,6 +162,13 @@ AND t.device_id = #{deviceId} + + AND t.status IN ( + + #{item} + + ) + AND (date_format(t.alarm_start_time,'%Y%m%d') BETWEEN date_format(#{alarmStartTime},'%Y%m%d') and date_format(#{alarmEndTime},'%Y%m%d') or date_format(t.alarm_end_time,'%Y%m%d') BETWEEN date_format(#{alarmStartTime},'%Y%m%d') and date_format(#{alarmEndTime},'%Y%m%d') ) diff --git a/ems-system/src/main/resources/mapper/ems/EmsBatteryDataDayMapper.xml b/ems-system/src/main/resources/mapper/ems/EmsBatteryDataDayMapper.xml index be2f7b8..96e21ca 100644 --- a/ems-system/src/main/resources/mapper/ems/EmsBatteryDataDayMapper.xml +++ b/ems-system/src/main/resources/mapper/ems/EmsBatteryDataDayMapper.xml @@ -198,4 +198,19 @@ update_by = IF(VALUES(temperature) > temperature, VALUES(update_by), update_by), temperature = IF(VALUES(temperature) > temperature, VALUES(temperature), temperature) + + +