rogee/quyun-v2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add superadmin health center

Browse Source
This commit is contained in:
Rogee
2026-01-17 09:18:05 +08:00
parent 94a10a3af0
commit 4f2b8ea3ad
14 changed files with 870 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

75
backend/app/http/super/v1/dto/super_health.go Normal file
View File

@@ -0,0 +1,75 @@
package dto
// SuperHealthOverviewFilter 超管健康概览查询条件。
type SuperHealthOverviewFilter struct {
// TenantID 租户ID（不传代表全平台）。
TenantID *int64 `query:"tenant_id"`
// StartAt 统计开始时间（RFC3339，可选；默认当前时间往前 7 天）。
StartAt *string `query:"start_at"`
// EndAt 统计结束时间（RFC3339，可选；默认当前时间）。
EndAt *string `query:"end_at"`
// UploadStuckHours 上传处理超时时长（小时，可选；默认 24 小时）。
UploadStuckHours *int64 `query:"upload_stuck_hours"`
}
// SuperHealthOverviewResponse 超管健康概览响应。
type SuperHealthOverviewResponse struct {
// TenantID 当前统计的租户ID（0 代表全平台）。
TenantID int64 `json:"tenant_id"`
// StartAt 统计开始时间（RFC3339）。
StartAt string `json:"start_at"`
// EndAt 统计结束时间（RFC3339）。
EndAt string `json:"end_at"`
// UploadStuckHours 上传处理超时时长（小时）。
UploadStuckHours int64 `json:"upload_stuck_hours"`
// TenantTotal 租户总数。
TenantTotal int64 `json:"tenant_total"`
// TenantWarningCount 健康预警租户数。
TenantWarningCount int64 `json:"tenant_warning_count"`
// TenantRiskCount 健康风险租户数。
TenantRiskCount int64 `json:"tenant_risk_count"`
// OrderTotal 订单总数（统计区间内）。
OrderTotal int64 `json:"order_total"`
// OrderFailed 失败订单数（统计区间内）。
OrderFailed int64 `json:"order_failed"`
// OrderFailedRate 失败率（失败订单数 / 总订单数）。
OrderFailedRate float64 `json:"order_failed_rate"`
// UploadTotal 上传资产总数（统计区间内）。
UploadTotal int64 `json:"upload_total"`
// UploadFailed 上传失败资产数（统计区间内）。
UploadFailed int64 `json:"upload_failed"`
// UploadFailedRate 上传失败率（失败资产数 / 总资产数）。
UploadFailedRate float64 `json:"upload_failed_rate"`
// UploadProcessingStuck 处理超时资产数（processing 且超时）。
UploadProcessingStuck int64 `json:"upload_processing_stuck"`
// UploadUploadedStuck 已上传但未进入处理的超时资产数（uploaded 且超时）。
UploadUploadedStuck int64 `json:"upload_uploaded_stuck"`
// StorageTotalCount 资产总量（全量）。
StorageTotalCount int64 `json:"storage_total_count"`
// StorageTotalSize 资产总大小（字节，全量）。
StorageTotalSize int64 `json:"storage_total_size"`
// Alerts 健康告警列表。
Alerts []SuperHealthAlertItem `json:"alerts"`
}
// SuperHealthAlertItem 健康告警条目。
type SuperHealthAlertItem struct {
// Level 告警级别（warning/risk）。
Level string `json:"level"`
// Kind 告警类型（order_error_rate/upload_error_rate/upload_stuck/tenant_health）。
Kind string `json:"kind"`
// TenantID 关联租户ID（无则为 0）。
TenantID int64 `json:"tenant_id"`
// TenantCode 关联租户编码。
TenantCode string `json:"tenant_code"`
// TenantName 关联租户名称。
TenantName string `json:"tenant_name"`
// Title 告警标题。
Title string `json:"title"`
// Detail 告警详情说明。
Detail string `json:"detail"`
// Count 关联数量（例如失败数、超时数）。
Count int64 `json:"count"`
// UpdatedAt 告警更新时间（RFC3339）。
UpdatedAt string `json:"updated_at"`
}

29
backend/app/http/super/v1/healths.go Normal file
View File

@@ -0,0 +1,29 @@
package v1
import (
dto "quyun/v2/app/http/super/v1/dto"
"quyun/v2/app/services"
"github.com/gofiber/fiber/v3"
)
// @provider
type healths struct{}
// Health overview
//
// @Router /super/v1/health/overview [get]
// @Summary Health overview
// @Description Platform health overview
// @Tags Health
// @Accept json
// @Produce json
// @Param tenant_id query int false "Tenant ID"
// @Param start_at query string false "Start time"
// @Param end_at query string false "End time"
// @Param upload_stuck_hours query int false "Upload stuck hours"
// @Success 200 {object} dto.SuperHealthOverviewResponse
// @Bind filter query
func (c *healths) Overview(ctx fiber.Ctx, filter *dto.SuperHealthOverviewFilter) (*dto.SuperHealthOverviewResponse, error) {
return services.Super.HealthOverview(ctx, filter)
}

9
backend/app/http/super/v1/provider.gen.go
View File

@@ -73,6 +73,13 @@ func Provide(opts ...opt.Option) error {
}); err != nil {
return err
}
if err := container.Container.Provide(func() (*healths, error) {
obj := &healths{}
return obj, nil
}); err != nil {
return err
}
if err := container.Container.Provide(func() (*notifications, error) {
obj := &notifications{}
@@ -111,6 +118,7 @@ func Provide(opts ...opt.Option) error {
creatorApplications *creatorApplications,
creators *creators,
finance *finance,
healths *healths,
middlewares *middlewares.Middlewares,
notifications *notifications,
orders *orders,
@@ -131,6 +139,7 @@ func Provide(opts ...opt.Option) error {
creatorApplications: creatorApplications,
creators: creators,
finance: finance,
healths: healths,
middlewares: middlewares,
notifications: notifications,
orders: orders,

7
backend/app/http/super/v1/routes.gen.go
View File

@@ -34,6 +34,7 @@ type Routes struct {
creatorApplications *creatorApplications
creators *creators
finance *finance
healths *healths
notifications *notifications
orders *orders
payoutAccounts *payoutAccounts
@@ -243,6 +244,12 @@ func (r *Routes) Register(router fiber.Router) {
r.finance.ListLedgers,
Query[dto.SuperLedgerListFilter]("filter"),
))
// Register routes for controller: healths
r.log.Debugf("Registering route: Get /super/v1/health/overview -> healths.Overview")
router.Get("/super/v1/health/overview"[len(r.Path()):], DataFunc1(
r.healths.Overview,
Query[dto.SuperHealthOverviewFilter]("filter"),
))
// Register routes for controller: notifications
r.log.Debugf("Registering route: Get /super/v1/notifications -> notifications.List")
router.Get("/super/v1/notifications"[len(r.Path()):], DataFunc1(

170
backend/docs/docs.go
View File

@@ -1153,6 +1153,55 @@ const docTemplate = `{
}
}
},
"/super/v1/health/overview": {
"get": {
"description": "Platform health overview",
"consumes": [
"application/json"
],
"produces": [
"application/json"
],
"tags": [
"Health"
],
"summary": "Health overview",
"parameters": [
{
"type": "integer",
"description": "Tenant ID",
"name": "tenant_id",
"in": "query"
},
{
"type": "string",
"description": "Start time",
"name": "start_at",
"in": "query"
},
{
"type": "string",
"description": "End time",
"name": "end_at",
"in": "query"
},
{
"type": "integer",
"description": "Upload stuck hours",
"name": "upload_stuck_hours",
"in": "query"
}
],
"responses": {
"200": {
"description": "OK",
"schema": {
"$ref": "#/definitions/dto.SuperHealthOverviewResponse"
}
}
}
}
},
"/super/v1/notifications": {
"get": {
"description": "List notifications across tenants",
@@ -8669,6 +8718,127 @@ const docTemplate = `{
}
}
},
"dto.SuperHealthAlertItem": {
"type": "object",
"properties": {
"count": {
"description": "Count 关联数量（例如失败数、超时数）。",
"type": "integer"
},
"detail": {
"description": "Detail 告警详情说明。",
"type": "string"
},
"kind": {
"description": "Kind 告警类型（order_error_rate/upload_error_rate/upload_stuck/tenant_health）。",
"type": "string"
},
"level": {
"description": "Level 告警级别（warning/risk）。",
"type": "string"
},
"tenant_code": {
"description": "TenantCode 关联租户编码。",
"type": "string"
},
"tenant_id": {
"description": "TenantID 关联租户ID（无则为 0）。",
"type": "integer"
},
"tenant_name": {
"description": "TenantName 关联租户名称。",
"type": "string"
},
"title": {
"description": "Title 告警标题。",
"type": "string"
},
"updated_at": {
"description": "UpdatedAt 告警更新时间（RFC3339）。",
"type": "string"
}
}
},
"dto.SuperHealthOverviewResponse": {
"type": "object",
"properties": {
"alerts": {
"description": "Alerts 健康告警列表。",
"type": "array",
"items": {
"$ref": "#/definitions/dto.SuperHealthAlertItem"
}
},
"end_at": {
"description": "EndAt 统计结束时间（RFC3339）。",
"type": "string"
},
"order_failed": {
"description": "OrderFailed 失败订单数（统计区间内）。",
"type": "integer"
},
"order_failed_rate": {
"description": "OrderFailedRate 失败率（失败订单数 / 总订单数）。",
"type": "number"
},
"order_total": {
"description": "OrderTotal 订单总数（统计区间内）。",
"type": "integer"
},
"start_at": {
"description": "StartAt 统计开始时间（RFC3339）。",
"type": "string"
},
"storage_total_count": {
"description": "StorageTotalCount 资产总量（全量）。",
"type": "integer"
},
"storage_total_size": {
"description": "StorageTotalSize 资产总大小（字节，全量）。",
"type": "integer"
},
"tenant_id": {
"description": "TenantID 当前统计的租户ID（0 代表全平台）。",
"type": "integer"
},
"tenant_risk_count": {
"description": "TenantRiskCount 健康风险租户数。",
"type": "integer"
},
"tenant_total": {
"description": "TenantTotal 租户总数。",
"type": "integer"
},
"tenant_warning_count": {
"description": "TenantWarningCount 健康预警租户数。",
"type": "integer"
},
"upload_failed": {
"description": "UploadFailed 上传失败资产数（统计区间内）。",
"type": "integer"
},
"upload_failed_rate": {
"description": "UploadFailedRate 上传失败率（失败资产数 / 总资产数）。",
"type": "number"
},
"upload_processing_stuck": {
"description": "UploadProcessingStuck 处理超时资产数（processing 且超时）。",
"type": "integer"
},
"upload_stuck_hours": {
"description": "UploadStuckHours 上传处理超时时长（小时）。",
"type": "integer"
},
"upload_total": {
"description": "UploadTotal 上传资产总数（统计区间内）。",
"type": "integer"
},
"upload_uploaded_stuck": {
"description": "UploadUploadedStuck 已上传但未进入处理的超时资产数（uploaded 且超时）。",
"type": "integer"
}
}
},
"dto.SuperLedgerItem": {
"type": "object",
"properties": {

170
backend/docs/swagger.json
View File

@@ -1147,6 +1147,55 @@
}
}
},
"/super/v1/health/overview": {
"get": {
"description": "Platform health overview",
"consumes": [
"application/json"
],
"produces": [
"application/json"
],
"tags": [
"Health"
],
"summary": "Health overview",
"parameters": [
{
"type": "integer",
"description": "Tenant ID",
"name": "tenant_id",
"in": "query"
},
{
"type": "string",
"description": "Start time",
"name": "start_at",
"in": "query"
},
{
"type": "string",
"description": "End time",
"name": "end_at",
"in": "query"
},
{
"type": "integer",
"description": "Upload stuck hours",
"name": "upload_stuck_hours",
"in": "query"
}
],
"responses": {
"200": {
"description": "OK",
"schema": {
"$ref": "#/definitions/dto.SuperHealthOverviewResponse"
}
}
}
}
},
"/super/v1/notifications": {
"get": {
"description": "List notifications across tenants",
@@ -8663,6 +8712,127 @@
}
}
},
"dto.SuperHealthAlertItem": {
"type": "object",
"properties": {
"count": {
"description": "Count 关联数量（例如失败数、超时数）。",
"type": "integer"
},
"detail": {
"description": "Detail 告警详情说明。",
"type": "string"
},
"kind": {
"description": "Kind 告警类型（order_error_rate/upload_error_rate/upload_stuck/tenant_health）。",
"type": "string"
},
"level": {
"description": "Level 告警级别（warning/risk）。",
"type": "string"
},
"tenant_code": {
"description": "TenantCode 关联租户编码。",
"type": "string"
},
"tenant_id": {
"description": "TenantID 关联租户ID（无则为 0）。",
"type": "integer"
},
"tenant_name": {
"description": "TenantName 关联租户名称。",
"type": "string"
},
"title": {
"description": "Title 告警标题。",
"type": "string"
},
"updated_at": {
"description": "UpdatedAt 告警更新时间（RFC3339）。",
"type": "string"
}
}
},
"dto.SuperHealthOverviewResponse": {
"type": "object",
"properties": {
"alerts": {
"description": "Alerts 健康告警列表。",
"type": "array",
"items": {
"$ref": "#/definitions/dto.SuperHealthAlertItem"
}
},
"end_at": {
"description": "EndAt 统计结束时间（RFC3339）。",
"type": "string"
},
"order_failed": {
"description": "OrderFailed 失败订单数（统计区间内）。",
"type": "integer"
},
"order_failed_rate": {
"description": "OrderFailedRate 失败率（失败订单数 / 总订单数）。",
"type": "number"
},
"order_total": {
"description": "OrderTotal 订单总数（统计区间内）。",
"type": "integer"
},
"start_at": {
"description": "StartAt 统计开始时间（RFC3339）。",
"type": "string"
},
"storage_total_count": {
"description": "StorageTotalCount 资产总量（全量）。",
"type": "integer"
},
"storage_total_size": {
"description": "StorageTotalSize 资产总大小（字节，全量）。",
"type": "integer"
},
"tenant_id": {
"description": "TenantID 当前统计的租户ID（0 代表全平台）。",
"type": "integer"
},
"tenant_risk_count": {
"description": "TenantRiskCount 健康风险租户数。",
"type": "integer"
},
"tenant_total": {
"description": "TenantTotal 租户总数。",
"type": "integer"
},
"tenant_warning_count": {
"description": "TenantWarningCount 健康预警租户数。",
"type": "integer"
},
"upload_failed": {
"description": "UploadFailed 上传失败资产数（统计区间内）。",
"type": "integer"
},
"upload_failed_rate": {
"description": "UploadFailedRate 上传失败率（失败资产数 / 总资产数）。",
"type": "number"
},
"upload_processing_stuck": {
"description": "UploadProcessingStuck 处理超时资产数（processing 且超时）。",
"type": "integer"
},
"upload_stuck_hours": {
"description": "UploadStuckHours 上传处理超时时长（小时）。",
"type": "integer"
},
"upload_total": {
"description": "UploadTotal 上传资产总数（统计区间内）。",
"type": "integer"
},
"upload_uploaded_stuck": {
"description": "UploadUploadedStuck 已上传但未进入处理的超时资产数（uploaded 且超时）。",
"type": "integer"
}
}
},
"dto.SuperLedgerItem": {
"type": "object",
"properties": {

121
backend/docs/swagger.yaml
View File

@@ -1762,6 +1762,95 @@ definitions:
required:
- action
type: object
dto.SuperHealthAlertItem:
properties:
count:
description: Count 关联数量（例如失败数、超时数）。
type: integer
detail:
description: Detail 告警详情说明。
type: string
kind:
description: Kind 告警类型（order_error_rate/upload_error_rate/upload_stuck/tenant_health）。
type: string
level:
description: Level 告警级别（warning/risk）。
type: string
tenant_code:
description: TenantCode 关联租户编码。
type: string
tenant_id:
description: TenantID 关联租户ID（无则为 0）。
type: integer
tenant_name:
description: TenantName 关联租户名称。
type: string
title:
description: Title 告警标题。
type: string
updated_at:
description: UpdatedAt 告警更新时间（RFC3339）。
type: string
type: object
dto.SuperHealthOverviewResponse:
properties:
alerts:
description: Alerts 健康告警列表。
items:
$ref: '#/definitions/dto.SuperHealthAlertItem'
type: array
end_at:
description: EndAt 统计结束时间（RFC3339）。
type: string
order_failed:
description: OrderFailed 失败订单数（统计区间内）。
type: integer
order_failed_rate:
description: OrderFailedRate 失败率（失败订单数 / 总订单数）。
type: number
order_total:
description: OrderTotal 订单总数（统计区间内）。
type: integer
start_at:
description: StartAt 统计开始时间（RFC3339）。
type: string
storage_total_count:
description: StorageTotalCount 资产总量（全量）。
type: integer
storage_total_size:
description: StorageTotalSize 资产总大小（字节，全量）。
type: integer
tenant_id:
description: TenantID 当前统计的租户ID（0 代表全平台）。
type: integer
tenant_risk_count:
description: TenantRiskCount 健康风险租户数。
type: integer
tenant_total:
description: TenantTotal 租户总数。
type: integer
tenant_warning_count:
description: TenantWarningCount 健康预警租户数。
type: integer
upload_failed:
description: UploadFailed 上传失败资产数（统计区间内）。
type: integer
upload_failed_rate:
description: UploadFailedRate 上传失败率（失败资产数 / 总资产数）。
type: number
upload_processing_stuck:
description: UploadProcessingStuck 处理超时资产数（processing 且超时）。
type: integer
upload_stuck_hours:
description: UploadStuckHours 上传处理超时时长（小时）。
type: integer
upload_total:
description: UploadTotal 上传资产总数（统计区间内）。
type: integer
upload_uploaded_stuck:
description: UploadUploadedStuck 已上传但未进入处理的超时资产数（uploaded 且超时）。
type: integer
type: object
dto.SuperLedgerItem:
properties:
amount:
@@ -4064,6 +4153,38 @@ paths:
summary: List ledgers
tags:
- Finance
/super/v1/health/overview:
get:
consumes:
- application/json
description: Platform health overview
parameters:
- description: Tenant ID
in: query
name: tenant_id
type: integer
- description: Start time
in: query
name: start_at
type: string
- description: End time
in: query
name: end_at
type: string
- description: Upload stuck hours
in: query
name: upload_stuck_hours
type: integer
produces:
- application/json
responses:
"200":
description: OK
schema:
$ref: '#/definitions/dto.SuperHealthOverviewResponse'
summary: Health overview
tags:
- Health
/super/v1/notifications:
get:
consumes: