| | |
|---|
| | | import javax.sip.InvalidArgumentException; |
|---|
| | | import javax.sip.RequestEvent; |
|---|
| | | import javax.sip.SipException; |
|---|
| | | import javax.sip.header.CSeqHeader; |
|---|
| | | import javax.sip.header.CallIdHeader; |
|---|
| | | import javax.sip.message.Response; |
|---|
| | | import java.text.ParseException; |
|---|
| | |
|---|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest()); |
|---|
| | | CallIdHeader callIdHeader = (CallIdHeader)evt.getRequest().getHeader(CallIdHeader.NAME); |
|---|
| | | // 查询设备是否存在 |
|---|
| | | CSeqHeader cseqHeader = (CSeqHeader) evt.getRequest().getHeader(CSeqHeader.NAME); |
|---|
| | | String method = cseqHeader.getMethod(); |
|---|
| | | if (method.equals("MESSAGE")) { |
|---|
| | | System.out.println(); |
|---|
| | | } |
|---|
| | | Device device = redisCatchStorage.getDevice(deviceId); |
|---|
| | | // 查询上级平台是否存在 |
|---|
| | | ParentPlatform parentPlatform = storage.queryParentPlatByServerGBId(deviceId); |
|---|
| | |
|---|
| | | sipSubscribe.getErrorSubscribe(callIdHeader.getCallId()).response(eventResult); |
|---|
| | | }; |
|---|
| | | }else { |
|---|
| | | Element rootElement = getRootElement(evt); |
|---|
| | | Element rootElement = null; |
|---|
| | | try { |
|---|
| | | rootElement = getRootElement(evt); |
|---|
| | | } catch (DocumentException e) { |
|---|
| | | logger.warn("解析XML消息内容异常", e); |
|---|
| | | // 不存在则回复404 |
|---|
| | | responseAck(evt, Response.BAD_REQUEST, e.getMessage()); |
|---|
| | | } |
|---|
| | | String name = rootElement.getName(); |
|---|
| | | IMessageHandler messageHandler = messageHandlerMap.get(name); |
|---|
| | | if (messageHandler != null) { |
|---|
| | |
|---|
| | | logger.warn("参数无效", e); |
|---|
| | | } catch (ParseException e) { |
|---|
| | | logger.warn("SIP回复时解析异常", e); |
|---|
| | | } catch (DocumentException e) { |
|---|
| | | logger.warn("解析XML消息内容异常", e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
