| | |
|---|
| | | public String YSPassword; |
|---|
| | | /** |
|---|
| | | * 通过查mongoDB每日一机一档数据获取设备ip |
|---|
| | | * 筛选视频设备 |
|---|
| | | * 通过设备ip、品牌调用不同api获取osd信息 |
|---|
| | | * 比对mongoDB一机一档信息，整理成result存入mongo |
|---|
| | | * 同步品牌到mysql |
|---|
| | |
|---|
| | | new ThreadPoolExecutor.CallerRunsPolicy() |
|---|
| | | ); |
|---|
| | | List<TMonitor> monitors = monitorMapper.selectByNumbers(serialNumbers); |
|---|
| | | //过滤ip |
|---|
| | | monitors = monitors.stream().filter(monitor -> !StringUtils.isEmpty(monitor.getIp()) && !"127.0.0.1".equals(monitor.getIp())).collect(Collectors.toList()); |
|---|
| | | //过滤掉无效ip并筛选出视频设备 |
|---|
| | | monitors = monitors.stream() |
|---|
| | | .filter(monitor -> !StringUtils.isEmpty(monitor.getIp()) && |
|---|
| | | !"127.0.0.1".equals(monitor.getIp())) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | List<Future<OSDResult>> futureList = new ArrayList<>(48); |
|---|
| | | List<OSDResult> osdResultList = new ArrayList<>(); |
|---|
| | | for (TMonitor monitor : monitors) { |
|---|
