You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

1233 lines
41 KiB

import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'package:firebase_auth/firebase_auth.dart';
import 'package:flutter_dotenv/flutter_dotenv.dart';
import 'package:get_storage/get_storage.dart';
import 'package:get/get.dart';
import 'package:ble_service/ble_service.dart';
import 'package:agent_service/agent_service.dart';
import '../models/user_Info.dart' as userInfo;
import '/data/models/appconfig_model.dart';
import '../../data/models/appconfig.dart';
import '../../core/utils/logger.dart';
import 'bluetooth_manager.dart';
import 'language_manager.dart';
import 'network/dio_manager.dart';
// 重新导出BLE连接状态常量,让外部可以通过BleManager访问
export 'package:ble_service/ble_service.dart' show BleConnectionState;
/// 命令类型常量(与原生层保持一致)
class BleCommands {
static const int GET_VERSION = 0x01;
static const int GET_PRODUCT_ID = 0x02;
static const int GET_PRODUCT_COLOR = 0x03;
static const int GET_BATTERY_INFO = 0x04;
static const int CONTROL_CODEC = 0x05;
}
/// 判断编解码控制指令是否成功
///
/// 根据 rawData 第二字节是否为非 0 来判断:
/// - 成功:第二字节不为 0
/// - 失败或无法解析:返回 false
bool _isCodecControlSuccess(Map<dynamic, dynamic> data) {
final dynamic raw = data['rawData'];
if (raw == null) return false;
int? secondByte;
if (raw is List) {
if (raw.length >= 2) {
final s = raw[1];
if (s is int) {
secondByte = s;
} else if (s is num) {
secondByte = s.toInt();
} else if (s is String) {
final t = s.trim();
if (t.startsWith('0x') || t.startsWith('0X')) {
secondByte = int.tryParse(t.substring(2), radix: 16);
} else {
secondByte = int.tryParse(t);
}
}
}
} else if (raw is String) {
final normalized = raw.trim().replaceAll('[', '').replaceAll(']', '');
final parts =
normalized.split(RegExp(r'[,\s]+')).where((e) => e.isNotEmpty).toList();
if (parts.length >= 2) {
final t = parts[1].trim();
if (t.startsWith('0x') || t.startsWith('0X')) {
secondByte = int.tryParse(t.substring(2), radix: 16);
} else {
secondByte = int.tryParse(t);
}
}
} else if (raw is Map) {
final dynamic s = raw['second'] ?? raw['status2'] ?? raw['result'];
if (s is int) {
secondByte = s;
} else if (s is num) {
secondByte = s.toInt();
} else if (s is String) {
final t = s.trim();
if (t.startsWith('0x') || t.startsWith('0X')) {
secondByte = int.tryParse(t.substring(2), radix: 16);
} else {
secondByte = int.tryParse(t);
}
}
} else {
// 无法解析的类型
return false;
}
return secondByte != null && secondByte != 0;
}
/// 蓝牙设备信息缓存模型
class DeviceInfo {
final String address;
final String name;
// 整体电池电量
final int batteryLevel;
// 详细电池信息
final int leftEarBattery;
final int rightEarBattery;
final int caseBattery;
// 充电状态
final bool leftEarCharging;
final bool rightEarCharging;
final bool caseCharging;
final String firmwareVersion;
final String firmwareProductId;
final String firmwareProductColor;
final DateTime lastUpdated;
DeviceInfo({
required this.address,
required this.name,
this.batteryLevel = 0,
this.leftEarBattery = 0,
this.rightEarBattery = 0,
this.caseBattery = 0,
this.leftEarCharging = false,
this.rightEarCharging = false,
this.caseCharging = false,
this.firmwareVersion = '',
this.firmwareProductId = '',
this.firmwareProductColor = '',
DateTime? lastUpdated,
}) : lastUpdated = lastUpdated ?? DateTime.now();
/// 创建更新后的设备信息副本
DeviceInfo copyWith({
String? address,
String? name,
int? batteryLevel,
int? leftEarBattery,
int? rightEarBattery,
int? caseBattery,
bool? leftEarCharging,
bool? rightEarCharging,
bool? caseCharging,
String? firmwareVersion,
String? firmwareProductId,
String? firmwareProductColor,
}) {
return DeviceInfo(
address: address ?? this.address,
name: name ?? this.name,
batteryLevel: batteryLevel ?? this.batteryLevel,
leftEarBattery: leftEarBattery ?? this.leftEarBattery,
rightEarBattery: rightEarBattery ?? this.rightEarBattery,
caseBattery: caseBattery ?? this.caseBattery,
leftEarCharging: leftEarCharging ?? this.leftEarCharging,
rightEarCharging: rightEarCharging ?? this.rightEarCharging,
caseCharging: caseCharging ?? this.caseCharging,
firmwareVersion: firmwareVersion ?? this.firmwareVersion,
firmwareProductId: firmwareProductId ?? this.firmwareProductId,
firmwareProductColor: firmwareProductColor ?? this.firmwareProductColor,
lastUpdated: DateTime.now(),
);
}
@override
String toString() {
return 'DeviceInfo(address: $address, name: $name, '
'battery: $batteryLevel%, L: $leftEarBattery%, R: $rightEarBattery%, Case: $caseBattery%, '
'charging: L:$leftEarCharging, R:$rightEarCharging, C:$caseCharging, '
'version: $firmwareVersion)';
}
}
/// BLE管理器 - 专门处理BLE设备连接和信息管理
class BleManager extends GetxService {
static BleManager get to => Get.find<BleManager>();
// BLE服务实例
final BleService _bleService = BleService();
// 经典蓝牙实例
// 当前连接的设备信息
String? currentDeviceAddress;
String? _currentDeviceName;
// BLE连接状态
final _connectionState = BleConnectionState.disconnected.obs;
int get connectionState => _connectionState.value;
// 公开的连接状态流,供外部监听
RxInt get connectionStateRx => _connectionState;
// 连接状态监听
final _isCall = false.obs;
final _isConnected = false.obs;
bool get isConnected => _isConnected.value;
bool get isCall => _isCall.value;
// 设备信息缓存
final deviceInfo = Rx<DeviceInfo?>(null); // 使用 Rx 包装
//添加编码器状态跟踪
final _isCodecActive = false.obs;
bool get isCodecActive => _isCodecActive.value;
RxBool get isCodecActiveRx => _isCodecActive;
// 订阅
StreamSubscription<dynamic>? _statusSubscription;
StreamSubscription<dynamic>? _dataSubscription;
final GetStorage _storage = GetStorage();
/// 初始化
@override
void onInit() {
super.onInit();
Logger.info('BLE管理器初始化');
// 设置BLE事件监听
_setupBleListener();
}
/// 释放资源
@override
void onClose() {
_statusSubscription?.cancel();
_dataSubscription?.cancel();
super.onClose();
}
/// 设置BLE事件监听
void _setupBleListener() {
//Logger.info('lxm--_setupBleListener被调用,开始设置BLE事件监听');
_statusSubscription?.cancel();
_dataSubscription?.cancel();
try {
Logger.info('lxm--开始监听BLE状态更新流');
// 监听BLE状态更新
_statusSubscription = _bleService.onStatusUpdated.listen(
(event) {
Logger.info('lxm--收到BLE状态更新事件: $event');
if (event is Map) {
Logger.info('lxm--事件是Map类型,开始处理');
// 处理连接状态更新
if (event['type'] == 'connectionStateChanged') {
Logger.info('lxm--处理连接状态变化事件');
final state = event['state'] as int;
final oldState = _connectionState.value;
_connectionState.value = state;
Logger.d('BleManager', '🔄 BLE状态更新: $oldState → $state');
Logger.d('BleManager', '📡 通知监听器状态变化: ${_connectionState.value}');
// 连接状态转换
if (state == BleConnectionState.connected) {
Logger.info('lxm--BLE设备已连接');
_isConnected.value = true;
// 在连接成功后延迟 300 毫秒获取设备信息(可根据需要调整时间)
Future.delayed(const Duration(milliseconds: 300), () {
// 可选:检查是否仍处于连接状态
if (_isConnected.value) {
Logger.info('lxm--连接后延迟获取设备信息(当前被注释)');
// fetchDeviceInfo();
}
});
} else if (state == BleConnectionState.disconnected ||
state == BleConnectionState.error) {
Logger.info('lxm--BLE设备已断开或发生错误');
_isConnected.value = false;
// 更新设备信息Add commentMore actions
Logger.info('lxm--断开连接时重置设备信息为0');
_updateDeviceInfoIfNeeded(
batteryLevel: 0,
leftEarBattery: 0,
rightEarBattery: 0,
caseBattery: 0,
leftEarCharging: false,
rightEarCharging: false,
caseCharging: false,
firmwareVersion: '',
firmwareProductId: '',
firmwareProductColor: '',
);
// 断开连接时不清除设备信息,保留最后的电量信息
// 只有在需要完全清除设备时才重置信息
}
}
Logger.info('lxm--准备调用_processDeviceInfo处理设备信息');
// 处理设备信息
_processDeviceInfo(event);
} else {
Logger.info('lxm--事件不是Map类型: ${event.runtimeType}');
}
},
onError: (error) {
Logger.error('lxm--BLE状态事件流错误: $error');
},
);
Logger.info('lxm--BLE状态监听器设置完成');
// 监听BLE数据流
} catch (e) {
Logger.error('lxm--设置BLE事件监听器失败: ${e.toString()}');
}
}
/// 处理来自原生层的设备信息
void _processDeviceInfo(Map<dynamic, dynamic> event) {
try {
Logger.info('lxm--_processDeviceInfo被调用');
Logger.info('lxm--接收到的事件数据: $event');
// 检查是否是设备信息响应
if (event.containsKey('command') && event.containsKey('success')) {
Logger.info('lxm--事件包含command和success字段');
final bool success = event['success'] as bool;
Logger.info('lxm--命令执行成功状态: $success');
if (!success) {
Logger.warning('lxm--设备命令执行失败: ${event['command']}');
return;
}
// 根据命令类型处理不同信息
final command = event['command'];
Logger.info('lxm--命令类型: $command (${command.runtimeType})');
if (command is int) {
Logger.info('lxm--基于命令ID处理: $command');
// 基于命令ID处理
_processDeviceInfoByCommandId(command, event);
} else if (command is String) {
Logger.info('lxm--基于命令名称处理: $command');
// 基于命令名称处理
_processDeviceInfoByCommandName(command, event);
} else {
Logger.warning('lxm--未知的命令类型: ${command.runtimeType}');
}
} else {
Logger.info('lxm--事件不包含command或success字段,跳过处理');
Logger.info('lxm--事件包含的键: ${event.keys.toList()}');
}
} catch (e) {
Logger.error('lxm--处理设备信息异常: ${e.toString()}');
Logger.error('lxm--异常堆栈: ${StackTrace.current}');
}
}
/// 根据命令ID处理设备信息
void _processDeviceInfoByCommandId(
int commandId, Map<dynamic, dynamic> data) {
Logger.info('lxm--_processDeviceInfoByCommandId被调用,命令ID: $commandId');
Logger.info('lxm--命令数据: $data');
switch (commandId) {
case BleCommands.GET_VERSION:
Logger.info('lxm--处理版本信息命令');
_updateVersionInfoFromData(data);
break;
case BleCommands.GET_PRODUCT_ID:
Logger.info('lxm--处理产品ID命令');
_updateProductIdFromData(data);
break;
case BleCommands.GET_PRODUCT_COLOR:
Logger.info('lxm--处理产品颜色命令(暂未实现)');
break;
case BleCommands.GET_BATTERY_INFO:
Logger.info('lxm--处理电池信息命令,准备调用_updateBatteryInfoFromData');
_updateBatteryInfoFromData(data);
Logger.info('lxm--电池信息处理完成');
break;
case BleCommands.CONTROL_CODEC:
Logger.info('lxm--处理编解码控制命令');
// 处理通话状态
print(" CONTROL_CODEC: $commandId,$data");
final bool codecSuccess = _isCodecControlSuccess(data);
_isCodecActive.value = codecSuccess; // 更新编解码器状态
if (codecSuccess) {
print("lxm--编解码控制成功 (rawData 第二字节非 0)");
Logger.info('lxm--编解码控制成功 (rawData 第二字节非 0)');
} else {
print("lxm--编解码控制失败 (rawData 为 [162, 0] 或无法解析)");
Logger.warning('lxm--编解码控制失败 (rawData 为 [162, 0] 或无法解析)');
}
break;
default:
Logger.warning('lxm--未处理的命令ID: $commandId,数据: $data');
print(" 未处理的命令ID: $commandId,$data");
}
}
/// 根据命令名称处理设备信息
void _processDeviceInfoByCommandName(
String commandName, Map<dynamic, dynamic> data) {
switch (commandName) {
case 'batteryInfo':
_updateBatteryInfoFromData(data);
break;
case 'versionInfo':
_updateVersionInfoFromData(data);
break;
case 'productId':
_updateProductIdFromData(data);
break;
case 'productColor':
break;
case 'Error':
print(" Error: $commandName,$data");
break;
default:
print(" 未处理的命令名称: $commandName,$data");
Logger.info('未处理的命令名称: $commandName');
}
}
/// 更新电池信息
void _updateBatteryInfoFromData(Map<dynamic, dynamic> data) {
try {
Logger.info('lxm--_updateBatteryInfoFromData被调用');
Logger.info('lxm--接收到的原始数据: $data');
// 确保数据中包含电池信息
if (!data.containsKey('leftEarBattery') ||
!data.containsKey('rightEarBattery') ||
!data.containsKey('caseBattery')) {
Logger.warning('lxm--电池信息数据不完整,缺少必要字段');
Logger.warning('lxm--数据包含的键: ${data.keys.toList()}');
return;
}
Logger.info('lxm--原始电池数据解析:');
Logger.info(
'lxm-- leftEarBattery原始值: ${data['leftEarBattery']} (类型: ${data['leftEarBattery'].runtimeType})');
Logger.info(
'lxm-- rightEarBattery原始值: ${data['rightEarBattery']} (类型: ${data['rightEarBattery'].runtimeType})');
Logger.info(
'lxm-- caseBattery原始值: ${data['caseBattery']} (类型: ${data['caseBattery'].runtimeType})');
Logger.info(
'lxm-- leftEarCharging原始值: ${data['leftEarCharging']} (类型: ${data['leftEarCharging'].runtimeType})');
Logger.info(
'lxm-- rightEarCharging原始值: ${data['rightEarCharging']} (类型: ${data['rightEarCharging'].runtimeType})');
Logger.info(
'lxm-- caseCharging原始值: ${data['caseCharging']} (类型: ${data['caseCharging'].runtimeType})');
Logger.info(
'lxm-- batteryLevel原始值: ${data['batteryLevel']} (类型: ${data['batteryLevel']?.runtimeType})');
// 提取电池信息
final int leftBattery = (data['leftEarBattery'] as int? ?? 0) == 127
? -1 // 特殊值127转换为-1
: (data['leftEarBattery'] as int? ?? 0) > 100
? 0 // 大于100的值重置为0
: (data['leftEarBattery'] as int? ?? 0); // 正常值
final int rightBattery = (data['rightEarBattery'] as int? ?? 0) == 127
? -1 // 特殊值127转换为-1
: (data['rightEarBattery'] as int? ?? 0) > 100
? 0 // 大于100的值重置为0
: (data['rightEarBattery'] as int? ?? 0); // 正常值
final int caseBattery = (data['caseBattery'] as int? ?? 0) == 127
? -1 // 特殊值127转换为-1
: (data['caseBattery'] as int? ?? 0) > 100
? 0 // 大于100的值重置为0
: (data['caseBattery'] as int? ?? 0); // 正常值
final bool leftCharging = data['leftEarCharging'] as bool? ?? false;
final bool rightCharging = data['rightEarCharging'] as bool? ?? false;
final bool caseCharging = data['caseCharging'] as bool? ?? false;
// 获取整体电量(原生层使用左耳电量作为主要指示)
final int overallBattery = data['batteryLevel'] as int? ?? leftBattery;
Logger.info('lxm--处理后的电池数据:');
Logger.info('lxm-- leftBattery: $leftBattery');
Logger.info('lxm-- rightBattery: $rightBattery');
Logger.info('lxm-- caseBattery: $caseBattery');
Logger.info('lxm-- leftCharging: $leftCharging');
Logger.info('lxm-- rightCharging: $rightCharging');
Logger.info('lxm-- caseCharging: $caseCharging');
Logger.info('lxm-- overallBattery: $overallBattery');
Logger.info('lxm--准备调用_updateDeviceInfoIfNeeded');
// 更新设备信息
_updateDeviceInfoIfNeeded(
batteryLevel: overallBattery,
leftEarBattery: leftBattery,
rightEarBattery: rightBattery,
caseBattery: caseBattery,
leftEarCharging: leftCharging,
rightEarCharging: rightCharging,
caseCharging: caseCharging,
);
Logger.info(
'lxm--设备电池信息已更新: 电量=$overallBattery%, 左耳=$leftBattery%, 右耳=$rightBattery%, 充电仓=$caseBattery%');
} catch (e) {
Logger.error('lxm--更新电池信息失败: ${e.toString()}');
Logger.error('lxm--错误堆栈: ${StackTrace.current}');
}
}
/// 更新版本信息
void _updateVersionInfoFromData(Map<dynamic, dynamic> data) {
try {
// 确保数据中包含版本信息
if (!data.containsKey('version')) {
Logger.warning('版本信息数据不完整');
return;
}
// 提取版本信息
final String version = data['version'] as String? ?? '';
// 更新设备信息
_updateDeviceInfoIfNeeded(
firmwareVersion: version,
);
Logger.info('设备版本信息已更新: 版本=$version');
} catch (e) {
Logger.error('更新版本信息失败: ${e.toString()}');
}
}
/// 更新设备id
void _updateProductIdFromData(Map<dynamic, dynamic> data) {
try {
// 确保数据中包含版本信息
if (!data.containsKey('productId')) {
Logger.warning('版本信息数据不完整');
return;
}
// 提取版本信息
final String productId = data['productId'] as String? ?? '';
// 更新设备信息
_updateDeviceInfoIfNeeded(
firmwareProductId: productId,
);
Logger.info('设备设备id已更新: 设备id=$productId');
} catch (e) {
Logger.error('更新设备id失败: ${e.toString()}');
}
}
/// 更新设备信息(如果已存在设备)
void _updateDeviceInfoIfNeeded({
int? batteryLevel,
int? leftEarBattery,
int? rightEarBattery,
int? caseBattery,
bool? leftEarCharging,
bool? rightEarCharging,
bool? caseCharging,
String? firmwareVersion,
String? firmwareProductId,
String? firmwareProductColor,
}) {
Logger.info('lxm--_updateDeviceInfoIfNeeded被调用');
Logger.info(
'lxm--传入参数: batteryLevel=$batteryLevel, leftEarBattery=$leftEarBattery, rightEarBattery=$rightEarBattery, caseBattery=$caseBattery');
Logger.info(
'lxm--充电状态: leftEarCharging=$leftEarCharging, rightEarCharging=$rightEarCharging, caseCharging=$caseCharging');
Logger.info('lxm--当前deviceInfo.value是否为null: ${deviceInfo.value == null}');
// 如果设备信息已存在,则更新
if (deviceInfo.value != null) {
Logger.info('lxm--设备信息已存在,进行更新操作');
Logger.info('lxm--更新前的设备信息: ${deviceInfo.value}');
deviceInfo.value = deviceInfo.value!.copyWith(
batteryLevel: batteryLevel ?? deviceInfo.value?.batteryLevel,
leftEarBattery: _getValidBatteryValue(
leftEarBattery, deviceInfo.value?.leftEarBattery),
rightEarBattery: _getValidBatteryValue(
rightEarBattery, deviceInfo.value?.rightEarBattery),
caseBattery: caseBattery ?? deviceInfo.value?.caseBattery,
leftEarCharging: leftEarCharging ?? deviceInfo.value!.leftEarCharging,
rightEarCharging:
rightEarCharging ?? deviceInfo.value!.rightEarCharging,
caseCharging: caseCharging ?? deviceInfo.value!.caseCharging,
firmwareVersion: firmwareVersion ?? deviceInfo.value!.firmwareVersion,
firmwareProductId:
firmwareProductId ?? deviceInfo.value!.firmwareProductId,
firmwareProductColor:
firmwareProductColor ?? deviceInfo.value!.firmwareProductColor,
);
Logger.info('lxm--更新后的设备信息: ${deviceInfo.value}');
}
// 创建设备信息
// 如果设备信息不存在,但有地址和名称,则创建新的设备信息
else if (deviceInfo.value == null &&
_isConnected.value &&
(firmwareVersion != null || batteryLevel != null)) {
Logger.info('lxm--设备信息不存在,创建新的设备信息对象');
// 使用保存的设备信息创建新的DeviceInfo对象
String deviceAddress = currentDeviceAddress ?? "";
String deviceName = _currentDeviceName ?? "";
Logger.info('lxm--创建新的设备信息对象: address=$deviceAddress, name=$deviceName');
deviceInfo.value = DeviceInfo(
address: deviceAddress,
name: deviceName,
batteryLevel: batteryLevel ?? 0,
leftEarBattery: leftEarBattery ?? 0,
rightEarBattery: rightEarBattery ?? 0,
caseBattery: caseBattery ?? 0,
leftEarCharging: leftEarCharging ?? false,
rightEarCharging: rightEarCharging ?? false,
caseCharging: caseCharging ?? false,
firmwareVersion: firmwareVersion ?? '',
firmwareProductId: firmwareProductId ?? '',
firmwareProductColor: firmwareProductColor ?? '',
);
Logger.info('lxm--新创建的设备信息: ${deviceInfo.value}');
} else {
Logger.info(
'lxm--不满足更新条件: deviceInfo.value == null: ${deviceInfo.value == null}, _isConnected.value: ${_isConnected.value}, firmwareVersion: $firmwareVersion, batteryLevel: $batteryLevel');
}
}
// 新增智能电池值选择方法
int? _getValidBatteryValue(int? newValue, int? currentValue) {
// 如果新值为null,使用当前值
if (newValue == null) return currentValue;
// 如果当前值为null或0,使用新值(即使新值为0)
if (currentValue == null || currentValue == 0) return newValue;
// 如果新值为0但当前值不为0,保持当前值(避免有效数据被0覆盖)
if (newValue == 0 && currentValue > 0) {
Logger.warning('检测到电池数据异常(新值为0),保持当前值: $currentValue');
return currentValue;
}
// 其他情况使用新值
return newValue;
}
/// 清除设备信息(用于完全断开连接或切换设备时)
void clearDeviceInfo() {
Logger.info('清除设备信息');
deviceInfo.value = null;
currentDeviceAddress = null;
_currentDeviceName = null;
}
/// 连接成功后获取设备信息
Future<void> fetchDeviceInfo() async {
Logger.info('开始获取BLE设备详细信息');
try {
// 确保设备信息对象存在
if (deviceInfo.value == null && _isConnected.value) {
// 创建初始设备信息对象
String deviceAddress = currentDeviceAddress ?? "";
String deviceName = _currentDeviceName ?? "";
Logger.info('初始化设备信息对象: address=$deviceAddress, name=$deviceName');
deviceInfo.value = DeviceInfo(
address: deviceAddress,
name: deviceName,
batteryLevel: 0,
leftEarBattery: 0,
rightEarBattery: 0,
caseBattery: 0,
leftEarCharging: false,
rightEarCharging: false,
caseCharging: false,
firmwareVersion: '',
firmwareProductId: '',
firmwareProductColor: '',
);
}
// 并行获取所有设备信息,不使用延迟
final results = await Future.wait([
_bleService.getBatteryInfo(),
_bleService.getDeviceVersion(),
_bleService.getProductId(),
]);
Logger.info(
'设备信息获取结果: 电池=${results[0]}, 版本=${results[1]}, 产品ID=${results[2]}');
if (!results[0]) {
Logger.warning('电池信息获取指令发送失败');
}
if (!results[1]) {
Logger.warning('版本信息获取指令发送失败');
}
if (!results[2]) {
Logger.warning('产品ID获取指令发送失败');
}
} catch (e) {
Logger.error('获取BLE设备信息失败: ${e.toString()}');
}
}
/// 检查BLE连接状态
Future<int> getConnectionState() async {
try {
final isConnected = await _bleService.isConnected();
_connectionState.value = isConnected
? BleConnectionState.connected
: BleConnectionState.disconnected;
_isConnected.value = isConnected;
return _connectionState.value;
} catch (e) {
Logger.error('获取BLE连接状态失败: ${e.toString()}');
return BleConnectionState.error;
}
}
String getDeviceName() {
if (deviceInfo.value != null) {
return deviceInfo.value!.name;
}
return "";
}
// 加载TTS偏好设置
Future<bool> _loadTtsInterrupe() async {
try {
if (!_storage.hasData("agent_tts_interrupt")) {
// 获取设备类型以确定检查策略
String deviceName = getDeviceName();
DBProduct? product = AppConfig.getproduct(deviceName);
if (deviceName != "" && product != null) {
// Logger.d('AgentController',
// 'liwe----------product $deviceName ${product.toJson()}');
return !product.iscontinuouschat!;
} else {
return false;
}
} else {
return _storage.read('agent_tts_interrupt') ?? false;
}
} catch (e) {
return false;
}
}
/// 启动BLE服务
Future<bool> startAgentService() async {
try {
// 从.env文件直接读取环境变量
var serverurl = DioManager().baseUrl;
var jsonString = _storage.read<String>("logintoken");
final azureSpeechKey = AppConfig.env('AZURE_SPEECH_KEY') ?? '';
final azureSpeechRegion =
AppConfig.env('AZURE_SPEECH_REGION') ?? 'eastasia';
final openaiApiKey = AppConfig.env('OPENAI_API_KEY') ?? '';
final openaiBaseUrl =
AppConfig.env('OPENAI_BASE_URL') ?? 'https://api.openai.com/v1';
final openaiModel = AppConfig.env('OPENAI_MODEL') ?? 'gpt-3.5-turbo';
final openaiModelMedia = AppConfig.env('OPENAI_API_VISION_MODEL') ??
'doubao-1-5-vision-pro-32k-250115';
final openaiagentid =
AppConfig.env('OPENAI_AGENT_ID') ?? 'personal_assistant';
final systemPrompt = AppConfig.agentsystemPrompt(openaiagentid);
var musicServiceType =
AppConfig.env('APP_ANDROID_MUSICSERVICE_TYPE') ?? 'AUTO';
if (Platform.isIOS) {
musicServiceType = AppConfig.env('APP_IOS_MUSICSERVICE_TYPE') ?? 'AUTO';
}
final navigationMode =
AppConfig.env('APP_NAVIGATION_MODE') ?? 'external_auto';
// 从Flutter资源包中加载.mcp.json
final jsonData = AppConfig.mcpConfig();
Logger.info('启动BLE服务,musicServiceType: ${musicServiceType}');
final isTtsInterruptEnabled = await _loadTtsInterrupe();
final vipExpiryTime = userInfo.User.instance.vipexptime;
Logger.info('liwei------ vipexptime 1: $vipExpiryTime');
// 根据APP语言动态配置语音识别语言
List<String> supportedLanguages = [];
try {
final storage = GetStorage();
final languageManager = Get.find<LanguageManager>();
// 从存储中读取用户设置的语言
String? savedLanguage = storage.read('language');
if (savedLanguage != null && savedLanguage != 'system') {
// 用户设置了特定语言
final parts = savedLanguage.split('_');
if (parts.length == 2) {
final asrCode = languageManager.getAsrCodeByShortCode(parts[0]);
if (asrCode != null) {
supportedLanguages.add(asrCode);
} else {
// 直接使用语言-国家格式
supportedLanguages.add('${parts[0]}-${parts[1]}');
}
}
} else {
// 跟随系统语言或未设置
final appLocale = Get.locale;
if (appLocale != null) {
final lang = appLocale.languageCode;
final country = appLocale.countryCode;
// 尝试从语言管理器获取对应的ASR代码
final asrCode = languageManager.getAsrCodeByShortCode(lang);
if (asrCode != null) {
supportedLanguages.add(asrCode);
} else if (country != null && country.isNotEmpty) {
// 构造 Azure SDK 需要的格式 (e.g., 'en-US')
supportedLanguages.add('$lang-$country');
} else {
supportedLanguages.add('en-US'); // 默认英语
}
}
}
// 最终兜底
if (supportedLanguages.isEmpty) {
supportedLanguages.add('en-US');
}
// Logger.info('动态配置语音识别语言: ${supportedLanguages.join(', ')}');
} catch (e) {
Logger.error('获取APP语言配置失败,使用默认语言: $e');
supportedLanguages = ['zh-CN', 'en-US'];
}
final config = <String, dynamic>{
// 语音代理配置参数
'azureSpeechKey': azureSpeechKey,
'azureSpeechRegion': azureSpeechRegion,
'openaiApiKey': openaiApiKey,
'openaiBaseUrl': openaiBaseUrl,
'openaiModel': openaiModel,
'openaivisionModel': openaiModelMedia,
'systemPrompt': systemPrompt,
'mcpServer': jsonEncode(jsonData),
'volcanoAppId': '2316081933',
'volcanoToken': 'mcJTh6OelBqU_L78lgGd77Nyrc_-5-En',
'serverurl': serverurl,
'usertoken': jsonString,
'supportedLanguages': supportedLanguages,
'musicServiceType': musicServiceType,
"navigationMode": navigationMode,
"isttsinterrupt": isTtsInterruptEnabled ? "true" : "false",
"vipexptime": vipExpiryTime, //会员过期时间
"callingToolText": "callingTool".tr,
"insufficientIntegralText": "insufficientIntegral".tr,
};
// 记录日志(不记录敏感信息)
Logger.info('启动BLE服务,配置参数键名: ${config}');
if (azureSpeechKey.isEmpty || openaiApiKey.isEmpty) {
Logger.warning('缺少必要的API密钥,请检查.env文件配置');
// 检查.env中相关密钥是否存在
if (azureSpeechKey.isEmpty) {
Logger.warning('AZURE_SPEECH_KEY未配置在.env文件中');
}
if (openaiApiKey.isEmpty) {
Logger.warning('OPENAI_API_KEY未配置在.env文件中');
}
}
Logger.info('lxm--准备调用AgentService.startAgentService启动BLE服务');
final result = await AgentService.startAgentService(config);
Logger.info('lxm--AgentService.startAgentService调用结果: $result');
if (result) {
Logger.info('lxm--BLE服务启动成功');
// 添加延迟以等待设备连接
Logger.info('lxm--等待2秒让设备连接');
//await Future.delayed(const Duration(seconds: 2));
// 检查连接状态
Logger.info('lxm--检查设备连接状态');
final isConnected = await _bleService.isConnected();
Logger.info('lxm--设备连接状态检查结果: $isConnected');
if (isConnected) {
Logger.info('lxm--设备已连接,更新连接状态');
_isConnected.value = true;
_connectionState.value = BleConnectionState.connected;
// 如果设备信息存在,则获取详细信息
Logger.info('lxm--准备获取设备详细信息');
if (deviceInfo.value != null) {
// 获取详细设备信息
// fetchDeviceInfo();
}
}
} else {
Logger.error('BLE服务启动失败');
}
return result;
} catch (e) {
Logger.error('启动BLE服务失败: ${e.toString()}');
return false;
}
}
/// 停止BLE服务
Future<bool> stopAgentService() async {
try {
final result = await AgentService.stopAgentService();
if (result) {
Logger.info('BLE服务停止成功');
_isConnected.value = false;
_connectionState.value = BleConnectionState.disconnected;
// 停止服务时清除设备信息
clearDeviceInfo();
} else {
Logger.error('BLE服务停止失败');
}
return result;
} catch (e) {
Logger.error('停止BLE服务失败: ${e.toString()}');
return false;
}
}
/// 获取电池电量
Future<int> getBatteryLevel() async {
try {
return await _bleService.getBatteryLevel();
} catch (e) {
Logger.error('获取电池电量失败: ${e.toString()}');
return 0;
}
}
/// 主动获取电池信息
Future<bool> fetchBatteryInfo() async {
try {
//Logger.info('lxm--fetchBatteryInfo被调用,准备向设备发送获取电池信息指令');
final result = await _bleService.getBatteryInfo();
//Logger.info('lxm--getBatteryInfo指令发送结果: $result');
return result;
} catch (e) {
//Logger.error('lxm--获取电池信息失败: ${e.toString()}');
return false;
}
}
/// 主动产品id
Future<bool> getProductId() async {
try {
return await _bleService.getProductId();
} catch (e) {
Logger.error('获取设备版本失败: ${e.toString()}');
return false;
}
}
/// 主动获取设备版本信息
Future<bool> fetchDeviceVersion() async {
try {
return await _bleService.getDeviceVersion();
} catch (e) {
Logger.error('获取设备版本失败: ${e.toString()}');
return false;
}
}
/// 打开编码器
Future<bool> openEncoder() async {
try {
return await _bleService.openEncoder();
} catch (e) {
Logger.error('打开编码器失败: ${e.toString()}');
return false;
}
}
/// 打开解码器
Future<bool> openDecoder() async {
try {
return await _bleService.openDecoder();
} catch (e) {
Logger.error('打开解码器失败: ${e.toString()}');
return false;
}
}
/// 打开解码器
Future<bool> openA2DPDecoder() async {
try {
return await _bleService.openA2DPDecoder();
} catch (e) {
Logger.error('打开解码器失败: ${e.toString()}');
return false;
}
}
/// 打开解码器
Future<bool> openCallRecordDecoder() async {
try {
return await _bleService.openCallRecordDecoder();
} catch (e) {
Logger.error('打开解码器失败: ${e.toString()}');
return false;
}
}
/// 关闭编解码器
Future<bool> closeCodec() async {
try {
return await _bleService.closeCodec();
} catch (e) {
Logger.error('关闭编解码器失败: ${e.toString()}');
return false;
}
}
/// 播放A2DP
Future<bool> playA2DP() async {
try {
return await _bleService.playA2DP();
} catch (e) {
Logger.error('播放A2DP失败: ${e.toString()}');
return false;
}
}
// ==================== 配对相关方法 ====================
/// 检查设备是否支持Companion Device Manager
Future<bool> isCompanionSupported() async {
try {
return await _bleService.isCompanionSupported();
} catch (e) {
Logger.error('检查Companion支持失败: ${e.toString()}');
return false;
}
}
/// 获取已配对的MAC地址
Future<String?> getPairedMacAddress() async {
try {
return await _bleService.getPairedMacAddress();
} catch (e) {
Logger.error('获取已配对MAC地址失败: ${e.toString()}');
return null;
}
}
/// 检查BLE连接状态
Future<bool> isBleConnected() async {
try {
return await _bleService.isBleConnected();
} catch (e) {
Logger.error('检查BLE连接状态失败: ${e.toString()}');
return false;
}
}
/// 设置是否是ota模式
Future<void> setEnterOta(bool enterOta) async {
try {
await _bleService.setEnterOta(enterOta);
} catch (e) {
Logger.error('设置是否是ota模式失败: ${e.toString()}');
}
}
/// 断开连接
Future<void> disconnect() async {
try {
await _bleService.disconnect();
} catch (e) {
Logger.error('断开连接失败: ${e.toString()}');
}
}
/// 验证设备是否可以配对
Future<void> startScan(List<String> uuids) async {
try {
await _bleService.startScan(uuids);
} catch (e) {
Logger.error('开始扫描设备: ${e.toString()}');
}
}
/// 验证设备是否可以配对
Future<void> stopScan() async {
try {
await _bleService.stopScan();
} catch (e) {
Logger.error('停止扫描设备: ${e.toString()}');
}
}
Future<Map<String, String>?> getDeviceInfo(String deviceName) async {
try {
final result = _bleService.getDeviceInfo(deviceName);
return result;
} catch (e) {
Logger.error('获取设备信息: ${e.toString()}');
return null;
}
}
Future<List<Map<String, String>>?> getDeviceList(String deviceName) async {
try {
final result = _bleService.getDeviceList(deviceName);
return result;
} catch (e) {
Logger.error('获取设备信息: ${e.toString()}');
return null;
}
}
/// 验证设备是否可以配对
Future<bool> verifyDeviceCanPair(String macAddress) async {
try {
return true;
} catch (e) {
Logger.error('验证设备配对失败: ${e.toString()}');
return false;
}
}
/// 启动设备关联
Future<bool> startDeviceAssociation({
required String deviceNamePattern,
required String macAddress,
}) async {
try {
return await _bleService.startDeviceAssociation(
deviceNamePattern: deviceNamePattern,
macAddress: macAddress,
);
} catch (e) {
Logger.error('启动设备关联失败: ${e.toString()}');
return false;
}
}
/// 启动设备关联
Future<void> connect() async {
try {
await _bleService.connect();
} catch (e) {
Logger.error('连接设备失败: ${e.toString()}');
}
}
/// 注册后台扫描
Future<bool> registerBackgroundScan({
String? macAddress,
List<String>? uuids,
}) async {
try {
// 在注册新设备前先清除旧设备信息
if (macAddress != null && macAddress != currentDeviceAddress) {
clearDeviceInfo(); // 清除上一个设备的信息
}
// 保存设备地址信息
if (macAddress != null) {
currentDeviceAddress = macAddress;
// 从蓝牙管理器获取设备名称
final bluetoothManager = Get.find<BluetoothManager>();
_currentDeviceName = bluetoothManager.currentDevice?.name ?? "";
Logger.info(
'保存设备信息: address=$currentDeviceAddress, name=$_currentDeviceName');
}
return await _bleService.registerBackgroundScan(
macAddress: macAddress,
uuids: uuids,
);
} catch (e) {
Logger.error('注册后台扫描失败: ${e.toString()}');
return false;
}
}
/// 注销后台扫描
Future<bool> unregisterBackgroundScan() async {
try {
return await _bleService.unregisterBackgroundScan();
} catch (e) {
Logger.error('注销后台扫描失败: ${e.toString()}');
return false;
}
}
/// 清除BLE配对设备
Future<bool> clearPairedDevices() async {
try {
return await _bleService.clearAssociations();
} catch (e) {
Logger.error('清除BLE配对设备失败: ${e.toString()}');
return false;
}
}
/// 注册服务
static Future<BleManager> init() async {
if (!Get.isRegistered<BleManager>()) {
Get.put(BleManager(), permanent: true);
}
return Future.value(Get.find<BleManager>());
}
/// 请求蓝牙权限
Future<bool> requestBluetoothPermission() async {
try {
return await _bleService.requestBluetoothPermission();
} catch (e) {
Logger.error('请求蓝牙权限失败: ${e.toString()}');
return false;
}
}
}