fuzhongyun
/
ai_scheduler
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

结构修改

This commit is contained in:
renzhiyuan 2025-09-29 15:09:22 +08:00
parent f17e10a0b3
commit ca0fce6911
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/biz/router.go
View File

@ -100,9 +100,7 @@ func (r *AiRouterBiz) RouteWithSocket(c *websocket.Conn, req *entitys.ChatSockRe
go func() { go func() {
defer func() { defer func() {
close(done) close(done)
if len(chat) > 0 {
}
var his = []*model.AiChatHi{ var his = []*model.AiChatHi{
{ {
SessionID: session, SessionID: session,
@ -133,7 +131,7 @@ func (r *AiRouterBiz) RouteWithSocket(c *websocket.Conn, req *entitys.ChatSockRe
cancel() // 通知主流程退出 cancel() // 通知主流程退出
return return
} }
if v.Type == entitys.ResponseText || v.Type == entitys.ResponseStream { if v.Type == entitys.ResponseText || v.Type == entitys.ResponseStream || v.Type == entitys.ResponseJson {
chat = append(chat, v.Content) chat = append(chat, v.Content)
} }
@ -408,7 +406,7 @@ func (r *AiRouterBiz) getSessionChatHis(sessionId string) (his []model.AiChatHi,
cond := builder.NewCond() cond := builder.NewCond()
cond = cond.And(builder.Eq{"session_id": sessionId}) cond = cond.And(builder.Eq{"session_id": sessionId})
_, err = r.hisImpl.GetListToStruct(&cond, &dataTemp.ReqPageBo{Limit: r.conf.Sys.SessionLen}, &his, "his_id asc") _, err = r.hisImpl.GetListToStruct(&cond, &dataTemp.ReqPageBo{Limit: r.conf.Sys.SessionLen}, &his, "his_id desc")
return return
} }