‘liusuyi’
2023-08-25 63a661a78e1999423ea7d94277a645ed4b9e7e6d
ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/MinioTask.java
@@ -1,11 +1,11 @@
package com.ruoyi.quartz.task;
import com.ruoyi.device.hiksdk.util.minio.MinioUtils;
import com.ruoyi.utils.minio.MinioUtil;
import io.minio.Result;
import io.minio.messages.Item;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
@@ -26,17 +26,17 @@
        log.debug("执行历史数据删除");
        //遍历存储
        try {
            List<String> buckets=new ArrayList<>();
            List<String> buckets = new ArrayList<>();
            buckets.add("pic");
            buckets.add("record");
            for (String name:buckets) {
                Iterable<Result<Item>> listObjectsPic = MinioUtils.getObjectsByBucket(name);
            for (String name : buckets) {
                Iterable<Result<Item>> listObjectsPic = MinioUtil.getObjectsByBucket(name);
                for (Result<Item> result : listObjectsPic) {
                    Item item = result.get();
                    DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").withZone(ZoneId.of("Asia/Shanghai"));
                    String objectTime = item.lastModified().format(formatter);
                    Date now= new Date();
                    Date now = new Date();
                    // 把日期往前增加一天,整数往后推,负数往前移动
                    Calendar calendar = new GregorianCalendar();
                    calendar.setTime(now);
@@ -48,10 +48,9 @@
                        log.debug("objectTime : " + objectTime);
                        log.debug("expireTime : " + expireTime);
                        log.debug("objectTime 时间在 expireTime 之前,执行删除");
                        boolean b = MinioUtils.removeObject(name, item.objectName());
                        if(b)
                        {
                            log.debug("成功删除过期数据:"+ item.objectName()+"---"+item.lastModified());
                        boolean b = MinioUtil.removeObject(name, item.objectName());
                        if (b) {
                            log.debug("成功删除过期数据:" + item.objectName() + "---" + item.lastModified());
                        }
                    }
                }
@@ -60,5 +59,4 @@
            log.error("minio历史数据删除异常:" + ex.getMessage());
        }
    }
}