linkeyu
fda82fe313
## 变更 - 权限目录新增一级分组“监控审计”，统一设备存活、埋点成功率、埋点日志和审计日志。 - 补齐 `analytics-health` 页面权限，技术角色默认拥有四项监控审计权限；运营默认仅保留设备存活。 - 新增服务端 `require_page` 守卫，四组 API 不再只依赖前端隐藏导航，直接调用也会校验角色或个人页面权限。 - 增加迁移，为存量技术角色补上 `analytics-health` 权限，并同步接口文档。 ## 验证 - 改动文件 `ruff check` 通过。 - `tests/test_admin_roles.py tests/test_analytics_health.py`: 24 passed。 - Alembic 从空库 upgrade 到 head，再 downgrade 本迁移：通过。 - 全量测试：443 passed、6 failed；6 项失败在干净 `origin/main` 上原样复现（主干为 442 passed、6 failed），与本 PR 无关。 --------- Co-authored-by: unknown <798648091@qq.com> Reviewed-on: #159 Co-authored-by: linkeyu <linkeyu@wonderable.ai> Co-committed-by: linkeyu <linkeyu@wonderable.ai>
64 lines
2.3 KiB
Python
64 lines
2.3 KiB
Python
"""admin 设备存活监控(只读):列设备心跳/在线掉线 + 顶部统计卡片。
|
|
|
|
数据源 device_liveness 表(心跳 last_heartbeat_at + liveness_state + kill_alert_pending,
|
|
见 app/models/device.py)。在线/掉线、掉线时长由 repo 按 HEARTBEAT_TIMEOUT_MINUTES 阈值派生。
|
|
纯读:无写、无审计。需要 device-liveness 页面权限。
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
from typing import Annotated
|
|
|
|
from fastapi import APIRouter, Depends, Query
|
|
|
|
from app.admin.deps import AdminDb, require_page
|
|
from app.admin.repositories import queries
|
|
from app.admin.schemas.common import CursorPage
|
|
from app.admin.schemas.device import DeviceLivenessItem, DeviceLivenessStats
|
|
|
|
router = APIRouter(
|
|
prefix="/admin/api/device-liveness",
|
|
tags=["admin-device-liveness"],
|
|
dependencies=[Depends(require_page("device-liveness"))],
|
|
)
|
|
|
|
|
|
@router.get("/stats", response_model=DeviceLivenessStats, summary="设备存活统计(顶部卡片)")
|
|
def device_stats(db: AdminDb) -> DeviceLivenessStats:
|
|
return DeviceLivenessStats(**queries.device_liveness_stats(db))
|
|
|
|
|
|
@router.get(
|
|
"",
|
|
response_model=CursorPage[DeviceLivenessItem],
|
|
summary="设备存活列表(在线情况/设备id/归属用户 筛选 + 排序 + 分页,默认掉线置顶)",
|
|
)
|
|
def list_devices(
|
|
db: AdminDb,
|
|
status: Annotated[str | None, Query(pattern="^(online|offline|never)$")] = None,
|
|
device_id: Annotated[str | None, Query(max_length=128)] = None,
|
|
phone: Annotated[str | None, Query(max_length=20)] = None,
|
|
user_id: Annotated[int | None, Query()] = None,
|
|
sort_by: Annotated[
|
|
str, Query(pattern="^(status|last_heartbeat_at|created_at)$")
|
|
] = "status",
|
|
sort_order: Annotated[str, Query(pattern="^(asc|desc)$")] = "desc",
|
|
limit: Annotated[int, Query(ge=1, le=100)] = 20,
|
|
cursor: Annotated[int | None, Query()] = None,
|
|
) -> CursorPage[DeviceLivenessItem]:
|
|
items, next_cursor, total = queries.list_device_liveness(
|
|
db,
|
|
status=status,
|
|
device_id=device_id,
|
|
phone=phone,
|
|
user_id=user_id,
|
|
sort_by=sort_by,
|
|
sort_order=sort_order,
|
|
limit=limit,
|
|
cursor=cursor,
|
|
)
|
|
return CursorPage(
|
|
items=[DeviceLivenessItem.model_validate(d) for d in items],
|
|
next_cursor=next_cursor,
|
|
total=total,
|
|
)
|