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

Compare commits

base: fuzhongyun:ca4fca9a16dd6e39e224adc60eae5d4b119afa78
Branches Tags
fuzhongyun:master
fuzhongyun:feature/toolSelect
fuzhongyun:dev
fuzhongyun:feature/session
fuzhongyun:feature/fiber
..
compare: fuzhongyun:a1844bc818c2e15a208da9316dfe44501f4ed1be
Branches Tags
fuzhongyun:master
fuzhongyun:feature/toolSelect
fuzhongyun:dev
fuzhongyun:feature/session
fuzhongyun:feature/fiber

No commits in common. "ca4fca9a16dd6e39e224adc60eae5d4b119afa78" and "a1844bc818c2e15a208da9316dfe44501f4ed1be" have entirely different histories.
ca4fca9a16 ... a1844bc818

1 changed files with 4 additions and 2 deletions
Show Stats Expand all files Collapse all files

6
internal/biz/router.go
View File

@ -100,7 +100,9 @@ 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,
@ -131,7 +133,7 @@ func (r *AiRouterBiz) RouteWithSocket(c *websocket.Conn, req *entitys.ChatSockRe
cancel() // 通知主流程退出 cancel() // 通知主流程退出
return return
} }
if v.Type == entitys.ResponseText || v.Type == entitys.ResponseStream || v.Type == entitys.ResponseJson { if v.Type == entitys.ResponseText || v.Type == entitys.ResponseStream {
chat = append(chat, v.Content) chat = append(chat, v.Content)
} }
@ -406,7 +408,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 desc") _, err = r.hisImpl.GetListToStruct(&cond, &dataTemp.ReqPageBo{Limit: r.conf.Sys.SessionLen}, &his, "his_id asc")
return return
} }