From c1145a816399528e81589eef11046d877315ad5e Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期一, 12 十二月 2022 10:28:36 +0800
Subject: [PATCH] 优化级联注册,以及sip日志

---
 src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java |   31 ++++++++++++++-----------------
 1 files changed, 14 insertions(+), 17 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java
index 46aa63c..c94dbf2 100644
--- a/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java
+++ b/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java
@@ -106,24 +106,21 @@
 			msg.setData(wvpResult);
 			resultHolder.invokeResult(msg);
 		});
-
-
-			// TODO 鍦ㄧ偣鎾湭鎴愬姛鐨勬儏鍐典笅鍦ㄦ璋冪敤鎺ュ彛鐐规挱浼氬鑷磋繑鍥炵殑娴佸湴鍧�ip閿欒
-			deferredResultEx.setFilter(result1 -> {
-				WVPResult<StreamInfo> wvpResult1 = (WVPResult<StreamInfo>)result1;
-				WVPResult<StreamContent> resultStream = null;
-				if (wvpResult1.getCode() == ErrorCode.SUCCESS.getCode()) {
-					StreamInfo data = wvpResult1.getData().clone();
-					if (userSetting.getUseSourceIpAsStreamIp()) {
-						data.channgeStreamIp(request.getLocalName());
-					}
-					resultStream = new WVPResult<>();
-					resultStream.setCode(wvpResult1.getCode());
-					resultStream.setMsg(wvpResult1.getMsg());
-					resultStream.setData(new StreamContent(wvpResult1.getData()));
+		// TODO 鍦ㄧ偣鎾湭鎴愬姛鐨勬儏鍐典笅鍦ㄦ璋冪敤鎺ュ彛鐐规挱浼氬鑷磋繑鍥炵殑娴佸湴鍧�ip閿欒
+		deferredResultEx.setFilter(result1 -> {
+			WVPResult<StreamInfo> wvpResult1 = (WVPResult<StreamInfo>)result1;
+			WVPResult<StreamContent> resultStream = new WVPResult<>();
+			resultStream.setCode(wvpResult1.getCode());
+			resultStream.setMsg(wvpResult1.getMsg());
+			if (wvpResult1.getCode() == ErrorCode.SUCCESS.getCode()) {
+				StreamInfo data = wvpResult1.getData().clone();
+				if (userSetting.getUseSourceIpAsStreamIp()) {
+					data.channgeStreamIp(request.getLocalName());
 				}
-				return resultStream;
-			});
+				resultStream.setData(new StreamContent(wvpResult1.getData()));
+			}
+			return resultStream;
+		});
 
 
 		// 褰曞儚鏌ヨ浠hannelId浣滀负deviceId鏌ヨ

--
Gitblit v1.8.0