From 7a9f9cb3c34ebc0836720d0f5738bbe70070bbb3 Mon Sep 17 00:00:00 2001 From: zhaoqingang <zhaoqg0118@163.com> Date: 星期四, 05 十二月 2024 14:22:24 +0800 Subject: [PATCH] 增加菜单和路由控制 --- app/service/dialog.py | 10 +++++----- 1 files changed, 5 insertions(+), 5 deletions(-) diff --git a/app/service/dialog.py b/app/service/dialog.py index 3af1363..a0ab574 100644 --- a/app/service/dialog.py +++ b/app/service/dialog.py @@ -1,6 +1,5 @@ from datetime import datetime -from app.api.user import user_list from app.models import KnowledgeModel, GroupModel, DialogModel, ConversationModel from app.models.user_model import UserModel from Log import logger @@ -25,14 +24,15 @@ return {"rows": [kld.to_json() for kld in dialog_list]} -async def update_session_history(db, data: dict, user_id, is_new): +async def update_session_history(db, data: dict, user_id): session_id = data.get("id") if not session_id: logger.error("鏇存柊鍥炶瘽璁板綍澶辫触锛亄}".format(data)) - + return data["create_date"] = datetime.strptime(data["create_date"], '%a, %d %b %Y %H:%M:%S %Z') data["update_date"] = datetime.strptime(data["update_date"], '%a, %d %b %Y %H:%M:%S %Z') - if is_new: + conversation = db.query(ConversationModel).filter(ConversationModel.id == session_id).first() + if not conversation: try: data["tenant_id"] = user_id conversation_model = ConversationModel(**data) @@ -43,7 +43,7 @@ db.rollback() else: try: - data["tenant_id"] = user_id + # data["tenant_id"] = user_id del data["id"] db.query(ConversationModel).filter(ConversationModel.id == session_id).update(data) db.commit() -- Gitblit v1.8.0