| | |
| | | AddressImpl address = (AddressImpl) fromHeader.getAddress();
|
| | | SipUri uri = (SipUri) address.getURI();
|
| | | String deviceId = uri.getUser();
|
| | | device = new Device();
|
| | | device.setStreamMode("UDP");
|
| | | device.setDeviceId(deviceId);
|
| | | device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | device = new Device();
|
| | | device.setStreamMode("UDP");
|
| | | device.setDeviceId(deviceId);
|
| | | }
|
| | | device.setIp(received);
|
| | | device.setPort(rPort);
|
| | | device.setHostAddress(received.concat(":").concat(String.valueOf(rPort)));
|
| | |
| | | // 下发catelog查询目录
|
| | | if (registerFlag == 1 && device != null) {
|
| | | logger.info("注册成功! deviceId:" + device.getDeviceId());
|
| | | boolean exists = storager.exists(device.getDeviceId());
|
| | | // boolean exists = storager.exists(device.getDeviceId());
|
| | | device.setRegisterTimeMillis(System.currentTimeMillis());
|
| | | storager.updateDevice(device);
|
| | | publisher.onlineEventPublish(device.getDeviceId(), VideoManagerConstants.EVENT_ONLINE_REGISTER);
|