diff --git a/ems-system/src/main/java/com/xzzn/ems/domain/vo/AmmeterDataVo.java b/ems-system/src/main/java/com/xzzn/ems/domain/vo/AmmeterDataVo.java index 54f4b7f..ff85c61 100644 --- a/ems-system/src/main/java/com/xzzn/ems/domain/vo/AmmeterDataVo.java +++ b/ems-system/src/main/java/com/xzzn/ems/domain/vo/AmmeterDataVo.java @@ -2,6 +2,7 @@ package com.xzzn.ems.domain.vo; import com.fasterxml.jackson.annotation.JsonFormat; +import java.math.BigDecimal; import java.util.Date; import java.util.List; @@ -26,6 +27,87 @@ public class AmmeterDataVo { /** 表数据信息 */ private List loadDataDetailInfo; + // 正向有功电能 + private BigDecimal forwardActive; + // 反向有功电能 + private BigDecimal reverseActive; + // 正向无功电能 + private BigDecimal forwardReactive; + // 反向无功电能 + private BigDecimal reverseReactive; + // 有功功率 + private BigDecimal activePower; + // 无功功率 + private BigDecimal reactivePower; + // 有功电能 + private BigDecimal activeEnergy; + // 无功电能 + private BigDecimal reactiveEnergy; + + public BigDecimal getActiveEnergy() { + return activeEnergy; + } + + public void setActiveEnergy(BigDecimal activeEnergy) { + this.activeEnergy = activeEnergy; + } + + public BigDecimal getReactiveEnergy() { + return reactiveEnergy; + } + + public void setReactiveEnergy(BigDecimal reactiveEnergy) { + this.reactiveEnergy = reactiveEnergy; + } + + public BigDecimal getForwardActive() { + return forwardActive; + } + + public void setForwardActive(BigDecimal forwardActive) { + this.forwardActive = forwardActive; + } + + public BigDecimal getReverseActive() { + return reverseActive; + } + + public void setReverseActive(BigDecimal reverseActive) { + this.reverseActive = reverseActive; + } + + public BigDecimal getForwardReactive() { + return forwardReactive; + } + + public void setForwardReactive(BigDecimal forwardReactive) { + this.forwardReactive = forwardReactive; + } + + public BigDecimal getReverseReactive() { + return reverseReactive; + } + + public void setReverseReactive(BigDecimal reverseReactive) { + this.reverseReactive = reverseReactive; + } + + public BigDecimal getActivePower() { + return activePower; + } + + public void setActivePower(BigDecimal activePower) { + this.activePower = activePower; + } + + public BigDecimal getReactivePower() { + return reactivePower; + } + + public void setReactivePower(BigDecimal reactivePower) { + this.reactivePower = reactivePower; + } + public String getDeviceName() { return deviceName; } diff --git a/ems-system/src/main/java/com/xzzn/ems/mapper/EmsPointMatchMapper.java b/ems-system/src/main/java/com/xzzn/ems/mapper/EmsPointMatchMapper.java index 6bd17d6..2807b09 100644 --- a/ems-system/src/main/java/com/xzzn/ems/mapper/EmsPointMatchMapper.java +++ b/ems-system/src/main/java/com/xzzn/ems/mapper/EmsPointMatchMapper.java @@ -121,13 +121,13 @@ public interface EmsPointMatchMapper // 单个站点单个设备点位查询-除了电池簇其他设备使用 public List getSingleSiteDevicePoints(@Param("siteId")String siteId, @Param("deviceCategory")String deviceCategory, - @Param("dataPointName")String dataPointName, + @Param("pointName")String pointName, @Param("dataPoint")String dataPoint); // 单个站点单个设备点位查询-电池簇使用 public List getClusterDevicePoints(@Param("siteId")String siteId, @Param("deviceId")String deviceId, @Param("parentDeviceId")String parentDeviceId, @Param("deviceCategory")String deviceCategory, - @Param("dataPointName")String dataPointName, + @Param("pointName")String pointName, @Param("dataPoint")String dataPoint); } diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsDeviceSettingServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsDeviceSettingServiceImpl.java index 66d006f..af9ef50 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsDeviceSettingServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsDeviceSettingServiceImpl.java @@ -190,9 +190,13 @@ public class EmsDeviceSettingServiceImpl implements IEmsDeviceSettingService // 结果排序 String sortMethod = request.getSortMethod(); if (sortMethod==null || sortMethod.isEmpty() || "asc".equals(sortMethod)) {// 升序 - response = response.stream().sorted(Comparator.comparing(PointQueryResponse::getUpdateTime)).collect(Collectors.toList()); + response = response.stream() + .filter(p -> p.getPointValue() != null) + .sorted(Comparator.comparing(PointQueryResponse::getUpdateTime)).collect(Collectors.toList()); } else if ("desc".equals(sortMethod)) {//降序 - response = response.stream().sorted(Comparator.comparing(PointQueryResponse::getUpdateTime).reversed()).collect(Collectors.toList()); + response = response.stream() + .filter(p -> p.getPointValue() != null) + .sorted(Comparator.comparing(PointQueryResponse::getUpdateTime).reversed()).collect(Collectors.toList()); } return response; } diff --git a/ems-system/src/main/resources/mapper/ems/EmsPointMatchMapper.xml b/ems-system/src/main/resources/mapper/ems/EmsPointMatchMapper.xml index 4126698..870d722 100644 --- a/ems-system/src/main/resources/mapper/ems/EmsPointMatchMapper.xml +++ b/ems-system/src/main/resources/mapper/ems/EmsPointMatchMapper.xml @@ -332,8 +332,8 @@ and t.device_category = #{deviceCategory} - - and t.data_point_name like CONCAT('%', #{dataPointName}, '%') + + and t.point_name like CONCAT('%', #{pointName}, '%') and t.data_point like CONCAT('%', #{dataPoint}, '%') @@ -362,8 +362,8 @@ ) as tmp where 1=1 - - and tmp.dataPointName like CONCAT('%', #{dataPointName}, '%') + + and tmp.point_name like CONCAT('%', #{pointName}, '%') and tmp.dataPoint like CONCAT('%', #{dataPoint}, '%')