From 7716cf0a84e88f27e05ab70346f79c4781e5692a Mon Sep 17 00:00:00 2001
From: aijinhui <aijinhui>
Date: 星期二, 12 九月 2023 09:48:25 +0800
Subject: [PATCH] 设备健康点位

---
 ard-work/src/main/java/com/ruoyi/media/service/impl/MediaServiceImpl.java |   45 +++++++++++++++++++++++++++------------------
 1 files changed, 27 insertions(+), 18 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 c7cdcc4..5eecbc0 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
@@ -11,6 +11,9 @@
 import com.sun.jna.Platform;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.PostConstruct;
@@ -33,11 +36,13 @@
  **/
 @Service
 @Slf4j(topic = "cmd")
-public class MediaServiceImpl implements IMediaService {
+@Order(2)
+public class MediaServiceImpl implements IMediaService, ApplicationRunner {
     @Resource
     VtduMapper vtduMapper;
     @Resource
     MediaClient mediaClient;
+
     @Value("${mediamtx.host}")
     String mediamtxHost;
     @Value("${mediamtx.enabled}")
@@ -47,12 +52,28 @@
 
     String processName = "mediamtx.exe";
 
-    static{
-
+    @Override
+    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());
+            }
+        }
+        catch (Exception ex)
+        {
+            log.error("鍔犺浇娴佸獟浣撳垪琛ㄥ紓甯�:"+ex.getMessage());
+        }
     }
     @PostConstruct
     public void initMediaMtx() {
         if (mediamtxEnabled) {
+            log.info("鍒濆鍖栧惎鍔╩ediaMTX");
             if (Platform.isWindows()) {
                 String exePath = System.getProperty("user.dir") + File.separator + "lib" + File.separator + "mediamtx" + File.separator + "mediamtx.exe";
                 String ymlPath = System.getProperty("user.dir") + File.separator + "lib" + File.separator + "mediamtx" + File.separator + "mediamtx.yml";
@@ -70,20 +91,6 @@
 //            String[] command = {"cmd","/c","start",exePath,ymlPath};
 //            CmdUtils.commandStart(command);
             }
-        }
-        try {
-            Thread.sleep(2000); // 绛夊緟5绉�
-        } catch (InterruptedException e) {
-            e.printStackTrace();
-        }
-        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());
         }
     }
 
@@ -106,6 +113,7 @@
         //-vcodec libx264 //鎸囧畾瑙嗛缂栫爜鍣ㄤ负 libx264锛屼娇鐢� H.264 缂栫爜鏍煎紡杩涜瑙嗛鍘嬬缉
         //-preset ultrafast  //--preset鐨勫弬鏁颁富瑕佽皟鑺傜紪鐮侀�熷害鍜岃川閲忕殑骞宠 锛屾湁ultrafast锛堣浆鐮侀�熷害鏈�蹇紝瑙嗛寰�寰�涔熸渶妯$硦锛夈�乻uperfast銆乿eryfast銆乫aster銆乫ast銆乵edium銆乻low銆乻lower銆乿eryslow銆乸lacebo杩�10涓�夐」锛屼粠蹇埌鎱�
         //-r 25 //璁剧疆杈撳嚭瑙嗛鐨勫抚鐜囦负 25 甯�/绉�
+        //-g 20 //鍏抽敭甯ч棿闅�20
         //-rtsp_transport tcp //杩欎釜閫夐」鍛婅瘔 FFmpeg 浣跨敤 TCP 浣滀负 RTSP 鐨勪紶杈撳崗璁�
         //-threads 4: 鎸囧畾瑕佷娇鐢ㄧ殑绾跨▼鏁颁负 4銆�//杩欏厑璁� FFmpeg 鍦ㄥ鏍稿鐞嗗櫒涓婁娇鐢ㄥ涓嚎绋嬫潵杩涜瑙嗛缂栫爜锛屼互鍔犲揩閫熷害銆�
         // -i //鐢ㄤ簬鎸囧畾杈撳叆濯掍綋鏂囦欢鎴栬緭鍏ユ祦鐨勫湴鍧�
@@ -116,7 +124,7 @@
         //GPU纭В鐮佺紪鐮� -hwaccel cuvid -c:v h264_cuvid  浣跨敤cuda瑙g爜   -c:v h264_nvenc 浣跨敤cuda缂栫爜
         //String cmd = rootPath  + "/lib/mediamtx/" + "ffmpeg -hwaccel cuvid -c:v h264_cuvid  -rtsp_transport udp  -i " + rtspPath + " -c:v h264_nvenc  -r 25 -threads 4  -b:v 2048k -bf 0 -f rtsp rtsp://localhost:$RTSP_PORT/$MTX_PATH";
         if (isCode.equals("1")) {
-            String cmd =  "ffmpeg -rtsp_transport tcp -i " + rtspPath + " -vcodec libx264 -preset:v ultrafast -r 25 -threads 6  -b:v 1024k -f rtsp rtsp://localhost:$RTSP_PORT/$MTX_PATH";
+            String cmd =  "ffmpeg -rtsp_transport tcp -i " + rtspPath + " -vcodec libx264 -preset:v ultrafast -r 25 -g 20 -threads 6  -b:v 2048k -f rtsp rtsp://localhost:$RTSP_PORT/$MTX_PATH";
             if (!softwareDecoding) {
                 cmd =  "ffmpeg -hwaccel cuvid -c:v h264_cuvid  -rtsp_transport tcp  -i " + rtspPath + " -c:v h264_nvenc  -r 25 -threads 6  -b:v 2048k -bf 0 -f rtsp rtsp://localhost:$RTSP_PORT/$MTX_PATH";
             }
@@ -456,4 +464,5 @@
             return false;
         }
     }
+
 }

--
Gitblit v1.9.3