Browse Source

上传代码优化

weicu
liwei1dao 1 year ago
parent
commit
40628c4f30
  1. 47
      lib/modules/agent/controllers/agent_controller.dart
  2. 2
      local_plugins/open_ai_service/android/src/main/kotlin/com/yunqiinnovation/open_ai_service/OpenAIService.kt

47
lib/modules/agent/controllers/agent_controller.dart

@ -116,12 +116,12 @@ class AgentController extends GetxController {
// 切换TTS状态
Future<void> toggleTts() async {
isTtsEnabled.toggle();
// 如果关闭TTS,停止当前语音
if (!isTtsEnabled.value && isSpeaking.value) {
await AgentService.stopTts();
}
// 保存偏好设置
try {
final storage = GetStorage();
@ -382,22 +382,15 @@ class AgentController extends GetxController {
logger.i('Flutter 结束调用 mcp: $result, $functionCall');
if (result.isNotEmpty) {
final parsedResult = jsonDecode(result);
final meta = parsedResult["meta"];
Map<String, dynamic> metaResult = {};
if (meta != null && meta is String && meta.isNotEmpty) {
try {
metaResult = jsonDecode(meta);
} catch (e) {
print('解析meta数据失败: $e');
}
}
if(metaResult.isNotEmpty){
final meta = parsedResult["meta"] as String;
final metaResult = jsonDecode(meta);
if (meta.isNotEmpty) {
logger.i('Flutter 结束调用 mcp metaResult: $metaResult');
// 判断是否为新的回复或响应ID是否改变
if (_isNewAssistantResponse || _currentResponseId != responseId) {
// 添加新消息
messages.add(Message(isUser: false, text: "", meta: metaResult));
messages
.add(Message(isUser: false, text: "", meta: metaResult));
_isNewAssistantResponse = false;
_currentResponseId = responseId;
} else {
@ -407,11 +400,14 @@ class AgentController extends GetxController {
messages[lastIndex] = Message(
isUser: false,
text: messages[lastIndex].text,
meta: meta,
meta: metaResult,
timestamp: messages[lastIndex].timestamp,
);
}
}
messages.refresh();
// 滚动到底部
_scrollToBottom();
}
}
break;
@ -467,7 +463,8 @@ class AgentController extends GetxController {
// 标记为新的AI回复
_isNewAssistantResponse = true;
// 根据TTS状态决定是否朗读
await AgentService.processTextInput(text, speakResponse: isTtsEnabled.value);
await AgentService.processTextInput(text,
speakResponse: isTtsEnabled.value);
} catch (e) {
logger.e('发送文本消息失败: $e');
isProcessing.value = false;
@ -549,18 +546,18 @@ class AgentController extends GetxController {
Future<bool> _checkMicrophonePermission() async {
try {
PermissionStatus status = await Permission.microphone.status;
// 如果已授权,直接返回 true
if (status.isGranted) {
return true;
}
// 如果被永久拒绝,提示用户前往设置页面
if (status.isPermanentlyDenied) {
_showPermissionDialog(true);
return false;
}
// 如果之前拒绝但不是永久拒绝,或首次请求,尝试请求权限
if (status.isDenied) {
status = await Permission.microphone.request();
@ -571,22 +568,22 @@ class AgentController extends GetxController {
return false;
}
}
return false;
} catch (e) {
logger.e('检查麦克风权限失败: $e');
return false;
}
}
// 显示权限提示对话框
void _showPermissionDialog(bool isPermanent) {
Get.dialog(
AlertDialog(
title: const Text('需要麦克风权限'),
content: Text(isPermanent
? '语音功能需要麦克风权限。请前往设置页面手动开启权限。'
: '语音功能需要麦克风权限。请允许使用麦克风权限以继续使用语音功能。'),
content: Text(isPermanent
? '语音功能需要麦克风权限。请前往设置页面手动开启权限。'
: '语音功能需要麦克风权限。请允许使用麦克风权限以继续使用语音功能。'),
actions: [
TextButton(
onPressed: () => Get.back(),

2
local_plugins/open_ai_service/android/src/main/kotlin/com/yunqiinnovation/open_ai_service/OpenAIService.kt

@ -698,7 +698,7 @@ class OpenAIService(private val context: Context? = null) : CoroutineScope {
put("arguments", firstToolCall.arguments)
put("id", firstToolCall.id)
}
Log.d(TAG, "工具调用: id=${firstToolCall.id}, name=${firstToolCall.name}")
Log.d(TAG, "工具调用: id=${firstToolCall.id}, name=${firstToolCall.name} arguments=${firstToolCall.arguments}")
// 通知上层工具调用事件
callback.onFunctionCall(functionCall)

Loading…
Cancel
Save