搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2022-03-10 c1d7f867c2ffcb1364334a5e013eb8f208819ef5 
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/SIPRequestHeaderPlarformProvider.java


@@ -2,6 +2,8 @@




import com.genersoft.iot.vmp.conf.SipConfig;


import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;


import com.genersoft.iot.vmp.gb28181.bean.SubscribeInfo;


import com.genersoft.iot.vmp.storager.IRedisCatchStorage;


import gov.nist.javax.sip.message.MessageFactoryImpl;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Component;


@@ -32,6 +34,9 @@


   @Autowired


   private SipFactory sipFactory;




   @Autowired


   private IRedisCatchStorage redisCatchStorage;






   public Request createKeetpaliveMessageRequest(ParentPlatform parentPlatform, String content, String viaTag, String fromTag, String toTag, CallIdHeader callIdHeader) throws ParseException, InvalidArgumentException, PeerUnavailableException {


      Request request = null;


@@ -57,7 +62,7 @@


      // Forwards


      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);


      // ceq


      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(1L, Request.MESSAGE);


      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(Request.MESSAGE), Request.MESSAGE);




      request = sipFactory.createMessageFactory().createRequest(requestURI, Request.MESSAGE, callIdHeader, cSeqHeader, fromHeader,


            toHeader, viaHeaders, maxForwards);


@@ -122,8 +127,16 @@


                               String callId, WWWAuthenticateHeader www , CallIdHeader callIdHeader) throws ParseException, PeerUnavailableException, InvalidArgumentException {






      Request registerRequest = createRegisterRequest(parentPlatform, 2L, fromTag, viaTag, callIdHeader);




      Request registerRequest = createRegisterRequest(parentPlatform, redisCatchStorage.getCSEQ(Request.REGISTER), fromTag, viaTag, callIdHeader);


      SipURI requestURI = sipFactory.createAddressFactory().createSipURI(parentPlatform.getServerGBId(), parentPlatform.getServerIP() + ":" + parentPlatform.getServerPort());


      if (www == null) {


         AuthorizationHeader authorizationHeader = sipFactory.createHeaderFactory().createAuthorizationHeader("Digest");


         authorizationHeader.setUsername(parentPlatform.getDeviceGBId());


         authorizationHeader.setURI(requestURI);


         authorizationHeader.setAlgorithm("MD5");


         registerRequest.addHeader(authorizationHeader);


         return  registerRequest;


      }


      String realm = www.getRealm();


      String nonce = www.getNonce();


      String scheme = www.getScheme();


@@ -134,7 +147,6 @@




      callIdHeader.setCallId(callId);




      SipURI requestURI = sipFactory.createAddressFactory().createSipURI(parentPlatform.getServerGBId(), parentPlatform.getServerIP() + ":" + parentPlatform.getServerPort());


      String cNonce = null;


      String nc = "00000001";


      if (qop != null) {


@@ -208,7 +220,7 @@


      // Forwards


      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);


      // ceq


      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(1L, Request.MESSAGE);


      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(Request.MESSAGE), Request.MESSAGE);


      MessageFactoryImpl messageFactory = (MessageFactoryImpl) sipFactory.createMessageFactory();


      // 设置编码， 防止中文乱码


      messageFactory.setDefaultContentEncodingCharset("gb2312");


@@ -219,8 +231,62 @@


      UserAgentHeader userAgentHeader = sipFactory.createHeaderFactory().createUserAgentHeader(agentParam);


      request.addHeader(userAgentHeader);




      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("APPLICATION", "MANSCDP+xml");


      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("Application", "MANSCDP+xml");


      request.setContent(content, contentTypeHeader);


      return request;


   }




//    public Request createNotifyRequest(ParentPlatform parentPlatform, String content, CallIdHeader callIdHeader, String viaTag, String fromTag, SubscribeInfo subscribeInfo) throws PeerUnavailableException, ParseException, InvalidArgumentException {


//      Request request = null;


//      // sipuri


//      SipURI requestURI = sipFactory.createAddressFactory().createSipURI(parentPlatform.getServerGBId(), parentPlatform.getServerIP()+ ":" + parentPlatform.getServerPort());


//      // via


//      ArrayList<ViaHeader> viaHeaders = new ArrayList<ViaHeader>();


//      ViaHeader viaHeader = sipFactory.createHeaderFactory().createViaHeader(parentPlatform.getDeviceIp(), Integer.parseInt(parentPlatform.getDevicePort()),


//            parentPlatform.getTransport(), viaTag);


//      viaHeader.setRPort();


//      viaHeaders.add(viaHeader);


//      // from


//      SipURI fromSipURI = sipFactory.createAddressFactory().createSipURI(parentPlatform.getDeviceGBId(),


//            parentPlatform.getDeviceIp() + ":" + parentPlatform.getDevicePort());


//      Address fromAddress = sipFactory.createAddressFactory().createAddress(fromSipURI);


//      FromHeader fromHeader = sipFactory.createHeaderFactory().createFromHeader(fromAddress, fromTag);


//      // to


//      SipURI toSipURI = sipFactory.createAddressFactory().createSipURI(parentPlatform.getServerGBId(), parentPlatform.getServerGBDomain());


//      Address toAddress = sipFactory.createAddressFactory().createAddress(toSipURI);


//      ToHeader toHeader = sipFactory.createHeaderFactory().createToHeader(toAddress, subscribeInfo.getFromTag());


//


//      // Forwards


//      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);


//      // ceq


//      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory().createCSeqHeader(redisCatchStorage.getCSEQ(Request.NOTIFY), Request.NOTIFY);


//      MessageFactoryImpl messageFactory = (MessageFactoryImpl) sipFactory.createMessageFactory();


//      // 设置编码， 防止中文乱码


//      messageFactory.setDefaultContentEncodingCharset("gb2312");


//      request = messageFactory.createRequest(requestURI, Request.NOTIFY, callIdHeader, cSeqHeader, fromHeader,


//            toHeader, viaHeaders, maxForwards);


//      List<String> agentParam = new ArrayList<>();


//      agentParam.add("wvp-pro");


//      UserAgentHeader userAgentHeader = sipFactory.createHeaderFactory().createUserAgentHeader(agentParam);


//      request.addHeader(userAgentHeader);


//


//      EventHeader event = sipFactory.createHeaderFactory().createEventHeader(subscribeInfo.getEventType());


//      if (subscribeInfo.getEventId() != null) {


//         event.setEventId(subscribeInfo.getEventId());


//      }


//


//      request.addHeader(event);


//


//      SubscriptionStateHeader active = sipFactory.createHeaderFactory().createSubscriptionStateHeader("active");


//      request.setHeader(active);


//


//      String sipAddress = sipConfig.getIp() + ":" + sipConfig.getPort();


//      Address concatAddress = sipFactory.createAddressFactory().createAddress(sipFactory.createAddressFactory()


//            .createSipURI(parentPlatform.getDeviceGBId(), sipAddress));


//      request.addHeader(sipFactory.createHeaderFactory().createContactHeader(concatAddress));


//


//      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("Application", "MANSCDP+xml");


//      request.setContent(content, contentTypeHeader);


//      return request;


//    }


}