old mode 100644
new mode 100755
| | |
| | | package com.genersoft.iot.vmp.gb28181.task.impl; |
| | | |
| | | import com.genersoft.iot.vmp.common.CommonCallback; |
| | | import com.genersoft.iot.vmp.conf.DynamicTask; |
| | | import com.genersoft.iot.vmp.gb28181.bean.Device; |
| | | import com.genersoft.iot.vmp.gb28181.task.ISubscribeTask; |
| | | import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommander; |
| | | import gov.nist.javax.sip.message.SIPRequest; |
| | | import gov.nist.javax.sip.message.SIPResponse; |
| | | import org.dom4j.Element; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.scheduling.annotation.Async; |
| | | |
| | | import javax.sip.Dialog; |
| | | import javax.sip.DialogState; |
| | | import javax.sip.InvalidArgumentException; |
| | | import javax.sip.ResponseEvent; |
| | | import javax.sip.SipException; |
| | | import javax.sip.header.ToHeader; |
| | | import java.text.ParseException; |
| | | import java.util.Timer; |
| | | import java.util.TimerTask; |
| | | |
| | | /** |
| | | * 移动位置订阅的定时更新 |
| | |
| | | if (dynamicTask.get(taskKey) != null) { |
| | | dynamicTask.stop(taskKey); |
| | | } |
| | | SIPRequest sipRequest = sipCommander.mobilePositionSubscribe(device, request, eventResult -> { |
| | | // 成功 |
| | | logger.info("[移动位置订阅]成功: {}", device.getDeviceId()); |
| | | ResponseEvent event = (ResponseEvent) eventResult.event; |
| | | ToHeader toHeader = (ToHeader)event.getResponse().getHeader(ToHeader.NAME); |
| | | try { |
| | | this.request.getToHeader().setTag(toHeader.getTag()); |
| | | } catch (ParseException e) { |
| | | logger.info("[移动位置订阅]成功: 为request设置ToTag失败"); |
| | | SIPRequest sipRequest = null; |
| | | try { |
| | | sipRequest = sipCommander.mobilePositionSubscribe(device, request, eventResult -> { |
| | | // 成功 |
| | | logger.info("[移动位置订阅]成功: {}", device.getDeviceId()); |
| | | ResponseEvent event = (ResponseEvent) eventResult.event; |
| | | ToHeader toHeader = (ToHeader)event.getResponse().getHeader(ToHeader.NAME); |
| | | try { |
| | | this.request.getToHeader().setTag(toHeader.getTag()); |
| | | } catch (ParseException e) { |
| | | logger.info("[移动位置订阅]成功: 为request设置ToTag失败"); |
| | | this.request = null; |
| | | } |
| | | },eventResult -> { |
| | | this.request = null; |
| | | } |
| | | },eventResult -> { |
| | | this.request = null; |
| | | // 失败 |
| | | logger.warn("[移动位置订阅]失败,信令发送失败: {}-{} ", device.getDeviceId(), eventResult.msg); |
| | | dynamicTask.startDelay(taskKey, MobilePositionSubscribeTask.this, 2000); |
| | | }); |
| | | // 失败 |
| | | logger.warn("[移动位置订阅]失败,信令发送失败: {}-{} ", device.getDeviceId(), eventResult.msg); |
| | | dynamicTask.startDelay(taskKey, MobilePositionSubscribeTask.this, 2000); |
| | | }); |
| | | } catch (InvalidArgumentException | SipException | ParseException e) { |
| | | logger.error("[命令发送失败] 移动位置订阅: {}", e.getMessage()); |
| | | } |
| | | if (sipRequest != null) { |
| | | this.request = sipRequest; |
| | | } |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void stop() { |
| | | public void stop(CommonCallback<Boolean> callback) { |
| | | /** |
| | | * dialog 的各个状态 |
| | | * EARLY-> Early state状态-初始请求发送以后,收到了一个临时响应消息 |
| | |
| | | dynamicTask.stop(taskKey); |
| | | } |
| | | device.setSubscribeCycleForMobilePosition(0); |
| | | sipCommander.mobilePositionSubscribe(device, request, eventResult -> { |
| | | ResponseEvent event = (ResponseEvent) eventResult.event; |
| | | if (event.getResponse().getRawContent() != null) { |
| | | // 成功 |
| | | logger.info("[取消移动位置订阅]成功: {}", device.getDeviceId()); |
| | | }else { |
| | | // 成功 |
| | | logger.info("[取消移动位置订阅]成功: {}", device.getDeviceId()); |
| | | } |
| | | },eventResult -> { |
| | | // 失败 |
| | | logger.warn("[取消移动位置订阅]失败,信令发送失败: {}-{} ", device.getDeviceId(), eventResult.msg); |
| | | }); |
| | | try { |
| | | sipCommander.mobilePositionSubscribe(device, request, eventResult -> { |
| | | ResponseEvent event = (ResponseEvent) eventResult.event; |
| | | if (event.getResponse().getRawContent() != null) { |
| | | // 成功 |
| | | logger.info("[取消移动位置订阅]成功: {}", device.getDeviceId()); |
| | | }else { |
| | | // 成功 |
| | | logger.info("[取消移动位置订阅]成功: {}", device.getDeviceId()); |
| | | } |
| | | if (callback != null) { |
| | | callback.run(event.getResponse().getRawContent() != null); |
| | | } |
| | | },eventResult -> { |
| | | // 失败 |
| | | logger.warn("[取消移动位置订阅]失败,信令发送失败: {}-{} ", device.getDeviceId(), eventResult.msg); |
| | | }); |
| | | } catch (InvalidArgumentException | SipException | ParseException e) { |
| | | logger.error("[命令发送失败] 取消移动位置订阅: {}", e.getMessage()); |
| | | } |
| | | } |
| | | } |