流媒体定时任务

hazard-admin/src/main/java/com/ozs/web/core/util/CameraUtil.java

@@ -1045,57 +1045,57 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
     }
 
 
-    public void removePrice(Integer number) {
-        try {
-            // 创建MinioClient对象
-            MinioClient minioClient = MinioClient.builder()
-                    .endpoint(endpoint)
-                    .credentials(accessKey, secretKey)
-                    .build();
-
-            // 指定要删除文件的桶名和目录名
-            String bucketName = this.bucketName;
-            String prefix = "/camera_picture/normal/";
-
-            // 指定要删除的时间点（此处为当前时间之前的时间）
-            ZonedDateTime deleteTime = ZonedDateTime.now().minusDays(number); // 删除30天前的文件
-
-            // 删除指定目录下的所有文件和文件夹
-            deleteObjectsAndEmptyDirectoriesRecursively(minioClient, bucketName, prefix, deleteTime);
-        } catch (Exception e) {
-            System.out.println("Error occurred: " + e);
-        }
-    }
-
-    private static void deleteObjectsAndEmptyDirectoriesRecursively(MinioClient minioClient, String bucketName, String prefix, ZonedDateTime deleteTime) throws Exception {
-        Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder()
-                .bucket(bucketName)
-                .prefix(prefix)
-                .recursive(true)
-                .build());
-
-        for (Result<Item> result : results) {
-            Item item = result.get();
-            ZonedDateTime itemLastModified = item.lastModified();
-            log.info("删除的时间:" + deleteTime);
-            log.info("文件夹的时间:" + itemLastModified);
-            if (itemLastModified.isBefore(deleteTime)) {
-                // 删除文件或文件夹
-                minioClient.removeObject(RemoveObjectArgs.builder()
-                        .bucket(bucketName)
-                        .object(item.objectName())
-                        .build());
-                log.info("删除文件或文件夹: " + item.objectName());
-            }
-        }
-    }
+//    public void removePrice(Integer number) {
+//        try {
+//            // 创建MinioClient对象
+//            MinioClient minioClient = MinioClient.builder()
+//                    .endpoint(endpoint)
+//                    .credentials(accessKey, secretKey)
+//                    .build();
+//
+//            // 指定要删除文件的桶名和目录名
+//            String bucketName = this.bucketName;
+//            String prefix = "/camera_picture/normal/";
+//
+//            // 指定要删除的时间点（此处为当前时间之前的时间）
+//            ZonedDateTime deleteTime = ZonedDateTime.now().minusDays(number); // 删除30天前的文件
+//
+//            // 删除指定目录下的所有文件和文件夹
+//            deleteObjectsAndEmptyDirectoriesRecursively(minioClient, bucketName, prefix, deleteTime);
+//        } catch (Exception e) {
+//            System.out.println("Error occurred: " + e);
+//        }
+//    }
+//
+//    private static void deleteObjectsAndEmptyDirectoriesRecursively(MinioClient minioClient, String bucketName, String prefix, ZonedDateTime deleteTime) throws Exception {
+//        Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder()
+//                .bucket(bucketName)
+//                .prefix(prefix)
+//                .recursive(true)
+//                .build());
+//
+//        for (Result<Item> result : results) {
+//            Item item = result.get();
+//            ZonedDateTime itemLastModified = item.lastModified();
+//            log.info("删除的时间:" + deleteTime);
+//            log.info("文件夹的时间:" + itemLastModified);
+//            if (itemLastModified.isBefore(deleteTime)) {
+//                // 删除文件或文件夹
+//                minioClient.removeObject(RemoveObjectArgs.builder()
+//                        .bucket(bucketName)
+//                        .object(item.objectName())
+//                        .build());
+//                log.info("删除文件或文件夹: " + item.objectName());
+//            }
+//        }
+//    }
 
 
     public void test(Integer number) {
-        removePrice(number);
+        removePrice();
     }
 
-    public static void main(String[] args) {
+    public  void removePrice() {
         String host = "124.70.58.209"; // 远程主机
         String user = "root"; // SSH用户名
         String password = "y06ak@ql95K50"; // SSH密码