From ea813e602be860cb96cce8ea1a15f9e849392eea Mon Sep 17 00:00:00 2001 From: zhaoqingang <zhaoqg0118@163.com> Date: 星期五, 15 十一月 2024 15:04:33 +0800 Subject: [PATCH] merge --- app/service/bisheng.py | 12 +++-- app/task/fetch_agent.py | 2 app/api/report.py | 12 ++++-- app/config/config.yaml | 5 +- app/api/agent.py | 47 +++++++++++++++-------- 5 files changed, 48 insertions(+), 30 deletions(-) diff --git a/app/api/agent.py b/app/api/agent.py index a3c9a22..67fe927 100644 --- a/app/api/agent.py +++ b/app/api/agent.py @@ -1,3 +1,4 @@ +import json import uuid from fastapi import Depends, APIRouter, Query, HTTPException @@ -82,8 +83,8 @@ 'reference': reference }) last_question = None - reference_index += 1 # 鍙湁鍦ㄦ坊鍔犱簡assistant鐨勫洖绛斿悗锛岀储寮曟墠澧炲姞 - return JSONResponse(status_code=200, content={"code": 200, "log": combined_logs}) + reference_index += 1 + return JSONResponse(status_code=200, content={"code": 200, "data": combined_logs}) else: return JSONResponse(status_code=200, content={"code": 400, "message": "Invalid result structure"}) @@ -94,21 +95,33 @@ try: token = get_bisheng_token(db, current_user.id) result = await bisheng_service.get_session_log(token, agent_id, conversation_id) - if 'session_log' in result: - combined_logs = [] - last_question = None - for session in result['session_log']: - if session['role'] == 'question': - last_question = session['message'] - elif session['role'] == 'answer' and last_question: - combined_logs.append({ - 'question': last_question, - 'answer': session['message'] - }) - last_question = None - return JSONResponse(status_code=200, content={"code": 200, "log": combined_logs}) - else: - return JSONResponse(status_code=200, content={"code": 400, "message": "Invalid result structure"}) + combined_logs = [] + last_question = None + + for session in result: + message = session['message'] + + # 鍒ゆ柇message鏄瓧绗︿覆杩樻槸json 瀵硅薄,濡傛灉鏄痡son鍙栧叾涓殑question瀛楁锛屾垨鑰卹eport_name瀛楁璧嬪�肩粰message + try: + message_json = json.loads(message) + if 'question' in message_json: + message = message_json['question'] + elif 'query' in message_json: + message = message_json['query'] + elif 'report_name' in message_json: + message = message_json['report_name'] + except json.JSONDecodeError: + pass + + if session['role'] == 'question': + last_question = message + elif session['role'] == 'answer' and last_question: + combined_logs.append({ + 'question': last_question, + 'answer': message + }) + last_question = None + return JSONResponse(status_code=200, content={"code": 200, "data": combined_logs}) except Exception as e: raise HTTPException(status_code=500, detail=str(e)) else: diff --git a/app/api/report.py b/app/api/report.py index 232c4b0..b2bac8a 100644 --- a/app/api/report.py +++ b/app/api/report.py @@ -65,16 +65,19 @@ files = data.get("files", []) steps = data.get("intermediate_steps", "") msg = data.get("message", "") + category = data.get("category", "") - if len(files) != 0 or (steps and last_message == "step") or msg or data["type"] == "close": + if len(files) != 0 or (msg and category != "answer") or data["type"] == "close": if data["type"] == "close": t = "close" else: t = "stream" process_files(files, agent_id) - result = {"step_message": steps, "message": msg, "type": t, "files": files} + result = {"message": msg, "type": t, "files": files} await websocket.send_json(result) - print(f"Forwarded to client, {chat_id}: {result}") + elif steps and last_message == "step": + result = {"step_message": steps, "type": "stream", "files": files} + await websocket.send_json(result) last_message = "message" if msg else "step" @@ -90,7 +93,8 @@ task.cancel() try: await task - except asyncio.CancelledError: + except asyncio.CancelledError as e: + print(f"asyncio CancelledError: {e}") pass except WebSocketDisconnect as e: diff --git a/app/config/config.yaml b/app/config/config.yaml index 26ec7e9..48050ba 100644 --- a/app/config/config.yaml +++ b/app/config/config.yaml @@ -10,6 +10,5 @@ MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEArq9XTUSeYr2+N1h3Afl/z8Dse/2yD0ZGrKwx+EEEcdsBLca9Ynmx3nIB5obmLlSfmskLpBo0UACBmB5rEjBp2Q2f3AG3Hjd4B+gNCG6BDaawuDlgANIhGnaTLrIqWrrcm4EMzJOnAOI1fgzJRsOOUEfaS318Eq9OVO3apEyCCt0lOQK6PuksduOjVxtltDav+guVAA068NrPYmRNabVKRNLJpL8w4D44sfth5RvZ3q9t+6RTArpEtc5sh5ChzvqPOzKGMXW83C95TxmXqpbK6olN4RevSfVjEAgCydH6HN6OhtOQEcnrU97r9H0iZOWwbw3pVrZiUkuRD1R56Wzs2wIDAQAB -----END PUBLIC KEY----- PRIVATE_KEY: str -fetch_sgb_agent: 鎶ュ憡鐢熸垚 -fetch_fwr_agent: 鐭ヨ瘑闂瓟,鏂囨。鏅鸿兘,鏅鸿兘闂瓟 -HASH_SUB_KEY: bZQDT7xZ8KkGfdnwbbxy4Ovk1Ci8AHJh7NEC9mwnLhk= \ No newline at end of file +fetch_sgb_agent: 鎶ュ憡鐢熸垚,鏂囨。鏅鸿兘 +fetch_fwr_agent: 鐭ヨ瘑闂瓟,鏅鸿兘闂瓟 \ No newline at end of file diff --git a/app/service/bisheng.py b/app/service/bisheng.py index 77473f5..e55dbb7 100644 --- a/app/service/bisheng.py +++ b/app/service/bisheng.py @@ -84,15 +84,17 @@ response = await client.get(url, headers=headers) response.raise_for_status() data = self._check_response(response) - session_log = { - "session_log": [ + session_log = [ { - "message": message.get("intermediate_steps"), + "message": message.get("message"), "role": message.get("category"), + "ts": message.get("create_time") } for message in data - ], - } + ] + + # 鎶妔ession_log 鎸塼s 鍗囧簭鎺掑簭 + session_log.sort(key=lambda x: x['ts']) return session_log async def variable_list(self, token: str, agent_id: str) -> list: diff --git a/app/task/fetch_agent.py b/app/task/fetch_agent.py index b6852c0..b8aacd4 100644 --- a/app/task/fetch_agent.py +++ b/app/task/fetch_agent.py @@ -112,7 +112,7 @@ initial_agents = [ ('80ee430a-e396-48c4-a12c-7c7cdf5eda51', 1, '鎶ュ憡鐢熸垚', 'BISHENG', 'report'), ('basic_excel_merge', 2, '鎶ヨ〃鍚堝苟', 'BASIC', 'excelMerge'), - ('bfd090d589d811efb3630242ac190006', 4, '鏂囨。鏅鸿兘', 'RAGFLOW', 'documentChat'), + ('bfd090d589d811efb3630242ac190006', 4, '鏂囨。鏅鸿兘', 'BISHENG', 'report'), ('da3451da89d911efb9490242ac190006', 3, '鐭ヨ瘑闂瓟', 'RAGFLOW', 'knowledgeQA'), ('e96eb7a589db11ef87d20242ac190006', 5, '鏅鸿兘闂瓟', 'RAGFLOW', 'chat') ] -- Gitblit v1.8.0