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