feat(ccproxy): add request statistics and token usage tracking with dashboard UI

Author: aidyou

RELEASE.md

@@ -2,6 +2,28 @@
 
 # Release Notes
 
+## [1.1.25] - 2026-01-27
+
+### 🚀 New Features
+
+- **New Proxy Statistics Feature**:
+  - **Full Data Monitoring**: The system now automatically records all requests passing through the proxy module, including the requested model, provider, client protocol, HTTP status code, and detailed error messages.
+  - **Precise Token Tracking**: Supports recording cumulative input, output, and cache token counts, providing users with a clear understanding of traffic consumption.
+  - **Dual-Mode Support**: Automatic statistics recording is implemented for both protocol conversion mode and direct forward mode.
+- **Brand New Statistics & Analytics UI**:
+  - **Visual Dashboard**: A new "Statistics" tab has been added to the Proxy Settings page, supporting daily usage summaries.
+  - **Multi-dimensional Drill-down**: Click on daily summaries to expand "Statistics Details," viewing granular distribution by provider, protocol, and tool mode.
+  - **Deep Error Tracking**: Click on error counts to view error code distribution and specific failure reasons for that date, facilitating rapid troubleshooting.
+  - **Smart Unit Conversion**: Token counts are automatically converted to "Ten Thousand" (万) or "Hundred Million" (亿) units for more intuitive display of large values.
+
+### 🪄 Improvements
+
+- **System Architecture Optimizations**:
+  - **Database Evolution**: Introduced V4 database migration logic, adding the `ccproxy_stats` table with indexes on key fields to ensure high-performance querying of massive statistical data.
+  - **Enhanced Robustness**: Optimized token capture logic during streaming transmissions to ensure the accuracy and completeness of statistical data.
+
+---
+
 ## [1.1.24] - 2026-01-27
 
 ### 🚀 New Features

RELEASE.zh-CN.md

@@ -2,6 +2,28 @@
 
 # 发布日志
 
+## [1.1.25] - 2026-01-27
+
+### 🚀 新特性
+
+- **新增代理统计功能**：
+  - **全量数据监控**：现在系统会自动记录所有通过代理模块的请求，包括请求模型、供应商、客户端协议、HTTP 状态码及详细的错误信息。
+  - **精准 Token 统计**：支持记录累计输入、输出及缓存 Token 数，帮助用户清晰掌握流量消耗。
+  - **双模式支持**：无论是协议转换模式还是直连转发模式，均已实现自动统计入库。
+- **全新统计分析界面**：
+  - **可视化看板**：在代理设置页面新增“统计信息”标签页，支持按天汇总显示使用情况。
+  - **多维度下钻**：点击每日统计可展开“统计详情”，按供应商、协议和工具模式查看更细致的分布数据。
+  - **错误深度追踪**：支持点击错误次数查看该日期下的错误码分布及具体错误原因，便于快速定位问题。
+  - **智能单位换算**：Token 数量支持自动换算为“万”或“亿”单位，大额数据展示更直观。
+
+### 🪄 改进
+
+- **系统架构优化**：
+  - **数据库版本演进**：引入了 V4 数据库迁移逻辑，新增 `ccproxy_stats` 表并配置了关键字段索引，确保海量统计数据下的查询性能。
+  - **健壮性增强**：优化了流式传输下的 Token 捕获逻辑，确保统计数据的准确性和完整性。
+
+---
+
 ## [1.1.24] - 2026-01-27
 
 ### 🚀 新特性

src-tauri/src/ccproxy/handler/chat_handler.rs

@@ -28,7 +28,7 @@ use crate::ccproxy::{
     types::ollama::OllamaChatCompletionRequest,
 };
 use crate::constants::{CFG_CCPROXY_LOG_PROXY_TO_FILE, CFG_CCPROXY_LOG_TO_FILE};
-use crate::db::MainStore;
+use crate::db::{CcproxyStat, MainStore};
 
 fn get_proxy_alias_from_body(
     chat_protocol: &ChatProtocol,
@@ -277,7 +277,7 @@ pub async fn handle_chat_completion(
         Some("compat") => true,
         Some("native") => false,
         Some("auto") | None => tool_compat_mode, // Use route parameter for auto mode
-        _ => tool_compat_mode, // Fallback to route parameter
+        _ => tool_compat_mode,                   // Fallback to route parameter
     };
 
     if chat_protocol == proxy_model.chat_protocol && !final_tool_compat_mode {
@@ -540,6 +540,23 @@ pub async fn handle_chat_completion(
             "code": status_code.as_u16().to_string()
         });
 
+        // Record error statistics
+        if let Ok(store) = main_store_arc.read() {
+            let _ = store.record_ccproxy_stat(CcproxyStat {
+                id: None,
+                model: proxy_model.model.clone(),
+                provider: proxy_model.provider.clone(),
+                protocol: chat_protocol.to_string(),
+                tool_compat_mode: if final_tool_compat_mode { 1 } else { 0 },
+                status_code: status_code.as_u16() as i32,
+                error_message: Some(message_content),
+                input_tokens: 0,
+                output_tokens: 0,
+                cache_tokens: 0,
+                request_at: None,
+            });
+        }
+
         let mut response =
             (status_code, Json(json!({ "error": final_error_json }))).into_response();
 
@@ -635,11 +652,16 @@ pub async fn handle_chat_completion(
     if is_streaming_request {
         let res = handle_streamed_response(
             Arc::new(proxy_model.chat_protocol),
+            chat_protocol,
             target_response,
             backend_adapter,
             output_adapter,
             sse_status,
             log_org_to_file,
+            main_store_arc.clone(),
+            proxy_model.model.clone(),
+            proxy_model.provider.clone(),
+            final_tool_compat_mode,
         )
         .await?;
         Ok(res.into_response())
@@ -662,6 +684,35 @@ pub async fn handle_chat_completion(
             .await
             .map_err(|e| CCProxyError::InternalError(e.to_string()))?;
 
+        // Record success statistics
+        if let Ok(store) = main_store_arc.read() {
+            log::info!(
+                "Recording ccproxy stats for non-streaming response: model={}, provider={}",
+                &proxy_model.model,
+                &proxy_model.provider
+            );
+            let cache_tokens = unified_response
+                .usage
+                .cache_read_input_tokens
+                .or(unified_response.usage.prompt_cached_tokens)
+                .or(unified_response.usage.cached_content_tokens)
+                .unwrap_or(0);
+
+            let _ = store.record_ccproxy_stat(CcproxyStat {
+                id: None,
+                model: proxy_model.model.clone(),
+                provider: proxy_model.provider.clone(),
+                protocol: chat_protocol.to_string(),
+                tool_compat_mode: if final_tool_compat_mode { 1 } else { 0 },
+                status_code: 200,
+                error_message: None,
+                input_tokens: unified_response.usage.input_tokens as i64,
+                output_tokens: unified_response.usage.output_tokens as i64,
+                cache_tokens: cache_tokens as i64,
+                request_at: None,
+            });
+        }
+
         let response = output_adapter
             .adapt_response(unified_response, sse_status)
             .map_err(|e| CCProxyError::InternalError(e.to_string()))?;