factor(documents): 移除文档模型中的 source 字段

从 Document 数据库模型中删除 source 列
从列表文档 API 端点中删除 source 查询参数
从 CreateDocumentRequest schema 中删除 source 字段
从 DocumentResponse schema 中删除 source 字段
从 DocumentListItem schema 中删除 source 字段
从文档服务列表方法中删除 source 过滤逻辑
从数据库迁移文件中删除 source 索引
移除 chat/workflow 来源区分，简化文档追踪逻辑

app/api/v1/documents.py

@@ -48,7 +48,6 @@ async def list_documents(
     page: int = Query(1, ge=1),
     page_size: int = Query(20, ge=1, le=100, alias="pageSize"),
     session_id: Optional[str] = Query(None, alias="sessionId"),
-    source: Optional[Literal["chat", "workflow"]] = None,
     sort_by: Literal["created_at", "updated_at"] = Query("updated_at", alias="sortBy"),
     sort_order: Literal["asc", "desc"] = Query("desc", alias="sortOrder"),
     db: AsyncSession = Depends(get_db),
@@ -58,7 +57,6 @@ async def list_documents(
         page=page,
         page_size=page_size,
         session_id=session_id,
-        source=source,
         sort_by=sort_by,
         sort_order=sort_order,
     )

app/models/document.py

@@ -20,7 +20,6 @@ class Document(Base):
     format: Mapped[str] = mapped_column(String(32), nullable=False, default="markdown")
     session_id: Mapped[str | None] = mapped_column(String(128), nullable=True)
     template_id: Mapped[str | None] = mapped_column(String(64), nullable=True)
-    source: Mapped[str] = mapped_column(String(32), nullable=False, default="chat")
     created_by: Mapped[str | None] = mapped_column(String(128), nullable=True)
     created_at: Mapped[datetime] = mapped_column(
         DateTime(timezone=True), server_default=func.now(), nullable=False

app/schemas/document.py

@@ -20,7 +20,6 @@ class CreateDocumentRequest(BaseModel):
     format: Literal["markdown"] = "markdown"
     session_id: Optional[str] = Field(None, alias="sessionId")
     template_id: Optional[str] = Field(None, alias="templateId")
-    source: Literal["chat", "workflow"] = "chat"
 
     model_config = {"populate_by_name": True}
 
@@ -46,7 +45,6 @@ class DocumentResponse(BaseModel):
     format: str
     session_id: Optional[str] = Field(None, serialization_alias="sessionId")
     template_id: Optional[str] = Field(None, serialization_alias="templateId")
-    source: Literal["chat", "workflow"]
     created_by: Optional[str] = Field(None, serialization_alias="createdBy")
     created_at: datetime = Field(..., serialization_alias="createdAt")
     updated_at: datetime = Field(..., serialization_alias="updatedAt")
@@ -57,7 +55,6 @@ class DocumentResponse(BaseModel):
 class DocumentListItem(BaseModel):
     id: str
     title: str
-    source: Literal["chat", "workflow"]
     template_id: Optional[str] = Field(None, serialization_alias="templateId")
     created_at: datetime = Field(..., serialization_alias="createdAt")
     updated_at: datetime = Field(..., serialization_alias="updatedAt")

app/services/document_service.py

@@ -32,7 +32,6 @@ class DocumentService:
             format=data.format,
             session_id=data.session_id,
             template_id=data.template_id,
-            source=data.source,
             created_by=user_id,
         )
         self.db.add(doc)
@@ -57,7 +56,6 @@ class DocumentService:
         page: int = 1,
         page_size: int = 20,
         session_id: str | None = None,
-        source: str | None = None,
         sort_by: str = "updated_at",
         sort_order: str = "desc",
     ) -> tuple[list[Document], int]:
@@ -65,8 +63,6 @@ class DocumentService:
 
         if session_id:
             query = query.where(Document.session_id == session_id)
-        if source:
-            query = query.where(Document.source == source)
 
         # 排序
         sort_col = getattr(Document, sort_by, Document.updated_at)

migrations/versions/001_init_documents.py

@@ -23,7 +23,6 @@ def upgrade() -> None:
         sa.Column("format", sa.String(32), nullable=False, server_default="markdown"),
         sa.Column("session_id", sa.String(128), nullable=True),
         sa.Column("template_id", sa.String(64), nullable=True),
-        sa.Column("source", sa.String(32), nullable=False, server_default="chat"),
         sa.Column("created_by", sa.String(128), nullable=True),
         sa.Column(
             "created_at",
@@ -40,10 +39,8 @@ def upgrade() -> None:
         ),
     )
     op.create_index("ix_documents_session_id", "documents", ["session_id"])
-    op.create_index("ix_documents_source", "documents", ["source"])
 
 
 def downgrade() -> None:
-    op.drop_index("ix_documents_source", table_name="documents")
     op.drop_index("ix_documents_session_id", table_name="documents")
     op.drop_table("documents")