Upload 3 files

app.py

@@ -0,0 +1,572 @@
+from flask import Flask, render_template, jsonify, request
+import json
+import os
+import threading
+
+# 导入原有的微信服务模块
+from wechat_service import (
+    TOKEN, session_manager, executor, client, API_KEY,
+    verify_signature, verify_msg_signature, parse_xml_message,
+    generate_response_xml, handle_async_task, generate_initial_response,
+    append_status_message, split_message, AsyncResponse, cleanup_sessions
+)
+import wechat_service
+import uuid
+import xml.etree.ElementTree as ET
+import requests
+
+app = Flask(__name__)
+
+CONFIG_FILE = 'config.json'
+
+def load_config():
+    """加载配置文件"""
+    if os.path.exists(CONFIG_FILE):
+        with open(CONFIG_FILE, 'r', encoding='utf-8') as f:
+            return json.load(f)
+    else:
+        # 默认配置
+        default_config = {
+            "models": {
+                "text_model": "gpt-4.1-mini",
+                "image_model": "gpt-4.1-mini",
+                "image_generation_model": "dall-e-3"
+            },
+            "system_prompt": "你是HXIAO公众号的智能助手，这一个用来分享与学习人工智能的公众号，我们的目标是专注AI应用的简单研究与实践。致力于分享切实可行的技术方案，希望让复杂的技术变得简单易懂。也喜欢用通俗的语言来解释专业概念，让技术真正服务于每个学习者",
+            "functions": [
+                {
+                    "name": "generate_image",
+                    "description": "Generate an image based on text description",
+                    "parameters": {
+                        "type": "object",
+                        "properties": {
+                            "prompt": {
+                                "type": "string",
+                                "description": "The description of the image to generate"
+                            }
+                        },
+                        "required": ["prompt"]
+                    },
+                    "http_config": {
+                        "method": "POST",
+                        "url": "https://api1.oaipro.com/v1/images/generations",
+                        "headers": {
+                            "Content-Type": "application/json",
+                            "Authorization": f"Bearer {API_KEY}"
+                        },
+                        "body_template": {
+                            "model": "dall-e-3",
+                            "prompt": "{prompt}",
+                            "n": 1,
+                            "size": "1024x1024"
+                        },
+                        "response_type": "image"
+                    }
+                }
+            ],
+            "settings": {
+                "max_workers": 10,
+                "request_timeout": 60,
+                "max_message_length": 500,
+                "session_timeout": 3600
+            }
+        }
+        save_config(default_config)
+        return default_config
+
+def save_config(config):
+    """保存配置文件"""
+    with open(CONFIG_FILE, 'w', encoding='utf-8') as f:
+        json.dump(config, f, ensure_ascii=False, indent=2)
+
+# 全局配置
+config = load_config()
+
+def build_dynamic_tools():
+    """动态构建Function工具列表"""
+    tools = []
+    for func_config in config['functions']:
+        tool = {
+            "type": "function",
+            "function": {
+                "name": func_config['name'],
+                "description": func_config['description'],
+                "parameters": func_config['parameters']
+            }
+        }
+        tools.append(tool)
+    return tools
+
+def execute_dynamic_function(function_name, arguments):
+    """执行动态Function"""
+    func_config = None
+    for func in config['functions']:
+        if func['name'] == function_name:
+            func_config = func
+            break
+    
+    if not func_config:
+        raise Exception(f"Function {function_name} not found")
+    
+    http_config = func_config['http_config']
+    
+    # 构建请求
+    method = http_config['method']
+    url = http_config['url']
+    headers = http_config.get('headers', {})
+    
+    # 处理URL参数替换
+    for key, value in arguments.items():
+        url = url.replace(f"{{{key}}}", str(value))
+    
+    # 处理请求体
+    if method.upper() in ['POST', 'PUT', 'PATCH'] and 'body_template' in http_config:
+        body_template = http_config['body_template']
+        body = {}
+        for key, value in body_template.items():
+            if isinstance(value, str) and value.startswith('{') and value.endswith('}'):
+                param_name = value[1:-1]
+                if param_name in arguments:
+                    body[key] = arguments[param_name]
+                else:
+                    body[key] = value
+            else:
+                body[key] = value
+        
+        response = requests.request(
+            method=method,
+            url=url,
+            headers=headers,
+            json=body,
+            timeout=config['settings']['request_timeout']
+        )
+    else:
+        # GET请求或其他无body请求
+        params = {}
+        for key, value in arguments.items():
+            if f"{{{key}}}" not in url:  # 如果不在URL中，则作为查询参数
+                params[key] = value
+        
+        response = requests.request(
+            method=method,
+            url=url,
+            headers=headers,
+            params=params,
+            timeout=config['settings']['request_timeout']
+        )
+    
+    response.raise_for_status()
+    
+    # 处理响应
+    if http_config.get('response_type') == 'image':
+        # 图片生成的特殊处理
+        result = response.json()
+        if 'data' in result and result['data']:
+            image_url = result['data'][0]['url']
+            img_response = requests.get(image_url, timeout=30)
+            img_response.raise_for_status()
+            return {
+                "type": "image",
+                "data": img_response.content
+            }
+    
+    return {
+        "type": "text",
+        "data": response.json() if response.headers.get('content-type', '').startswith('application/json') else response.text
+    }
+
+def update_wechat_service_config():
+    """更新wechat_service模块中的配置"""
+    if not session_manager:
+        return
+        
+    # 更新现有会话的系统提示词
+    for session in session_manager.sessions.values():
+        if session.messages and session.messages[0]['role'] == 'system':
+            session.messages[0]['content'] = config['system_prompt']
+
+def enhanced_process_long_running_task(messages, message_type='text', image_data=None):
+    """增强版的长时间任务处理，支持动态Function"""
+    try:
+        if message_type == 'image':
+            # 图片处理保持原有逻辑
+            if 'process_long_running_task' in globals():
+                return process_long_running_task(messages, message_type, image_data)
+            else:
+                raise Exception("wechat_service module not available")
+        else:
+            # 文本处理使用动态工具
+            tools = build_dynamic_tools()
+            
+            response = client.chat.completions.create(
+                model=config['models']['text_model'],
+                messages=messages,
+                tools=tools,
+                tool_choice="auto",
+                timeout=config['settings']['request_timeout']
+            )
+            
+            if response.choices[0].message.tool_calls:
+                tool_call = response.choices[0].message.tool_calls[0]
+                function_name = tool_call.function.name
+                arguments = json.loads(tool_call.function.arguments)
+                
+                result = execute_dynamic_function(function_name, arguments)
+                
+                if result["type"] == "image":
+                    if 'upload_image_to_wechat' in globals():
+                        media_id = upload_image_to_wechat(result["data"])
+                        return {
+                            "type": "image",
+                            "media_id": media_id
+                        }
+                    else:
+                        return {
+                            "type": "text",
+                            "content": "图片处理功能暂不可用"
+                        }
+                else:
+                    return {
+                        "type": "text",
+                        "content": str(result["data"])
+                    }
+            
+            return {
+                "type": "text",
+                "content": response.choices[0].message.content
+            }
+    except Exception as e:
+        print(f"增强任务处理失败: {str(e)}")
+        raise
+
+def enhanced_handle_async_task(session, task_id, messages=None, message_type='text', message_data=None):
+    """增强版异步任务处理"""
+    try:
+        if task_id not in session.response_queue:
+            return
+            
+        if message_type == 'image':
+            result = enhanced_process_long_running_task(None, 'image', message_data)
+        else:
+            result = enhanced_process_long_running_task(messages)
+            
+        if task_id in session.response_queue and not session.response_queue[task_id].is_expired():
+            session.response_queue[task_id].status = "completed"
+            session.response_queue[task_id].response_type = result.get("type", "text")
+            
+            if result["type"] == "image":
+                session.response_queue[task_id].media_id = result["media_id"]
+                session.response_queue[task_id].result = None
+            else:
+                session.response_queue[task_id].result = result["content"]
+                
+            if messages and result["type"] == "text":
+                messages.append({"role": "assistant", "content": result["content"]})
+                
+    except Exception as e:
+        print(f"增强异步任务处理失败: {str(e)}")
+        if task_id in session.response_queue:
+            session.response_queue[task_id].status = "failed"
+            session.response_queue[task_id].error = str(e)
+
+# Web管理界面路由
+@app.route('/')
+def index():
+    return render_template('index.html')
+
+@app.route('/api/config', methods=['GET'])
+def get_config():
+    return jsonify(config)
+
+@app.route('/api/config', methods=['POST'])
+def update_config():
+    global config
+    try:
+        new_config = request.json
+        config.update(new_config)
+        save_config(config)
+        
+        # 更新wechat_service模块的配置
+        update_wechat_service_config()
+        
+        # 重新加载系统提示词到现有会话
+        for session in session_manager.sessions.values():
+            if session.messages and session.messages[0]['role'] == 'system':
+                session.messages[0]['content'] = config['system_prompt']
+        
+        return jsonify({"success": True, "message": "配置已更新"})
+    except Exception as e:
+        return jsonify({"success": False, "message": str(e)}), 500
+
+@app.route('/api/sessions', methods=['GET'])
+def get_sessions():
+    try:
+        if not session_manager:
+            return jsonify([])
+            
+        sessions_info = []
+        for user_id, session in session_manager.sessions.items():
+            sessions_info.append({
+                "user_id": user_id,
+                "last_active": session.last_active,
+                "message_count": len(session.messages),
+                "has_pending": len(session.pending_parts) > 0,
+                "current_task": session.current_task is not None
+            })
+        return jsonify(sessions_info)
+    except Exception as e:
+        print(f"获取会话列表失败: {e}")
+        return jsonify([])
+
+@app.route('/api/sessions/<user_id>/clear', methods=['POST'])
+def clear_user_session(user_id):
+    try:
+        if session_manager:
+            session_manager.clear_session(user_id)
+            return jsonify({"success": True, "message": f"用户 {user_id} 的会话已清理"})
+        else:
+            return jsonify({"success": False, "message": "会话管理器不可用"})
+    except Exception as e:
+        return jsonify({"success": False, "message": str(e)}), 500
+
+@app.route('/api/logs', methods=['GET'])
+def get_logs():
+    try:
+        lines = int(request.args.get('lines', 100))
+        with open('wechat_service.log', 'r', encoding='utf-8') as f:
+            log_lines = f.readlines()[-lines:]
+        return jsonify({"logs": log_lines})
+    except Exception as e:
+        return jsonify({"error": str(e)}), 500
+
+@app.route('/api/test-function', methods=['POST'])
+def test_function():
+    try:
+        data = request.json
+        function_name = data['function_name']
+        arguments = data['arguments']
+        
+        result = execute_dynamic_function(function_name, arguments)
+        return jsonify({"success": True, "result": result})
+    except Exception as e:
+        return jsonify({"success": False, "error": str(e)}), 500
+
+# 微信服务路由（使用原有逻辑但增强Function支持）
+@app.route('/api/wx', methods=['GET', 'POST'])
+def wechatai():
+    if request.method == 'GET':
+        signature = request.args.get('signature')
+        timestamp = request.args.get('timestamp')
+        nonce = request.args.get('nonce')
+        echostr = request.args.get('echostr')
+        
+        if verify_signature(signature, timestamp, nonce, TOKEN):
+            return echostr
+        return 'error', 403
+    
+    try:
+        encrypt_type = request.args.get('encrypt_type', '')
+        
+        if encrypt_type == 'aes':
+            msg_signature = request.args.get('msg_signature')
+            timestamp = request.args.get('timestamp')
+            nonce = request.args.get('nonce')
+            
+            xml_tree = ET.fromstring(request.data)
+            encrypted_text = xml_tree.find('Encrypt').text
+            
+            if not verify_msg_signature(msg_signature, timestamp, nonce, TOKEN, encrypted_text):
+                return 'Invalid signature', 403
+            
+            try:
+                decrypted_xml = session_manager.crypto.decrypt(encrypted_text)
+                message_data = parse_xml_message(decrypted_xml)
+            except Exception as e:
+                return 'Decryption failed', 403
+        else:
+            try:
+                message_data = parse_xml_message(request.data)
+            except Exception as e:
+                return 'Invalid XML', 400
+        
+        from_user = message_data['from_user']
+        to_user = message_data['to_user']
+        msg_type = message_data['msg_type']
+        
+        try:
+            session = session_manager.get_session(from_user)
+        except Exception as e:
+            return generate_response_xml(
+                from_user,
+                to_user,
+                append_status_message('系统错误，请稍后重试。'),
+                encrypt_type=encrypt_type
+            )
+
+        if msg_type == 'image':
+            try:
+                task_id = str(uuid.uuid4())
+                session.current_task = task_id
+                session.response_queue[task_id] = AsyncResponse()
+                
+                executor.submit(
+                    enhanced_handle_async_task, 
+                    session, 
+                    task_id, 
+                    None,
+                    'image',
+                    message_data
+                )
+                
+                return generate_response_xml(
+                    from_user,
+                    to_user,
+                    append_status_message("正在分析图片，请稍候...\n回复'查询'获取分析结果", is_processing=True),
+                    encrypt_type=encrypt_type
+                )
+            except Exception as e:
+                return generate_response_xml(
+                    from_user,
+                    to_user,
+                    append_status_message('处理图片时出现错误，请稍后重试。'),
+                    encrypt_type=encrypt_type
+                )
+        else:
+            try:
+                user_content = message_data['content'].strip()
+                
+                if user_content == '新对话':
+                    session_manager.clear_session(from_user)
+                    return generate_response_xml(
+                        from_user,
+                        to_user,
+                        append_status_message('已开始新的对话。请描述您的问题。'),
+                        encrypt_type=encrypt_type
+                    )
+
+                if user_content == '继续':
+                    if session.pending_parts:
+                        next_part = session.pending_parts.pop(0)
+                        has_more = bool(session.pending_parts)
+                        return generate_response_xml(
+                            from_user,
+                            to_user,
+                            append_status_message(next_part, has_more),
+                            encrypt_type=encrypt_type
+                        )
+                    return generate_response_xml(
+                        from_user,
+                        to_user,
+                        append_status_message('没有更多内容了。请继续您的问题。'),
+                        encrypt_type=encrypt_type
+                    )
+
+                if user_content == '查询':
+                    if session.current_task:
+                        task_response = session.response_queue.get(session.current_task)
+                        if task_response:
+                            if task_response.is_expired():
+                                del session.response_queue[session.current_task]
+                                session.current_task = None
+                                return generate_response_xml(
+                                    from_user,
+                                    to_user,
+                                    append_status_message('请求已过期，请重新提问。'),
+                                    encrypt_type=encrypt_type
+                                )
+                            
+                            if task_response.status == "completed":
+                                if task_response.response_type == "image":
+                                    del session.response_queue[session.current_task]
+                                    session.current_task = None
+                                    return generate_response_xml(
+                                        from_user,
+                                        to_user,
+                                        "",
+                                        response_type="image",
+                                        media_id=task_response.media_id,
+                                        encrypt_type=encrypt_type
+                                    )
+                                else:
+                                    response = task_response.result
+                                    del session.response_queue[session.current_task]
+                                    session.current_task = None
+                                    
+                                    max_length = config['settings']['max_message_length']
+                                    if len(response) > max_length:
+                                        parts = split_message(response, max_length)
+                                        first_part = parts.pop(0)
+                                        session.pending_parts = parts
+                                        return generate_response_xml(
+                                            from_user,
+                                            to_user,
+                                            append_status_message(first_part, True),
+                                            encrypt_type=encrypt_type
+                                        )
+                                    return generate_response_xml(
+                                        from_user,
+                                        to_user,
+                                        append_status_message(response),
+                                        encrypt_type=encrypt_type
+                                    )
+                            elif task_response.status == "failed":
+                                error_message = '处理过程中出现错误，请重新提问。'
+                                del session.response_queue[session.current_task]
+                                session.current_task = None
+                                return generate_response_xml(
+                                    from_user,
+                                    to_user,
+                                    append_status_message(error_message),
+                                    encrypt_type=encrypt_type
+                                )
+                            else:
+                                return generate_response_xml(
+                                    from_user,
+                                    to_user,
+                                    append_status_message('正在处理中，请稍后再次查询。', is_processing=True),
+                                    encrypt_type=encrypt_type
+                                )
+                    return generate_response_xml(
+                        from_user,
+                        to_user,
+                        append_status_message('没有正在处理的请求。'),
+                        encrypt_type=encrypt_type
+                    )
+
+                session.messages.append({"role": "user", "content": user_content})
+                
+                task_id = str(uuid.uuid4())
+                session.current_task = task_id
+                session.response_queue[task_id] = AsyncResponse()
+                
+                executor.submit(enhanced_handle_async_task, session, task_id, session.messages.copy())
+                
+                return generate_response_xml(
+                    from_user,
+                    to_user,
+                    append_status_message(generate_initial_response(), is_processing=True),
+                    encrypt_type=encrypt_type
+                )
+                
+            except Exception as e:
+                return generate_response_xml(
+                    from_user,
+                    to_user,
+                    append_status_message('处理消息时出现错误，请稍后重试。'),
+                    encrypt_type=encrypt_type
+                )
+
+    except Exception as e:
+        return generate_response_xml(
+            message_data['from_user'] if 'message_data' in locals() else 'unknown',
+            message_data['to_user'] if 'message_data' in locals() else 'unknown',
+            append_status_message('抱歉，系统暂时出现问题，请稍后重试。'),
+            encrypt_type if 'encrypt_type' in locals() else ''
+        )
+
+if __name__ == '__main__':
+    # 启动会话清理线程
+    cleanup_thread = threading.Thread(target=cleanup_sessions, daemon=True)
+    cleanup_thread.start()
+    
+    app.run(host='0.0.0.0', port=7860, debug=True)

templates/index.html

@@ -0,0 +1,1705 @@
+<!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>
+    <style>
+        /* 基础样式重置 */
+        * {
+            margin: 0;
+            padding: 0;
+            box-sizing: border-box;
+        }
+
+        body {
+            font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, sans-serif;
+            background-color: #ffffff;
+            color: #333333;
+            line-height: 1.6;
+        }
+
+        /* 应用容器 */
+        .app-container {
+            display: flex;
+            min-height: 100vh;
+        }
+
+        /* PC端侧边栏 */
+        .sidebar {
+            width: 260px;
+            background-color: #ffffff;
+            border-right: 1px solid #e8f5e8;
+            padding: 20px 0;
+            position: fixed;
+            height: 100vh;
+            overflow-y: auto;
+            z-index: 100;
+        }
+
+        .sidebar-header {
+            padding: 0 20px 30px;
+            border-bottom: 1px solid #e8f5e8;
+            margin-bottom: 20px;
+        }
+
+        .logo {
+            display: flex;
+            align-items: center;
+            gap: 12px;
+        }
+
+        .logo span {
+            font-size: 18px;
+            font-weight: 600;
+            color: #2e7d32;
+        }
+
+        .nav-menu {
+            list-style: none;
+            padding: 0 10px;
+        }
+
+        .nav-item {
+            display: flex;
+            align-items: center;
+            gap: 12px;
+            padding: 12px 16px;
+            margin-bottom: 4px;
+            border-radius: 8px;
+            cursor: pointer;
+            transition: all 0.2s ease;
+            color: #666666;
+        }
+
+        .nav-item:hover {
+            background-color: #f0f8f0;
+            color: #2e7d32;
+        }
+
+        .nav-item.active {
+            background-color: #e8f5e8;
+            color: #2e7d32;
+            border: 1px solid #c8e6c8;
+        }
+
+        .nav-item svg {
+            width: 20px;
+            height: 20px;
+        }
+
+        .nav-item span {
+            font-size: 14px;
+            font-weight: 500;
+        }
+
+        /* 移动端底部导航 */
+        .bottom-nav {
+            display: none;
+            position: fixed;
+            bottom: 0;
+            left: 0;
+            right: 0;
+            background-color: #ffffff;
+            border-top: 1px solid #e8f5e8;
+            padding: 8px 0;
+            z-index: 100;
+        }
+
+        .bottom-nav .nav-item {
+            flex: 1;
+            display: flex;
+            flex-direction: column;
+            align-items: center;
+            gap: 4px;
+            padding: 8px 4px;
+            cursor: pointer;
+            transition: all 0.2s ease;
+            color: #666666;
+        }
+
+        .bottom-nav .nav-item:hover,
+        .bottom-nav .nav-item.active {
+            color: #2e7d32;
+        }
+
+        .bottom-nav .nav-item svg {
+            width: 20px;
+            height: 20px;
+        }
+
+        .bottom-nav .nav-item span {
+            font-size: 11px;
+            font-weight: 500;
+        }
+
+        /* 主内容区域 */
+        .main-content {
+            flex: 1;
+            margin-left: 260px;
+            background-color: #fafafa;
+            min-height: 100vh;
+        }
+
+        /* 页面样式 */
+        .page {
+            display: none;
+            padding: 30px;
+        }
+
+        .page.active {
+            display: block;
+        }
+
+        .page-header {
+            margin-bottom: 30px;
+            display: flex;
+            justify-content: space-between;
+            align-items: flex-start;
+            flex-wrap: wrap;
+            gap: 16px;
+        }
+
+        .page-header h1 {
+            font-size: 28px;
+            font-weight: 700;
+            color: #2e7d32;
+            margin-bottom: 4px;
+        }
+
+        .page-header p {
+            color: #666666;
+            font-size: 16px;
+        }
+
+        /* 按钮样式 */
+        .btn {
+            display: inline-flex;
+            align-items: center;
+            gap: 8px;
+            padding: 10px 20px;
+            border: none;
+            border-radius: 8px;
+            font-size: 14px;
+            font-weight: 500;
+            cursor: pointer;
+            transition: all 0.2s ease;
+            text-decoration: none;
+        }
+
+        .btn-primary {
+            background-color: #90ee90;
+            color: #2e7d32;
+            border: 1px solid #81c784;
+        }
+
+        .btn-primary:hover {
+            background-color: #81c784;
+            color: #ffffff;
+        }
+
+        .btn-secondary {
+            background-color: #ffffff;
+            color: #666666;
+            border: 1px solid #e0e0e0;
+        }
+
+        .btn-secondary:hover {
+            background-color: #f5f5f5;
+            color: #333333;
+        }
+
+        .btn-danger {
+            background-color: #ffffff;
+            color: #d32f2f;
+            border: 1px solid #ffcdd2;
+        }
+
+        .btn-danger:hover {
+            background-color: #ffebee;
+        }
+
+        /* 统计卡片网格 */
+        .stats-grid {
+            display: grid;
+            grid-template-columns: repeat(auto-fit, minmax(240px, 1fr));
+            gap: 20px;
+            margin-bottom: 30px;
+        }
+
+        .stat-card {
+            background-color: #ffffff;
+            border: 1px solid #e8f5e8;
+            border-radius: 12px;
+            padding: 24px;
+            display: flex;
+            align-items: center;
+            gap: 16px;
+        }
+
+        .stat-icon {
+            width: 48px;
+            height: 48px;
+            background-color: #f0f8f0;
+            border-radius: 12px;
+            display: flex;
+            align-items: center;
+            justify-content: center;
+            color: #2e7d32;
+        }
+
+        .stat-content h3 {
+            font-size: 14px;
+            color: #666666;
+            font-weight: 500;
+            margin-bottom: 4px;
+        }
+
+        .stat-value {
+            font-size: 24px;
+            font-weight: 700;
+            color: #2e7d32;
+        }
+
+        /* 卡片样式 */
+        .card {
+            background-color: #ffffff;
+            border: 1px solid #e8f5e8;
+            border-radius: 12px;
+            padding: 24px;
+            margin-bottom: 20px;
+        }
+
+        .card h3 {
+            font-size: 18px;
+            font-weight: 600;
+            color: #2e7d32;
+            margin-bottom: 20px;
+        }
+
+        /* 表单样式 */
+        .form-group {
+            margin-bottom: 20px;
+        }
+
+        .form-row {
+            display: grid;
+            grid-template-columns: 1fr 1fr;
+            gap: 20px;
+        }
+
+        .form-group label {
+            display: block;
+            font-size: 14px;
+            font-weight: 500;
+            color: #333333;
+            margin-bottom: 8px;
+        }
+
+        .form-group input,
+        .form-group textarea,
+        .form-group select {
+            width: 100%;
+            padding: 12px;
+            border: 1px solid #e0e0e0;
+            border-radius: 8px;
+            font-size: 14px;
+            transition: all 0.2s ease;
+            background-color: #ffffff;
+        }
+
+        .form-group input:focus,
+        .form-group textarea:focus,
+        .form-group select:focus {
+            outline: none;
+            border-color: #81c784;
+            box-shadow: 0 0 0 3px rgba(129, 199, 132, 0.1);
+        }
+
+        .form-actions {
+            display: flex;
+            gap: 12px;
+            margin-top: 30px;
+        }
+
+        /* Functions网格 */
+        .functions-grid {
+            display: grid;
+            grid-template-columns: repeat(auto-fill, minmax(320px, 1fr));
+            gap: 20px;
+        }
+
+        .function-card {
+            background-color: #ffffff;
+            border: 1px solid #e8f5e8;
+            border-radius: 12px;
+            padding: 20px;
+            position: relative;
+        }
+
+        .function-card-header {
+            display: flex;
+            justify-content: space-between;
+            align-items: flex-start;
+            margin-bottom: 12px;
+        }
+
+        .function-card h4 {
+            font-size: 16px;
+            font-weight: 600;
+            color: #2e7d32;
+            margin-bottom: 4px;
+        }
+
+        .function-card p {
+            color: #666666;
+            font-size: 14px;
+            margin-bottom: 16px;
+        }
+
+        .function-method {
+            display: inline-block;
+            padding: 4px 8px;
+            border-radius: 4px;
+            font-size: 12px;
+            font-weight: 600;
+            text-transform: uppercase;
+        }
+
+        .method-get {
+            background-color: #e8f5e8;
+            color: #2e7d32;
+        }
+
+        .method-post {
+            background-color: #fff3e0;
+            color: #f57c00;
+        }
+
+        .method-put {
+            background-color: #e3f2fd;
+            color: #1976d2;
+        }
+
+        .method-delete {
+            background-color: #ffebee;
+            color: #d32f2f;
+        }
+
+        .function-actions {
+            display: flex;
+            gap: 8px;
+            margin-top: 16px;
+        }
+
+        .function-actions .btn {
+            padding: 6px 12px;
+            font-size: 12px;
+        }
+
+        .function-url {
+            margin-bottom: 16px;
+        }
+
+        .function-url code {
+            background-color: #f5f5f5;
+            padding: 4px 8px;
+            border-radius: 4px;
+            font-size: 12px;
+            color: #666666;
+        }
+
+        /* 表格样式 */
+        .sessions-table {
+            background-color: #ffffff;
+            border: 1px solid #e8f5e8;
+            border-radius: 12px;
+            overflow: hidden;
+        }
+
+        .sessions-table table {
+            width: 100%;
+            border-collapse: collapse;
+        }
+
+        .sessions-table th,
+        .sessions-table td {
+            padding: 12px 16px;
+            text-align: left;
+            border-bottom: 1px solid #f0f0f0;
+        }
+
+        .sessions-table th {
+            background-color: #f8f9fa;
+            font-weight: 600;
+            color: #333333;
+            font-size: 14px;
+        }
+
+        .sessions-table td {
+            font-size: 14px;
+            color: #666666;
+        }
+
+        .session-status {
+            display: inline-block;
+            padding: 4px 8px;
+            border-radius: 4px;
+            font-size: 12px;
+            font-weight: 500;
+        }
+
+        .status-active {
+            background-color: #e8f5e8;
+            color: #2e7d32;
+        }
+
+        .status-pending {
+            background-color: #fff3e0;
+            color: #f57c00;
+        }
+
+        .status-idle {
+            background-color: #f5f5f5;
+            color: #666666;
+        }
+
+        /* 日志容器 */
+        .logs-container {
+            background-color: #ffffff;
+            border: 1px solid #e8f5e8;
+            border-radius: 12px;
+            padding: 20px;
+            height: 600px;
+            overflow-y: auto;
+        }
+
+        #logs-content {
+            font-family: 'Monaco', 'Menlo', 'Ubuntu Mono', monospace;
+            font-size: 12px;
+            line-height: 1.4;
+            color: #333333;
+            white-space: pre-wrap;
+            word-wrap: break-word;
+        }
+
+        /* 模态框样式 */
+        .modal {
+            display: none;
+            position: fixed;
+            top: 0;
+            left: 0;
+            width: 100%;
+            height: 100%;
+            background-color: rgba(0, 0, 0, 0.5);
+            z-index: 1000;
+        }
+
+        .modal.active {
+            display: flex;
+            align-items: center;
+            justify-content: center;
+            padding: 20px;
+        }
+
+        .modal-content {
+            background-color: #ffffff;
+            border-radius: 12px;
+            width: 100%;
+            max-width: 600px;
+            max-height: 90vh;
+            overflow-y: auto;
+            box-shadow: 0 10px 30px rgba(0, 0, 0, 0.2);
+        }
+
+        .modal-header {
+            display: flex;
+            justify-content: space-between;
+            align-items: center;
+            padding: 20px 24px;
+            border-bottom: 1px solid #f0f0f0;
+        }
+
+        .modal-header h3 {
+            font-size: 18px;
+            font-weight: 600;
+            color: #2e7d32;
+        }
+
+        .modal-close {
+            background: none;
+            border: none;
+            color: #666666;
+            cursor: pointer;
+            padding: 4px;
+            border-radius: 4px;
+            transition: all 0.2s ease;
+        }
+
+        .modal-close:hover {
+            background-color: #f5f5f5;
+            color: #333333;
+        }
+
+        .modal-body {
+            padding: 24px;
+        }
+
+        .modal-footer {
+            display: flex;
+            justify-content: flex-end;
+            gap: 12px;
+            padding: 20px 24px;
+            border-top: 1px solid #f0f0f0;
+        }
+
+        /* 通知样式 */
+        .notification {
+            position: fixed;
+            top: 20px;
+            right: 20px;
+            padding: 16px 20px;
+            border-radius: 8px;
+            color: #ffffff;
+            font-weight: 500;
+            z-index: 1100;
+            transform: translateX(400px);
+            transition: transform 0.3s ease;
+        }
+
+        .notification.show {
+            transform: translateX(0);
+        }
+
+        .notification.success {
+            background-color: #4caf50;
+        }
+
+        .notification.error {
+            background-color: #f44336;
+        }
+
+        .notification.warning {
+            background-color: #ff9800;
+        }
+
+        .notification.info {
+            background-color: #2196f3;
+        }
+
+        /* 代码块样式 */
+        pre {
+            background-color: #f8f9fa;
+            border: 1px solid #e9ecef;
+            border-radius: 8px;
+            padding: 16px;
+            overflow-x: auto;
+            font-family: 'Monaco', 'Menlo', 'Ubuntu Mono', monospace;
+            font-size: 13px;
+            line-height: 1.4;
+        }
+
+        /* 空状态 */
+        .empty-state {
+            text-align: center;
+            padding: 60px 20px;
+            color: #666666;
+        }
+
+        .empty-state svg {
+            width: 48px;
+            height: 48px;
+            margin-bottom: 16px;
+            opacity: 0.5;
+        }
+
+        .empty-state h3 {
+            font-size: 18px;
+            margin-bottom: 8px;
+            color: #333333;
+        }
+
+        .empty-state p {
+            font-size: 14px;
+            margin-bottom: 20px;
+        }
+
+        /* 响应式设计 */
+        @media (max-width: 768px) {
+            .sidebar {
+                display: none;
+            }
+            
+            .bottom-nav {
+                display: flex;
+            }
+            
+            .main-content {
+                margin-left: 0;
+                padding-bottom: 70px;
+            }
+            
+            .page {
+                padding: 20px;
+            }
+            
+            .page-header {
+                flex-direction: column;
+                align-items: flex-start;
+                gap: 12px;
+            }
+            
+            .page-header h1 {
+                font-size: 24px;
+            }
+            
+            .stats-grid {
+                grid-template-columns: 1fr;
+                gap: 16px;
+            }
+            
+            .form-row {
+                grid-template-columns: 1fr;
+                gap: 16px;
+            }
+            
+            .functions-grid {
+                grid-template-columns: 1fr;
+                gap: 16px;
+            }
+            
+            .form-actions {
+                flex-direction: column;
+            }
+            
+            .btn {
+                justify-content: center;
+            }
+            
+            .modal-content {
+                margin: 10px;
+                max-width: none;
+            }
+            
+            .modal-footer {
+                flex-direction: column;
+            }
+            
+            .sessions-table {
+                overflow-x: auto;
+            }
+            
+            .sessions-table table {
+                min-width: 600px;
+            }
+        }
+
+        @media (max-width: 480px) {
+            .page {
+                padding: 16px;
+            }
+            
+            .card {
+                padding: 16px;
+            }
+            
+            .stat-card {
+                padding: 16px;
+            }
+            
+            .modal-body,
+            .modal-header,
+            .modal-footer {
+                padding: 16px;
+            }
+        }
+    </style>
+</head>
+<body>
+    <div class="app-container">
+        <!-- PC端侧边栏 -->
+        <nav class="sidebar">
+            <div class="sidebar-header">
+                <div class="logo">
+                    <svg width="32" height="32" viewBox="0 0 32 32">
+                        <rect x="4" y="4" width="24" height="24" rx="4" fill="#90EE90" stroke="#4CAF50" stroke-width="2"/>
+                        <circle cx="12" cy="12" r="2" fill="#fff"/>
+                        <circle cx="20" cy="12" r="2" fill="#fff"/>
+                        <path d="M10 20 Q16 24 22 20" stroke="#fff" stroke-width="2" fill="none"/>
+                    </svg>
+                    <span>AI助手管理</span>
+                </div>
+            </div>
+            <ul class="nav-menu">
+                <li class="nav-item active" data-page="dashboard">
+                    <svg width="20" height="20" viewBox="0 0 20 20">
+                        <rect x="2" y="2" width="7" height="7" rx="1" fill="currentColor"/>
+                        <rect x="11" y="2" width="7" height="7" rx="1" fill="currentColor"/>
+                        <rect x="2" y="11" width="7" height="7" rx="1" fill="currentColor"/>
+                        <rect x="11" y="11" width="7" height="7" rx="1" fill="currentColor"/>
+                    </svg>
+                    <span>仪表盘</span>
+                </li>
+                <li class="nav-item" data-page="config">
+                    <svg width="20" height="20" viewBox="0 0 20 20">
+                        <circle cx="10" cy="10" r="3" fill="none" stroke="currentColor" stroke-width="2"/>
+                        <path d="M10 1v2m0 14v2M18.66 5.34l-1.41 1.41M4.75 14.25l-1.41 1.41M1 10h2m14 0h2M18.66 14.66l-1.41-1.41M4.75 5.75l-1.41-1.41" stroke="currentColor" stroke-width="2"/>
+                    </svg>
+                    <span>系统配置</span>
+                </li>
+                <li class="nav-item" data-page="functions">
+                    <svg width="20" height="20" viewBox="0 0 20 20">
+                        <rect x="2" y="6" width="16" height="8" rx="2" fill="none" stroke="currentColor" stroke-width="2"/>
+                        <path d="M6 10h8m-4-2v4" stroke="currentColor" stroke-width="2"/>
+                    </svg>
+                    <span>Function管理</span>
+                </li>
+                <li class="nav-item" data-page="sessions">
+                    <svg width="20" height="20" viewBox="0 0 20 20">
+                        <circle cx="6" cy="6" r="4" fill="none" stroke="currentColor" stroke-width="2"/>
+                        <path d="M2 18v-2a4 4 0 0 1 8 0v2" stroke="currentColor" stroke-width="2"/>
+                        <circle cx="16" cy="7" r="2" fill="currentColor"/>
+                        <path d="M13 18v-1a3 3 0 0 1 3-3h2a3 3 0 0 1 3 3v1" stroke="currentColor" stroke-width="2"/>
+                    </svg>
+                    <span>用户会话</span>
+                </li>
+                <li class="nav-item" data-page="logs">
+                    <svg width="20" height="20" viewBox="0 0 20 20">
+                        <rect x="3" y="2" width="14" height="16" rx="2" fill="none" stroke="currentColor" stroke-width="2"/>
+                        <path d="M7 6h6m-6 4h6m-6 4h4" stroke="currentColor" stroke-width="2"/>
+                    </svg>
+                    <span>系统日志</span>
+                </li>
+            </ul>
+        </nav>
+
+        <!-- 移动端底部导航 -->
+        <nav class="bottom-nav">
+            <div class="nav-item active" data-page="dashboard">
+                <svg width="20" height="20" viewBox="0 0 20 20">
+                    <rect x="2" y="2" width="7" height="7" rx="1" fill="currentColor"/>
+                    <rect x="11" y="2" width="7" height="7" rx="1" fill="currentColor"/>
+                    <rect x="2" y="11" width="7" height="7" rx="1" fill="currentColor"/>
+                    <rect x="11" y="11" width="7" height="7" rx="1" fill="currentColor"/>
+                </svg>
+                <span>仪表盘</span>
+            </div>
+            <div class="nav-item" data-page="config">
+                <svg width="20" height="20" viewBox="0 0 20 20">
+                    <circle cx="10" cy="10" r="3" fill="none" stroke="currentColor" stroke-width="2"/>
+                    <path d="M10 1v2m0 14v2M18.66 5.34l-1.41 1.41M4.75 14.25l-1.41 1.41M1 10h2m14 0h2M18.66 14.66l-1.41-1.41M4.75 5.75l-1.41-1.41" stroke="currentColor" stroke-width="2"/>
+                </svg>
+                <span>配置</span>
+            </div>
+            <div class="nav-item" data-page="functions">
+                <svg width="20" height="20" viewBox="0 0 20 20">
+                    <rect x="2" y="6" width="16" height="8" rx="2" fill="none" stroke="currentColor" stroke-width="2"/>
+                    <path d="M6 10h8m-4-2v4" stroke="currentColor" stroke-width="2"/>
+                </svg>
+                <span>Functions</span>
+            </div>
+            <div class="nav-item" data-page="sessions">
+                <svg width="20" height="20" viewBox="0 0 20 20">
+                    <circle cx="6" cy="6" r="4" fill="none" stroke="currentColor" stroke-width="2"/>
+                    <path d="M2 18v-2a4 4 0 0 1 8 0v2" stroke="currentColor" stroke-width="2"/>
+                    <circle cx="16" cy="7" r="2" fill="currentColor"/>
+                    <path d="M13 18v-1a3 3 0 0 1 3-3h2a3 3 0 0 1 3 3v1" stroke="currentColor" stroke-width="2"/>
+                </svg>
+                <span>会话</span>
+            </div>
+            <div class="nav-item" data-page="logs">
+                <svg width="20" height="20" viewBox="0 0 20 20">
+                    <rect x="3" y="2" width="14" height="16" rx="2" fill="none" stroke="currentColor" stroke-width="2"/>
+                    <path d="M7 6h6m-6 4h6m-6 4h4" stroke="currentColor" stroke-width="2"/>
+                </svg>
+                <span>日志</span>
+            </div>
+        </nav>
+
+        <!-- 主内容区域 -->
+        <main class="main-content">
+            <!-- 仪表盘页面 -->
+            <div class="page active" id="dashboard">
+                <div class="page-header">
+                    <div>
+                        <h1>系统仪表盘</h1>
+                        <p>微信AI助手运行状态监控</p>
+                    </div>
+                </div>
+                <div class="stats-grid">
+                    <div class="stat-card">
+                        <div class="stat-icon">
+                            <svg width="24" height="24" viewBox="0 0 24 24">
+                                <circle cx="12" cy="12" r="10" fill="none" stroke="currentColor" stroke-width="2"/>
+                                <path d="M8 12l2 2 4-4" stroke="currentColor" stroke-width="2"/>
+                            </svg>
+                        </div>
+                        <div class="stat-content">
+                            <h3>服务状态</h3>
+                            <p class="stat-value" id="service-status">运行中</p>
+                        </div>
+                    </div>
+                    <div class="stat-card">
+                        <div class="stat-icon">
+                            <svg width="24" height="24" viewBox="0 0 24 24">
+                                <circle cx="6" cy="6" r="4" fill="none" stroke="currentColor" stroke-width="2"/>
+                                <path d="M2 18v-2a4 4 0 0 1 8 0v2" stroke="currentColor" stroke-width="2"/>
+                                <circle cx="18" cy="9" r="3" fill="currentColor"/>
+                            </svg>
+                        </div>
+                        <div class="stat-content">
+                            <h3>活跃用户</h3>
+                            <p class="stat-value" id="active-users">0</p>
+                        </div>
+                    </div>
+                    <div class="stat-card">
+                        <div class="stat-icon">
+                            <svg width="24" height="24" viewBox="0 0 24 24">
+                                <rect x="2" y="6" width="20" height="12" rx="2" fill="none" stroke="currentColor" stroke-width="2"/>
+                                <path d="M6 10h12" stroke="currentColor" stroke-width="2"/>
+                            </svg>
+                        </div>
+                        <div class="stat-content">
+                            <h3>处理中任务</h3>
+                            <p class="stat-value" id="pending-tasks">0</p>
+                        </div>
+                    </div>
+                    <div class="stat-card">
+                        <div class="stat-icon">
+                            <svg width="24" height="24" viewBox="0 0 24 24">
+                                <rect x="2" y="6" width="16" height="8" rx="2" fill="none" stroke="currentColor" stroke-width="2"/>
+                                <path d="M6 10h8" stroke="currentColor" stroke-width="2"/>
+                            </svg>
+                        </div>
+                        <div class="stat-content">
+                            <h3>可用Functions</h3>
+                            <p class="stat-value" id="function-count">0</p>
+                        </div>
+                    </div>
+                </div>
+            </div>
+
+            <!-- 系统配置页面 -->
+            <div class="page" id="config">
+                <div class="page-header">
+                    <div>
+                        <h1>系统配置</h1>
+                        <p>管理AI模型和系统参数</p>
+                    </div>
+                </div>
+                <div class="config-section">
+                    <div class="card">
+                        <h3>AI模型配置</h3>
+                        <div class="form-group">
+                            <label for="text-model">文本对话模型</label>
+                            <input type="text" id="text-model" placeholder="gpt-4.1-mini">
+                        </div>
+                        <div class="form-group">
+                            <label for="image-model">图像识别模型</label>
+                            <input type="text" id="image-model" placeholder="gpt-4.1-mini">
+                        </div>
+                        <div class="form-group">
+                            <label for="image-gen-model">图像生成模型</label>
+                            <input type="text" id="image-gen-model" placeholder="dall-e-3">
+                        </div>
+                    </div>
+                    <div class="card">
+                        <h3>系统提示词</h3>
+                        <div class="form-group">
+                            <label for="system-prompt">AI助手角色设定</label>
+                            <textarea id="system-prompt" rows="5" placeholder="输入系统提示词..."></textarea>
+                        </div>
+                    </div>
+                    <div class="card">
+                        <h3>系统参数</h3>
+                        <div class="form-row">
+                            <div class="form-group">
+                                <label for="max-workers">最大并发数</label>
+                                <input type="number" id="max-workers" min="1" max="50">
+                            </div>
+                            <div class="form-group">
+                                <label for="request-timeout">请求超时时间(秒)</label>
+                                <input type="number" id="request-timeout" min="10" max="300">
+                            </div>
+                        </div>
+                        <div class="form-row">
+                            <div class="form-group">
+                                <label for="max-message-length">消息最大长度</label>
+                                <input type="number" id="max-message-length" min="100" max="2000">
+                            </div>
+                            <div class="form-group">
+                                <label for="session-timeout">会话超时时间(秒)</label>
+                                <input type="number" id="session-timeout" min="300" max="7200">
+                            </div>
+                        </div>
+                    </div>
+                    <div class="form-actions">
+                        <button class="btn btn-primary" onclick="saveConfig()">保存配置</button>
+                        <button class="btn btn-secondary" onclick="loadConfig()">重新加载</button>
+                    </div>
+                </div>
+            </div>
+
+            <!-- Function管理页面 -->
+            <div class="page" id="functions">
+                <div class="page-header">
+                    <div>
+                        <h1>Function管理</h1>
+                        <p>添加和管理自定义Function</p>
+                    </div>
+                    <button class="btn btn-primary" onclick="showAddFunctionModal()">
+                        <svg width="16" height="16" viewBox="0 0 16 16">
+                            <path d="M8 1v14m-7-7h14" stroke="currentColor" stroke-width="2"/>
+                        </svg>
+                        添加Function
+                    </button>
+                </div>
+                <div class="functions-grid" id="functions-list">
+                    <!-- Functions列表将在这里动态生成 -->
+                </div>
+            </div>
+
+            <!-- 用户会话页面 -->
+            <div class="page" id="sessions">
+                <div class="page-header">
+                    <div>
+                        <h1>用户会话</h1>
+                        <p>查看和管理用户对话会话</p>
+                    </div>
+                    <button class="btn btn-secondary" onclick="refreshSessions()">
+                        <svg width="16" height="16" viewBox="0 0 16 16">
+                            <path d="M1 4v6h6m8-6v6h-6M15 4a8 8 0 0 0-8-8" stroke="currentColor" stroke-width="2" fill="none"/>
+                        </svg>
+                        刷新
+                    </button>
+                </div>
+                <div class="sessions-table">
+                    <table>
+                        <thead>
+                            <tr>
+                                <th>用户ID</th>
+                                <th>最后活跃时间</th>
+                                <th>消息数量</th>
+                                <th>状态</th>
+                                <th>操作</th>
+                            </tr>
+                        </thead>
+                        <tbody id="sessions-tbody">
+                            <!-- 会话列表将在这里动态生成 -->
+                        </tbody>
+                    </table>
+                </div>
+            </div>
+
+            <!-- 系统日志页面 -->
+            <div class="page" id="logs">
+                <div class="page-header">
+                    <div>
+                        <h1>系统日志</h1>
+                        <p>查看系统运行日志</p>
+                    </div>
+                    <button class="btn btn-secondary" onclick="refreshLogs()">
+                        <svg width="16" height="16" viewBox="0 0 16 16">
+                            <path d="M1 4v6h6m8-6v6h-6M15 4a8 8 0 0 0-8-8" stroke="currentColor" stroke-width="2" fill="none"/>
+                        </svg>
+                        刷新
+                    </button>
+                </div>
+                <div class="logs-container">
+                    <pre id="logs-content">加载中...</pre>
+                </div>
+            </div>
+        </main>
+    </div>
+
+    <!-- Function添加/编辑模态框 -->
+    <div class="modal" id="function-modal">
+        <div class="modal-content">
+            <div class="modal-header">
+                <h3 id="function-modal-title">添加Function</h3>
+                <button class="modal-close" onclick="closeFunctionModal()">
+                    <svg width="20" height="20" viewBox="0 0 20 20">
+                        <path d="M15 5L5 15m0-10l10 10" stroke="currentColor" stroke-width="2"/>
+                    </svg>
+                </button>
+            </div>
+            <div class="modal-body">
+                <form id="function-form">
+                    <div class="form-group">
+                        <label for="func-name">Function名称</label>
+                        <input type="text" id="func-name" required>
+                    </div>
+                    <div class="form-group">
+                        <label for="func-description">描述</label>
+                        <textarea id="func-description" rows="2" required></textarea>
+                    </div>
+                    <div class="form-group">
+                        <label for="func-method">HTTP方法</label>
+                        <select id="func-method">
+                            <option value="GET">GET</option>
+                            <option value="POST">POST</option>
+                            <option value="PUT">PUT</option>
+                            <option value="DELETE">DELETE</option>
+                        </select>
+                    </div>
+                    <div class="form-group">
+                        <label for="func-url">请求URL</label>
+                        <input type="url" id="func-url" placeholder="https://api.example.com/endpoint" required>
+                    </div>
+                    <div class="form-group">
+                        <label for="func-headers">请求头(JSON格式)</label>
+                        <textarea id="func-headers" rows="3" placeholder='{"Content-Type": "application/json"}'></textarea>
+                    </div>
+                    <div class="form-group">
+                        <label for="func-body">请求体模板(JSON格式)</label>
+                        <textarea id="func-body" rows="4" placeholder='{"param1": "{value1}", "param2": "{value2}"}'></textarea>
+                    </div>
+                    <div class="form-group">
+                        <label for="func-parameters">参数定义(JSON Schema)</label>
+                        <textarea id="func-parameters" rows="6" placeholder='{"type": "object", "properties": {"value1": {"type": "string", "description": "参数描述"}}, "required": ["value1"]}'></textarea>
+                    </div>
+                    <div class="form-group">
+                        <label for="func-response-type">响应类型</label>
+                        <select id="func-response-type">
+                            <option value="text">文本</option>
+                            <option value="image">图片</option>
+                        </select>
+                    </div>
+                </form>
+            </div>
+            <div class="modal-footer">
+                <button type="button" class="btn btn-secondary" onclick="closeFunctionModal()">取消</button>
+                <button type="button" class="btn btn-primary" onclick="testFunction()">测试</button>
+                <button type="button" class="btn btn-primary" onclick="saveFunction()">保存</button>
+            </div>
+        </div>
+    </div>
+
+    <!-- 测试结果模态框 -->
+    <div class="modal" id="test-modal">
+        <div class="modal-content">
+            <div class="modal-header">
+                <h3>测试结果</h3>
+                <button class="modal-close" onclick="closeTestModal()">
+                    <svg width="20" height="20" viewBox="0 0 20 20">
+                        <path d="M15 5L5 15m0-10l10 10" stroke="currentColor" stroke-width="2"/>
+                    </svg>
+                </button>
+            </div>
+            <div class="modal-body">
+                <div class="form-group">
+                    <label>测试参数(JSON格式)</label>
+                    <textarea id="test-params" rows="4" placeholder='{"param1": "value1"}'></textarea>
+                </div>
+                <div class="form-group">
+                    <label>测试结果</label>
+                    <pre id="test-result">等待测试...</pre>
+                </div>
+            </div>
+            <div class="modal-footer">
+                <button type="button" class="btn btn-secondary" onclick="closeTestModal()">关闭</button>
+                <button type="button" class="btn btn-primary" onclick="runTest()">执行测试</button>
+            </div>
+        </div>
+    </div>
+
+    <script>
+        // 全局状态
+        let currentConfig = {};
+        let currentEditingFunction = null;
+
+        // 页面初始化
+        document.addEventListener('DOMContentLoaded', function() {
+            initNavigation();
+            loadConfig();
+            loadDashboard();
+            
+            // 定期刷新仪表盘数据
+            setInterval(loadDashboard, 30000);
+        });
+
+        // 导航功能
+        function initNavigation() {
+            // PC端导航
+            const sidebarItems = document.querySelectorAll('.sidebar .nav-item');
+            sidebarItems.forEach(item => {
+                item.addEventListener('click', () => {
+                    const page = item.dataset.page;
+                    switchPage(page);
+                    updateActiveNav(item, '.sidebar .nav-item');
+                });
+            });
+            
+            // 移动端导航
+            const bottomNavItems = document.querySelectorAll('.bottom-nav .nav-item');
+            bottomNavItems.forEach(item => {
+                item.addEventListener('click', () => {
+                    const page = item.dataset.page;
+                    switchPage(page);
+                    updateActiveNav(item, '.bottom-nav .nav-item');
+                });
+            });
+        }
+
+        function switchPage(pageId) {
+            // 隐藏所有页面
+            document.querySelectorAll('.page').forEach(page => {
+                page.classList.remove('active');
+            });
+            
+            // 显示目标页面
+            const targetPage = document.getElementById(pageId);
+            if (targetPage) {
+                targetPage.classList.add('active');
+                
+                // 加载页面数据
+                switch(pageId) {
+                    case 'dashboard':
+                        loadDashboard();
+                        break;
+                    case 'config':
+                        loadConfig();
+                        break;
+                    case 'functions':
+                        loadFunctions();
+                        break;
+                    case 'sessions':
+                        loadSessions();
+                        break;
+                    case 'logs':
+                        loadLogs();
+                        break;
+                }
+            }
+        }
+
+        function updateActiveNav(activeItem, selector) {
+            document.querySelectorAll(selector).forEach(item => {
+                item.classList.remove('active');
+            });
+            activeItem.classList.add('active');
+        }
+
+        // 仪表盘功能
+        async function loadDashboard() {
+            try {
+                // 加载会话数据
+                const sessionsResponse = await fetch('/api/sessions');
+                const sessions = await sessionsResponse.json();
+                
+                // 加载配置数据
+                const configResponse = await fetch('/api/config');
+                const config = await configResponse.json();
+                
+                // 更新统计数据
+                document.getElementById('service-status').textContent = '运行中';
+                document.getElementById('active-users').textContent = sessions.length;
+                document.getElementById('pending-tasks').textContent = sessions.filter(s => s.current_task).length;
+                document.getElementById('function-count').textContent = config.functions ? config.functions.length : 0;
+                
+            } catch (error) {
+                console.error('加载仪表盘数据失败:', error);
+                showNotification('加载仪表盘数据失败', 'error');
+            }
+        }
+
+        // 配置管理功能
+        async function loadConfig() {
+            try {
+                const response = await fetch('/api/config');
+                const config = await response.json();
+                currentConfig = config;
+                
+                // 填充表单
+                document.getElementById('text-model').value = config.models.text_model || '';
+                document.getElementById('image-model').value = config.models.image_model || '';
+                document.getElementById('image-gen-model').value = config.models.image_generation_model || '';
+                document.getElementById('system-prompt').value = config.system_prompt || '';
+                document.getElementById('max-workers').value = config.settings.max_workers || 10;
+                document.getElementById('request-timeout').value = config.settings.request_timeout || 60;
+                document.getElementById('max-message-length').value = config.settings.max_message_length || 500;
+                document.getElementById('session-timeout').value = config.settings.session_timeout || 3600;
+                
+            } catch (error) {
+                console.error('加载配置失败:', error);
+                showNotification('加载配置失败', 'error');
+            }
+        }
+
+        async function saveConfig() {
+            try {
+                const config = {
+                    models: {
+                        text_model: document.getElementById('text-model').value,
+                        image_model: document.getElementById('image-model').value,
+                        image_generation_model: document.getElementById('image-gen-model').value
+                    },
+                    system_prompt: document.getElementById('system-prompt').value,
+                    settings: {
+                        max_workers: parseInt(document.getElementById('max-workers').value),
+                        request_timeout: parseInt(document.getElementById('request-timeout').value),
+                        max_message_length: parseInt(document.getElementById('max-message-length').value),
+                        session_timeout: parseInt(document.getElementById('session-timeout').value)
+                    },
+                    functions: currentConfig.functions || []
+                };
+                
+                const response = await fetch('/api/config', {
+                    method: 'POST',
+                    headers: {
+                        'Content-Type': 'application/json'
+                    },
+                    body: JSON.stringify(config)
+                });
+                
+                const result = await response.json();
+                if (result.success) {
+                    showNotification('配置保存成功', 'success');
+                    currentConfig = config;
+                } else {
+                    showNotification(result.message, 'error');
+                }
+                
+            } catch (error) {
+                console.error('保存配置失败:', error);
+                showNotification('保存配置失败', 'error');
+            }
+        }
+
+        // Function管理功能
+        async function loadFunctions() {
+            try {
+                const response = await fetch('/api/config');
+                const config = await response.json();
+                const functions = config.functions || [];
+                
+                const container = document.getElementById('functions-list');
+                
+                if (functions.length === 0) {
+                    container.innerHTML = `
+                        <div class="empty-state">
+                            <svg viewBox="0 0 48 48">
+                                <rect x="8" y="16" width="32" height="16" rx="4" fill="none" stroke="currentColor" stroke-width="2"/>
+                                <path d="M16 24h16m-8-4v8" stroke="currentColor" stroke-width="2"/>
+                            </svg>
+                            <h3>暂无Function</h3>
+                            <p>点击右上角按钮添加您的第一个Function</p>
+                        </div>
+                    `;
+                    return;
+                }
+                
+                container.innerHTML = functions.map(func => `
+                    <div class="function-card">
+                        <div class="function-card-header">
+                            <div>
+                                <h4>${func.name}</h4>
+                                <p>${func.description}</p>
+                            </div>
+                            <span class="function-method method-${func.http_config.method.toLowerCase()}">
+                                ${func.http_config.method}
+                            </span>
+                        </div>
+                        <div class="function-url">
+                            <code>${func.http_config.url}</code>
+                        </div>
+                        <div class="function-actions">
+                            <button class="btn btn-secondary" onclick="editFunction('${func.name}')">编辑</button>
+                            <button class="btn btn-secondary" onclick="testFunctionDialog('${func.name}')">测试</button>
+                            <button class="btn btn-danger" onclick="deleteFunction('${func.name}')">删除</button>
+                        </div>
+                    </div>
+                `).join('');
+                
+            } catch (error) {
+                console.error('加载Functions失败:', error);
+                showNotification('加载Functions失败', 'error');
+            }
+        }
+
+        function showAddFunctionModal() {
+            currentEditingFunction = null;
+            document.getElementById('function-modal-title').textContent = '添加Function';
+            document.getElementById('function-form').reset();
+            
+            // 设置默认值
+            document.getElementById('func-headers').value = '{"Content-Type": "application/json"}';
+            document.getElementById('func-parameters').value = JSON.stringify({
+                "type": "object",
+                "properties": {
+                    "param1": {
+                        "type": "string",
+                        "description": "参数描述"
+                    }
+                },
+                "required": ["param1"]
+            }, null, 2);
+            
+            document.getElementById('function-modal').classList.add('active');
+        }
+
+        function editFunction(functionName) {
+            const func = currentConfig.functions.find(f => f.name === functionName);
+            if (!func) return;
+            
+            currentEditingFunction = functionName;
+            document.getElementById('function-modal-title').textContent = '编辑Function';
+            
+            // 填充表单
+            document.getElementById('func-name').value = func.name;
+            document.getElementById('func-description').value = func.description;
+            document.getElementById('func-method').value = func.http_config.method;
+            document.getElementById('func-url').value = func.http_config.url;
+            document.getElementById('func-headers').value = JSON.stringify(func.http_config.headers || {}, null, 2);
+            document.getElementById('func-body').value = JSON.stringify(func.http_config.body_template || {}, null, 2);
+            document.getElementById('func-parameters').value = JSON.stringify(func.parameters, null, 2);
+            document.getElementById('func-response-type').value = func.http_config.response_type || 'text';
+            
+            document.getElementById('function-modal').classList.add('active');
+        }
+
+        function closeFunctionModal() {
+            document.getElementById('function-modal').classList.remove('active');
+            currentEditingFunction = null;
+        }
+
+        async function saveFunction() {
+            try {
+                const formData = {
+                    name: document.getElementById('func-name').value,
+                    description: document.getElementById('func-description').value,
+                    parameters: JSON.parse(document.getElementById('func-parameters').value),
+                    http_config: {
+                        method: document.getElementById('func-method').value,
+                        url: document.getElementById('func-url').value,
+                        headers: JSON.parse(document.getElementById('func-headers').value || '{}'),
+                        body_template: JSON.parse(document.getElementById('func-body').value || '{}'),
+                        response_type: document.getElementById('func-response-type').value
+                    }
+                };
+                
+                // 验证必填字段
+                if (!formData.name || !formData.description || !formData.http_config.url) {
+                    showNotification('请填写所有必填字段', 'warning');
+                    return;
+                }
+                
+                // 更新配置
+                let functions = [...(currentConfig.functions || [])];
+                
+                if (currentEditingFunction) {
+                    // 编辑现有Function
+                    const index = functions.findIndex(f => f.name === currentEditingFunction);
+                    if (index !== -1) {
+                        functions[index] = formData;
+                    }
+                } else {
+                    // 添加新Function
+                    if (functions.find(f => f.name === formData.name)) {
+                        showNotification('Function名称已存在', 'warning');
+                        return;
+                    }
+                    functions.push(formData);
+                }
+                
+                const newConfig = {
+                    ...currentConfig,
+                    functions: functions
+                };
+                
+                const response = await fetch('/api/config', {
+                    method: 'POST',
+                    headers: {
+                        'Content-Type': 'application/json'
+                    },
+                    body: JSON.stringify(newConfig)
+                });
+                
+                const result = await response.json();
+                if (result.success) {
+                    showNotification('Function保存成功', 'success');
+                    currentConfig = newConfig;
+                    closeFunctionModal();
+                    loadFunctions();
+                } else {
+                    showNotification(result.message, 'error');
+                }
+                
+            } catch (error) {
+                console.error('保存Function失败:', error);
+                showNotification('保存Function失败，请检查JSON格式', 'error');
+            }
+        }
+
+        async function deleteFunction(functionName) {
+            if (!confirm('确定要删除这个Function吗？')) return;
+            
+            try {
+                const functions = currentConfig.functions.filter(f => f.name !== functionName);
+                const newConfig = {
+                    ...currentConfig,
+                    functions: functions
+                };
+                
+                const response = await fetch('/api/config', {
+                    method: 'POST',
+                    headers: {
+                        'Content-Type': 'application/json'
+                    },
+                    body: JSON.stringify(newConfig)
+                });
+                
+                const result = await response.json();
+                if (result.success) {
+                    showNotification('Function删除成功', 'success');
+                    currentConfig = newConfig;
+                    loadFunctions();
+                } else {
+                    showNotification(result.message, 'error');
+                }
+                
+            } catch (error) {
+                console.error('删除Function失败:', error);
+                showNotification('删除Function失败', 'error');
+            }
+        }
+
+        // Function测试功能
+        function testFunctionDialog(functionName) {
+            const func = currentConfig.functions.find(f => f.name === functionName);
+            if (!func) return;
+            
+            currentEditingFunction = functionName;
+            
+            // 生成示例参数
+            const exampleParams = {};
+            if (func.parameters && func.parameters.properties) {
+                Object.keys(func.parameters.properties).forEach(key => {
+                    const prop = func.parameters.properties[key];
+                    switch(prop.type) {
+                        case 'string':
+                            exampleParams[key] = '示例文本';
+                            break;
+                        case 'number':
+                            exampleParams[key] = 123;
+                            break;
+                        case 'boolean':
+                            exampleParams[key] = true;
+                            break;
+                        default:
+                            exampleParams[key] = '示例值';
+                    }
+                });
+            }
+            
+            document.getElementById('test-params').value = JSON.stringify(exampleParams, null, 2);
+            document.getElementById('test-result').textContent = '等待测试...';
+            document.getElementById('test-modal').classList.add('active');
+        }
+
+        function closeTestModal() {
+            document.getElementById('test-modal').classList.remove('active');
+        }
+
+        async function runTest() {
+            try {
+                const params = JSON.parse(document.getElementById('test-params').value);
+                
+                document.getElementById('test-result').textContent = '测试中...';
+                
+                const response = await fetch('/api/test-function', {
+                    method: 'POST',
+                    headers: {
+                        'Content-Type': 'application/json'
+                    },
+                    body: JSON.stringify({
+                        function_name: currentEditingFunction,
+                        arguments: params
+                    })
+                });
+                
+                const result = await response.json();
+                
+                if (result.success) {
+                    document.getElementById('test-result').textContent = JSON.stringify(result.result, null, 2);
+                    showNotification('测试成功', 'success');
+                } else {
+                    document.getElementById('test-result').textContent = `错误: ${result.error}`;
+                    showNotification('测试失败', 'error');
+                }
+                
+            } catch (error) {
+                console.error('Function测试失败:', error);
+                document.getElementById('test-result').textContent = `错误: ${error.message}`;
+                showNotification('测试失败，请检查参数格式', 'error');
+            }
+        }
+
+        function testFunction() {
+            // 先保存Function，然后测试
+            saveFunction().then(() => {
+                if (currentEditingFunction) {
+                    closeFunctionModal();
+                    setTimeout(() => {
+                        testFunctionDialog(currentEditingFunction);
+                    }, 100);
+                }
+            });
+        }
+
+        // 会话管理功能
+        async function loadSessions() {
+            try {
+                const response = await fetch('/api/sessions');
+                const sessions = await response.json();
+                
+                const tbody = document.getElementById('sessions-tbody');
+                
+                if (sessions.length === 0) {
+                    tbody.innerHTML = `
+                        <tr>
+                            <td colspan="5" style="text-align: center; padding: 40px; color: #666;">
+                                暂无活跃会话
+                            </td>
+                        </tr>
+                    `;
+                    return;
+                }
+                
+                tbody.innerHTML = sessions.map(session => {
+                    const lastActive = new Date(session.last_active * 1000).toLocaleString();
+                    let status = 'idle';
+                    let statusText = '空闲';
+                    
+                    if (session.current_task) {
+                        status = 'pending';
+                        statusText = '处理中';
+                    } else if (session.has_pending) {
+                        status = 'active';
+                        statusText = '活跃';
+                    }
+                    
+                    return `
+                        <tr>
+                            <td>${session.user_id}</td>
+                            <td>${lastActive}</td>
+                            <td>${session.message_count}</td>
+                            <td><span class="session-status status-${status}">${statusText}</span></td>
+                            <td>
+                                <button class="btn btn-secondary" onclick="clearSession('${session.user_id}')">
+                                    清理会话
+                                </button>
+                            </td>
+                        </tr>
+                    `;
+                }).join('');
+                
+            } catch (error) {
+                console.error('加载会话数据失败:', error);
+                showNotification('加载会话数据失败', 'error');
+            }
+        }
+
+        async function clearSession(userId) {
+            if (!confirm(`确定要清理用户 ${userId} 的会话吗？`)) return;
+            
+            try {
+                const response = await fetch(`/api/sessions/${userId}/clear`, {
+                    method: 'POST'
+                });
+                
+                const result = await response.json();
+                if (result.success) {
+                    showNotification('会话清理成功', 'success');
+                    loadSessions();
+                } else {
+                    showNotification(result.message, 'error');
+                }
+                
+            } catch (error) {
+                console.error('清理会话失败:', error);
+                showNotification('清理会话失败', 'error');
+            }
+        }
+
+        function refreshSessions() {
+            loadSessions();
+        }
+
+        // 日志管理功能
+        async function loadLogs() {
+            try {
+                const response = await fetch('/api/logs?lines=200');
+                const result = await response.json();
+                
+                if (result.logs) {
+                    document.getElementById('logs-content').textContent = result.logs.join('');
+                    
+                    // 滚动到底部
+                    const container = document.querySelector('.logs-container');
+                    container.scrollTop = container.scrollHeight;
+                } else {
+                    document.getElementById('logs-content').textContent = result.error || '加载日志失败';
+                }
+                
+            } catch (error) {
+                console.error('加载日志失败:', error);
+                document.getElementById('logs-content').textContent = '加载日志失败';
+                showNotification('加载日志失败', 'error');
+            }
+        }
+
+        function refreshLogs() {
+            loadLogs();
+        }
+
+        // 通知功能
+        function showNotification(message, type = 'info') {
+            const notification = document.createElement('div');
+            notification.className = `notification ${type}`;
+            notification.textContent = message;
+            
+            document.body.appendChild(notification);
+            
+            // 显示动画
+            setTimeout(() => {
+                notification.classList.add('show');
+            }, 100);
+            
+            // 自动隐藏
+            setTimeout(() => {
+                notification.classList.remove('show');
+                setTimeout(() => {
+                    document.body.removeChild(notification);
+                }, 300);
+            }, 3000);
+        }
+
+        // 键盘快捷键
+        document.addEventListener('keydown', function(e) {
+            // ESC关闭模态框
+            if (e.key === 'Escape') {
+                document.querySelectorAll('.modal.active').forEach(modal => {
+                    modal.classList.remove('active');
+                });
+            }
+            
+            // Ctrl+S保存配置
+            if (e.ctrlKey && e.key === 's') {
+                e.preventDefault();
+                const activePage = document.querySelector('.page.active');
+                if (activePage && activePage.id === 'config') {
+                    saveConfig();
+                }
+            }
+        });
+
+        // 点击模态框背景关闭
+        document.addEventListener('click', function(e) {
+            if (e.target.classList.contains('modal')) {
+                e.target.classList.remove('active');
+            }
+        });
+    </script>
+</body>
+</html>

wechat_service.py

@@ -0,0 +1,612 @@
+from flask import Flask, request, make_response
+import hashlib
+import time
+import xml.etree.ElementTree as ET
+import os
+import json
+from openai import OpenAI
+from dotenv import load_dotenv
+from markdown import markdown
+import re
+import threading
+import logging
+from datetime import datetime
+import asyncio
+from concurrent.futures import ThreadPoolExecutor
+import queue
+import uuid
+import base64
+from Crypto.Cipher import AES
+import struct
+import random
+import string
+import requests
+
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(levelname)s - %(message)s',
+    handlers=[
+        logging.FileHandler('wechat_service.log'),
+        logging.StreamHandler()
+    ]
+)
+
+load_dotenv()
+
+# Configuration
+TOKEN = os.getenv('TOKEN')
+ENCODING_AES_KEY = os.getenv('ENCODING_AES_KEY')
+APPID = os.getenv('APPID')
+APPSECRET = os.getenv('APPSECRET')
+API_KEY = os.getenv("API_KEY")
+BASE_URL = os.getenv("OPENAI_BASE_URL")
+IMAGE_MODEL_URL = os.getenv("IMAGE_MODEL_URL")
+IMAGE_MODEL_KEY = os.getenv("IMAGE_MODEL_KEY")
+
+client = OpenAI(api_key=API_KEY, base_url=BASE_URL)
+executor = ThreadPoolExecutor(max_workers=10)
+
+# Define tools for image generation
+TOOLS = [
+    {
+        "type": "function",
+        "function": {
+            "name": "generate_image",
+            "description": "Generate an image based on text description",
+            "parameters": {
+                "type": "object",
+                "properties": {
+                    "prompt": {
+                        "type": "string",
+                        "description": "The description of the image to generate"
+                    }
+                },
+                "required": ["prompt"]
+            }
+        }
+    }
+]
+
+class AccessTokenManager:
+    def __init__(self):
+        self._access_token = None
+        self._expires_at = 0
+        self._lock = threading.Lock()
+
+    def get_token(self):
+        with self._lock:
+            now = time.time()
+            # 提前5分钟刷新token，确保在调用时token都是有效的
+            if self._access_token and now < (self._expires_at - 300):
+                return self._access_token
+
+            try:
+                url = "https://api.weixin.qq.com/cgi-bin/token"
+                params = {
+                    "grant_type": "client_credential",
+                    "appid": APPID,
+                    "secret": APPSECRET
+                }
+                
+                logging.info("开始获取新的access_token")
+                response = requests.get(url, params=params)
+                response.raise_for_status()
+                result = response.json()
+                
+                if "access_token" not in result:
+                    error_msg = f"获取access_token失败: {result}"
+                    logging.error(error_msg)
+                    raise ValueError(error_msg)
+                
+                self._access_token = result["access_token"]
+                self._expires_at = now + result["expires_in"]
+                logging.info("成功获取新的access_token")
+                
+                return self._access_token
+                
+            except Exception as e:
+                error_msg = f"获取access_token时发生错误: {str(e)}"
+                logging.error(error_msg)
+                raise
+
+    def refresh_token(self):
+        with self._lock:
+            self._access_token = None
+            return self.get_token()
+            
+class WeChatCrypto:
+    def __init__(self, key, app_id):
+        self.key = base64.b64decode(key + '=')
+        self.app_id = app_id
+
+    def encrypt(self, text):
+        random_str = ''.join(random.choices(string.ascii_letters + string.digits, k=16))
+        text_bytes = text.encode('utf-8')
+        msg_len = struct.pack('>I', len(text_bytes))
+        message = random_str.encode('utf-8') + msg_len + text_bytes + self.app_id.encode('utf-8')
+        pad_len = 32 - (len(message) % 32)
+        message += chr(pad_len).encode('utf-8') * pad_len
+        cipher = AES.new(self.key, AES.MODE_CBC, self.key[:16])
+        encrypted = cipher.encrypt(message)
+        return base64.b64encode(encrypted).decode('utf-8')
+
+    def decrypt(self, encrypted_text):
+        encrypted_data = base64.b64decode(encrypted_text)
+        cipher = AES.new(self.key, AES.MODE_CBC, self.key[:16])
+        decrypted = cipher.decrypt(encrypted_data)
+        pad_len = decrypted[-1]
+        if not isinstance(pad_len, int):
+            pad_len = ord(pad_len)
+        content = decrypted[16:-pad_len]
+        msg_len = struct.unpack('>I', content[:4])[0]
+        xml_content = content[4:msg_len + 4].decode('utf-8')
+        app_id = content[msg_len + 4:].decode('utf-8')
+        if app_id != self.app_id:
+            raise ValueError('Invalid AppID')
+        return xml_content
+
+class AsyncResponse:
+    def __init__(self):
+        self.status = "processing"
+        self.result = None
+        self.error = None
+        self.create_time = time.time()
+        self.timeout = 3600
+        self.response_type = "text"  # Can be "text" or "image"
+        self.media_id = None  # For image responses
+
+    def is_expired(self):
+        return time.time() - self.create_time > self.timeout
+
+class UserSession:
+    def __init__(self):
+        self.messages = [{"role": "system", "content": "你是HXIAO公众号的智能助手，这一个用来分享与学习人工智能的公众号，我们的目标是专注AI应用的简单研究与实践。致力于分享切实可行的技术方案，希望让复杂的技术变得简单易懂。也喜欢用通俗的语言来解释专业概念，让技术真正服务于每个学习者"}]
+        self.pending_parts = []
+        self.last_active = time.time()
+        self.current_task = None
+        self.response_queue = {}
+        self.session_timeout = 3600
+
+    def is_expired(self):
+        return time.time() - self.last_active > self.session_timeout
+
+    def cleanup_expired_tasks(self):
+        expired_tasks = [
+            task_id for task_id, response in self.response_queue.items()
+            if response.is_expired()
+        ]
+        for task_id in expired_tasks:
+            del self.response_queue[task_id]
+            if self.current_task == task_id:
+                self.current_task = None
+
+class SessionManager:
+    def __init__(self):
+        self.sessions = {}
+        self._lock = threading.Lock()
+        self.crypto = WeChatCrypto(ENCODING_AES_KEY, APPID)
+
+    def get_session(self, user_id):
+        with self._lock:
+            current_time = time.time()
+            if user_id in self.sessions:
+                session = self.sessions[user_id]
+                if session.is_expired():
+                    session = UserSession()
+                else:
+                    session.cleanup_expired_tasks()
+            else:
+                session = UserSession()
+            session.last_active = current_time
+            self.sessions[user_id] = session
+            return session
+
+    def clear_session(self, user_id):
+        with self._lock:
+            if user_id in self.sessions:
+                self.sessions[user_id] = UserSession()
+
+    def cleanup_expired_sessions(self):
+        with self._lock:
+            current_time = time.time()
+            expired_users = [
+                user_id for user_id, session in self.sessions.items()
+                if session.is_expired()
+            ]
+            for user_id in expired_users:
+                del self.sessions[user_id]
+                logging.info(f"已清理过期会话: {user_id}")
+
+def convert_markdown_to_wechat(md_text):
+    if not md_text:
+        return md_text
+        
+    md_text = re.sub(r'^# (.*?)$', r'【标题】\1', md_text, flags=re.MULTILINE)
+    md_text = re.sub(r'^## (.*?)$', r'【子标题】\1', md_text, flags=re.MULTILINE)
+    md_text = re.sub(r'^### (.*?)$', r'【小标题】\1', md_text, flags=re.MULTILINE)
+    md_text = re.sub(r'\*\*(.*?)\*\*', r'『\1』', md_text)
+    md_text = re.sub(r'\*(.*?)\*', r'「\1」', md_text)
+    md_text = re.sub(r'`(.*?)`', r'「\1」', md_text)
+    md_text = re.sub(r'^\- ', '• ', md_text, flags=re.MULTILINE)
+    md_text = re.sub(r'^\d\. ', '○ ', md_text, flags=re.MULTILINE)
+    md_text = re.sub(r'```[\w]*\n(.*?)```', r'【代码开始】\n\1\n【代码结束】', md_text, flags=re.DOTALL)
+    md_text = re.sub(r'^> (.*?)$', r'▎\1', md_text, flags=re.MULTILINE)
+    md_text = re.sub(r'^-{3,}$', r'—————————', md_text, flags=re.MULTILINE)
+    md_text = re.sub(r'\[(.*?)\]\((.*?)\)', r'\1（\2）', md_text)
+    md_text = re.sub(r'\n{3,}', '\n\n', md_text)
+    
+    return md_text
+
+def verify_signature(signature, timestamp, nonce, token):
+    items = [token, timestamp, nonce]
+    items.sort()
+    temp_str = ''.join(items)
+    hash_sha1 = hashlib.sha1(temp_str.encode('utf-8')).hexdigest()
+    return hash_sha1 == signature
+
+def verify_msg_signature(msg_signature, timestamp, nonce, token, encrypt_msg):
+    """
+    验证消息签名
+    Args:
+        msg_signature: 消息签名
+        timestamp: 时间戳
+        nonce: 随机数
+        token: 验证令牌
+        encrypt_msg: 加密的消息内容
+    Returns:
+        bool: 签名是否有效
+    """
+    items = [token, timestamp, nonce, encrypt_msg]
+    items.sort()
+    temp_str = ''.join(items)
+    hash_sha1 = hashlib.sha1(temp_str.encode('utf-8')).hexdigest()
+    return hash_sha1 == msg_signature
+
+
+def parse_xml_message(xml_content):
+    """
+    解析微信XML消息，支持文本和图片消息类型
+    """
+    root = ET.fromstring(xml_content)
+    message = {
+        'from_user': root.find('FromUserName').text,
+        'to_user': root.find('ToUserName').text,
+        'create_time': root.find('CreateTime').text,
+        'msg_type': root.find('MsgType').text,
+        'msg_id': root.find('MsgId').text if root.find('MsgId') is not None else '',
+        'msg_data_id': root.find('MsgDataId').text if root.find('MsgDataId') is not None else '',
+        'idx': root.find('Idx').text if root.find('Idx') is not None else ''
+    }
+    
+    if message['msg_type'] == 'text':
+        message['content'] = root.find('Content').text if root.find('Content') is not None else ''
+    elif message['msg_type'] == 'image':
+        message['pic_url'] = root.find('PicUrl').text
+        message['media_id'] = root.find('MediaId').text
+    
+    return message
+
+def get_image_content(media_id):
+    """
+    通过微信接口获取图片内容
+    """
+    try:
+        access_token = token_manager.get_token()
+        url = f'https://api.weixin.qq.com/cgi-bin/media/get?access_token={access_token}&media_id={media_id}'
+        
+        logging.info(f"开始下载图片，media_id: {media_id}")
+        response = requests.get(url)
+        
+        if response.headers.get('Content-Type') == 'text/plain':
+            # 如果返回JSON错误信息
+            error_info = response.json()
+            if error_info.get('errcode') == 40001:
+                # access_token过期，刷新后重试
+                logging.info("access_token已过期，正在刷新并重试")
+                access_token = token_manager.refresh_token()
+                url = f'https://api.weixin.qq.com/cgi-bin/media/get?access_token={access_token}&media_id={media_id}'
+                response = requests.get(url)
+        
+        response.raise_for_status()
+        return response.content
+        
+    except Exception as e:
+        logging.error(f"获取图片内容失败: {str(e)}")
+        raise
+
+
+def generate_response_xml(to_user, from_user, content, response_type='text', media_id=None, encrypt_type='aes'):
+    timestamp = str(int(time.time()))
+    nonce = ''.join(random.choices(string.ascii_letters + string.digits, k=10))
+    
+    if response_type == 'image' and media_id:
+        xml_content = f'''
+        <xml>
+            <ToUserName><![CDATA[{to_user}]]></ToUserName>
+            <FromUserName><![CDATA[{from_user}]]></FromUserName>
+            <CreateTime>{timestamp}</CreateTime>
+            <MsgType><![CDATA[image]]></MsgType>
+            <Image>
+                <MediaId><![CDATA[{media_id}]]></MediaId>
+            </Image>
+        </xml>
+        '''
+    else:
+        formatted_content = convert_markdown_to_wechat(content)
+        xml_content = f'''
+        <xml>
+            <ToUserName><![CDATA[{to_user}]]></ToUserName>
+            <FromUserName><![CDATA[{from_user}]]></FromUserName>
+            <CreateTime>{timestamp}</CreateTime>
+            <MsgType><![CDATA[text]]></MsgType>
+            <Content><![CDATA[{formatted_content}]]></Content>
+        </xml>
+        '''
+    
+    if encrypt_type == 'aes':
+        encrypted = session_manager.crypto.encrypt(xml_content)
+        signature_list = [TOKEN, timestamp, nonce, encrypted]
+        signature_list.sort()
+        msg_signature = hashlib.sha1(''.join(signature_list).encode('utf-8')).hexdigest()
+        
+        response_xml = f'''
+        <xml>
+            <Encrypt><![CDATA[{encrypted}]]></Encrypt>
+            <MsgSignature><![CDATA[{msg_signature}]]></MsgSignature>
+            <TimeStamp>{timestamp}</TimeStamp>
+            <Nonce><![CDATA[{nonce}]]></Nonce>
+        </xml>
+        '''
+    else:
+        response_xml = xml_content
+    
+    response = make_response(response_xml)
+    response.content_type = 'application/xml'
+    return response
+    
+# 创建全局的token管理器实例
+token_manager = AccessTokenManager()
+
+def upload_image_to_wechat(image_data):
+    """上传图片到微信服务器并获取media_id"""
+    try:
+        access_token = token_manager.get_token()
+        upload_url = f'https://api.weixin.qq.com/cgi-bin/media/upload?access_token={access_token}&type=image'
+        files = {'media': ('image.jpg', image_data, 'image/jpeg')}
+        
+        logging.info("开始上传图片到微信服务器")
+        response = requests.post(upload_url, files=files)
+        response.raise_for_status()
+        result = response.json()
+        
+        if 'media_id' not in result:
+            if 'errcode' in result and result['errcode'] == 40001:
+                # access_token 可能过期，尝试刷新并重试
+                logging.info("access_token已过期，正在刷新并重试")
+                access_token = token_manager.refresh_token()
+                upload_url = f'https://api.weixin.qq.com/cgi-bin/media/upload?access_token={access_token}&type=image'
+                response = requests.post(upload_url, files=files)
+                response.raise_for_status()
+                result = response.json()
+            
+            if 'media_id' not in result:
+                error_msg = f"上传图片失败: {result}"
+                logging.error(error_msg)
+                raise ValueError(error_msg)
+        
+        logging.info(f"图片上传成功，获取到media_id")
+        return result['media_id']
+        
+    except Exception as e:
+        error_msg = f"上传图片过程中发生错误: {str(e)}"
+        logging.error(error_msg)
+        raise
+
+def process_long_running_task(messages, message_type='text', image_data=None):
+    """
+    处理长时间运行的任务，支持文本对话和图片识别
+    """
+    try:
+        logging.info(f"开始调用AI服务，消息类型: {message_type}")
+        
+        if message_type == 'image':
+            # 图片识别逻辑保持不变
+            try:
+                image_content = get_image_content(image_data['media_id'])
+                image_base64 = base64.b64encode(image_content).decode('utf-8')
+                
+                image_messages = [
+                    {
+                        "role": "user",
+                        "content": [
+                            {"type": "text", "text": "请详细描述这张图片中的内容，包括主要对象、场景、活动等关键信息"},
+                            {
+                                "type": "image_url",
+                                "image_url": {
+                                    "url": f"data:image/jpeg;base64,{image_base64}"
+                                }
+                            }
+                        ]
+                    }
+                ]
+                
+                logging.info("开始调用图像识别模型")
+                image_response = client.chat.completions.create(
+                    model="gpt-4.1-mini",
+                    messages=image_messages,
+                    max_tokens=300,
+                    timeout=60
+                )
+                logging.info("图像识别完成")
+                
+                if not image_response.choices:
+                    raise Exception("图像识别服务未返回有效结果")
+                    
+                return {
+                    "type": "text",
+                    "content": image_response.choices[0].message.content
+                }
+                
+            except Exception as e:
+                logging.error(f"图像识别过程中发生错误: {str(e)}")
+                raise
+                
+        else:
+            # 处理文本消息
+            try:
+                logging.info("开始处理文本消息")
+                response = client.chat.completions.create(
+                    model="gpt-4.1-mini",
+                    messages=messages,
+                    tools=TOOLS,
+                    tool_choice="auto",
+                    timeout=60
+                )
+                
+                # 检查是否需要生成图片
+                if response.choices[0].message.tool_calls:
+                    tool_call = response.choices[0].message.tool_calls[0]
+                    if tool_call.function.name == "generate_image":
+                        try:
+                            logging.info("检测到图片生成请求")
+                            args = json.loads(tool_call.function.arguments)
+                            
+                            # 使用新的DALL-E 3 API进行图片生成
+                            image_generation_response = requests.post(
+                                "https://api1.oaipro.com/v1/images/generations",
+                                headers={
+                                    'Content-Type': 'application/json',
+                                    'Authorization': f'Bearer {API_KEY}'
+                                },
+                                json={
+                                    "model": "dall-e-3",
+                                    "prompt": args['prompt'],
+                                    "n": 1,
+                                    "size": "1024x1024"
+                                },
+                                timeout=60
+                            )
+                            image_generation_response.raise_for_status()
+                            generation_result = image_generation_response.json()
+                            
+                            if 'data' not in generation_result or not generation_result['data']:
+                                raise Exception("图片生成服务未返回有效结果")
+                            
+                            # 获取生成的图片URL
+                            image_url = generation_result['data'][0]['url']
+                            
+                            # 下载生成的图片
+                            img_response = requests.get(image_url, timeout=30)
+                            img_response.raise_for_status()
+                            
+                            # 上传图片到微信服务器
+                            media_id = upload_image_to_wechat(img_response.content)
+                            
+                            return {
+                                "type": "image",
+                                "media_id": media_id
+                            }
+                            
+                        except requests.exceptions.RequestException as e:
+                            logging.error(f"图片生成过程中发生网络错误: {str(e)}")
+                            raise
+                        except Exception as e:
+                            logging.error(f"图片生成过程中发生错误: {str(e)}")
+                            raise
+                
+                # 返回文本响应
+                return {
+                    "type": "text",
+                    "content": response.choices[0].message.content
+                }
+                
+            except requests.exceptions.RequestException as e:
+                logging.error(f"处理文本消息时发生网络错误: {str(e)}")
+                raise
+            except Exception as e:
+                logging.error(f"处理文本消息时发生错误: {str(e)}")
+                raise
+                
+    except Exception as e:
+        logging.error(f"API调用错误: {str(e)}")
+        raise
+
+def handle_async_task(session, task_id, messages=None, message_type='text', message_data=None):
+    """
+    处理异步任务，支持文本对话和图片识别
+    """
+    try:
+        logging.info(f"开始处理异步任务: {task_id}, 类型: {message_type}")
+        
+        if task_id not in session.response_queue:
+            return
+            
+        if message_type == 'image':
+            result = process_long_running_task(None, 'image', message_data)
+        else:
+            result = process_long_running_task(messages)
+            
+        if task_id in session.response_queue and not session.response_queue[task_id].is_expired():
+            session.response_queue[task_id].status = "completed"
+            session.response_queue[task_id].response_type = result.get("type", "text")
+            
+            if result["type"] == "image":
+                session.response_queue[task_id].media_id = result["media_id"]
+                session.response_queue[task_id].result = None
+            else:
+                session.response_queue[task_id].result = result["content"]
+                
+            if messages and result["type"] == "text":
+                messages.append({"role": "assistant", "content": result["content"]})
+                
+    except Exception as e:
+        logging.error(f"异步任务处理失败: {str(e)}")
+        if task_id in session.response_queue:
+            session.response_queue[task_id].status = "failed"
+            session.response_queue[task_id].error = str(e)
+
+
+def generate_initial_response():
+    return "您的请求正在处理中，请回复'查询'获取结果（生图需要时间）"
+
+def split_message(message, max_length=500):
+    """
+    将长消息分割成多个部分
+    Args:
+        message: 需要分割的消息
+        max_length: 每部分的最大长度
+    Returns:
+        list: 分割后的消息部分列表
+    """
+    return [message[i:i+max_length] for i in range(0, len(message), max_length)]
+
+def append_status_message(content, has_pending_parts=False, is_processing=False):
+    """
+    添加状态消息到响应内容
+    Args:
+        content: 原始内容
+        has_pending_parts: 是否有待发送的部分
+        is_processing: 是否正在处理中
+    Returns:
+        str: 添加了状态信息的内容
+    """
+    if "您的请求正在处理中" in content:
+        return content + "\n\n-------------------\n发送'新对话'开始新的对话"
+        
+    status_message = "\n\n-------------------"
+    if is_processing:
+        status_message += "\n请回复'查询'获取结果"
+    elif has_pending_parts:
+        status_message += "\n当前消息已截断，发送'继续'查看后续内容"
+    status_message += "\n发送'新对话'开始新的对话"
+    return content + status_message
+
+session_manager = SessionManager()
+
+def cleanup_sessions():
+    while True:
+        time.sleep(3600)  # 每小时清理一次
+        try:
+            session_manager.cleanup_expired_sessions()
+        except Exception as e:
+            logging.error(f"清理会话时出错: {str(e)}")