@@ -367,7 +507,12 @@ function formatBotMessage(text) {{
function addMessage(role, text) {{
const div = document.createElement('div');
div.className = 'bubble ' + role;
- const avatar = role === 'user' ? '👤' : (role === 'bot' ? '🤖' : '⚠️');
+
+ const userSvg = '
';
+ const botSvg = '
';
+ const errorSvg = '
';
+
+ const avatar = role === 'user' ? userSvg : (role === 'bot' ? botSvg : errorSvg);
let contentHtml;
if (role === 'bot') {{
diff --git a/ai-service/app/main.py b/ai-service/app/main.py
index 119ec44..336be0d 100644
--- a/ai-service/app/main.py
+++ b/ai-service/app/main.py
@@ -4,6 +4,8 @@ Main FastAPI application for AI Service.
"""
import logging
+import os
+from logging.handlers import RotatingFileHandler
from contextlib import asynccontextmanager
from fastapi import FastAPI, Request, status
@@ -52,15 +54,51 @@ from app.core.qdrant_client import close_qdrant_client
settings = get_settings()
-logging.basicConfig(
- level=getattr(logging, settings.log_level.upper()),
- format="%(asctime)s - %(name)s - %(levelname)s - %(message)s",
-)
-logging.getLogger("sqlalchemy.engine").setLevel(logging.WARNING)
-logging.getLogger("sqlalchemy.pool").setLevel(logging.WARNING)
-logging.getLogger("sqlalchemy.dialects").setLevel(logging.WARNING)
-logging.getLogger("sqlalchemy.orm").setLevel(logging.WARNING)
+def setup_logging():
+ """
+ 配置滚动日志文件。
+ - 日志文件存储在 logs/ 目录
+ - 单文件最大 2MB，超过则切分
+ - 保留最近 7 天的日志（约 70 个备份文件）
+ - 同时输出到控制台
+ """
+ log_dir = os.path.join(os.path.dirname(os.path.dirname(__file__)), "logs")
+ os.makedirs(log_dir, exist_ok=True)
+
+ log_format = "%(asctime)s - %(name)s - %(levelname)s - %(message)s"
+ formatter = logging.Formatter(log_format)
+
+ root_logger = logging.getLogger()
+ root_logger.setLevel(getattr(logging, settings.log_level.upper()))
+
+ root_logger.handlers.clear()
+
+ console_handler = logging.StreamHandler()
+ console_handler.setLevel(getattr(logging, settings.log_level.upper()))
+ console_handler.setFormatter(formatter)
+ root_logger.addHandler(console_handler)
+
+ log_file = os.path.join(log_dir, "ai-service.log")
+ file_handler = RotatingFileHandler(
+ filename=log_file,
+ maxBytes=2 * 1024 * 1024,
+ backupCount=70,
+ encoding="utf-8",
+ )
+ file_handler.setLevel(getattr(logging, settings.log_level.upper()))
+ file_handler.setFormatter(formatter)
+ root_logger.addHandler(file_handler)
+
+ logging.getLogger("sqlalchemy.engine").setLevel(logging.WARNING)
+ logging.getLogger("sqlalchemy.pool").setLevel(logging.WARNING)
+ logging.getLogger("sqlalchemy.dialects").setLevel(logging.WARNING)
+ logging.getLogger("sqlalchemy.orm").setLevel(logging.WARNING)
+
+ return log_dir
+
+
+setup_logging()
logger = logging.getLogger(__name__)
diff --git a/ai-service/app/models/entities.py b/ai-service/app/models/entities.py
index 445dc26..77f9a7d 100644
--- a/ai-service/app/models/entities.py
+++ b/ai-service/app/models/entities.py
@@ -116,6 +116,44 @@ class ChatMessageCreate(SQLModel):
content: str
+class UserMemory(SQLModel, table=True):
+ """
+ [AC-IDMP-14] 用户级记忆存储（滚动摘要）
+ 支持多租户隔离，存储最新 summary + facts/preferences/open_issues
+ """
+
+ __tablename__ = "user_memories"
+ __table_args__ = (
+ Index("ix_user_memories_tenant_user", "tenant_id", "user_id"),
+ Index("ix_user_memories_tenant_user_updated", "tenant_id", "user_id", "updated_at"),
+ )
+
+ id: uuid.UUID = Field(default_factory=uuid.uuid4, primary_key=True)
+ tenant_id: str = Field(..., description="Tenant ID for multi-tenant isolation", index=True)
+ user_id: str = Field(..., description="User ID for memory storage", index=True)
+ summary: str | None = Field(default=None, description="Rolling summary for user")
+ facts: list[str] | None = Field(
+ default=None,
+ sa_column=Column("facts", JSON, nullable=True),
+ description="Extracted stable facts list",
+ )
+ preferences: dict[str, Any] | None = Field(
+ default=None,
+ sa_column=Column("preferences", JSON, nullable=True),
+ description="User preferences as structured JSON",
+ )
+ open_issues: list[str] | None = Field(
+ default=None,
+ sa_column=Column("open_issues", JSON, nullable=True),
+ description="Open issues list",
+ )
+ summary_version: int = Field(default=1, description="Summary version / update round")
+ last_turn_id: str | None = Field(default=None, description="Last turn identifier (optional)")
+ expires_at: datetime | None = Field(default=None, description="Expiration time (optional)")
+ created_at: datetime = Field(default_factory=datetime.utcnow, description="Creation time")
+ updated_at: datetime = Field(default_factory=datetime.utcnow, description="Last update time")
+
+
class SharedSession(SQLModel, table=True):
"""
[AC-IDMP-SHARE] Shared session entity for dialogue sharing.