package com.ruoyi.quartz.task;

import com.ruoyi.alarm.global.domain.GuidePriorityQueue;
import com.ruoyi.alarm.global.domain.GuideTask;
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 java.text.SimpleDateFormat;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.concurrent.PriorityBlockingQueue;

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

    public void delHistoryTask(Integer saveDays) {
        log.debug("执行历史数据删除");
        //遍历存储
        try {
            List<String> buckets = new ArrayList<>();
            buckets.add("pic");
            buckets.add("record");
            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();
                    // 把日期往前增加一天,整数往后推,负数往前移动
                    Calendar calendar = new GregorianCalendar();
                    calendar.setTime(now);
                    calendar.add(Calendar.DATE, saveDays);
                    SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                    String expireTime = fmt.format(calendar.getTime());

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

    /**
     * 定时清空引导队列
     * 刘苏义
     * 2023/7/1 10:41
     */
    public void clearGuideQueue() {
        try {
            log.info("定时清理引导队列");
            for (PriorityBlockingQueue<GuideTask> guideQueue : GuidePriorityQueue.cameraQueueMap.values()) {
                guideQueue.clear();
            }
        } catch (Exception ex) {
            log.error("定时清空引导队列:" + ex.getMessage());
        }
    }
}