From ac08343f56c1acfee08a56a08ff8bc422da1ef1b Mon Sep 17 00:00:00 2001 From: guofeihu <3347277866@qq.com> Date: Sat, 14 Sep 2024 09:21:32 +0800 Subject: [PATCH] =?UTF-8?q?DataInHarmV=E8=AF=A5=E5=90=8D=E7=A7=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/DataInHarmRateVService.java | 13 --------- .../influx/service/DataInHarmVService.java | 13 +++++++++ .../impl/DataInHarmRateVServiceImpl.java | 29 ------------------- .../service/impl/DataInHarmVServiceImpl.java | 29 +++++++++++++++++++ 4 files changed, 42 insertions(+), 42 deletions(-) delete mode 100644 src/main/java/com/njcn/influx/service/DataInHarmRateVService.java create mode 100644 src/main/java/com/njcn/influx/service/DataInHarmVService.java delete mode 100644 src/main/java/com/njcn/influx/service/impl/DataInHarmRateVServiceImpl.java create mode 100644 src/main/java/com/njcn/influx/service/impl/DataInHarmVServiceImpl.java diff --git a/src/main/java/com/njcn/influx/service/DataInHarmRateVService.java b/src/main/java/com/njcn/influx/service/DataInHarmRateVService.java deleted file mode 100644 index 76ff497..0000000 --- a/src/main/java/com/njcn/influx/service/DataInHarmRateVService.java +++ /dev/null @@ -1,13 +0,0 @@ -package com.njcn.influx.service; - -import com.njcn.influx.pojo.po.DataInHarmRateV; -import java.util.List; - -/** - * @author guofeihu - * @version 1.0.0 - * @date 2024年09月13日 11:01 - */ -public interface DataInHarmRateVService { - List getNewDataInHarmRateV(String lineIndex, String startTime, String endTime); -} diff --git a/src/main/java/com/njcn/influx/service/DataInHarmVService.java b/src/main/java/com/njcn/influx/service/DataInHarmVService.java new file mode 100644 index 0000000..32afdf1 --- /dev/null +++ b/src/main/java/com/njcn/influx/service/DataInHarmVService.java @@ -0,0 +1,13 @@ +package com.njcn.influx.service; + +import com.njcn.influx.pojo.po.DataInHarmV; +import java.util.List; + +/** + * @author guofeihu + * @version 1.0.0 + * @date 2024年09月13日 11:01 + */ +public interface DataInHarmVService { + List getNewDataInHarmV(String lineIndex, String startTime, String endTime); +} diff --git a/src/main/java/com/njcn/influx/service/impl/DataInHarmRateVServiceImpl.java b/src/main/java/com/njcn/influx/service/impl/DataInHarmRateVServiceImpl.java deleted file mode 100644 index 634c86b..0000000 --- a/src/main/java/com/njcn/influx/service/impl/DataInHarmRateVServiceImpl.java +++ /dev/null @@ -1,29 +0,0 @@ -package com.njcn.influx.service.impl; - -import com.njcn.influx.imapper.DataInHarmRateVMapper; -import com.njcn.influx.pojo.po.DataInHarmRateV; -import com.njcn.influx.query.InfluxQueryWrapper; -import com.njcn.influx.service.DataInHarmRateVService; -import lombok.RequiredArgsConstructor; -import org.springframework.stereotype.Service; -import java.util.List; - -/** - * @author guofeihu - * @version 1.0.0 - * @date 2024年09月13日 11:01 - */ -@Service -@RequiredArgsConstructor -public class DataInHarmRateVServiceImpl implements DataInHarmRateVService { - - private final DataInHarmRateVMapper dataInHarmRateVMapper; - - @Override - public List getNewDataInHarmRateV(String lineIndex, String startTime, String endTime) { - InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataInHarmRateV.class); - influxQueryWrapper.eq(DataInHarmRateV::getLineId, lineIndex) - .between(DataInHarmRateV::getTime, startTime, endTime);; - return dataInHarmRateVMapper.getStatisticsByWraper(influxQueryWrapper); - } -} diff --git a/src/main/java/com/njcn/influx/service/impl/DataInHarmVServiceImpl.java b/src/main/java/com/njcn/influx/service/impl/DataInHarmVServiceImpl.java new file mode 100644 index 0000000..56d75e7 --- /dev/null +++ b/src/main/java/com/njcn/influx/service/impl/DataInHarmVServiceImpl.java @@ -0,0 +1,29 @@ +package com.njcn.influx.service.impl; + +import com.njcn.influx.imapper.DataInHarmVMapper; +import com.njcn.influx.pojo.po.DataInHarmV; +import com.njcn.influx.query.InfluxQueryWrapper; +import com.njcn.influx.service.DataInHarmVService; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; +import java.util.List; + +/** + * @author guofeihu + * @version 1.0.0 + * @date 2024年09月13日 11:01 + */ +@Service +@RequiredArgsConstructor +public class DataInHarmVServiceImpl implements DataInHarmVService { + + private final DataInHarmVMapper dataInHarmVMapper; + + @Override + public List getNewDataInHarmV(String lineIndex, String startTime, String endTime) { + InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(DataInHarmV.class); + influxQueryWrapper.eq(DataInHarmV::getLineId, lineIndex) + .between(DataInHarmV::getTime, startTime, endTime);; + return dataInHarmVMapper.getStatisticsByWraper(influxQueryWrapper); + } +}