[RPC 拉流代理] 修复停止是误报信息

src/main/java/com/genersoft/iot/vmp/streamProxy/dao/StreamProxyMapper.java

@@ -13,10 +13,10 @@ public interface StreamProxyMapper {
 
     @Insert("INSERT INTO wvp_stream_proxy (type, app, stream,relates_media_server_id, src_url, " +
             "timeout, ffmpeg_cmd_key, rtsp_type, enable_audio, enable_mp4, enable, pulling, " +
-            "enable_remove_none_reader, enable_disable_none_reader, create_time) VALUES" +
+            "enable_remove_none_reader, enable_disable_none_reader, server_id, create_time) VALUES" +
             "(#{type}, #{app}, #{stream}, #{relatesMediaServerId}, #{srcUrl}, " +
             "#{timeout}, #{ffmpegCmdKey}, #{rtspType}, #{enableAudio}, #{enableMp4}, #{enable}, #{pulling}, " +
-            "#{enableRemoveNoneReader}, #{enableDisableNoneReader}, #{createTime} )")
+            "#{enableRemoveNoneReader}, #{enableDisableNoneReader}, #{serverId}, #{createTime} )")
     @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
     int add(StreamProxy streamProxyDto);
 

src/main/java/com/genersoft/iot/vmp/streamProxy/service/impl/StreamProxyPlayServiceImpl.java

@@ -83,6 +83,7 @@ public class StreamProxyPlayServiceImpl implements IStreamProxyPlayService {
         }
         if (!userSetting.getServerId().equals(streamProxy.getServerId())) {
             redisRpcPlayService.stopProxy(streamProxy.getServerId(), streamProxy.getId());
+            return;
         }
         stopProxy(streamProxy);
     }

数据库/2.7.3/数据库统合-更新.sql

@@ -3,4 +3,8 @@
 */
 alter table wvp_device add server_id character varying(50);
 alter table wvp_media_server add server_id character varying(50);
-alter table wvp_stream_proxy add server_id character varying(50);
+alter table wvp_stream_proxy add server_id character varying(50);
+
+update wvp_device set server_id = "你服务的ID";
+update wvp_media_server set server_id = "你服务的ID";
+update wvp_stream_proxy set server_id = "你服务的ID";