Add: Supabase 日志系统

完整的结构化日志记录解决方案

新增文件:
1. supabase_schema_with_logs.sql - 数据库表结构
- api_access_logs: API 访问日志
- error_logs: 错误日志
- debug_logs: 调试日志
- model_performance_logs: 模型性能日志
- user_behavior_logs: 用户行为日志

2. services/supabase_logger.py - 日志记录器
- SupabaseLogger 类：统一的日志记录接口
- 装饰器：@log_api_access, @log_model_performance
- 上下文管理器：LogPerformance
- 简化函数：log_debug, log_error

3. services/supabase_logger_examples.py - 使用示例
- 基本日志记录
- 装饰器使用
- 上下文管理器使用
- FastAPI 集成
- 批量日志记录

功能特性:
- 自动记录 API 访问和性能指标
- 结构化错误追踪
- 模型性能监控
- 用户行为分析
- 自动日志清理
- 统计和查询函数

环境变量:
- ENABLE_SUPABASE_LOGGING=true 启用日志

Co-Authored-By: Claude <noreply@anthropic.com>

services/supabase_logger.py

@@ -0,0 +1,516 @@
+"""
+Supabase 日志记录器
+
+提供结构化的日志记录功能，将日志存储到 Supabase
+支持：API 访问日志、错误日志、调试日志、模型性能日志、用户行为日志
+"""
+import os
+import json
+import time
+import traceback
+from typing import Optional, Dict, Any, List
+from datetime import datetime
+from functools import wraps
+import logging
+
+
+class SupabaseLogger:
+    """
+    Supabase 日志记录器
+
+    用法:
+        logger = SupabaseLogger()
+
+        # 记录 API 访问
+        logger.log_api_access(
+            endpoint="/api/v1/chat",
+            method="POST",
+            status_code=200,
+            response_time_ms=150
+        )
+
+        # 记录错误
+        logger.log_error(
+            error_type="model_load",
+            error_message="Failed to load model",
+            error_stack=traceback.format_exc()
+        )
+
+        # 记录调试信息
+        logger.log_debug(
+            level="INFO",
+            logger="intelligence_analyzer",
+            message="Scenario detected: policy_inquiry",
+            data={"scenario": "policy_inquiry", "confidence": 0.9}
+        )
+    """
+
+    def __init__(self):
+        """初始化日志记录器"""
+        self._client = None
+        self._enabled = None
+        self._fallback_logger = logging.getLogger(__name__)
+
+    @property
+    def client(self):
+        """延迟加载 Supabase 客户端"""
+        if self._client is None:
+            try:
+                from services.supabase_client import get_supabase_client
+                self._client = get_supabase_client()
+            except Exception as e:
+                self._fallback_logger.warning(f"Supabase client not available: {e}")
+                self._client = False  # 标记为不可用
+        return self._client if self._client is not False else None
+
+    @property
+    def enabled(self) -> bool:
+        """检查是否启用日志记录"""
+        if self._enabled is None:
+            self._enabled = os.getenv("ENABLE_SUPABASE_LOGGING", "true").lower() == "true"
+        return self._enabled
+
+    def log_api_access(
+        self,
+        endpoint: str,
+        method: str,
+        path: Optional[str] = None,
+        query_params: Optional[Dict] = None,
+        client_ip: Optional[str] = None,
+        user_agent: Optional[str] = None,
+        session_id: Optional[str] = None,
+        response_time_ms: Optional[int] = None,
+        status_code: Optional[int] = None,
+        metadata: Optional[Dict] = None
+    ) -> bool:
+        """
+        记录 API 访问日志
+
+        Args:
+            endpoint: API 端点（如 /api/v1/chat）
+            method: HTTP 方法
+            path: 请求路径
+            query_params: 查询参数
+            client_ip: 客户端 IP
+            user_agent: 用户代理
+            session_id: 会话 ID
+            response_time_ms: 响应时间（毫秒）
+            status_code: HTTP 状态码
+            metadata: 额外元数据
+
+        Returns:
+            是否成功记录
+        """
+        if not self.enabled or not self.client:
+            return False
+
+        try:
+            data = {
+                "endpoint": endpoint,
+                "method": method,
+                "path": path,
+                "query_params": query_params,
+                "client_ip": client_ip,
+                "user_agent": user_agent,
+                "session_id": session_id,
+                "response_time_ms": response_time_ms,
+                "status_code": status_code,
+                "metadata": metadata or {}
+            }
+
+            self.client.table("api_access_logs").insert(data).execute()
+            return True
+        except Exception as e:
+            self._fallback_logger.error(f"Failed to log API access: {e}")
+            return False
+
+    def log_error(
+        self,
+        error_type: str,
+        error_message: str,
+        error_stack: Optional[str] = None,
+        endpoint: Optional[str] = None,
+        session_id: Optional[str] = None,
+        user_input: Optional[str] = None,
+        request_data: Optional[Dict] = None,
+        metadata: Optional[Dict] = None
+    ) -> bool:
+        """
+        记录错误日志
+
+        Args:
+            error_type: 错误类型
+            error_message: 错误消息
+            error_stack: 错误堆栈
+            endpoint: 发生错误的端点
+            session_id: 会话 ID
+            user_input: 用户输入
+            request_data: 请求数据
+            metadata: 额外元数据
+
+        Returns:
+            是否成功记录
+        """
+        if not self.enabled or not self.client:
+            return False
+
+        try:
+            data = {
+                "error_type": error_type,
+                "error_message": error_message,
+                "error_stack": error_stack,
+                "endpoint": endpoint,
+                "session_id": session_id,
+                "user_input": user_input,
+                "request_data": request_data,
+                "metadata": metadata or {}
+            }
+
+            self.client.table("error_logs").insert(data).execute()
+            return True
+        except Exception as e:
+            self._fallback_logger.error(f"Failed to log error: {e}")
+            return False
+
+    def log_debug(
+        self,
+        level: str,
+        logger: str,
+        message: str,
+        session_id: Optional[str] = None,
+        function_name: Optional[str] = None,
+        line_number: Optional[int] = None,
+        data: Optional[Dict] = None,
+        metadata: Optional[Dict] = None
+    ) -> bool:
+        """
+        记录调试日志
+
+        Args:
+            level: 日志级别（DEBUG, INFO, WARNING, ERROR）
+            logger: 模块名称
+            message: 日志消息
+            session_id: 会话 ID
+            function_name: 函数名
+            line_number: 行号
+            data: 结构化数据
+            metadata: 额外元数据
+
+        Returns:
+            是否成功记录
+        """
+        if not self.enabled or not self.client:
+            return False
+
+        # 只记录 INFO 及以上级别的日志
+        if level == "DEBUG" and os.getenv("LOG_LEVEL", "INFO").upper() != "DEBUG":
+            return False
+
+        try:
+            log_data = {
+                "level": level,
+                "logger": logger,
+                "message": message,
+                "session_id": session_id,
+                "function_name": function_name,
+                "line_number": line_number,
+                "data": data,
+                "metadata": metadata or {}
+            }
+
+            self.client.table("debug_logs").insert(log_data).execute()
+            return True
+        except Exception as e:
+            self._fallback_logger.error(f"Failed to log debug: {e}")
+            return False
+
+    def log_model_performance(
+        self,
+        model_name: str,
+        model_type: str,
+        load_time_ms: Optional[int] = None,
+        inference_time_ms: Optional[int] = None,
+        total_time_ms: Optional[int] = None,
+        input_text: Optional[str] = None,
+        output_summary: Optional[str] = None,
+        metadata: Optional[Dict] = None
+    ) -> bool:
+        """
+        记录模型性能日志
+
+        Args:
+            model_name: 模型名称
+            model_type: 模型类型（sbert, sentiment, compliance, llm）
+            load_time_ms: 加载时间
+            inference_time_ms: 推理时间
+            total_time_ms: 总时间
+            input_text: 输入文本
+            output_summary: 输出摘要
+            metadata: 额外元数据
+
+        Returns:
+            是否成功记录
+        """
+        if not self.enabled or not self.client:
+            return False
+
+        try:
+            data = {
+                "model_name": model_name,
+                "model_type": model_type,
+                "load_time_ms": load_time_ms,
+                "inference_time_ms": inference_time_ms,
+                "total_time_ms": total_time_ms,
+                "input_text": input_text[:500] if input_text else None,  # 限制长度
+                "output_summary": output_summary[:500] if output_summary else None,
+                "metadata": metadata or {}
+            }
+
+            self.client.table("model_performance_logs").insert(data).execute()
+            return True
+        except Exception as e:
+            self._fallback_logger.error(f"Failed to log model performance: {e}")
+            return False
+
+    def log_user_behavior(
+        self,
+        session_id: str,
+        action_type: str,
+        action_detail: Optional[str] = None,
+        input_text: Optional[str] = None,
+        intent_detected: Optional[str] = None,
+        scenario_detected: Optional[str] = None,
+        success: Optional[bool] = None,
+        error_message: Optional[str] = None,
+        user_id: Optional[str] = None,
+        metadata: Optional[Dict] = None
+    ) -> bool:
+        """
+        记录用户行为日志
+
+        Args:
+            session_id: 会话 ID
+            action_type: 动作类型（chat, evaluate, config_check, etc.）
+            action_detail: 动作详情
+            input_text: 用户输入
+            intent_detected: 检测到的意图
+            scenario_detected: 检测到的场景
+            success: 是否成功
+            error_message: 错误消息
+            user_id: 用户 ID
+            metadata: 额外元数据
+
+        Returns:
+            是否成功记录
+        """
+        if not self.enabled or not self.client:
+            return False
+
+        try:
+            data = {
+                "session_id": session_id,
+                "user_id": user_id,
+                "action_type": action_type,
+                "action_detail": action_detail,
+                "input_text": input_text,
+                "intent_detected": intent_detected,
+                "scenario_detected": scenario_detected,
+                "success": success,
+                "error_message": error_message,
+                "metadata": metadata or {}
+            }
+
+            self.client.table("user_behavior_logs").insert(data).execute()
+            return True
+        except Exception as e:
+            self._fallback_logger.error(f"Failed to log user behavior: {e}")
+            return False
+
+
+# 全局单例
+_supabase_logger_instance = None
+
+
+def get_supabase_logger() -> SupabaseLogger:
+    """获取 Supabase 日志记录器单例"""
+    global _supabase_logger_instance
+    if _supabase_logger_instance is None:
+        _supabase_logger_instance = SupabaseLogger()
+    return _supabase_logger_instance
+
+
+# ============================================
+# 装饰器
+# ============================================
+
+def log_api_access(endpoint: str = None):
+    """
+    API 访问日志装饰器
+
+    用法:
+        @log_api_access("/api/v1/chat")
+        async def chat_endpoint(request):
+            ...
+    """
+    def decorator(func):
+        @wraps(func)
+        async def wrapper(*args, **kwargs):
+            logger = get_supabase_logger()
+            start_time = time.time()
+
+            # 获取端点名称
+            ep = endpoint or f"/{func.__name__}"
+
+            try:
+                result = await func(*args, **kwargs)
+                status_code = getattr(result, 'status_code', 200) if hasattr(result, 'status_code') else 200
+
+                # 记录成功的 API 调用
+                response_time = int((time.time() - start_time) * 1000)
+                logger.log_api_access(
+                    endpoint=ep,
+                    method="POST",
+                    status_code=status_code,
+                    response_time_ms=response_time
+                )
+
+                return result
+            except Exception as e:
+                # 记录失败的 API 调用
+                response_time = int((time.time() - start_time) * 1000)
+                logger.log_api_access(
+                    endpoint=ep,
+                    method="POST",
+                    status_code=500,
+                    response_time_ms=response_time
+                )
+
+                # 记录错误
+                logger.log_error(
+                    error_type="api_error",
+                    error_message=str(e),
+                    error_stack=traceback.format_exc(),
+                    endpoint=ep
+                )
+
+                raise
+
+        return wrapper
+    return decorator
+
+
+def log_model_performance(model_name: str, model_type: str):
+    """
+    模型性能日志装饰器
+
+    用法:
+        @log_model_performance("sbert-hr-v2", "sbert")
+        def encode_text(text):
+            ...
+    """
+    def decorator(func):
+        @wraps(func)
+        def wrapper(*args, **kwargs):
+            logger = get_supabase_logger()
+            start_time = time.time()
+
+            try:
+                result = func(*args, **kwargs)
+                total_time = int((time.time() - start_time) * 1000)
+
+                # 记录性能
+                logger.log_model_performance(
+                    model_name=model_name,
+                    model_type=model_type,
+                    total_time_ms=total_time,
+                    input_text=str(args[0]) if args else None
+                )
+
+                return result
+            except Exception as e:
+                total_time = int((time.time() - start_time) * 1000)
+
+                # 记录错误
+                logger.log_error(
+                    error_type="model_inference",
+                    error_message=str(e),
+                    error_stack=traceback.format_exc()
+                )
+
+                raise
+
+        return wrapper
+    return decorator
+
+
+# ============================================
+# 上下文管理器 - 用于性能追踪
+# ============================================
+
+class LogPerformance:
+    """
+    性能日志上下文管理器
+
+    用法:
+        with LogPerformance("chat_processing", "llm"):
+            # 执行耗时操作
+            result = process_chat(request)
+    """
+
+    def __init__(self, operation_name: str, model_name: str, model_type: str):
+        self.operation_name = operation_name
+        self.model_name = model_name
+        self.model_type = model_type
+        self.logger = get_supabase_logger()
+        self.start_time = None
+
+    def __enter__(self):
+        self.start_time = time.time()
+        return self
+
+    def __exit__(self, exc_type, exc_val, exc_tb):
+        total_time = int((time.time() - self.start_time) * 1000)
+
+        if exc_type is None:
+            # 成功完成
+            self.logger.log_model_performance(
+                model_name=self.model_name,
+                model_type=self.model_type,
+                total_time_ms=total_time
+            )
+        else:
+            # 发生错误
+            self.logger.log_error(
+                error_type="performance_error",
+                error_message=str(exc_val),
+                error_stack=traceback.format_exception(exc_type, exc_val, exc_tb),
+                metadata={
+                    "operation": self.operation_name,
+                    "duration_ms": total_time
+                }
+            )
+
+        return False  # 不抑制异常
+
+
+# ============================================
+# 简化的日志函数
+# ============================================
+
+def log_debug(logger_name: str, message: str, level: str = "INFO", **kwargs):
+    """简化的调试日志记录"""
+    get_supabase_logger().log_debug(
+        level=level,
+        logger=logger_name,
+        message=message,
+        **kwargs
+    )
+
+
+def log_error(error_type: str, error_message: str, **kwargs):
+    """简化的错误日志记录"""
+    get_supabase_logger().log_error(
+        error_type=error_type,
+        error_message=error_message,
+        **kwargs
+    )

services/supabase_logger_examples.py

@@ -0,0 +1,324 @@
+"""
+Supabase 日志使用示例
+
+演示如何在项目中使用 Supabase 日志记录器
+"""
+from services.supabase_logger import (
+    get_supabase_logger,
+    log_api_access,
+    log_model_performance,
+    LogPerformance,
+    log_debug,
+    log_error
+)
+from functools import wraps
+import time
+
+
+# ============================================
+# 示例 1: 基本日志记录
+# ============================================
+
+def example_basic_logging():
+    """基本日志记录示例"""
+    logger = get_supabase_logger()
+
+    # 记录 API 访问
+    logger.log_api_access(
+        endpoint="/api/v1/chat",
+        method="POST",
+        session_id="user_123",
+        response_time_ms=150,
+        status_code=200
+    )
+
+    # 记录调试信息
+    logger.log_debug(
+        level="INFO",
+        logger="intelligence_analyzer",
+        message="Scenario detected: policy_inquiry",
+        session_id="user_123",
+        data={
+            "scenario": "policy_inquiry",
+            "confidence": 0.95,
+            "keywords": ["年假", "多少"]
+        }
+    )
+
+    # 记录错误
+    logger.log_error(
+        error_type="model_load",
+        error_message="Failed to load sentiment model",
+        error_stack="Traceback...\n  File ...",
+        endpoint="/api/v1/evaluate"
+    )
+
+
+# ============================================
+# 示例 2: 使用装饰器
+# ============================================
+
+@log_api_access("/api/v1/chat")
+def process_chat_request(question: str, session_id: str):
+    """
+    使用 API 日志装饰器
+    自动记录 API 调用和响应时间
+    """
+    # 模拟处理
+    time.sleep(0.1)
+    return {"answer": "这是回复内容"}
+
+
+@log_model_performance("sbert-hr-v2", "sbert")
+def encode_with_sbert(text: str):
+    """
+    使用模型性能装饰器
+    自动记录模型推理性能
+    """
+    # 模拟编码
+    time.sleep(0.05)
+    return [0.1, 0.2, 0.3]
+
+
+# ============================================
+# 示例 3: 使用上下文管理器
+# ============================================
+
+def example_context_manager():
+    """使用上下文管理器追踪性能"""
+    with LogPerformance("chat_processing", "deepseek-chat", "llm"):
+        # 执行耗时操作
+        result = call_llm_api("年假有多少天？")
+        return result
+
+
+def call_llm_api(prompt: str):
+    """模拟 LLM API 调用"""
+    time.sleep(0.2)
+    return "根据规定，年假天数与工龄挂钩..."
+
+
+# ============================================
+# 示例 4: 在 intelligence_analyzer 中集成
+# ============================================
+
+def analyze_with_logging(employee_input: str, session_id: str):
+    """
+    在分析器中集成日志记录
+    """
+    logger = get_supabase_logger()
+
+    # 记录输入
+    logger.log_debug(
+        level="INFO",
+        logger="intelligence_analyzer",
+        message=f"Processing input: {employee_input[:50]}...",
+        session_id=session_id
+    )
+
+    try:
+        # 场景识别
+        start_time = time.time()
+        scenario = detect_scenario(employee_input)
+
+        logger.log_debug(
+            level="INFO",
+            logger="intelligence_analyzer",
+            message="Scenario detected",
+            session_id=session_id,
+            data={"scenario": scenario, "confidence": 0.9}
+        )
+
+        # 记录用户行为
+        logger.log_user_behavior(
+            session_id=session_id,
+            action_type="chat",
+            action_detail="scenario_detection",
+            input_text=employee_input,
+            scenario_detected=scenario,
+            success=True
+        )
+
+        return scenario
+
+    except Exception as e:
+        # 记录错误
+        logger.log_error(
+            error_type="analysis_error",
+            error_message=str(e),
+            session_id=session_id,
+            user_input=employee_input
+        )
+        raise
+
+
+def detect_scenario(text: str) -> str:
+    """模拟场景检测"""
+    time.sleep(0.02)
+    return "policy_inquiry"
+
+
+# ============================================
+# 示例 5: 在 FastAPI 路由中集成
+# ============================================
+
+from fastapi import Request
+
+
+async def log_request_middleware(request: Request, call_next):
+    """
+    FastAPI 中间件 - 记录所有请求
+    """
+    logger = get_supabase_logger()
+    start_time = time.time()
+
+    # 处理请求
+    response = await call_next(request)
+
+    # 计算响应时间
+    process_time = int((time.time() - start_time) * 1000)
+
+    # 记录日志
+    logger.log_api_access(
+        endpoint=request.url.path,
+        method=request.method,
+        client_ip=request.client.host if request.client else None,
+        user_agent=request.headers.get("user-agent"),
+        session_id=request.headers.get("x-session-id"),
+        response_time_ms=process_time,
+        status_code=response.status_code
+    )
+
+    # 添加响应头
+    response.headers["X-Process-Time"] = str(process_time)
+    return response
+
+
+# ============================================
+# 示例 6: 批量日志记录
+# ============================================
+
+def batch_log_examples():
+    """批量日志记录示例"""
+    logger = get_supabase_logger()
+
+    # 批量记录用户行为
+    behaviors = [
+        {
+            "session_id": "user_1",
+            "action_type": "chat",
+            "scenario_detected": "policy_inquiry",
+            "success": True
+        },
+        {
+            "session_id": "user_1",
+            "action_type": "chat",
+            "scenario_detected": "leave_application",
+            "success": True
+        },
+        {
+            "session_id": "user_2",
+            "action_type": "evaluate",
+            "success": False,
+            "error_message": "Invalid dialogue format"
+        }
+    ]
+
+    for behavior in behaviors:
+        logger.log_user_behavior(**behavior)
+
+
+# ============================================
+# 示例 7: 错误追踪
+# ============================================
+
+def example_with_error_tracking():
+    """带错误追踪的示例"""
+    logger = get_supabase_logger()
+
+    try:
+        # 模拟错误
+        result = 1 / 0
+    except Exception as e:
+        import traceback
+
+        # 记录详细错误信息
+        logger.log_error(
+            error_type="calculation_error",
+            error_message=str(e),
+            error_stack=traceback.format_exc(),
+            session_id="debug_session",
+            request_data={"operation": "division", "operands": [1, 0]}
+        )
+
+
+# ============================================
+# 示例 8: 模型性能追踪
+# ============================================
+
+def track_all_models():
+    """追踪所有模型的性能"""
+    logger = get_supabase_logger()
+
+    models = {
+        "sbert": "KarenYYH/sbert-hr-v2",
+        "sentiment": "KarenYYH/sentiment-hr",
+        "llm": "deepseek-chat"
+    }
+
+    for model_type, model_name in models.items():
+        with LogPerformance(f"load_{model_type}", model_name, model_type):
+            # 模拟模型加载
+            time.sleep(0.1)
+
+
+# ============================================
+# 简化的日志记录
+# ============================================
+
+def example_simplified_logging():
+    """使用简化函数记录日志"""
+    # 调试日志
+    log_debug("intelligence_analyzer", "处理用户输入", level="INFO",
+              session_id="user_123", data={"input_length": 20})
+
+    # 错误日志
+    log_error("api_error", "请求超时", endpoint="/api/v1/chat",
+              session_id="user_123", response_time_ms=5000)
+
+
+# ============================================
+# 运行所有示例
+# ============================================
+
+if __name__ == "__main__":
+    print("运行 Supabase 日志示例...")
+
+    example_basic_logging()
+    print("✓ 基本日志记录")
+
+    process_chat_request("年假有多少天？", "user_123")
+    print("✓ API 日志装饰器")
+
+    encode_with_sbert("测试文本")
+    print("✓ 模型性能装饰器")
+
+    example_context_manager()
+    print("✓ 上下文管理器")
+
+    analyze_with_logging("年假有多少天？", "user_456")
+    print("✓ 分析器集成")
+
+    batch_log_examples()
+    print("✓ 批量日志")
+
+    example_with_error_tracking()
+    print("✓ 错误追踪")
+
+    track_all_models()
+    print("✓ 模型性能追踪")
+
+    example_simplified_logging()
+    print("✓ 简化日志")
+
+    print("\n所有示例运行完成！")

supabase_schema_with_logs.sql

@@ -0,0 +1,431 @@
+-- HR 对话质量评估系统 - Supabase 数据库表结构（含日志）
+-- 在 Supabase SQL Editor 中执行此脚本
+
+-- ============================================
+-- 1. 对话历史表（已有）
+-- ============================================
+CREATE TABLE IF NOT EXISTS conversation_history (
+    id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
+    session_id TEXT NOT NULL,
+    user_message TEXT NOT NULL,
+    assistant_message TEXT NOT NULL,
+    analysis_report JSONB,
+    context_summary JSONB,
+    metadata JSONB,
+    created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW()
+);
+
+CREATE INDEX IF NOT EXISTS idx_conversation_history_session_id ON conversation_history(session_id);
+CREATE INDEX IF NOT EXISTS idx_conversation_history_created_at ON conversation_history(created_at DESC);
+
+-- ============================================
+-- 2. API 访问日志表（新增）
+-- ============================================
+CREATE TABLE IF NOT EXISTS api_access_logs (
+    id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
+    timestamp TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
+
+    -- 请求信息
+    endpoint TEXT NOT NULL,
+    method TEXT NOT NULL,
+    path TEXT,
+    query_params JSONB,
+
+    -- 客户端信息
+    client_ip TEXT,
+    user_agent TEXT,
+    session_id TEXT,
+
+    -- 性能指标
+    response_time_ms INTEGER,
+    status_code INTEGER,
+
+    -- 附加信息
+    metadata JSONB
+);
+
+-- 索引优化
+CREATE INDEX IF NOT EXISTS idx_api_logs_timestamp ON api_access_logs(timestamp DESC);
+CREATE INDEX IF NOT EXISTS idx_api_logs_endpoint ON api_access_logs(endpoint);
+CREATE INDEX IF NOT EXISTS idx_api_logs_session_id ON api_access_logs(session_id);
+CREATE INDEX IF NOT EXISTS idx_api_logs_status_code ON api_access_logs(status_code);
+
+-- 分区（按月）- 可选，大数据量时使用
+-- CREATE TABLE api_access_logs_y2025m01 PARTITION OF api_access_logs
+--     FOR VALUES FROM ('2025-01-01') TO ('2025-02-01');
+
+-- ============================================
+-- 3. 错误日志表（新增）
+-- ============================================
+CREATE TABLE IF NOT EXISTS error_logs (
+    id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
+    timestamp TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
+
+    -- 错误信息
+    error_type TEXT NOT NULL,  -- 'validation', 'model_load', 'api_error', etc.
+    error_message TEXT NOT NULL,
+    error_stack TEXT,
+
+    -- 上下文
+    endpoint TEXT,
+    session_id TEXT,
+    user_input TEXT,
+
+    -- 请求详情
+    request_data JSONB,
+
+    -- 元数据
+    metadata JSONB
+);
+
+CREATE INDEX IF NOT EXISTS idx_error_logs_timestamp ON error_logs(timestamp DESC);
+CREATE INDEX IF NOT EXISTS idx_error_logs_type ON error_logs(error_type);
+CREATE INDEX IF NOT EXISTS idx_error_logs_session_id ON error_logs(session_id);
+
+-- ============================================
+-- 4. 模型性能日志表（新增）
+-- ============================================
+CREATE TABLE IF NOT EXISTS model_performance_logs (
+    id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
+    timestamp TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
+
+    -- 模型信息
+    model_name TEXT NOT NULL,
+    model_type TEXT NOT NULL,  -- 'sbert', 'sentiment', 'compliance', 'llm'
+
+    -- 性能指标
+    load_time_ms INTEGER,
+    inference_time_ms INTEGER,
+    total_time_ms INTEGER,
+
+    -- 输入输出
+    input_text TEXT,
+    output_summary TEXT,
+
+    -- 附加信息
+    metadata JSONB
+);
+
+CREATE INDEX IF NOT EXISTS idx_model_perf_timestamp ON model_performance_logs(timestamp DESC);
+CREATE INDEX IF NOT EXISTS idx_model_perf_model_name ON model_performance_logs(model_name);
+CREATE INDEX IF NOT EXISTS idx_model_perf_type ON model_performance_logs(model_type);
+
+-- ============================================
+-- 5. 调试日志表（新增）- 用于开发调试
+-- ============================================
+CREATE TABLE IF NOT EXISTS debug_logs (
+    id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
+    timestamp TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
+
+    -- 日志信息
+    level TEXT NOT NULL,  -- 'DEBUG', 'INFO', 'WARNING', 'ERROR'
+    logger TEXT NOT NULL,  -- 模块名称，如 'intelligence_analyzer'
+    message TEXT NOT NULL,
+
+    -- 上下文
+    session_id TEXT,
+    function_name TEXT,
+    line_number INTEGER,
+
+    -- 结构化数据
+    data JSONB,
+
+    -- 附加信息
+    metadata JSONB
+);
+
+CREATE INDEX IF NOT EXISTS idx_debug_logs_timestamp ON debug_logs(timestamp DESC);
+CREATE INDEX IF NOT EXISTS idx_debug_logs_level ON debug_logs(level);
+CREATE INDEX IF NOT EXISTS idx_debug_logs_logger ON debug_logs(logger);
+CREATE INDEX IF NOT EXISTS idx_debug_logs_session_id ON debug_logs(session_id);
+
+-- ============================================
+-- 6. 用户行为分析表（新增）
+-- ============================================
+CREATE TABLE IF NOT EXISTS user_behavior_logs (
+    id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
+    timestamp TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
+
+    -- 用户标识
+    session_id TEXT NOT NULL,
+    user_id TEXT,  -- 可选，如果有多用户系统
+
+    -- 行为类型
+    action_type TEXT NOT NULL,  -- 'chat', 'evaluate', 'config_check', etc.
+    action_detail TEXT,
+
+    -- 内容
+    input_text TEXT,
+    intent_detected TEXT,
+    scenario_detected TEXT,
+
+    -- 结果
+    success BOOLEAN,
+    error_message TEXT,
+
+    -- 元数据
+    metadata JSONB
+);
+
+CREATE INDEX IF NOT EXISTS idx_user_behavior_timestamp ON user_behavior_logs(timestamp DESC);
+CREATE INDEX IF NOT EXISTS idx_user_behavior_session_id ON user_behavior_logs(session_id);
+CREATE INDEX IF NOT EXISTS idx_user_behavior_action_type ON user_behavior_logs(action_type);
+
+-- ============================================
+-- 启用行级安全性 (RLS)
+-- ============================================
+ALTER TABLE api_access_logs ENABLE ROW LEVEL SECURITY;
+ALTER TABLE error_logs ENABLE ROW LEVEL SECURITY;
+ALTER TABLE model_performance_logs ENABLE ROW LEVEL SECURITY;
+ALTER TABLE debug_logs ENABLE ROW LEVEL SECURITY;
+ALTER TABLE user_behavior_logs ENABLE ROW LEVEL SECURITY;
+
+-- 允许所有操作（演示环境）
+CREATE POLICY "Enable all access for api_access_logs" ON api_access_logs FOR ALL USING (true);
+CREATE POLICY "Enable all access for error_logs" ON error_logs FOR ALL USING (true);
+CREATE POLICY "Enable all access for model_performance_logs" ON model_performance_logs FOR ALL USING (true);
+CREATE POLICY "Enable all access for debug_logs" ON debug_logs FOR ALL USING (true);
+CREATE POLICY "Enable all access for user_behavior_logs" ON user_behavior_logs FOR ALL USING (true);
+
+-- ============================================
+-- 实用函数
+-- ============================================
+
+-- 清理旧日志（保留最近 N 天）
+CREATE OR REPLACE FUNCTION cleanup_old_logs(days_to_keep INTEGER DEFAULT 30)
+RETURNS TABLE (
+    api_logs_deleted BIGINT,
+    error_logs_deleted BIGINT,
+    debug_logs_deleted BIGINT,
+    model_perf_logs_deleted BIGINT
+)
+LANGUAGE plpgsql
+AS $$
+DECLARE
+    api_count BIGINT;
+    error_count BIGINT;
+    debug_count BIGINT;
+    model_count BIGINT;
+BEGIN
+    -- 清理 API 日志
+    DELETE FROM api_access_logs
+    WHERE timestamp < NOW() - (days_to_keep || ' days')::INTERVAL;
+    GET DIAGNOSTICS api_count = ROW_COUNT;
+
+    -- 清理错误日志（保留更久）
+    DELETE FROM error_logs
+    WHERE timestamp < NOW() - ((days_to_keep * 2) || ' days')::INTERVAL;
+    GET DIAGNOSTICS error_count = ROW_COUNT;
+
+    -- 清理调试日志（保留更短时间）
+    DELETE FROM debug_logs
+    WHERE timestamp < NOW() - ((days_to_keep / 2) || ' days')::INTERVAL;
+    GET DIAGNOSTICS debug_count = ROW_COUNT;
+
+    -- 清理模型性能日志
+    DELETE FROM model_performance_logs
+    WHERE timestamp < NOW() - (days_to_keep || ' days')::INTERVAL;
+    GET DIAGNOSTICS model_count = ROW_COUNT;
+
+    RETURN QUERY SELECT api_count, error_count, debug_count, model_count;
+END;
+$$;
+
+-- 获取 API 统计
+CREATE OR REPLACE FUNCTION get_api_statistics(hours_ago INTEGER DEFAULT 24)
+RETURNS TABLE (
+    endpoint TEXT,
+    request_count BIGINT,
+    avg_response_time NUMERIC,
+    error_rate NUMERIC,
+    p95_response_time NUMERIC
+)
+LANGUAGE plpgsql
+AS $$
+BEGIN
+    RETURN QUERY
+    SELECT
+        endpoint,
+        COUNT(*) as request_count,
+        AVG(response_time_ms) as avg_response_time,
+        COUNT(*) FILTER (WHERE status_code >= 400) * 100.0 / COUNT(*) as error_rate,
+        PERCENTILE_CONT(0.95) WITHIN GROUP (ORDER BY response_time_ms) as p95_response_time
+    FROM api_access_logs
+    WHERE timestamp >= NOW() - (hours_ago || ' hours')::INTERVAL
+    GROUP BY endpoint
+    ORDER BY request_count DESC;
+END;
+$$;
+
+-- 获取错误统计
+CREATE OR REPLACE FUNCTION get_error_summary(hours_ago INTEGER DEFAULT 24)
+RETURNS TABLE (
+    error_type TEXT,
+    error_count BIGINT,
+    most_common_message TEXT
+)
+LANGUAGE plpgsql
+AS $$
+BEGIN
+    RETURN QUERY
+    SELECT
+        error_type,
+        COUNT(*) as error_count,
+        mode() WITHIN GROUP (ORDER BY error_message) as most_common_message
+    FROM error_logs
+    WHERE timestamp >= NOW() - (hours_ago || ' hours')::INTERVAL
+    GROUP BY error_type
+    ORDER BY error_count DESC;
+END;
+$$;
+
+-- 搜索日志
+CREATE OR REPLACE FUNCTION search_logs(
+    search_term TEXT,
+    log_type TEXT DEFAULT 'all',  -- 'api', 'error', 'debug', 'all'
+    hours_ago INTEGER DEFAULT 24,
+    limit_count INTEGER DEFAULT 100
+)
+RETURNS TABLE (
+    log_type TEXT,
+    log_id UUID,
+    timestamp TIMESTAMP WITH TIME ZONE,
+    summary TEXT
+)
+LANGUAGE plpgsql
+AS $$
+BEGIN
+    -- API 日志
+    IF log_type = 'api' OR log_type = 'all' THEN
+        RETURN QUERY
+        SELECT
+            'api'::TEXT as log_type,
+            id as log_id,
+            timestamp,
+            endpoint || ' - ' || status_code::TEXT as summary
+        FROM api_access_logs
+        WHERE (
+            search_term ILIKE '%' || search_term || '%'
+            OR endpoint ILIKE '%' || search_term || '%'
+            OR path ILIKE '%' || search_term || '%'
+        )
+        AND timestamp >= NOW() - (hours_ago || ' hours')::INTERVAL
+        LIMIT limit_count;
+    END IF;
+
+    -- 错误日志
+    IF log_type = 'error' OR log_type = 'all' THEN
+        RETURN QUERY
+        SELECT
+            'error'::TEXT as log_type,
+            id as log_id,
+            timestamp,
+            error_type || ' - ' || LEFT(error_message, 50) as summary
+        FROM error_logs
+        WHERE error_message ILIKE '%' || search_term || '%'
+        AND timestamp >= NOW() - (hours_ago || ' hours')::INTERVAL
+        LIMIT limit_count;
+    END IF;
+
+    -- 调试日志
+    IF log_type = 'debug' OR log_type = 'all' THEN
+        RETURN QUERY
+        SELECT
+            'debug'::TEXT as log_type,
+            id as log_id,
+            timestamp,
+            level || ' - ' || logger || ' - ' || LEFT(message, 50) as summary
+        FROM debug_logs
+        WHERE message ILIKE '%' || search_term || '%'
+        AND timestamp >= NOW() - (hours_ago || ' hours')::INTERVAL
+        LIMIT limit_count;
+    END IF;
+END;
+$$;
+
+-- ============================================
+-- 定时清理任务（可选）
+-- ============================================
+-- 创建一个函数来定期清理日志
+CREATE OR REPLACE FUNCTION auto_cleanup_logs()
+RETURNS VOID
+LANGUAGE plpgsql
+AS $$
+BEGIN
+    -- 清理 7 天前的调试日志
+    DELETE FROM debug_logs
+    WHERE timestamp < NOW() - INTERVAL '7 days';
+
+    -- 清理 30 天前的 API 日志
+    DELETE FROM api_access_logs
+    WHERE timestamp < NOW() - INTERVAL '30 days';
+
+    -- 清理 90 天前的模型性能日志
+    DELETE FROM model_performance_logs
+    WHERE timestamp < NOW() - INTERVAL '90 days';
+
+    -- 错误日志保留 180 天
+    DELETE FROM error_logs
+    WHERE timestamp < NOW() - INTERVAL '180 days';
+END;
+$$;
+
+-- 在 Supabase Dashboard 中设置 cron job 来调用这个函数
+-- 或者使用 pg_cron 扩展（如果可用）
+-- SELECT cron.schedule('cleanup-logs', '0 2 * * *', 'SELECT auto_cleanup_logs()');
+
+-- ============================================
+-- 视图 - 方便查询
+-- ============================================
+
+-- 综合日志视图
+CREATE OR REPLACE VIEW v_recent_logs AS
+SELECT
+    'api' as log_type,
+    timestamp,
+    endpoint as title,
+    status_code::TEXT as detail,
+    session_id
+FROM api_access_logs
+WHERE timestamp >= NOW() - INTERVAL '24 hours'
+
+UNION ALL
+
+SELECT
+    'error' as log_type,
+    timestamp,
+    error_type as title,
+    LEFT(error_message, 50) as detail,
+    session_id
+FROM error_logs
+WHERE timestamp >= NOW() - INTERVAL '24 hours'
+
+UNION ALL
+
+SELECT
+    'debug' as log_type,
+    timestamp,
+    logger as title,
+    level || ' - ' || LEFT(message, 30) as detail,
+    session_id
+FROM debug_logs
+WHERE timestamp >= NOW() - INTERVAL '24 hours'
+
+ORDER BY timestamp DESC
+LIMIT 100;
+
+-- ============================================
+-- 注释
+-- ============================================
+COMMENT ON TABLE api_access_logs IS 'API 访问日志';
+COMMENT ON TABLE error_logs IS '错误日志';
+COMMENT ON TABLE model_performance_logs IS '模型性能日志';
+COMMENT ON TABLE debug_logs IS '调试日志';
+COMMENT ON TABLE user_behavior_logs IS '用户行为日志';
+
+COMMENT ON FUNCTION cleanup_old_logs IS '清理旧日志，默认保留 30 天';
+COMMENT ON FUNCTION get_api_statistics IS '获取 API 统计信息';
+COMMENT ON FUNCTION get_error_summary IS '获取错误摘要';
+COMMENT ON FUNCTION search_logs IS '搜索日志内容';
+COMMENT ON FUNCTION auto_cleanup_logs IS '自动清理日志';
+COMMENT ON VIEW v_recent_logs IS '最近 24 小时的综合日志视图';