| | |
| | | import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent; |
| | | import com.genersoft.iot.vmp.gb28181.utils.SipUtils; |
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorager; |
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorage; |
| | | import gov.nist.javax.sip.message.SIPRequest; |
| | | import org.dom4j.DocumentException; |
| | | import org.dom4j.Element; |
| | | import org.slf4j.Logger; |
| | |
| | | import javax.sip.InvalidArgumentException; |
| | | import javax.sip.RequestEvent; |
| | | import javax.sip.SipException; |
| | | import javax.sip.address.SipURI; |
| | | import javax.sip.header.CSeqHeader; |
| | | import javax.sip.header.CallIdHeader; |
| | | import javax.sip.message.Response; |
| | |
| | | private SIPProcessorObserver sipProcessorObserver; |
| | | |
| | | @Autowired |
| | | private IVideoManagerStorager storage; |
| | | private IVideoManagerStorage storage; |
| | | |
| | | @Autowired |
| | | private SipSubscribe sipSubscribe; |
| | |
| | | // 查询上级平台是否存在 |
| | | ParentPlatform parentPlatform = storage.queryParentPlatByServerGBId(deviceId); |
| | | try { |
| | | if (device != null && parentPlatform != null) { |
| | | logger.warn("[重复]平台与设备编号重复:{}", deviceId); |
| | | SIPRequest request = (SIPRequest) evt.getRequest(); |
| | | String hostAddress = request.getRemoteAddress().getHostAddress(); |
| | | int remotePort = request.getRemotePort(); |
| | | if (device.getHostAddress().equals(hostAddress + ":" + remotePort)) { |
| | | parentPlatform = null; |
| | | }else { |
| | | device = null; |
| | | } |
| | | } |
| | | if (device == null && parentPlatform == null) { |
| | | // 不存在则回复404 |
| | | responseAck(evt, Response.NOT_FOUND, "device "+ deviceId +" not found"); |