|
@ -1,21 +1,17 @@ |
|
|
package com.genersoft.iot.vmp.gb28181.transmit.event.request.impl; |
|
|
package com.genersoft.iot.vmp.gb28181.transmit.event.request.impl; |
|
|
|
|
|
|
|
|
import com.genersoft.iot.vmp.common.VideoManagerConstants; |
|
|
|
|
|
import com.genersoft.iot.vmp.conf.SipConfig; |
|
|
import com.genersoft.iot.vmp.conf.SipConfig; |
|
|
import com.genersoft.iot.vmp.gb28181.auth.DigestServerAuthenticationHelper; |
|
|
|
|
|
import com.genersoft.iot.vmp.gb28181.bean.Device; |
|
|
import com.genersoft.iot.vmp.gb28181.bean.Device; |
|
|
import com.genersoft.iot.vmp.gb28181.bean.WvpSipDate; |
|
|
import com.genersoft.iot.vmp.gb28181.bean.WvpSipDate; |
|
|
import com.genersoft.iot.vmp.gb28181.event.EventPublisher; |
|
|
|
|
|
import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorObserver; |
|
|
import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorObserver; |
|
|
import com.genersoft.iot.vmp.gb28181.transmit.event.request.ISIPRequestProcessor; |
|
|
import com.genersoft.iot.vmp.gb28181.transmit.event.request.ISIPRequestProcessor; |
|
|
import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent; |
|
|
import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent; |
|
|
import com.genersoft.iot.vmp.service.IDeviceService; |
|
|
import com.genersoft.iot.vmp.service.IDeviceService; |
|
|
import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
|
|
|
|
|
import com.genersoft.iot.vmp.storager.IVideoManagerStorage; |
|
|
|
|
|
import com.genersoft.iot.vmp.utils.DateUtil; |
|
|
import com.genersoft.iot.vmp.utils.DateUtil; |
|
|
import gov.nist.javax.sip.RequestEventExt; |
|
|
import gov.nist.javax.sip.RequestEventExt; |
|
|
import gov.nist.javax.sip.address.AddressImpl; |
|
|
import gov.nist.javax.sip.address.AddressImpl; |
|
|
import gov.nist.javax.sip.address.SipUri; |
|
|
import gov.nist.javax.sip.address.SipUri; |
|
|
|
|
|
import gov.nist.javax.sip.clientauthutils.DigestServerAuthenticationHelper; |
|
|
import gov.nist.javax.sip.header.Expires; |
|
|
import gov.nist.javax.sip.header.Expires; |
|
|
import gov.nist.javax.sip.header.SIPDateHeader; |
|
|
import gov.nist.javax.sip.header.SIPDateHeader; |
|
|
import org.slf4j.Logger; |
|
|
import org.slf4j.Logger; |
|
@ -50,15 +46,6 @@ public class RegisterRequestProcessor extends SIPRequestProcessorParent implemen |
|
|
@Autowired |
|
|
@Autowired |
|
|
private SipConfig sipConfig; |
|
|
private SipConfig sipConfig; |
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
private IRedisCatchStorage redisCatchStorage; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
private IVideoManagerStorage storager; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
private EventPublisher publisher; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
@Autowired |
|
|
private SIPProcessorObserver sipProcessorObserver; |
|
|
private SIPProcessorObserver sipProcessorObserver; |
|
|
|
|
|
|
|
@ -86,7 +73,7 @@ public class RegisterRequestProcessor extends SIPRequestProcessorParent implemen |
|
|
ExpiresHeader expiresHeader = (ExpiresHeader) request.getHeader(Expires.NAME); |
|
|
ExpiresHeader expiresHeader = (ExpiresHeader) request.getHeader(Expires.NAME); |
|
|
Response response = null; |
|
|
Response response = null; |
|
|
boolean passwordCorrect = false; |
|
|
boolean passwordCorrect = false; |
|
|
// 注册标志 0:未携带授权头或者密码错误 1:注册成功 2:注销成功
|
|
|
// 注册标志 true:注册成功 false:注册成功
|
|
|
boolean registerFlag = false; |
|
|
boolean registerFlag = false; |
|
|
FromHeader fromHeader = (FromHeader) request.getHeader(FromHeader.NAME); |
|
|
FromHeader fromHeader = (FromHeader) request.getHeader(FromHeader.NAME); |
|
|
AddressImpl address = (AddressImpl) fromHeader.getAddress(); |
|
|
AddressImpl address = (AddressImpl) fromHeader.getAddress(); |
|
|