feat: 优化 Stats 页面和升级计费精度至纳美元

- 添加 year 粒度支持，用于全时间范围查询
- 修复时间范围边界问题，避免 lastWeek/lastMonth 等重复计算边界日期
- 使用系统配置的时区而不是 UTC 进行时间桶计算
- 添加筛选条件摘要显示（精确到时间）
- 修复 model 参数未传递到 API 的问题
- 移除侧边栏折叠功能，保持始终显示
- 图表颜色使用主题变量，Cost 在图例和 Tooltip 中优先显示
- 修复 Filter 清空按钮的布局位移问题
- Provider 分组显示类型名称标签

- 成本计算从微美元(microUSD)升级到纳美元(nanoUSD)，精度提升1000倍
- 使用 big.Int 进行计算，防止大数量 token 时的整数溢出
- 添加 CacheCreationCount fallback 支持
- 保留旧函数作为兼容层（标记为 Deprecated）

Author: Bowl42

cmd/maxx/main.go

@@ -228,6 +228,7 @@ func main() {
 		responseModelRepo,
 		*addr,
 		r, // Router implements ProviderAdapterRefresher interface
+		wsHub,
 	)
 
 	// Create backup service

internal/core/database.go

@@ -275,6 +275,7 @@ func InitializeServerComponents(
 		repos.ResponseModelRepo,
 		addr,
 		r,
+		wailsBroadcaster,
 	)
 
 	log.Printf("[Core] Creating backup service")

internal/domain/model.go

@@ -239,7 +239,7 @@ type ProxyRequest struct {
 	Cache5mWriteCount uint64 `json:"cache5mWriteCount"`
 	Cache1hWriteCount uint64 `json:"cache1hWriteCount"`
 
-	// 成本 (微美元，1 USD = 1,000,000)
+	// 成本 (纳美元，1 USD = 1,000,000,000 nanoUSD)
 	Cost uint64 `json:"cost"`
 
 	// 使用的 API Token ID，0 表示未使用 Token
@@ -295,6 +295,22 @@ type ProxyUpstreamAttempt struct {
 	Cost uint64 `json:"cost"`
 }
 
+// AttemptCostData contains minimal data needed for cost recalculation
+type AttemptCostData struct {
+	ID               uint64
+	ProxyRequestID   uint64
+	ResponseModel    string
+	MappedModel      string
+	RequestModel     string
+	InputTokenCount  uint64
+	OutputTokenCount uint64
+	CacheReadCount   uint64
+	CacheWriteCount  uint64
+	Cache5mWriteCount uint64
+	Cache1hWriteCount uint64
+	Cost             uint64
+}
+
 // 重试配置
 type RetryConfig struct {
 	ID        uint64    `json:"id"`
@@ -432,7 +448,7 @@ type ProviderStats struct {
 	TotalCacheRead    uint64 `json:"totalCacheRead"`
 	TotalCacheWrite   uint64 `json:"totalCacheWrite"`
 
-	// 成本 (微美元)
+	// 成本 (纳美元)
 	TotalCost uint64 `json:"totalCost"`
 }
 
@@ -445,6 +461,7 @@ const (
 	GranularityDay    Granularity = "day"
 	GranularityWeek   Granularity = "week"
 	GranularityMonth  Granularity = "month"
+	GranularityYear   Granularity = "year"
 )
 
 // UsageStats 使用统计汇总（多层级时间聚合）
@@ -476,7 +493,7 @@ type UsageStats struct {
 	CacheRead    uint64 `json:"cacheRead"`
 	CacheWrite   uint64 `json:"cacheWrite"`
 
-	// 成本 (微美元)
+	// 成本 (纳美元)
 	Cost uint64 `json:"cost"`
 }
 
@@ -756,3 +773,14 @@ type DashboardData struct {
 	ProviderStats map[uint64]DashboardProviderStats `json:"providerStats"`
 	Timezone      string                            `json:"timezone"` // 配置的时区，如 "Asia/Shanghai"
 }
+
+// ===== Progress Reporting =====
+
+// Progress represents a progress update for long-running operations
+type Progress struct {
+	Phase      string `json:"phase"`      // Current phase of the operation
+	Current    int    `json:"current"`    // Current item being processed
+	Total      int    `json:"total"`      // Total items to process
+	Percentage int    `json:"percentage"` // 0-100
+	Message    string `json:"message"`    // Human-readable message
+}

internal/executor/executor.go

@@ -404,7 +404,12 @@ func (e *Executor) Execute(ctx context.Context, w http.ResponseWriter, req *http
 						Cache5mCreationCount: attemptRecord.Cache5mWriteCount,
 						Cache1hCreationCount: attemptRecord.Cache1hWriteCount,
 					}
-					attemptRecord.Cost = pricing.GlobalCalculator().Calculate(attemptRecord.MappedModel, metrics)
+					// Use ResponseModel for pricing (actual model from API response), fallback to MappedModel
+					pricingModel := attemptRecord.ResponseModel
+					if pricingModel == "" {
+						pricingModel = attemptRecord.MappedModel
+					}
+					attemptRecord.Cost = pricing.GlobalCalculator().Calculate(pricingModel, metrics)
 				}
 
 				_ = e.attemptRepo.Update(attemptRecord)
@@ -476,7 +481,12 @@ func (e *Executor) Execute(ctx context.Context, w http.ResponseWriter, req *http
 					Cache5mCreationCount: attemptRecord.Cache5mWriteCount,
 					Cache1hCreationCount: attemptRecord.Cache1hWriteCount,
 				}
-				attemptRecord.Cost = pricing.GlobalCalculator().Calculate(attemptRecord.MappedModel, metrics)
+				// Use ResponseModel for pricing (actual model from API response), fallback to MappedModel
+				pricingModel := attemptRecord.ResponseModel
+				if pricingModel == "" {
+					pricingModel = attemptRecord.MappedModel
+				}
+				attemptRecord.Cost = pricing.GlobalCalculator().Calculate(pricingModel, metrics)
 			}
 
 			_ = e.attemptRepo.Update(attemptRecord)

internal/handler/admin.go

@@ -9,6 +9,7 @@ import (
 
 	"github.com/awsl-project/maxx/internal/cooldown"
 	"github.com/awsl-project/maxx/internal/domain"
+	"github.com/awsl-project/maxx/internal/pricing"
 	"github.com/awsl-project/maxx/internal/repository"
 	"github.com/awsl-project/maxx/internal/service"
 )
@@ -88,6 +89,8 @@ func (h *AdminHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		h.handleResponseModels(w, r)
 	case "backup":
 		h.handleBackup(w, r, parts)
+	case "pricing":
+		h.handlePricing(w, r)
 	default:
 		writeJSON(w, http.StatusNotFound, map[string]string{"error": "not found"})
 	}
@@ -650,7 +653,7 @@ func (h *AdminHandler) handleRoutingStrategies(w http.ResponseWriter, r *http.Re
 }
 
 // ProxyRequest handlers
-// Routes: /admin/requests, /admin/requests/count, /admin/requests/active, /admin/requests/{id}, /admin/requests/{id}/attempts
+// Routes: /admin/requests, /admin/requests/count, /admin/requests/active, /admin/requests/{id}, /admin/requests/{id}/attempts, /admin/requests/{id}/recalculate-cost
 func (h *AdminHandler) handleProxyRequests(w http.ResponseWriter, r *http.Request, id uint64, parts []string) {
 	// Check for count endpoint: /admin/requests/count
 	if len(parts) > 2 && parts[2] == "count" {
@@ -670,6 +673,12 @@ func (h *AdminHandler) handleProxyRequests(w http.ResponseWriter, r *http.Reques
 		return
 	}
 
+	// Check for sub-resource: /admin/requests/{id}/recalculate-cost
+	if len(parts) > 3 && parts[3] == "recalculate-cost" && id > 0 {
+		h.handleRecalculateRequestCost(w, r, id)
+		return
+	}
+
 	switch r.Method {
 	case http.MethodGet:
 		if id > 0 {
@@ -691,7 +700,18 @@ func (h *AdminHandler) handleProxyRequests(w http.ResponseWriter, r *http.Reques
 			if a := r.URL.Query().Get("after"); a != "" {
 				after, _ = strconv.ParseUint(a, 10, 64)
 			}
-			result, err := h.svc.GetProxyRequestsCursor(limit, before, after)
+
+			// 构建过滤条件
+			var filter *repository.ProxyRequestFilter
+			if p := r.URL.Query().Get("providerId"); p != "" {
+				if providerID, err := strconv.ParseUint(p, 10, 64); err == nil {
+					filter = &repository.ProxyRequestFilter{
+						ProviderID: &providerID,
+					}
+				}
+			}
+
+			result, err := h.svc.GetProxyRequestsCursor(limit, before, after, filter)
 			if err != nil {
 				writeJSON(w, http.StatusInternalServerError, map[string]string{"error": err.Error()})
 				return
@@ -710,7 +730,18 @@ func (h *AdminHandler) handleProxyRequestsCount(w http.ResponseWriter, r *http.R
 		return
 	}
 
-	count, err := h.svc.GetProxyRequestsCount()
+	// 解析 providerId 过滤参数
+	var filter *repository.ProxyRequestFilter
+	if providerIDStr := r.URL.Query().Get("providerId"); providerIDStr != "" {
+		providerID, err := strconv.ParseUint(providerIDStr, 10, 64)
+		if err != nil {
+			writeJSON(w, http.StatusBadRequest, map[string]string{"error": "invalid providerId"})
+			return
+		}
+		filter = &repository.ProxyRequestFilter{ProviderID: &providerID}
+	}
+
+	count, err := h.svc.GetProxyRequestsCountWithFilter(filter)
 	if err != nil {
 		writeJSON(w, http.StatusInternalServerError, map[string]string{"error": err.Error()})
 		return
@@ -748,6 +779,21 @@ func (h *AdminHandler) handleProxyUpstreamAttempts(w http.ResponseWriter, r *htt
 	writeJSON(w, http.StatusOK, attempts)
 }
 
+// handleRecalculateRequestCost handles POST /admin/requests/{id}/recalculate-cost
+func (h *AdminHandler) handleRecalculateRequestCost(w http.ResponseWriter, r *http.Request, requestID uint64) {
+	if r.Method != http.MethodPost {
+		writeJSON(w, http.StatusMethodNotAllowed, map[string]string{"error": "method not allowed"})
+		return
+	}
+
+	result, err := h.svc.RecalculateRequestCost(requestID)
+	if err != nil {
+		writeJSON(w, http.StatusInternalServerError, map[string]string{"error": err.Error()})
+		return
+	}
+	writeJSON(w, http.StatusOK, result)
+}
+
 // Settings handlers
 func (h *AdminHandler) handleSettings(w http.ResponseWriter, r *http.Request, parts []string) {
 	var key string
@@ -1168,6 +1214,11 @@ func (h *AdminHandler) handleUsageStats(w http.ResponseWriter, r *http.Request)
 		h.handleRecalculateUsageStats(w, r)
 		return
 	}
+	// Check for recalculate-costs endpoint: /admin/usage-stats/recalculate-costs
+	if strings.HasSuffix(path, "/recalculate-costs") {
+		h.handleRecalculateCosts(w, r)
+		return
+	}
 
 	if r.Method != http.MethodGet {
 		writeJSON(w, http.StatusMethodNotAllowed, map[string]string{"error": "method not allowed"})
@@ -1259,6 +1310,22 @@ func (h *AdminHandler) handleRecalculateUsageStats(w http.ResponseWriter, r *htt
 	writeJSON(w, http.StatusOK, map[string]string{"message": "usage stats recalculated successfully"})
 }
 
+// handleRecalculateCosts handles POST /admin/usage-stats/recalculate-costs
+// Recalculates cost for all attempts using the current price table
+func (h *AdminHandler) handleRecalculateCosts(w http.ResponseWriter, r *http.Request) {
+	if r.Method != http.MethodPost {
+		writeJSON(w, http.StatusMethodNotAllowed, map[string]string{"error": "method not allowed"})
+		return
+	}
+
+	result, err := h.svc.RecalculateCosts()
+	if err != nil {
+		writeJSON(w, http.StatusInternalServerError, map[string]string{"error": err.Error()})
+		return
+	}
+	writeJSON(w, http.StatusOK, result)
+}
+
 // handleResponseModels handles GET /admin/response-models
 func (h *AdminHandler) handleResponseModels(w http.ResponseWriter, r *http.Request) {
 	if r.Method != http.MethodGet {
@@ -1359,6 +1426,18 @@ func (h *AdminHandler) handleBackupImport(w http.ResponseWriter, r *http.Request
 	writeJSON(w, http.StatusOK, result)
 }
 
+// handlePricing handles GET /admin/pricing
+// Returns the default price table for cost calculation display
+func (h *AdminHandler) handlePricing(w http.ResponseWriter, r *http.Request) {
+	if r.Method != http.MethodGet {
+		writeJSON(w, http.StatusMethodNotAllowed, map[string]string{"error": "method not allowed"})
+		return
+	}
+
+	priceTable := pricing.DefaultPriceTable()
+	writeJSON(w, http.StatusOK, priceTable)
+}
+
 func writeJSON(w http.ResponseWriter, status int, data interface{}) {
 	w.Header().Set("Content-Type", "application/json")
 	w.WriteHeader(status)

internal/pricing/calculator.go

@@ -34,7 +34,7 @@ func NewCalculator(pt *PriceTable) *Calculator {
 	}
 }
 
-// Calculate 计算成本，返回微美元 (1 USD = 1,000,000 microUSD)
+// Calculate 计算成本，返回纳美元 (1 USD = 1,000,000,000 nanoUSD)
 // model: 模型名称
 // metrics: token使用指标
 // 如果模型未找到，返回0并记录警告日志
@@ -56,6 +56,7 @@ func (c *Calculator) Calculate(model string, metrics *usage.Metrics) uint64 {
 }
 
 // CalculateWithPricing 使用指定价格计算成本（纯整数运算）
+// 返回: 纳美元成本 (nanoUSD)
 func (c *Calculator) CalculateWithPricing(pricing *ModelPricing, metrics *usage.Metrics) uint64 {
 	if pricing == nil || metrics == nil {
 		return 0
@@ -67,56 +68,64 @@ func (c *Calculator) CalculateWithPricing(pricing *ModelPricing, metrics *usage.
 	if metrics.InputTokens > 0 {
 		if pricing.Has1MContext {
 			inputNum, inputDenom := pricing.GetInputPremiumFraction()
-			totalCost += CalculateTieredCostMicro(
+			totalCost += CalculateTieredCost(
 				metrics.InputTokens,
 				pricing.InputPriceMicro,
 				inputNum, inputDenom,
 				pricing.GetContext1MThreshold(),
 			)
 		} else {
-			totalCost += CalculateLinearCostMicro(metrics.InputTokens, pricing.InputPriceMicro)
+			totalCost += CalculateLinearCost(metrics.InputTokens, pricing.InputPriceMicro)
 		}
 	}
 
 	// 2. 输出成本
 	if metrics.OutputTokens > 0 {
 		if pricing.Has1MContext {
 			outputNum, outputDenom := pricing.GetOutputPremiumFraction()
-			totalCost += CalculateTieredCostMicro(
+			totalCost += CalculateTieredCost(
 				metrics.OutputTokens,
 				pricing.OutputPriceMicro,
 				outputNum, outputDenom,
 				pricing.GetContext1MThreshold(),
 			)
 		} else {
-			totalCost += CalculateLinearCostMicro(metrics.OutputTokens, pricing.OutputPriceMicro)
+			totalCost += CalculateLinearCost(metrics.OutputTokens, pricing.OutputPriceMicro)
 		}
 	}
 
 	// 3. 缓存读取成本（使用 input 价格的 10%）
 	if metrics.CacheReadCount > 0 {
-		totalCost += CalculateLinearCostMicro(
+		totalCost += CalculateLinearCost(
 			metrics.CacheReadCount,
 			pricing.GetEffectiveCacheReadPriceMicro(),
 		)
 	}
 
 	// 4. 5分钟缓存写入成本（使用 input 价格的 125%）
 	if metrics.Cache5mCreationCount > 0 {
-		totalCost += CalculateLinearCostMicro(
+		totalCost += CalculateLinearCost(
 			metrics.Cache5mCreationCount,
 			pricing.GetEffectiveCache5mWritePriceMicro(),
 		)
 	}
 
 	// 5. 1小时缓存写入成本（使用 input 价格的 200%）
 	if metrics.Cache1hCreationCount > 0 {
-		totalCost += CalculateLinearCostMicro(
+		totalCost += CalculateLinearCost(
 			metrics.Cache1hCreationCount,
 			pricing.GetEffectiveCache1hWritePriceMicro(),
 		)
 	}
 
+	// 6. Fallback: 如果没有 5m/1h 细分但有总缓存写入数
+	if metrics.Cache5mCreationCount == 0 && metrics.Cache1hCreationCount == 0 && metrics.CacheCreationCount > 0 {
+		totalCost += CalculateLinearCost(
+			metrics.CacheCreationCount,
+			pricing.GetEffectiveCache5mWritePriceMicro(), // 使用 5m 价格作为默认
+		)
+	}
+
 	return totalCost
 }