From a7f17cd2eff15c96cde099e5f52445513926f0a1 Mon Sep 17 00:00:00 2001 From: xy <748613696@qq.com> Date: Tue, 5 Nov 2024 08:52:26 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/njcn/influx/service/CommonService.java | 8 ++++++++ .../njcn/influx/service/impl/CommonServiceImpl.java | 13 +++++++++++++ 2 files changed, 21 insertions(+) diff --git a/src/main/java/com/njcn/influx/service/CommonService.java b/src/main/java/com/njcn/influx/service/CommonService.java index 97e5f52..5de7e61 100644 --- a/src/main/java/com/njcn/influx/service/CommonService.java +++ b/src/main/java/com/njcn/influx/service/CommonService.java @@ -77,4 +77,12 @@ public interface CommonService { * @return */ List getTopTemperature(String lineId,String tableName, String columnName,String process); + + /** + * 获取监测点的指标数量，用来计算完整率 + * + */ + StatisticalDataDTO getCounts(String lineId, String tableName, String columnName,String resultName, String phasic, String dataType, String clDid, String process,String startTime, String endTime); + + } 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 73896d7..f353cd2 100644 --- a/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java +++ b/src/main/java/com/njcn/influx/service/impl/CommonServiceImpl.java @@ -147,6 +147,19 @@ public class CommonServiceImpl implements CommonService { return commonMapper.getTopTemperature(influxQueryWrapper); } + @Override + public StatisticalDataDTO getCounts(String lineId, String tableName, String columnName,String resultName, String phasic, String dataType, String clDid,String process,String startTime, String endTime) { + InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(tableName,StatisticalDataDTO.class); + influxQueryWrapper.select(StatisticalDataDTO::getLineId) + .count(columnName,resultName) + .eq(InfluxDBTableConstant.LINE_ID,lineId) + .eq(InfluxDBTableConstant.PHASIC_TYPE,phasic) + .eq(InfluxDBTableConstant.VALUE_TYPE,dataType) + .eq(InfluxDBTableConstant.CL_DID,clDid) + .eq(InfluxDBTableConstant.PROCESS,process) + .between(InfluxDBTableConstant.TIME, startTime, endTime);; + return commonMapper.getLineRtData(influxQueryWrapper); + } }