From 116d979d87f53f878a8c930cfad2c6a7cc831b19 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期二, 09 八月 2022 16:58:31 +0800 Subject: [PATCH] 合并主线 --- src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/InviteRequestProcessor.java | 100 ++------------------------------- web_src/src/components/Login.vue | 5 + src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java | 2 src/main/java/com/genersoft/iot/vmp/service/impl/PlayServiceImpl.java | 8 -- web_src/src/components/dialog/devicePlayer.vue | 5 + src/main/java/com/genersoft/iot/vmp/service/impl/MediaServiceImpl.java | 2 src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java | 3 + 7 files changed, 21 insertions(+), 104 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java b/src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java index 45e03bc..902bfb5 100644 --- a/src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java +++ b/src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java @@ -98,5 +98,8 @@ return user.getRole(); } + public String getPushKey() { + return user.getPushKey(); + } } diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/InviteRequestProcessor.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/InviteRequestProcessor.java index 5e6e8d7..cb7faf2 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/InviteRequestProcessor.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/InviteRequestProcessor.java @@ -23,10 +23,7 @@ import com.genersoft.iot.vmp.media.zlm.ZLMMediaListManager; import com.genersoft.iot.vmp.media.zlm.ZLMRESTfulUtils; import com.genersoft.iot.vmp.media.zlm.ZLMRTPServerFactory; -import com.genersoft.iot.vmp.media.zlm.dto.MediaItem; -import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; -import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItemLite; -import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem; +import com.genersoft.iot.vmp.media.zlm.dto.*; import com.genersoft.iot.vmp.service.IMediaServerService; import com.genersoft.iot.vmp.service.IMediaService; import com.genersoft.iot.vmp.service.IPlayService; @@ -883,101 +880,15 @@ // hook鐩戝惉绛夊緟璁惧鎺ㄦ祦涓婃潵 // 娣诲姞璁㈤槄 - JSONObject subscribeKey = new JSONObject(); - subscribeKey.put("app", app); - subscribeKey.put("stream", stream); - subscribeKey.put("regist", true); - subscribeKey.put("schema", "rtsp"); - subscribeKey.put("mediaServerId", mediaServerItem.getId()); + HookSubscribeForStreamChange subscribeKey = HookSubscribeFactory.on_stream_changed(app, stream, true, "rtsp", mediaServerItem.getId()); + String finalSsrc = ssrc; // 娴佸凡缁忓瓨鍦ㄦ椂鐩存帴鎺ㄦ祦 -// JSONObject mediaInfo = zlmresTfulUtils.getMediaList(mediaServerItem, app, stream); -// System.out.println(mediaInfo != null); -// System.out.println(mediaInfo); -// if (mediaInfo != null && -// (mediaInfo.getInteger("code") != null && mediaInfo.getInteger("code") == 0 -// && mediaInfo.getJSONArray("data") != null && mediaInfo.getJSONArray("data").size() > 0)) { -// logger.info("鍙戠幇宸茬粡鍦ㄦ帹娴�"); -// JSONArray tracks = mediaInfo.getJSONArray("data").getJSONObject(0).getJSONArray("tracks"); -// Integer codecId = null; -// if (tracks != null && tracks.size() > 0) { -// for (int i = 0; i < tracks.size(); i++) { -// MediaItem.MediaTrack track = JSON.toJavaObject((JSON)tracks.get(i),MediaItem.MediaTrack.class); -// if (track.getCodecType() == 1) { -// codecId = track.getCodecId(); -// break; -// } -// } -// } -// sendRtpItem.setStatus(2); -// redisCatchStorage.updateSendRTPSever(sendRtpItem); -// StringBuffer content = new StringBuffer(200); -// content.append("v=0\r\n"); -// content.append("o="+ config.getId() +" "+ sdp.getOrigin().getSessionId() +" " + sdp.getOrigin().getSessionVersion() + " IN IP4 "+mediaServerItem.getSdpIp()+"\r\n"); -// content.append("s=Play\r\n"); -// content.append("c=IN IP4 "+mediaServerItem.getSdpIp()+"\r\n"); -// content.append("t=0 0\r\n"); -// if (codecId == null) { -// if (mediaTransmissionTCP) { -// content.append("m=audio "+ sendRtpItem.getLocalPort()+" TCP/RTP/AVP 8\r\n"); -// }else { -// content.append("m=audio "+ sendRtpItem.getLocalPort()+" RTP/AVP 8\r\n"); -// } -// -// content.append("a=rtpmap:8 PCMA/8000\r\n"); -// }else { -// if (codecId == 4) { -// if (mediaTransmissionTCP) { -// content.append("m=audio "+ sendRtpItem.getLocalPort()+" TCP/RTP/AVP 0\r\n"); -// }else { -// content.append("m=audio "+ sendRtpItem.getLocalPort()+" RTP/AVP 0\r\n"); -// } -// content.append("a=rtpmap:0 PCMU/8000\r\n"); -// }else { -// if (mediaTransmissionTCP) { -// content.append("m=audio "+ sendRtpItem.getLocalPort()+" TCP/RTP/AVP 8\r\n"); -// }else { -// content.append("m=audio "+ sendRtpItem.getLocalPort()+" RTP/AVP 8\r\n"); -// } -// content.append("a=rtpmap:8 PCMA/8000\r\n"); -// } -// } -// if (sendRtpItem.isTcp()) { -// content.append("a=connection:new\r\n"); -// if (!sendRtpItem.isTcpActive()) { -// content.append("a=setup:active\r\n"); -// }else { -// content.append("a=setup:passive\r\n"); -// } -// } -// content.append("a=sendonly\r\n"); -// content.append("y="+ finalSsrc + "\r\n"); -// content.append("f=v/////a/1/8/1\r\n"); -// -// ParentPlatform parentPlatform = new ParentPlatform(); -// parentPlatform.setServerIP(device.getIp()); -// parentPlatform.setServerPort(device.getPort()); -// parentPlatform.setServerGBId(device.getDeviceId()); -// try { -// responseSdpAck(evt, content.toString(), parentPlatform); -// Dialog dialog = evt.getDialog(); -// audioBroadcastCatch.setDialog((SIPDialog) dialog); -// audioBroadcastCatch.setRequest((SIPRequest) request); -// audioBroadcastManager.update(audioBroadcastCatch); -// } catch (SipException e) { -// throw new RuntimeException(e); -// } catch (InvalidArgumentException e) { -// throw new RuntimeException(e); -// } catch (ParseException e) { -// throw new RuntimeException(e); -// } -// }else { - // 娴佷笉瀛樺湪鏃剁洃鍚祦涓婄嚎 // 璁剧疆绛夊緟鎺ㄦ祦鐨勮秴鏃�; 榛樿20s String waiteStreamTimeoutTaskKey = "waite-stream-" + device.getDeviceId() + audioBroadcastCatch.getChannelId(); dynamicTask.startDelay(waiteStreamTimeoutTaskKey, ()->{ logger.info("绛夊緟鎺ㄦ祦瓒呮椂: {}/{}", app, stream); - subscribe.removeSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey); + subscribe.removeSubscribe(subscribeKey); playService.stopAudioBroadcast(device.getDeviceId(), audioBroadcastCatch.getChannelId()); // 鍙戦�乥ye try { @@ -992,9 +903,10 @@ }, 20*1000); boolean finalMediaTransmissionTCP = mediaTransmissionTCP; - subscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey, + subscribe.addSubscribe(subscribeKey, (MediaServerItem mediaServerItemInUse, JSONObject json)->{ logger.info("鏀跺埌璇煶瀵硅鎺ㄦ祦"); + dynamicTask.stop(waiteStreamTimeoutTaskKey); MediaItem mediaItem = JSON.toJavaObject(json, MediaItem.class); Integer audioCodecId = null; if (mediaItem.getTracks() != null && mediaItem.getTracks().size() > 0) { diff --git a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java index 0dc6bd3..2e11833 100644 --- a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java +++ b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java @@ -238,7 +238,7 @@ // 閴存潈閫氳繃 redisCatchStorage.updateStreamAuthorityInfo(param.getApp(), param.getStream(), streamAuthorityInfo); // 閫氱煡assist鏂扮殑callId - if (mediaInfo != null) { + if (mediaInfo != null && mediaInfo.getRecordAssistPort() > 0) { assistRESTfulUtils.addStreamCallInfo(mediaInfo, param.getApp(), param.getStream(), callId, null); } }else { diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServiceImpl.java index 5a277d7..abba530 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServiceImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServiceImpl.java @@ -69,7 +69,7 @@ if (authority) { streamInfo = getStreamInfoByAppAndStream(mediaInfo, app, stream, tracks, addr,streamAuthorityInfo.getCallId(), true); }else { - streamInfo = getStreamInfoByAppAndStream(mediaInfo, app, stream, tracks, addr,null); + streamInfo = getStreamInfoByAppAndStream(mediaInfo, app, stream, tracks, addr,null, true); } } diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/PlayServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/impl/PlayServiceImpl.java index 5ae0103..9036839 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/impl/PlayServiceImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/service/impl/PlayServiceImpl.java @@ -8,6 +8,7 @@ import javax.sip.ResponseEvent; +import com.genersoft.iot.vmp.gb28181.bean.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -23,13 +24,6 @@ import com.genersoft.iot.vmp.conf.DynamicTask; import com.genersoft.iot.vmp.conf.SipConfig; import com.genersoft.iot.vmp.conf.UserSetting; -import com.genersoft.iot.vmp.gb28181.bean.Device; -import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel; -import com.genersoft.iot.vmp.gb28181.bean.InviteStreamCallback; -import com.genersoft.iot.vmp.gb28181.bean.InviteStreamInfo; -import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; -import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem; -import com.genersoft.iot.vmp.gb28181.bean.SsrcTransaction; import com.genersoft.iot.vmp.gb28181.event.SipSubscribe; import com.genersoft.iot.vmp.gb28181.session.AudioBroadcastManager; import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager; diff --git a/web_src/src/components/Login.vue b/web_src/src/components/Login.vue index 4ade744..1dbd919 100644 --- a/web_src/src/components/Login.vue +++ b/web_src/src/components/Login.vue @@ -35,6 +35,7 @@ <script> import crypto from 'crypto' +import Vue from 'vue' export default { name: 'Login', data(){ @@ -84,11 +85,13 @@ url:"/api/user/login", params: loginParam }).then(function (res) { - console.log(JSON.stringify(res)); + console.log(res); + console.log(res.data.data); if (res.data.code == 0 && res.data.msg == "success") { that.$cookies.set("session", {"username": that.username,"roleId":res.data.data.role.id}) ; //鐧诲綍鎴愬姛鍚� that.cancelEnterkeyDefaultAction(); + Vue.prototype.$loginUser = res.data.data that.$router.push('/'); }else{ that.isLoging = false; diff --git a/web_src/src/components/dialog/devicePlayer.vue b/web_src/src/components/dialog/devicePlayer.vue index ba02441..c11df1d 100644 --- a/web_src/src/components/dialog/devicePlayer.vue +++ b/web_src/src/components/dialog/devicePlayer.vue @@ -298,6 +298,7 @@ <script> import rtcPlayer from '../dialog/rtcPlayer.vue' +import crypto from 'crypto' // import LivePlayer from '@liveqing/liveplayer' // import player from '../dialog/easyPlayer.vue' import jessibucaPlayer from '../common/jessibuca.vue' @@ -861,6 +862,10 @@ } }, startBroadcast(url){ + // 鑾峰彇鎺ㄦ祦閴存潈KEY + console.log(this.$loginUser) + console.log(this.$loginUser.pushKey) + url += "&sign=" + crypto.createHash('md5').update(this.$loginUser.pushKey, "utf8").digest('hex') console.log("寮�濮嬭闊冲璁诧細 " + url) this.broadcastRtc = new ZLMRTCClient.Endpoint({ debug: true, // 鏄惁鎵撳嵃鏃ュ織 -- Gitblit v1.8.0