songjvcheng/go_digital_backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

jijo
All checks were successful
Gitea Actions Demo / Explore-Gitea-Actions (push) Successful in 53s
Details

Browse Source
This commit is contained in:
Song367 2025-06-18 19:14:11 +08:00
parent 7f89c584c0
commit f4b35f4596
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
service/llm_service.go
View File

@ -167,6 +167,7 @@ func (s *LLMService) handleStreamingResponse(req *http.Request, data map[string]
} }
messageChan := make(chan Message, 100) // Buffered channel for better performance messageChan := make(chan Message, 100) // Buffered channel for better performance
all_message := ""
initialSessage := "" initialSessage := ""
go func() { go func() {
defer resp.Body.Close() defer resp.Body.Close()
@ -256,6 +257,7 @@ func (s *LLMService) handleStreamingResponse(req *http.Request, data map[string]
} }
new_message := "" new_message := ""
initialSessage += answer initialSessage += answer
all_message += answer
if containsPunctuation(initialSessage) { if containsPunctuation(initialSessage) {
segments := splitByPunctuation(initialSessage) segments := splitByPunctuation(initialSessage)
// fmt.Printf("原始文本: %s\n", initialSessage) // fmt.Printf("原始文本: %s\n", initialSessage)
@ -341,10 +343,10 @@ func (s *LLMService) handleStreamingResponse(req *http.Request, data map[string]
} }
break // 获取到音频就退出 break // 获取到音频就退出
} }
fmt.Println("audio is empty, retry", speechResp) // fmt.Println("audio is empty, retry", speechResp)
// time.Sleep(1 * time.Second) // time.Sleep(1 * time.Second)
} }
fmt.Println("所有消息：", all_message)
messageChan <- Message{ messageChan <- Message{
Answer: new_message, Answer: new_message,
IsEnd: false, IsEnd: false,