|
@@ -633,7 +633,7 @@ public class MonitorDataReportServiceImpl implements MonitorDataReportService {
|
|
|
for (MonitorDataValueEntity monitorDataValueEntity : monitorDataEntity.getDataValues()) {
|
|
|
if (monitorDataValueEntity.getAttributeId().equals(deviceWaterDetail.getAttributeId())) {
|
|
|
//累计当天流量
|
|
|
- deviceWaterAmount.addWaterSupplyAmountForDay(new BigDecimal(monitorDataValueEntity.getDataValue()).subtract(deviceWaterDetail.getLatestValue()).add(deviceWaterDetail.getAmount()));
|
|
|
+ deviceWaterAmount.addWaterSupplyAmountForDay(new BigDecimal(monitorDataValueEntity.getDataValue()).subtract(deviceWaterDetail.getLatestValue()));
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -646,7 +646,7 @@ public class MonitorDataReportServiceImpl implements MonitorDataReportService {
|
|
|
for (MonitorDataValueEntity monitorDataValueEntity : monitorDataEntity.getDataValues()) {
|
|
|
if (monitorDataValueEntity.getAttributeId().equals(deviceWaterDetail.getAttributeId())) {
|
|
|
//累计当天流量
|
|
|
- deviceWaterAmount.addWaterIntakeAmountForDay(new BigDecimal(monitorDataValueEntity.getDataValue()).subtract(deviceWaterDetail.getLatestValue()).add(deviceWaterDetail.getAmount()));
|
|
|
+ deviceWaterAmount.addWaterIntakeAmountForDay(new BigDecimal(monitorDataValueEntity.getDataValue()).subtract(deviceWaterDetail.getLatestValue()));
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -850,12 +850,12 @@ public class MonitorDataReportServiceImpl implements MonitorDataReportService {
|
|
|
if (monitorDataEntity != null && monitorDataEntity.getDataValues() != null && monitorDataEntity.getDataValues().size() > 0) {
|
|
|
monitorDataEntity.getDataValues().stream()
|
|
|
.filter(monitorDataValueEntity ->
|
|
|
- monitorDataValueEntity.getAttributeId().equals(deviceWaterDetail.getAttributeId().longValue())
|
|
|
+ monitorDataValueEntity.getAttributeId().equals(deviceWaterDetail.getAttributeId())
|
|
|
)
|
|
|
.forEach(monitorDataValueEntity ->
|
|
|
//累计当天流量
|
|
|
sceneWaterAmount.setWaterAmount(sceneWaterAmount.getWaterAmount().add(
|
|
|
- new BigDecimal(monitorDataValueEntity.getDataValue()).subtract(deviceWaterDetail.getLatestValue()).add(deviceWaterDetail.getAmount())))
|
|
|
+ new BigDecimal(monitorDataValueEntity.getDataValue()).subtract(deviceWaterDetail.getLatestValue())))
|
|
|
);
|
|
|
}
|
|
|
});
|