diff --git a/ems-system/src/main/java/com/xzzn/ems/domain/vo/PointNameRequest.java b/ems-system/src/main/java/com/xzzn/ems/domain/vo/PointNameRequest.java index f7b7470..f2eaa6f 100644 --- a/ems-system/src/main/java/com/xzzn/ems/domain/vo/PointNameRequest.java +++ b/ems-system/src/main/java/com/xzzn/ems/domain/vo/PointNameRequest.java @@ -22,6 +22,8 @@ public class PointNameRequest { private String endDate; + private String deviceId; + private Map> siteDeviceMap; public List getSiteIds() { @@ -79,4 +81,12 @@ public class PointNameRequest { public void setSiteDeviceMap(Map> siteDeviceMap) { this.siteDeviceMap = siteDeviceMap; } + + public String getDeviceId() { + return deviceId; + } + + public void setDeviceId(String deviceId) { + this.deviceId = deviceId; + } } 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 818acb3..78aabdc 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 @@ -100,17 +100,20 @@ public interface EmsPointMatchMapper @Param("tableName")String tableName, @Param("tableField")String tableField, @Param("startDate")Date startDate, - @Param("endDate")Date endDate); + @Param("endDate")Date endDate, + @Param("deviceId")String deviceId); // 根据条件查询数据-按小时-其他设备 public List getCommonPointDataByHours(@Param("siteIds")List siteIds, @Param("tableName")String tableName, @Param("tableField")String tableField, @Param("startDate") Date startDate, - @Param("endDate")Date endDate); + @Param("endDate")Date endDate, + @Param("deviceId")String deviceId); // 根据条件查询数据-按天-其他设备 public List getCommonPointDataByDays(@Param("siteIds")List siteIds, @Param("tableName")String tableName, @Param("tableField")String tableField, @Param("startDate")Date startDate, - @Param("endDate")Date endDate); + @Param("endDate")Date endDate, + @Param("deviceId")String deviceId); } diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/GeneralQueryServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/GeneralQueryServiceImpl.java index 78bf576..0fadf9b 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/GeneralQueryServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/GeneralQueryServiceImpl.java @@ -129,20 +129,21 @@ public class GeneralQueryServiceImpl implements IGeneralQueryService List dataVoList = new ArrayList<>(); int dataUnit = request.getDataUnit(); + String deviceId = request.getDeviceId(); Date startDate = DateUtils.dateTime(DateUtils.YYYY_MM_DD_HH_MM_SS,request.getStartDate()); Date endDate = DateUtils.dateTime(DateUtils.YYYY_MM_DD_HH_MM_SS,request.getEndDate()); if (dataUnit == 1) { // 分钟:yyyy-MM-dd HH:mm:ss startDate = DateUtils.adjustToStartOfMinutes(request.getStartDate()); - dataVoList = emsPointMatchMapper.getCommonPointDataByMinutes(querySiteIds,tableName,tableField,startDate,endDate); + dataVoList = emsPointMatchMapper.getCommonPointDataByMinutes(querySiteIds,tableName,tableField,startDate,endDate,deviceId); if (dataVoList != null && dataVoList.size() > 0) { dataVoList = dealWithMinutesData(querySiteIds,dataVoList,deviceCategory, request.getStartDate(),request.getEndDate()); } } else if (dataUnit == 2) { // 小时:yyyy-MM-dd HH:mm:ss - dataVoList = emsPointMatchMapper.getCommonPointDataByHours(querySiteIds,tableName,tableField,startDate,endDate); + dataVoList = emsPointMatchMapper.getCommonPointDataByHours(querySiteIds,tableName,tableField,startDate,endDate,deviceId); } else if (dataUnit == 3) { // 天:yyyy-MM-dd 00:00:00 endDate = DateUtils.adjustToEndOfDay(request.getEndDate()); - dataVoList = emsPointMatchMapper.getCommonPointDataByDays(querySiteIds,tableName,tableField,startDate,endDate); + dataVoList = emsPointMatchMapper.getCommonPointDataByDays(querySiteIds,tableName,tableField,startDate,endDate,deviceId); } // 数据转换 diff --git a/ems-system/src/main/resources/mapper/ems/EmsPointMatchMapper.xml b/ems-system/src/main/resources/mapper/ems/EmsPointMatchMapper.xml index 5064b7d..853e524 100644 --- a/ems-system/src/main/resources/mapper/ems/EmsPointMatchMapper.xml +++ b/ems-system/src/main/resources/mapper/ems/EmsPointMatchMapper.xml @@ -238,6 +238,9 @@ #{siteId} + + and device_id = #{deviceId} + GROUP BY valueDate, site_id, device_id,pointValue ORDER BY site_id,device_id, valueDate ASC @@ -259,6 +262,9 @@ #{siteId} + + and device_id = #{deviceId} + GROUP BY site_id, device_id, hour_group ) tmp ON t.site_id = tmp.site_id AND t.device_id = tmp.device_id @@ -285,6 +291,9 @@ #{siteId} + + and device_id = #{deviceId} + GROUP BY site_id, device_id, day_group ) tmp ON t.site_id = tmp.site_id AND t.device_id = tmp.device_id