wvp-pro.git - Gitblit

			@@ -14,6 +14,7 @@
			import com.genersoft.iot.vmp.conf.MediaServerConfig;
			import com.genersoft.iot.vmp.gb28181.bean.Device;
			import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;
			import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;
			import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem;
			import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommander;
			import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommanderFroPlatform;
			@@ -74,37 +75,38 @@
			Request request = evt.getRequest();
			SipURI sipURI = (SipURI) request.getRequestURI();
			String channelId = sipURI.getUser();
			String platformId = null;
			String requesterId = null;

			FromHeader fromHeader = (FromHeader)request.getHeader(FromHeader.NAME);
			AddressImpl address = (AddressImpl) fromHeader.getAddress();
			SipUri uri = (SipUri) address.getURI();
			platformId = uri.getUser();
			requesterId = uri.getUser();

			if (platformId == null \|\| channelId == null) {
			logger.info("无法从FromHeader的Address中获取到平台id，返回404");
			if (requesterId == null \|\| channelId == null) {
			logger.info("无法从FromHeader的Address中获取到平台id，返回400");
			responseAck(evt, Response.BAD_REQUEST); // 参数不全，发400，请求错误
			return;
			}

			// 查询请求方是否上级平台
			ParentPlatform platform = storager.queryParentPlatById(requesterId);
			if (platform != null) {
			// 查询平台下是否有该通道
			DeviceChannel channel = storager.queryChannelInParentPlatform(platformId, channelId);
			DeviceChannel channel = storager.queryChannelInParentPlatform(requesterId, channelId);
			if (channel == null) {
			logger.info("通道不存在，返回404");
			responseAck(evt, Response.NOT_FOUND); // 通道不存在，发404，资源不存在
			return;
			}else {
			responseAck(evt, Response.TRYING); // 通道存在，发100，trying
			responseAck(evt, Response.CALL_IS_BEING_FORWARDED); // 通道存在，发181，呼叫转接中
			}
			// 解析sdp消息, 使用jainsip 自带的sdp解析方式
			String contentString = new String(request.getRawContent());

			// jainSip不支持y=字段，移除移除以解析。
			int ssrcIndex = contentString.indexOf("y=");
			String ssrc = contentString.substring(ssrcIndex + 2, ssrcIndex + 12);
			//ssrc规定长度为10字节，不取余下长度以避免后续还有“f=”字段
			// String ssrc = contentString.substring(ssrcIndex + 2, contentString.length())
			// .replace("\r\n", "").replace("\n", "");

			String ssrc = contentString.substring(ssrcIndex + 2, ssrcIndex + 12);
			String substring = contentString.substring(0, contentString.indexOf("y="));
			SessionDescription sdp = SdpFactory.getInstance().createSessionDescription(substring);

			@@ -152,13 +154,13 @@
			//String sessionName = sdp.getSessionName().getValue();
			logger.info("[上级点播]用户：{}，地址：{}:{}， ssrc：{}", username, addressStr, port, ssrc);

			Device device = storager.queryVideoDeviceByPlatformIdAndChannelId(platformId, channelId);
			Device device = storager.queryVideoDeviceByPlatformIdAndChannelId(requesterId, channelId);
			if (device == null) {
			logger.warn("点播平台{}的通道{}时未找到设备信息", platformId, channel);
			logger.warn("点播平台{}的通道{}时未找到设备信息", requesterId, channel);
			responseAck(evt, Response.SERVER_INTERNAL_ERROR);
			return;
			}
			SendRtpItem sendRtpItem = zlmrtpServerFactory.createSendRtpItem(addressStr, port, ssrc, platformId, device.getDeviceId(), channelId,
			SendRtpItem sendRtpItem = zlmrtpServerFactory.createSendRtpItem(addressStr, port, ssrc, requesterId, device.getDeviceId(), channelId,
			mediaTransmissionTCP);
			if (tcpActive != null) {
			sendRtpItem.setTcpActive(tcpActive);
			@@ -205,7 +207,6 @@
			try {
			response = getMessageFactory().createResponse(event.getResponse().getStatusCode(), evt.getRequest());
			getServerTransaction(evt).sendResponse(response);

			} catch (ParseException \| SipException \| InvalidArgumentException e) {
			e.printStackTrace();
			}
			@@ -213,6 +214,78 @@
			if (logger.isDebugEnabled()) {
			logger.debug(playResult.getResult().toString());
			}
			} else {
			// 非上级平台请求，查询是否设备请求（通常为接收语音广播的设备）
			Device device = storager.queryVideoDevice(requesterId);
			if (device != null) {
			logger.info("收到设备" + requesterId + "的语音广播Invite请求");
			responseAck(evt, Response.TRYING);

			String contentString = new String(request.getRawContent());
			// jainSip不支持y=字段，移除移除以解析。
			String substring = contentString;
			String ssrc = "0000000404";
			int ssrcIndex = contentString.indexOf("y=");
			if (ssrcIndex > 0) {
			substring = contentString.substring(0, ssrcIndex);
			ssrc = contentString.substring(ssrcIndex + 2, ssrcIndex + 12);
			}
			ssrcIndex = substring.indexOf("f=");
			if (ssrcIndex > 0) {
			substring = contentString.substring(0, ssrcIndex);
			}
			SessionDescription sdp = SdpFactory.getInstance().createSessionDescription(substring);

			// 获取支持的格式
			Vector mediaDescriptions = sdp.getMediaDescriptions(true);
			// 查看是否支持PS 负载96
			int port = -1;
			//boolean recvonly = false;
			boolean mediaTransmissionTCP = false;
			Boolean tcpActive = null;
			for (int i = 0; i < mediaDescriptions.size(); i++) {
			MediaDescription mediaDescription = (MediaDescription)mediaDescriptions.get(i);
			Media media = mediaDescription.getMedia();

			Vector mediaFormats = media.getMediaFormats(false);
			if (mediaFormats.contains("8")) {
			port = media.getMediaPort();
			String protocol = media.getProtocol();
			// 区分TCP发流还是udp，当前默认udp
			if ("TCP/RTP/AVP".equals(protocol)) {
			String setup = mediaDescription.getAttribute("setup");
			if (setup != null) {
			mediaTransmissionTCP = true;
			if ("active".equals(setup)) {
			tcpActive = true;
			} else if ("passive".equals(setup)) {
			tcpActive = false;
			}
			}
			}
			break;
			}
			}
			if (port == -1) {
			logger.info("不支持的媒体格式，返回415");
			// 回复不支持的格式
			responseAck(evt, Response.UNSUPPORTED_MEDIA_TYPE); // 不支持的格式，发415
			return;
			}
			String username = sdp.getOrigin().getUsername();
			String addressStr = sdp.getOrigin().getAddress();
			logger.info("设备{}请求语音流，地址：{}:{}，ssrc：{}", username, addressStr, port, ssrc);






			} else {
			logger.warn("来自无效设备/平台的请求");
			responseAck(evt, Response.BAD_REQUEST);
			}
			}

			} catch (SipException \| InvalidArgumentException \| ParseException e) {
			e.printStackTrace();