diff --git a/service/llm_service.go b/service/llm_service.go index e980d4c..a4559bb 100644 --- a/service/llm_service.go +++ b/service/llm_service.go @@ -336,7 +336,7 @@ func (s *LLMService) processStreamSegment(initialSessage *string, all_message *s break } } - return new_message, audio, true + return s_msg, audio, true } // handleStreamingResponse processes streaming responses @@ -536,7 +536,7 @@ func (s *LLMService) handleStreamingResponse(req *http.Request, data map[string] } fmt.Println("所有消息:", all_message) messageChan <- Message{ - Answer: new_message, + Answer: s_msg, IsEnd: false, ConversationID: getString(jsonData, "conversation_id"), TaskID: getString(jsonData, "task_id"),