| | |
|---|
| | | // 未注册的设备不做处理 |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | // 回复200 OK |
|---|
| | | try { |
|---|
| | | responseAck(getServerTransaction(evt), Response.OK); |
|---|
| | | } catch (SipException | InvalidArgumentException | ParseException e) { |
|---|
| | | logger.error("[命令发送失败] 国标级联 心跳回复: {}", e.getMessage()); |
|---|
| | | } |
|---|
| | | // 判断RPort是否改变，改变则说明路由nat信息变化，修改设备信息 |
|---|
| | | // 获取到通信地址等信息 |
|---|
| | | ViaHeader viaHeader = (ViaHeader) evt.getRequest().getHeader(ViaHeader.NAME); |
|---|
| | |
|---|
| | | device.setHostAddress(received.concat(":").concat(String.valueOf(rPort))); |
|---|
| | | } |
|---|
| | | device.setKeepaliveTime(DateUtil.getNow()); |
|---|
| | | // 回复200 OK |
|---|
| | | responseAck(getServerTransaction(evt), Response.OK); |
|---|
| | | |
|---|
| | | if (device.getOnline() == 1) { |
|---|
| | | deviceService.updateDevice(device); |
|---|
| | | }else { |
|---|
| | |
|---|
| | | if (!deviceService.expire(device)){ |
|---|
| | | deviceService.online(device); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } catch (SipException | InvalidArgumentException | ParseException e) { |
|---|
| | | logger.error("[命令发送失败] 国标级联 心跳回复: {}", e.getMessage()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
