心跳接口修改

vehicle-sdk/src/main/java/com/ozs/controller/upload/GeoHazardMonitorTokenController.java

@@ -93,6 +93,7 @@ import java.util.List;
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 /**
@@ -722,7 +723,14 @@ public class GeoHazardMonitorTokenController {
                                         String[] parts = str.split("/");
                                         log.info("--------------parts--------------:" + Arrays.toString(parts));
                                         if (parts.length == 2) {
-                                            cameraUtil.stopStream(parts[0], parts[1]);
+                                            CompletableFuture.runAsync(() -> {
+                                                try {
+                                                    TimeUnit.SECONDS.sleep(3);
+                                                } catch (InterruptedException e) {
+                                                    e.printStackTrace();
+                                                }
+                                                cameraUtil.stopStream(parts[0], parts[1]);
+                                            });
                                         }
                                     }
                                 }
@@ -870,7 +878,14 @@ public class GeoHazardMonitorTokenController {
                                             String[] parts = str.split("/");
                                             log.info("--------------parts--------------:" + parts);
                                             if (parts.length == 2) {
-                                                cameraUtil.stopStream(parts[0], parts[1]);
+                                                CompletableFuture.runAsync(() -> {
+                                                    try {
+                                                        TimeUnit.SECONDS.sleep(3);
+                                                    } catch (InterruptedException e) {
+                                                        e.printStackTrace();
+                                                    }
+                                                    cameraUtil.stopStream(parts[0], parts[1]);
+                                                });
                                             }
                                         }
                                     }
@@ -945,7 +960,14 @@ public class GeoHazardMonitorTokenController {
                                     String[] parts = str.split("/");
                                     log.info("--------------parts--------------:" + parts);
                                     if (parts.length == 2) {
-                                        cameraUtil.stopStream(parts[0], parts[1]);
+                                        CompletableFuture.runAsync(() -> {
+                                            try {
+                                                TimeUnit.SECONDS.sleep(3);
+                                            } catch (InterruptedException e) {
+                                                e.printStackTrace();
+                                            }
+                                            cameraUtil.stopStream(parts[0], parts[1]);
+                                        });
                                     }
                                 }
                             }
@@ -1065,7 +1087,14 @@ public class GeoHazardMonitorTokenController {
                                         String[] parts = str.split("/");
                                         log.info("--------------parts--------------:" + parts);
                                         if (parts.length == 2) {
-                                            cameraUtil.stopStream(parts[0], parts[1]);
+                                            CompletableFuture.runAsync(() -> {
+                                                try {
+                                                    TimeUnit.SECONDS.sleep(3);
+                                                } catch (InterruptedException e) {
+                                                    e.printStackTrace();
+                                                }
+                                                cameraUtil.stopStream(parts[0], parts[1]);
+                                            });
                                         }
                                     }
                                 }
@@ -1151,7 +1180,14 @@ public class GeoHazardMonitorTokenController {
                                     String[] parts = str.split("/");
                                     log.info("--------------parts--------------:" + parts);
                                     if (parts.length == 2) {
-                                        cameraUtil.stopStream(parts[0], parts[1]);
+                                        CompletableFuture.runAsync(() -> {
+                                            try {
+                                                TimeUnit.SECONDS.sleep(3);
+                                            } catch (InterruptedException e) {
+                                                e.printStackTrace();
+                                            }
+                                            cameraUtil.stopStream(parts[0], parts[1]);
+                                        });
                                     }
                                 }
                             }
@@ -1210,7 +1246,14 @@ public class GeoHazardMonitorTokenController {
                                     String[] parts = str.split("/");
                                     log.info("--------------parts--------------:" + parts);
                                     if (parts.length == 2) {
-                                        cameraUtil.stopStream(parts[0], parts[1]);
+                                        CompletableFuture.runAsync(() -> {
+                                            try {
+                                                TimeUnit.SECONDS.sleep(3);
+                                            } catch (InterruptedException e) {
+                                                e.printStackTrace();
+                                            }
+                                            cameraUtil.stopStream(parts[0], parts[1]);
+                                        });
                                     }
                                 }
                             }