From ac24724ee813971afc7e516828e3fb0b27b28a03 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Thu, 19 Dec 2024 10:28:02 +0800
Subject: [PATCH] =?UTF-8?q?limitRate=E7=AE=97=E6=B3=95=E6=B7=BB=E5=8A=A0?=
 =?UTF-8?q?=E7=A9=BA=E6=95=B0=E6=8D=AE=E5=88=A4=E6=96=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mysql/Impl/line/LimitRateServiceImpl.java | 38 +++++++++++++++++++
 1 file changed, 38 insertions(+)

diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateServiceImpl.java
index 62fe9f281..de1f9d7b2 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateServiceImpl.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateServiceImpl.java
@@ -5,6 +5,7 @@ import cn.hutool.core.date.DatePattern;
 import cn.hutool.core.date.LocalDateTimeUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.common.pojo.exception.BusinessException;
 import com.njcn.common.utils.NjcnBeanUtil;
 import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
 import com.njcn.device.biz.pojo.po.Overlimit;
@@ -95,6 +96,43 @@ public class LimitRateServiceImpl extends MppServiceImpl<LimitRatePOMapper, Limi
             list11.addAll(getDataPlt(pendingId, startTime, endTime));
         }
 
+        if (CollectionUtils.isEmpty(overLimitList)) {
+            throw new BusinessException("限值表数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list1)) {
+            throw new BusinessException("data_v allTime数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list2)) {
+            throw new BusinessException("data_plt flickerAllTime数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list3)) {
+            throw new BusinessException("data_harmrate_v 谐波数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list4)) {
+            throw new BusinessException("data_I 谐波数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list5)) {
+            throw new BusinessException("data_inharm_v 间谐波数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list6)) {
+            throw new BusinessException("data_v 电压总谐波畸变率数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list7)) {
+            throw new BusinessException("data_v 三相电压不平衡度数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list8)) {
+            throw new BusinessException("data_I 负序电流数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list9)) {
+            throw new BusinessException("data_v 频率偏差数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list10)) {
+            throw new BusinessException("data_v 电压偏差数据缺失");
+        }
+        if (CollectionUtils.isEmpty(list11)) {
+            throw new BusinessException("data_plt 闪变数据缺失");
+        }
+
         //数据处理,按监测点分组
         Map<String,List<DataV>> map1 = list1.stream().collect(Collectors.groupingBy(DataV::getLineId));
         Map<String,List<DataPlt>> map2 = list2.stream().collect(Collectors.groupingBy(DataPlt::getLineId));