fix: 修复配置文件路径和报表合并逻辑
This commit is contained in:
parent
c7baaa8514
commit
02acb714ba
|
|
@ -65,9 +65,14 @@ func (d *DingBotService) runBackgroundTasks(ctx context.Context, data *chatbot.B
|
||||||
defer func() {
|
defer func() {
|
||||||
// 确保通道最终关闭
|
// 确保通道最终关闭
|
||||||
log.Println("流式处理协程关闭")
|
log.Println("流式处理协程关闭")
|
||||||
|
|
||||||
close(resChan)
|
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)
|
// 2. 业务处理协程(负责关闭requireData.Ch)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue