From dbbc7d891c0f9837d3580842fa5326ba40a21476 Mon Sep 17 00:00:00 2001 From: zhaoqingang <zhaoqg0118@163.com> Date: 星期四, 21 十一月 2024 11:46:20 +0800 Subject: [PATCH] 出题组卷 --- app/api/chat.py | 99 ++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 93 insertions(+), 6 deletions(-) diff --git a/app/api/chat.py b/app/api/chat.py index b54db51..de05de8 100644 --- a/app/api/chat.py +++ b/app/api/chat.py @@ -10,8 +10,11 @@ from app.models.agent_model import AgentModel, AgentType from app.models.base_model import get_db from app.models.user_model import UserModel +from app.service.dialog import update_session_history +from app.service.basic import BasicService from app.service.ragflow import RagflowService -from app.service.token import get_bisheng_token, get_ragflow_token +from app.service.service_token import get_bisheng_token, get_ragflow_token +from app.service.session import SessionService router = APIRouter() @@ -44,6 +47,7 @@ try: async def forward_to_ragflow(): while True: + is_new = False message = await websocket.receive_json() print(f"Received from client {chat_id}: {message}") chat_history = message.get('chatHistory', []) @@ -51,8 +55,10 @@ if len(chat_history) == 0: chat_history = await ragflow_service.get_session_history(token, chat_id) if len(chat_history) == 0: + is_new = True chat_history = await ragflow_service.set_session(token, agent_id, message, chat_id, True) + # print("chat_history------------------------", chat_history) if len(chat_history) == 0: result = {"message": "鍐呴儴閿欒锛氬垱寤轰細璇濆け璐�", "type": "close"} await websocket.send_json(result) @@ -64,6 +70,7 @@ "doc_ids": message.get("doc_ids", []), "role": "user" }) + complete_response = "" async for rag_response in ragflow_service.chat(token, chat_id, chat_history): try: if rag_response[:5] == "data:": @@ -72,8 +79,9 @@ else: # 鍚﹀垯锛屼繚鎸佸師鏍� text = rag_response + complete_response += text try: - json_data = json.loads(text) + json_data = json.loads(complete_response) data = json_data.get("data") if data is True: # 瀹屾垚杈撳嚭 result = {"message": "", "type": "close"} @@ -85,14 +93,17 @@ reference = data.get("reference", {}) result = {"message": answer, "type": "message", "reference": reference} await websocket.send_json(result) - except json.JSONDecodeError: - print(f"Error decode ragflow response: {text}") - pass - + complete_response = "" + except json.JSONDecodeError as e: + print(f"Error decoding JSON: {e}") + # print(f"Response text: {text}") except Exception as e2: result = {"message": f"鍐呴儴閿欒锛� {e2}", "type": "close"} await websocket.send_json(result) print(f"Error process message of ragflow: {e2}") + dialog_chat_history = await ragflow_service.get_session_history(token, chat_id, 1) + await update_session_history(db, dialog_chat_history, current_user.id, is_new) + # 鍚姩浠诲姟澶勭悊瀹㈡埛绔秷鎭� tasks = [ asyncio.create_task(forward_to_ragflow()) @@ -187,6 +198,82 @@ await task except asyncio.CancelledError: pass + elif agent_type == AgentType.BASIC: + try: + service = BasicService(base_url=settings.basic_base_url) + while True: + # 鎺ユ敹鍓嶇娑堟伅 + message = await websocket.receive_json() + question = message.get("message") + SessionService(db).create_session( + session_id=chat_id, + name=question, + agent_id=agent_id, + agent_type=AgentType.BASIC + ) + if not question: + await websocket.send_json({"message": "Invalid request", "type": "error"}) + continue + if agent.agent_type == "questionTalk": + async for result in service.questions_talk(question, chat_id): + try: + if result[:5] == "data:": + # 濡傛灉鏄紝鍒欐埅鍙栨帀鍓�5涓瓧绗︼紝骞跺幓闄ら灏剧┖鐧界 + text = result[5:].strip() + else: + # 鍚﹀垯锛屼繚鎸佸師鏍� + text = result + try: + data = json.loads(text) + output = data.get("output", "") + file_name = data.get("filename", "") + + excel_url = None + if file_name: + excel_url = f"/api/files/download/?agent_id=basic_question_talk&file_id={file_name}&file_type=word" + result = {"message": output, "type": "message", "file_url": excel_url} + await websocket.send_json(result | data) + except json.JSONDecodeError as e: + print(f"Error decoding JSON: {e}") + # print(f"Response text: {text}") + except Exception as e2: + result = {"message": f"鍐呴儴閿欒锛� {e2}", "type": "close"} + await websocket.send_json(result) + print(f"Error process message of basic agent: {e2}") + else: + async for result in service.excel_talk(question, chat_id): + try: + if result[:5] == "data:": + # 濡傛灉鏄紝鍒欐埅鍙栨帀鍓�5涓瓧绗︼紝骞跺幓闄ら灏剧┖鐧界 + text = result[5:].strip() + else: + # 鍚﹀垯锛屼繚鎸佸師鏍� + text = result + try: + data = json.loads(text) + output = data.get("output", "") + excel_name = data.get("excel_name", "") + image_name = data.get("image_name", "") + excel_url = None + image_url = None + if excel_name: + excel_url = f"/api/files/download/?agent_id=basic_excel_talk&file_id={excel_name}&file_type=excel" + if image_name: + image_url = f"/api/files/download/?agent_id=basic_excel_talk&file_id={image_name}&file_type=image" + result = {"message": output, "type": "message", "excel_url": excel_url, "image_url": image_url} + await websocket.send_json(result | data) + except json.JSONDecodeError as e: + print(f"Error decoding JSON: {e}") + # print(f"Response text: {text}") + except Exception as e2: + result = {"message": f"鍐呴儴閿欒锛� {e2}", "type": "close"} + await websocket.send_json(result) + print(f"Error process message of basic agent: {e2}") + except Exception as e: + await websocket.send_json({"message": str(e), "type": "error"}) + finally: + await websocket.close() + print(f"Client {agent_id} disconnected") else: ret = {"message": "Agent not found", "type": "close"} await websocket.send_json(ret) -- Gitblit v1.8.0