From f9ddb60c8882203fc3e8d646840358888f121d60 Mon Sep 17 00:00:00 2001
From: zhaoqingang <zhaoqg0118@163.com>
Date: 星期四, 16 一月 2025 14:29:24 +0800
Subject: [PATCH] tmp

---
 app/service/dialog.py |    9 +++++----
 1 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/app/service/dialog.py b/app/service/dialog.py
index 26d1e19..19f253c 100644
--- a/app/service/dialog.py
+++ b/app/service/dialog.py
@@ -120,17 +120,18 @@
             chat = ChatBaseApply()
             token = await get_chat_token(db, dialog_id)
             if not token:
-                workflow = await get_app_token(db, workflow_server)
-                if workflow:
+                access_token = await get_app_token(db, workflow_server)
+                # print(workflow)
+                if access_token:
                     url = settings.dify_base_url + DF_CHAT_API_KEY.format(dialog_id)
-                    param = await chat.chat_get(url, {}, await chat.get_headers(workflow.access_token))
+                    param = await chat.chat_get(url, {}, await chat.get_headers(access_token))
                     if param and param.get("data"):
                         token = param.get("data", [{}])[0].get("token")
                         token_id = param.get("data", [{}])[0].get("id")
                         await add_chat_token(db, {"id":token_id, "app_id": dialog_id, "type":"app", "token": token})
                         # dialog.parameters = json.dumps(param)
                     else:
-                        param = await chat.chat_post(url, {}, await chat.get_headers(workflow.access_token))
+                        param = await chat.chat_post(url, {}, await chat.get_headers(access_token))
                         if param:
                             token = param.get("token")
                             token_id = param.get("id")

--
Gitblit v1.8.0