From 3edf08c7e482f32bc1db0cc9786b64e17b097000 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期五, 22 十一月 2024 17:06:09 +0800 Subject: [PATCH] Merge branch 'master' of http://192.168.5.5:10010/r/rag-gateway --- app/api/chat.py | 131 ++++++++++++++++++++++--------------------- 1 files changed, 67 insertions(+), 64 deletions(-) diff --git a/app/api/chat.py b/app/api/chat.py index de05de8..b2486ab 100644 --- a/app/api/chat.py +++ b/app/api/chat.py @@ -5,6 +5,8 @@ import asyncio import websockets from sqlalchemy.orm import Session + +from Log import logger from app.api import get_current_user_websocket from app.config.config import settings from app.models.agent_model import AgentModel, AgentType @@ -47,7 +49,6 @@ 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', []) @@ -55,7 +56,6 @@ 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) @@ -101,8 +101,12 @@ 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) + try: + dialog_chat_history = await ragflow_service.get_session_history(token, chat_id, 1) + await update_session_history(db, dialog_chat_history, current_user.id) + except Exception as e: + logger.error(e) + logger.error("-----------------淇濆瓨ragflow鐨勫巻鍙蹭細璇濆紓甯�-----------------") # 鍚姩浠诲姟澶勭悊瀹㈡埛绔秷鎭� tasks = [ @@ -205,72 +209,71 @@ # 鎺ユ敹鍓嶇娑堟伅 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 - ) + try: + SessionService(db).create_session( + chat_id, + question, + agent_id, + AgentType.BASIC, + current_user.id + ) + except Exception as e: + logger.error(e) 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", "") + logger.error(agent.type) + if agent.type == "questionTalk": - 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: + data = await service.questions_talk(question, chat_id) + 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, "file_name":file_name} 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}") + SessionService(db).update_session(chat_id, + message={"role": "assistant", "content": result}) + except Exception as e: + logger.error(e) + logger.error("-----------------杩斿洖鏁版嵁--------------------") + await websocket.send_json(result) + except Exception as e2: + + result = {"message": f"鍐呴儴閿欒锛� {e2}", "type": "close"} + logger.error(str(e2)) + logger.error(f"Error process message of basic chuti agent: {e2}") + await websocket.send_json(result) + + else: + async for data in service.excel_talk(question, chat_id): + output = data.get("output", "") + excel_name = data.get("excel_name", "") + image_name = data.get("image_name", "") + + def build_file_url(name, file_type): + if not name: + return None + return (f"/api/files/download/?agent_id={agent_id}&file_id={name}" + f"&file_type={file_type}") + excel_url = build_file_url(excel_name, 'excel') + image_url = build_file_url(image_name, 'image') + try: + SessionService(db).update_session(chat_id, message={"content": output, "role": "assistant"}) + except Exception as e: + logger.error(f"Unexpected error when update_session: {e}") + # 鍙戦�佺粨鏋滅粰瀹㈡埛绔� + data["type"] = "message" + data["message"] = output + data["excel_url"] = excel_url + data["image_url"] = image_url + await websocket.send_json(data) except Exception as e: - await websocket.send_json({"message": str(e), "type": "error"}) + logger.error(e) + await websocket.send_json({"message": "鍑虹幇閿欒锛�", "type": "error"}) finally: await websocket.close() print(f"Client {agent_id} disconnected") -- Gitblit v1.8.0