From 7f48246165b3c815e928cee04f8d4e2cf689b6aa Mon Sep 17 00:00:00 2001
From: panlinlin <648540858@qq.com>
Date: 星期四, 22 四月 2021 18:09:46 +0800
Subject: [PATCH] 增加对设备录像播放的兼容性

---
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/SIPRequestHeaderProvider.java |    3 +--
 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java                 |    1 -
 web_src/src/components/StreamProxyList.vue                                             |    2 +-
 web_src/src/components/dialog/StreamProxyEdit.vue                                      |    9 +++++++--
 4 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/SIPRequestHeaderProvider.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/SIPRequestHeaderProvider.java
index cecbe3c..691bc42 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/SIPRequestHeaderProvider.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/SIPRequestHeaderProvider.java
@@ -37,8 +37,7 @@
 		SipURI requestURI = sipFactory.createAddressFactory().createSipURI(device.getDeviceId(), device.getHostAddress());
 		// via
 		ArrayList<ViaHeader> viaHeaders = new ArrayList<ViaHeader>();
-		ViaHeader viaHeader = sipFactory.createHeaderFactory().createViaHeader(sipConfig.getSipIp(), sipConfig.getSipPort(),
-				device.getTransport(), viaTag);
+		ViaHeader viaHeader = sipFactory.createHeaderFactory().createViaHeader(sipConfig.getSipIp(), sipConfig.getSipPort(), device.getTransport(), viaTag);
 		viaHeader.setRPort();
 		viaHeaders.add(viaHeader);
 		// from
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 14719cc..5795690 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
@@ -254,7 +254,6 @@
 			System.out.println("on_stream_changed->>" + schema);
 		}
 		if ("rtmp".equals(schema)){
-
 			if ("rtp".equals(app) && !regist ) {
 				StreamInfo streamInfo = redisCatchStorage.queryPlayByStreamId(streamId);
 				if (streamInfo!=null){
diff --git a/web_src/src/components/StreamProxyList.vue b/web_src/src/components/StreamProxyList.vue
index ee3d43c..0e0fcdd 100644
--- a/web_src/src/components/StreamProxyList.vue
+++ b/web_src/src/components/StreamProxyList.vue
@@ -194,7 +194,7 @@
 					          that.initData()
                 }).catch(function (error) {
                     console.log(error);
-					that.getListLoading = false;
+					          that.getListLoading = false;
                 });
 			},
 			start: function(row){
diff --git a/web_src/src/components/dialog/StreamProxyEdit.vue b/web_src/src/components/dialog/StreamProxyEdit.vue
index 66f63ad..696379e 100644
--- a/web_src/src/components/dialog/StreamProxyEdit.vue
+++ b/web_src/src/components/dialog/StreamProxyEdit.vue
@@ -10,7 +10,7 @@
       @close="close()"
     >
       <div id="shared" style="margin-top: 1rem;margin-right: 100px;">
-        <el-form ref="streamProxy" :rules="rules" :model="proxyParam" label-width="140px">
+        <el-form ref="streamProxy" :rules="rules" :model="proxyParam" label-width="140px" >
               <el-form-item label="绫诲瀷" prop="type">
                 <el-select
                   v-model="proxyParam.type"
@@ -66,7 +66,7 @@
               </el-form-item>
               <el-form-item>
                 <div style="float: right;">
-                  <el-button type="primary" @click="onSubmit">{{onSubmit_text}}</el-button>
+                  <el-button type="primary" @click="onSubmit" :loading="dialogLoading" >{{onSubmit_text}}</el-button>
                   <el-button @click="close">鍙栨秷</el-button>
                 </div>
 
@@ -104,6 +104,7 @@
       listChangeCallback: null,
       showDialog: false,
       isLoging: false,
+      dialogLoading: false,
       onSubmit_text: "绔嬪嵆鍒涘缓",
       proxyParam: {
           name: null,
@@ -145,12 +146,14 @@
     },
     onSubmit: function () {
       console.log("onSubmit");
+      this.dialogLoading = true;
       var that = this;
       that.$axios({
         method: 'post',
         url:`/api/proxy/save`,
         data: that.proxyParam
       }).then(function (res) {
+        that.dialogLoading = false;
         if (typeof (res.data.code) != "undefined" && res.data.code === 0) {
           that.$message({
             showClose: true,
@@ -164,11 +167,13 @@
         }
       }).catch(function (error) {
         console.log(error);
+        this.dialogLoading = false;
       });
     },
     close: function () {
       console.log("鍏抽棴娣诲姞瑙嗛骞冲彴");
       this.showDialog = false;
+      this.dialogLoading = false;
       this.$refs.streamProxy.resetFields();
     },
     deviceGBIdExit: async function (deviceGbId) {

--
Gitblit v1.8.0