wechat_notices.py 655 B

12345678910111213141516171819
  1. """服务号审批 outbox 定时发送。"""
  2. import logging
  3. from app.core.config import settings
  4. from app.core.database import SessionLocal
  5. logger = logging.getLogger(__name__)
  6. def deliver_wechat_notices():
  7. if not settings.WECHAT_OA_ENABLED:
  8. return
  9. from app.services.wechat_approval_notices import deliver_pending
  10. with SessionLocal() as db:
  11. try:
  12. deliver_pending(db)
  13. except Exception:
  14. db.rollback()
  15. # 不输出异常原文,防止网络请求参数和绑定信息进入日志。
  16. logger.error("服务号通知任务失败,请检查队列、配置及数据库状态")