24 lines
711 B
Python
24 lines
711 B
Python
"""运输计划 - 证件到期提醒定时扫描"""
|
|
import logging
|
|
|
|
from app.core.database import SessionLocal
|
|
from app.services.pl_cert_service import scan_cert_expiry
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
def scan_pl_cert_expiry_job():
|
|
"""每日扫描 pl_cert，生成证件到期提醒。"""
|
|
db = SessionLocal()
|
|
try:
|
|
logger.info("======== 开始执行证件到期扫描任务 ========")
|
|
created_count = scan_cert_expiry(db)
|
|
db.commit()
|
|
logger.info("证件到期扫描完成，新建提醒 %d 条", created_count)
|
|
except Exception:
|
|
db.rollback()
|
|
logger.exception("证件到期扫描任务失败")
|
|
raise
|
|
finally:
|
|
db.close()
|