报警回放本地测试修改

business-service/src/main/java/com/ozs/utils/CameraUtil.java

@@ -260,7 +260,6 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
 
     /**
      * web页面实时流接口
-     *
      * @param cameraCode
      * @param channel
      * @return
@@ -562,7 +561,7 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
         host = caneraConfig.getHost();
         appKey = caneraConfig.getAppKey();
         appSecret = caneraConfig.getAppSecret();
-        rtmpUrl = caneraConfig.getRtmpUrl();
+        rtmpUrl=caneraConfig.getRtmpUrl();
     }
 
     /**
@@ -705,7 +704,6 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
 
     /**
      * web页面视频回放接口
-     *
      * @param code
      * @param startTm
      * @param endTm
@@ -746,8 +744,8 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
             @Override
             public String call() throws Exception {
                 // 执行网络请求...
-                log.info(ffmpegPath + " -re -i /opt/streams/compress/" + code + ".mp4  -c:v copy -c:a copy -f flv " + rtmpUrl + "/live/" + code);
-                cmdCameraUtil.cmd(ffmpegPath + " -re -i /opt/streams/compress/" + code + ".mp4  -c:v copy -c:a copy -f flv " + rtmpUrl + "/live/" + code);
+                log.info(ffmpegPath + " -re -i /opt/streams/compress/" + code + ".mp4  -c:v copy -c:a copy -f flv "+rtmpUrl+"/live/" + code);
+                cmdCameraUtil.cmd(ffmpegPath + " -re -i /opt/streams/compress/" + code + ".mp4  -c:v copy -c:a copy -f flv "+rtmpUrl+"/live/" + code);
                 return "Response";
             }
         };
@@ -761,7 +759,7 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
         }
 
         executor.shutdown();
-        return bakUrlRtsp + "/live/" + code;
+        return  bakUrlRtsp+"/live/"+code;
     }
 
 
@@ -769,9 +767,9 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
      * RTSP流视频压缩
      */
     public void videoCompression(String code) {
-        // 执行网络请求...
-        log.info(ffmpegPath + " -i /opt/streams/map/" + code + ".mp4 -c:v libx264 -s 640x480 -c:a adpcm_swf -ar 44100 /opt/streams/compress/" + code + ".mp4");
-        cmdCameraUtil.cmd(ffmpegPath + " -i /opt/streams/map/" + code + ".mp4 -c:v libx264 -s 640x480 -c:a adpcm_swf -ar 44100 /opt/streams/compress/" + code + ".mp4");
+                // 执行网络请求...
+                log.info(ffmpegPath + " -i /opt/streams/map/"+code+".mp4 -c:v libx264 -s 640x480 -c:a adpcm_swf -ar 44100 /opt/streams/compress/" + code+".mp4");
+                cmdCameraUtil.cmd(ffmpegPath + " -i /opt/streams/map/"+code+".mp4 -c:v libx264 -s 640x480 -c:a adpcm_swf -ar 44100 /opt/streams/compress/" + code+".mp4");
     }
 
 
@@ -942,11 +940,10 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
 
     /**
      * 车载终端实时流调用的远程天网接口
-     *
      * @param camerasVo
      * @param channel
      */
-    public String apiPreviewURLs(CamerasVo camerasVo) {
+    public  String apiPreviewURLs(CamerasVo camerasVo) {
         /**
          *  jsonBody.put("cameraIndexCode", "01ea43e6676f4e47bd6c5cd9e02aa006");
          *         jsonBody.put("streamType", 0);
@@ -966,14 +963,13 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
             JSONObject data = outJson.getJSONObject("data");
             String urls = data.getString("url");
             return urls;
-        } else {
+        }else {
             return "1";
         }
     }
 
     /**
      * web页面实时流调用的远程天网接口
-     *
      * @param camerasVo
      * @param channel
      */
@@ -1004,16 +1000,15 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
     /**
      * 报警回放本地测试
      * 从天网拉回放流,然后根据url把流下载下来变成文件,然后进行视频压缩
-     *
      * @param list
      * @param alarmPlayTimeValue
      */
     public void playbackURLs(List<String> list, String alarmPlayTimeValue) {
         log.info("--------------->playbackURLs");
-        String code = "42010001541320000024";
-        CompletableFuture<Void> recordFuture = CompletableFuture.runAsync(() -> {
+        CompletableFuture future = CompletableFuture.supplyAsync(() -> {
             log.info("异步任务开始-----》");
 //            for (String code : list) {
+            String code="42010001541320000024";
             PlaybackVo playbackVo = new PlaybackVo();
             playbackVo.setCameraIndexCode(code);
             // 获取当前时间
@@ -1044,22 +1039,16 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
 //                String urls = data.getString("url");
 //                log.info("--------------->urls::" + urls);
 
-            String FilePath = "/opt/streams/map/" + code + ".mp4";
+            String FilePath = "/opt/streams/map/"+code+".mp4";
 //                String FilePath = "/opt/streams/map/01ea43e6676f4e47bd6c5cd9e02aa006.mp4";
-            Process process = rtspToMP4.StartRecord(ffmpegPath, "rtsp://124.70.58.209:8554/" + code + "/" + code, FilePath);
+            Process process = rtspToMP4.StartRecord(ffmpegPath, "rtsp://124.70.58.209:8554/"+code+"/"+code, FilePath);
             log.info("------playbackURLs----->>>>:" + process);
             if (null != process) {
                 map.put(code, process);
             }
+            return 1;
         });
-        CompletableFuture<Integer> compressionFuture = recordFuture.thenCompose(result ->
-                CompletableFuture.supplyAsync(() -> {
-                    log.info("-------videoCompression------->");
-                    videoCompression(code);
-                    return 1;
-                })
-        );
-        compressionFuture.join();
+        future.join();
     }
 
     public AjaxResult stop(String id) {