| | |
|---|
| | | package com.ruoyi.quartz.task; |
|---|
| | | |
|---|
| | | import com.ruoyi.storage.minio.utils.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; |
|---|
| | |
|---|
| | | @Component("MinioTask") |
|---|
| | | @Slf4j(topic = "minio") |
|---|
| | | public class MinioTask { |
|---|
| | | @Resource |
|---|
| | | MinioUtils minioUtil; |
|---|
| | | |
|---|
| | | public void delHistoryTask(Integer saveDays) { |
|---|
| | | log.debug("执行历史数据删除"); |
|---|
| | |
|---|
| | | buckets.add("pic"); |
|---|
| | | buckets.add("record"); |
|---|
| | | for (String name : buckets) { |
|---|
| | | Iterable<Result<Item>> listObjectsPic = minioUtil.getObjectsByBucket(name); |
|---|
| | | 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")); |
|---|
| | |
|---|
| | | log.debug("objectTime : " + objectTime); |
|---|
| | | log.debug("expireTime : " + expireTime); |
|---|
| | | log.debug("objectTime 时间在 expireTime 之前,执行删除"); |
|---|
| | | boolean b = minioUtil.removeObject(name, item.objectName()); |
|---|
| | | boolean b = MinioUtil.removeObject(name, item.objectName()); |
|---|
| | | if (b) { |
|---|
| | | log.debug("成功删除过期数据：" + item.objectName() + "---" + item.lastModified()); |
|---|
| | | } |
|---|
