wvp-pro.git - Gitblit

			@@ -1,7 +1,9 @@
			package com.genersoft.iot.vmp.gb28181.transmit.event.request.impl;

			import com.genersoft.iot.vmp.common.VideoManagerConstants;
			import com.alibaba.fastjson2.JSON;
			import com.alibaba.fastjson2.JSONObject;
			import com.genersoft.iot.vmp.common.StreamInfo;
			import com.genersoft.iot.vmp.common.VideoManagerConstants;
			import com.genersoft.iot.vmp.conf.DynamicTask;
			import com.genersoft.iot.vmp.conf.SipConfig;
			import com.genersoft.iot.vmp.conf.UserSetting;
			@@ -50,6 +52,8 @@
			import javax.sip.message.Response;
			import java.text.ParseException;
			import java.time.Instant;
			import java.util.HashMap;
			import java.util.Map;
			import java.util.Random;
			import java.util.Vector;

			@@ -163,7 +167,7 @@
			// 查询平台下是否有该通道
			DeviceChannel channel = storager.queryChannelInParentPlatform(requesterId, channelId);
			GbStream gbStream = storager.queryStreamInParentPlatform(requesterId, channelId);
			PlatformCatalog catalog = storager.getCatalog(channelId);
			PlatformCatalog catalog = storager.getCatalog(requesterId, channelId);

			MediaServerItem mediaServerItem = null;
			StreamPushItem streamPushItem = null;
			@@ -406,6 +410,7 @@
			content.append("y=" + sendRtpItem.getSsrc() + "\r\n");
			content.append("f=\r\n");


			try {
			// 超时未收到Ack应该回复bye,当前等待时间为10秒
			dynamicTask.startDelay(callIdHeader.getCallId(), () -> {
			@@ -418,8 +423,34 @@
			logger.error("[命令发送失败] 国标级联发送BYE: {}", e.getMessage());
			}
			}, 60 * 1000);

			responseSdpAck(request, content.toString(), platform);
			responseSdpAck(request, content.toString(), platform);
			// tcp主动模式，回复sdp后开启监听
			if (sendRtpItem.isTcpActive()) {
			MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId());
			Map<String, Object> param = new HashMap<>(12);
			param.put("vhost","__defaultVhost__");
			param.put("app",sendRtpItem.getApp());
			param.put("stream",sendRtpItem.getStream());
			param.put("ssrc", sendRtpItem.getSsrc());
			if (!sendRtpItem.isTcpActive()) {
			param.put("dst_url",sendRtpItem.getIp());
			param.put("dst_port", sendRtpItem.getPort());
			}
			String is_Udp = sendRtpItem.isTcp() ? "0" : "1";
			param.put("is_udp", is_Udp);
			param.put("src_port", localPort);
			param.put("pt", sendRtpItem.getPt());
			param.put("use_ps", sendRtpItem.isUsePs() ? "1" : "0");
			param.put("only_audio", sendRtpItem.isOnlyAudio() ? "1" : "0");
			if (!sendRtpItem.isTcp()) {
			// 开启rtcp保活
			param.put("udp_rtcp_timeout", sendRtpItem.isRtcp()? "1":"0");
			}
			JSONObject startSendRtpStreamResult = zlmServerFactory.startSendRtpPassive(mediaInfo, param);
			if (startSendRtpStreamResult != null) {
			startSendRtpStreamHand(evt, sendRtpItem, null, startSendRtpStreamResult, param, callIdHeader);
			}
			}
			} catch (SipException \| InvalidArgumentException \| ParseException e) {
			logger.error("[命令发送失败] 国标级联回复SdpAck", e);
			}
			@@ -438,8 +469,10 @@
			sendRtpItem.setApp("rtp");
			if ("Playback".equalsIgnoreCase(sessionName)) {
			sendRtpItem.setPlayType(InviteStreamType.PLAYBACK);
			SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, null, null, device.isSsrcCheck(), true, 0, false, false, device.getStreamModeForParam());
			sendRtpItem.setStream(ssrcInfo.getStream());
			String startTimeStr = DateUtil.urlFormatter.format(start);
			String endTimeStr = DateUtil.urlFormatter.format(end);
			String stream = device.getDeviceId() + "_" + channelId + "_" + startTimeStr + "_" + endTimeStr;
			SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, stream, null, device.isSsrcCheck(), true, 0, false, device.getStreamModeForParam());
			// 写入redis，超时时回复
			redisCatchStorage.updateSendRTPSever(sendRtpItem);
			playService.playBack(mediaServerItem, ssrcInfo, device.getDeviceId(), channelId, DateUtil.formatter.format(start),
			@@ -499,12 +532,7 @@
			}
			}));
			sendRtpItem.setPlayType(InviteStreamType.PLAY);
			String streamId = null;
			if (mediaServerItem.isRtpEnable()) {
			streamId = String.format("%s_%s", device.getDeviceId(), channelId);
			}else {
			streamId = String.format("%08x", Integer.parseInt(ssrcInfo.getSsrc())).toUpperCase();
			}
			String streamId = String.format("%s_%s", device.getDeviceId(), channelId);
			sendRtpItem.setStream(streamId);
			sendRtpItem.setSsrc(ssrcInfo.getSsrc());
			redisCatchStorage.updateSendRTPSever(sendRtpItem);
			@@ -553,6 +581,18 @@
			}
			}

			private void startSendRtpStreamHand(RequestEvent evt, SendRtpItem sendRtpItem, ParentPlatform parentPlatform,
			JSONObject jsonObject, Map<String, Object> param, CallIdHeader callIdHeader) {
			if (jsonObject == null) {
			logger.error("下级TCP被动启动监听失败: 请检查ZLM服务");
			} else if (jsonObject.getInteger("code") == 0) {
			logger.info("调用ZLM-TCP被动推流接口, 结果： {}", jsonObject);
			logger.info("启动监听TCP被动推流成功[ {}/{} ]，{}->{}:{}, " ,param.get("app"), param.get("stream"), jsonObject.getString("local_port"), param.get("dst_url"), param.get("dst_port"));
			} else {
			logger.error("启动监听TCP被动推流失败: {}, 参数：{}",jsonObject.getString("msg"), JSON.toJSONString(param));
			}
			}

			/**
			* 安排推流
			*/