package com.ruoyi.quartz.task;

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 java.text.SimpleDateFormat;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.*;

/**
 * @ClassName: MinioDeleteTask
 * @Description:
 * @Author: Administrator
 * @Date: 2023年01月14日 8:15
 * @Version: 1.0
 **/
@Component("MinioTask")
@Slf4j(topic = "minio")
public class MinioTask {

    public void delHistoryTask(Integer saveDays) {
        log.info("执行历史数据删除");
        //遍历存储
        try {
            List<String> buckets=new ArrayList<>();
            buckets.add("pic");
            buckets.add("record");
            for (String name:buckets) {
                Iterable<Result<Item>> listObjectsPic = MinioUtils.getObjectsByBucket(name);
                for (Result<Item> result : listObjectsPic) {
                    Item item = result.get();
                    log.info(item.objectName() + "创建时间：" + item.lastModified());
                    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();
                    // 把日期往前增加一天,整数往后推,负数往前移动
                    Calendar calendar = new GregorianCalendar();
                    calendar.setTime(now);
                    calendar.add(Calendar.DATE, saveDays);
                    SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                    String nowTime = fmt.format(calendar.getTime());

                    log.info("objectTime : " + objectTime);
                    log.info("nowTime : " + nowTime);

                    if (objectTime.compareTo(nowTime) < 0) {
                        log.info("objectTime 时间在 nowTime 之前");
                        boolean b = MinioUtils.removeObject(name, item.objectName());
                        if(b)
                        {
                            log.info("删除过期数据："+ item.objectName()+"---"+item.lastModified());
                        }
                    }
                }
            }
        } catch (Exception ex) {
            log.error("minio历史数据删除异常：" + ex.getMessage());
        }
    }

}