sqxp/backend/app/tasks/order_auto_confirm_receive.py

"""送达后超时未确认收货，系统自动确认。"""
import logging
from datetime import datetime, timedelta

from sqlalchemy.orm import Session

from app.crud.order import order_crud

logger = logging.getLogger(__name__)


def run_auto_confirm_receive_overdue(db: Session) -> int:
    from app.api.system_config import get_auto_confirm_receive_days_for_job

    days = get_auto_confirm_receive_days_for_job(db)
    before = datetime.now() - timedelta(days=days)
    count = order_crud.auto_confirm_receive_overdue(
        db,
        before_threshold=before,
        configured_days=days,
    )
    return count


def run_auto_confirm_receive_job(db: Session):
    count = run_auto_confirm_receive_overdue(db)
    if count:
        logger.info(f"自动确认收货完成: {count} 条")