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 pendingId : pendingIds) { //获取dataV数据 List vList = getDataV(pendingId,beginDay,endDay); + log.info("mysql入库数据:" + vList); list1.addAll(vList); //获取dataI数据 //List 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 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 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 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 result4 = dataVMapper.getStatisticsByWraper(influxQueryWrapper4); + log.info("CP95值数据:" + result4); result4.forEach(item->{ item.setValueType(InfluxDbSqlConstant.CP95); });