BiliNote/backend/events/handlers.py

import os
from app.utils.logger import get_logger
logger = get_logger(__name__)

def cleanup_temp_files(data):
    logger.info(f"starting cleanup temp files ：{data['file_path']}")
    file_path = data['file_path']
    if not os.path.exists(file_path):
        logger.warning(f"路径不存在：{file_path}")
        return

    dir_path = os.path.dirname(file_path)
    base_name = os.path.basename(file_path)
    video_id, _ = os.path.splitext(base_name)

    logger.info(f"开始清理 video_id={video_id} 所有相关文件")

    for file in os.listdir(dir_path):
        if file.startswith(video_id):
            full_path = os.path.join(dir_path, file)
            try:
                os.remove(full_path)
                logger.info(f"删除文件：{full_path}")
            except Exception as e:
                logger.error(f"删除失败：{full_path}，原因：{e}")