fix: 修复模型字段缺失和语法错误

- Conversation模型添加tags字段
- Keyword模型添加synonyms字段
- Alert模型添加assignee/assignee_note/assigned_at字段
- 修复senders.py/conversations.py/alerts.py语法错误
- 修复会话标签列表查询（MySQL JSON列兼容）

Author: chu0119

backend/app/api/alerts.py

@@ -598,7 +598,7 @@ async def assign_alert(
     result = await db.execute(select(Alert).where(Alert.id == alert_id))
     alert = result.scalar_one_or_none()
     if not alert:
-        raise HTTPException(status_code=404, detail=告警不存在)
+        raise HTTPException(status_code=404, detail="告警不存在")
     alert.assignee = assignee
     alert.assignee_note = note
     alert.assigned_at = now_utc()

backend/app/api/conversations.py

@@ -869,13 +869,22 @@ async def add_all_channels_from_account(
 @router.get("/tags/list")
 async def list_all_tags(db: AsyncSession = Depends(get_db)):
     """获取所有标签（去重）"""
+    from sqlalchemy import text
     result = await db.execute(
-        select(Conversation.tags).where(Conversation.tags.isnot(None))
+        text("SELECT tags FROM conversations WHERE tags IS NOT NULL AND tags != 'null'")
     )
     all_tags = set()
-    for row in result.scalars().all():
-        if row and isinstance(row, list):
-            all_tags.update(row)
+    for row in result.all():
+        tags = row[0]
+        if tags:
+            import json
+            try:
+                if isinstance(tags, str):
+                    tags = json.loads(tags)
+                if isinstance(tags, list):
+                    all_tags.update(tags)
+            except (json.JSONDecodeError, TypeError):
+                pass
     return sorted(all_tags)
 
 
@@ -891,7 +900,7 @@ async def update_conversation_tags(
     )
     conv = result.scalar_one_or_none()
     if not conv:
-        raise HTTPException(status_code=404, detail=会话不存在)
+        raise HTTPException(status_code=404, detail="会话不存在")
     conv.tags = tags
     await db.commit()
-    return {message: 标签已更新, tags: tags}
+    return {"message": "标签已更新", "tags": tags}

backend/app/api/senders.py

@@ -95,13 +95,13 @@ async def get_sender_detail(
     sender_id: int,
     db: AsyncSession = Depends(get_db),
 ):
-    获取发送者详情
+    """获取发送者详情"""
     from app.models.message import Message
     result = await db.execute(select(Sender).where(Sender.id == sender_id))
     sender = result.scalar_one_or_none()
     if not sender:
         from fastapi import HTTPException
-        raise HTTPException(status_code=404, detail=发送者不存在)
+        raise HTTPException(status_code=404, detail="发送者不存在")
 
     # 实时统计告警数
     alert_count_result = await db.execute(
@@ -118,19 +118,19 @@ async def get_sender_detail(
     message_types = {row[0]: row[1] for row in type_result.all()}
 
     return {
-        id: sender.id,
-        user_id: sender.user_id,
-        username: sender.username,
-        first_name: sender.first_name,
-        last_name: sender.last_name,
-        phone: sender.phone,
-        is_bot: sender.is_bot,
-        is_verified: sender.is_verified,
-        is_premium: sender.is_premium,
-        message_count: sender.message_count,
-        alert_count: alert_count,
-        message_types: message_types,
-        created_at: sender.created_at.isoformat() if sender.created_at else None,
+        "id": sender.id,
+        "user_id": sender.user_id,
+        "username": sender.username,
+        "first_name": sender.first_name,
+        "last_name": sender.last_name,
+        "phone": sender.phone,
+        "is_bot": sender.is_bot,
+        "is_verified": sender.is_verified,
+        "is_premium": sender.is_premium,
+        "message_count": sender.message_count,
+        "alert_count": alert_count,
+        "message_types": message_types,
+        "created_at": sender.created_at.isoformat() if sender.created_at else None,
     }
 
 
@@ -141,15 +141,15 @@ async def get_sender_messages(
     page_size: int = Query(20, ge=1, le=100),
     db: AsyncSession = Depends(get_db),
 ):
-    获取发送者的消息历史
+    """获取发送者的消息历史"""
     from app.models.message import Message
     from app.models.conversation import Conversation
 
     # 验证发送者存在
     sender_result = await db.execute(select(Sender).where(Sender.id == sender_id))
     if not sender_result.scalar_one_or_none():
         from fastapi import HTTPException
-        raise HTTPException(status_code=404, detail=发送者不存在)
+        raise HTTPException(status_code=404, detail="发送者不存在")
 
     # 总数
     count_result = await db.execute(
@@ -172,23 +172,23 @@ async def get_sender_messages(
     items = []
     for msg, conv_title in rows:
         items.append({
-            id: msg.id,
-            conversation_id: msg.conversation_id,
-            conversation_title: conv_title,
-            message_type: msg.message_type,
-            text: msg.text,
-            caption: msg.caption,
-            date: msg.date.isoformat() if msg.date else None,
-            views: msg.views,
-            forwards: msg.forwards,
-            has_media: msg.has_media,
-            is_reply: msg.is_reply,
+            "id": msg.id,
+            "conversation_id": msg.conversation_id,
+            "conversation_title": conv_title,
+            "message_type": msg.message_type,
+            "text": msg.text,
+            "caption": msg.caption,
+            "date": msg.date.isoformat() if msg.date else None,
+            "views": msg.views,
+            "forwards": msg.forwards,
+            "has_media": msg.has_media,
+            "is_reply": msg.is_reply,
         })
 
     return {
-        items: items,
-        total: total,
-        page: page,
-        page_size: page_size,
-        total_pages: (total + page_size - 1) // page_size if total else 0,
+        "items": items,
+        "total": total,
+        "page": page,
+        "page_size": page_size,
+        "total_pages": (total + page_size - 1) // page_size if total else 0,
     }

backend/app/models/conversation.py

@@ -58,6 +58,9 @@ class Conversation(Base):
     # 元数据
     created_at = Column(DateTime, server_default=func.now())
     updated_at = Column(DateTime, server_default=func.now(), onupdate=func.now())
+    # 标签
+    tags = Column(JSON, comment="标签列表")
+
     note = Column(Text)
     extra = Column(JSON)
 

backend/app/models/keyword.py

@@ -48,6 +48,9 @@ class KeywordGroup(Base):
     total_keywords = Column(Integer, default=0, comment="关键词数量")
     total_matches = Column(Integer, default=0, comment="总匹配次数")
 
+    # 同义词扩展
+    synonyms = Column(JSON, comment="同义词列表")
+
     # 元数据
     created_at = Column(DateTime, server_default=func.now(), comment="创建时间")
     updated_at = Column(DateTime, server_default=func.now(), onupdate=func.now(), comment="更新时间")