From 5fd7178b33e698997eab4256b023afa30091f56b Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期二, 05 九月 2023 14:00:34 +0800
Subject: [PATCH] 优化

---
 ard-work/src/main/java/com/ruoyi/media/service/impl/MediaServiceImpl.java |   27 ++++++++++++++++-----------
 1 files changed, 16 insertions(+), 11 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/media/service/impl/MediaServiceImpl.java b/ard-work/src/main/java/com/ruoyi/media/service/impl/MediaServiceImpl.java
index bd0b588..e27adb7 100644
--- a/ard-work/src/main/java/com/ruoyi/media/service/impl/MediaServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/media/service/impl/MediaServiceImpl.java
@@ -36,12 +36,13 @@
  **/
 @Service
 @Slf4j(topic = "cmd")
-@Order(1)
+@Order(2)
 public class MediaServiceImpl implements IMediaService, ApplicationRunner {
     @Resource
     VtduMapper vtduMapper;
     @Resource
     MediaClient mediaClient;
+
     @Value("${mediamtx.host}")
     String mediamtxHost;
     @Value("${mediamtx.enabled}")
@@ -51,18 +52,22 @@
 
     String processName = "mediamtx.exe";
 
-
     @Override
-    public void run(ApplicationArguments args) throws Exception {
-        log.info("寮�濮嬪姞杞芥祦濯掍綋鍒楄〃");
-        List<StreamInfo> paths = paths();
-        for(StreamInfo path:paths)
-        {
-            mediaClient.removePath(path.getName());
+    public void run(ApplicationArguments args){
+        try {
+            log.info("寮�濮嬪姞杞芥祦濯掍綋鍒楄〃");
+            List<StreamInfo> paths = paths();
+            for (StreamInfo path : paths) {
+                mediaClient.removePath(path.getName());
+            }
+            List<Vtdu> vtduList = vtduMapper.selectVtduList(new Vtdu());
+            for (Vtdu v : vtduList) {
+                addPath(v.getName(), v.getRtspUrl(), v.getCodeType(), v.getIsCode());
+            }
         }
-        List<Vtdu> vtduList = vtduMapper.selectVtduList(new Vtdu());
-        for (Vtdu v : vtduList) {
-            addPath(v.getName(), v.getRtspUrl(), v.getCodeType(), v.getIsCode());
+        catch (Exception ex)
+        {
+            log.error("鍔犺浇娴佸獟浣撳垪琛ㄥ紓甯�:"+ex.getMessage());
         }
     }
     @PostConstruct

--
Gitblit v1.9.3