| | |
|---|
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
|
|---|
| | | import com.genersoft.iot.vmp.utils.DateUtil;
|
|---|
| | | import com.genersoft.iot.vmp.vmanager.bean.ErrorCode;
|
|---|
| | | import com.genersoft.iot.vmp.vmanager.bean.OtherPsSendInfo;
|
|---|
| | | import com.genersoft.iot.vmp.vmanager.bean.OtherRtpSendInfo;
|
|---|
| | | import com.genersoft.iot.vmp.vmanager.bean.StreamContent;
|
|---|
| | | import org.slf4j.Logger;
|
|---|
| | |
|---|
| | |
|
|---|
| | | String mediaServerId = json.getString("mediaServerId");
|
|---|
| | | MediaServerItem mediaInfo = mediaServerService.getOne(mediaServerId);
|
|---|
| | |
|
|---|
| | | if (mediaInfo == null) {
|
|---|
| | | return new HookResultForOnPublish(200, "success");
|
|---|
| | | }
|
|---|
| | | // 推流鉴权的处理
|
|---|
| | | if (!"rtp".equals(param.getApp())) {
|
|---|
| | | if (userSetting.getPushAuthority()) {
|
|---|
| | | // 推流鉴权
|
|---|
| | |
|---|
| | | }
|
|---|
| | | });
|
|---|
| | |
|
|---|
| | | // 是否录像
|
|---|
| | | if ("rtp".equals(param.getApp())) {
|
|---|
| | | result.setEnable_mp4(userSetting.getRecordSip());
|
|---|
| | | } else {
|
|---|
| | | result.setEnable_mp4(userSetting.isRecordPushLive());
|
|---|
| | | }
|
|---|
| | | // 替换流地址
|
|---|
| | | if ("rtp".equals(param.getApp()) && !mediaInfo.isRtpEnable()) {
|
|---|
| | | String ssrc = String.format("%010d", Long.parseLong(param.getStream(), 16));;
|
|---|
| | | InviteInfo inviteInfo = inviteStreamService.getInviteInfoBySSRC(ssrc);
|
|---|
| | | if (inviteInfo != null) {
|
|---|
| | | result.setStream_replace(inviteInfo.getStream());
|
|---|
| | | logger.info("[ZLM HOOK]推流鉴权 stream: {} 替换为 {}", param.getStream(), inviteInfo.getStream());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | List<SsrcTransaction> ssrcTransactionForAll = sessionManager.getSsrcTransactionForAll(null, null, null, param.getStream());
|
|---|
| | | if (ssrcTransactionForAll != null && ssrcTransactionForAll.size() == 1) {
|
|---|
| | |
|---|
| | | if (param.getApp().equalsIgnoreCase("rtp")) {
|
|---|
| | | String receiveKey = VideoManagerConstants.WVP_OTHER_RECEIVE_RTP_INFO + userSetting.getServerId() + "_" + param.getStream();
|
|---|
| | | OtherRtpSendInfo otherRtpSendInfo = (OtherRtpSendInfo)redisTemplate.opsForValue().get(receiveKey);
|
|---|
| | | if (otherRtpSendInfo != null) {
|
|---|
| | |
|
|---|
| | | String receiveKeyForPS = VideoManagerConstants.WVP_OTHER_RECEIVE_PS_INFO + userSetting.getServerId() + "_" + param.getStream();
|
|---|
| | | OtherPsSendInfo otherPsSendInfo = (OtherPsSendInfo)redisTemplate.opsForValue().get(receiveKeyForPS);
|
|---|
| | | if (otherRtpSendInfo != null || otherPsSendInfo != null) {
|
|---|
| | | result.setEnable_mp4(true);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|---|
| | |
|
|---|
| | | if ("rtp".equals(param.getApp())) {
|
|---|
| | | String[] s = param.getStream().split("_");
|
|---|
| | | if (!mediaInfo.isRtpEnable() || (s.length != 2 && s.length != 4)) {
|
|---|
| | | if ((s.length != 2 && s.length != 4)) {
|
|---|
| | | defaultResult.setResult(HookResult.SUCCESS());
|
|---|
| | | return defaultResult;
|
|---|
| | | }
|
|---|
| | |
|---|
| | |
|
|---|
| | | result.onTimeout(() -> {
|
|---|
| | | logger.info("[ZLM HOOK] 预览流自动点播, 等待超时");
|
|---|
| | | // 释放rtpserver
|
|---|
| | | msg.setData(new HookResult(ErrorCode.ERROR100.getCode(), "点播超时"));
|
|---|
| | | resultHolder.invokeResult(msg);
|
|---|
| | | });
|
|---|
