From e33c78a0408832135e2ff272d4ad4f393f4f4b65 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Thu, 18 Jan 2024 17:23:16 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B2=B3=E5=8C=97=E8=B6=85=E9=AB=98=E5=8E=8B?=
 =?UTF-8?q?=E7=AE=97=E6=B3=95=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../harmonic/service/mysql/Impl/line/DayDataServiceImpl.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java
index a30d62924..c25d8dcd0 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java
@@ -151,6 +151,7 @@ public class DayDataServiceImpl implements DayDataService {
         for (List<String> pendingId : pendingIds) {
             //获取dataV数据
             List<DataV> vList = getDataV(pendingId,beginDay,endDay);
+            log.info("mysql入库数据：" + vList);
             list1.addAll(vList);
             //获取dataI数据
             //List<DataI> iList = getDataI(pendingId,beginDay,endDay);
@@ -464,6 +465,7 @@ public class DayDataServiceImpl implements DayDataService {
                 .groupBy(DataV::getLineId,DataV::getPhasicType,DataV::getQualityFlag,DataV::getValueType)
                 .between(DataV::getTime, startTime, endTime);
         List<DataV> result1 = dataVMapper.getStatisticsByWraper(influxQueryWrapper);
+        log.info("最小值数据：" + result1);
         result.addAll(result1);
         //最大值
         InfluxQueryWrapper influxQueryWrapper2 = new InfluxQueryWrapper(DataV.class);
@@ -484,6 +486,7 @@ public class DayDataServiceImpl implements DayDataService {
                 .groupBy(DataV::getLineId,DataV::getPhasicType,DataV::getQualityFlag,DataV::getValueType)
                 .between(DataV::getTime, startTime, endTime);
         List<DataV> result2 = dataVMapper.getStatisticsByWraper(influxQueryWrapper2);
+        log.info("最大值数据：" + result2);
         result.addAll(result2);
         //平均值
         InfluxQueryWrapper influxQueryWrapper3 = new InfluxQueryWrapper(DataV.class);
@@ -504,6 +507,7 @@ public class DayDataServiceImpl implements DayDataService {
                 .groupBy(DataV::getLineId,DataV::getPhasicType,DataV::getQualityFlag,DataV::getValueType)
                 .between(DataV::getTime, startTime, endTime);
         List<DataV> result3 = dataVMapper.getStatisticsByWraper(influxQueryWrapper3);
+        log.info("平均值数据：" + result3);
         result.addAll(result3);
         //CP95(取平均值的CP95值)
         InfluxQueryWrapper influxQueryWrapper4 = new InfluxQueryWrapper(DataV.class);
@@ -524,6 +528,7 @@ public class DayDataServiceImpl implements DayDataService {
                 .groupBy(DataV::getLineId,DataV::getPhasicType,DataV::getQualityFlag,DataV::getValueType)
                 .between(DataV::getTime, startTime, endTime);
         List<DataV> result4 = dataVMapper.getStatisticsByWraper(influxQueryWrapper4);
+        log.info("CP95值数据：" + result4);
         result4.forEach(item->{
             item.setValueType(InfluxDbSqlConstant.CP95);
         });