| | |
|---|
| | | AddressImpl address = (AddressImpl) fromHeader.getAddress(); |
|---|
| | | SipUri uri = (SipUri) address.getURI(); |
|---|
| | | String deviceId = uri.getUser(); |
|---|
| | | Device device = redisCatchStorage.getDevice(deviceId); |
|---|
| | | AuthorizationHeader authorhead = (AuthorizationHeader) request.getHeader(AuthorizationHeader.NAME); |
|---|
| | | Device deviceInRedis = redisCatchStorage.getDevice(deviceId); |
|---|
| | | Device device = storager.queryVideoDevice(deviceId); |
|---|
| | | if (deviceInRedis != null && device == null) { |
|---|
| | | // redis 存在脏数据 |
|---|
| | | redisCatchStorage.clearCatchByDeviceId(deviceId); |
|---|
| | | } |
|---|
| | | AuthorizationHeader authorhead = (AuthorizationHeader) request.getHeader(AuthorizationHeader.NAME); |
|---|
| | | // 校验密码是否正确 |
|---|
| | | if (authorhead != null) { |
|---|
| | | passwordCorrect = new DigestServerAuthenticationHelper().doAuthenticatePlainTextPassword(request, |
|---|
| | |
|---|
| | | device.setCharset("gb2312"); |
|---|
| | | device.setDeviceId(deviceId); |
|---|
| | | device.setFirsRegister(true); |
|---|
| | | }else { |
|---|
| | | if (device.getOnline() == 0) { |
|---|
| | | device.setFirsRegister(true); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | device.setIp(received); |
|---|
| | | device.setPort(rPort); |
|---|
| | |
|---|
| | | if (serverTransaction.getDialog() != null) serverTransaction.getDialog().delete(); |
|---|
| | | // 注册成功 |
|---|
| | | // 保存到redis |
|---|
| | | // 下发catelog查询目录 |
|---|
| | | if (registerFlag == 1 ) { |
|---|
| | | logger.info("[{}] 注册成功! deviceId:" + device.getDeviceId(), requestAddress); |
|---|
| | | publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_REGISTER); |
|---|
