refactor: Optimize recent problem queries. (#556)

ziyujiahao · web-flow · commit 0d4bd64d7b4b · 2025-12-03T10:37:14.000+08:00
diff --git a/backend/apps/chat/curd/chat.py b/backend/apps/chat/curd/chat.py
@@ -46,8 +46,9 @@ def list_recent_questions(session: SessionDep, current_user: CurrentUser, dataso
             ChatRecord.question,
             func.count(ChatRecord.question).label('question_count')
         )
+        .join(Chat, ChatRecord.chat_id == Chat.id)  # 关联Chat表
         .filter(
-            ChatRecord.datasource == datasource_id,
+            Chat.datasource == datasource_id,  # 使用Chat表的datasource字段
             ChatRecord.question.isnot(None)
         )
         .group_by(ChatRecord.question)
@@ -57,7 +58,6 @@ def list_recent_questions(session: SessionDep, current_user: CurrentUser, dataso
     )
     return [record[0] for record in chat_records] if chat_records else []
 
-
 def rename_chat(session: SessionDep, rename_object: RenameChat) -> str:
     chat = session.get(Chat, rename_object.id)
     if not chat:

Original file line number	Diff line number	Diff line change
`@@ -46,8 +46,9 @@ def list_recent_questions(session: SessionDep, current_user: CurrentUser, dataso`
`46`	`46`	`ChatRecord.question,`
`47`	`47`	`func.count(ChatRecord.question).label('question_count')`
`48`	`48`	`)`
	`49`	`+ .join(Chat, ChatRecord.chat_id == Chat.id) # 关联Chat表`
`49`	`50`	`.filter(`
`50`		`- ChatRecord.datasource == datasource_id,`
	`51`	`+ Chat.datasource == datasource_id, # 使用Chat表的datasource字段`
`51`	`52`	`ChatRecord.question.isnot(None)`
`52`	`53`	`)`
`53`	`54`	`.group_by(ChatRecord.question)`
`@@ -57,7 +58,6 @@ def list_recent_questions(session: SessionDep, current_user: CurrentUser, dataso`
`57`	`58`	`)`
`58`	`59`	`return [record[0] for record in chat_records] if chat_records else []`
`59`	`60`
`60`		`-`
`61`	`61`	`def rename_chat(session: SessionDep, rename_object: RenameChat) -> str:`
`62`	`62`	`chat = session.get(Chat, rename_object.id)`
`63`	`63`	`if not chat:`