From ed6075a89cbc56f7bf4ced106a5daef0f4b2ece0 Mon Sep 17 00:00:00 2001 From: CakeCN Date: Tue, 9 Dec 2025 22:03:55 +0800 Subject: [PATCH] =?UTF-8?q?=E7=94=A8user=5Fid=20save?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../course_services/learning_progess_process.py | 14 ++++++-------- Html/apps/sockets/namespaces.py | 6 +++--- 2 files changed, 9 insertions(+), 11 deletions(-) diff --git a/Html/apps/services/course_services/learning_progess_process.py b/Html/apps/services/course_services/learning_progess_process.py index baacdff..f1f6801 100644 --- a/Html/apps/services/course_services/learning_progess_process.py +++ b/Html/apps/services/course_services/learning_progess_process.py @@ -8,12 +8,11 @@ from urllib.parse import urlparse from datetime import datetime from bson import ObjectId -def save_learning_progress(user_uuid: str, chatmanager, user_id: str) -> bool: +def save_learning_progress(chatmanager, user_id: str) -> bool: """ 保存用户学习进度到MongoDB 参数: - - user_uuid: 用户UUID - chatmanager: ChatManager实例,包含学习进度数据 - user_id: 用户ID @@ -29,7 +28,6 @@ def save_learning_progress(user_uuid: str, chatmanager, user_id: str) -> bool: his_data = dialog_list['data'] # 构建学习进度数据 progress_data = { - "user_uuid": user_uuid, "user_id": user_id, "material_id": chatmanager.material_id, "chapter_name": chatmanager.chapter_name, @@ -44,7 +42,7 @@ def save_learning_progress(user_uuid: str, chatmanager, user_id: str) -> bool: # 保存到MongoDB,使用upsert操作(如果存在则更新,不存在则插入) mongo.db.learning_progress.update_one( { - "user_uuid": user_uuid, + "user_id": user_id, "material_id": chatmanager.material_id, "chapter_name": chatmanager.chapter_name, "lesson_name": chatmanager.lesson_name @@ -53,7 +51,7 @@ def save_learning_progress(user_uuid: str, chatmanager, user_id: str) -> bool: upsert=True ) - current_app.logger.info(f"学习进度保存成功: user_uuid={user_uuid}, lesson={chatmanager.lesson_name}") + current_app.logger.info(f"学习进度保存成功: user_id={user_id}, lesson={chatmanager.lesson_name}") return True except Exception as e: current_app.logger.error(f"保存学习进度失败: {str(e)}") @@ -102,12 +100,12 @@ def get_multiagents_dialog_list(user_id: str) -> List[Dict]: current_app.logger.error(f"获取MultiAgents对话列表异常: {str(e)}") return [] -def load_learning_progress(user_uuid: str, material_id: str, chapter_name: str, lesson_name: str) -> Optional[Dict]: +def load_learning_progress(user_id: str, material_id: str, chapter_name: str, lesson_name: str) -> Optional[Dict]: """ 加载用户学习进度 参数: - - user_uuid: 用户UUID + - user_id: 用户ID - material_id: 课程ID - chapter_name: 章节名 - lesson_name: 课时名 @@ -118,7 +116,7 @@ def load_learning_progress(user_uuid: str, material_id: str, chapter_name: str, try: mongo = current_app.extensions["mongo"] progress = mongo.db.learning_progress.find_one({ - "user_uuid": user_uuid, + "user_id": user_id, "material_id": material_id, "chapter_name": chapter_name, "lesson_name": lesson_name diff --git a/Html/apps/sockets/namespaces.py b/Html/apps/sockets/namespaces.py index ffb7365..9749784 100644 --- a/Html/apps/sockets/namespaces.py +++ b/Html/apps/sockets/namespaces.py @@ -86,7 +86,7 @@ class AgentNamespace(Namespace): chatmanager.function_manager.add_function(next_chapter, {'user_uuid': user_uuid}) if not chatmanager.restart:# 尝试加载用户学习进度 - progress = load_learning_progress(user_uuid, course_id, chapter_name, lesson_name) + progress = load_learning_progress(user_id, course_id, chapter_name, lesson_name) need_skip_chapters = 0 if progress: @@ -243,8 +243,8 @@ class AgentNamespace(Namespace): # 调用保存学习进度功能 chatmanager = user_uuid2chatmanager.get(uuid) if chatmanager: - save_result = save_learning_progress(uuid, chatmanager, user_id) - print(f"保存学习进度结果: {save_result}, user_uuid={uuid}") + save_result = save_learning_progress(chatmanager, user_id) + print(f"保存学习进度结果: {save_result}") except Exception as e: print(f"保存学习进度时发生异常: {str(e)}")