Function sync_token_pool

app/admin/api.py:1069–1111

手动同步 Token 池（从数据库重新加载）

()

@router.post("/tokens/sync-pool")
async def sync_token_pool():
    """手动同步 Token 池（从数据库重新加载）"""
    from app.utils.token_pool import get_token_pool

    pool = get_token_pool()

    if not pool:
        return HTMLResponse("""
        <div class="bg-yellow-100 border border-yellow-400 text-yellow-700 px-4 py-3 rounded relative" role="alert">
            <strong class="font-bold">提示！</strong>
            <span class="block sm:inline">Token 池未初始化，请重启服务。</span>
        </div>
        """)

    # 从数据库同步
    await pool.sync_from_database(DEFAULT_TOKEN_NAMESPACE)

    # 获取同步后的状态
    status = pool.get_pool_status()
    total_count = status.get("total_tokens", 0)
    available_count = status.get("available_tokens", 0)
    user_count = status.get("user_tokens", 0)

    logger.info(
        f"✅ Token 池手动同步完成，总计 {total_count} 个 Token, 可用 {available_count} 个, 认证用户 {user_count} 个"
    )

    if total_count == 0:
        message_class = "bg-yellow-100 border-yellow-400 text-yellow-700"
        message = "同步完成：当前没有可用 Token，请在数据库中启用 Token。"
    elif available_count == 0:
        message_class = "bg-orange-100 border-orange-400 text-orange-700"
        message = f"同步完成：共 {total_count} 个 Token，但无可用 Token（可能都已禁用）。"
    else:
        message_class = "bg-green-100 border-green-400 text-green-700"
        message = f"同步完成：共 {total_count} 个 Token，{available_count} 个可用，{user_count} 个认证用户。"

    return HTMLResponse(f"""
    <div class="{message_class} border px-4 py-3 rounded relative" role="alert">
        <strong class="font-bold">Token 池同步完成！</strong>
        <span class="block sm:inline">{message}</span>
    </div>
    """)