diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/InfluxdbCsCommunicateServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/InfluxdbCsCommunicateServiceImpl.java index a9c1792..41cda98 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/InfluxdbCsCommunicateServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/InfluxdbCsCommunicateServiceImpl.java @@ -95,7 +95,7 @@ public class InfluxdbCsCommunicateServiceImpl implements ICsCommunicateService { .select(PqsCommunicate::getDevId) .select(PqsCommunicate::getDescription) .select(PqsCommunicate::getType) - .le(PqsCommunicate::getTime, lineParam.getEndTime()) + .between(PqsCommunicate::getTime, lineParam.getStartTime(), lineParam.getEndTime()) .timeDesc() .limit(1); List list = pqsCommunicateMapper.selectByQueryWrapper(influxQueryWrapper); diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/RStatOnlineRateDServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/RStatOnlineRateDServiceImpl.java index bba0b9c..286f246 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/RStatOnlineRateDServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/RStatOnlineRateDServiceImpl.java @@ -188,6 +188,10 @@ public class RStatOnlineRateDServiceImpl extends MppServiceImpl