refactor: streamline chat UI and session handling

Author: Noxiven

backend/docs/docs.go

@@ -283,6 +283,7 @@ func NewApp() (*App, error) {
 	adminService.SetAuthSecurityService(authService)
 	adminService.SetSystemEventService(systemEventService)
 	adminService.SetUsageLogService(billingService)
+	adminService.SetUsageStatisticsService(billingService)
 	adminService.SetOrderLogService(billingService)
 	adminService.SetConversationEventService(conversationService)
 	adminService.SetLogCleanupService(logCleanupService)

backend/docs/swagger.json

@@ -96,6 +96,10 @@ type usageLogService interface {
 	ListUsageLogs(ctx context.Context, page int, pageSize int, filter billing.UsageLogListFilter) ([]domainbilling.UsageLedger, int64, error)
 }
 
+type usageStatisticsService interface {
+	GetUsageStatistics(ctx context.Context, filter billing.UsageStatisticsFilter) (domainbilling.UsageStatistics, error)
+}
+
 type orderLogService interface {
 	ListPaymentOrders(ctx context.Context, page int, pageSize int, filter billing.PaymentOrderListFilter) ([]domainbilling.PaymentOrder, int64, error)
 }
@@ -119,6 +123,7 @@ type Service struct {
 	auditService                               auditService
 	systemEventService                         systemEventService
 	usageLogService                            usageLogService
+	usageStatisticsService                     usageStatisticsService
 	orderLogService                            orderLogService
 	conversationEventSvc                       conversationEventService
 	logCleanupService                          logCleanupService
@@ -187,6 +192,11 @@ func (s *Service) SetUsageLogService(service usageLogService) {
 	s.usageLogService = service
 }
 
+// SetUsageStatisticsService 注入管理员用量统计能力。
+func (s *Service) SetUsageStatisticsService(service usageStatisticsService) {
+	s.usageStatisticsService = service
+}
+
 // SetOrderLogService 注入支付订单日志查询能力。
 func (s *Service) SetOrderLogService(service orderLogService) {
 	s.orderLogService = service

backend/docs/swagger.yaml

@@ -28,6 +28,14 @@ func (s *Service) ListUsageLogs(ctx context.Context, page int, pageSize int, fil
 	return s.usageLogService.ListUsageLogs(ctx, page, pageSize, filter)
 }
 
+// GetUsageStatistics 查询管理员仪表盘的全局用量聚合。
+func (s *Service) GetUsageStatistics(ctx context.Context, filter billing.UsageStatisticsFilter) (domainbilling.UsageStatistics, error) {
+	if s.usageStatisticsService == nil {
+		return domainbilling.UsageStatistics{}, errors.New("usage statistics service unavailable")
+	}
+	return s.usageStatisticsService.GetUsageStatistics(ctx, filter)
+}
+
 // ListPaymentOrders 查询管理员支付订单记录。
 func (s *Service) ListPaymentOrders(ctx context.Context, page int, pageSize int, filter billing.PaymentOrderListFilter) ([]domainbilling.PaymentOrder, int64, error) {
 	if s.orderLogService == nil {

backend/internal/app/app.go

@@ -2266,6 +2266,87 @@ func (s *Service) ListUsageLogs(ctx context.Context, page int, pageSize int, fil
 	}, offset, limit)
 }
 
+// UsageStatisticsFilter 描述管理员仪表盘的用量统计条件。
+type UsageStatisticsFilter struct {
+	StartDate         time.Time
+	EndDate           time.Time
+	UserID            uint
+	PlatformModelName string
+	BillingScope      string
+	RankBy            string
+}
+
+// GetUsageStatistics 查询管理员仪表盘使用的全局用量统计。
+func (s *Service) GetUsageStatistics(ctx context.Context, filter UsageStatisticsFilter) (domainbilling.UsageStatistics, error) {
+	statisticsRepo, ok := s.repo.(repository.UsageStatisticsRepository)
+	if !ok {
+		return domainbilling.UsageStatistics{}, errors.New("usage statistics repository unavailable")
+	}
+
+	startDate := time.Date(filter.StartDate.Year(), filter.StartDate.Month(), filter.StartDate.Day(), 0, 0, 0, 0, filter.StartDate.Location())
+	endDate := time.Date(filter.EndDate.Year(), filter.EndDate.Month(), filter.EndDate.Day(), 0, 0, 0, 0, filter.EndDate.Location())
+	if endDate.Before(startDate) {
+		return domainbilling.UsageStatistics{}, errors.New("invalid usage statistics date range")
+	}
+	days := int(endDate.Sub(startDate).Hours()/24) + 1
+	if days <= 0 || days > 366 {
+		return domainbilling.UsageStatistics{}, errors.New("invalid usage statistics date range")
+	}
+
+	granularity := "day"
+	if days > 90 {
+		granularity = "month"
+	}
+	result, err := statisticsRepo.GetUsageStatistics(ctx, repository.UsageStatisticsFilter{
+		StartDate:         startDate,
+		EndDateExclusive:  endDate.AddDate(0, 0, 1),
+		UserID:            filter.UserID,
+		PlatformModelName: strings.TrimSpace(filter.PlatformModelName),
+		BillingScope:      strings.TrimSpace(filter.BillingScope),
+		Granularity:       granularity,
+		RankBy:            strings.TrimSpace(filter.RankBy),
+		RankLimit:         10,
+	})
+	if err != nil {
+		return domainbilling.UsageStatistics{}, err
+	}
+	result.Granularity = granularity
+	result.Trend = fillUsageStatisticsTrend(result.Trend, startDate, endDate, granularity)
+	return result, nil
+}
+
+func fillUsageStatisticsTrend(
+	items []domainbilling.UsageStatisticsTrendPoint,
+	startDate time.Time,
+	endDate time.Time,
+	granularity string,
+) []domainbilling.UsageStatisticsTrendPoint {
+	byPeriod := make(map[string]domainbilling.UsageStatisticsTrendPoint, len(items))
+	for _, item := range items {
+		byPeriod[item.PeriodStart.Format("2006-01-02")] = item
+	}
+
+	current := startDate
+	if granularity == "month" {
+		current = time.Date(startDate.Year(), startDate.Month(), 1, 0, 0, 0, 0, startDate.Location())
+	}
+	results := make([]domainbilling.UsageStatisticsTrendPoint, 0, len(items))
+	for !current.After(endDate) {
+		key := current.Format("2006-01-02")
+		if item, exists := byPeriod[key]; exists {
+			results = append(results, item)
+		} else {
+			results = append(results, domainbilling.UsageStatisticsTrendPoint{PeriodStart: current})
+		}
+		if granularity == "month" {
+			current = current.AddDate(0, 1, 0)
+		} else {
+			current = current.AddDate(0, 0, 1)
+		}
+	}
+	return results
+}
+
 // ListPaymentOrders 分页查询管理员支付订单记录。
 func (s *Service) ListPaymentOrders(ctx context.Context, page int, pageSize int, filter PaymentOrderListFilter) ([]domainbilling.PaymentOrder, int64, error) {
 	offset, limit := normalizePage(page, pageSize)

backend/internal/application/admin/service.go

@@ -406,3 +406,45 @@ type UsageDailyModelSummary struct {
 	AvgLatencyMS      int64
 	BilledNanousd     int64
 }
+
+// UsageStatisticsMetrics 表示一组聚合后的用量指标。
+type UsageStatisticsMetrics struct {
+	RecordCount      int64
+	InputTokens      int64
+	CacheReadTokens  int64
+	CacheWriteTokens int64
+	OutputTokens     int64
+	ReasoningTokens  int64
+	CallCount        int64
+	AvgLatencyMS     int64
+	BilledNanousd    int64
+}
+
+// UsageStatisticsTrendPoint 表示一个按日或按月聚合的趋势点。
+type UsageStatisticsTrendPoint struct {
+	PeriodStart time.Time
+	Metrics     UsageStatisticsMetrics
+}
+
+// UsageStatisticsModelRank 表示平台模型的用量排名项。
+type UsageStatisticsModelRank struct {
+	PlatformModelName string
+	Metrics           UsageStatisticsMetrics
+	Trend             []UsageStatisticsTrendPoint
+}
+
+// UsageStatisticsUserRank 表示用户的用量排名项。
+type UsageStatisticsUserRank struct {
+	UserID  uint
+	Metrics UsageStatisticsMetrics
+	Trend   []UsageStatisticsTrendPoint
+}
+
+// UsageStatistics 表示管理员仪表盘使用的全局用量聚合。
+type UsageStatistics struct {
+	Granularity string
+	Totals      UsageStatisticsMetrics
+	Trend       []UsageStatisticsTrendPoint
+	TopModels   []UsageStatisticsModelRank
+	TopUsers    []UsageStatisticsUserRank
+}