|
|
|
@ -98,12 +98,14 @@ public class ProOverviewServiceImpl implements IProOverviewService { |
|
|
|
List<CollectionParamsManage> realInAndOutTempParams = queryCollectionParams("12", "1", 140, null, true); |
|
|
|
List<CollectionParamsManage> realInAndOutTempParams = queryCollectionParams("12", "1", 140, null, true); |
|
|
|
BigDecimal avgInTemp = new BigDecimal("0.00"); |
|
|
|
BigDecimal avgInTemp = new BigDecimal("0.00"); |
|
|
|
BigDecimal avgOutTemp = new BigDecimal("0.00"); |
|
|
|
BigDecimal avgOutTemp = new BigDecimal("0.00"); |
|
|
|
|
|
|
|
BigDecimal avgInTemp1 = new BigDecimal("0.00"); |
|
|
|
|
|
|
|
BigDecimal avgOutTemp1 = new BigDecimal("0.00"); |
|
|
|
if (null != realInAndOutTempParams && !realInAndOutTempParams.isEmpty()) { |
|
|
|
if (null != realInAndOutTempParams && !realInAndOutTempParams.isEmpty()) { |
|
|
|
// 查询供水温度的平均值
|
|
|
|
// 查询高中区供水温度的平均值
|
|
|
|
List<BigDecimal> filteredValues = realInAndOutTempParams.stream() |
|
|
|
List<BigDecimal> filteredValues = realInAndOutTempParams.stream() |
|
|
|
.filter(param -> param != null |
|
|
|
.filter(param -> param != null |
|
|
|
&& param.getOtherName() != null |
|
|
|
&& param.getOtherName() != null |
|
|
|
&& param.getOtherName().contains("供水")) |
|
|
|
&& (param.getOtherName().contains("高区供水") || param.getOtherName().contains("中区供水"))) |
|
|
|
.map(CollectionParamsManage::getCurValue) |
|
|
|
.map(CollectionParamsManage::getCurValue) |
|
|
|
.filter(Objects::nonNull) |
|
|
|
.filter(Objects::nonNull) |
|
|
|
.toList(); |
|
|
|
.toList(); |
|
|
|
@ -114,11 +116,11 @@ public class ProOverviewServiceImpl implements IProOverviewService { |
|
|
|
avgOutTemp = filteredValues.isEmpty() ? BigDecimal.ZERO : |
|
|
|
avgOutTemp = filteredValues.isEmpty() ? BigDecimal.ZERO : |
|
|
|
sum.divide(BigDecimal.valueOf(filteredValues.size()), 2, BigDecimal.ROUND_HALF_UP); |
|
|
|
sum.divide(BigDecimal.valueOf(filteredValues.size()), 2, BigDecimal.ROUND_HALF_UP); |
|
|
|
|
|
|
|
|
|
|
|
// 查询回水温度的平均值
|
|
|
|
// 查询高中区回水温度的平均值
|
|
|
|
List<BigDecimal> filteredValues1 = realInAndOutTempParams.stream() |
|
|
|
List<BigDecimal> filteredValues1 = realInAndOutTempParams.stream() |
|
|
|
.filter(param -> param != null |
|
|
|
.filter(param -> param != null |
|
|
|
&& param.getOtherName() != null |
|
|
|
&& param.getOtherName() != null |
|
|
|
&& param.getOtherName().contains("回水")) |
|
|
|
&& (param.getOtherName().contains("高区回水") || param.getOtherName().contains("中区回水"))) |
|
|
|
.map(CollectionParamsManage::getCurValue) |
|
|
|
.map(CollectionParamsManage::getCurValue) |
|
|
|
.filter(Objects::nonNull) |
|
|
|
.filter(Objects::nonNull) |
|
|
|
.toList(); |
|
|
|
.toList(); |
|
|
|
@ -128,12 +130,44 @@ public class ProOverviewServiceImpl implements IProOverviewService { |
|
|
|
|
|
|
|
|
|
|
|
avgInTemp = filteredValues1.isEmpty() ? BigDecimal.ZERO : |
|
|
|
avgInTemp = filteredValues1.isEmpty() ? BigDecimal.ZERO : |
|
|
|
sum1.divide(BigDecimal.valueOf(filteredValues1.size()), 2, BigDecimal.ROUND_HALF_UP); |
|
|
|
sum1.divide(BigDecimal.valueOf(filteredValues1.size()), 2, BigDecimal.ROUND_HALF_UP); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 查询裙楼中厨供水温度的平均值
|
|
|
|
|
|
|
|
List<BigDecimal> filteredValues2 = realInAndOutTempParams.stream() |
|
|
|
|
|
|
|
.filter(param -> param != null |
|
|
|
|
|
|
|
&& param.getOtherName() != null |
|
|
|
|
|
|
|
&& (param.getOtherName().contains("裙楼供水") || param.getOtherName().contains("中厨供水"))) |
|
|
|
|
|
|
|
.map(CollectionParamsManage::getCurValue) |
|
|
|
|
|
|
|
.filter(Objects::nonNull) |
|
|
|
|
|
|
|
.toList(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
BigDecimal sum2 = filteredValues2.stream() |
|
|
|
|
|
|
|
.reduce(BigDecimal.ZERO, BigDecimal::add); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
avgOutTemp1 = filteredValues2.isEmpty() ? BigDecimal.ZERO : |
|
|
|
|
|
|
|
sum2.divide(BigDecimal.valueOf(filteredValues2.size()), 2, BigDecimal.ROUND_HALF_UP); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 查询裙楼中厨回水温度的平均值
|
|
|
|
|
|
|
|
List<BigDecimal> filteredValues3 = realInAndOutTempParams.stream() |
|
|
|
|
|
|
|
.filter(param -> param != null |
|
|
|
|
|
|
|
&& param.getOtherName() != null |
|
|
|
|
|
|
|
&& (param.getOtherName().contains("裙楼回水") || param.getOtherName().contains("中厨回水"))) |
|
|
|
|
|
|
|
.map(CollectionParamsManage::getCurValue) |
|
|
|
|
|
|
|
.filter(Objects::nonNull) |
|
|
|
|
|
|
|
.toList(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
BigDecimal sum3 = filteredValues3.stream() |
|
|
|
|
|
|
|
.reduce(BigDecimal.ZERO, BigDecimal::add); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
avgInTemp1 = filteredValues3.isEmpty() ? BigDecimal.ZERO : |
|
|
|
|
|
|
|
sum3.divide(BigDecimal.valueOf(filteredValues3.size()), 2, BigDecimal.ROUND_HALF_UP); |
|
|
|
} |
|
|
|
} |
|
|
|
ColumnFilter inTempColumn = new ColumnFilter("回水平均温度", avgInTemp.toString()); |
|
|
|
ColumnFilter inTempColumn = new ColumnFilter("高中区回水平均温度", avgInTemp.toString()); |
|
|
|
ColumnFilter outTempColumn = new ColumnFilter("供水平均温度", avgOutTemp.toString()); |
|
|
|
ColumnFilter outTempColumn = new ColumnFilter("高中区供水平均温度", avgOutTemp.toString()); |
|
|
|
|
|
|
|
ColumnFilter inTempColumn1 = new ColumnFilter("裙楼中厨回水平均温度", avgInTemp1.toString()); |
|
|
|
|
|
|
|
ColumnFilter outTempColumn1 = new ColumnFilter("裙楼中厨供水平均温度", avgOutTemp1.toString()); |
|
|
|
DeviceMonitorDTO deviceMonitorDTO2 = new DeviceMonitorDTO(); |
|
|
|
DeviceMonitorDTO deviceMonitorDTO2 = new DeviceMonitorDTO(); |
|
|
|
deviceMonitorDTO2.setName(sysDictData.getDictLabel()); |
|
|
|
deviceMonitorDTO2.setName(sysDictData.getDictLabel()); |
|
|
|
deviceMonitorDTO2.setValues(Stream.of(inTempColumn, outTempColumn).collect(Collectors.toList())); |
|
|
|
deviceMonitorDTO2.setValues(Stream.of(inTempColumn, outTempColumn, inTempColumn1, outTempColumn1).collect(Collectors.toList())); |
|
|
|
deviceMonitorDTOList.add(deviceMonitorDTO2); |
|
|
|
deviceMonitorDTOList.add(deviceMonitorDTO2); |
|
|
|
break; |
|
|
|
break; |
|
|
|
case 2: |
|
|
|
case 2: |
|
|
|
@ -291,7 +325,7 @@ public class ProOverviewServiceImpl implements IProOverviewService { |
|
|
|
case "18": |
|
|
|
case "18": |
|
|
|
return "总用水量"; |
|
|
|
return "总用水量"; |
|
|
|
case "19": |
|
|
|
case "19": |
|
|
|
return "总用气量"; |
|
|
|
return "总蒸汽流量"; |
|
|
|
default: |
|
|
|
default: |
|
|
|
throw new IllegalArgumentException("Invalid param type: " + paramType); |
|
|
|
throw new IllegalArgumentException("Invalid param type: " + paramType); |
|
|
|
} |
|
|
|
} |
|
|
|
|