合并主线

648540858

2023-07-31 4fbc364ab3dc09d8c364d751f97299bdb9510bd5

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/AckRequestProcessor.java

@@ -9,7 +9,7 @@
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.SIPRequestProcessorParent;
import com.genersoft.iot.vmp.media.zlm.ZLMRTPServerFactory;
import com.genersoft.iot.vmp.media.zlm.ZLMServerFactory;
import com.genersoft.iot.vmp.media.zlm.ZlmHttpHookSubscribe;
import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
import com.genersoft.iot.vmp.service.IDeviceService;
@@ -66,7 +66,7 @@
   private IDeviceService deviceService;

   @Autowired
   private ZLMRTPServerFactory zlmrtpServerFactory;
   private ZLMServerFactory zlmServerFactory;

   @Autowired
   private ZlmHttpHookSubscribe hookSubscribe;
@@ -98,6 +98,10 @@
         logger.warn("[收到ACK]：未找到来自{}，目标为({})的推流信息",fromUserId, toUserId);
         return;
      }
        // tcp主动时，此时是级联下级平台，在回复200ok时，本地已经请求zlm开启监听，跳过下面步骤
        if (sendRtpItem.isTcpActive()) {
            return;
        }
      logger.info("[收到ACK]：rtp/{}开始级推流, 目标={}:{}，SSRC={}, RTCP={}", sendRtpItem.getStream(),
            sendRtpItem.getIp(), sendRtpItem.getPort(), sendRtpItem.getSsrc(), sendRtpItem.isRtcp());
      // 取消设置的超时任务
@@ -168,19 +172,19 @@
      JSONObject startSendRtpStreamResult = null;
      if (sendRtpItem.getLocalPort() != 0) {
         if (sendRtpItem.isTcpActive()) {
            startSendRtpStreamResult = zlmrtpServerFactory.startSendRtpPassive(mediaInfo, param);
            startSendRtpStreamResult = zlmServerFactory.startSendRtpPassive(mediaInfo, param);
         }else {
            param.put("dst_url", sendRtpItem.getIp());
            param.put("dst_port", sendRtpItem.getPort());
            startSendRtpStreamResult = zlmrtpServerFactory.startSendRtpStream(mediaInfo, param);
            startSendRtpStreamResult = zlmServerFactory.startSendRtpStream(mediaInfo, param);
         }
      }else {
         if (sendRtpItem.isTcpActive()) {
            startSendRtpStreamResult = zlmrtpServerFactory.startSendRtpPassive(mediaInfo, param);
            startSendRtpStreamResult = zlmServerFactory.startSendRtpPassive(mediaInfo, param);
         }else {
            param.put("dst_url", sendRtpItem.getIp());
            param.put("dst_port", sendRtpItem.getPort());
            startSendRtpStreamResult = zlmrtpServerFactory.startSendRtpStream(mediaInfo, param);
            startSendRtpStreamResult = zlmServerFactory.startSendRtpStream(mediaInfo, param);
         }
      }
      return startSendRtpStreamResult;