| | |
|---|
| | | log.info("开始获取OSD"); |
|---|
| | | // YSApi.getOsd("51.95.66.42",YSUserName,YSPassword); |
|---|
| | | |
|---|
| | | DHApi.getOsd("51.95.67.189",DHUserName,DHPassword); |
|---|
| | | // DHApi.getOsd("51.95.67.189",DHUserName,DHPassword); |
|---|
| | | //批量修改海康品牌集合 |
|---|
| | | List<String> hkList = new ArrayList<>(); |
|---|
| | | //批量修改大华品牌集合 |
|---|
| | |
|---|
| | | if(!CollectionUtils.isEmpty(serialNumbers)) { |
|---|
| | | List<TMonitor> monitors = monitorMapper.selectByNumbers(serialNumbers); |
|---|
| | | monitors = monitors.stream().filter(monitor -> !StringUtils.isEmpty(monitor.getIp()) && !"127.0.0.1".equals(monitor.getIp())).collect(Collectors.toList()); |
|---|
| | | // monitors = monitors.stream().filter(monitor -> monitor.getId() < 7000).collect(Collectors.toList()); |
|---|
| | | log.info("处理数据大小{}", monitors.size()); |
|---|
| | | for (TMonitor monitor : monitors) { |
|---|
| | | executorService.submit(() -> { |
|---|
| | |
|---|
| | | } else if (DeviceType.YS.getType().equals(monitor.getDeviceType())) { |
|---|
| | | //TODO：宇视api |
|---|
| | | } |
|---|
| | | log.info("//未知品牌或者api调用失败，挨个执行所有api"); |
|---|
| | | //未知品牌或者api调用失败，挨个执行所有api |
|---|
| | | OSDResult osd = tryAllApi(monitor, hkList, dhList, ysList); |
|---|
| | | if (osd != null) { |
|---|
