| | |
| | | package com.ruoyi.quartz.task; |
| | | |
| | | import com.ruoyi.device.hiksdk.util.minioUtil.MinioUtil; |
| | | import com.ruoyi.device.hiksdk.util.minio.MinioUtils; |
| | | 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; |
| | |
| | | @Component("MinioTask") |
| | | @Slf4j(topic = "minio") |
| | | public class MinioTask { |
| | | @Resource |
| | | MinioUtil minioUtil; |
| | | |
| | | public void delHistoryTask(Integer saveDays) { |
| | | log.info("执行历史数据删除"); |
| | |
| | | buckets.add("pic"); |
| | | buckets.add("record"); |
| | | for (String name:buckets) { |
| | | Iterable<Result<Item>> listObjectsPic = minioUtil.getObjectsByBucket(name); |
| | | Iterable<Result<Item>> listObjectsPic = MinioUtils.getObjectsByBucket(name); |
| | | for (Result<Item> result : listObjectsPic) { |
| | | Item item = result.get(); |
| | | log.info(item.objectName() + "创建时间:" + item.lastModified()); |
| | |
| | | |
| | | if (objectTime.compareTo(nowTime) < 0) { |
| | | log.info("objectTime 时间在 nowTime 之前"); |
| | | boolean b = minioUtil.deleteObject(name, item.objectName()); |
| | | boolean b = MinioUtils.removeObject(name, item.objectName()); |
| | | if(b) |
| | | { |
| | | log.info("删除过期数据:"+ item.objectName()+"---"+item.lastModified()); |