| | |
| | | @Slf4j |
| | | public class OSDCheckThread implements Callable<OSDResult> { |
| | | private TMonitor monitor; |
| | | @Value("${HK.userName}") |
| | | public String HKUserName; |
| | | @Value("${HK.password}") |
| | | public String HKPassword; |
| | | @Value("${DH.userName}") |
| | | public String DHUserName; |
| | | @Value("${DH.password}") |
| | | public String DHPassword; |
| | | @Value("${YS.userName}") |
| | | public String YSUserName; |
| | | @Value("${YS.password}") |
| | | public String YSPassword; |
| | | |
| | | public OSDCheckThread(TMonitor monitor) { |
| | | this.monitor = monitor; |
| | |
| | | public OSDResult call() throws Exception { |
| | | if (DeviceType.HK.getType().equals(monitor.getDeviceType())) { |
| | | //海康 |
| | | OSDResult osd = HKApi.getOsdByIP(monitor.getIp(), HKUserName, HKPassword); |
| | | OSDResult osd = HKApi.getOsdByIP(monitor.getSerialNumber(),monitor.getIp(),monitor.getUsername(),monitor.getPassword()); |
| | | OSDResult osdResult = checkSuccess(monitor, osd); |
| | | if (osdResult!=null) { |
| | | log.info("海康调用成功" + osd); |
| | | return osd; |
| | | }else { |
| | | return null; |
| | | } |
| | | } else if (DeviceType.DH.getType().equals(monitor.getDeviceType())) { |
| | | //大华 |
| | | OSDResult osd = DHApi.getOsd(monitor.getIp(), DHUserName, DHPassword); |
| | | OSDResult osd = DHApi.getOsd(monitor.getSerialNumber(),monitor.getIp(), monitor.getUsername(),monitor.getPassword()); |
| | | OSDResult osdResult = checkSuccess(monitor, osd); |
| | | if (osdResult!=null) { |
| | | log.info("大华调用成功" + osd); |
| | | return osd; |
| | | }else { |
| | | return null; |
| | | } |
| | | } else if (DeviceType.YS.getType().equals(monitor.getDeviceType())) { |
| | | //宇视 |
| | | OSDResult osd = YSApi.getOsd(monitor.getIp(), YSUserName, YSPassword); |
| | | OSDResult osd = YSApi.getOsd(monitor.getIp(), monitor.getUsername(),monitor.getPassword()); |
| | | OSDResult osdResult = checkSuccess(monitor, osd); |
| | | if (osdResult!=null) { |
| | | log.info("宇视调用成功" + osd); |
| | | return osd; |
| | | }else { |
| | | return null; |
| | |
| | | |
| | | private OSDResult tryAllApi(TMonitor monitor) { |
| | | //尝试海康的api |
| | | OSDResult hkosd = HKApi.getOsdByIP(monitor.getIp(), HKUserName, HKPassword); |
| | | OSDResult hkosd = HKApi.getOsdByIP(monitor.getSerialNumber(),monitor.getIp(), monitor.getUsername(),monitor.getPassword()); |
| | | if (hkosd != null) { |
| | | hkosd.setSerialNumber(monitor.getSerialNumber()); |
| | | log.info("海康调用成功" + hkosd); |
| | | return hkosd; |
| | | } |
| | | //尝试大华的api |
| | | OSDResult dhosd = DHApi.getOsd(monitor.getIp(), DHUserName, DHPassword); |
| | | OSDResult dhosd = DHApi.getOsd(monitor.getSerialNumber(),monitor.getIp(),monitor.getUsername(),monitor.getPassword()); |
| | | if (dhosd != null) { |
| | | dhosd.setSerialNumber(monitor.getSerialNumber()); |
| | | log.info("大华调用成功" + dhosd); |
| | | return dhosd; |
| | | } |
| | | //宇视api |
| | | OSDResult ysosd = YSApi.getOsd(monitor.getIp(), YSUserName, YSPassword); |
| | | OSDResult ysosd = YSApi.getOsd(monitor.getIp(), monitor.getUsername(),monitor.getPassword()); |
| | | if (ysosd != null) { |
| | | ysosd.setSerialNumber(monitor.getSerialNumber()); |
| | | log.info("宇视调用成功" + ysosd); |
| | | return ysosd; |
| | | } |
| | | return null; |