Method record_token_success

app/utils/token_pool.py:340–361

标记成功并实时同步数据库统计。

(self, token: str, dao=None)

                    logger.warning(f"🚫 Token 已禁用: {token[:20]}... (失败 {status.failure_count} 次)")

    async def record_token_success(self, token: str, dao=None):
        """标记成功并实时同步数据库统计。"""
        self.mark_token_success(token)

        token_id = self.get_token_id(token)
        if token_id is None:
            return

        if dao is None:
            from app.services.token_dao import get_token_dao

            dao = get_token_dao()

        try:
            await dao.record_success(token_id)
        except Exception as e:
            logger.error(f"❌ 同步 Token 成功统计失败: {e}")
            return

        with self._lock:
            if token in self.token_statuses:
                self.token_statuses[token].db_synced_successful_requests += 1

    async def record_token_failure(self, token: str, error: Exception = None, dao=None):
        """标记失败并实时同步数据库统计。"""