From c96c29776db8fc36c0c6c2c27b24944a6cd843be Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: Mon, 22 Jul 2024 14:20:40 +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 --- .../controller/StreamProxyController.java | 9 ++++--- .../service/IStreamProxyService.java | 2 ++ .../service/impl/StreamProxyServiceImpl.java | 10 ++++++-- web_src/src/components/StreamProxyList.vue | 24 ++++++++++++++++++- 4 files changed, 37 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/streamProxy/controller/StreamProxyController.java b/src/main/java/com/genersoft/iot/vmp/streamProxy/controller/StreamProxyController.java index 8633ccebf..bbee224c4 100755 --- a/src/main/java/com/genersoft/iot/vmp/streamProxy/controller/StreamProxyController.java +++ b/src/main/java/com/genersoft/iot/vmp/streamProxy/controller/StreamProxyController.java @@ -192,10 +192,9 @@ public class StreamProxyController { @GetMapping(value = "/stop") @ResponseBody @Operation(summary = "停用代理", security = @SecurityRequirement(name = JwtUtils.HEADER)) - @Parameter(name = "app", description = "应用名", required = true) - @Parameter(name = "stream", description = "流id", required = true) - public void stop(String app, String stream){ - log.info("停用代理： " + app + "/" + stream); - streamProxyService.stopByAppAndStream(app, stream); + @Parameter(name = "id", description = "代理Id", required = true) + public void stop(int id){ + log.info("停用代理： {}", id); + streamProxyService.stop(id); } } diff --git a/src/main/java/com/genersoft/iot/vmp/streamProxy/service/IStreamProxyService.java b/src/main/java/com/genersoft/iot/vmp/streamProxy/service/IStreamProxyService.java index 77259ee85..f445cc160 100755 --- a/src/main/java/com/genersoft/iot/vmp/streamProxy/service/IStreamProxyService.java +++ b/src/main/java/com/genersoft/iot/vmp/streamProxy/service/IStreamProxyService.java @@ -94,4 +94,6 @@ public interface IStreamProxyService { void delete(int id); StreamInfo start(int id); + + void stop(int id); } 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 8a14dfd7a..1e7a3ab81 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 @@ -474,8 +474,14 @@ public class StreamProxyServiceImpl implements IStreamProxyService { return streamProxyMapper.select(id); } - - + @Override + public void stop(int id) { + StreamProxy streamProxy = streamProxyMapper.select(id); + if (streamProxy == null) { + throw new ControllerException(ErrorCode.ERROR404.getCode(), "代理信息未找到"); + } + stopProxy(streamProxy); + } // @Scheduled(cron = "* 0/10 * * * ?") // public void asyncCheckStreamProxyStatus() { diff --git a/web_src/src/components/StreamProxyList.vue b/web_src/src/components/StreamProxyList.vue index 4a523bad5..6255fc65f 100755 --- a/web_src/src/components/StreamProxyList.vue +++ b/web_src/src/components/StreamProxyList.vue @@ -74,8 +74,10 @@