"""证据模块异步任务"""

from __future__ import annotations

import logging
from typing import Any

logger = logging.getLogger("apps.evidence")


def merge_evidence_pdf_task(list_id: int) -> Any:
    from apps.evidence.services.evidence_merge_usecase import EvidenceMergeUseCase

    logger.info("merge_evidence_pdf_task_start", extra={"list_id": list_id})
    result = EvidenceMergeUseCase().merge(list_id=list_id)
    logger.info("merge_evidence_pdf_task_done", extra={"list_id": list_id, "status": result.get("status")})
    return result


def ocr_evidence_item_task(item_id: int) -> None:
    """异步 OCR 提取证据文件文本"""
    from apps.evidence.services.evidence_ocr_service import EvidenceOCRService

    logger.info("ocr_evidence_item_start", extra={"item_id": item_id})
    EvidenceOCRService().extract_and_save(item_id)
    logger.info("ocr_evidence_item_done", extra={"item_id": item_id})