Skip to content

D
device-new-platform
Commit 6ba44a3b authored by 赵啸非's avatar 赵啸非
Browse files
Options

添加告警统计信息

parent 88897a99
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 4 deletions
device-manager/src/main/java/com/mortals/xhx/module/device/service/impl/DeviceAlarmInfoServiceImpl.java
View file @ 6ba44a3b
...@@ -91,10 +91,7 @@ public class DeviceAlarmInfoServiceImpl extends AbstractCRUDServiceImpl<DeviceAl ...@@ -91,10 +91,7 @@ public class DeviceAlarmInfoServiceImpl extends AbstractCRUDServiceImpl<DeviceAl
//分站点统计设备今日告警数量 //分站点统计设备今日告警数量
Map<String, Long> siteDeviceAlarmCollect = deviceAlarmInfoList.parallelStream().distinct().collect(groupingBy(x -> x.getSiteId(), counting())) Map<String, Long> siteDeviceAlarmCollect = deviceAlarmInfoList.parallelStream().distinct().collect(groupingBy(x -> x.getSiteId(), counting()))
.entrySet().stream().sorted(Map.Entry.comparingByValue(Comparator.reverseOrder())) .entrySet().stream().sorted(Map.Entry.comparingByValue(Comparator.reverseOrder()))
.collect(Collectors.toMap( .collect(Collectors.toMap(x->siteMap.get(x.getKey())==null?"未知站点":siteMap.get(x.getKey()).getSiteName(),y->y.getValue(),(o,n)->n));
x -> siteMap.get(x)==null?"未知站点":siteMap.get(x).getSiteName(),
Map.Entry::getValue,
(oldVal, newVal) -> oldVal));
deviceAlarmInfo.setSiteDeviceAlarmCollect(siteDeviceAlarmCollect); deviceAlarmInfo.setSiteDeviceAlarmCollect(siteDeviceAlarmCollect);
//设备类型分布 //设备类型分布
Map<String, String> deviceConnTypeCollect = deviceList.parallelStream().collect(groupingBy(x -> DeviceSrcEnum.getByValue(x.getDeviceSrc()).getDesc(), Collectors.collectingAndThen(counting(), y -> Map<String, String> deviceConnTypeCollect = deviceList.parallelStream().collect(groupingBy(x -> DeviceSrcEnum.getByValue(x.getDeviceSrc()).getDesc(), Collectors.collectingAndThen(counting(), y ->
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment