648540858
2022-09-14 ab74d1cff90cc563e0eca8deb8f154d84eb51908
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java
@@ -21,6 +21,7 @@
import com.genersoft.iot.vmp.service.bean.SSRCInfo;
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
import com.genersoft.iot.vmp.utils.GitUtil;
import gov.nist.javax.sip.SipProviderImpl;
import gov.nist.javax.sip.SipStackImpl;
import gov.nist.javax.sip.message.MessageFactoryImpl;
@@ -41,7 +42,9 @@
import javax.sip.message.Request;
import java.lang.reflect.Field;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
/**    
 * @description:设备能力接口,用于定义设备的控制、查询能力   
@@ -59,6 +62,9 @@
   @Autowired
   private SipFactory sipFactory;
   @Autowired
   private GitUtil gitUtil;
   @Autowired
   @Qualifier(value="tcpSipProvider")
@@ -285,7 +291,7 @@
         ptzXml.append("<ControlPriority>5</ControlPriority>\r\n");
         ptzXml.append("</Info>\r\n");
         ptzXml.append("</Control>\r\n");
         CallIdHeader callIdHeader = device.getTransport().equalsIgnoreCase("TCP") ? tcpSipProvider.getNewCallId()
               : udpSipProvider.getNewCallId();
@@ -320,7 +326,7 @@
         ptzXml.append("<ControlPriority>5</ControlPriority>\r\n");
         ptzXml.append("</Info>\r\n");
         ptzXml.append("</Control>\r\n");
         CallIdHeader callIdHeader = device.getTransport().equalsIgnoreCase("TCP") ? tcpSipProvider.getNewCallId()
               : udpSipProvider.getNewCallId();
@@ -663,6 +669,38 @@
      streamByeCmd(deviceId, channelId, stream, callId, null);
   }
   @Override
   public void streamByeCmd(SIPDialog dialog, String channelId, SIPRequest request, SipSubscribe.Event okEvent) throws SipException, ParseException, InvalidArgumentException {
      Request byeRequest = dialog.createRequest(Request.BYE);
      SipURI byeURI = (SipURI) byeRequest.getRequestURI();
      byeURI.setHost(request.getRemoteAddress().getHostAddress());
      byeURI.setPort(request.getRemotePort());
      byeURI.setUser(channelId);
      ViaHeader viaHeader = (ViaHeader) byeRequest.getHeader(ViaHeader.NAME);
      String protocol = viaHeader.getTransport().toUpperCase();
      viaHeader.setRPort();
      // 增加Contact header
      Address concatAddress = sipFactory.createAddressFactory().createAddress(sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getIp()+":"+sipConfig.getPort()));
      byeRequest.addHeader(sipFactory.createHeaderFactory().createContactHeader(concatAddress));
      UserAgentHeader userAgentHeader = HeaderUtils.createUserAgentHeader(sipFactory);
      byeRequest.addHeader(userAgentHeader);
      ClientTransaction clientTransaction = null;
      if("TCP".equals(protocol)) {
         clientTransaction = tcpSipProvider.getNewClientTransaction(byeRequest);
      } else if("UDP".equals(protocol)) {
         clientTransaction = udpSipProvider.getNewClientTransaction(byeRequest);
      }
      CallIdHeader callIdHeader = (CallIdHeader) byeRequest.getHeader(CallIdHeader.NAME);
      if (okEvent != null) {
         sipSubscribe.addOkSubscribe(callIdHeader.getCallId(), okEvent);
      }
      CSeqHeader cSeqHeader = (CSeqHeader)byeRequest.getHeader(CSeqHeader.NAME);
      cSeqHeader.setSeqNumber(redisCatchStorage.getCSEQ());
      dialog.sendRequest(clientTransaction);
   }
   /**
    * 视频流停止
    */
@@ -690,7 +728,7 @@
            dialog = streamSession.getDialogByStream(ssrcTransaction.getDeviceId(), ssrcTransaction.getChannelId(), ssrcTransaction.getStream());
         }
         mediaServerService.releaseSsrc(ssrcTransaction.getMediaServerId(), ssrcTransaction.getSsrc());
         mediaServerService.closeRTPServer(ssrcTransaction.getDeviceId(), ssrcTransaction.getChannelId(), ssrcTransaction.getStream());
         mediaServerService.closeRTPServer(ssrcTransaction.getMediaServerId(), ssrcTransaction.getStream());
         streamSession.remove(ssrcTransaction.getDeviceId(), ssrcTransaction.getChannelId(), ssrcTransaction.getStream());
         if (dialog == null) {
@@ -727,7 +765,7 @@
         // 增加Contact header
         Address concatAddress = sipFactory.createAddressFactory().createAddress(sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getIp()+":"+sipConfig.getPort()));
         byeRequest.addHeader(sipFactory.createHeaderFactory().createContactHeader(concatAddress));
         UserAgentHeader userAgentHeader = SipUtils.createUserAgentHeader(sipFactory);
         UserAgentHeader userAgentHeader = SipUtils.createUserAgentHeader(sipFactory, gitUtil);
         byeRequest.addHeader(userAgentHeader);
         ClientTransaction clientTransaction = null;
         if("TCP".equals(protocol)) {
@@ -755,21 +793,9 @@
    * 语音广播
    * 
    * @param device  视频设备
    * @param channelId  预览通道
    */
   @Override
   public boolean audioBroadcastCmd(Device device, String channelId) {
      // 改为新的实现
      return false;
   }
   /**
    * 语音广播
    *
    * @param device  视频设备
    */
   @Override
   public boolean audioBroadcastCmd(Device device) {
   public boolean audioBroadcastCmd(Device device,String channelId, SipSubscribe.Event okEvent, SipSubscribe.Event errorEvent) {
      try {
         StringBuffer broadcastXml = new StringBuffer(200);
         String charset = device.getCharset();
@@ -778,7 +804,7 @@
         broadcastXml.append("<CmdType>Broadcast</CmdType>\r\n");
         broadcastXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");
         broadcastXml.append("<SourceID>" + sipConfig.getId() + "</SourceID>\r\n");
         broadcastXml.append("<TargetID>" + device.getDeviceId() + "</TargetID>\r\n");
         broadcastXml.append("<TargetID>" + channelId + "</TargetID>\r\n");
         broadcastXml.append("</Notify>\r\n");
         CallIdHeader callIdHeader = device.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()
@@ -807,15 +833,15 @@
         CallIdHeader callIdHeader = device.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()
               : udpSipProvider.getNewCallId();
         Request request = headerProvider.createMessageRequest(device, broadcastXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null, callIdHeader);
         transmitRequest(device, request, errorEvent);
      } catch (SipException | ParseException | InvalidArgumentException e) {
         e.printStackTrace();
      }
   }
      }
   }
   /**
    * 音视频录像控制
    * 
@@ -1242,7 +1268,7 @@
            recordInfoXml.append("<Type>" + type+"</Type>\r\n");
         }
         recordInfoXml.append("</Query>\r\n");
         CallIdHeader callIdHeader = device.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()
               : udpSipProvider.getNewCallId();
@@ -1299,7 +1325,7 @@
            cmdXml.append("<EndAlarmTime>" + endTime + "</EndAlarmTime>\r\n");
         }
         cmdXml.append("</Query>\r\n");
         CallIdHeader callIdHeader = device.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()
               : udpSipProvider.getNewCallId();
@@ -1335,7 +1361,7 @@
         }
         cmdXml.append("<ConfigType>" + configType + "</ConfigType>\r\n");
         cmdXml.append("</Query>\r\n");
         CallIdHeader callIdHeader = device.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()
               : udpSipProvider.getNewCallId();
@@ -1368,7 +1394,7 @@
            cmdXml.append("<DeviceID>" + channelId + "</DeviceID>\r\n");
         }
         cmdXml.append("</Query>\r\n");
         CallIdHeader callIdHeader = device.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()
               : udpSipProvider.getNewCallId();
@@ -1398,7 +1424,7 @@
         mobilePostitionXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");
         mobilePostitionXml.append("<Interval>60</Interval>\r\n");
         mobilePostitionXml.append("</Query>\r\n");
         CallIdHeader callIdHeader = device.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()
               : udpSipProvider.getNewCallId();
@@ -1616,13 +1642,11 @@
         clientTransaction = udpSipProvider.getNewClientTransaction(request);
      }
      if (request.getHeader(UserAgentHeader.NAME) == null) {
         UserAgentHeader userAgentHeader = null;
         try {
            userAgentHeader = SipUtils.createUserAgentHeader(sipFactory);
            request.addHeader(SipUtils.createUserAgentHeader(sipFactory, gitUtil));
         } catch (ParseException e) {
            logger.error("添加UserAgentHeader失败", e);
         }
         request.addHeader(userAgentHeader);
      }
      CallIdHeader callIdHeader = (CallIdHeader)request.getHeader(CallIdHeader.NAME);
      // 添加错误订阅
@@ -1768,7 +1792,7 @@
   private int getInfoCseq() {
      return (int) ((Math.random() * 9 + 1) * Math.pow(10, 8));
   }
   @Override
   public void playbackControlCmd(Device device, StreamInfo streamInfo, String content,SipSubscribe.Event errorEvent, SipSubscribe.Event okEvent) {
      try {