chat.py 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. from pydantic import BaseModel, Field, ConfigDict
  2. from typing import List, Optional, Dict, Any
  3. from datetime import datetime
  4. from ..config.config import Config
  5. class FileAttachment(BaseModel):
  6. """附件信息"""
  7. file_id: str # 火山方舟返回的 file_id
  8. filename: str # 原始文件名
  9. media_type: str # "image" | "video" | "audio"
  10. size: Optional[int] = None # 文件字节数
  11. class ChatMessage(BaseModel):
  12. role: str # "user" | "assistant" | "system"
  13. content: str
  14. attachments: Optional[List[FileAttachment]] = None # 附件列表(图片/视频/音频)
  15. timestamp: Optional[datetime] = None
  16. response_id: Optional[str] = None
  17. thinking: Optional[str] = None
  18. searching: Optional[str] = None
  19. # 帖子请求
  20. class CommentRequest(BaseModel):
  21. id: str # 帖子的主键
  22. # 兴趣圈提示词模版
  23. class CirclePromptConfig(BaseModel):
  24. appName: str # 包名,作为唯一标识
  25. name: str # 兴趣圈名称
  26. role: str # AI 扮演的角色
  27. style: str # 回复风格描述
  28. keywords: List[str] = [] # 推荐使用的关键词
  29. forbidden: List[str] = [] # 禁止使用的词语
  30. extra_instruction: str # 是给模型更细化的行为指引,可以包含在最终提示词中。
  31. # Ai的请求对象
  32. class ChatRequest(BaseModel):
  33. model_config = ConfigDict(populate_by_name=True)
  34. messages: List[ChatMessage]
  35. model: Optional[str] = Config.MODEL_NAME
  36. stream: Optional[bool] = False
  37. source: Optional[str] = None # source=app 时走第三方 token 认证
  38. token: Optional[str] = None # App 端传入的第三方 token
  39. session_id: Optional[str] = Field(None, alias="sessionId") # 会话ID,前端传 sessionId
  40. # Ai的返回对象
  41. class ChatResponse(BaseModel):
  42. message: ChatMessage
  43. model: str
  44. usage: Optional[Dict[str, Any]] = None
  45. response_id: Optional[str] = None
  46. # 流式对象
  47. class StreamResponse(BaseModel):
  48. content: str
  49. finished: bool
  50. model: str
  51. timestamp: datetime
  52. type: str = "answer" # "thinking"=AI思考开过车delta | "searching"=搜索状态/关键词 | "answer" = 正式回答 delta(现有逻辑)
  53. # 历史人物
  54. class HistoricalFigure(BaseModel):
  55. id: str = Field(alias="_id") # MongoDB _id
  56. name: str # 姓名,如 "孔子"
  57. era: str # 朝代/时期,如 "春秋时期"
  58. description: str # 简介,如 "儒家创始人"
  59. prompt: str # 说话风格提示词,用于 AI 润色
  60. model_config = ConfigDict(populate_by_name=True)
  61. # 历史人物新增/修改(不含 id,由 MongoDB 生成)
  62. class FigureUpsert(BaseModel):
  63. name: str
  64. era: str
  65. description: str
  66. prompt: str
  67. # 润色请求
  68. class RephraseRequest(BaseModel):
  69. figureId: str # 历史人物 _id
  70. text: str # 用户原文
  71. # 机器人群内自动回复
  72. class GroupChatRequest(BaseModel):
  73. message: str #@机器人的消息
  74. user_id: str # 用户编号= IM中的account
  75. app_name: str #IM群所对应的app包名
  76. # 帖子评论区机器人多轮对话
  77. class PostCommentBotRequest(BaseModel):
  78. post_id: str # 帖子 MongoDB ObjectId
  79. user_id: str # 评论用户账号
  80. app_name: str # app 包名
  81. message: str # @机器人的消息内容
  82. parent_comment: Optional[str] = None # 被回复的评论原文(场景2)