diff --git a/src/chat/express/expression_learner.py b/src/chat/express/expression_learner.py index f219bcac5..162011a01 100644 --- a/src/chat/express/expression_learner.py +++ b/src/chat/express/expression_learner.py @@ -251,7 +251,7 @@ class ExpressionLearner: # 使用CRUD查询 crud = CRUDBase(Expression) - all_expressions = await crud.get_all_by(chat_id=chat_id) + all_expressions = await crud.get_multi(chat_id=chat_id, limit=10000) for expr in all_expressions: # 确保create_date存在,如果不存在则使用last_active_time @@ -284,7 +284,7 @@ class ExpressionLearner: try: # 使用CRUD查询所有表达方式 crud = CRUDBase(Expression) - all_expressions = await crud.get_all() + all_expressions = await crud.get_multi(limit=100000) # 获取所有表达方式 updated_count = 0 deleted_count = 0 diff --git a/src/chat/message_receive/chat_stream.py b/src/chat/message_receive/chat_stream.py index b20892623..feefee98a 100644 --- a/src/chat/message_receive/chat_stream.py +++ b/src/chat/message_receive/chat_stream.py @@ -704,7 +704,7 @@ class ChatManager: loaded_streams_data = [] # 使用CRUD批量查询 crud = CRUDBase(ChatStreams) - all_streams = await crud.get_all() + all_streams = await crud.get_multi(limit=100000) # 获取所有聊天流 for model_instance in all_streams: user_info_data = { diff --git a/src/person_info/person_info.py b/src/person_info/person_info.py index 931b43720..c6a60f5f9 100644 --- a/src/person_info/person_info.py +++ b/src/person_info/person_info.py @@ -643,7 +643,7 @@ class PersonInfoManager: try: # 使用CRUD获取所有记录 crud = CRUDBase(PersonInfo) - all_records = await crud.get_all() + all_records = await crud.get_multi(limit=100000) # 获取所有记录 for record in all_records: value = getattr(record, f_name, None) if value is not None and way(value):