| | |
| | | public void uploadData(String time,WaterFacilityPO facilityPO, List<CountVO> listVo) { |
| | | CountVO stateVo = listVo.stream().filter(x -> x.getName().equals(facilityPO.getFacilityCode() + "_state1")).findFirst().orElse(null); |
| | | CountVO heartbeat = listVo.stream().filter(x -> x.getName().equals(facilityPO.getFacilityCode() + "_heartbeat")).findFirst().orElse(null); |
| | | CountVO countVO = listVo.stream().filter(x -> x.getName().equals(facilityPO.getFacilityCode() + "_count2")).findFirst().orElse(null); |
| | | CountVO countVO = listVo.stream().filter(x -> x.getName().equals(facilityPO.getFacilityCode() + "_count1")).findFirst().orElse(null); |
| | | switch (stateVo.getValue()) { |
| | | case "0"://取水完成 |
| | | BigDecimal divide = new BigDecimal(countVO.getValue()).divide(new BigDecimal(100)).setScale(2,RoundingMode.DOWN); |
| | | BigDecimal divide = new BigDecimal(countVO.getValue()).setScale(2,RoundingMode.DOWN); |
| | | BigDecimal subtract=divide.subtract(facilityPO.getWaterCount()); |
| | | if(subtract.compareTo(BigDecimal.ZERO)>0){ |
| | | facilityPO.setWaterCount(divide); |