From c0520910c1eb3cdb0a7a19eaa869cde2194f5719 Mon Sep 17 00:00:00 2001
From: liuwei <liuwei@wdtrgf.com.cn>
Date: Mon, 31 Mar 2025 14:44:12 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E5=8E=86=E5=8F=B2=E5=86=85?=
 =?UTF-8?q?=E5=AE=B9=E6=A0=BC=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 plugins/dify/main.py | 18 ++++++++++++++----
 1 file changed, 14 insertions(+), 4 deletions(-)

diff --git a/plugins/dify/main.py b/plugins/dify/main.py
index 9b7977c..473212c 100644
--- a/plugins/dify/main.py
+++ b/plugins/dify/main.py
@@ -192,14 +192,24 @@ class DifyPlugin(MessagePluginInterface):
             "Accept": "text/event-stream"  # 指定接受事件流
         }
 
+        # 准备历史记录
+        history_text = ""
+        if self.conversations[session_id]:
+            # 将历史记录转换为字符串格式
+            for msg in self.conversations[session_id]:
+                role = "用户" if msg["role"] == "user" else "助手"
+                history_text += f"{role}: {msg['content']}\n"
+            history_text = history_text.strip()
+
+        # 准备输入参数
         inputs_params = {
             "query": query,
             "conversation_id": session_id
         }
 
-        # 添加历史记录
-        if self.conversations[session_id]:
-            inputs_params["history"] = self.conversations[session_id]
+        # 如果有历史记录，添加到inputs_params中
+        if history_text:
+            inputs_params["history"] = history_text
 
         # 准备请求数据
         data = {
@@ -209,7 +219,7 @@ class DifyPlugin(MessagePluginInterface):
             "response_mode": "blocking"  # 使用阻塞响应模式
         }
 
-        # 添加历史记录
+        # 如果有历史记录，同时添加到conversation_history中
         if self.conversations[session_id]:
             data["conversation_history"] = self.conversations[session_id]