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

refactor(influxdb): 移除冗余的相位类型判断逻辑

Browse Source 
- 注释掉 InfluxdbDataHarmpowerPImpl 中 phasicType 和 lineParam.type 的条件判断
- 注释掉 InfluxdbDataHarmpowerQImpl 中 phasicType 和 lineParam.type 的条件判断
- 注释掉 InfluxdbDataHarmpowerSImpl 中 phasicType 和 lineParam.type 的条件判断
- 统一使用 extractDataLists(valueTypeList, "") 进行数据提取
- 简化代码逻辑，提高可读性
This commit is contained in:
xy
2026-06-22 19:29:39 +08:00
parent 5090e023b1
commit 7bf8b9d393
3 changed files with 18 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -107,11 +107,12 @@ 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);
}); });

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

@@ -105,13 +105,13 @@ public class InfluxdbDataHarmpowerQImpl extends MppServiceImpl<RStatDataHarmPowe
valueTypeMap.forEach((valueType,valueTypeList)->{ valueTypeMap.forEach((valueType,valueTypeList)->{
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);
}); });

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

@@ -106,11 +106,12 @@ 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);
}); });