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

fix(influxdb): 恢复功率数据提取中的相位类型判断逻辑

Browse Source 
- 在 InfluxdbDataHarmpowerPImpl 中启用相位类型条件判断
- 在 InfluxdbDataHarmpowerQImpl 中启用相位类型条件判断
- 在 InfluxdbDataHarmpowerSImpl 中启用相位类型条件判断
- 恢复了被注释掉的 Tot 参数提取逻辑
- 确保三相类型且线路参数为2时正确提取总量数据
This commit is contained in:
xy
2026-06-26 18:01:04 +08:00
parent 69df89f2e8
commit 587e936554
3 changed files with 15 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerPImpl.java
View File

@@ -107,12 +107,11 @@ public class InfluxdbDataHarmpowerPImpl extends MppServiceImpl<RStatDataHarmPowe
CommonMinuteDto.ValueType value = new CommonMinuteDto.ValueType(); CommonMinuteDto.ValueType value = new CommonMinuteDto.ValueType();
value.setValueType(valueType); value.setValueType(valueType);
List<List<Double>> lists; List<List<Double>> lists;
// if (Objects.equals(phasicType, "T") && Objects.equals(lineParam.getType(), 2)) { if (Objects.equals(phasicType, "T") && Objects.equals(lineParam.getType(), 2)) {
// lists = extractDataLists(valueTypeList, "Tot"); lists = extractDataLists(valueTypeList, "Tot");
// } else { } else {
// lists = extractDataLists(valueTypeList, ""); lists = extractDataLists(valueTypeList, "");
// } }
lists = extractDataLists(valueTypeList, "");
value.setValueList(lists); value.setValueList(lists);
valueTypes.add(value); valueTypes.add(value);
}); });

11
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerQImpl.java
View File

@@ -106,12 +106,11 @@ public class InfluxdbDataHarmpowerQImpl extends MppServiceImpl<RStatDataHarmPowe
CommonMinuteDto.ValueType value = new CommonMinuteDto.ValueType(); CommonMinuteDto.ValueType value = new CommonMinuteDto.ValueType();
value.setValueType(valueType); value.setValueType(valueType);
List<List<Double>> lists; List<List<Double>> lists;
// if (Objects.equals(phasicType, "T") && Objects.equals(lineParam.getType(), 2)) { if (Objects.equals(phasicType, "T") && Objects.equals(lineParam.getType(), 2)) {
// lists = extractDataLists(valueTypeList, "Tot"); lists = extractDataLists(valueTypeList, "Tot");
// } else { } else {
// lists = extractDataLists(valueTypeList, ""); lists = extractDataLists(valueTypeList, "");
// } }
lists = extractDataLists(valueTypeList, "");
value.setValueList(lists); value.setValueList(lists);
valueTypes.add(value); valueTypes.add(value);
}); });

11
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataHarmpowerSImpl.java
View File

@@ -106,12 +106,11 @@ public class InfluxdbDataHarmpowerSImpl extends MppServiceImpl<RStatDataHarmPowe
CommonMinuteDto.ValueType value = new CommonMinuteDto.ValueType(); CommonMinuteDto.ValueType value = new CommonMinuteDto.ValueType();
value.setValueType(valueType); value.setValueType(valueType);
List<List<Double>> lists; List<List<Double>> lists;
// if (Objects.equals(phasicType, "T") && Objects.equals(lineParam.getType(), 2)) { if (Objects.equals(phasicType, "T") && Objects.equals(lineParam.getType(), 2)) {
// lists = extractDataLists(valueTypeList, "Tot"); lists = extractDataLists(valueTypeList, "Tot");
// } else { } else {
// lists = extractDataLists(valueTypeList, ""); lists = extractDataLists(valueTypeList, "");
// } }
lists = extractDataLists(valueTypeList, "");
value.setValueList(lists); value.setValueList(lists);
valueTypes.add(value); valueTypes.add(value);
}); });