diff --git a/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java b/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java index df18318..760854a 100644 --- a/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java +++ b/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java @@ -1,6 +1,5 @@ package com.njcn.influx.service.impl; -import cn.hutool.core.util.ObjectUtil; import com.njcn.influx.imapper.CommonMapper; import com.njcn.influx.pojo.bo.CommonQueryParam; import com.njcn.influx.pojo.constant.InfluxDBTableConstant; @@ -10,7 +9,9 @@ import com.njcn.influx.service.CommonService; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; -import java.util.*; +import java.time.LocalDateTime; +import java.util.ArrayList; +import java.util.List; /** * Description: @@ -32,6 +33,7 @@ public class CommonServiceImpl implements CommonService { .select(StatisticalDataDTO::getPhaseType) .select(StatisticalDataDTO::getValueType) .last(columnName) + .le(InfluxDBTableConstant.TIME, LocalDateTime.now()) .eq(InfluxDBTableConstant.LINE_ID,lineId) .eq(InfluxDBTableConstant.PHASIC_TYPE,phasic) .eq(InfluxDBTableConstant.VALUE_TYPE,dataType)