Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

算法调整

Browse Source
This commit is contained in:
xy
2025-04-08 11:14:01 +08:00
parent e91adc93ef
commit a350e6c367
1 changed files with 81 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

117
algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java
View File

@@ -1,6 +1,7 @@
package com.njcn.algorithm.serviceimpl.line; package com.njcn.algorithm.serviceimpl.line;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import com.njcn.algorithm.pojo.bo.CalculatedParam; import com.njcn.algorithm.pojo.bo.CalculatedParam;
import com.njcn.algorithm.service.line.IDataCleanService; import com.njcn.algorithm.service.line.IDataCleanService;
import com.njcn.dataProcess.api.*; import com.njcn.dataProcess.api.*;
@@ -547,45 +548,89 @@ public class DataCleanServiceImpl implements IDataCleanService {
} }
} }
//线电压正偏差 //电压偏差
pqReasonableRangeDto = map.get(DataCleanEnum.VuDev.getCode()); //电压偏差分为正偏差和负偏差，目前正负偏差都存储在vu_dev字段中，如果vu_dev>=0为正偏差数值，如果vu_dev<0为负偏差数值
phaseList = Arrays.asList(pqReasonableRangeDto.getPhaseType().split(",")); if (ObjectUtil.isNotNull(dto.getVuDev())) {
if (phaseList.contains(dto.getPhasicType())) { if (dto.getVuDev() >= 0) {
if (dto.getVuDev() < pqReasonableRangeDto.getMinValue() || dto.getVuDev() > pqReasonableRangeDto.getMaxValue()) { pqReasonableRangeDto = map.get(DataCleanEnum.VuDev.getCode());
//log.info("dataV-线电压正偏差数据异常,已清洗!数据值:{},数据时间:{}", dto.getVuDev(), dto.getMinTime()); phaseList = Arrays.asList(pqReasonableRangeDto.getPhaseType().split(","));
PqDataVerify pqDataVerify = getPqDataVerify(dto.getLineId() if (phaseList.contains(dto.getPhasicType())) {
,dto.getMinTime() if (dto.getVuDev() > pqReasonableRangeDto.getMaxValue()) {
,dto.getValueType() //log.info("dataV-线电压正偏差数据异常,已清洗!数据值:{},数据时间:{}", dto.getVuDev(), dto.getMinTime());
,dto.getPhasicType() PqDataVerify pqDataVerify = getPqDataVerify(dto.getLineId()
,pqReasonableRangeDto.getIndexCode() ,dto.getMinTime()
,pqReasonableRangeDto.getIndexName() ,dto.getValueType()
,pqReasonableRangeDto.getInfluxdbTableName() ,dto.getPhasicType()
,dto.getVuDev() ,pqReasonableRangeDto.getIndexCode()
,pqReasonableRangeDto.getMinValue() ,pqReasonableRangeDto.getIndexName()
,pqReasonableRangeDto.getMaxValue()); ,pqReasonableRangeDto.getInfluxdbTableName()
list.add(pqDataVerify); ,dto.getVuDev()
,pqReasonableRangeDto.getMinValue()
,pqReasonableRangeDto.getMaxValue());
list.add(pqDataVerify);
}
}
} else {
pqReasonableRangeDto = map.get(DataCleanEnum.VlDev.getCode());
phaseList = Arrays.asList(pqReasonableRangeDto.getPhaseType().split(","));
if (phaseList.contains(dto.getPhasicType())) {
if (dto.getVuDev() < pqReasonableRangeDto.getMinValue()) {
//log.info("dataV-线电压负偏差数据异常,已清洗!数据值:{},数据时间:{}", dto.getVlDev(), dto.getMinTime());
PqDataVerify pqDataVerify = getPqDataVerify(dto.getLineId()
,dto.getMinTime()
,dto.getValueType()
,dto.getPhasicType()
,pqReasonableRangeDto.getIndexCode()
,pqReasonableRangeDto.getIndexName()
,pqReasonableRangeDto.getInfluxdbTableName()
,dto.getVuDev()
,pqReasonableRangeDto.getMinValue()
,pqReasonableRangeDto.getMaxValue());
list.add(pqDataVerify);
}
}
} }
} }
//线电压负偏差 // //线电压正偏差
pqReasonableRangeDto = map.get(DataCleanEnum.VlDev.getCode()); // pqReasonableRangeDto = map.get(DataCleanEnum.VuDev.getCode());
phaseList = Arrays.asList(pqReasonableRangeDto.getPhaseType().split(",")); // phaseList = Arrays.asList(pqReasonableRangeDto.getPhaseType().split(","));
if (phaseList.contains(dto.getPhasicType())) { // if (phaseList.contains(dto.getPhasicType())) {
if (dto.getVlDev() < pqReasonableRangeDto.getMinValue() || dto.getVlDev() > pqReasonableRangeDto.getMaxValue()) { // if (dto.getVuDev() < pqReasonableRangeDto.getMinValue() || dto.getVuDev() > pqReasonableRangeDto.getMaxValue()) {
//log.info("dataV-线电压负偏差数据异常,已清洗!数据值:{},数据时间:{}", dto.getVlDev(), dto.getMinTime()); // //log.info("dataV-线电压正偏差数据异常,已清洗!数据值:{},数据时间:{}", dto.getVuDev(), dto.getMinTime());
PqDataVerify pqDataVerify = getPqDataVerify(dto.getLineId() // PqDataVerify pqDataVerify = getPqDataVerify(dto.getLineId()
,dto.getMinTime() // ,dto.getMinTime()
,dto.getValueType() // ,dto.getValueType()
,dto.getPhasicType() // ,dto.getPhasicType()
,pqReasonableRangeDto.getIndexCode() // ,pqReasonableRangeDto.getIndexCode()
,pqReasonableRangeDto.getIndexName() // ,pqReasonableRangeDto.getIndexName()
,pqReasonableRangeDto.getInfluxdbTableName() // ,pqReasonableRangeDto.getInfluxdbTableName()
,dto.getVlDev() // ,dto.getVuDev()
,pqReasonableRangeDto.getMinValue() // ,pqReasonableRangeDto.getMinValue()
,pqReasonableRangeDto.getMaxValue()); // ,pqReasonableRangeDto.getMaxValue());
list.add(pqDataVerify); // list.add(pqDataVerify);
} // }
} // }
//
// //线电压负偏差
// pqReasonableRangeDto = map.get(DataCleanEnum.VlDev.getCode());
// phaseList = Arrays.asList(pqReasonableRangeDto.getPhaseType().split(","));
// if (phaseList.contains(dto.getPhasicType())) {
// if (dto.getVlDev() < pqReasonableRangeDto.getMinValue() || dto.getVlDev() > pqReasonableRangeDto.getMaxValue()) {
// //log.info("dataV-线电压负偏差数据异常,已清洗!数据值:{},数据时间:{}", dto.getVlDev(), dto.getMinTime());
// PqDataVerify pqDataVerify = getPqDataVerify(dto.getLineId()
// ,dto.getMinTime()
// ,dto.getValueType()
// ,dto.getPhasicType()
// ,pqReasonableRangeDto.getIndexCode()
// ,pqReasonableRangeDto.getIndexName()
// ,pqReasonableRangeDto.getInfluxdbTableName()
// ,dto.getVlDev()
// ,pqReasonableRangeDto.getMinValue()
// ,pqReasonableRangeDto.getMaxValue());
// list.add(pqDataVerify);
// }
// }
//电压总谐波畸变率 //电压总谐波畸变率
pqReasonableRangeDto = map.get(DataCleanEnum.VThd.getCode()); pqReasonableRangeDto = map.get(DataCleanEnum.VThd.getCode());