11

app/api/v1/agent_card_keys.py

@@ -0,0 +1,109 @@
+"""管理员卡密 CRUD。"""
+
+from typing import Literal
+
+from fastapi import APIRouter, Query
+
+from app.dependencies import AdminUser, DbSession
+from app.schemas.admin_card_key import (
+    CardKeyBatchCreateResult,
+    CardKeyCreate,
+    CardKeyOut,
+    CardKeyUpdate,
+)
+from app.schemas.common import ApiResponse, PaginatedData
+from app.services import admin_card_key as card_key_service
+
+router = APIRouter(prefix="/agent/card-keys", tags=["管理-卡密"])
+
+
+@router.get("", response_model=ApiResponse[PaginatedData[CardKeyOut]])
+async def list_card_keys(
+    _admin: AdminUser,
+    db: DbSession,
+    page: int = Query(1, ge=1),
+    page_size: int = Query(
+        card_key_service.DEFAULT_PAGE_SIZE,
+        ge=1,
+        le=card_key_service.MAX_PAGE_SIZE,
+    ),
+    status: Literal["all", "unused", "used"] | None = Query(
+        default="all",
+        description="筛选：all 全部 / unused 未使用 / used 已激活",
+    ),
+    username: str | None = Query(default=None, description="按激活用户名模糊筛选"),
+    oem_id: int | None = Query(default=None, description="按预分配 OEM 筛选"),
+    agent_id: int | None = Query(default=None, description="按预分配代理筛选"),
+) -> ApiResponse[PaginatedData[CardKeyOut]]:
+    filter_status = None if status == "all" else status
+    cards, total = await card_key_service.list_card_keys(
+        db,
+        page=page,
+        page_size=page_size,
+        status=filter_status,
+        username=username,
+        oem_id=oem_id,
+        agent_id=agent_id,
+    )
+    return ApiResponse(
+        ok=True,
+        message="",
+        data=PaginatedData.build(
+            [CardKeyOut.model_validate(c) for c in cards],
+            total=total,
+            page=page,
+            page_size=page_size,
+        ),
+    )
+
+
+@router.post("", response_model=ApiResponse[CardKeyBatchCreateResult])
+async def create_card_keys(
+    body: CardKeyCreate,
+    _admin: AdminUser,
+    db: DbSession,
+) -> ApiResponse[CardKeyBatchCreateResult]:
+    try:
+        created = await card_key_service.create_card_keys(db, body)
+    except card_key_service.AdminCardKeyError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    items = [CardKeyOut.model_validate(c) for c in created]
+    return ApiResponse(
+        ok=True,
+        message=f"已生成 {len(items)} 张卡密",
+        data=CardKeyBatchCreateResult(items=items, created_count=len(items)),
+    )
+
+
+@router.patch("/{card_id}", response_model=ApiResponse[CardKeyOut])
+async def update_card_key(
+    card_id: int,
+    body: CardKeyUpdate,
+    _admin: AdminUser,
+    db: DbSession,
+) -> ApiResponse[CardKeyOut]:
+    try:
+        card = await card_key_service.update_card_key(db, card_id, body)
+    except card_key_service.AdminCardKeyError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(
+        ok=True,
+        message="卡密已更新",
+        data=CardKeyOut.model_validate(card),
+    )
+
+
+@router.delete("/{card_id}", response_model=ApiResponse[None])
+async def delete_card_key(
+    card_id: int,
+    _admin: AdminUser,
+    db: DbSession,
+) -> ApiResponse[None]:
+    try:
+        await card_key_service.delete_card_key(db, card_id)
+    except card_key_service.AdminCardKeyError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(ok=True, message="卡密已删除")

app/api/v1/agent_users.py

@@ -0,0 +1,103 @@
+"""管理员用户 CRUD。"""
+
+from fastapi import APIRouter, Query
+
+from app.dependencies import OemUser, DbSession
+from app.schemas.admin_user import AdminUserCreate, AdminUserOut, AdminUserUpdate
+from app.schemas.common import ApiResponse, PaginatedData
+from app.services import admin_user as oem_user_service
+
+router = APIRouter(prefix="/agent/users", tags=["管理-用户"])
+
+
+@router.get("", response_model=ApiResponse[PaginatedData[AdminUserOut]])
+async def list_users(
+    _oem: OemUser,
+    db: DbSession,
+    page: int = Query(1, ge=1, description="页码，从 1 开始"),
+    page_size: int = Query(
+        oem_user_service.DEFAULT_PAGE_SIZE,
+        ge=1,
+        le=oem_user_service.MAX_PAGE_SIZE,
+        description="每页条数",
+    ),
+    username: str | None = Query(None, description="用户名模糊搜索"),
+    agent_id: int | None = Query(None, description="按所属代理用户 ID 筛选"),
+    role_id: int | None = Query(None, ge=0, le=3, description="按角色筛选"),
+) -> ApiResponse[PaginatedData[AdminUserOut]]:
+    oem_id=_oem.id
+    users, total = await oem_user_service.list_users(
+        db,
+        page=page,
+        page_size=page_size,
+        username=username,
+        oem_id=oem_id,
+        agent_id=agent_id,
+        role_id=role_id,
+    )
+    return ApiResponse(
+        ok=True,
+        message="",
+        data=PaginatedData.build(
+            [AdminUserOut.model_validate(u) for u in users],
+            total=total,
+            page=page,
+            page_size=page_size,
+        ),
+    )
+
+
+@router.post("", response_model=ApiResponse[AdminUserOut])
+async def create_user(
+    body: AdminUserCreate,
+    oem: OemUser,
+    db: DbSession,
+) -> ApiResponse[AdminUserOut]:
+    try:
+        user = await oem_user_service.create_user(db, body,oem)
+    except oem_user_service.AdminUserError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(
+        ok=True,
+        message="用户已创建",
+        data=AdminUserOut.model_validate(user),
+    )
+
+
+@router.patch("/{user_id}", response_model=ApiResponse[AdminUserOut])
+async def update_user(
+    user_id: int,
+    body: AdminUserUpdate,
+    oem: OemUser,
+    db: DbSession,
+) -> ApiResponse[AdminUserOut]:
+    try:
+        user = await oem_user_service.update_user(
+            db,
+            user_id,
+            body,
+            actor_id=oem.id,
+        )
+    except oem_user_service.AdminUserError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(
+        ok=True,
+        message="用户已更新",
+        data=AdminUserOut.model_validate(user),
+    )
+
+
+@router.delete("/{user_id}", response_model=ApiResponse[None])
+async def delete_user(
+    user_id: int,
+    oem: OemUser,
+    db: DbSession,
+) -> ApiResponse[None]:
+    try:
+        await oem_user_service.delete_user(db, user_id, actor_id=admin.id)
+    except oem_user_service.AdminUserError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(ok=True, message="用户已删除")

app/api/v1/oem_card_keys.py

@@ -0,0 +1,109 @@
+"""管理员卡密 CRUD。"""
+
+from typing import Literal
+
+from fastapi import APIRouter, Query
+
+from app.dependencies import OemUser, DbSession
+from app.schemas.admin_card_key import (
+    CardKeyBatchCreateResult,
+    CardKeyCreate,
+    CardKeyOut,
+    CardKeyUpdate,
+)
+from app.schemas.common import ApiResponse, PaginatedData
+from app.services import admin_card_key as card_key_service
+
+router = APIRouter(prefix="/oem/card-keys", tags=["管理-卡密"])
+
+
+@router.get("", response_model=ApiResponse[PaginatedData[CardKeyOut]])
+async def list_card_keys(
+    _admin: OemUser,
+    db: DbSession,
+    page: int = Query(1, ge=1),
+    page_size: int = Query(
+        card_key_service.DEFAULT_PAGE_SIZE,
+        ge=1,
+        le=card_key_service.MAX_PAGE_SIZE,
+    ),
+    status: Literal["all", "unused", "used"] | None = Query(
+        default="all",
+        description="筛选：all 全部 / unused 未使用 / used 已激活",
+    ),
+    username: str | None = Query(default=None, description="按激活用户名模糊筛选"),
+    oem_id: int | None = Query(default=None, description="按预分配 OEM 筛选"),
+    agent_id: int | None = Query(default=None, description="按预分配代理筛选"),
+) -> ApiResponse[PaginatedData[CardKeyOut]]:
+    filter_status = None if status == "all" else status
+    cards, total = await card_key_service.list_card_keys(
+        db,
+        page=page,
+        page_size=page_size,
+        status=filter_status,
+        username=username,
+        oem_id=oem_id,
+        agent_id=agent_id,
+    )
+    return ApiResponse(
+        ok=True,
+        message="",
+        data=PaginatedData.build(
+            [CardKeyOut.model_validate(c) for c in cards],
+            total=total,
+            page=page,
+            page_size=page_size,
+        ),
+    )
+
+
+@router.post("", response_model=ApiResponse[CardKeyBatchCreateResult])
+async def create_card_keys(
+    body: CardKeyCreate,
+    _admin: OemUser,
+    db: DbSession,
+) -> ApiResponse[CardKeyBatchCreateResult]:
+    try:
+        created = await card_key_service.create_card_keys(db, body)
+    except card_key_service.AdminCardKeyError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    items = [CardKeyOut.model_validate(c) for c in created]
+    return ApiResponse(
+        ok=True,
+        message=f"已生成 {len(items)} 张卡密",
+        data=CardKeyBatchCreateResult(items=items, created_count=len(items)),
+    )
+
+
+@router.patch("/{card_id}", response_model=ApiResponse[CardKeyOut])
+async def update_card_key(
+    card_id: int,
+    body: CardKeyUpdate,
+    _admin: OemUser,
+    db: DbSession,
+) -> ApiResponse[CardKeyOut]:
+    try:
+        card = await card_key_service.update_card_key(db, card_id, body)
+    except card_key_service.AdminCardKeyError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(
+        ok=True,
+        message="卡密已更新",
+        data=CardKeyOut.model_validate(card),
+    )
+
+
+@router.delete("/{card_id}", response_model=ApiResponse[None])
+async def delete_card_key(
+    card_id: int,
+    _admin: OemUser,
+    db: DbSession,
+) -> ApiResponse[None]:
+    try:
+        await card_key_service.delete_card_key(db, card_id)
+    except card_key_service.AdminCardKeyError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(ok=True, message="卡密已删除")

app/api/v1/oem_desktop_configs.py

@@ -0,0 +1,95 @@
+"""管理员 desktop_configs 键值 CRUD。"""
+
+from fastapi import APIRouter, Query
+
+from app.dependencies import OemUser, DbSession
+from app.schemas.admin_desktop_config import (
+    DesktopConfigCreate,
+    DesktopConfigOut,
+    DesktopConfigUpdate,
+)
+from app.schemas.common import ApiResponse, PaginatedData
+from app.services import admin_desktop_config as config_service
+
+router = APIRouter(prefix="/oem/desktop-configs", tags=["管理-桌面配置"])
+
+
+@router.get("", response_model=ApiResponse[PaginatedData[DesktopConfigOut]])
+async def list_configs(
+    _admin: OemUser,
+    db: DbSession,
+    page: int = Query(1, ge=1),
+    page_size: int = Query(
+        config_service.DEFAULT_PAGE_SIZE,
+        ge=1,
+        le=config_service.MAX_PAGE_SIZE,
+    ),
+    keyword: str | None = Query(default=None, max_length=64, description="按键名模糊搜索"),
+) -> ApiResponse[PaginatedData[DesktopConfigOut]]:
+    rows, total = await config_service.list_configs(
+        db,
+        page=page,
+        page_size=page_size,
+        keyword=keyword,
+    )
+    return ApiResponse(
+        ok=True,
+        message="",
+        data=PaginatedData.build(
+            [DesktopConfigOut.model_validate(r) for r in rows],
+            total=total,
+            page=page,
+            page_size=page_size,
+        ),
+    )
+
+
+@router.post("", response_model=ApiResponse[DesktopConfigOut])
+async def create_config(
+    body: DesktopConfigCreate,
+    _admin: OemUser,
+    db: DbSession,
+) -> ApiResponse[DesktopConfigOut]:
+    try:
+        row = await config_service.create_config(db, body)
+    except config_service.AdminDesktopConfigError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(
+        ok=True,
+        message="配置已创建",
+        data=DesktopConfigOut.model_validate(row),
+    )
+
+
+@router.patch("/{config_id}", response_model=ApiResponse[DesktopConfigOut])
+async def update_config(
+    config_id: int,
+    body: DesktopConfigUpdate,
+    _admin: OemUser,
+    db: DbSession,
+) -> ApiResponse[DesktopConfigOut]:
+    try:
+        row = await config_service.update_config(db, config_id, body)
+    except config_service.AdminDesktopConfigError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(
+        ok=True,
+        message="配置已更新",
+        data=DesktopConfigOut.model_validate(row),
+    )
+
+
+@router.delete("/{config_id}", response_model=ApiResponse[None])
+async def delete_config(
+    config_id: int,
+    _admin: OemUser,
+    db: DbSession,
+) -> ApiResponse[None]:
+    try:
+        await config_service.delete_config(db, config_id)
+    except config_service.AdminDesktopConfigError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(ok=True, message="配置已删除")

app/api/v1/oem_oem_branding.py

@@ -0,0 +1,49 @@
+"""管理员：默认 OEM（id=1）软件品牌配置。"""
+
+from fastapi import APIRouter
+
+from app.dependencies import OemUser, DbSession
+from app.schemas.admin_oem_branding import OemBrandingOut, OemBrandingUpdate
+from app.schemas.common import ApiResponse
+from app.services import admin_oem_branding as branding_service
+
+router = APIRouter(prefix="/oem/oem-branding", tags=["管理-OEM品牌"])
+
+
+@router.get("", response_model=ApiResponse[OemBrandingOut])
+async def get_oem_branding(
+    admin: OemUser,
+    db: DbSession,
+) -> ApiResponse[OemBrandingOut]:
+    try:
+        oem = await branding_service.get_default_oem_branding(
+            db, owner_user_id=admin.id
+        )
+    except branding_service.AdminOemBrandingError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(
+        ok=True,
+        message="",
+        data=OemBrandingOut.model_validate(oem),
+    )
+
+
+@router.patch("", response_model=ApiResponse[OemBrandingOut])
+async def update_oem_branding(
+    body: OemBrandingUpdate,
+    admin: OemUser,
+    db: DbSession,
+) -> ApiResponse[OemBrandingOut]:
+    try:
+        oem = await branding_service.update_default_oem_branding(
+            db, body, owner_user_id=admin.id
+        )
+    except branding_service.AdminOemBrandingError as exc:
+        return ApiResponse(ok=False, message=exc.message)
+
+    return ApiResponse(
+        ok=True,
+        message="软件配置已保存",
+        data=OemBrandingOut.model_validate(oem),
+    )

app/api/v1/router.py

@@ -2,9 +2,14 @@ from fastapi import APIRouter
 
 from app.api.v1 import (
     admin_card_keys,
+    oem_card_keys,
+    agent_card_keys,
     admin_desktop_configs,
+    oem_desktop_configs,
     admin_oem_branding,
+    oem_oem_branding,
     admin_users,
+    agent_users,
     app_config,
     oem_public,
     oem_users,
@@ -18,9 +23,14 @@ api_router.include_router(oem_users.router)
 api_router.include_router(oem_public.router)
 api_router.include_router(auth.router)
 api_router.include_router(admin_users.router)
+api_router.include_router(agent_users.router)
 api_router.include_router(admin_card_keys.router)
+api_router.include_router(oem_card_keys.router)
+api_router.include_router(agent_card_keys.router)
 api_router.include_router(admin_desktop_configs.router)
+api_router.include_router(oem_desktop_configs.router)
 api_router.include_router(admin_oem_branding.router)
+api_router.include_router(oem_oem_branding.router)
 api_router.include_router(app_config.router)
 api_router.include_router(quickjs_scripts.router)
 api_router.include_router(nodejs_scripts.router)