From ba6640052ad83b955e4af92b86196ca2a9f8e6f0 Mon Sep 17 00:00:00 2001
From: 15945162479 <15945162479@qq.com>
Date: Sat, 13 Dec 2025 14:46:05 +0800
Subject: [PATCH] Add File

---
 server/app.py | 2425 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 2425 insertions(+)
 create mode 100644 server/app.py

diff --git a/server/app.py b/server/app.py
new file mode 100644
index 0000000..fb529a0
--- /dev/null
+++ b/server/app.py
@@ -0,0 +1,2425 @@
+"""
+KinEcho 服务端 - Flask应用主入口
+支持家人端和老人端的日程同步管理
+"""
+from flask import Flask, request, jsonify, send_from_directory, Response
+from flask_cors import CORS
+from datetime import datetime, timedelta, timezone
+import sqlite3
+import os
+import json
+import time
+import requests
+from werkzeug.utils import secure_filename
+
+app = Flask(__name__)
+CORS(app)  # 允许跨域请求
+
+# 北京时区 (UTC+8)
+BEIJING_TZ = timezone(timedelta(hours=8))
+
+def get_beijing_time():
+    """获取当前北京时间"""
+    return datetime.now(BEIJING_TZ)
+
+def utc_to_beijing(utc_str):
+    """将UTC时间字符串转换为北京时间字符串"""
+    if not utc_str:
+        return None
+    try:
+        # 解析UTC时间（SQLite的CURRENT_TIMESTAMP格式）
+        utc_dt = datetime.strptime(utc_str, '%Y-%m-%d %H:%M:%S')
+        # 添加UTC时区信息
+        utc_dt = utc_dt.replace(tzinfo=timezone.utc)
+        # 转换为北京时间
+        beijing_dt = utc_dt.astimezone(BEIJING_TZ)
+        # 返回不带时区信息的字符串
+        return beijing_dt.strftime('%Y-%m-%d %H:%M:%S')
+    except:
+        return utc_str
+
+# 数据库配置
+DB_PATH = os.path.join(os.path.dirname(__file__), 'kinecho.db')
+
+# 文件上传配置
+UPLOAD_FOLDER = os.path.join(os.path.dirname(__file__), 'uploads')
+ALLOWED_EXTENSIONS = {'png', 'jpg', 'jpeg', 'gif', 'mp4', 'mov', 'avi'}
+MAX_FILE_SIZE = 100 * 1024 * 1024  # 100MB
+
+# 确保上传目录存在
+os.makedirs(UPLOAD_FOLDER, exist_ok=True)
+os.makedirs(os.path.join(UPLOAD_FOLDER, 'thumbnails'), exist_ok=True)
+
+app.config['UPLOAD_FOLDER'] = UPLOAD_FOLDER
+app.config['MAX_CONTENT_LENGTH'] = MAX_FILE_SIZE
+
+def allowed_file(filename):
+    """检查文件扩展名是否允许"""
+    return '.' in filename and filename.rsplit('.', 1)[1].lower() in ALLOWED_EXTENSIONS
+
+def generate_video_thumbnail(video_path, filename):
+    """使用ffmpeg生成视频缩略图"""
+    import subprocess
+
+    thumbnail_filename = filename.rsplit('.', 1)[0] + '_thumb.jpg'
+    thumbnail_path = os.path.join(UPLOAD_FOLDER, 'thumbnails', thumbnail_filename)
+
+    try:
+        # 使用ffmpeg截取第1秒的帧作为缩略图
+        cmd = [
+            'ffmpeg', '-i', video_path,
+            '-ss', '00:00:01',
+            '-vframes', '1',
+            '-vf', 'scale=320:-1',
+            '-y', thumbnail_path
+        ]
+        subprocess.run(cmd, capture_output=True, check=True, timeout=30)
+        return thumbnail_path
+    except Exception as e:
+        print(f'生成视频缩略图失败: {e}')
+        return None
+
+def generate_photo_thumbnail(photo_path, filename):
+    """生成图片缩略图"""
+    from PIL import Image
+
+    thumbnail_filename = filename.rsplit('.', 1)[0] + '_thumb.jpg'
+    thumbnail_path = os.path.join(UPLOAD_FOLDER, 'thumbnails', thumbnail_filename)
+
+    try:
+        with Image.open(photo_path) as img:
+            # 转换为RGB（处理PNG等格式）
+            if img.mode in ('RGBA', 'P'):
+                img = img.convert('RGB')
+            # 生成缩略图，保持比例
+            img.thumbnail((320, 320))
+            img.save(thumbnail_path, 'JPEG', quality=85)
+        return thumbnail_path
+    except Exception as e:
+        print(f'生成图片缩略图失败: {e}')
+        return None
+
+def get_db():
+    """获取数据库连接"""
+    conn = sqlite3.connect(DB_PATH)
+    conn.row_factory = sqlite3.Row  # 返回字典格式
+    return conn
+
+def init_db():
+    """初始化数据库"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 用户表
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS users (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            user_type TEXT NOT NULL,  -- 'family' 或 'elderly'
+            name TEXT NOT NULL,
+            phone TEXT,
+            family_id TEXT,  -- 家庭组ID，关联家人和老人
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+    ''')
+
+    # 日程/护理计划表
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS schedules (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            family_id TEXT NOT NULL,  -- 家庭组ID
+            title TEXT NOT NULL,  -- 日程标题
+            description TEXT,  -- 详细描述
+            schedule_type TEXT,  -- 类型：medication(用药)、exercise(运动)、meal(饮食)、checkup(检查)等
+            schedule_time TIMESTAMP NOT NULL,  -- 日程时间
+            repeat_type TEXT DEFAULT 'once',  -- 重复类型：once, daily, weekly, monthly
+            repeat_days TEXT,  -- 重复的星期几，JSON格式：[1,3,5]
+            status TEXT DEFAULT 'pending',  -- 状态：pending(待执行), completed(已完成), skipped(已放弃), missed(已错过)
+            completed_at TIMESTAMP,  -- 完成时间
+            auto_remind INTEGER DEFAULT 1,  -- 数字人自动播报：1=启用，0=禁用
+            is_active INTEGER DEFAULT 1,  -- 是否启用
+            created_by INTEGER,  -- 创建者用户ID
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY (created_by) REFERENCES users(id)
+        )
+    ''')
+
+    # 提醒记录表
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS reminders (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            schedule_id INTEGER NOT NULL,
+            elderly_id INTEGER NOT NULL,  -- 老人用户ID
+            remind_time TIMESTAMP NOT NULL,  -- 提醒时间
+            status TEXT DEFAULT 'pending',  -- pending, completed, missed, dismissed
+            completed_at TIMESTAMP,
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY (schedule_id) REFERENCES schedules(id),
+            FOREIGN KEY (elderly_id) REFERENCES users(id)
+        )
+    ''')
+
+    # 媒体文件表
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS media (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            family_id TEXT NOT NULL,  -- 家庭组ID
+            media_type TEXT NOT NULL,  -- 'photo' 或 'video'
+            title TEXT NOT NULL,  -- 媒体标题
+            description TEXT,  -- 描述
+            file_path TEXT NOT NULL,  -- 文件存储路径
+            file_size INTEGER,  -- 文件大小（字节）
+            duration INTEGER,  -- 视频时长（秒），仅视频有值
+            thumbnail_path TEXT,  -- 缩略图路径
+            uploaded_by INTEGER,  -- 上传者用户ID
+            is_active INTEGER DEFAULT 1,  -- 是否启用
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY (uploaded_by) REFERENCES users(id)
+        )
+    ''')
+
+    # 媒体标签表
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS media_tags (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            media_id INTEGER NOT NULL,
+            tag TEXT NOT NULL,  -- 标签内容，如 '孙女小米', '生日', '旅行' 等
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY (media_id) REFERENCES media(id) ON DELETE CASCADE
+        )
+    ''')
+
+    # 媒体触发策略表
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS media_policies (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            media_id INTEGER NOT NULL,
+            time_windows TEXT,  -- 播放时段，JSON格式：["07:00-09:00", "19:00-21:00"]
+            moods TEXT,  -- 适合心境，JSON格式：["happy", "sad", "calm"]
+            occasions TEXT,  -- 特殊场合，JSON格式：["birthday", "anniversary"]
+            cooldown INTEGER DEFAULT 60,  -- 冷却时间（分钟），避免重复播放
+            priority INTEGER DEFAULT 5,  -- 优先级 1-10，数字越大优先级越高
+            last_played_at TIMESTAMP,  -- 上次播放时间
+            play_count INTEGER DEFAULT 0,  -- 播放次数
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY (media_id) REFERENCES media(id) ON DELETE CASCADE
+        )
+    ''')
+
+    # 媒体播放历史表
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS media_play_history (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            media_id INTEGER NOT NULL,
+            elderly_id INTEGER NOT NULL,  -- 老人用户ID
+            played_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,  -- 播放时间
+            duration_watched INTEGER,  -- 观看时长（秒）
+            completed INTEGER DEFAULT 0,  -- 是否看完：1=是，0=否
+            triggered_by TEXT,  -- 触发方式：'auto'=自动, 'manual'=手动, 'mood'=情绪触发等
+            mood_before TEXT,  -- 播放前情绪状态
+            mood_after TEXT,  -- 播放后情绪状态
+            FOREIGN KEY (media_id) REFERENCES media(id),
+            FOREIGN KEY (elderly_id) REFERENCES users(id)
+        )
+    ''')
+
+    # 媒体反馈表（点赞/点踩）
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS media_feedback (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            media_id INTEGER NOT NULL,
+            elderly_id INTEGER NOT NULL,  -- 老人用户ID
+            feedback_type TEXT NOT NULL,  -- 'like' 或 'dislike'
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY (media_id) REFERENCES media(id),
+            FOREIGN KEY (elderly_id) REFERENCES users(id),
+            UNIQUE(media_id, elderly_id)  -- 每个老人对每个媒体只能有一个反馈
+        )
+    ''')
+
+    # 家属留言表
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS family_messages (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            family_id TEXT NOT NULL,  -- 家庭组ID
+            content TEXT NOT NULL,  -- 留言内容
+            sender_name TEXT NOT NULL,  -- 发送者姓名
+            sender_relation TEXT NOT NULL,  -- 发送者称呼（儿子、女儿、孙女等）
+            scheduled_time TIMESTAMP NOT NULL,  -- 预约播报时间
+            played INTEGER DEFAULT 0,  -- 是否已播放：0=未播放，1=已播放
+            played_at TIMESTAMP,  -- 实际播报时间
+            liked INTEGER DEFAULT 0,  -- 老人是否点赞：0=未点赞，1=已点赞
+            is_active INTEGER DEFAULT 1,  -- 是否有效
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+    ''')
+
+    # 家属端消息/告警表（优化版）
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS family_alerts (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            family_id TEXT NOT NULL,  -- 家庭组ID
+            elderly_id INTEGER,  -- 老人用户ID（可选，用于关联具体老人）
+            alert_type TEXT NOT NULL,  -- 消息类型：sos_emergency, contact_family, medication, emotion, inactive, emergency
+            level TEXT NOT NULL,  -- 级别：low, medium, high
+            title TEXT,  -- 消息标题（简短概要）
+            message TEXT NOT NULL,  -- 消息详细内容
+            metadata TEXT,  -- 额外元数据，JSON格式，如 {"location": "客厅", "device": "平板"}
+            source TEXT DEFAULT 'elderly',  -- 消息来源：elderly(老人端), system(系统自动), family(家属端)
+            handled INTEGER DEFAULT 0,  -- 是否已处理：0=未处理，1=已处理
+            handled_at TIMESTAMP,  -- 处理时间
+            handled_by INTEGER,  -- 处理人用户ID
+            reply_message TEXT,  -- 家属回复内容
+            read INTEGER DEFAULT 0,  -- 是否已读：0=未读，1=已读
+            read_at TIMESTAMP,  -- 阅读时间
+            is_active INTEGER DEFAULT 1,  -- 是否有效
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY (elderly_id) REFERENCES users(id),
+            FOREIGN KEY (handled_by) REFERENCES users(id)
+        )
+    ''')
+
+    # 情绪记录表
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS mood_records (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            family_id TEXT NOT NULL,  -- 家庭组ID
+            elderly_id INTEGER,  -- 老人用户ID
+            mood_type TEXT NOT NULL,  -- 情绪类型：happy(开心), calm(平静), sad(难过), anxious(焦虑), angry(生气), tired(疲惫)
+            mood_score INTEGER DEFAULT 5,  -- 情绪分数 1-10，数字越大越积极
+            note TEXT,  -- 备注说明
+            source TEXT DEFAULT 'manual',  -- 来源：manual(手动记录), ai_detect(AI检测), voice(语音分析)
+            trigger_event TEXT,  -- 触发事件，如 '看了家人照片', '完成了散步'
+            location TEXT,  -- 记录地点
+            weather TEXT,  -- 天气情况
+            recorded_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,  -- 记录时间
+            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            FOREIGN KEY (elderly_id) REFERENCES users(id)
+        )
+    ''')
+
+    # 情绪记录索引
+    cursor.execute('''
+        CREATE INDEX IF NOT EXISTS idx_mood_records_family_id
+        ON mood_records(family_id)
+    ''')
+
+    cursor.execute('''
+        CREATE INDEX IF NOT EXISTS idx_mood_records_elderly_id
+        ON mood_records(elderly_id)
+    ''')
+
+    cursor.execute('''
+        CREATE INDEX IF NOT EXISTS idx_mood_records_recorded_at
+        ON mood_records(recorded_at DESC)
+    ''')
+
+    # 创建索引以提高查询性能
+    cursor.execute('''
+        CREATE INDEX IF NOT EXISTS idx_family_alerts_family_id
+        ON family_alerts(family_id)
+    ''')
+
+    cursor.execute('''
+        CREATE INDEX IF NOT EXISTS idx_family_alerts_created_at
+        ON family_alerts(created_at DESC)
+    ''')
+
+    cursor.execute('''
+        CREATE INDEX IF NOT EXISTS idx_family_alerts_handled
+        ON family_alerts(handled, created_at DESC)
+    ''')
+
+    conn.commit()
+    conn.close()
+
+# ==================== 家人端 API ====================
+
+@app.route('/api/family/schedules', methods=['GET'])
+def get_family_schedules():
+    """获取家庭所有日程"""
+    family_id = request.args.get('family_id')
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        SELECT s.*, u.name as creator_name
+        FROM schedules s
+        LEFT JOIN users u ON s.created_by = u.id
+        WHERE s.family_id = ? AND s.is_active = 1
+        ORDER BY s.schedule_time DESC
+    ''', (family_id,))
+
+    schedules = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({'schedules': schedules})
+
+@app.route('/api/family/schedules', methods=['POST'])
+def create_schedule():
+    """创建新日程"""
+    data = request.json
+
+    required_fields = ['family_id', 'title', 'schedule_time']
+    if not all(field in data for field in required_fields):
+        return jsonify({'error': '缺少必需字段'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        INSERT INTO schedules (
+            family_id, title, description, schedule_type,
+            schedule_time, repeat_type, repeat_days, auto_remind, created_by
+        ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
+    ''', (
+        data['family_id'],
+        data['title'],
+        data.get('description', ''),
+        data.get('schedule_type', 'other'),
+        data['schedule_time'],
+        data.get('repeat_type', 'once'),
+        data.get('repeat_days', ''),
+        data.get('auto_remind', 1),
+        data.get('created_by')
+    ))
+
+    schedule_id = cursor.lastrowid
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True, 'schedule_id': schedule_id}), 201
+
+@app.route('/api/family/schedules/<int:schedule_id>', methods=['PUT'])
+def update_schedule(schedule_id):
+    """更新日程"""
+    data = request.json
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 构建更新语句
+    update_fields = []
+    params = []
+
+    for field in ['title', 'description', 'schedule_type', 'schedule_time', 'repeat_type', 'repeat_days', 'auto_remind', 'status']:
+        if field in data:
+            update_fields.append(f"{field} = ?")
+            params.append(data[field])
+
+    if not update_fields:
+        return jsonify({'error': '没有要更新的字段'}), 400
+
+    update_fields.append("updated_at = CURRENT_TIMESTAMP")
+    params.append(schedule_id)
+
+    cursor.execute(f'''
+        UPDATE schedules
+        SET {', '.join(update_fields)}
+        WHERE id = ?
+    ''', params)
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/family/schedules/<int:schedule_id>', methods=['DELETE'])
+def delete_schedule(schedule_id):
+    """删除日程（软删除）"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE schedules
+        SET is_active = 0, updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (schedule_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+# ==================== 家属端消息/告警 API ====================
+
+@app.route('/api/family/alerts', methods=['GET'])
+def get_family_alerts():
+    """获取家庭所有消息/告警"""
+    family_id = request.args.get('family_id')
+    status = request.args.get('status')  # all, unhandled, handled
+    handled = request.args.get('handled')  # true/false 布尔值
+    read = request.args.get('read')  # true/false 布尔值
+    alert_type = request.args.get('alert_type')  # 消息类型
+    elderly_id = request.args.get('elderly_id', type=int)  # 老人ID
+    level = request.args.get('level')  # low, medium, high
+    limit = request.args.get('limit', 100, type=int)
+    offset = request.args.get('offset', 0, type=int)
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 构建查询条件
+    conditions = ['a.family_id = ?', 'a.is_active = 1']
+    params = [family_id]
+
+    # 排除媒体展示事件（这些只用于老人端轮询，不应出现在家属端通知列表）
+    conditions.append("a.alert_type != 'media_display'")
+
+    # 支持status参数（兼容旧版）
+    if status == 'unhandled':
+        conditions.append('a.handled = 0')
+    elif status == 'handled':
+        conditions.append('a.handled = 1')
+
+    # 支持handled参数（布尔值）
+    if handled is not None:
+        if handled.lower() == 'true':
+            conditions.append('a.handled = 1')
+        elif handled.lower() == 'false':
+            conditions.append('a.handled = 0')
+
+    # 支持read参数（布尔值）
+    if read is not None:
+        if read.lower() == 'true':
+            conditions.append('a.read = 1')
+        elif read.lower() == 'false':
+            conditions.append('a.read = 0')
+
+    # 支持alert_type参数
+    if alert_type:
+        conditions.append('a.alert_type = ?')
+        params.append(alert_type)
+
+    # 支持elderly_id参数
+    if elderly_id:
+        conditions.append('a.elderly_id = ?')
+        params.append(elderly_id)
+
+    if level:
+        conditions.append('a.level = ?')
+        params.append(level)
+
+    where_clause = ' AND '.join(conditions)
+
+    # 查询总数
+    cursor.execute(f'''
+        SELECT COUNT(*) as total FROM family_alerts a
+        WHERE {where_clause}
+    ''', params)
+
+    total = cursor.fetchone()['total']
+
+    # 查询数据（包含老人信息）
+    cursor.execute(f'''
+        SELECT
+            a.*,
+            u.name as elderly_name,
+            h.name as handler_name
+        FROM family_alerts a
+        LEFT JOIN users u ON a.elderly_id = u.id
+        LEFT JOIN users h ON a.handled_by = h.id
+        WHERE {where_clause}
+        ORDER BY a.created_at DESC
+        LIMIT ? OFFSET ?
+    ''', params + [limit, offset])
+
+    alerts = []
+    for row in cursor.fetchall():
+        alert = dict(row)
+        # 转换布尔值
+        alert['handled'] = bool(alert['handled'])
+        alert['read'] = bool(alert['read'])
+        # 解析元数据JSON
+        if alert['metadata']:
+            try:
+                alert['metadata'] = json.loads(alert['metadata'])
+            except:
+                alert['metadata'] = {}
+        alerts.append(alert)
+
+    conn.close()
+
+    return jsonify({
+        'alerts': alerts,
+        'total': total,
+        'limit': limit,
+        'offset': offset
+    })
+
+@app.route('/api/family/alerts', methods=['POST'])
+def create_alert():
+    """创建新消息/告警（由老人端或系统触发）"""
+    data = request.json
+
+    required_fields = ['family_id', 'alert_type', 'level', 'message']
+    if not all(field in data for field in required_fields):
+        return jsonify({'error': '缺少必需字段'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 处理元数据
+    metadata = data.get('metadata', {})
+    metadata_json = json.dumps(metadata) if metadata else None
+
+    cursor.execute('''
+        INSERT INTO family_alerts (
+            family_id, elderly_id, alert_type, level, title, message,
+            metadata, source
+        ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)
+    ''', (
+        data['family_id'],
+        data.get('elderly_id'),
+        data['alert_type'],
+        data['level'],
+        data.get('title'),
+        data['message'],
+        metadata_json,
+        data.get('source', 'elderly')
+    ))
+
+    alert_id = cursor.lastrowid
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True, 'alert_id': alert_id}), 201
+
+@app.route('/api/family/alerts/<int:alert_id>/handle', methods=['POST'])
+def handle_alert(alert_id):
+    """标记消息/告警为已处理"""
+    data = request.json or {}
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE family_alerts
+        SET handled = 1,
+            handled_at = CURRENT_TIMESTAMP,
+            handled_by = ?,
+            reply_message = ?,
+            updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (
+        data.get('handled_by'),
+        data.get('reply_message'),
+        alert_id
+    ))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/family/alerts/<int:alert_id>/read', methods=['POST'])
+def mark_alert_read(alert_id):
+    """标记消息为已读"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE family_alerts
+        SET read = 1,
+            read_at = CURRENT_TIMESTAMP,
+            updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (alert_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/family/alerts/<int:alert_id>/reply', methods=['POST'])
+def reply_alert(alert_id):
+    """家属回复消息"""
+    data = request.json
+
+    if not data or 'reply_message' not in data:
+        return jsonify({'error': '缺少reply_message字段'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE family_alerts
+        SET reply_message = ?,
+            updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (data['reply_message'], alert_id))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/family/alerts/<int:alert_id>', methods=['DELETE'])
+def delete_alert(alert_id):
+    """删除消息/告警（软删除）"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE family_alerts
+        SET is_active = 0,
+            updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (alert_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/family/alerts/stats', methods=['GET'])
+def get_alerts_stats():
+    """获取消息统计数据"""
+    family_id = request.args.get('family_id')
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 统计各级别消息数量（排除媒体展示事件）
+    cursor.execute('''
+        SELECT
+            level,
+            COUNT(*) as count
+        FROM family_alerts
+        WHERE family_id = ? AND is_active = 1 AND alert_type != 'media_display'
+        GROUP BY level
+    ''', (family_id,))
+
+    level_stats = {row['level']: row['count'] for row in cursor.fetchall()}
+
+    # 统计各类型消息数量（排除媒体展示事件）
+    cursor.execute('''
+        SELECT
+            alert_type,
+            COUNT(*) as count
+        FROM family_alerts
+        WHERE family_id = ? AND is_active = 1 AND alert_type != 'media_display'
+        GROUP BY alert_type
+    ''', (family_id,))
+
+    type_stats = {row['alert_type']: row['count'] for row in cursor.fetchall()}
+
+    # 统计已处理/未处理（排除媒体展示事件）
+    cursor.execute('''
+        SELECT
+            COUNT(CASE WHEN handled = 0 THEN 1 END) as unhandled,
+            COUNT(CASE WHEN handled = 1 THEN 1 END) as handled,
+            COUNT(CASE WHEN read = 0 THEN 1 END) as unread
+        FROM family_alerts
+        WHERE family_id = ? AND is_active = 1 AND alert_type != 'media_display'
+    ''', (family_id,))
+
+    status_stats = dict(cursor.fetchone())
+
+    # 今日新增消息数（排除媒体展示事件）
+    cursor.execute('''
+        SELECT COUNT(*) as today_count
+        FROM family_alerts
+        WHERE family_id = ? AND is_active = 1 AND alert_type != 'media_display'
+        AND DATE(created_at) = DATE('now')
+    ''', (family_id,))
+
+    today_count = cursor.fetchone()['today_count']
+
+    conn.close()
+
+    return jsonify({
+        'level_stats': level_stats,
+        'type_stats': type_stats,
+        'status_stats': status_stats,
+        'today_count': today_count
+    })
+
+# ==================== 家属留言 API ====================
+
+@app.route('/api/family/messages', methods=['GET'])
+def get_family_messages():
+    """获取家庭所有留言"""
+    family_id = request.args.get('family_id')
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        SELECT * FROM family_messages
+        WHERE family_id = ? AND is_active = 1
+        ORDER BY created_at DESC
+    ''', (family_id,))
+
+    messages = []
+    for row in cursor.fetchall():
+        msg = dict(row)
+        # 转换布尔值
+        msg['played'] = bool(msg['played'])
+        msg['liked'] = bool(msg['liked'])
+        # 转换UTC时间为北京时间
+        msg['created_at'] = utc_to_beijing(msg['created_at'])
+        msg['updated_at'] = utc_to_beijing(msg['updated_at'])
+        if msg.get('played_at'):
+            msg['played_at'] = utc_to_beijing(msg['played_at'])
+        messages.append(msg)
+
+    conn.close()
+
+    return jsonify({'messages': messages})
+
+@app.route('/api/family/messages', methods=['POST'])
+def create_message():
+    """创建新留言"""
+    data = request.json
+
+    required_fields = ['family_id', 'content', 'sender_name', 'sender_relation', 'scheduled_time']
+    if not all(field in data for field in required_fields):
+        return jsonify({'error': '缺少必需字段'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        INSERT INTO family_messages (
+            family_id, content, sender_name, sender_relation, scheduled_time
+        ) VALUES (?, ?, ?, ?, ?)
+    ''', (
+        data['family_id'],
+        data['content'],
+        data['sender_name'],
+        data['sender_relation'],
+        data['scheduled_time']
+    ))
+
+    message_id = cursor.lastrowid
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True, 'message_id': message_id}), 201
+
+@app.route('/api/family/messages/<int:message_id>', methods=['DELETE'])
+def delete_message(message_id):
+    """删除留言（软删除）"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE family_messages
+        SET is_active = 0, updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (message_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+# ==================== 老人端留言 API ====================
+
+@app.route('/api/elderly/messages', methods=['GET'])
+def get_elderly_messages():
+    """获取老人端的留言列表（按预约时间排序）"""
+    family_id = request.args.get('family_id')
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        SELECT * FROM family_messages
+        WHERE family_id = ? AND is_active = 1
+        ORDER BY scheduled_time ASC
+    ''', (family_id,))
+
+    messages = []
+    for row in cursor.fetchall():
+        msg = dict(row)
+        msg['played'] = bool(msg['played'])
+        msg['liked'] = bool(msg['liked'])
+        # 转换UTC时间为北京时间
+        msg['created_at'] = utc_to_beijing(msg['created_at'])
+        msg['updated_at'] = utc_to_beijing(msg['updated_at'])
+        if msg.get('played_at'):
+            msg['played_at'] = utc_to_beijing(msg['played_at'])
+        messages.append(msg)
+
+    conn.close()
+
+    return jsonify({'messages': messages})
+
+@app.route('/api/elderly/messages/pending', methods=['GET'])
+def get_pending_messages():
+    """获取待播放的留言（预约时间已到但未播放的）"""
+    family_id = request.args.get('family_id')
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 调试日志 - 使用北京时间
+    beijing_now = get_beijing_time()
+    current_time = beijing_now.strftime('%Y-%m-%d %H:%M:%S')
+    print(f"[DEBUG] 当前北京时间: {current_time}")
+
+    cursor.execute('''
+        SELECT * FROM family_messages
+        WHERE family_id = ?
+          AND is_active = 1
+          AND played = 0
+        ORDER BY scheduled_time ASC
+    ''', (family_id,))
+
+    # 获取所有未播放的消息
+    all_messages = []
+    for row in cursor.fetchall():
+        msg = dict(row)
+        print(f"[DEBUG] 留言 ID: {msg['id']}, 预约时间: {msg['scheduled_time']}")
+        all_messages.append(msg)
+
+    # 在 Python 中进行时间比较（更可靠） - 使用北京时间
+    now = beijing_now.replace(tzinfo=None)  # 移除时区信息以便比较
+    messages = []
+    for msg in all_messages:
+        try:
+            # 处理各种可能的时间格式
+            scheduled_str = msg['scheduled_time']
+            # 移除 'T'，统一为空格分隔
+            scheduled_str = scheduled_str.replace('T', ' ')
+            # 如果没有秒数，添加 :00
+            if len(scheduled_str) == 16:  # YYYY-MM-DD HH:MM
+                scheduled_str += ':00'
+
+            scheduled_time = datetime.strptime(scheduled_str, '%Y-%m-%d %H:%M:%S')
+
+            print(f"[DEBUG] 解析后时间: {scheduled_time}, 当前北京时间: {now}, 已到期: {scheduled_time <= now}")
+
+            if scheduled_time <= now:
+                msg['played'] = bool(msg['played'])
+                msg['liked'] = bool(msg['liked'])
+                # 转换UTC时间为北京时间
+                msg['created_at'] = utc_to_beijing(msg['created_at'])
+                msg['updated_at'] = utc_to_beijing(msg['updated_at'])
+                if msg.get('played_at'):
+                    msg['played_at'] = utc_to_beijing(msg['played_at'])
+                messages.append(msg)
+        except Exception as e:
+            print(f"[DEBUG] 时间解析错误: {e}, 原始值: {msg['scheduled_time']}")
+            continue
+
+    conn.close()
+
+    print(f"[DEBUG] 找到 {len(messages)} 条待播放留言")
+    return jsonify({'messages': messages})
+
+@app.route('/api/elderly/messages/<int:message_id>/play', methods=['POST'])
+def play_message(message_id):
+    """标记留言为已播放"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE family_messages
+        SET played = 1,
+            played_at = CURRENT_TIMESTAMP,
+            updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (message_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/elderly/messages/<int:message_id>/like', methods=['POST'])
+def like_message(message_id):
+    """老人点赞留言"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE family_messages
+        SET liked = 1, updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (message_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/elderly/messages/<int:message_id>/unlike', methods=['POST'])
+def unlike_message(message_id):
+    """老人取消点赞"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE family_messages
+        SET liked = 0, updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (message_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+# ==================== 老人端消息/告警 API ====================
+
+@app.route('/api/elderly/alerts', methods=['POST'])
+def create_elderly_alert():
+    """老人端创建消息（如SOS、联系家人）"""
+    data = request.json
+
+    required_fields = ['family_id', 'alert_type', 'level', 'message']
+    if not all(field in data for field in required_fields):
+        return jsonify({'error': '缺少必需字段'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 处理元数据
+    metadata = data.get('metadata', {})
+    metadata_json = json.dumps(metadata) if metadata else None
+
+    cursor.execute('''
+        INSERT INTO family_alerts (
+            family_id, elderly_id, alert_type, level, title, message,
+            metadata, source
+        ) VALUES (?, ?, ?, ?, ?, ?, ?, 'elderly')
+    ''', (
+        data['family_id'],
+        data.get('elderly_id'),
+        data['alert_type'],
+        data['level'],
+        data.get('title'),
+        data['message'],
+        metadata_json
+    ))
+
+    alert_id = cursor.lastrowid
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True, 'alert_id': alert_id}), 201
+
+@app.route('/api/elderly/alerts/replies', methods=['GET'])
+def get_elderly_alert_replies():
+    """获取家属对老人消息的回复"""
+    family_id = request.args.get('family_id')
+    elderly_id = request.args.get('elderly_id')
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    conditions = ['family_id = ?', 'is_active = 1', 'reply_message IS NOT NULL']
+    params = [family_id]
+
+    if elderly_id:
+        conditions.append('elderly_id = ?')
+        params.append(elderly_id)
+
+    where_clause = ' AND '.join(conditions)
+
+    cursor.execute(f'''
+        SELECT
+            id, alert_type, level, message, reply_message,
+            handled_at, created_at
+        FROM family_alerts
+        WHERE {where_clause}
+        ORDER BY handled_at DESC
+        LIMIT 10
+    ''', params)
+
+    replies = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({'replies': replies})
+
+# ==================== 情绪记录 API ====================
+
+@app.route('/api/elderly/moods', methods=['POST'])
+def create_mood_record():
+    """老人端创建情绪记录"""
+    data = request.json
+
+    required_fields = ['family_id', 'mood_type']
+    if not all(field in data for field in required_fields):
+        return jsonify({'error': '缺少必需字段'}), 400
+
+    # 验证情绪类型
+    valid_moods = ['happy', 'calm', 'sad', 'anxious', 'angry', 'tired']
+    if data['mood_type'] not in valid_moods:
+        return jsonify({'error': '无效的情绪类型'}), 400
+
+    # 验证情绪分数范围
+    mood_score = data.get('mood_score', 5)
+    if not (1 <= mood_score <= 10):
+        return jsonify({'error': '情绪分数必须在1-10之间'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        INSERT INTO mood_records (
+            family_id, elderly_id, mood_type, mood_score, note,
+            source, trigger_event, location, weather, recorded_at
+        ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+    ''', (
+        data['family_id'],
+        data.get('elderly_id'),
+        data['mood_type'],
+        mood_score,
+        data.get('note', ''),
+        data.get('source', 'manual'),
+        data.get('trigger_event', ''),
+        data.get('location', ''),
+        data.get('weather', ''),
+        data.get('recorded_at', datetime.now().strftime('%Y-%m-%d %H:%M:%S'))
+    ))
+
+    record_id = cursor.lastrowid
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True, 'record_id': record_id}), 201
+
+@app.route('/api/elderly/moods', methods=['GET'])
+def get_elderly_moods():
+    """获取老人的情绪记录列表"""
+    family_id = request.args.get('family_id')
+    elderly_id = request.args.get('elderly_id')
+    limit = request.args.get('limit', 50, type=int)
+    offset = request.args.get('offset', 0, type=int)
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    conditions = ['family_id = ?']
+    params = [family_id]
+
+    if elderly_id:
+        conditions.append('elderly_id = ?')
+        params.append(elderly_id)
+
+    where_clause = ' AND '.join(conditions)
+
+    # 查询总数
+    cursor.execute(f'''
+        SELECT COUNT(*) as total FROM mood_records
+        WHERE {where_clause}
+    ''', params)
+
+    total = cursor.fetchone()['total']
+
+    # 查询数据
+    cursor.execute(f'''
+        SELECT * FROM mood_records
+        WHERE {where_clause}
+        ORDER BY recorded_at DESC
+        LIMIT ? OFFSET ?
+    ''', params + [limit, offset])
+
+    records = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({
+        'records': records,
+        'total': total,
+        'limit': limit,
+        'offset': offset
+    })
+
+@app.route('/api/elderly/moods/today', methods=['GET'])
+def get_today_moods():
+    """获取老人今日的情绪记录"""
+    family_id = request.args.get('family_id')
+    elderly_id = request.args.get('elderly_id')
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    today = datetime.now().strftime('%Y-%m-%d')
+
+    conditions = ['family_id = ?', 'DATE(recorded_at) = DATE(?)']
+    params = [family_id, today]
+
+    if elderly_id:
+        conditions.append('elderly_id = ?')
+        params.append(elderly_id)
+
+    where_clause = ' AND '.join(conditions)
+
+    cursor.execute(f'''
+        SELECT * FROM mood_records
+        WHERE {where_clause}
+        ORDER BY recorded_at DESC
+    ''', params)
+
+    records = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({'records': records})
+
+@app.route('/api/elderly/moods/latest', methods=['GET'])
+def get_latest_mood():
+    """获取老人最新的情绪记录"""
+    family_id = request.args.get('family_id')
+    elderly_id = request.args.get('elderly_id')
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    conditions = ['family_id = ?']
+    params = [family_id]
+
+    if elderly_id:
+        conditions.append('elderly_id = ?')
+        params.append(elderly_id)
+
+    where_clause = ' AND '.join(conditions)
+
+    cursor.execute(f'''
+        SELECT * FROM mood_records
+        WHERE {where_clause}
+        ORDER BY recorded_at DESC
+        LIMIT 1
+    ''', params)
+
+    row = cursor.fetchone()
+    conn.close()
+
+    if row:
+        return jsonify({'record': dict(row)})
+    else:
+        return jsonify({'record': None})
+
+# ==================== 家属端情绪记录 API ====================
+
+@app.route('/api/family/moods', methods=['GET'])
+def get_family_moods():
+    """家属端获取老人的情绪记录"""
+    family_id = request.args.get('family_id')
+    elderly_id = request.args.get('elderly_id')
+    mood_type = request.args.get('mood_type')
+    start_date = request.args.get('start_date')
+    end_date = request.args.get('end_date')
+    limit = request.args.get('limit', 100, type=int)
+    offset = request.args.get('offset', 0, type=int)
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    conditions = ['m.family_id = ?']
+    params = [family_id]
+
+    if elderly_id:
+        conditions.append('m.elderly_id = ?')
+        params.append(elderly_id)
+
+    if mood_type:
+        conditions.append('m.mood_type = ?')
+        params.append(mood_type)
+
+    if start_date:
+        conditions.append('DATE(m.recorded_at) >= DATE(?)')
+        params.append(start_date)
+
+    if end_date:
+        conditions.append('DATE(m.recorded_at) <= DATE(?)')
+        params.append(end_date)
+
+    where_clause = ' AND '.join(conditions)
+
+    # 查询总数
+    cursor.execute(f'''
+        SELECT COUNT(*) as total FROM mood_records m
+        WHERE {where_clause}
+    ''', params)
+
+    total = cursor.fetchone()['total']
+
+    # 查询数据（包含老人信息）
+    cursor.execute(f'''
+        SELECT
+            m.*,
+            u.name as elderly_name
+        FROM mood_records m
+        LEFT JOIN users u ON m.elderly_id = u.id
+        WHERE {where_clause}
+        ORDER BY m.recorded_at DESC
+        LIMIT ? OFFSET ?
+    ''', params + [limit, offset])
+
+    records = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({
+        'records': records,
+        'total': total,
+        'limit': limit,
+        'offset': offset
+    })
+
+@app.route('/api/family/moods/stats', methods=['GET'])
+def get_mood_stats():
+    """获取情绪统计数据"""
+    family_id = request.args.get('family_id')
+    elderly_id = request.args.get('elderly_id')
+    days = request.args.get('days', 7, type=int)  # 统计最近N天
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    conditions = ['family_id = ?']
+    params = [family_id]
+
+    if elderly_id:
+        conditions.append('elderly_id = ?')
+        params.append(elderly_id)
+
+    # 添加时间范围条件
+    conditions.append(f"DATE(recorded_at) >= DATE('now', '-{days} days')")
+
+    where_clause = ' AND '.join(conditions)
+
+    # 按情绪类型统计
+    cursor.execute(f'''
+        SELECT
+            mood_type,
+            COUNT(*) as count,
+            AVG(mood_score) as avg_score
+        FROM mood_records
+        WHERE {where_clause}
+        GROUP BY mood_type
+        ORDER BY count DESC
+    ''', params)
+
+    mood_type_stats = []
+    for row in cursor.fetchall():
+        stat = dict(row)
+        stat['avg_score'] = round(stat['avg_score'], 1) if stat['avg_score'] else 0
+        mood_type_stats.append(stat)
+
+    # 按日期统计平均分数
+    cursor.execute(f'''
+        SELECT
+            DATE(recorded_at) as date,
+            AVG(mood_score) as avg_score,
+            COUNT(*) as count
+        FROM mood_records
+        WHERE {where_clause}
+        GROUP BY DATE(recorded_at)
+        ORDER BY date DESC
+    ''', params)
+
+    daily_stats = []
+    for row in cursor.fetchall():
+        stat = dict(row)
+        stat['avg_score'] = round(stat['avg_score'], 1) if stat['avg_score'] else 0
+        daily_stats.append(stat)
+
+    # 计算整体统计
+    cursor.execute(f'''
+        SELECT
+            COUNT(*) as total_records,
+            AVG(mood_score) as avg_score,
+            MAX(mood_score) as max_score,
+            MIN(mood_score) as min_score
+        FROM mood_records
+        WHERE {where_clause}
+    ''', params)
+
+    overall = dict(cursor.fetchone())
+    overall['avg_score'] = round(overall['avg_score'], 1) if overall['avg_score'] else 0
+
+    # 今日记录数
+    cursor.execute(f'''
+        SELECT COUNT(*) as today_count
+        FROM mood_records
+        WHERE {where_clause.replace(f"DATE(recorded_at) >= DATE('now', '-{days} days')", "DATE(recorded_at) = DATE('now')")}
+    ''', params)
+
+    today_count = cursor.fetchone()['today_count']
+
+    conn.close()
+
+    return jsonify({
+        'mood_type_stats': mood_type_stats,
+        'daily_stats': daily_stats,
+        'overall': overall,
+        'today_count': today_count,
+        'days': days
+    })
+
+@app.route('/api/family/moods/trend', methods=['GET'])
+def get_mood_trend():
+    """获取情绪趋势数据"""
+    family_id = request.args.get('family_id')
+    elderly_id = request.args.get('elderly_id')
+    days = request.args.get('days', 30, type=int)
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    conditions = ['family_id = ?']
+    params = [family_id]
+
+    if elderly_id:
+        conditions.append('elderly_id = ?')
+        params.append(elderly_id)
+
+    conditions.append(f"DATE(recorded_at) >= DATE('now', '-{days} days')")
+
+    where_clause = ' AND '.join(conditions)
+
+    # 按日期获取情绪趋势
+    cursor.execute(f'''
+        SELECT
+            DATE(recorded_at) as date,
+            mood_type,
+            AVG(mood_score) as avg_score,
+            COUNT(*) as count
+        FROM mood_records
+        WHERE {where_clause}
+        GROUP BY DATE(recorded_at), mood_type
+        ORDER BY date ASC, count DESC
+    ''', params)
+
+    trend_data = []
+    for row in cursor.fetchall():
+        item = dict(row)
+        item['avg_score'] = round(item['avg_score'], 1) if item['avg_score'] else 0
+        trend_data.append(item)
+
+    conn.close()
+
+    return jsonify({
+        'trend': trend_data,
+        'days': days
+    })
+
+# ==================== 老人端 API ====================
+
+@app.route('/api/elderly/schedules/today', methods=['GET'])
+def get_today_schedules():
+    """获取老人今日日程"""
+    family_id = request.args.get('family_id')
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 获取今天的日期范围
+    today = datetime.now().strftime('%Y-%m-%d')
+
+    cursor.execute('''
+        SELECT * FROM schedules
+        WHERE family_id = ?
+        AND is_active = 1
+        AND (
+            (repeat_type = 'once' AND DATE(schedule_time) = DATE(?))
+            OR repeat_type = 'daily'
+            OR (repeat_type = 'weekly' AND CAST(strftime('%w', ?) AS INTEGER) IN (
+                SELECT value FROM json_each(repeat_days)
+            ))
+        )
+        ORDER BY TIME(schedule_time)
+    ''', (family_id, today, today))
+
+    schedules = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({'schedules': schedules})
+
+@app.route('/api/elderly/schedules/upcoming', methods=['GET'])
+def get_upcoming_schedules():
+    """获取即将到来的日程（下一小时内）"""
+    family_id = request.args.get('family_id')
+    elderly_id = request.args.get('elderly_id')
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        SELECT * FROM schedules
+        WHERE family_id = ?
+        AND is_active = 1
+        AND datetime(schedule_time) BETWEEN datetime('now') AND datetime('now', '+1 hour')
+        ORDER BY schedule_time
+    ''', (family_id,))
+
+    schedules = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({'schedules': schedules})
+
+@app.route('/api/elderly/reminders/<int:reminder_id>/complete', methods=['POST'])
+def complete_reminder(reminder_id):
+    """标记提醒为已完成"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE reminders
+        SET status = 'completed', completed_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (reminder_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/elderly/reminders/<int:reminder_id>/dismiss', methods=['POST'])
+def dismiss_reminder(reminder_id):
+    """忽略提醒"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE reminders
+        SET status = 'dismissed'
+        WHERE id = ?
+    ''', (reminder_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/elderly/schedules/<int:schedule_id>/status', methods=['POST'])
+def update_schedule_status(schedule_id):
+    """更新日程状态"""
+    data = request.json
+    status = data.get('status')  # pending, completed, skipped, missed
+
+    if status not in ['pending', 'completed', 'skipped', 'missed']:
+        return jsonify({'error': '无效的状态值'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 如果状态是 completed，记录完成时间
+    if status == 'completed':
+        cursor.execute('''
+            UPDATE schedules
+            SET status = ?, completed_at = CURRENT_TIMESTAMP, updated_at = CURRENT_TIMESTAMP
+            WHERE id = ?
+        ''', (status, schedule_id))
+    else:
+        cursor.execute('''
+            UPDATE schedules
+            SET status = ?, updated_at = CURRENT_TIMESTAMP
+            WHERE id = ?
+        ''', (status, schedule_id))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+# ==================== 用户管理 API ====================
+
+@app.route('/api/users', methods=['POST'])
+def create_user():
+    """创建用户"""
+    data = request.json
+
+    required_fields = ['user_type', 'name', 'family_id']
+    if not all(field in data for field in required_fields):
+        return jsonify({'error': '缺少必需字段'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        INSERT INTO users (user_type, name, phone, family_id)
+        VALUES (?, ?, ?, ?)
+    ''', (
+        data['user_type'],
+        data['name'],
+        data.get('phone', ''),
+        data['family_id']
+    ))
+
+    user_id = cursor.lastrowid
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True, 'user_id': user_id}), 201
+
+@app.route('/api/users/<string:family_id>', methods=['GET'])
+def get_family_users(family_id):
+    """获取家庭成员列表"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        SELECT * FROM users
+        WHERE family_id = ?
+        ORDER BY user_type, created_at
+    ''', (family_id,))
+
+    users = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({'users': users})
+
+# ==================== 媒体库 API ====================
+
+@app.route('/api/family/media', methods=['POST'])
+def upload_media():
+    """家属端上传媒体文件"""
+    # 检查是否有文件
+    if 'file' not in request.files:
+        return jsonify({'error': '没有上传文件'}), 400
+
+    file = request.files['file']
+    if file.filename == '':
+        return jsonify({'error': '文件名为空'}), 400
+
+    if not allowed_file(file.filename):
+        return jsonify({'error': '不支持的文件类型'}), 400
+
+    # 获取其他表单数据
+    family_id = request.form.get('family_id')
+    title = request.form.get('title')
+    description = request.form.get('description', '')
+    uploaded_by = request.form.get('uploaded_by')
+
+    if not family_id or not title:
+        return jsonify({'error': '缺少必需字段'}), 400
+
+    # 保存文件
+    filename = secure_filename(file.filename)
+    timestamp = datetime.now().strftime('%Y%m%d%H%M%S')
+    unique_filename = f"{timestamp}_{filename}"
+    file_path = os.path.join(app.config['UPLOAD_FOLDER'], unique_filename)
+    file.save(file_path)
+
+    # 判断媒体类型
+    ext = filename.rsplit('.', 1)[1].lower()
+    media_type = 'video' if ext in {'mp4', 'mov', 'avi'} else 'photo'
+
+    # 获取文件大小
+    file_size = os.path.getsize(file_path)
+
+    # 生成缩略图
+    thumbnail_path = None
+    if media_type == 'video':
+        thumbnail_path = generate_video_thumbnail(file_path, unique_filename)
+    elif media_type == 'photo':
+        thumbnail_path = generate_photo_thumbnail(file_path, unique_filename)
+
+    # 插入数据库
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        INSERT INTO media (
+            family_id, media_type, title, description,
+            file_path, file_size, thumbnail_path, uploaded_by
+        ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)
+    ''', (family_id, media_type, title, description, file_path, file_size, thumbnail_path, uploaded_by))
+
+    media_id = cursor.lastrowid
+
+    # 创建默认触发策略
+    cursor.execute('''
+        INSERT INTO media_policies (media_id, time_windows, moods, occasions, cooldown, priority)
+        VALUES (?, ?, ?, ?, ?, ?)
+    ''', (media_id, '[]', '[]', '[]', 60, 5))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({
+        'success': True,
+        'media_id': media_id,
+        'file_path': file_path,
+        'media_type': media_type
+    }), 201
+
+@app.route('/api/family/media', methods=['GET'])
+def get_family_media():
+    """获取家庭所有媒体列表"""
+    family_id = request.args.get('family_id')
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 获取媒体列表及其标签和策略
+    cursor.execute('''
+        SELECT
+            m.*,
+            p.time_windows,
+            p.moods,
+            p.occasions,
+            p.cooldown,
+            p.priority,
+            p.play_count,
+            p.last_played_at,
+            GROUP_CONCAT(t.tag) as tags
+        FROM media m
+        LEFT JOIN media_policies p ON m.id = p.media_id
+        LEFT JOIN media_tags t ON m.id = t.media_id
+        WHERE m.family_id = ? AND m.is_active = 1
+        GROUP BY m.id
+        ORDER BY m.created_at DESC
+    ''', (family_id,))
+
+    media_list = []
+    for row in cursor.fetchall():
+        media_dict = dict(row)
+        # 解析标签
+        if media_dict['tags']:
+            media_dict['tags'] = media_dict['tags'].split(',')
+        else:
+            media_dict['tags'] = []
+
+        # 解析JSON字段
+        for field in ['time_windows', 'moods', 'occasions']:
+            try:
+                media_dict[field] = json.loads(media_dict[field]) if media_dict[field] else []
+            except:
+                media_dict[field] = []
+
+        media_list.append(media_dict)
+
+    conn.close()
+
+    return jsonify({'media': media_list})
+
+@app.route('/api/family/media/<int:media_id>', methods=['GET'])
+def get_media_detail(media_id):
+    """获取媒体详情"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        SELECT
+            m.*,
+            p.time_windows,
+            p.moods,
+            p.occasions,
+            p.cooldown,
+            p.priority,
+            p.play_count,
+            p.last_played_at
+        FROM media m
+        LEFT JOIN media_policies p ON m.id = p.media_id
+        WHERE m.id = ?
+    ''', (media_id,))
+
+    row = cursor.fetchone()
+    if not row:
+        conn.close()
+        return jsonify({'error': '媒体不存在'}), 404
+
+    media_dict = dict(row)
+
+    # 获取标签
+    cursor.execute('SELECT tag FROM media_tags WHERE media_id = ?', (media_id,))
+    media_dict['tags'] = [row['tag'] for row in cursor.fetchall()]
+
+    # 解析JSON字段
+    for field in ['time_windows', 'moods', 'occasions']:
+        try:
+            media_dict[field] = json.loads(media_dict[field]) if media_dict[field] else []
+        except:
+            media_dict[field] = []
+
+    # 获取播放统计
+    cursor.execute('''
+        SELECT
+            COUNT(*) as total_plays,
+            SUM(CASE WHEN feedback_type = 'like' THEN 1 ELSE 0 END) as likes,
+            SUM(CASE WHEN feedback_type = 'dislike' THEN 1 ELSE 0 END) as dislikes
+        FROM media_play_history mph
+        LEFT JOIN media_feedback mf ON mph.media_id = mf.media_id AND mph.elderly_id = mf.elderly_id
+        WHERE mph.media_id = ?
+    ''', (media_id,))
+
+    stats = dict(cursor.fetchone())
+    media_dict['statistics'] = stats
+
+    conn.close()
+
+    return jsonify(media_dict)
+
+@app.route('/api/family/media/<int:media_id>', methods=['PUT'])
+def update_media(media_id):
+    """更新媒体信息和触发策略"""
+    data = request.json
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 更新媒体基本信息
+    if 'title' in data or 'description' in data:
+        update_fields = []
+        params = []
+
+        if 'title' in data:
+            update_fields.append('title = ?')
+            params.append(data['title'])
+
+        if 'description' in data:
+            update_fields.append('description = ?')
+            params.append(data['description'])
+
+        update_fields.append('updated_at = CURRENT_TIMESTAMP')
+        params.append(media_id)
+
+        cursor.execute(f'''
+            UPDATE media
+            SET {', '.join(update_fields)}
+            WHERE id = ?
+        ''', params)
+
+    # 更新标签
+    if 'tags' in data:
+        # 删除旧标签
+        cursor.execute('DELETE FROM media_tags WHERE media_id = ?', (media_id,))
+
+        # 添加新标签
+        for tag in data['tags']:
+            cursor.execute('''
+                INSERT INTO media_tags (media_id, tag)
+                VALUES (?, ?)
+            ''', (media_id, tag))
+
+    # 更新触发策略
+    policy_fields = ['time_windows', 'moods', 'occasions', 'cooldown', 'priority']
+    policy_updates = []
+    policy_params = []
+
+    for field in policy_fields:
+        if field in data:
+            policy_updates.append(f'{field} = ?')
+            # JSON字段需要序列化
+            if field in ['time_windows', 'moods', 'occasions']:
+                policy_params.append(json.dumps(data[field]))
+            else:
+                policy_params.append(data[field])
+
+    if policy_updates:
+        policy_updates.append('updated_at = CURRENT_TIMESTAMP')
+        policy_params.append(media_id)
+
+        cursor.execute(f'''
+            UPDATE media_policies
+            SET {', '.join(policy_updates)}
+            WHERE media_id = ?
+        ''', policy_params)
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/family/media/<int:media_id>', methods=['DELETE'])
+def delete_media(media_id):
+    """删除媒体（软删除）"""
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        UPDATE media
+        SET is_active = 0, updated_at = CURRENT_TIMESTAMP
+        WHERE id = ?
+    ''', (media_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+# ==================== 老人端媒体 API ====================
+
+@app.route('/api/elderly/media/recommended', methods=['GET'])
+def get_recommended_media():
+    """获取推荐媒体（基于时段、心境、场合等策略）"""
+    family_id = request.args.get('family_id')
+    elderly_id = request.args.get('elderly_id')
+    current_mood = request.args.get('mood', '')  # 当前心境
+    occasion = request.args.get('occasion', '')  # 特殊场合
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 获取当前时间
+    now = datetime.now()
+    current_time = now.strftime('%H:%M')
+
+    # 查询符合条件的媒体
+    cursor.execute('''
+        SELECT
+            m.*,
+            p.time_windows,
+            p.moods,
+            p.occasions,
+            p.cooldown,
+            p.priority,
+            p.play_count,
+            p.last_played_at,
+            GROUP_CONCAT(t.tag) as tags
+        FROM media m
+        INNER JOIN media_policies p ON m.id = p.media_id
+        LEFT JOIN media_tags t ON m.id = t.media_id
+        WHERE m.family_id = ? AND m.is_active = 1
+        GROUP BY m.id
+        ORDER BY p.priority DESC, p.play_count ASC
+    ''', (family_id,))
+
+    recommended = []
+    for row in cursor.fetchall():
+        media_dict = dict(row)
+
+        # 解析JSON字段
+        time_windows = json.loads(media_dict['time_windows']) if media_dict['time_windows'] else []
+        moods = json.loads(media_dict['moods']) if media_dict['moods'] else []
+        occasions = json.loads(media_dict['occasions']) if media_dict['occasions'] else []
+
+        # 检查冷却时间
+        if media_dict['last_played_at']:
+            last_played = datetime.fromisoformat(media_dict['last_played_at'])
+            cooldown_minutes = media_dict['cooldown']
+            if now - last_played < timedelta(minutes=cooldown_minutes):
+                continue  # 还在冷却期，跳过
+
+        # 检查时段匹配
+        time_match = not time_windows  # 如果没有设置时段，默认匹配
+        for window in time_windows:
+            if '-' in window:
+                start, end = window.split('-')
+                if start <= current_time <= end:
+                    time_match = True
+                    break
+
+        if not time_match:
+            continue
+
+        # 检查心境匹配
+        mood_match = not moods or not current_mood or current_mood in moods
+        if not mood_match:
+            continue
+
+        # 检查场合匹配
+        occasion_match = not occasions or not occasion or occasion in occasions
+        if not occasion_match:
+            continue
+
+        # 解析标签
+        if media_dict['tags']:
+            media_dict['tags'] = media_dict['tags'].split(',')
+        else:
+            media_dict['tags'] = []
+
+        recommended.append(media_dict)
+
+    conn.close()
+
+    return jsonify({'media': recommended})
+
+@app.route('/api/elderly/media/<int:media_id>/play', methods=['POST'])
+def record_media_play(media_id):
+    """记录媒体播放"""
+    data = request.json
+
+    elderly_id = data.get('elderly_id')
+    duration_watched = data.get('duration_watched', 0)
+    completed = data.get('completed', 0)
+    triggered_by = data.get('triggered_by', 'manual')
+    mood_before = data.get('mood_before', '')
+    mood_after = data.get('mood_after', '')
+
+    if not elderly_id:
+        return jsonify({'error': '缺少elderly_id'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 记录播放历史
+    cursor.execute('''
+        INSERT INTO media_play_history (
+            media_id, elderly_id, duration_watched, completed,
+            triggered_by, mood_before, mood_after
+        ) VALUES (?, ?, ?, ?, ?, ?, ?)
+    ''', (media_id, elderly_id, duration_watched, completed,
+          triggered_by, mood_before, mood_after))
+
+    # 更新媒体策略的播放次数和最后播放时间
+    cursor.execute('''
+        UPDATE media_policies
+        SET play_count = play_count + 1,
+            last_played_at = CURRENT_TIMESTAMP
+        WHERE media_id = ?
+    ''', (media_id,))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/elderly/media/<int:media_id>/feedback', methods=['POST'])
+def submit_media_feedback(media_id):
+    """提交媒体反馈（点赞/点踩）"""
+    data = request.json
+
+    elderly_id = data.get('elderly_id')
+    feedback_type = data.get('feedback_type')  # 'like' 或 'dislike'
+
+    if not elderly_id or feedback_type not in ['like', 'dislike']:
+        return jsonify({'error': '参数错误'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 使用 INSERT OR REPLACE 来处理重复反馈
+    cursor.execute('''
+        INSERT OR REPLACE INTO media_feedback (media_id, elderly_id, feedback_type)
+        VALUES (?, ?, ?)
+    ''', (media_id, elderly_id, feedback_type))
+
+    conn.commit()
+    conn.close()
+
+    return jsonify({'success': True})
+
+@app.route('/api/elderly/media/history', methods=['GET'])
+def get_media_history():
+    """获取媒体播放历史"""
+    elderly_id = request.args.get('elderly_id')
+    limit = request.args.get('limit', 50)
+
+    if not elderly_id:
+        return jsonify({'error': '缺少elderly_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        SELECT
+            mph.*,
+            m.title,
+            m.media_type,
+            m.file_path,
+            mf.feedback_type
+        FROM media_play_history mph
+        INNER JOIN media m ON mph.media_id = m.id
+        LEFT JOIN media_feedback mf ON mph.media_id = mf.media_id AND mph.elderly_id = mf.elderly_id
+        WHERE mph.elderly_id = ?
+        ORDER BY mph.played_at DESC
+        LIMIT ?
+    ''', (elderly_id, limit))
+
+    history = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({'history': history})
+
+@app.route('/api/family/media/recent-plays', methods=['GET'])
+def get_recent_plays():
+    """获取最近播放的媒体（家属端查看）"""
+    family_id = request.args.get('family_id')
+    limit = request.args.get('limit', 10)
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        SELECT
+            m.id,
+            m.title,
+            m.media_type,
+            m.thumbnail_path,
+            mph.played_at,
+            COUNT(CASE WHEN mf.feedback_type = 'like' THEN 1 END) as likes,
+            COUNT(CASE WHEN mf.feedback_type = 'dislike' THEN 1 END) as dislikes
+        FROM media m
+        INNER JOIN media_play_history mph ON m.id = mph.media_id
+        LEFT JOIN media_feedback mf ON m.id = mf.media_id
+        WHERE m.family_id = ?
+        GROUP BY m.id, mph.played_at
+        ORDER BY mph.played_at DESC
+        LIMIT ?
+    ''', (family_id, limit))
+
+    recent = [dict(row) for row in cursor.fetchall()]
+    conn.close()
+
+    return jsonify({'recent_plays': recent})
+
+# ==================== 静态文件服务 ====================
+
+@app.route('/uploads/<path:filename>')
+def serve_upload(filename):
+    """提供上传文件的访问"""
+    return send_from_directory(app.config['UPLOAD_FOLDER'], filename)
+
+# ==================== 数字人媒体展示 API ====================
+
+@app.route('/api/elderly/show-media', methods=['POST'])
+def show_media_on_avatar():
+    """
+    控制老人端在数字人主页中部弹出透明窗口展示媒体文件
+    参数:
+    - media_title: 媒体标题(用于查找媒体文件)
+    - avatar_text: 数字人播报内容
+    - duration: 展示时长(秒),默认30秒
+    """
+    data = request.json
+
+    required_fields = ['media_title', 'avatar_text']
+    if not all(field in data for field in required_fields):
+        return jsonify({'error': '缺少必需字段: media_title 和 avatar_text'}), 400
+
+    media_title = data['media_title']
+    avatar_text = data['avatar_text']
+    duration = data.get('duration', 30)  # 默认30秒
+
+    # 从数据库查找媒体文件
+    conn = get_db()
+    cursor = conn.cursor()
+
+    cursor.execute('''
+        SELECT id, media_type, file_path, title
+        FROM media
+        WHERE title = ? AND is_active = 1
+        LIMIT 1
+    ''', (media_title,))
+
+    media_row = cursor.fetchone()
+
+    if not media_row:
+        conn.close()
+        return jsonify({'error': f'未找到标题为 "{media_title}" 的媒体文件'}), 404
+
+    media_dict = dict(media_row)
+    media_type = media_dict['media_type']
+    file_path = media_dict['file_path']
+
+    # 提取文件名(不含路径)
+    media_filename = os.path.basename(file_path)
+
+    try:
+        # 1. 推送播报内容到数字人（5000端口）
+        avatar_response = requests.post(
+            'http://127.0.0.1:5000/transparent-pass',
+            json={
+                'user': 'User',
+                'text': avatar_text
+            },
+            timeout=5
+        )
+
+        if not avatar_response.ok:
+            print(f'推送数字人播报失败: {avatar_response.status_code}')
+
+        # 2. 通知老人端弹出媒体展示窗口
+        # 创建媒体展示事件（使用 family_alerts 表的特殊类型）
+        cursor.execute('''
+            INSERT INTO family_alerts (
+                family_id, alert_type, level, title, message, metadata, source
+            ) VALUES (?, ?, ?, ?, ?, ?, ?)
+        ''', (
+            data.get('family_id', 'family_001'),
+            'media_display',  # 特殊类型：媒体展示
+            'low',
+            media_title,  # 使用媒体标题作为标题
+            avatar_text,
+            json.dumps({
+                'media_filename': media_filename,
+                'media_type': media_type,
+                'media_title': media_title,
+                'avatar_text': avatar_text,
+                'duration': duration,
+                'event_type': 'show_media'
+            }),
+            'system'
+        ))
+
+        event_id = cursor.lastrowid
+        conn.commit()
+        conn.close()
+
+        return jsonify({
+            'success': True,
+            'event_id': event_id,
+            'message': '媒体展示请求已发送'
+        }), 201
+
+    except Exception as e:
+        print(f'处理媒体展示请求失败: {e}')
+        return jsonify({'error': str(e)}), 500
+
+@app.route('/api/elderly/hide-media', methods=['POST'])
+def hide_media_on_avatar():
+    """
+    控制老人端关闭当前显示的媒体窗口
+    参数:
+    - family_id: 家庭ID（可选，默认family_001）
+    """
+    data = request.json or {}
+    family_id = data.get('family_id', 'family_001')
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    try:
+        # 创建隐藏媒体事件
+        cursor.execute('''
+            INSERT INTO family_alerts (
+                family_id, alert_type, level, title, message, metadata, source
+            ) VALUES (?, ?, ?, ?, ?, ?, ?)
+        ''', (
+            family_id,
+            'media_display',  # 使用相同类型
+            'low',
+            '关闭媒体显示',
+            '关闭当前显示的媒体',
+            json.dumps({
+                'event_type': 'hide_media'
+            }),
+            'system'
+        ))
+
+        event_id = cursor.lastrowid
+        conn.commit()
+        conn.close()
+
+        return jsonify({
+            'success': True,
+            'event_id': event_id,
+            'message': '关闭媒体请求已发送'
+        }), 201
+
+    except Exception as e:
+        print(f'处理关闭媒体请求失败: {e}')
+        conn.close()
+        return jsonify({'error': str(e)}), 500
+
+@app.route('/api/elderly/poll-media-events', methods=['GET'])
+def poll_media_events():
+    """
+    老人端轮询媒体展示事件
+    """
+    family_id = request.args.get('family_id', 'family_001')
+
+    conn = get_db()
+    cursor = conn.cursor()
+
+    # 查询未读的媒体展示事件
+    cursor.execute('''
+        SELECT * FROM family_alerts
+        WHERE family_id = ?
+        AND alert_type = 'media_display'
+        AND read = 0
+        AND is_active = 1
+        ORDER BY created_at DESC
+        LIMIT 1
+    ''', (family_id,))
+
+    row = cursor.fetchone()
+
+    if row:
+        alert = dict(row)
+        # 解析元数据
+        if alert['metadata']:
+            try:
+                alert['metadata'] = json.loads(alert['metadata'])
+            except:
+                alert['metadata'] = {}
+
+        # 标记为已读
+        cursor.execute('''
+            UPDATE family_alerts
+            SET read = 1, read_at = CURRENT_TIMESTAMP
+            WHERE id = ?
+        ''', (alert['id'],))
+        conn.commit()
+        conn.close()
+
+        return jsonify({'event': alert})
+    else:
+        conn.close()
+        return jsonify({'event': None})
+
+# ==================== 老人端Toast通知 ====================
+
+# 全局变量存储待显示的toast（内存中，重启会丢失）
+pending_toasts = {}  # key: family_id, value: list of toast objects
+
+# SSE连接管理
+sse_clients = {}  # key: family_id, value: list of response queues
+
+@app.route('/api/elderly/toast', methods=['POST'])
+def create_toast():
+    """创建老人端Toast通知（供MCP工具调用）"""
+    data = request.json
+
+    family_id = data.get('family_id')
+    toast_type = data.get('type', 'info')  # success, info, calling
+    message = data.get('message')
+    duration = data.get('duration', 3000)  # 默认3秒
+
+    if not family_id or not message:
+        return jsonify({'error': '缺少必需参数'}), 400
+
+    # 创建toast对象
+    toast = {
+        'id': int(time.time() * 1000),  # 使用时间戳作为ID
+        'type': toast_type,
+        'message': message,
+        'duration': duration,
+        'created_at': datetime.now().isoformat()
+    }
+
+    # 添加到待显示列表（备用轮询方式）
+    if family_id not in pending_toasts:
+        pending_toasts[family_id] = []
+    pending_toasts[family_id].append(toast)
+
+    # 通过SSE推送给连接的客户端
+    if family_id in sse_clients:
+        for client_queue in sse_clients[family_id]:
+            try:
+                client_queue.put(toast)
+            except:
+                pass  # 客户端可能已断开
+
+    return jsonify({'success': True, 'toast_id': toast['id']}), 201
+
+@app.route('/api/elderly/toast/poll', methods=['GET'])
+def poll_toast():
+    """老人端轮询获取待显示的Toast（备用方案）"""
+    family_id = request.args.get('family_id')
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    # 获取并清空该family的待显示toast
+    toasts = pending_toasts.get(family_id, [])
+    if toasts:
+        # 返回最新的toast，并从列表中移除
+        toast = toasts.pop(0)
+        return jsonify({'toast': toast})
+
+    return jsonify({'toast': None})
+
+@app.route('/api/elderly/toast/stream', methods=['GET'])
+def toast_stream():
+    """SSE端点：实时推送Toast通知"""
+    family_id = request.args.get('family_id')
+
+    if not family_id:
+        return jsonify({'error': '缺少family_id参数'}), 400
+
+    def generate():
+        import queue
+
+        # 为此客户端创建队列
+        client_queue = queue.Queue()
+
+        # 注册客户端
+        if family_id not in sse_clients:
+            sse_clients[family_id] = []
+        sse_clients[family_id].append(client_queue)
+
+        try:
+            # 发送连接成功消息
+            yield f"data: {json.dumps({'type': 'connected'})}\n\n"
+
+            # 持续监听队列
+            while True:
+                try:
+                    # 等待新的toast（30秒超时，发送心跳）
+                    toast = client_queue.get(timeout=30)
+                    yield f"data: {json.dumps(toast)}\n\n"
+                except queue.Empty:
+                    # 发送心跳保持连接
+                    yield f": heartbeat\n\n"
+        finally:
+            # 客户端断开时清理
+            if family_id in sse_clients:
+                sse_clients[family_id].remove(client_queue)
+                if not sse_clients[family_id]:
+                    del sse_clients[family_id]
+
+    return Response(
+        generate(),
+        mimetype='text/event-stream',
+        headers={
+            'Cache-Control': 'no-cache',
+            'X-Accel-Buffering': 'no',
+            'Connection': 'keep-alive'
+        }
+    )
+
+# ==================== 健康检查 ====================
+
+@app.route('/api/health', methods=['GET'])
+def health_check():
+    """健康检查端点"""
+    return jsonify({'status': 'ok', 'timestamp': datetime.now().isoformat()})
+
+if __name__ == '__main__':
+    # 初始化数据库
+    init_db()
+    print("数据库初始化完成")
+
+    # 启动应用
+    app.run(host='0.0.0.0', port=8000, debug=True)