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

Compare commits

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

2 Commits
a1844bc818 ... ca4fca9a16

Author SHA1 Message Date
renzhiyuan ca4fca9a16 Merge remote-tracking branch 'origin/master' 2025-09-29 15:09:25 +08:00
renzhiyuan ca0fce6911 结构修改 2025-09-29 15:09:22 +08:00
1 changed files with 2 additions and 4 deletions
Show Stats 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
} }