From 02acb714baf671b9b7d835cb03b35f20366cb6a8 Mon Sep 17 00:00:00 2001
From: renzhiyuan <465386466@qq.com>
Date: Mon, 9 Feb 2026 17:09:45 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E9=85=8D=E7=BD=AE?=
 =?UTF-8?q?=E6=96=87=E4=BB=B6=E8=B7=AF=E5=BE=84=E5=92=8C=E6=8A=A5=E8=A1=A8?=
 =?UTF-8?q?=E5=90=88=E5=B9=B6=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/services/dtalk_bot.go | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/internal/services/dtalk_bot.go b/internal/services/dtalk_bot.go
index 28eacb1..c0c29fe 100644
--- a/internal/services/dtalk_bot.go
+++ b/internal/services/dtalk_bot.go
@@ -65,9 +65,14 @@ func (d *DingBotService) runBackgroundTasks(ctx context.Context, data *chatbot.B
 		defer func() {
 			// 确保通道最终关闭
 			log.Println("流式处理协程关闭")
+
 			close(resChan)
 		}()
-		return d.dingTalkBotBiz.HandleStreamRes(ctx, data, resChan)
+		err := d.dingTalkBotBiz.HandleStreamRes(ctx, data, resChan)
+		if err != nil {
+			log.Println("流式回复产生错误，错误：", err.Error())
+		}
+		return err
 	})
 
 	// 2. 业务处理协程（负责关闭requireData.Ch）