Class SchedulerService

app/services/scheduler_service.py:22–566

Run account payment flows at configured local times.

class SchedulerService:
    """Run account payment flows at configured local times."""

    def __init__(self) -> None:
        self.state_service = get_account_state_service()
        self.payment_service = get_payment_service()
        self.runtime_logs = get_runtime_log_service()
        self._stop_event = threading.Event()
        self._thread: threading.Thread | None = None
        self._running_accounts: set[str] = set()
        self._pause_requested: set[str] = set()
        self._lock = threading.Lock()

    def start(self) -> None:
        if self._thread and self._thread.is_alive():
            return
        self._stop_event.clear()
        self._thread = threading.Thread(target=self._run_loop, name="glm-desk-scheduler", daemon=True)
        self._thread.start()
        threading.Thread(target=self.check_cached_accounts_once, name="glm-desk-account-check", daemon=True).start()
        self.runtime_logs.log_system_event(
            stage="scheduler",
            status="started",
            message="调度器已启动",
        )

    def stop(self) -> None:
        self._stop_event.set()
        if self._thread and self._thread.is_alive():
            self._thread.join(timeout=2)
        self.runtime_logs.log_system_event(
            stage="scheduler",
            status="stopped",
            message="调度器已停止",
        )

    def _run_loop(self) -> None:
        while not self._stop_event.is_set():
            try:
                self.poll_once()
            except Exception as exc:  # pragma: no cover - defensive scheduler guard
                logger.exception("scheduler poll failed: %s", exc)
                self.runtime_logs.log_system_event(
                    stage="scheduler_poll",
                    status="failed",
                    message=f"调度器轮询失败：{exc}",
                    details={"error": exc.__class__.__name__},
                    level=logging.ERROR,
                )
            self._stop_event.wait(1)

    def poll_once(self) -> None:
        now = datetime.now(SCHEDULER_TZ) if SCHEDULER_TZ is not None else datetime.now().astimezone()
        current_hms = now.strftime("%H:%M:%S")
        current_date = now.strftime("%Y-%m-%d")
        for public_account in self.state_service.list_accounts():
            if not public_account.schedule_enabled or not public_account.scheduled_start_time:
                continue