From a1ba81196299c95b9ae21cf96ec87fda642cde16 Mon Sep 17 00:00:00 2001
From: lin <648540858@qq.com>
Date: Tue, 20 May 2025 17:59:16 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E6=8E=A8=E6=B5=81=E8=8E=B7?=
 =?UTF-8?q?=E5=8F=96=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/StreamPushPlayServiceImpl.java       | 29 ++++++++++---------
 1 file changed, 15 insertions(+), 14 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/streamPush/service/impl/StreamPushPlayServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/streamPush/service/impl/StreamPushPlayServiceImpl.java
index 653b97712..ec5e030dc 100644
--- a/src/main/java/com/genersoft/iot/vmp/streamPush/service/impl/StreamPushPlayServiceImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/streamPush/service/impl/StreamPushPlayServiceImpl.java
@@ -63,21 +63,22 @@ public class StreamPushPlayServiceImpl implements IStreamPushPlayService {
         }
 
         MediaServer mediaServer = mediaServerService.getOne(streamPush.getMediaServerId());
-        Assert.notNull(mediaServer, "节点" + streamPush.getMediaServerId() + "未找到");
-        MediaInfo mediaInfo = mediaServerService.getMediaInfo(mediaServer, streamPush.getApp(), streamPush.getStream());
-        if (mediaInfo != null) {
-            String callId = null;
-            StreamAuthorityInfo streamAuthorityInfo = redisCatchStorage.getStreamAuthorityInfo(streamPush.getApp(), streamPush.getStream());
-            if (streamAuthorityInfo != null) {
-                callId = streamAuthorityInfo.getCallId();
+        if (mediaServer != null) {
+            MediaInfo mediaInfo = mediaServerService.getMediaInfo(mediaServer, streamPush.getApp(), streamPush.getStream());
+            if (mediaInfo != null) {
+                String callId = null;
+                StreamAuthorityInfo streamAuthorityInfo = redisCatchStorage.getStreamAuthorityInfo(streamPush.getApp(), streamPush.getStream());
+                if (streamAuthorityInfo != null) {
+                    callId = streamAuthorityInfo.getCallId();
+                }
+                callback.run(ErrorCode.SUCCESS.getCode(), ErrorCode.SUCCESS.getMsg(), mediaServerService.getStreamInfoByAppAndStream(mediaServer,
+                        streamPush.getApp(), streamPush.getStream(), mediaInfo, callId));
+                if (!streamPush.isPushing()) {
+                    streamPush.setPushing(true);
+                    streamPushMapper.update(streamPush);
+                }
+                return;
             }
-            callback.run(ErrorCode.SUCCESS.getCode(), ErrorCode.SUCCESS.getMsg(), mediaServerService.getStreamInfoByAppAndStream(mediaServer,
-                    streamPush.getApp(), streamPush.getStream(), mediaInfo, callId));
-            if (!streamPush.isPushing()) {
-                streamPush.setPushing(true);
-                streamPushMapper.update(streamPush);
-            }
-            return;
         }
         Assert.isTrue(streamPush.isStartOfflinePush(), "通道未推流");
         // 发送redis消息以使设备上线，流上线后被