From 78088ba53f58d5d1514d161086524ca05708f736 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Thu, 18 Jul 2024 18:00:45 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=B4=E6=97=B6=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/StreamProxyServiceImpl.java  | 20 ++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/streamProxy/service/impl/StreamProxyServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/streamProxy/service/impl/StreamProxyServiceImpl.java
index 7bdb29bb..0386b056 100755
--- a/src/main/java/com/genersoft/iot/vmp/streamProxy/service/impl/StreamProxyServiceImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/streamProxy/service/impl/StreamProxyServiceImpl.java
@@ -429,11 +429,29 @@ public class StreamProxyServiceImpl implements IStreamProxyService {
         }
         streamProxyMapper.add(streamProxy);
         if (streamProxy.isEnable()) {
-//            start()
+            return startProxy(streamProxy);
         }
         return null;
     }
 
+    private StreamInfo startProxy(StreamProxy streamProxy){
+        if (!streamProxy.isEnable()) {
+            return null;
+        }
+        MediaServer mediaServer;
+        String mediaServerId = streamProxy.getMediaServerId();
+        if (mediaServerId == null || "auto".equals(mediaServerId)) {
+            mediaServer = mediaServerService.getMediaServerForMinimumLoad(null);
+        }else {
+            mediaServer = mediaServerService.getOne(mediaServerId);
+        }
+        if (mediaServer == null) {
+            throw new ControllerException(ErrorCode.ERROR100.getCode(), "未找到可用的媒体节点");
+        }
+
+        return mediaServerService.startProxy(mediaServer, streamProxy);
+
+    }
     //    @Scheduled(cron = "* 0/10 * * * ?")
 //    public void asyncCheckStreamProxyStatus() {
 //