Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

limitRate算法添加空数据判断

Browse Source
This commit is contained in:
xy
2024-12-19 10:28:02 +08:00
parent 8f4949af80
commit ac24724ee8
1 changed files with 38 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateServiceImpl.java
View File

@@ -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));