搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2023-03-21 82adc0cb23f3ee47322e78889cdaba57e9309000 
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/SIPRequestProcessorParent.java


@@ -1,14 +1,10 @@


package com.genersoft.iot.vmp.gb28181.transmit.event.request;




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


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


import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommander;


import com.genersoft.iot.vmp.gb28181.transmit.SIPSender;


import com.genersoft.iot.vmp.gb28181.utils.SipUtils;


import gov.nist.javax.sip.SipProviderImpl;


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


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


import gov.nist.javax.sip.stack.SIPServerTransactionImpl;


import org.apache.commons.lang3.ArrayUtils;


import org.dom4j.Document;


import org.dom4j.DocumentException;


@@ -17,14 +13,13 @@


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


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


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


import org.springframework.security.core.parameters.P;




import javax.sip.*;


import javax.sip.address.Address;


import javax.sip.address.AddressFactory;


import javax.sip.address.SipURI;


import javax.sip.header.*;


import javax.sip.header.ContentTypeHeader;


import javax.sip.header.ExpiresHeader;


import javax.sip.header.HeaderFactory;


import javax.sip.message.MessageFactory;


import javax.sip.message.Request;


import javax.sip.message.Response;


@@ -45,15 +40,6 @@




   @Autowired


   private SIPSender sipSender;




   public AddressFactory getAddressFactory() {


      try {


         return SipFactory.getInstance().createAddressFactory();


      } catch (PeerUnavailableException e) {


         e.printStackTrace();


      }


      return null;


   }




   public HeaderFactory getHeaderFactory() {


      try {


@@ -157,7 +143,10 @@


      responseAckExtraParam.content = sdp;


      responseAckExtraParam.sipURI = sipURI;




      return responseAck(request, Response.OK, null, responseAckExtraParam);


      SIPResponse sipResponse = responseAck(request, Response.OK, null, responseAckExtraParam);






      return sipResponse;


   }




   /**


@@ -190,7 +179,8 @@


      reader.setEncoding(charset);


      // 对海康出现的未转义字符做处理。


      String[] destStrArray = new String[]{"<",">","&","'","""};


      char despChar = '&'; // 或许可扩展兼容其他字符


      // 或许可扩展兼容其他字符


      char despChar = '&';


      byte destBye = (byte) despChar;


      List<Byte> result = new ArrayList<>();


      byte[] rawContent = request.getRawContent();


@@ -220,4 +210,5 @@


      return xml.getRootElement();


   }






}