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)