修改bug

2024-12-12 13:00:36 +08:00
parent eb54a13226
commit 721aa81c36
6 changed files with 96 additions and 92 deletions
--- a/pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/carrycapacity/impl/CarryCapacityServiceImpl.java
+++ b/pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/carrycapacity/impl/CarryCapacityServiceImpl.java
@@ -266,10 +266,10 @@ public class CarryCapacityServiceImpl implements CarryCapacityService {


        }
-        dataHarmPowerpList = dataHarmPowerpList.stream().map(temp -> {
-            temp.setTime(temp.getTime().plusMillis(TimeUnit.HOURS.toMillis(8)));
-            return temp;
-        }).collect(Collectors.toList());
+//        dataHarmPowerpList = dataHarmPowerpList.stream().map(temp -> {
+//            temp.setTime(temp.getTime().plusMillis(TimeUnit.HOURS.toMillis(8)));
+//            return temp;
+//        }).collect(Collectors.toList());
        carryCapacityDataVO.setData(dataHarmPowerpList);


@@ -336,10 +336,10 @@ public class CarryCapacityServiceImpl implements CarryCapacityService {
            redisUtil.saveByKey(lineId + "#" + LocalDateTimeUtil.format(startDate, formatter) + "#" + LocalDateTimeUtil.format(endDate, formatter) + "#" + "Q",
                    dataHarmPowerqList);
        }
-        dataHarmPowerqList = dataHarmPowerqList.stream().map(temp -> {
-            temp.setTime(temp.getTime().plusMillis(TimeUnit.HOURS.toMillis(8)));
-            return temp;
-        }).collect(Collectors.toList());
+//        dataHarmPowerqList = dataHarmPowerqList.stream().map(temp -> {
+//            temp.setTime(temp.getTime().plusMillis(TimeUnit.HOURS.toMillis(8)));
+//            return temp;
+//        }).collect(Collectors.toList());

        carryCapacityDataqVO.setData(dataHarmPowerqList);

@@ -394,13 +394,17 @@ public class CarryCapacityServiceImpl implements CarryCapacityService {
            stringBuilder2.append("line_id='").append(lineId).append("' and ").append(InfluxDbSqlConstant.TIME + " >= '").append(startTime).append("' and ").append(InfluxDbSqlConstant.TIME).append(" <= '").append(endTime).append("'  group by time(").append(timeInterval).append("m),* fill(3.1415926) ").append(InfluxDbSqlConstant.TZ);
            String sqlI1 = "select " + stringBuilder1 + " from " + InfluxDBTableConstant.DATA_I + " where value_type='CP95' and phasic_type!='T' and  " + stringBuilder2;
            dataI = dataiMapper.getSqlResult(sqlI1);
+            //此处查询influxdb少8个小时
+            dataI = dataI.stream().map(temp -> {
+                temp.setTime(temp.getTime().plusMillis(TimeUnit.HOURS.toMillis(8)));
+                return temp;
+            }).collect(Collectors.toList());
            if (CollectionUtil.isEmpty(dataI)) {
                throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
            } else {
                List<CarryCapcityData> iList = dataI.stream().map(temp -> {
                    CarryCapcityData carryCapcityData = new CarryCapcityData();
                    BeanUtils.copyProperties(temp, carryCapcityData);
-                    carryCapcityData.setTime(temp.getTime().plusMillis(TimeUnit.HOURS.toMillis(8)));
                    carryCapcityData.setValue(temp.getI2());
                    return carryCapcityData;
                }).collect(Collectors.toList());
@@ -419,7 +423,6 @@ public class CarryCapacityServiceImpl implements CarryCapacityService {
        List<CarryCapcityData> iList = dataI.stream().map(temp -> {
            CarryCapcityData carryCapcityData = new CarryCapcityData();
            BeanUtils.copyProperties(temp, carryCapcityData);
-            carryCapcityData.setTime(temp.getTime().plusMillis(TimeUnit.HOURS.toMillis(8)));
            carryCapcityData.setValue(Utils.getAttributeValueByPropertyName(temp, "i" + queryParam.getTime()));
            return carryCapcityData;
        }).collect(Collectors.toList());
@@ -624,81 +627,81 @@ public class CarryCapacityServiceImpl implements CarryCapacityService {
        List<CarryCapcityData> dataHarmPowerq2List = excelDataDTO.getDataHarmPowerQ2List();
        List<CarryCapcityData> dataHarmPoweruList = excelDataDTO.getDataHarmPowerU2List();

-//        //数据校验
-//        if (CollectionUtil.isEmpty(dataHarmPowerpList)) {
-//            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//        } else {
-//
-//            if (checkData(dataHarmPowerpList, startDate, endDate, timeInterval)) {
-//
-//                throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//            }
-//        }
-//        linearInterpolation(dataHarmPowerpList);
-//
-//        //数据校验
-//        if (CollectionUtil.isEmpty(dataHarmPowerp2List)) {
-//            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//        } else {
-//
-//            if (checkData(dataHarmPowerp2List, startDate2, endDate2, timeInterval)) {
-//
-//                throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//            }
-//        }
-//        linearInterpolation(dataHarmPowerp2List);
-//
-//        //数据校验
-//        if (CollectionUtil.isEmpty(dataHarmPowerqList)) {
-//            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//        } else {
-//
-//            if (checkData(dataHarmPowerqList, startDate, endDate, timeInterval)) {
-//
-//                throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//            }
-//        }
-//        linearInterpolation(dataHarmPowerqList);
-//
-//        //数据校验
-//        if (CollectionUtil.isEmpty(dataHarmPowerq2List)) {
-//            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//        } else {
-//
-//            if (checkData(dataHarmPowerq2List, startDate2, endDate2, timeInterval)) {
-//
-//                throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//            }
-//        }
-//        linearInterpolation(dataHarmPowerq2List);
-//
-//        //数据校验
-//        if (CollectionUtil.isEmpty(dataHarmPoweruList)) {
-//            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//        } else {
-//
-//            if (checkData(dataHarmPoweruList, startDate2, endDate2, timeInterval)) {
-//
-//                throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//            }
-//        }
-//        linearInterpolation(dataHarmPoweruList);
-//
-//        if (CollectionUtil.isEmpty(dataiList)) {
-//            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//        } else {
-//            List<CarryCapcityData> iList = dataiList.stream().map(temp -> {
-//                CarryCapcityData carryCapcityData = new CarryCapcityData();
-//                BeanUtils.copyProperties(temp, carryCapcityData);
-//                carryCapcityData.setValue(temp.getI2());
-//                return carryCapcityData;
-//            }).collect(Collectors.toList());
-//            if (checkData(iList, startDate, endDate, timeInterval)) {
-//
-//                throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
-//            }
-//        }
-//        linearInterpolationI(dataiList);
+        //数据校验
+        if (CollectionUtil.isEmpty(dataHarmPowerpList)) {
+            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
+        } else {
+
+            if (checkData(dataHarmPowerpList, startDate, endDate, timeInterval)) {
+
+                throw new BusinessException("数据量过少，请查看上传数据集的数据集时间与页面选择时间"+startDate+"-"+endDate+"的本周数据是否充足");
+            }
+        }
+        linearInterpolation(dataHarmPowerpList);
+
+        //数据校验
+        if (CollectionUtil.isEmpty(dataHarmPowerp2List)) {
+            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
+        } else {
+
+            if (checkData(dataHarmPowerp2List, startDate2, endDate2, timeInterval)) {
+
+                throw new BusinessException("数据量过少，请查看上传数据集的数据集时间与页面选择时间"+startDate+"-"+endDate+"的前一周数据量是否充足");
+            }
+        }
+        linearInterpolation(dataHarmPowerp2List);
+
+        //数据校验
+        if (CollectionUtil.isEmpty(dataHarmPowerqList)) {
+            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
+        } else {
+
+            if (checkData(dataHarmPowerqList, startDate, endDate, timeInterval)) {
+
+                throw new BusinessException("数据量过少，请查看上传数据集的数据集时间与页面选择时间"+startDate+"-"+endDate+"的本周数据是否充足");
+            }
+        }
+        linearInterpolation(dataHarmPowerqList);
+
+        //数据校验
+        if (CollectionUtil.isEmpty(dataHarmPowerq2List)) {
+            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
+        } else {
+
+            if (checkData(dataHarmPowerq2List, startDate2, endDate2, timeInterval)) {
+
+                throw new BusinessException("数据量过少，请查看上传数据集的数据集时间与页面选择时间"+startDate+"-"+endDate+"的前一周数据量是否充足");
+            }
+        }
+        linearInterpolation(dataHarmPowerq2List);
+
+        //数据校验
+        if (CollectionUtil.isEmpty(dataHarmPoweruList)) {
+            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
+        } else {
+
+            if (checkData(dataHarmPoweruList, startDate2, endDate2, timeInterval)) {
+
+                throw new BusinessException("数据量过少，请查看上传数据集的数据集时间与页面选择时间"+startDate+"-"+endDate+"的前一周数据量是否充足");
+            }
+        }
+        linearInterpolation(dataHarmPoweruList);
+
+        if (CollectionUtil.isEmpty(dataiList)) {
+            throw new BusinessException(AdvanceResponseEnum.DATA_NOT_FOUND);
+        } else {
+            List<CarryCapcityData> iList = dataiList.stream().map(temp -> {
+                CarryCapcityData carryCapcityData = new CarryCapcityData();
+                BeanUtils.copyProperties(temp, carryCapcityData);
+                carryCapcityData.setValue(temp.getI2());
+                return carryCapcityData;
+            }).collect(Collectors.toList());
+            if (checkData(iList, startDate, endDate, timeInterval)) {
+
+                throw new BusinessException("数据量过少，请查看上传数据集的数据集时间与页面选择时间"+startDate+"-"+endDate+"的本周数据量是否充足");
+            }
+        }
+        linearInterpolationI(dataiList);

 //        存入redis
        redisUtil.saveByKey(lineId + "#" + LocalDateTimeUtil.format(startDate, formatter) + "#" + LocalDateTimeUtil.format(endDate, formatter) + "#" + "P",