feat: wire superadmin p1 data

2026-01-15 09:35:16 +08:00
parent bb4c5b39d2
commit 235a216b0c
21 changed files with 3188 additions and 28 deletions
--- a/backend/app/services/super.go
+++ b/backend/app/services/super.go
@@ -3,6 +3,7 @@ package services
 import (
 	"context"
 	"errors"
+	"strconv"
 	"strings"
 	"time"

@@ -2201,16 +2202,134 @@ func (s *super) evaluateTenantHealth(tenant *models.Tenant, metrics tenantHealth
 }

 func (s *super) ListWithdrawals(ctx context.Context, filter *super_dto.SuperOrderListFilter) (*requests.Pager, error) {
+	if filter == nil {
+		filter = &super_dto.SuperOrderListFilter{}
+	}
+
 	tbl, q := models.OrderQuery.QueryContext(ctx)
 	q = q.Where(tbl.Type.Eq(consts.OrderTypeWithdrawal))

+	if filter.ID != nil && *filter.ID > 0 {
+		q = q.Where(tbl.ID.Eq(*filter.ID))
+	}
+	if filter.TenantID != nil && *filter.TenantID > 0 {
+		q = q.Where(tbl.TenantID.Eq(*filter.TenantID))
+	}
+	if filter.UserID != nil && *filter.UserID > 0 {
+		q = q.Where(tbl.UserID.Eq(*filter.UserID))
+	}
+	if filter.Status != nil && *filter.Status != "" {
+		q = q.Where(tbl.Status.Eq(*filter.Status))
+	}
+	if filter.AmountPaidMin != nil {
+		q = q.Where(tbl.AmountPaid.Gte(*filter.AmountPaidMin))
+	}
+	if filter.AmountPaidMax != nil {
+		q = q.Where(tbl.AmountPaid.Lte(*filter.AmountPaidMax))
+	}
+
+	tenantIDs, tenantFilter, err := s.lookupTenantIDs(ctx, filter.TenantCode, filter.TenantName)
+	if err != nil {
+		return nil, err
+	}
+	if tenantFilter {
+		if len(tenantIDs) == 0 {
+			q = q.Where(tbl.ID.Eq(-1))
+		} else {
+			q = q.Where(tbl.TenantID.In(tenantIDs...))
+		}
+	}
+
+	userIDs, userFilter, err := s.lookupUserIDs(ctx, filter.Username)
+	if err != nil {
+		return nil, err
+	}
+	if userFilter {
+		if len(userIDs) == 0 {
+			q = q.Where(tbl.ID.Eq(-1))
+		} else {
+			q = q.Where(tbl.UserID.In(userIDs...))
+		}
+	}
+
+	if filter.CreatedAtFrom != nil {
+		from, err := s.parseFilterTime(filter.CreatedAtFrom)
+		if err != nil {
+			return nil, err
+		}
+		if from != nil {
+			q = q.Where(tbl.CreatedAt.Gte(*from))
+		}
+	}
+	if filter.CreatedAtTo != nil {
+		to, err := s.parseFilterTime(filter.CreatedAtTo)
+		if err != nil {
+			return nil, err
+		}
+		if to != nil {
+			q = q.Where(tbl.CreatedAt.Lte(*to))
+		}
+	}
+	if filter.PaidAtFrom != nil {
+		from, err := s.parseFilterTime(filter.PaidAtFrom)
+		if err != nil {
+			return nil, err
+		}
+		if from != nil {
+			q = q.Where(tbl.PaidAt.Gte(*from))
+		}
+	}
+	if filter.PaidAtTo != nil {
+		to, err := s.parseFilterTime(filter.PaidAtTo)
+		if err != nil {
+			return nil, err
+		}
+		if to != nil {
+			q = q.Where(tbl.PaidAt.Lte(*to))
+		}
+	}
+
+	orderApplied := false
+	if filter.Desc != nil && strings.TrimSpace(*filter.Desc) != "" {
+		switch strings.TrimSpace(*filter.Desc) {
+		case "id":
+			q = q.Order(tbl.ID.Desc())
+		case "created_at":
+			q = q.Order(tbl.CreatedAt.Desc())
+		case "paid_at":
+			q = q.Order(tbl.PaidAt.Desc())
+		case "amount_paid":
+			q = q.Order(tbl.AmountPaid.Desc())
+		case "status":
+			q = q.Order(tbl.Status.Desc())
+		}
+		orderApplied = true
+	} else if filter.Asc != nil && strings.TrimSpace(*filter.Asc) != "" {
+		switch strings.TrimSpace(*filter.Asc) {
+		case "id":
+			q = q.Order(tbl.ID)
+		case "created_at":
+			q = q.Order(tbl.CreatedAt)
+		case "paid_at":
+			q = q.Order(tbl.PaidAt)
+		case "amount_paid":
+			q = q.Order(tbl.AmountPaid)
+		case "status":
+			q = q.Order(tbl.Status)
+		}
+		orderApplied = true
+	}
+	if !orderApplied {
+		q = q.Order(tbl.ID.Desc())
+	}
+
 	filter.Pagination.Format()
 	total, err := q.Count()
 	if err != nil {
 		return nil, errorx.ErrDatabaseError.WithCause(err)
 	}

-	list, err := q.Offset(int(filter.Pagination.Offset())).Limit(int(filter.Pagination.Limit)).Order(tbl.ID.Desc()).Find()
+	list, err := q.Offset(int(filter.Pagination.Offset())).Limit(int(filter.Pagination.Limit)).Find()
 	if err != nil {
 		return nil, errorx.ErrDatabaseError.WithCause(err)
 	}
@@ -2226,6 +2345,436 @@ func (s *super) ListWithdrawals(ctx context.Context, filter *super_dto.SuperOrde
 	}, nil
 }

+func (s *super) ListCoupons(ctx context.Context, filter *super_dto.SuperCouponListFilter) (*requests.Pager, error) {
+	if filter == nil {
+		filter = &super_dto.SuperCouponListFilter{}
+	}
+
+	tbl, q := models.CouponQuery.QueryContext(ctx)
+	if filter.ID != nil && *filter.ID > 0 {
+		q = q.Where(tbl.ID.Eq(*filter.ID))
+	}
+	if filter.TenantID != nil && *filter.TenantID > 0 {
+		q = q.Where(tbl.TenantID.Eq(*filter.TenantID))
+	}
+
+	tenantIDs, tenantFilter, err := s.lookupTenantIDs(ctx, filter.TenantCode, filter.TenantName)
+	if err != nil {
+		return nil, err
+	}
+	if tenantFilter {
+		if len(tenantIDs) == 0 {
+			q = q.Where(tbl.ID.Eq(-1))
+		} else {
+			q = q.Where(tbl.TenantID.In(tenantIDs...))
+		}
+	}
+
+	if filter.Type != nil && strings.TrimSpace(*filter.Type) != "" {
+		parsed, err := consts.ParseCouponType(strings.TrimSpace(*filter.Type))
+		if err != nil {
+			return nil, errorx.ErrInvalidParameter.WithCause(err).WithMsg("优惠券类型无效")
+		}
+		q = q.Where(tbl.Type.Eq(parsed))
+	}
+	if filter.Keyword != nil && strings.TrimSpace(*filter.Keyword) != "" {
+		keyword := strings.TrimSpace(*filter.Keyword)
+		q = q.Where(field.Or(
+			tbl.Title.Like("%"+keyword+"%"),
+			tbl.Description.Like("%"+keyword+"%"),
+		))
+	}
+	if filter.Status != nil && strings.TrimSpace(*filter.Status) != "" {
+		status := strings.ToLower(strings.TrimSpace(*filter.Status))
+		now := time.Now()
+		switch status {
+		case "active":
+			q = q.Where(field.Or(tbl.StartAt.Lte(now), tbl.StartAt.IsNull()))
+			q = q.Where(field.Or(tbl.EndAt.Gte(now), tbl.EndAt.IsNull()))
+		case "expired":
+			q = q.Where(tbl.EndAt.IsNotNull(), tbl.EndAt.Lt(now))
+		case "upcoming":
+			q = q.Where(tbl.StartAt.IsNotNull(), tbl.StartAt.Gt(now))
+		default:
+			return nil, errorx.ErrInvalidParameter.WithMsg("状态参数无效")
+		}
+	}
+
+	if filter.CreatedAtFrom != nil {
+		from, err := s.parseFilterTime(filter.CreatedAtFrom)
+		if err != nil {
+			return nil, err
+		}
+		if from != nil {
+			q = q.Where(tbl.CreatedAt.Gte(*from))
+		}
+	}
+	if filter.CreatedAtTo != nil {
+		to, err := s.parseFilterTime(filter.CreatedAtTo)
+		if err != nil {
+			return nil, err
+		}
+		if to != nil {
+			q = q.Where(tbl.CreatedAt.Lte(*to))
+		}
+	}
+
+	orderApplied := false
+	if filter.Desc != nil && strings.TrimSpace(*filter.Desc) != "" {
+		switch strings.TrimSpace(*filter.Desc) {
+		case "id":
+			q = q.Order(tbl.ID.Desc())
+		case "created_at":
+			q = q.Order(tbl.CreatedAt.Desc())
+		case "start_at":
+			q = q.Order(tbl.StartAt.Desc())
+		case "end_at":
+			q = q.Order(tbl.EndAt.Desc())
+		}
+		orderApplied = true
+	} else if filter.Asc != nil && strings.TrimSpace(*filter.Asc) != "" {
+		switch strings.TrimSpace(*filter.Asc) {
+		case "id":
+			q = q.Order(tbl.ID)
+		case "created_at":
+			q = q.Order(tbl.CreatedAt)
+		case "start_at":
+			q = q.Order(tbl.StartAt)
+		case "end_at":
+			q = q.Order(tbl.EndAt)
+		}
+		orderApplied = true
+	}
+	if !orderApplied {
+		q = q.Order(tbl.CreatedAt.Desc())
+	}
+
+	filter.Pagination.Format()
+	total, err := q.Count()
+	if err != nil {
+		return nil, errorx.ErrDatabaseError.WithCause(err)
+	}
+
+	list, err := q.Offset(int(filter.Pagination.Offset())).Limit(int(filter.Pagination.Limit)).Find()
+	if err != nil {
+		return nil, errorx.ErrDatabaseError.WithCause(err)
+	}
+
+	items, err := s.buildSuperCouponItems(ctx, list)
+	if err != nil {
+		return nil, err
+	}
+	return &requests.Pager{
+		Pagination: filter.Pagination,
+		Total:      total,
+		Items:      items,
+	}, nil
+}
+
+func (s *super) ReportOverview(ctx context.Context, filter *super_dto.SuperReportOverviewFilter) (*v1_dto.ReportOverviewResponse, error) {
+	// 统一统计时间范围与粒度。
+	rg, err := s.normalizeReportRange(filter)
+	if err != nil {
+		return nil, err
+	}
+
+	tenantID := int64(0)
+	if filter != nil && filter.TenantID != nil {
+		tenantID = *filter.TenantID
+	}
+
+	// 统计累计曝光（全量累计值，暂无按时间拆分的曝光记录）。
+	var totalViews int64
+	contentQuery := models.ContentQuery.WithContext(ctx).
+		UnderlyingDB().
+		Model(&models.Content{}).
+		Select("coalesce(sum(views), 0)")
+	if tenantID > 0 {
+		contentQuery = contentQuery.Where("tenant_id = ?", tenantID)
+	}
+	if err := contentQuery.Scan(&totalViews).Error; err != nil {
+		return nil, errorx.ErrDatabaseError.WithCause(err)
+	}
+
+	// 订单仅统计内容购买类型，并按状态划分已支付/已退款。
+	paidCount, paidAmount, err := s.reportOrderAggregate(ctx, tenantID, consts.OrderStatusPaid, "paid_at", rg)
+	if err != nil {
+		return nil, err
+	}
+	refundCount, refundAmount, err := s.reportOrderAggregate(ctx, tenantID, consts.OrderStatusRefunded, "updated_at", rg)
+	if err != nil {
+		return nil, err
+	}
+
+	conversionRate := 0.0
+	if totalViews > 0 {
+		conversionRate = float64(paidCount) / float64(totalViews)
+	}
+
+	paidSeries, err := s.reportOrderSeries(ctx, tenantID, consts.OrderStatusPaid, "paid_at", rg)
+	if err != nil {
+		return nil, err
+	}
+	refundSeries, err := s.reportOrderSeries(ctx, tenantID, consts.OrderStatusRefunded, "updated_at", rg)
+	if err != nil {
+		return nil, err
+	}
+
+	items := make([]v1_dto.ReportOverviewItem, 0)
+	for day := rg.startDay; !day.After(rg.endDay); day = day.AddDate(0, 0, 1) {
+		key := day.Format("2006-01-02")
+		paidItem := paidSeries[key]
+		refundItem := refundSeries[key]
+		items = append(items, v1_dto.ReportOverviewItem{
+			Date:         key,
+			PaidOrders:   paidItem.Count,
+			PaidAmount:   float64(paidItem.Amount) / 100.0,
+			RefundOrders: refundItem.Count,
+			RefundAmount: float64(refundItem.Amount) / 100.0,
+		})
+	}
+
+	return &v1_dto.ReportOverviewResponse{
+		Summary: v1_dto.ReportSummary{
+			TotalViews:     totalViews,
+			PaidOrders:     paidCount,
+			PaidAmount:     float64(paidAmount) / 100.0,
+			RefundOrders:   refundCount,
+			RefundAmount:   float64(refundAmount) / 100.0,
+			ConversionRate: conversionRate,
+		},
+		Items: items,
+	}, nil
+}
+
+func (s *super) ExportReport(ctx context.Context, form *super_dto.SuperReportExportForm) (*v1_dto.ReportExportResponse, error) {
+	if form == nil {
+		return nil, errorx.ErrBadRequest.WithMsg("导出参数不能为空")
+	}
+	format := strings.ToLower(strings.TrimSpace(form.Format))
+	if format == "" {
+		format = "csv"
+	}
+	if format != "csv" {
+		return nil, errorx.ErrBadRequest.WithMsg("仅支持 CSV 导出")
+	}
+
+	overview, err := s.ReportOverview(ctx, &super_dto.SuperReportOverviewFilter{
+		TenantID:    form.TenantID,
+		StartAt:     form.StartAt,
+		EndAt:       form.EndAt,
+		Granularity: form.Granularity,
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	builder := &strings.Builder{}
+	builder.WriteString("date,paid_orders,paid_amount,refund_orders,refund_amount\n")
+	for _, item := range overview.Items {
+		builder.WriteString(item.Date)
+		builder.WriteString(",")
+		builder.WriteString(strconv.FormatInt(item.PaidOrders, 10))
+		builder.WriteString(",")
+		builder.WriteString(formatAmount(item.PaidAmount))
+		builder.WriteString(",")
+		builder.WriteString(strconv.FormatInt(item.RefundOrders, 10))
+		builder.WriteString(",")
+		builder.WriteString(formatAmount(item.RefundAmount))
+		builder.WriteString("\n")
+	}
+
+	filename := "report_overview_" + time.Now().Format("20060102_150405") + ".csv"
+	return &v1_dto.ReportExportResponse{
+		Filename: filename,
+		MimeType: "text/csv",
+		Content:  builder.String(),
+	}, nil
+}
+
+func (s *super) reportOrderAggregate(
+	ctx context.Context,
+	tenantID int64,
+	status consts.OrderStatus,
+	timeField string,
+	rg reportRange,
+) (int64, int64, error) {
+	var total struct {
+		Count  int64 `gorm:"column:count"`
+		Amount int64 `gorm:"column:amount"`
+	}
+
+	query := models.OrderQuery.WithContext(ctx).
+		UnderlyingDB().
+		Model(&models.Order{}).
+		Select("count(*) as count, coalesce(sum(amount_paid), 0) as amount").
+		Where("type = ? AND status = ? AND "+timeField+" >= ? AND "+timeField+" < ?",
+			consts.OrderTypeContentPurchase, status, rg.startDay, rg.endNext)
+	if tenantID > 0 {
+		query = query.Where("tenant_id = ?", tenantID)
+	}
+
+	if err := query.Scan(&total).Error; err != nil {
+		return 0, 0, errorx.ErrDatabaseError.WithCause(err)
+	}
+	return total.Count, total.Amount, nil
+}
+
+func (s *super) reportOrderSeries(
+	ctx context.Context,
+	tenantID int64,
+	status consts.OrderStatus,
+	timeField string,
+	rg reportRange,
+) (map[string]reportAggRow, error) {
+	rows := make([]reportAggRow, 0)
+	query := models.OrderQuery.WithContext(ctx).
+		UnderlyingDB().
+		Model(&models.Order{}).
+		Select("date_trunc('day', "+timeField+") as day, count(*) as count, coalesce(sum(amount_paid), 0) as amount").
+		Where("type = ? AND status = ? AND "+timeField+" >= ? AND "+timeField+" < ?",
+			consts.OrderTypeContentPurchase, status, rg.startDay, rg.endNext)
+	if tenantID > 0 {
+		query = query.Where("tenant_id = ?", tenantID)
+	}
+
+	if err := query.Group("day").Scan(&rows).Error; err != nil {
+		return nil, errorx.ErrDatabaseError.WithCause(err)
+	}
+
+	result := make(map[string]reportAggRow, len(rows))
+	for _, row := range rows {
+		key := row.Day.Format("2006-01-02")
+		result[key] = row
+	}
+	return result, nil
+}
+
+func (s *super) normalizeReportRange(filter *super_dto.SuperReportOverviewFilter) (reportRange, error) {
+	granularity := "day"
+	if filter != nil && filter.Granularity != nil && strings.TrimSpace(*filter.Granularity) != "" {
+		granularity = strings.ToLower(strings.TrimSpace(*filter.Granularity))
+	}
+	if granularity != "day" {
+		return reportRange{}, errorx.ErrBadRequest.WithMsg("仅支持按天统计")
+	}
+
+	now := time.Now()
+	endAt := now
+	if filter != nil && filter.EndAt != nil && strings.TrimSpace(*filter.EndAt) != "" {
+		parsed, err := time.Parse(time.RFC3339, strings.TrimSpace(*filter.EndAt))
+		if err != nil {
+			return reportRange{}, errorx.ErrBadRequest.WithMsg("结束时间格式错误")
+		}
+		endAt = parsed
+	}
+
+	startAt := endAt.AddDate(0, 0, -6)
+	if filter != nil && filter.StartAt != nil && strings.TrimSpace(*filter.StartAt) != "" {
+		parsed, err := time.Parse(time.RFC3339, strings.TrimSpace(*filter.StartAt))
+		if err != nil {
+			return reportRange{}, errorx.ErrBadRequest.WithMsg("开始时间格式错误")
+		}
+		startAt = parsed
+	}
+
+	startDay := time.Date(startAt.Year(), startAt.Month(), startAt.Day(), 0, 0, 0, 0, startAt.Location())
+	endDay := time.Date(endAt.Year(), endAt.Month(), endAt.Day(), 0, 0, 0, 0, endAt.Location())
+	if endDay.Before(startDay) {
+		return reportRange{}, errorx.ErrBadRequest.WithMsg("结束时间不能早于开始时间")
+	}
+
+	endNext := endDay.AddDate(0, 0, 1)
+	return reportRange{
+		startDay: startDay,
+		endDay:   endDay,
+		endNext:  endNext,
+	}, nil
+}
+
+func (s *super) buildSuperCouponItems(ctx context.Context, list []*models.Coupon) ([]super_dto.SuperCouponItem, error) {
+	if len(list) == 0 {
+		return []super_dto.SuperCouponItem{}, nil
+	}
+
+	tenantIDs := make([]int64, 0, len(list))
+	seen := make(map[int64]struct{}, len(list))
+	for _, c := range list {
+		if c == nil {
+			continue
+		}
+		if _, ok := seen[c.TenantID]; ok {
+			continue
+		}
+		seen[c.TenantID] = struct{}{}
+		tenantIDs = append(tenantIDs, c.TenantID)
+	}
+
+	tenantMap := make(map[int64]*models.Tenant, len(tenantIDs))
+	if len(tenantIDs) > 0 {
+		tbl, q := models.TenantQuery.QueryContext(ctx)
+		tenants, err := q.Where(tbl.ID.In(tenantIDs...)).Find()
+		if err != nil {
+			return nil, errorx.ErrDatabaseError.WithCause(err)
+		}
+		for _, t := range tenants {
+			tenantMap[t.ID] = t
+		}
+	}
+
+	items := make([]super_dto.SuperCouponItem, 0, len(list))
+	for _, c := range list {
+		if c == nil {
+			continue
+		}
+		items = append(items, s.toSuperCouponItem(c, tenantMap[c.TenantID]))
+	}
+	return items, nil
+}
+
+func (s *super) toSuperCouponItem(c *models.Coupon, tenant *models.Tenant) super_dto.SuperCouponItem {
+	status, statusDescription := s.resolveCouponStatus(c)
+	item := super_dto.SuperCouponItem{
+		ID:                c.ID,
+		TenantID:          c.TenantID,
+		Title:             c.Title,
+		Description:       c.Description,
+		Type:              c.Type,
+		TypeDescription:   c.Type.Description(),
+		Value:             c.Value,
+		MinOrderAmount:    c.MinOrderAmount,
+		MaxDiscount:       c.MaxDiscount,
+		TotalQuantity:     c.TotalQuantity,
+		UsedQuantity:      c.UsedQuantity,
+		Status:            status,
+		StatusDescription: statusDescription,
+		CreatedAt:         s.formatTime(c.CreatedAt),
+		UpdatedAt:         s.formatTime(c.UpdatedAt),
+	}
+	if tenant != nil {
+		item.TenantCode = tenant.Code
+		item.TenantName = tenant.Name
+	}
+	if !c.StartAt.IsZero() {
+		item.StartAt = s.formatTime(c.StartAt)
+	}
+	if !c.EndAt.IsZero() {
+		item.EndAt = s.formatTime(c.EndAt)
+	}
+	return item
+}
+
+func (s *super) resolveCouponStatus(c *models.Coupon) (string, string) {
+	now := time.Now()
+	if !c.EndAt.IsZero() && c.EndAt.Before(now) {
+		return "expired", "已过期"
+	}
+	if !c.StartAt.IsZero() && c.StartAt.After(now) {
+		return "upcoming", "未开始"
+	}
+	return "active", "生效中"
+}
+
 func (s *super) ApproveWithdrawal(ctx context.Context, operatorID, id int64) error {
 	if operatorID == 0 {
 		return errorx.ErrUnauthorized.WithMsg("缺少操作者信息")