wvp-pro.git - Gitblit

			@@ -143,16 +143,15 @@
			@ResponseBody
			@PostMapping(value = "/on_play", produces = "application/json;charset=UTF-8")
			public HookResult onPlay(@RequestBody OnPlayHookParam param) {
			if (logger.isDebugEnabled()) {
			logger.debug("[ZLM HOOK] 播放鉴权：{}->{}", param.getMediaServerId(), param);
			}

			Map<String, String> paramMap = urlParamToMap(param.getParams());
			// 对于播放流进行鉴权
			boolean authenticateResult = mediaService.authenticatePlay(param.getApp(), param.getStream(), paramMap.get("callId"));
			if (!authenticateResult) {
			logger.info("[ZLM HOOK] 播放鉴权失败：{}->{}", param.getMediaServerId(), param);
			return new HookResult(401, "Unauthorized");
			}

			logger.info("[ZLM HOOK] 播放鉴权成功：{}->{}", param.getMediaServerId(), param);
			return HookResult.SUCCESS();
			}

			@@ -2,9 +2,7 @@

			import com.genersoft.iot.vmp.common.InviteInfo;
			import com.genersoft.iot.vmp.common.InviteSessionType;
			import com.genersoft.iot.vmp.common.StreamInfo;
			import com.genersoft.iot.vmp.common.VideoManagerConstants;
			import com.genersoft.iot.vmp.conf.MediaConfig;
			import com.genersoft.iot.vmp.conf.UserSetting;
			import com.genersoft.iot.vmp.conf.exception.ControllerException;
			import com.genersoft.iot.vmp.conf.exception.SsrcTransactionNotFoundException;
			@@ -12,9 +10,7 @@
			import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager;
			import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommander;
			import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform;
			import com.genersoft.iot.vmp.media.bean.MediaInfo;
			import com.genersoft.iot.vmp.media.bean.ResultForOnPublish;
			import com.genersoft.iot.vmp.media.service.IMediaServerService;
			import com.genersoft.iot.vmp.media.zlm.ZLMMediaListManager;
			import com.genersoft.iot.vmp.media.zlm.dto.MediaServer;
			import com.genersoft.iot.vmp.media.zlm.dto.StreamAuthorityInfo;
			@@ -91,7 +87,7 @@
			return true;
			}
			StreamAuthorityInfo streamAuthorityInfo = redisCatchStorage.getStreamAuthorityInfo(app, stream);
			return (streamAuthorityInfo != null && streamAuthorityInfo.getCallId() != null && !streamAuthorityInfo.getCallId().equals(callId));
			return (streamAuthorityInfo != null && streamAuthorityInfo.getCallId() != null && streamAuthorityInfo.getCallId().equals(callId));
			}

			@Override

			@@ -447,6 +447,7 @@
			@Override
			public StreamAuthorityInfo getStreamAuthorityInfo(String app, String stream) {
			String key = VideoManagerConstants.MEDIA_STREAM_AUTHORITY + userSetting.getServerId() + "_" + app+ "_" + stream ;
			System.out.println(key);
			return JsonUtil.redisJsonToObject(redisTemplate, key, StreamAuthorityInfo.class);

			}

	src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java	7 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	src/main/java/com/genersoft/iot/vmp/service/impl/MediaServiceImpl.java	6 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	src/main/java/com/genersoft/iot/vmp/storager/impl/RedisCatchStorageImpl.java	1 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史