diff --git a/internal/services/dtalk_bot.go b/internal/services/dtalk_bot.go index 177406b..28eacb1 100644 --- a/internal/services/dtalk_bot.go +++ b/internal/services/dtalk_bot.go @@ -64,6 +64,7 @@ func (d *DingBotService) runBackgroundTasks(ctx context.Context, data *chatbot.B g.Go(func() error { defer func() { // 确保通道最终关闭 + log.Println("流式处理协程关闭") close(resChan) }() return d.dingTalkBotBiz.HandleStreamRes(ctx, data, resChan)