package com.ruoyi.quartz.task;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import com.ruoyi.system.service.IVehicleGpsService;

/**
 * 清理车辆GPS历史数据任务
 */
@Component("cleanVehicleGpsTask")
public class CleanVehicleGpsTask {
    private static final Logger log = LoggerFactory.getLogger(CleanVehicleGpsTask.class);

    /** 每批删除数量 */
    private static final int BATCH_SIZE = 10000;
    /** 每批间隔时间（毫秒），避免连续删除对数据库压力过大 */
    private static final long BATCH_INTERVAL_MS = 500;

    @Autowired
    private IVehicleGpsService vehicleGpsService;

    /**
     * 清理车辆GPS历史数据（保留最近2个月，分批删除）
     */
    public void cleanVehicleGpsData() {
        try {
            log.info("开始清理车辆GPS历史数据（保留最近2个月，每批 {} 条）", BATCH_SIZE);
            int totalCount = 0;
            int batchCount;
            int round = 0;
            do {
                batchCount = vehicleGpsService.deleteVehicleGpsBeforeDateBatch(BATCH_SIZE);
                totalCount += batchCount;
                round++;
                log.info("第 {} 批清理完成，本批删除 {} 条，已删除合计 {} 条", round, batchCount, totalCount);
                if (batchCount == BATCH_SIZE) {
                    // 还有数据，稍作休眠再继续
                    Thread.sleep(BATCH_INTERVAL_MS);
                }
            } while (batchCount == BATCH_SIZE);

            log.info("清理车辆GPS历史数据完成，共 {} 批，删除 {} 条记录", round, totalCount);

            if (totalCount > 0) {
                log.info("开始执行 OPTIMIZE TABLE，回收磁盘空间（此操作耗时较长，请勿中断）");
                vehicleGpsService.optimizeVehicleGpsTable();
                log.info("OPTIMIZE TABLE 执行完成");
            } else {
                log.info("本次无可清理的记录，跳过 OPTIMIZE TABLE");
            }
        } catch (Exception e) {
            log.error("清理车辆GPS历史数据异常", e);
        }
    }
}