qinqinghuisheng/server/app.py

"""
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)