diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/main/vo/AppHydropowerStationVo.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/main/vo/AppHydropowerStationVo.java index 9ce7719..c53a9b6 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/main/vo/AppHydropowerStationVo.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/main/vo/AppHydropowerStationVo.java @@ -61,4 +61,7 @@ public class AppHydropowerStationVo { @ApiModelProperty("站点告警列表") private List devices; + + @ApiModelProperty(value = "前池水位") + private Double frontWaterLevel; } diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/HydropowerServiceImpl.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/HydropowerServiceImpl.java index 895bb27..6f96611 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/HydropowerServiceImpl.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/HydropowerServiceImpl.java @@ -1539,6 +1539,10 @@ public class HydropowerServiceImpl implements HydropowerService { Map weekWeather = this.weatherService.getWeekWeather(stations.stream().map(StationEntity::getCode).collect(Collectors.toList())); // 实时监测点数据 List reals = (List) redisTemplate.opsForValue().get(load_hydropower_unit_real_key); + /** + * 水位 + */ + List levelList = (List) redisTemplate.opsForValue().get(loadwater_level_key); return stations.stream().map(station -> { AppHydropowerStationVo hydropower = new AppHydropowerStationVo(); hydropower.setDeptId(station.getRefDept()); @@ -1582,6 +1586,13 @@ public class HydropowerServiceImpl implements HydropowerService { }).sorted(Comparator.comparing(AppHydropowerDeviceVo::getOrd)).collect(Collectors.toList())); hydropower.setLoadUnit(hydropower.getDevices().get(0).getLoadUnit()); } + if(!CollectionUtil.isEmpty(levelList)){ + List validList = levelList.stream().filter(o-> station.getCode().equals(o.getStationCode())).collect(Collectors.toList()); + if(!CollectionUtil.isEmpty(validList)){ + WaterLevelVo level = validList.get(0); + hydropower.setFrontWaterLevel(level.getFrontWaterLevel()); + } + } return hydropower; }).sorted(Comparator.comparing(AppHydropowerStationVo::getSort)).collect(Collectors.toList()); }