diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsGroupServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsGroupServiceImpl.java index 7c7211b..d47e02b 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsGroupServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsGroupServiceImpl.java @@ -270,14 +270,15 @@ public class CsGroupServiceImpl extends ServiceImpl impl commonQueryParam.setTableName(getTableNameByClassId(epdPqd.getClassId())); commonQueryParam.setColumnName(epdPqd.getName()+ (param.getFrequency() == null ? "":"_"+param.getFrequency())); commonQueryParam.setPhasic(epdPqd.getPhase()); - commonQueryParam.setStartTime(commonStatisticalQueryParam.getStartTime()); - commonQueryParam.setEndTime(commonStatisticalQueryParam.getEndTime()); + //commonQueryParam.setStartTime(commonStatisticalQueryParam.getStartTime()); + //commonQueryParam.setEndTime(commonStatisticalQueryParam.getEndTime()); commonQueryParam.setDataType(commonStatisticalQueryParam.getValueType()); commonQueryParam.setProcess(data1.get(0).getProcess()+""); commonQueryParam.setClDid(getClDidByLineId(temp.getLineId())); return commonQueryParam; }).collect(Collectors.toList()); - List deviceRtData = commonService.getDeviceRtDataByTime(commonQueryParams); + //List deviceRtData = commonService.getDeviceRtDataByTime(commonQueryParams); + List deviceRtData = commonService.getDeviceRtData(commonQueryParams); List collect1 = deviceRtData.stream().map(temp -> { ThdDataVO vo = new ThdDataVO(); vo.setLineId(temp.getLineId()); diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java index c6e9122..b4cf1be 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java @@ -258,34 +258,33 @@ public class PortableOfflLogServiceImpl extends ServiceImpl