|
@@ -29,6 +29,7 @@ import java.util.Date;
|
29
|
29
|
import java.util.HashMap;
|
30
|
30
|
import java.util.List;
|
31
|
31
|
import java.util.Map;
|
|
32
|
+import java.util.stream.Collectors;
|
32
|
33
|
|
33
|
34
|
/**
|
34
|
35
|
* 监控 业务实现
|
|
@@ -107,6 +108,9 @@ public class MonitoringServiceImpl implements IMonitoringService {
|
107
|
108
|
return response;
|
108
|
109
|
}
|
109
|
110
|
|
|
111
|
+ // TODO 过滤 hls 的流地址,后面拆表后,就可以将改代码移除
|
|
112
|
+ tpEquipments = tpEquipments.stream().filter(e-> e.getMonitoringUrl().contains("rtsp")).collect(Collectors.toList());
|
|
113
|
+
|
110
|
114
|
Map<String, Object> map = Maps.newHashMap();
|
111
|
115
|
map.put("pageNo", page.getPageNum());
|
112
|
116
|
map.put("pageSize", page.getPageSize());
|
|
@@ -210,6 +214,9 @@ public class MonitoringServiceImpl implements IMonitoringService {
|
210
|
214
|
return response;
|
211
|
215
|
}
|
212
|
216
|
|
|
217
|
+ // TODO 过滤 rtsp 的流地址,后面拆表后,就可以将改代码移除
|
|
218
|
+ tpEquipments = tpEquipments.stream().filter(e-> e.getMonitoringUrl().contains("m3u8")).collect(Collectors.toList());
|
|
219
|
+
|
213
|
220
|
Map<String, Object> map = Maps.newHashMap();
|
214
|
221
|
map.put("pageNo", page.getPageNum());
|
215
|
222
|
map.put("pageSize", page.getPageSize());
|