hazard-admin/src/main/java/com/ozs/web/controller/accountmanagment/BaseCameraManagementController.java

@@ -1010,8 +1010,8 @@ public class BaseCameraManagementController extends BaseController {
      */
     @GetMapping("/removePrice/{number}")
     public AjaxResult removePrice(@PathVariable Integer number) {
-        log.info("removePrice");
-        cameraUtil.test();
+        log.info("-----------------------removePrice");
+        cameraUtil.removePrice();
         return success();
     }
 

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

@@ -1198,219 +1198,238 @@ 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() {
+        log.info("removePrice-----------开始调用");
+        try {
+            // 创建MinioClient对象
+            MinioClient minioClient = MinioClient.builder()
+                    .endpoint(endpoint)
+                    .credentials(accessKey, secretKey)
+                    .build();
 
-    public void test() {
-        removePrice();
-    }
+            // 指定要删除文件的桶名和目录名
+            String bucketName = this.bucketName;
+            String prefix = "camera_picture/normal/";
 
-    public void removePrice() {
-        String host = "10.161.12.52"; // 远程主机
-        String user = "root"; // SSH用户名
-        String password = "iTi*21116"; // SSH密码
+            // 指定要删除的时间点（此处为当前时间之前的时间）
+            ZonedDateTime deleteTime = ZonedDateTime.now().minusDays(120); // 删除30天前的文件
 
-        try {
-            JSch jsch = new JSch();
-            Session session = jsch.getSession(user, host, 22); // 默认SSH端口号是22
-            session.setConfig("StrictHostKeyChecking", "no"); // 不进行主机密钥检查
-            session.setPassword(password);
-            session.connect();
-
-            String remoteDir = "/data/minio/data/picbucket/camera_picture/normal/"; // 要查看的远程目录
-
-            Channel channel = session.openChannel("exec");
-            ((ChannelExec) channel).setCommand("ls " + remoteDir); // 在远程服务器上执行第一次`ls`命令
-            InputStream in = channel.getInputStream();
-            channel.connect();
-            BufferedReader reader = new BufferedReader(new InputStreamReader(in));
-            String line;
-            //第一次命令输出
-            while ((line = reader.readLine()) != null) {
-                StringBuilder commandOutput = new StringBuilder(); // 存储命令输出
-                commandOutput.append(remoteDir);
-                System.out.println(line);
-                commandOutput.append(line);
-
-                // 执行第二次命令输出
-                Channel channel2 = session.openChannel("exec");
-                ((ChannelExec) channel2).setCommand("ls " + commandOutput.toString()); // 在远程服务器上执行第二次`ls`命令
-                InputStream in2 = channel2.getInputStream();
-                channel2.connect();
-
-                BufferedReader reader2 = new BufferedReader(new InputStreamReader(in2));
-                while ((line = reader2.readLine()) != null) {
-                    System.out.println(line); // 输出第二次`ls -l`的结果
-                    commandOutput.append("/" + line);
-
-                    // 执行第三次命令输出
-                    Channel channel3 = session.openChannel("exec");
-                    ((ChannelExec) channel3).setCommand("ls " + commandOutput.toString()); // 在远程服务器上执行第三次`ls`命令
-                    InputStream in3 = channel3.getInputStream();
-                    channel3.connect();
-
-                    BufferedReader reader3 = new BufferedReader(new InputStreamReader(in3));
-                    while ((line = reader3.readLine()) != null) {
-                        System.out.println(line); // 输出第三次`ls -l`的结果
-                        commandOutput.append("/" + line);
-
-                        // 执行第四次命令输出
-                        Channel channel4 = session.openChannel("exec");
-                        ((ChannelExec) channel4).setCommand("ls " + commandOutput.toString()); // 在远程服务器上执行第四次`ls`命令
-                        InputStream in4 = channel4.getInputStream();
-                        channel4.connect();
-
-                        BufferedReader reader4 = new BufferedReader(new InputStreamReader(in4));
-                        while ((line = reader4.readLine()) != null) {
-                            System.out.println(line); // 输出第四次`ls -l`的结果
-                            commandOutput.append("/" + line);
-                            // 执行第五次命令输出
-                            Channel channel5 = session.openChannel("exec");
-                            ((ChannelExec) channel5).setCommand("ls -l " + commandOutput.toString()); // 在远程服务器上执行第五次`ls`命令
-                            InputStream in5 = channel5.getInputStream();
-                            channel5.connect();
-
-                            BufferedReader reader5 = new BufferedReader(new InputStreamReader(in5));
-                            while ((line = reader5.readLine()) != null) {
-                                System.out.println(line);// 输出第五次`ls -l`的结果
-                                Pattern pattern = Pattern.compile("\\S+$"); // 匹配最后一个非空白字符之后的内容，即文件名
-                                Matcher matcher = pattern.matcher(line);
-                                if (matcher.find()) {
-                                    long date = getDate(line, matcher.group());
-                                    System.out.println(matcher.group());
-                                    if ((int) date <= -7) {
-                                        //执行删除
-                                        System.out.println("执行删除：" + date);
-                                        Channel channel6 = session.openChannel("exec");
-                                        System.out.println("参数" + commandOutput + "/" + matcher.group());
-                                        ((ChannelExec) channel6).setCommand("rm -rf " + commandOutput + "/" + matcher.group());
-                                        InputStream in6 = channel6.getInputStream();
-                                        channel6.connect();
-                                    }
-                                }
-                            }
-                            channel5.disconnect();
-                            commandOutput.setLength(commandOutput.length() - 1);
-                        }
-                        channel4.disconnect();
-                        commandOutput.setLength(commandOutput.length() - 1);
-                    }
-                    channel3.disconnect();
-                    commandOutput.setLength(commandOutput.length() - 1);
+            // 删除指定目录下的所有文件和文件夹
+            deleteObjectsAndEmptyDirectoriesRecursively(minioClient, bucketName, prefix, deleteTime);
+        } catch (Exception e) {
+            System.out.println("Error occurred: " + e);
+        }
+    }
 
-                }
-                channel2.disconnect();
-                commandOutput.setLength(commandOutput.length() - 1);
+    private static void deleteObjectsAndEmptyDirectoriesRecursively(MinioClient minioClient, String bucketName, String prefix, ZonedDateTime deleteTime) throws Exception {
+        log.info("deleteObjectsAndEmptyDirectoriesRecursively-----------进入方法");
+        Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(prefix).recursive(true).build());
+        log.info("deleteObjectsAndEmptyDirectoriesRecursively-----------获取数据完毕");
+        for (Result<Item> result : results) {
+            log.info("deleteObjectsAndEmptyDirectoriesRecursively-----------进入循环");
+            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());
             }
-            channel.disconnect();
-            session.disconnect();
-        } catch (JSchException | java.io.IOException e) {
-            System.out.println(e);
         }
     }
 
-    public static long getDate(String text, String two) {
-
-        // 使用空格分割字符串
-        String[] parts = text.split(" ");
 
-        for (int i = 0; i < parts.length - 2; i++) {
-            // 检查当前部分和下一个部分是否符合Linux系统时间的格式
-            if (parts[i].matches("[A-Z][a-z]{2}")) {
-                String linuxTime = parts[i] + " " + two;
-                System.out.println("Linux系统时间: " + linuxTime);
-                // 指定一个默认的年份
-                String year = String.valueOf(LocalDate.now().getYear());
-
-                try {
-                    // 解析日期字符串并转换为LocalDate对象
-                    LocalDate date = parseDate(linuxTime, year);
-                    System.out.println("Converted date: " + date);
-                    // 当前时间
-                    // 计算日期之间的天数差异
-                    LocalDate currentDate = LocalDate.now();
-                    long daysDiff = ChronoUnit.DAYS.between(currentDate, date);
-                    System.out.println("Days difference with current date: " + daysDiff);
-                    return daysDiff;
-                } catch (DateTimeParseException e) {
-                    System.out.println("Error parsing date: " + e.getMessage());
-                }
-                break;
+    public void test() {
+        try {
+            // Initialize Minio client
+            MinioClient minioClient = MinioClient.builder()
+                    .endpoint(endpoint)
+                    .credentials(accessKey, secretKey)
+                    .build();
+
+            // Bucket name
+            String bucketName = this.bucketName;
+            String prefix = "camera_picture/normal/";
+            // List all objects in the bucket
+            Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(prefix).recursive(true).build());
+            log.info("-------获取minio所有图片--------"+results);
+            for (Result<Item> result : results) {
+                Item item = result.get();
+                log.info("----item.lastModified()----"+item.lastModified());
+                log.info(item.objectName());
             }
+        } catch (Exception e) {
+            log.error("Error occurred: " + e);
         }
-        return 0;
     }
 
-    private static LocalDate parseDate(String dateStr, String defaultYear) {
-        // 创建一个月份缩写到数字的映射
-        Map<String, String> monthMap = new HashMap<>();
-        monthMap.put("Jan", "01");
-        monthMap.put("Feb", "02");
-        monthMap.put("Mar", "03");
-        monthMap.put("Apr", "04");
-        monthMap.put("May", "05");
-        monthMap.put("Jun", "06");
-        monthMap.put("Jul", "07");
-        monthMap.put("Aug", "08");
-        monthMap.put("Sep", "09");
-        monthMap.put("Oct", "10");
-        monthMap.put("Nov", "11");
-        monthMap.put("Dec", "12");
-
-        // 将月份缩写替换为数字
-        String[] dateParts = dateStr.split(" ");
-        String month = monthMap.get(dateParts[0]);
-        String day = dateParts[1];
-        int num = Integer.parseInt(day);
-        if (num >= 1 && num <= 9) {
-            day = "0" + day;
-        }
-        String fullDateStr = month + " " + day + " " + defaultYear;
-
-        // 使用DateTimeFormatter解析日期
-        return LocalDate.parse(fullDateStr, DateTimeFormatter.ofPattern("MM dd yyyy"));
-    }
+//    public void removePrice() {
+//        String host = "10.161.12.52"; // 远程主机
+//        String user = "root"; // SSH用户名
+//        String password = "iTi*21116"; // SSH密码
+//
+//        try {
+//            JSch jsch = new JSch();
+//            Session session = jsch.getSession(user, host, 22); // 默认SSH端口号是22
+//            session.setConfig("StrictHostKeyChecking", "no"); // 不进行主机密钥检查
+//            session.setPassword(password);
+//            session.connect();
+//
+//            String remoteDir = "/data/minio/data/picbucket/camera_picture/normal/"; // 要查看的远程目录
+//
+//            Channel channel = session.openChannel("exec");
+//            ((ChannelExec) channel).setCommand("ls " + remoteDir); // 在远程服务器上执行第一次`ls`命令
+//            InputStream in = channel.getInputStream();
+//            channel.connect();
+//            BufferedReader reader = new BufferedReader(new InputStreamReader(in));
+//            String line;
+//            //第一次命令输出
+//            while ((line = reader.readLine()) != null) {
+//                StringBuilder commandOutput = new StringBuilder(); // 存储命令输出
+//                commandOutput.append(remoteDir);
+//                System.out.println(line);
+//                commandOutput.append(line);
+//
+//                // 执行第二次命令输出
+//                Channel channel2 = session.openChannel("exec");
+//                ((ChannelExec) channel2).setCommand("ls " + commandOutput.toString()); // 在远程服务器上执行第二次`ls`命令
+//                InputStream in2 = channel2.getInputStream();
+//                channel2.connect();
+//
+//                BufferedReader reader2 = new BufferedReader(new InputStreamReader(in2));
+//                while ((line = reader2.readLine()) != null) {
+//                    System.out.println(line); // 输出第二次`ls -l`的结果
+//                    commandOutput.append("/" + line);
+//
+//                    // 执行第三次命令输出
+//                    Channel channel3 = session.openChannel("exec");
+//                    ((ChannelExec) channel3).setCommand("ls " + commandOutput.toString()); // 在远程服务器上执行第三次`ls`命令
+//                    InputStream in3 = channel3.getInputStream();
+//                    channel3.connect();
+//
+//                    BufferedReader reader3 = new BufferedReader(new InputStreamReader(in3));
+//                    while ((line = reader3.readLine()) != null) {
+//                        System.out.println(line); // 输出第三次`ls -l`的结果
+//                        commandOutput.append("/" + line);
+//
+//                        // 执行第四次命令输出
+//                        Channel channel4 = session.openChannel("exec");
+//                        ((ChannelExec) channel4).setCommand("ls " + commandOutput.toString()); // 在远程服务器上执行第四次`ls`命令
+//                        InputStream in4 = channel4.getInputStream();
+//                        channel4.connect();
+//
+//                        BufferedReader reader4 = new BufferedReader(new InputStreamReader(in4));
+//                        while ((line = reader4.readLine()) != null) {
+//                            System.out.println(line); // 输出第四次`ls -l`的结果
+//                            commandOutput.append("/" + line);
+//                            // 执行第五次命令输出
+//                            Channel channel5 = session.openChannel("exec");
+//                            ((ChannelExec) channel5).setCommand("ls -l " + commandOutput.toString()); // 在远程服务器上执行第五次`ls`命令
+//                            InputStream in5 = channel5.getInputStream();
+//                            channel5.connect();
+//
+//                            BufferedReader reader5 = new BufferedReader(new InputStreamReader(in5));
+//                            while ((line = reader5.readLine()) != null) {
+//                                System.out.println(line);// 输出第五次`ls -l`的结果
+//                                Pattern pattern = Pattern.compile("\\S+$"); // 匹配最后一个非空白字符之后的内容，即文件名
+//                                Matcher matcher = pattern.matcher(line);
+//                                if (matcher.find()) {
+//                                    long date = getDate(line, matcher.group());
+//                                    System.out.println(matcher.group());
+//                                    if ((int) date <= -7) {
+//                                        //执行删除
+//                                        System.out.println("执行删除：" + date);
+//                                        Channel channel6 = session.openChannel("exec");
+//                                        System.out.println("参数" + commandOutput + "/" + matcher.group());
+//                                        ((ChannelExec) channel6).setCommand("rm -rf " + commandOutput + "/" + matcher.group());
+//                                        InputStream in6 = channel6.getInputStream();
+//                                        channel6.connect();
+//                                    }
+//                                }
+//                            }
+//                            channel5.disconnect();
+//                            commandOutput.setLength(commandOutput.length() - 1);
+//                        }
+//                        channel4.disconnect();
+//                        commandOutput.setLength(commandOutput.length() - 1);
+//                    }
+//                    channel3.disconnect();
+//                    commandOutput.setLength(commandOutput.length() - 1);
+//
+//                }
+//                channel2.disconnect();
+//                commandOutput.setLength(commandOutput.length() - 1);
+//            }
+//            channel.disconnect();
+//            session.disconnect();
+//        } catch (JSchException | java.io.IOException e) {
+//            System.out.println(e);
+//        }
+//    }
+//
+//    public static long getDate(String text, String two) {
+//
+//        // 使用空格分割字符串
+//        String[] parts = text.split(" ");
+//
+//        for (int i = 0; i < parts.length - 2; i++) {
+//            // 检查当前部分和下一个部分是否符合Linux系统时间的格式
+//            if (parts[i].matches("[A-Z][a-z]{2}")) {
+//                String linuxTime = parts[i] + " " + two;
+//                System.out.println("Linux系统时间: " + linuxTime);
+//                // 指定一个默认的年份
+//                String year = String.valueOf(LocalDate.now().getYear());
+//
+//                try {
+//                    // 解析日期字符串并转换为LocalDate对象
+//                    LocalDate date = parseDate(linuxTime, year);
+//                    System.out.println("Converted date: " + date);
+//                    // 当前时间
+//                    // 计算日期之间的天数差异
+//                    LocalDate currentDate = LocalDate.now();
+//                    long daysDiff = ChronoUnit.DAYS.between(currentDate, date);
+//                    System.out.println("Days difference with current date: " + daysDiff);
+//                    return daysDiff;
+//                } catch (DateTimeParseException e) {
+//                    System.out.println("Error parsing date: " + e.getMessage());
+//                }
+//                break;
+//            }
+//        }
+//        return 0;
+//    }
+//
+//    private static LocalDate parseDate(String dateStr, String defaultYear) {
+//        // 创建一个月份缩写到数字的映射
+//        Map<String, String> monthMap = new HashMap<>();
+//        monthMap.put("Jan", "01");
+//        monthMap.put("Feb", "02");
+//        monthMap.put("Mar", "03");
+//        monthMap.put("Apr", "04");
+//        monthMap.put("May", "05");
+//        monthMap.put("Jun", "06");
+//        monthMap.put("Jul", "07");
+//        monthMap.put("Aug", "08");
+//        monthMap.put("Sep", "09");
+//        monthMap.put("Oct", "10");
+//        monthMap.put("Nov", "11");
+//        monthMap.put("Dec", "12");
+//
+//        // 将月份缩写替换为数字
+//        String[] dateParts = dateStr.split(" ");
+//        String month = monthMap.get(dateParts[0]);
+//        String day = dateParts[1];
+//        int num = Integer.parseInt(day);
+//        if (num >= 1 && num <= 9) {
+//            day = "0" + day;
+//        }
+//        String fullDateStr = month + " " + day + " " + defaultYear;
+//
+//        // 使用DateTimeFormatter解析日期
+//        return LocalDate.parse(fullDateStr, DateTimeFormatter.ofPattern("MM dd yyyy"));
+//    }
 }