Merge remote-tracking branch 'origin/master'

aijinhui

2023-10-08 3c08ca7661566c94012040647428fee759820b39

 ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CleanTask.java

ÎļþÃû´Ó ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/MinioTask.java ÐÞ¸Ä
@@ -1,15 +1,18 @@
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 javax.annotation.Resource;

import java.text.SimpleDateFormat;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.concurrent.PriorityBlockingQueue;

/**
 * @ClassName: MinioDeleteTask
@@ -19,8 +22,8 @@
 * @Version: 1.0
 **/
@Component("MinioTask")
@Slf4j(topic = "minio")
public class MinioTask {
@Slf4j
public class CleanTask {

    public void delHistoryTask(Integer saveDays) {
        log.debug("执行历史数据删除");
@@ -59,4 +62,20 @@
            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());
        }
    }
}