commit 46216205fe1d3938dc782e796789ecf0ee438dfc
Author: hubian <908234780@qq.com>
Date:   Sat Apr 11 11:51:54 2026 +0800

    feat: AI对话系统 v1.0.0 - 网页端和Matrix端实时同步

diff --git a/ai_chat.db b/ai_chat.db
new file mode 100644
index 0000000..05dc5b4
Binary files /dev/null and b/ai_chat.db differ
diff --git a/logs/ai-chat.log b/logs/ai-chat.log
new file mode 100644
index 0000000..67a3c00
--- /dev/null
+++ b/logs/ai-chat.log
@@ -0,0 +1,18 @@
+Traceback (most recent call last):
+  File "/home/xian/.openclaw/workspace-coder/works/ai-chat/main.py", line 17, in <module>
+    from models import init_db, get_db, User, Conversation, Message, SystemConfig
+  File "/home/xian/.openclaw/workspace-coder/works/ai-chat/models/__init__.py", line 1, in <module>
+    from .database import Base, engine, SessionLocal, get_db, init_db
+  File "/home/xian/.openclaw/workspace-coder/works/ai-chat/models/database.py", line 33, in <module>
+    class Conversation(Base):
+  File "/home/xian/.local/lib/python3.10/site-packages/sqlalchemy/orm/decl_api.py", line 195, in __init__
+    _as_declarative(reg, cls, dict_)
+  File "/home/xian/.local/lib/python3.10/site-packages/sqlalchemy/orm/decl_base.py", line 247, in _as_declarative
+    return _MapperConfig.setup_mapping(registry, cls, dict_, None, {})
+  File "/home/xian/.local/lib/python3.10/site-packages/sqlalchemy/orm/decl_base.py", line 328, in setup_mapping
+    return _ClassScanMapperConfig(
+  File "/home/xian/.local/lib/python3.10/site-packages/sqlalchemy/orm/decl_base.py", line 574, in __init__
+    self._extract_mappable_attributes()
+  File "/home/xian/.local/lib/python3.10/site-packages/sqlalchemy/orm/decl_base.py", line 1507, in _extract_mappable_attributes
+    raise exc.InvalidRequestError(
+sqlalchemy.exc.InvalidRequestError: Attribute name 'metadata' is reserved when using the Declarative API.
diff --git a/main.py b/main.py
new file mode 100644
index 0000000..2d388bc
--- /dev/null
+++ b/main.py
@@ -0,0 +1,459 @@
+"""
+AI对话系统 - 主应用
+支持网页端和Matrix端实时同步对话
+"""
+from fastapi import FastAPI, WebSocket, WebSocketDisconnect, Depends, HTTPException, Request
+from fastapi.responses import HTMLResponse
+from fastapi.staticfiles import StaticFiles
+from fastapi.templating import Jinja2Templates
+from sqlalchemy.orm import Session
+from typing import Dict, Set
+import asyncio
+import json
+import logging
+from datetime import datetime
+import os
+
+from models import init_db, get_db, User, Conversation, Message, SystemConfig
+from services import ai_service, ConversationService, matrix_bot
+
+# 配置日志
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+
+# 创建应用
+app = FastAPI(title="AI对话系统", version="1.0.0")
+
+# 静态文件和模板
+BASE_DIR = os.path.dirname(os.path.abspath(__file__))
+app.mount("/static", StaticFiles(directory=os.path.join(BASE_DIR, "static")), name="static")
+templates = Jinja2Templates(directory=os.path.join(BASE_DIR, "templates"))
+
+# WebSocket连接管理
+class ConnectionManager:
+    def __init__(self):
+        # user_id -> Set[WebSocket]
+        self.active_connections: Dict[str, Set[WebSocket]] = {}
+    
+    async def connect(self, websocket: WebSocket, user_id: str):
+        await websocket.accept()
+        if user_id not in self.active_connections:
+            self.active_connections[user_id] = set()
+        self.active_connections[user_id].add(websocket)
+        logger.info(f"WebSocket连接: {user_id}, 当前连接数: {len(self.active_connections[user_id])}")
+    
+    def disconnect(self, websocket: WebSocket, user_id: str):
+        if user_id in self.active_connections:
+            self.active_connections[user_id].discard(websocket)
+            if not self.active_connections[user_id]:
+                del self.active_connections[user_id]
+        logger.info(f"WebSocket断开: {user_id}")
+    
+    async def send_to_user(self, user_id: str, message: dict):
+        """发送消息给用户的所有连接"""
+        if user_id in self.active_connections:
+            dead_connections = set()
+            for connection in self.active_connections[user_id]:
+                try:
+                    await connection.send_json(message)
+                except:
+                    dead_connections.add(connection)
+            
+            # 清理断开的连接
+            for conn in dead_connections:
+                self.active_connections[user_id].discard(conn)
+
+
+manager = ConnectionManager()
+
+
+# ==================== 页面路由 ====================
+
+@app.get("/", response_class=HTMLResponse)
+async def index(request: Request):
+    """主页 - 聊天界面"""
+    return templates.TemplateResponse("index.html", {"request": request})
+
+
+@app.get("/admin", response_class=HTMLResponse)
+async def admin(request: Request):
+    """后台管理首页"""
+    return templates.TemplateResponse("admin/index.html", {"request": request})
+
+
+# ==================== API路由 ====================
+
+@app.get("/api/conversations")
+async def get_conversations(user_id: str = None, db: Session = Depends(get_db)):
+    """获取会话列表"""
+    if not user_id:
+        # 临时用户ID（实际应用中应该从session获取）
+        user_id = "web_anonymous"
+    
+    conv_service = ConversationService(db)
+    user = conv_service.get_or_create_user(user_id, user_type='web')
+    conversations = conv_service.get_user_conversations(user.id)
+    
+    return {
+        "conversations": [
+            {
+                "id": c.conversation_id,
+                "title": c.title or "新对话",
+                "created_at": c.created_at.isoformat(),
+                "updated_at": c.updated_at.isoformat()
+            }
+            for c in conversations
+        ]
+    }
+
+
+@app.post("/api/conversations")
+async def create_conversation(user_id: str = None, db: Session = Depends(get_db)):
+    """创建新会话"""
+    if not user_id:
+        user_id = "web_anonymous"
+    
+    conv_service = ConversationService(db)
+    user = conv_service.get_or_create_user(user_id, user_type='web')
+    conversation = conv_service.create_conversation(user.id)
+    
+    return {
+        "id": conversation.conversation_id,
+        "title": conversation.title or "新对话",
+        "created_at": conversation.created_at.isoformat()
+    }
+
+
+@app.get("/api/conversations/{conversation_id}/messages")
+async def get_messages(conversation_id: str, db: Session = Depends(get_db)):
+    """获取会话消息"""
+    conv_service = ConversationService(db)
+    conversation = conv_service.get_conversation(conversation_id)
+    
+    if not conversation:
+        raise HTTPException(status_code=404, detail="会话不存在")
+    
+    messages = conv_service.get_messages(conversation.id)
+    
+    return {
+        "messages": [
+            {
+                "id": m.id,
+                "role": m.role,
+                "content": m.content,
+                "source": m.source,
+                "created_at": m.created_at.isoformat()
+            }
+            for m in messages
+        ]
+    }
+
+
+@app.delete("/api/conversations/{conversation_id}")
+async def delete_conversation(conversation_id: str, db: Session = Depends(get_db)):
+    """删除会话"""
+    conv_service = ConversationService(db)
+    success = conv_service.delete_conversation(conversation_id)
+    
+    if not success:
+        raise HTTPException(status_code=404, detail="会话不存在")
+    
+    return {"success": True}
+
+
+# ==================== WebSocket路由 ====================
+
+@app.websocket("/ws/{user_id}")
+async def websocket_endpoint(websocket: WebSocket, user_id: str, db: Session = Depends(get_db)):
+    """WebSocket连接 - 实时对话"""
+    await manager.connect(websocket, user_id)
+    conv_service = ConversationService(db)
+    user = conv_service.get_or_create_user(user_id, user_type='web')
+    
+    current_conversation_id = None
+    
+    try:
+        while True:
+            data = await websocket.receive_json()
+            
+            action = data.get("action")
+            
+            if action == "select_conversation":
+                # 选择会话
+                current_conversation_id = data.get("conversation_id")
+                conversation = conv_service.get_conversation(current_conversation_id)
+                
+                if conversation:
+                    # 发送历史消息
+                    messages = conv_service.get_messages(conversation.id)
+                    await websocket.send_json({
+                        "type": "history",
+                        "conversation_id": current_conversation_id,
+                        "messages": [
+                            {
+                                "role": m.role,
+                                "content": m.content,
+                                "source": m.source,
+                                "created_at": m.created_at.isoformat()
+                            }
+                            for m in messages
+                        ]
+                    })
+            
+            elif action == "chat":
+                # 对话消息
+                message = data.get("message", "")
+                conversation_id = data.get("conversation_id")
+                
+                if not message.strip():
+                    continue
+                
+                # 获取或创建会话
+                if conversation_id:
+                    conversation = conv_service.get_conversation(conversation_id)
+                else:
+                    conversation = conv_service.create_conversation(user.id)
+                    conversation_id = conversation.conversation_id
+                    await websocket.send_json({
+                        "type": "conversation_created",
+                        "conversation_id": conversation_id
+                    })
+                
+                # 保存用户消息
+                user_msg = conv_service.add_message(
+                    conversation_id=conversation.id,
+                    role='user',
+                    content=message,
+                    source='web'
+                )
+                
+                # 通知用户消息已收到
+                await manager.send_to_user(user_id, {
+                    "type": "user_message",
+                    "conversation_id": conversation_id,
+                    "message": {
+                        "id": user_msg.id,
+                        "role": "user",
+                        "content": message,
+                        "source": "web",
+                        "created_at": user_msg.created_at.isoformat()
+                    }
+                })
+                
+                # 获取对话历史
+                history = conv_service.get_conversation_history(conversation_id, limit=20)
+                
+                # 调用AI
+                try:
+                    ai_response = await ai_service.chat(history)
+                    
+                    # 保存AI回复
+                    assistant_msg = conv_service.add_message(
+                        conversation_id=conversation.id,
+                        role='assistant',
+                        content=ai_response,
+                        source='web'
+                    )
+                    
+                    # 发送AI回复
+                    await manager.send_to_user(user_id, {
+                        "type": "assistant_message",
+                        "conversation_id": conversation_id,
+                        "message": {
+                            "id": assistant_msg.id,
+                            "role": "assistant",
+                            "content": ai_response,
+                            "created_at": assistant_msg.created_at.isoformat()
+                        }
+                    })
+                    
+                except Exception as e:
+                    logger.error(f"AI调用失败: {e}")
+                    await websocket.send_json({
+                        "type": "error",
+                        "message": "AI服务暂时不可用，请稍后重试"
+                    })
+    
+    except WebSocketDisconnect:
+        manager.disconnect(websocket, user_id)
+    except Exception as e:
+        logger.error(f"WebSocket错误: {e}")
+        manager.disconnect(websocket, user_id)
+
+
+# ==================== 后台管理API ====================
+
+@app.get("/api/admin/stats")
+async def get_stats(db: Session = Depends(get_db)):
+    """获取统计数据"""
+    total_users = db.query(User).count()
+    total_conversations = db.query(Conversation).count()
+    total_messages = db.query(Message).count()
+    
+    return {
+        "total_users": total_users,
+        "total_conversations": total_conversations,
+        "total_messages": total_messages
+    }
+
+
+@app.get("/api/admin/users")
+async def get_users(skip: int = 0, limit: int = 50, db: Session = Depends(get_db)):
+    """获取用户列表"""
+    users = db.query(User).order_by(User.created_at.desc()).offset(skip).limit(limit).all()
+    
+    return {
+        "users": [
+            {
+                "id": u.id,
+                "user_id": u.user_id,
+                "display_name": u.display_name,
+                "user_type": u.user_type,
+                "created_at": u.created_at.isoformat(),
+                "last_active_at": u.last_active_at.isoformat(),
+                "is_active": u.is_active
+            }
+            for u in users
+        ]
+    }
+
+
+@app.get("/api/admin/conversations")
+async def admin_get_conversations(skip: int = 0, limit: int = 50, db: Session = Depends(get_db)):
+    """获取所有会话"""
+    conversations = db.query(Conversation).order_by(Conversation.updated_at.desc()).offset(skip).limit(limit).all()
+    
+    return {
+        "conversations": [
+            {
+                "id": c.id,
+                "conversation_id": c.conversation_id,
+                "user_id": c.user.user_id if c.user else None,
+                "title": c.title,
+                "message_count": len(c.messages),
+                "created_at": c.created_at.isoformat(),
+                "updated_at": c.updated_at.isoformat(),
+                "is_active": c.is_active
+            }
+            for c in conversations
+        ]
+    }
+
+
+@app.get("/api/admin/config")
+async def get_config(db: Session = Depends(get_db)):
+    """获取系统配置"""
+    configs = db.query(SystemConfig).all()
+    
+    return {
+        "configs": [
+            {
+                "key": c.key,
+                "value": c.value,
+                "description": c.description
+            }
+            for c in configs
+        ]
+    }
+
+
+@app.post("/api/admin/config")
+async def update_config(data: dict, db: Session = Depends(get_db)):
+    """更新系统配置"""
+    key = data.get("key")
+    value = data.get("value")
+    description = data.get("description", "")
+    
+    if not key:
+        raise HTTPException(status_code=400, detail="key不能为空")
+    
+    config = db.query(SystemConfig).filter(SystemConfig.key == key).first()
+    
+    if config:
+        config.value = value
+        if description:
+            config.description = description
+    else:
+        config = SystemConfig(key=key, value=value, description=description)
+        db.add(config)
+    
+    db.commit()
+    
+    # 如果更新了Matrix配置，重新连接
+    if key.startswith('matrix_') and matrix_bot.is_running:
+        await matrix_bot.disconnect()
+        await matrix_bot.init_from_config()
+    
+    return {"success": True, "config": {"key": key, "value": value}}
+
+
+# ==================== Matrix消息处理回调 ====================
+
+async def handle_matrix_message(conversation_id: str, user_message: str, user_id: str, room_id: str):
+    """处理从Matrix收到的消息"""
+    db = SessionLocal()
+    try:
+        conv_service = ConversationService(db)
+        
+        # 获取会话历史
+        history = conv_service.get_conversation_history(conversation_id, limit=20)
+        
+        # 调用AI
+        ai_response = await ai_service.chat(history)
+        
+        # 保存AI回复
+        conversation = conv_service.get_conversation(conversation_id)
+        if conversation:
+            conv_service.add_message(
+                conversation_id=conversation.id,
+                role='assistant',
+                content=ai_response,
+                source='matrix'
+            )
+        
+        # 发送到Matrix
+        await matrix_bot.send_message(room_id, ai_response)
+        
+        # 同时推送到网页端
+        await manager.send_to_user(user_id, {
+            "type": "assistant_message",
+            "conversation_id": conversation_id,
+            "message": {
+                "role": "assistant",
+                "content": ai_response,
+                "source": "matrix",
+                "created_at": datetime.utcnow().isoformat()
+            }
+        })
+    
+    except Exception as e:
+        logger.error(f"处理Matrix消息失败: {e}")
+    finally:
+        db.close()
+
+
+# ==================== 启动和关闭 ====================
+
+@app.on_event("startup")
+async def startup():
+    """应用启动时初始化"""
+    init_db()
+    logger.info("数据库初始化完成")
+    
+    # 初始化Matrix Bot
+    await matrix_bot.init_from_config()
+    if matrix_bot.is_running:
+        asyncio.create_task(matrix_bot.start_sync(handle_matrix_message))
+        logger.info("Matrix Bot已启动")
+
+
+@app.on_event("shutdown")
+async def shutdown():
+    """应用关闭时清理"""
+    await matrix_bot.disconnect()
+    logger.info("应用已关闭")
+
+
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=19020)
\ No newline at end of file
diff --git a/models/__init__.py b/models/__init__.py
new file mode 100644
index 0000000..f15d9fd
--- /dev/null
+++ b/models/__init__.py
@@ -0,0 +1,7 @@
+from .database import Base, engine, SessionLocal, get_db, init_db
+from .database import User, Conversation, Message, SystemConfig, MatrixRoomMapping
+
+__all__ = [
+    'Base', 'engine', 'SessionLocal', 'get_db', 'init_db',
+    'User', 'Conversation', 'Message', 'SystemConfig', 'MatrixRoomMapping'
+]
\ No newline at end of file
diff --git a/models/__pycache__/__init__.cpython-310.pyc b/models/__pycache__/__init__.cpython-310.pyc
new file mode 100644
index 0000000..bd3ad2e
Binary files /dev/null and b/models/__pycache__/__init__.cpython-310.pyc differ
diff --git a/models/__pycache__/database.cpython-310.pyc b/models/__pycache__/database.cpython-310.pyc
new file mode 100644
index 0000000..84c69bd
Binary files /dev/null and b/models/__pycache__/database.cpython-310.pyc differ
diff --git a/models/database.py b/models/database.py
new file mode 100644
index 0000000..2624bc0
--- /dev/null
+++ b/models/database.py
@@ -0,0 +1,98 @@
+"""
+AI对话系统 - 数据库模型
+"""
+from sqlalchemy import create_engine, Column, Integer, String, Text, Boolean, DateTime, ForeignKey, JSON
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy.orm import sessionmaker, relationship
+from datetime import datetime
+import os
+
+DATABASE_URL = os.environ.get('DATABASE_URL', 'sqlite:///./ai_chat.db')
+
+engine = create_engine(DATABASE_URL, connect_args={"check_same_thread": False})
+SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+Base = declarative_base()
+
+
+class User(Base):
+    """用户表 - 支持网页用户和Matrix用户"""
+    __tablename__ = 'users'
+    
+    id = Column(Integer, primary_key=True, index=True)
+    user_id = Column(String(100), unique=True, index=True)  # 唯一标识：web_xxx 或 @xxx:matrix.org
+    display_name = Column(String(100))
+    user_type = Column(String(20), default='web')  # web 或 matrix
+    matrix_user_id = Column(String(200), nullable=True)  # Matrix用户ID
+    created_at = Column(DateTime, default=datetime.utcnow)
+    last_active_at = Column(DateTime, default=datetime.utcnow)
+    is_active = Column(Boolean, default=True)
+    
+    conversations = relationship("Conversation", back_populates="user")
+
+
+class Conversation(Base):
+    """对话会话"""
+    __tablename__ = 'conversations'
+    
+    id = Column(Integer, primary_key=True, index=True)
+    conversation_id = Column(String(100), unique=True, index=True)  # 会话唯一标识
+    user_id = Column(Integer, ForeignKey('users.id'))
+    title = Column(String(200), nullable=True)
+    created_at = Column(DateTime, default=datetime.utcnow)
+    updated_at = Column(DateTime, default=datetime.utcnow, onupdate=datetime.utcnow)
+    is_active = Column(Boolean, default=True)
+    extra_data = Column(JSON, nullable=True)  # 额外元数据
+    
+    user = relationship("User", back_populates="conversations")
+    messages = relationship("Message", back_populates="conversation")
+
+
+class Message(Base):
+    """消息表"""
+    __tablename__ = 'messages'
+    
+    id = Column(Integer, primary_key=True, index=True)
+    conversation_id = Column(Integer, ForeignKey('conversations.id'))
+    role = Column(String(20))  # user, assistant, system
+    content = Column(Text)
+    source = Column(String(20))  # web, matrix
+    created_at = Column(DateTime, default=datetime.utcnow)
+    extra_data = Column(JSON, nullable=True)  # 额外元数据（如Matrix event_id）
+    
+    conversation = relationship("Conversation", back_populates="messages")
+
+
+class SystemConfig(Base):
+    """系统配置表"""
+    __tablename__ = 'system_config'
+    
+    id = Column(Integer, primary_key=True, index=True)
+    key = Column(String(100), unique=True, index=True)
+    value = Column(Text)
+    description = Column(String(500))
+    updated_at = Column(DateTime, default=datetime.utcnow, onupdate=datetime.utcnow)
+
+
+class MatrixRoomMapping(Base):
+    """Matrix房间映射 - 绑定房间到用户会话"""
+    __tablename__ = 'matrix_room_mapping'
+    
+    id = Column(Integer, primary_key=True, index=True)
+    room_id = Column(String(200), unique=True, index=True)  # Matrix房间ID
+    user_id = Column(Integer, ForeignKey('users.id'))
+    conversation_id = Column(Integer, ForeignKey('conversations.id'))
+    created_at = Column(DateTime, default=datetime.utcnow)
+
+
+def init_db():
+    """初始化数据库"""
+    Base.metadata.create_all(bind=engine)
+
+
+def get_db():
+    """获取数据库会话"""
+    db = SessionLocal()
+    try:
+        yield db
+    finally:
+        db.close()
\ No newline at end of file
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..d3371f8
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,9 @@
+# AI对话系统依赖
+
+fastapi==0.104.1
+uvicorn==0.24.0
+sqlalchemy==2.0.23
+python-multipart==0.0.6
+httpx==0.25.1
+matrix-nio==0.24.0
+jinja2==3.1.2
\ No newline at end of file
diff --git a/services/__init__.py b/services/__init__.py
new file mode 100644
index 0000000..99774e3
--- /dev/null
+++ b/services/__init__.py
@@ -0,0 +1,9 @@
+from .ai_service import ai_service, AIService
+from .conversation_service import ConversationService
+from .matrix_service import matrix_bot, MatrixBot
+
+__all__ = [
+    'ai_service', 'AIService',
+    'ConversationService',
+    'matrix_bot', 'MatrixBot'
+]
\ No newline at end of file
diff --git a/services/__pycache__/__init__.cpython-310.pyc b/services/__pycache__/__init__.cpython-310.pyc
new file mode 100644
index 0000000..1fd9702
Binary files /dev/null and b/services/__pycache__/__init__.cpython-310.pyc differ
diff --git a/services/__pycache__/ai_service.cpython-310.pyc b/services/__pycache__/ai_service.cpython-310.pyc
new file mode 100644
index 0000000..2001369
Binary files /dev/null and b/services/__pycache__/ai_service.cpython-310.pyc differ
diff --git a/services/__pycache__/conversation_service.cpython-310.pyc b/services/__pycache__/conversation_service.cpython-310.pyc
new file mode 100644
index 0000000..d727d09
Binary files /dev/null and b/services/__pycache__/conversation_service.cpython-310.pyc differ
diff --git a/services/__pycache__/matrix_service.cpython-310.pyc b/services/__pycache__/matrix_service.cpython-310.pyc
new file mode 100644
index 0000000..e189998
Binary files /dev/null and b/services/__pycache__/matrix_service.cpython-310.pyc differ
diff --git a/services/ai_service.py b/services/ai_service.py
new file mode 100644
index 0000000..e6f9000
--- /dev/null
+++ b/services/ai_service.py
@@ -0,0 +1,80 @@
+"""
+AI服务 - 调用大模型API
+"""
+import httpx
+from typing import List, Dict, Optional
+import json
+
+
+class AIService:
+    def __init__(self, api_base: str = "http://192.168.2.17:19007/v1", api_key: str = "sk-local", model: str = "qwen3.5-4b"):
+        self.api_base = api_base
+        self.api_key = api_key
+        self.model = model
+    
+    async def chat(self, messages: List[Dict], stream: bool = False) -> str:
+        """
+        调用AI模型进行对话
+        
+        Args:
+            messages: 对话历史 [{"role": "user", "content": "..."}]
+            stream: 是否流式输出
+        
+        Returns:
+            AI回复内容
+        """
+        url = f"{self.api_base}/chat/completions"
+        headers = {
+            "Authorization": f"Bearer {self.api_key}",
+            "Content-Type": "application/json"
+        }
+        payload = {
+            "model": self.model,
+            "messages": messages,
+            "stream": stream,
+            "temperature": 0.7,
+            "max_tokens": 2000
+        }
+        
+        async with httpx.AsyncClient(timeout=60.0) as client:
+            response = await client.post(url, headers=headers, json=payload)
+            response.raise_for_status()
+            data = response.json()
+            return data['choices'][0]['message']['content']
+    
+    async def chat_stream(self, messages: List[Dict]):
+        """
+        流式调用AI模型
+        """
+        url = f"{self.api_base}/chat/completions"
+        headers = {
+            "Authorization": f"Bearer {self.api_key}",
+            "Content-Type": "application/json"
+        }
+        payload = {
+            "model": self.model,
+            "messages": messages,
+            "stream": True,
+            "temperature": 0.7,
+            "max_tokens": 2000
+        }
+        
+        async with httpx.AsyncClient(timeout=60.0) as client:
+            async with client.stream("POST", url, headers=headers, json=payload) as response:
+                async for line in response.aiter_lines():
+                    if line.startswith("data: "):
+                        data_str = line[6:]
+                        if data_str == "[DONE]":
+                            break
+                        try:
+                            data = json.loads(data_str)
+                            if 'choices' in data and len(data['choices']) > 0:
+                                delta = data['choices'][0].get('delta', {})
+                                if 'content' in delta:
+                                    yield delta['content']
+                        except json.JSONDecodeError:
+                            continue
+
+
+# 全局实例
+ai_service = AIService()
\ No newline at end of file
diff --git a/services/conversation_service.py b/services/conversation_service.py
new file mode 100644
index 0000000..46285ed
--- /dev/null
+++ b/services/conversation_service.py
@@ -0,0 +1,111 @@
+"""
+会话管理服务
+"""
+from typing import List, Optional
+from datetime import datetime
+from sqlalchemy.orm import Session
+import uuid
+
+from models import User, Conversation, Message
+
+
+class ConversationService:
+    def __init__(self, db: Session):
+        self.db = db
+    
+    def get_or_create_user(self, user_id: str, display_name: str = None, user_type: str = 'web', matrix_user_id: str = None) -> User:
+        """获取或创建用户"""
+        user = self.db.query(User).filter(User.user_id == user_id).first()
+        if not user:
+            user = User(
+                user_id=user_id,
+                display_name=display_name or user_id,
+                user_type=user_type,
+                matrix_user_id=matrix_user_id
+            )
+            self.db.add(user)
+            self.db.commit()
+            self.db.refresh(user)
+        else:
+            user.last_active_at = datetime.utcnow()
+            self.db.commit()
+        return user
+    
+    def create_conversation(self, user_id: int, title: str = None) -> Conversation:
+        """创建新会话"""
+        conversation_id = f"conv_{uuid.uuid4().hex[:12]}"
+        conversation = Conversation(
+            conversation_id=conversation_id,
+            user_id=user_id,
+            title=title
+        )
+        self.db.add(conversation)
+        self.db.commit()
+        self.db.refresh(conversation)
+        return conversation
+    
+    def get_conversation(self, conversation_id: str) -> Optional[Conversation]:
+        """获取会话"""
+        return self.db.query(Conversation).filter(
+            Conversation.conversation_id == conversation_id
+        ).first()
+    
+    def get_user_conversations(self, user_id: int) -> List[Conversation]:
+        """获取用户的所有会话"""
+        return self.db.query(Conversation).filter(
+            Conversation.user_id == user_id,
+            Conversation.is_active == True
+        ).order_by(Conversation.updated_at.desc()).all()
+    
+    def add_message(self, conversation_id: int, role: str, content: str, source: str = 'web', extra_data: dict = None) -> Message:
+        """添加消息"""
+        message = Message(
+            conversation_id=conversation_id,
+            role=role,
+            content=content,
+            source=source,
+            extra_data=extra_data
+        )
+        self.db.add(message)
+        
+        # 更新会话时间
+        conversation = self.db.query(Conversation).filter(Conversation.id == conversation_id).first()
+        if conversation:
+            conversation.updated_at = datetime.utcnow()
+            # 如果没有标题，用第一条用户消息作为标题
+            if not conversation.title and role == 'user':
+                conversation.title = content[:50] + ('...' if len(content) > 50 else '')
+        
+        self.db.commit()
+        self.db.refresh(message)
+        return message
+    
+    def get_messages(self, conversation_id: int, limit: int = 50) -> List[Message]:
+        """获取会话消息"""
+        return self.db.query(Message).filter(
+            Message.conversation_id == conversation_id
+        ).order_by(Message.created_at.asc()).limit(limit).all()
+    
+    def get_conversation_history(self, conversation_id: str, limit: int = 20) -> List[dict]:
+        """获取会话历史（用于AI上下文）"""
+        conversation = self.get_conversation(conversation_id)
+        if not conversation:
+            return []
+        
+        messages = self.db.query(Message).filter(
+            Message.conversation_id == conversation.id
+        ).order_by(Message.created_at.desc()).limit(limit).all()
+        
+        # 反转顺序，最早的在前
+        messages.reverse()
+        
+        return [{"role": m.role, "content": m.content} for m in messages]
+    
+    def delete_conversation(self, conversation_id: str):
+        """删除会话（软删除）"""
+        conversation = self.get_conversation(conversation_id)
+        if conversation:
+            conversation.is_active = False
+            self.db.commit()
+            return True
+        return False
\ No newline at end of file
diff --git a/services/matrix_service.py b/services/matrix_service.py
new file mode 100644
index 0000000..fb215ad
--- /dev/null
+++ b/services/matrix_service.py
@@ -0,0 +1,172 @@
+"""
+Matrix Bot 服务 - 处理Matrix消息收发
+"""
+import asyncio
+import json
+from typing import Optional, Callable
+from nio import AsyncClient, MatrixRoom, RoomMessageText, LoginResponse, SyncResponse
+import logging
+
+from models import SessionLocal, User, Conversation, Message, MatrixRoomMapping, SystemConfig
+from services.conversation_service import ConversationService
+
+logger = logging.getLogger(__name__)
+
+
+class MatrixBot:
+    def __init__(self):
+        self.client: Optional[AsyncClient] = None
+        self.homeserver: str = ""
+        self.username: str = ""
+        self.password: str = ""
+        self.is_running: bool = False
+        self.on_message_callback: Optional[Callable] = None
+    
+    async def init_from_config(self):
+        """从数据库配置初始化"""
+        db = SessionLocal()
+        try:
+            configs = {c.key: c.value for c in db.query(SystemConfig).all()}
+            self.homeserver = configs.get('matrix_homeserver', 'https://matrix.tphai.com')
+            self.username = configs.get('matrix_username', '')
+            self.password = configs.get('matrix_password', '')
+            
+            if self.username and self.password:
+                await self.connect()
+        finally:
+            db.close()
+    
+    async def connect(self):
+        """连接到Matrix服务器"""
+        if not self.homeserver or not self.username:
+            logger.warning("Matrix配置不完整，跳过连接")
+            return False
+        
+        try:
+            self.client = AsyncClient(self.homeserver, self.username)
+            response = await self.client.login(self.password)
+            
+            if isinstance(response, LoginResponse):
+                logger.info(f"Matrix连接成功: {self.username}")
+                self.is_running = True
+                return True
+            else:
+                logger.error(f"Matrix登录失败: {response}")
+                return False
+        except Exception as e:
+            logger.error(f"Matrix连接错误: {e}")
+            return False
+    
+    async def start_sync(self, message_handler: Callable = None):
+        """开始同步消息"""
+        if not self.client:
+            return
+        
+        self.on_message_callback = message_handler
+        
+        # 注册消息处理器
+        self.client.add_event_callback(self._handle_room_message, RoomMessageText)
+        
+        # 开始同步循环
+        await self.client.sync_forever(timeout=30000)
+    
+    async def _handle_room_message(self, room: MatrixRoom, event: RoomMessageText):
+        """处理收到的房间消息"""
+        # 忽略自己发送的消息
+        if event.sender == self.username:
+            return
+        
+        db = SessionLocal()
+        try:
+            conv_service = ConversationService(db)
+            
+            # 获取或创建Matrix用户
+            matrix_user_id = event.sender
+            user = conv_service.get_or_create_user(
+                user_id=matrix_user_id,
+                display_name=room.users.get(matrix_user_id, {}).get('display_name', matrix_user_id),
+                user_type='matrix',
+                matrix_user_id=matrix_user_id
+            )
+            
+            # 获取或创建房间映射
+            mapping = db.query(MatrixRoomMapping).filter(
+                MatrixRoomMapping.room_id == room.room_id
+            ).first()
+            
+            if not mapping:
+                # 为这个房间创建新会话
+                conversation = conv_service.create_conversation(user.id, title=f"Matrix: {room.display_name}")
+                mapping = MatrixRoomMapping(
+                    room_id=room.room_id,
+                    user_id=user.id,
+                    conversation_id=conversation.id
+                )
+                db.add(mapping)
+                db.commit()
+                db.refresh(mapping)
+            
+            # 保存用户消息
+            conv_service.add_message(
+                conversation_id=mapping.conversation_id,
+                role='user',
+                content=event.body,
+                source='matrix',
+                extra_data={'event_id': event.event_id, 'room_id': room.room_id}
+            )
+            
+            # 调用外部消息处理器
+            if self.on_message_callback:
+                await self.on_message_callback(
+                    conversation_id=mapping.conversation.conversation_id,
+                    user_message=event.body,
+                    user_id=user.user_id,
+                    room_id=room.room_id
+                )
+        finally:
+            db.close()
+    
+    async def send_message(self, room_id: str, message: str):
+        """发送消息到Matrix房间"""
+        if not self.client:
+            return False
+        
+        try:
+            await self.client.room_send(
+                room_id=room_id,
+                message_type="m.room.message",
+                content={
+                    "msgtype": "m.text",
+                    "body": message
+                }
+            )
+            return True
+        except Exception as e:
+            logger.error(f"发送Matrix消息失败: {e}")
+            return False
+    
+    async def get_room_id_for_user(self, user_matrix_id: str) -> Optional[str]:
+        """获取与用户的对话房间ID"""
+        db = SessionLocal()
+        try:
+            user = db.query(User).filter(User.matrix_user_id == user_matrix_id).first()
+            if user:
+                mapping = db.query(MatrixRoomMapping).filter(
+                    MatrixRoomMapping.user_id == user.id
+                ).first()
+                if mapping:
+                    return mapping.room_id
+            return None
+        finally:
+            db.close()
+    
+    async def disconnect(self):
+        """断开连接"""
+        if self.client:
+            await self.client.logout()
+            await self.client.close()
+            self.is_running = False
+
+
+# 全局实例
+matrix_bot = MatrixBot()
\ No newline at end of file
diff --git a/start.sh b/start.sh
new file mode 100755
index 0000000..c173a3e
--- /dev/null
+++ b/start.sh
@@ -0,0 +1,21 @@
+#!/bin/bash
+# AI对话系统启动脚本
+
+cd /home/xian/.openclaw/workspace-coder/works/ai-chat
+
+# 创建必要目录
+mkdir -p static/css static/js logs
+
+# 启动服务
+nohup python3 main.py > logs/ai-chat.log 2>&1 &
+sleep 2
+
+# 检查服务状态
+if curl -s http://localhost:19020/api/admin/stats > /dev/null 2>&1; then
+    echo "✅ AI对话系统启动成功 (端口: 19020)"
+    echo "   网页端: http://localhost:19020"
+    echo "   后台管理: http://localhost:19020/admin"
+else
+    echo "❌ 启动失败，查看日志:"
+    cat logs/ai-chat.log | tail -20
+fi
\ No newline at end of file
diff --git a/status.sh b/status.sh
new file mode 100755
index 0000000..b9effb3
--- /dev/null
+++ b/status.sh
@@ -0,0 +1,9 @@
+#!/bin/bash
+# 检查AI对话系统状态
+
+if curl -s http://localhost:19020/api/admin/stats > /dev/null 2>&1; then
+    echo "✅ AI对话系统运行中 (端口: 19020)"
+    curl -s http://localhost:19020/api/admin/stats | python3 -m json.tool
+else
+    echo "❌ AI对话系统未运行"
+fi
\ No newline at end of file
diff --git a/stop.sh b/stop.sh
new file mode 100755
index 0000000..a9beef4
--- /dev/null
+++ b/stop.sh
@@ -0,0 +1,11 @@
+#!/bin/bash
+# AI对话系统停止脚本
+
+pkill -f "python3.*ai-chat/main.py" 2>/dev/null
+sleep 1
+
+if pgrep -f "python3.*ai-chat/main.py" > /dev/null; then
+    echo "❌ 进程仍在运行"
+else
+    echo "✅ AI对话系统已停止"
+fi
\ No newline at end of file
diff --git a/templates/admin/index.html b/templates/admin/index.html
new file mode 100644
index 0000000..a241c32
--- /dev/null
+++ b/templates/admin/index.html
@@ -0,0 +1,509 @@
+<!DOCTYPE html>
+<html lang="zh-CN">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>AI对话系统 - 后台管理</title>
+    <link href="https://cdn.jsdelivr.net/npm/remixicon@3.5.0/fonts/remixicon.css" rel="stylesheet">
+    <style>
+        * {
+            margin: 0;
+            padding: 0;
+            box-sizing: border-box;
+        }
+        
+        body {
+            font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, 'Helvetica Neue', Arial, sans-serif;
+            background: #f5f5f5;
+            min-height: 100vh;
+        }
+        
+        .header {
+            background: #202123;
+            color: #fff;
+            padding: 16px 24px;
+            display: flex;
+            align-items: center;
+            justify-content: space-between;
+        }
+        
+        .header h1 {
+            font-size: 20px;
+        }
+        
+        .header-links {
+            display: flex;
+            gap: 16px;
+        }
+        
+        .header-links a {
+            color: #fff;
+            text-decoration: none;
+            font-size: 14px;
+        }
+        
+        .header-links a:hover {
+            text-decoration: underline;
+        }
+        
+        .container {
+            max-width: 1200px;
+            margin: 24px auto;
+            padding: 0 24px;
+        }
+        
+        .stats-grid {
+            display: grid;
+            grid-template-columns: repeat(3, 1fr);
+            gap: 24px;
+            margin-bottom: 32px;
+        }
+        
+        .stat-card {
+            background: #fff;
+            border-radius: 12px;
+            padding: 24px;
+            box-shadow: 0 2px 8px rgba(0,0,0,0.05);
+        }
+        
+        .stat-card h3 {
+            color: #666;
+            font-size: 14px;
+            margin-bottom: 8px;
+        }
+        
+        .stat-card .value {
+            font-size: 32px;
+            font-weight: 600;
+            color: #333;
+        }
+        
+        .tabs {
+            display: flex;
+            gap: 8px;
+            margin-bottom: 24px;
+        }
+        
+        .tab-btn {
+            padding: 12px 24px;
+            background: #fff;
+            border: 1px solid #ddd;
+            border-radius: 8px;
+            cursor: pointer;
+            font-size: 14px;
+            transition: all 0.2s;
+        }
+        
+        .tab-btn:hover {
+            background: #f0f0f0;
+        }
+        
+        .tab-btn.active {
+            background: #10a37f;
+            color: #fff;
+            border-color: #10a37f;
+        }
+        
+        .tab-content {
+            background: #fff;
+            border-radius: 12px;
+            padding: 24px;
+            box-shadow: 0 2px 8px rgba(0,0,0,0.05);
+        }
+        
+        .tab-panel {
+            display: none;
+        }
+        
+        .tab-panel.active {
+            display: block;
+        }
+        
+        table {
+            width: 100%;
+            border-collapse: collapse;
+        }
+        
+        th, td {
+            padding: 12px 16px;
+            text-align: left;
+            border-bottom: 1px solid #eee;
+        }
+        
+        th {
+            font-weight: 600;
+            color: #666;
+            font-size: 14px;
+        }
+        
+        td {
+            color: #333;
+        }
+        
+        tr:hover {
+            background: #f9f9f9;
+        }
+        
+        .config-form {
+            display: flex;
+            gap: 16px;
+            margin-bottom: 24px;
+        }
+        
+        .config-form input, .config-form textarea {
+            padding: 12px 16px;
+            border: 1px solid #ddd;
+            border-radius: 8px;
+            font-size: 14px;
+        }
+        
+        .config-form input {
+            width: 200px;
+        }
+        
+        .config-form textarea {
+            width: 300px;
+            resize: vertical;
+            min-height: 60px;
+        }
+        
+        .config-form button {
+            padding: 12px 24px;
+            background: #10a37f;
+            color: #fff;
+            border: none;
+            border-radius: 8px;
+            cursor: pointer;
+            font-size: 14px;
+        }
+        
+        .config-form button:hover {
+            background: #0d8c6d;
+        }
+        
+        .config-list {
+            margin-top: 24px;
+        }
+        
+        .config-item {
+            display: flex;
+            align-items: center;
+            padding: 16px;
+            background: #f9f9f9;
+            border-radius: 8px;
+            margin-bottom: 8px;
+        }
+        
+        .config-item .key {
+            font-weight: 600;
+            width: 200px;
+            color: #333;
+        }
+        
+        .config-item .value {
+            flex: 1;
+            color: #666;
+            overflow: hidden;
+            text-overflow: ellipsis;
+        }
+        
+        .config-item .desc {
+            color: #999;
+            font-size: 12px;
+            width: 200px;
+        }
+        
+        .badge {
+            padding: 4px 8px;
+            border-radius: 4px;
+            font-size: 12px;
+            font-weight: 500;
+        }
+        
+        .badge.web {
+            background: #e3f2fd;
+            color: #1976d2;
+        }
+        
+        .badge.matrix {
+            background: #f3e5f5;
+            color: #7b1fa2;
+        }
+        
+        .badge.active {
+            background: #e8f5e9;
+            color: #2e7d32;
+        }
+        
+        .badge.inactive {
+            background: #ffebee;
+            color: #c62828;
+        }
+        
+        .message-preview {
+            max-width: 300px;
+            overflow: hidden;
+            text-overflow: ellipsis;
+            white-space: nowrap;
+        }
+    </style>
+</head>
+<body>
+    <div class="header">
+        <h1>🤖 AI对话系统 - 后台管理</h1>
+        <div class="header-links">
+            <a href="/">← 返回聊天</a>
+        </div>
+    </div>
+    
+    <div class="container">
+        <div class="stats-grid" id="statsGrid">
+            <div class="stat-card">
+                <h3>总用户数</h3>
+                <div class="value" id="totalUsers">-</div>
+            </div>
+            <div class="stat-card">
+                <h3>总对话数</h3>
+                <div class="value" id="totalConversations">-</div>
+            </div>
+            <div class="stat-card">
+                <h3>总消息数</h3>
+                <div class="value" id="totalMessages">-</div>
+            </div>
+        </div>
+        
+        <div class="tabs">
+            <button class="tab-btn active" onclick="switchTab('users')">用户管理</button>
+            <button class="tab-btn" onclick="switchTab('conversations')">对话记录</button>
+            <button class="tab-btn" onclick="switchTab('config')">系统配置</button>
+        </div>
+        
+        <div class="tab-content">
+            <!-- 用户管理 -->
+            <div class="tab-panel active" id="usersPanel">
+                <table>
+                    <thead>
+                        <tr>
+                            <th>用户ID</th>
+                            <th>显示名称</th>
+                            <th>类型</th>
+                            <th>创建时间</th>
+                            <th>最后活跃</th>
+                            <th>状态</th>
+                        </tr>
+                    </thead>
+                    <tbody id="usersTableBody">
+                        <tr><td colspan="6">加载中...</td></tr>
+                    </tbody>
+                </table>
+            </div>
+            
+            <!-- 对话记录 -->
+            <div class="tab-panel" id="conversationsPanel">
+                <table>
+                    <thead>
+                        <tr>
+                            <th>会话ID</th>
+                            <th>用户</th>
+                            <th>标题</th>
+                            <th>消息数</th>
+                            <th>创建时间</th>
+                            <th>最后更新</th>
+                            <th>状态</th>
+                        </tr>
+                    </thead>
+                    <tbody id="conversationsTableBody">
+                        <tr><td colspan="7">加载中...</td></tr>
+                    </tbody>
+                </table>
+            </div>
+            
+            <!-- 系统配置 -->
+            <div class="tab-panel" id="configPanel">
+                <div class="config-form">
+                    <input type="text" id="configKey" placeholder="配置键名">
+                    <textarea id="configValue" placeholder="配置值"></textarea>
+                    <input type="text" id="configDesc" placeholder="描述（可选）">
+                    <button onclick="saveConfig()">保存</button>
+                </div>
+                
+                <div class="config-list" id="configList">
+                    <!-- 配置列表 -->
+                </div>
+            </div>
+        </div>
+    </div>
+
+    <script>
+        // 初始化
+        document.addEventListener('DOMContentLoaded', () => {
+            loadStats();
+            loadUsers();
+            loadConversations();
+            loadConfig();
+        });
+        
+        // 切换标签页
+        function switchTab(tabName) {
+            document.querySelectorAll('.tab-btn').forEach(btn => btn.classList.remove('active'));
+            document.querySelectorAll('.tab-panel').forEach(panel => panel.classList.remove('active'));
+            
+            document.querySelector(`.tab-btn[onclick="switchTab('${tabName}')"]`).classList.add('active');
+            document.getElementById(`${tabName}Panel`).classList.add('active');
+        }
+        
+        // 加载统计数据
+        async function loadStats() {
+            try {
+                const response = await fetch('/api/admin/stats');
+                const data = await response.json();
+                
+                document.getElementById('totalUsers').textContent = data.total_users;
+                document.getElementById('totalConversations').textContent = data.total_conversations;
+                document.getElementById('totalMessages').textContent = data.total_messages;
+            } catch (error) {
+                console.error('加载统计失败:', error);
+            }
+        }
+        
+        // 加载用户列表
+        async function loadUsers() {
+            try {
+                const response = await fetch('/api/admin/users');
+                const data = await response.json();
+                
+                const tbody = document.getElementById('usersTableBody');
+                
+                if (data.users.length === 0) {
+                    tbody.innerHTML = '<tr><td colspan="6">暂无用户</td></tr>';
+                    return;
+                }
+                
+                tbody.innerHTML = data.users.map(user => `
+                    <tr>
+                        <td>${user.user_id}</td>
+                        <td>${user.display_name || '-'}</td>
+                        <td><span class="badge ${user.user_type}">${user.user_type}</span></td>
+                        <td>${formatDate(user.created_at)}</td>
+                        <td>${formatDate(user.last_active_at)}</td>
+                        <td><span class="badge ${user.is_active ? 'active' : 'inactive'}">${user.is_active ? '活跃' : '禁用'}</span></td>
+                    </tr>
+                `).join('');
+            } catch (error) {
+                console.error('加载用户失败:', error);
+            }
+        }
+        
+        // 加载对话列表
+        async function loadConversations() {
+            try {
+                const response = await fetch('/api/admin/conversations');
+                const data = await response.json();
+                
+                const tbody = document.getElementById('conversationsTableBody');
+                
+                if (data.conversations.length === 0) {
+                    tbody.innerHTML = '<tr><td colspan="7">暂无对话</td></tr>';
+                    return;
+                }
+                
+                tbody.innerHTML = data.conversations.map(conv => `
+                    <tr>
+                        <td>${conv.conversation_id}</td>
+                        <td>${conv.user_id || '-'}</td>
+                        <td class="message-preview">${conv.title || '新对话'}</td>
+                        <td>${conv.message_count}</td>
+                        <td>${formatDate(conv.created_at)}</td>
+                        <td>${formatDate(conv.updated_at)}</td>
+                        <td><span class="badge ${conv.is_active ? 'active' : 'inactive'}">${conv.is_active ? '活跃' : '已删除'}</span></td>
+                    </tr>
+                `).join('');
+            } catch (error) {
+                console.error('加载对话失败:', error);
+            }
+        }
+        
+        // 加载配置
+        async function loadConfig() {
+            try {
+                const response = await fetch('/api/admin/config');
+                const data = await response.json();
+                
+                const container = document.getElementById('configList');
+                
+                if (data.configs.length === 0) {
+                    container.innerHTML = '<p>暂无配置</p>';
+                    return;
+                }
+                
+                container.innerHTML = data.configs.map(config => `
+                    <div class="config-item">
+                        <div class="key">${config.key}</div>
+                        <div class="value">${config.value}</div>
+                        <div class="desc">${config.description || ''}</div>
+                    </div>
+                `).join('');
+            } catch (error) {
+                console.error('加载配置失败:', error);
+            }
+        }
+        
+        // 保存配置
+        async function saveConfig() {
+            const key = document.getElementById('configKey').value.trim();
+            const value = document.getElementById('configValue').value.trim();
+            const desc = document.getElementById('configDesc').value.trim();
+            
+            if (!key || !value) {
+                alert('请填写配置键名和值');
+                return;
+            }
+            
+            try {
+                const response = await fetch('/api/admin/config', {
+                    method: 'POST',
+                    headers: {'Content-Type': 'application/json'},
+                    body: JSON.stringify({key, value, description: desc})
+                });
+                
+                if (response.ok) {
+                    alert('配置已保存');
+                    document.getElementById('configKey').value = '';
+                    document.getElementById('configValue').value = '';
+                    document.getElementById('configDesc').value = '';
+                    loadConfig();
+                } else {
+                    alert('保存失败');
+                }
+            } catch (error) {
+                console.error('保存配置失败:', error);
+                alert('保存失败');
+            }
+        }
+        
+        // 格式化日期
+        function formatDate(dateStr) {
+            if (!dateStr) return '-';
+            const date = new Date(dateStr);
+            return date.toLocaleString('zh-CN', {
+                year: 'numeric',
+                month: '2-digit',
+                day: '2-digit',
+                hour: '2-digit',
+                minute: '2-digit'
+            });
+        }
+        
+        // 定时刷新
+        setInterval(() => {
+            loadStats();
+            if (document.getElementById('usersPanel').classList.contains('active')) {
+                loadUsers();
+            }
+            if (document.getElementById('conversationsPanel').classList.contains('active')) {
+                loadConversations();
+            }
+        }, 30000);
+    </script>
+</body>
+</html>
\ No newline at end of file
diff --git a/templates/index.html b/templates/index.html
new file mode 100644
index 0000000..200d2c3
--- /dev/null
+++ b/templates/index.html
@@ -0,0 +1,590 @@
+<!DOCTYPE html>
+<html lang="zh-CN">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>AI 对话系统</title>
+    <link href="https://cdn.jsdelivr.net/npm/remixicon@3.5.0/fonts/remixicon.css" rel="stylesheet">
+    <style>
+        * {
+            margin: 0;
+            padding: 0;
+            box-sizing: border-box;
+        }
+        
+        body {
+            font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, 'Helvetica Neue', Arial, sans-serif;
+            background: #f5f5f5;
+            height: 100vh;
+            display: flex;
+        }
+        
+        .sidebar {
+            width: 260px;
+            background: #202123;
+            color: #fff;
+            display: flex;
+            flex-direction: column;
+        }
+        
+        .sidebar-header {
+            padding: 16px;
+            border-bottom: 1px solid #4d4d4f;
+        }
+        
+        .new-chat-btn {
+            width: 100%;
+            padding: 12px 16px;
+            background: transparent;
+            border: 1px solid #4d4d4f;
+            border-radius: 6px;
+            color: #fff;
+            cursor: pointer;
+            display: flex;
+            align-items: center;
+            gap: 8px;
+            font-size: 14px;
+            transition: background 0.2s;
+        }
+        
+        .new-chat-btn:hover {
+            background: #2a2b32;
+        }
+        
+        .conversation-list {
+            flex: 1;
+            overflow-y: auto;
+            padding: 8px;
+        }
+        
+        .conversation-item {
+            padding: 12px;
+            border-radius: 6px;
+            cursor: pointer;
+            display: flex;
+            align-items: center;
+            justify-content: space-between;
+            margin-bottom: 4px;
+            color: #ececf1;
+        }
+        
+        .conversation-item:hover {
+            background: #2a2b32;
+        }
+        
+        .conversation-item.active {
+            background: #343541;
+        }
+        
+        .conversation-item .title {
+            flex: 1;
+            overflow: hidden;
+            text-overflow: ellipsis;
+            white-space: nowrap;
+            font-size: 14px;
+        }
+        
+        .conversation-item .delete-btn {
+            opacity: 0;
+            background: none;
+            border: none;
+            color: #999;
+            cursor: pointer;
+            padding: 4px;
+        }
+        
+        .conversation-item:hover .delete-btn {
+            opacity: 1;
+        }
+        
+        .main-content {
+            flex: 1;
+            display: flex;
+            flex-direction: column;
+            background: #fff;
+        }
+        
+        .chat-header {
+            padding: 16px 24px;
+            border-bottom: 1px solid #e5e5e5;
+            display: flex;
+            align-items: center;
+            justify-content: space-between;
+        }
+        
+        .chat-header h1 {
+            font-size: 18px;
+            font-weight: 600;
+        }
+        
+        .user-id-display {
+            font-size: 12px;
+            color: #666;
+            background: #f0f0f0;
+            padding: 4px 8px;
+            border-radius: 4px;
+        }
+        
+        .messages-container {
+            flex: 1;
+            overflow-y: auto;
+            padding: 24px;
+        }
+        
+        .message {
+            max-width: 800px;
+            margin: 0 auto 24px;
+            display: flex;
+            gap: 16px;
+        }
+        
+        .message-avatar {
+            width: 36px;
+            height: 36px;
+            border-radius: 4px;
+            display: flex;
+            align-items: center;
+            justify-content: center;
+            flex-shrink: 0;
+            font-size: 18px;
+        }
+        
+        .message.user .message-avatar {
+            background: #5436da;
+            color: #fff;
+        }
+        
+        .message.assistant .message-avatar {
+            background: #19c37d;
+            color: #fff;
+        }
+        
+        .message-content {
+            flex: 1;
+            line-height: 1.6;
+        }
+        
+        .message-content pre {
+            background: #1e1e1e;
+            color: #d4d4d4;
+            padding: 16px;
+            border-radius: 8px;
+            overflow-x: auto;
+            margin: 12px 0;
+        }
+        
+        .message-content code {
+            background: #f0f0f0;
+            padding: 2px 6px;
+            border-radius: 4px;
+            font-family: monospace;
+        }
+        
+        .message-content pre code {
+            background: transparent;
+            padding: 0;
+        }
+        
+        .input-container {
+            padding: 24px;
+            border-top: 1px solid #e5e5e5;
+        }
+        
+        .input-wrapper {
+            max-width: 800px;
+            margin: 0 auto;
+            display: flex;
+            gap: 12px;
+            align-items: flex-end;
+        }
+        
+        .input-wrapper textarea {
+            flex: 1;
+            padding: 12px 16px;
+            border: 1px solid #ddd;
+            border-radius: 12px;
+            font-size: 16px;
+            resize: none;
+            outline: none;
+            font-family: inherit;
+            max-height: 200px;
+        }
+        
+        .input-wrapper textarea:focus {
+            border-color: #10a37f;
+        }
+        
+        .send-btn {
+            width: 48px;
+            height: 48px;
+            border-radius: 12px;
+            background: #10a37f;
+            border: none;
+            color: #fff;
+            cursor: pointer;
+            font-size: 20px;
+            display: flex;
+            align-items: center;
+            justify-content: center;
+            transition: background 0.2s;
+        }
+        
+        .send-btn:hover {
+            background: #0d8c6d;
+        }
+        
+        .send-btn:disabled {
+            background: #ccc;
+            cursor: not-allowed;
+        }
+        
+        .welcome {
+            display: flex;
+            flex-direction: column;
+            align-items: center;
+            justify-content: center;
+            height: 100%;
+            color: #666;
+        }
+        
+        .welcome h2 {
+            font-size: 28px;
+            margin-bottom: 16px;
+            color: #333;
+        }
+        
+        .welcome p {
+            font-size: 16px;
+        }
+        
+        .loading {
+            display: flex;
+            align-items: center;
+            gap: 8px;
+            color: #666;
+        }
+        
+        .loading::after {
+            content: '';
+            animation: dots 1.5s infinite;
+        }
+        
+        @keyframes dots {
+            0%, 20% { content: '.'; }
+            40% { content: '..'; }
+            60%, 100% { content: '...'; }
+        }
+        
+        .empty-state {
+            text-align: center;
+            color: #666;
+            padding: 40px;
+        }
+        
+        /* 滚动条样式 */
+        ::-webkit-scrollbar {
+            width: 8px;
+        }
+        
+        ::-webkit-scrollbar-track {
+            background: transparent;
+        }
+        
+        ::-webkit-scrollbar-thumb {
+            background: #c1c1c1;
+            border-radius: 4px;
+        }
+        
+        ::-webkit-scrollbar-thumb:hover {
+            background: #a1a1a1;
+        }
+    </style>
+</head>
+<body>
+    <div class="sidebar">
+        <div class="sidebar-header">
+            <button class="new-chat-btn" onclick="createNewConversation()">
+                <i class="ri-add-line"></i>
+                新对话
+            </button>
+        </div>
+        <div class="conversation-list" id="conversationList">
+            <div class="empty-state">暂无对话</div>
+        </div>
+    </div>
+    
+    <div class="main-content">
+        <div class="chat-header">
+            <h1>AI 对话</h1>
+            <div class="user-id-display" id="userIdDisplay">用户: 加载中...</div>
+        </div>
+        
+        <div class="messages-container" id="messagesContainer">
+            <div class="welcome">
+                <h2>👋 欢迎使用 AI 对话系统</h2>
+                <p>开始一段新对话吧</p>
+            </div>
+        </div>
+        
+        <div class="input-container">
+            <div class="input-wrapper">
+                <textarea 
+                    id="messageInput" 
+                    placeholder="输入消息... (Shift+Enter换行, Enter发送)"
+                    rows="1"
+                ></textarea>
+                <button class="send-btn" id="sendBtn" onclick="sendMessage()">
+                    <i class="ri-send-plane-fill"></i>
+                </button>
+            </div>
+        </div>
+    </div>
+
+    <script>
+        // 全局变量
+        let ws = null;
+        let userId = 'web_' + Math.random().toString(36).substr(2, 9);
+        let currentConversationId = null;
+        let conversations = [];
+        
+        // 初始化
+        document.addEventListener('DOMContentLoaded', () => {
+            document.getElementById('userIdDisplay').textContent = `用户: ${userId}`;
+            connectWebSocket();
+            loadConversations();
+            setupTextarea();
+        });
+        
+        // WebSocket连接
+        function connectWebSocket() {
+            const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:';
+            ws = new WebSocket(`${protocol}//${window.location.host}/ws/${userId}`);
+            
+            ws.onopen = () => {
+                console.log('WebSocket已连接');
+            };
+            
+            ws.onmessage = (event) => {
+                const data = JSON.parse(event.data);
+                handleWebSocketMessage(data);
+            };
+            
+            ws.onclose = () => {
+                console.log('WebSocket已断开，3秒后重连...');
+                setTimeout(connectWebSocket, 3000);
+            };
+            
+            ws.onerror = (error) => {
+                console.error('WebSocket错误:', error);
+            };
+        }
+        
+        // 处理WebSocket消息
+        function handleWebSocketMessage(data) {
+            switch (data.type) {
+                case 'history':
+                    displayHistory(data.messages);
+                    break;
+                    
+                case 'conversation_created':
+                    currentConversationId = data.conversation_id;
+                    loadConversations();
+                    break;
+                    
+                case 'user_message':
+                    appendMessage('user', data.message.content, data.message.source);
+                    break;
+                    
+                case 'assistant_message':
+                    appendMessage('assistant', data.message.content, data.message.source);
+                    document.getElementById('sendBtn').disabled = false;
+                    break;
+                    
+                case 'error':
+                    alert(data.message);
+                    document.getElementById('sendBtn').disabled = false;
+                    break;
+            }
+        }
+        
+        // 显示历史消息
+        function displayHistory(messages) {
+            const container = document.getElementById('messagesContainer');
+            container.innerHTML = '';
+            
+            messages.forEach(msg => {
+                appendMessage(msg.role, msg.content, msg.source);
+            });
+        }
+        
+        // 添加消息到界面
+        function appendMessage(role, content, source = 'web') {
+            const container = document.getElementById('messagesContainer');
+            
+            // 移除欢迎界面
+            const welcome = container.querySelector('.welcome');
+            if (welcome) welcome.remove();
+            
+            const messageDiv = document.createElement('div');
+            messageDiv.className = `message ${role}`;
+            
+            const avatar = role === 'user' ? '👤' : '🤖';
+            const sourceLabel = source === 'matrix' ? ' [Matrix]' : '';
+            
+            messageDiv.innerHTML = `
+                <div class="message-avatar">${avatar}</div>
+                <div class="message-content">${formatContent(content)}${sourceLabel}</div>
+            `;
+            
+            container.appendChild(messageDiv);
+            container.scrollTop = container.scrollHeight;
+        }
+        
+        // 格式化消息内容（简单的Markdown支持）
+        function formatContent(content) {
+            return content
+                .replace(/```(\w*)\n([\s\S]*?)```/g, '<pre><code>$2</code></pre>')
+                .replace(/`([^`]+)`/g, '<code>$1</code>')
+                .replace(/\n/g, '<br>');
+        }
+        
+        // 加载会话列表
+        async function loadConversations() {
+            try {
+                const response = await fetch('/api/conversations?user_id=' + userId);
+                const data = await response.json();
+                conversations = data.conversations;
+                renderConversations();
+            } catch (error) {
+                console.error('加载会话失败:', error);
+            }
+        }
+        
+        // 渲染会话列表
+        function renderConversations() {
+            const container = document.getElementById('conversationList');
+            
+            if (conversations.length === 0) {
+                container.innerHTML = '<div class="empty-state">暂无对话</div>';
+                return;
+            }
+            
+            container.innerHTML = conversations.map(conv => `
+                <div class="conversation-item ${conv.id === currentConversationId ? 'active' : ''}" 
+                     onclick="selectConversation('${conv.id}')">
+                    <span class="title">${conv.title}</span>
+                    <button class="delete-btn" onclick="deleteConversation('${conv.id}', event)">
+                        <i class="ri-delete-bin-line"></i>
+                    </button>
+                </div>
+            `).join('');
+        }
+        
+        // 选择会话
+        function selectConversation(conversationId) {
+            currentConversationId = conversationId;
+            renderConversations();
+            
+            if (ws && ws.readyState === WebSocket.OPEN) {
+                ws.send(JSON.stringify({
+                    action: 'select_conversation',
+                    conversation_id: conversationId
+                }));
+            }
+        }
+        
+        // 创建新会话
+        async function createNewConversation() {
+            try {
+                const response = await fetch('/api/conversations?user_id=' + userId, {
+                    method: 'POST'
+                });
+                const data = await response.json();
+                currentConversationId = data.id;
+                
+                // 清空消息区域
+                const container = document.getElementById('messagesContainer');
+                container.innerHTML = `
+                    <div class="welcome">
+                        <h2>👋 开始新对话</h2>
+                        <p>输入您的问题开始对话</p>
+                    </div>
+                `;
+                
+                loadConversations();
+            } catch (error) {
+                console.error('创建会话失败:', error);
+            }
+        }
+        
+        // 删除会话
+        async function deleteConversation(conversationId, event) {
+            event.stopPropagation();
+            
+            if (!confirm('确定删除这个对话？')) return;
+            
+            try {
+                await fetch(`/api/conversations/${conversationId}`, {
+                    method: 'DELETE'
+                });
+                
+                if (conversationId === currentConversationId) {
+                    currentConversationId = null;
+                    const container = document.getElementById('messagesContainer');
+                    container.innerHTML = `
+                        <div class="welcome">
+                            <h2>👋 欢迎使用 AI 对话系统</h2>
+                            <p>开始一段新对话吧</p>
+                        </div>
+                    `;
+                }
+                
+                loadConversations();
+            } catch (error) {
+                console.error('删除会话失败:', error);
+            }
+        }
+        
+        // 发送消息
+        function sendMessage() {
+            const input = document.getElementById('messageInput');
+            const message = input.value.trim();
+            
+            if (!message) return;
+            
+            // 禁用发送按钮
+            document.getElementById('sendBtn').disabled = true;
+            
+            // 清空输入框
+            input.value = '';
+            input.style.height = 'auto';
+            
+            // 发送WebSocket消息
+            if (ws && ws.readyState === WebSocket.OPEN) {
+                ws.send(JSON.stringify({
+                    action: 'chat',
+                    message: message,
+                    conversation_id: currentConversationId
+                }));
+            }
+        }
+        
+        // 设置文本框
+        function setupTextarea() {
+            const textarea = document.getElementById('messageInput');
+            
+            textarea.addEventListener('keydown', (e) => {
+                if (e.key === 'Enter' && !e.shiftKey) {
+                    e.preventDefault();
+                    sendMessage();
+                }
+            });
+            
+            textarea.addEventListener('input', () => {
+                textarea.style.height = 'auto';
+                textarea.style.height = Math.min(textarea.scrollHeight, 200) + 'px';
+            });
+        }
+    </script>
+</body>
+</html>
\ No newline at end of file
diff --git a/venv/bin/python b/venv/bin/python
new file mode 120000
index 0000000..b8a0adb
--- /dev/null
+++ b/venv/bin/python
@@ -0,0 +1 @@
+python3
\ No newline at end of file
diff --git a/venv/bin/python3 b/venv/bin/python3
new file mode 120000
index 0000000..ae65fda
--- /dev/null
+++ b/venv/bin/python3
@@ -0,0 +1 @@
+/usr/bin/python3
\ No newline at end of file
diff --git a/venv/bin/python3.10 b/venv/bin/python3.10
new file mode 120000
index 0000000..b8a0adb
--- /dev/null
+++ b/venv/bin/python3.10
@@ -0,0 +1 @@
+python3
\ No newline at end of file
diff --git a/venv/lib64 b/venv/lib64
new file mode 120000
index 0000000..7951405
--- /dev/null
+++ b/venv/lib64
@@ -0,0 +1 @@
+lib
\ No newline at end of file
diff --git a/venv/pyvenv.cfg b/venv/pyvenv.cfg
new file mode 100644
index 0000000..0537ffc
--- /dev/null
+++ b/venv/pyvenv.cfg
@@ -0,0 +1,3 @@
+home = /usr/bin
+include-system-site-packages = false
+version = 3.10.12