|
|
@ -123,6 +123,7 @@ class AgentController extends GetxController { |
|
|
Timer? _progressTimer; |
|
|
Timer? _progressTimer; |
|
|
// 用于跟踪AI回复状态 |
|
|
// 用于跟踪AI回复状态 |
|
|
bool _isNewAssistantResponse = true; |
|
|
bool _isNewAssistantResponse = true; |
|
|
|
|
|
RxBool newAIReplyCompleted = true.obs; |
|
|
String _currentResponseId = ''; |
|
|
String _currentResponseId = ''; |
|
|
|
|
|
|
|
|
final TAG = 'AgentController'; |
|
|
final TAG = 'AgentController'; |
|
|
@ -635,6 +636,7 @@ class AgentController extends GetxController { |
|
|
isImageProcessing.value = false; |
|
|
isImageProcessing.value = false; |
|
|
// 标记当前回复完成 |
|
|
// 标记当前回复完成 |
|
|
_isNewAssistantResponse = true; |
|
|
_isNewAssistantResponse = true; |
|
|
|
|
|
newAIReplyCompleted.value = true; |
|
|
break; |
|
|
break; |
|
|
|
|
|
|
|
|
case AgentServiceEventType.error: |
|
|
case AgentServiceEventType.error: |
|
|
@ -892,6 +894,7 @@ class AgentController extends GetxController { |
|
|
isProcessing.value = true; |
|
|
isProcessing.value = true; |
|
|
// 标记为新的AI回复 |
|
|
// 标记为新的AI回复 |
|
|
_isNewAssistantResponse = true; |
|
|
_isNewAssistantResponse = true; |
|
|
|
|
|
newAIReplyCompleted.value = false; |
|
|
// 根据TTS状态决定是否朗读 |
|
|
// 根据TTS状态决定是否朗读 |
|
|
await AgentService.processTextInput(text, |
|
|
await AgentService.processTextInput(text, |
|
|
speakResponse: isTtsEnabled.value); |
|
|
speakResponse: isTtsEnabled.value); |
|
|
|