15 changed files with 1854 additions and 429 deletions
@ -0,0 +1,245 @@ |
|||
import 'package:flutter/material.dart'; |
|||
import 'package:get/get.dart'; |
|||
import 'package:logger/web.dart'; |
|||
import '../../../data/services/ble_manager.dart'; |
|||
import '../../../data/models/appconfig.dart'; |
|||
import '../../../data/models/appconfig_model.dart'; |
|||
|
|||
/// OTA核心服务 |
|||
/// 整合设备检查、版本管理和状态管理功能 |
|||
class OtaCoreService { |
|||
final BleManager _bleManager = Get.find<BleManager>(); |
|||
final int maxRetryAttempts = 3; |
|||
int currentRetryCount = 0; |
|||
|
|||
// ==================== 状态常量定义 ==================== |
|||
static const int NOT_STARTED = -1; // 未开始 |
|||
static const int VALIDATION_FILE = 0; // 验证文件 |
|||
static const int ONUPGRADE = 1; // 升级中 |
|||
static const int START_UPGRADING = 2; // 开始升级 |
|||
static const int UPGRADE_SUCCESS = 3; // 升级成功 |
|||
static const int UPGRADE_FAILED = 4; // 升级失败 |
|||
static const int CONNECTION_DISCONNECTION = 5; // 连接断开 |
|||
static const int CONNECTION_SUCCESS = 6; // 连接成功 |
|||
static const int DOWNLOADING_UP_FILES = 7; // 下载升级文件 |
|||
|
|||
/// 获取状态描述信息 |
|||
/// [type] 状态类型 |
|||
/// 返回对应的状态描述文本 |
|||
static String getStatusMessage(int type) { |
|||
switch (type) { |
|||
case NOT_STARTED: |
|||
return "未开始".tr; |
|||
case VALIDATION_FILE: |
|||
return "验证文件中".tr; |
|||
case ONUPGRADE: |
|||
return "升级中".tr; |
|||
case START_UPGRADING: |
|||
return "开始升级".tr; |
|||
case UPGRADE_SUCCESS: |
|||
return "升级成功".tr; |
|||
case UPGRADE_FAILED: |
|||
return "升级失败".tr; |
|||
case CONNECTION_DISCONNECTION: |
|||
return "连接断开".tr; |
|||
case CONNECTION_SUCCESS: |
|||
return "连接成功".tr; |
|||
case DOWNLOADING_UP_FILES: |
|||
return "下载升级文件".tr; |
|||
default: |
|||
return "未知状态".tr; |
|||
} |
|||
} |
|||
|
|||
// ==================== 设备检查功能 ==================== |
|||
|
|||
/// 检查设备电量是否满足升级条件 |
|||
/// 返回true表示电量充足，可以进行升级 |
|||
/// 返回false表示电量不足，不能进行升级 |
|||
bool checkBatteryLevel() { |
|||
try { |
|||
final deviceInfo = _bleManager.deviceInfo.value; |
|||
|
|||
if (deviceInfo == null) { |
|||
_showBatteryCheckFailedSnackbar('无法获取设备信息，请检查设备连接'); |
|||
return false; |
|||
} |
|||
|
|||
final leftBattery = deviceInfo.leftEarBattery; |
|||
final rightBattery = deviceInfo.rightEarBattery; |
|||
|
|||
// 检查左右耳电量是否都大于30% |
|||
if (leftBattery <= 30 || rightBattery <= 30) { |
|||
_showLowBatteryDialog(leftBattery, rightBattery); |
|||
return false; |
|||
} |
|||
|
|||
return true; |
|||
} catch (e) { |
|||
_showBatteryCheckFailedSnackbar('检查设备电量时发生错误：$e'); |
|||
return false; |
|||
} |
|||
} |
|||
|
|||
/// 显示电量不足对话框 |
|||
/// [leftBattery] 左耳电量 |
|||
/// [rightBattery] 右耳电量 |
|||
void _showLowBatteryDialog(int leftBattery, int rightBattery) { |
|||
String message = '设备电量不足，无法进行固件升级\n'; |
|||
message += '升级要求：左右耳电量均需大于30%\n'; |
|||
message += '当前电量：左耳 ${leftBattery}%，右耳 ${rightBattery}%\n'; |
|||
message += '请充电后再试'; |
|||
|
|||
Get.dialog( |
|||
AlertDialog( |
|||
title: Text( |
|||
'电量不足', |
|||
style: TextStyle( |
|||
color: Colors.orange[700], |
|||
fontWeight: FontWeight.w600, |
|||
), |
|||
), |
|||
content: Text( |
|||
message, |
|||
style: TextStyle( |
|||
color: Colors.orange[600], |
|||
), |
|||
), |
|||
actions: [ |
|||
TextButton( |
|||
onPressed: () => Get.back(), |
|||
style: TextButton.styleFrom( |
|||
foregroundColor: Colors.orange[700], |
|||
), |
|||
child: const Text('确定'), |
|||
), |
|||
], |
|||
shape: RoundedRectangleBorder( |
|||
borderRadius: BorderRadius.circular(12), |
|||
side: BorderSide( |
|||
color: Colors.orange.withValues(alpha: 0.3), |
|||
width: 1, |
|||
), |
|||
), |
|||
backgroundColor: Colors.orange[50], |
|||
), |
|||
); |
|||
} |
|||
|
|||
/// 显示电量检查失败提示 |
|||
/// [message] 错误信息 |
|||
void _showBatteryCheckFailedSnackbar(String message) { |
|||
Get.snackbar( |
|||
'电量检查失败', |
|||
message, |
|||
snackPosition: SnackPosition.BOTTOM, |
|||
backgroundColor: Colors.orange[600], |
|||
colorText: Colors.white, |
|||
icon: const Icon( |
|||
Icons.warning_amber, |
|||
color: Colors.white, |
|||
), |
|||
); |
|||
} |
|||
|
|||
// ==================== 版本管理功能 ==================== |
|||
|
|||
/// 获取当前设备版本信息 |
|||
/// 返回包含当前版本、产品ID和设备信息的Map |
|||
/// 抛出异常如果获取失败 |
|||
Future<Map<String, dynamic>> getCurrentVersionInfo() async { |
|||
DeviceInfo? deviceInfo = _bleManager.deviceInfo.value; |
|||
|
|||
// 重试机制获取设备信息 |
|||
while (currentRetryCount < maxRetryAttempts) { |
|||
deviceInfo = _bleManager.deviceInfo.value; |
|||
|
|||
if (deviceInfo != null && |
|||
deviceInfo.firmwareVersion.isNotEmpty && |
|||
deviceInfo.firmwareProductId.isNotEmpty) { |
|||
break; |
|||
} |
|||
|
|||
await _bleManager.fetchDeviceInfo(); |
|||
await Future.delayed(const Duration(seconds: 5)); |
|||
currentRetryCount++; |
|||
} |
|||
|
|||
if (deviceInfo == null || |
|||
deviceInfo.firmwareVersion.isEmpty || |
|||
deviceInfo.firmwareProductId.isEmpty) { |
|||
throw "获取设备信息失败，请检查连接"; |
|||
} |
|||
|
|||
// 验证固件版本格式 |
|||
final firmwareParts = deviceInfo.firmwareVersion.split('.'); |
|||
final firstPart = firmwareParts.sublist(0, 3).join('.'); |
|||
final secondPart = firmwareParts.sublist(3).join('.'); |
|||
|
|||
Logger().d("firstPart: $firstPart, secondPart: $secondPart"); |
|||
|
|||
if (firstPart != secondPart) { |
|||
throw "固件版本格式错误：${deviceInfo.firmwareVersion}"; |
|||
} |
|||
|
|||
return { |
|||
'currentVersion': firstPart, |
|||
'productId': deviceInfo.firmwareProductId, |
|||
'deviceInfo': deviceInfo, |
|||
}; |
|||
} |
|||
|
|||
/// 获取最新版本信息 |
|||
/// 返回包含最新版本、更新描述和更新包地址的Map |
|||
/// 抛出异常如果获取失败 |
|||
Future<Map<String, dynamic>> getLatestVersionInfo() async { |
|||
DBProduct? product = AppConfig.getproduct("DeapSound"); |
|||
|
|||
if (product == null) { |
|||
throw "无法获取产品信息"; |
|||
} |
|||
|
|||
return { |
|||
'latestVersion': product.version ?? "", |
|||
'updateDescription': product.updatedescription ?? "", |
|||
'updatePackageAddress': product.updatepackageaddress ?? "", |
|||
}; |
|||
} |
|||
|
|||
/// 比较版本号，判断是否有新版本可用 |
|||
/// [currentVersion] 当前版本号 |
|||
/// [latestVersion] 最新版本号 |
|||
/// 返回true表示有新版本可用（支持升级和降级） |
|||
bool isNewVersionAvailable(String currentVersion, String latestVersion) { |
|||
try { |
|||
List<int> currentParts = |
|||
currentVersion.split('.').map((e) => int.parse(e.trim())).toList(); |
|||
List<int> latestParts = |
|||
latestVersion.split('.').map((e) => int.parse(e.trim())).toList(); |
|||
|
|||
// 确保两个版本号长度一致，短的用0补齐 |
|||
int maxLength = currentParts.length > latestParts.length |
|||
? currentParts.length |
|||
: latestParts.length; |
|||
|
|||
while (currentParts.length < maxLength) { |
|||
currentParts.add(0); |
|||
} |
|||
while (latestParts.length < maxLength) { |
|||
latestParts.add(0); |
|||
} |
|||
|
|||
// 比较每一段，只要有不同就返回true（支持升级和降级） |
|||
for (int i = 0; i < maxLength; i++) { |
|||
if (latestParts[i] != currentParts[i]) { |
|||
return true; |
|||
} |
|||
} |
|||
|
|||
return false; |
|||
} catch (e) { |
|||
Logger().d('版本比较错误: $e'); |
|||
return false; |
|||
} |
|||
} |
|||
} |
|||
@ -1,99 +0,0 @@ |
|||
import 'package:flutter/material.dart'; |
|||
import 'package:get/get.dart'; |
|||
import 'package:flutter_screenutil/flutter_screenutil.dart'; |
|||
import '../../../data/services/ble_manager.dart'; |
|||
|
|||
/// 设备检查服务 |
|||
/// 负责检查设备状态，如电量检查等 |
|||
class DeviceChecker { |
|||
final BleManager _bleManager = Get.find<BleManager>(); |
|||
|
|||
/// 检查设备电量是否满足升级条件 |
|||
/// 返回true表示电量充足，可以进行升级 |
|||
/// 返回false表示电量不足，不能进行升级 |
|||
bool checkBatteryLevel() { |
|||
try { |
|||
final deviceInfo = _bleManager.deviceInfo.value; |
|||
|
|||
if (deviceInfo == null) { |
|||
_showBatteryCheckFailedSnackbar('无法获取设备信息，请检查设备连接'); |
|||
return false; |
|||
} |
|||
|
|||
final leftBattery = deviceInfo.leftEarBattery; |
|||
final rightBattery = deviceInfo.rightEarBattery; |
|||
|
|||
// 检查左右耳电量是否都大于30% |
|||
if (leftBattery <= 30 || rightBattery <= 30) { |
|||
_showLowBatteryDialog(leftBattery, rightBattery); |
|||
return false; |
|||
} |
|||
|
|||
return true; |
|||
} catch (e) { |
|||
_showBatteryCheckFailedSnackbar('检查设备电量时发生错误：$e'); |
|||
return false; |
|||
} |
|||
} |
|||
|
|||
/// 显示电量不足对话框 |
|||
/// [leftBattery] 左耳电量 |
|||
/// [rightBattery] 右耳电量 |
|||
void _showLowBatteryDialog(int leftBattery, int rightBattery) { |
|||
String message = '设备电量不足，无法进行固件升级\n'; |
|||
message += '升级要求：左右耳电量均需大于30%\n'; |
|||
message += '当前电量：左耳 ${leftBattery}%，右耳 ${rightBattery}%\n'; |
|||
message += '请充电后再试'; |
|||
|
|||
Get.dialog( |
|||
AlertDialog( |
|||
title: Text( |
|||
'电量不足', |
|||
style: TextStyle( |
|||
color: Colors.orange[700], |
|||
fontWeight: FontWeight.w600, |
|||
), |
|||
), |
|||
content: Text( |
|||
message, |
|||
style: TextStyle( |
|||
color: Colors.orange[600], |
|||
), |
|||
), |
|||
actions: [ |
|||
TextButton( |
|||
onPressed: () => Get.back(), |
|||
style: TextButton.styleFrom( |
|||
foregroundColor: Colors.orange[700], |
|||
), |
|||
child: const Text('确定'), |
|||
), |
|||
], |
|||
shape: RoundedRectangleBorder( |
|||
borderRadius: BorderRadius.circular(12), |
|||
side: BorderSide( |
|||
color: Colors.orange.withValues(alpha: 0.3), |
|||
width: 1, |
|||
), |
|||
), |
|||
backgroundColor: Colors.orange[50], |
|||
), |
|||
); |
|||
} |
|||
|
|||
/// 显示电量检查失败提示 |
|||
/// [message] 错误信息 |
|||
void _showBatteryCheckFailedSnackbar(String message) { |
|||
Get.snackbar( |
|||
'电量检查失败', |
|||
message, |
|||
snackPosition: SnackPosition.BOTTOM, |
|||
backgroundColor: Colors.orange[600], |
|||
colorText: Colors.white, |
|||
icon: const Icon( |
|||
Icons.warning_amber, |
|||
color: Colors.white, |
|||
), |
|||
); |
|||
} |
|||
} |
|||
@ -1,43 +0,0 @@ |
|||
import 'package:get/get.dart'; |
|||
|
|||
/// OTA升级状态管理器 |
|||
/// 负责管理OTA升级过程中的各种状态常量和状态描述 |
|||
class OtaStatusManager { |
|||
static const int NOT_STARTED = -1; // 未开始 |
|||
static const int VALIDATION_FILE = 0; // 验证文件 |
|||
static const int ONUPGRADE = 1; // 升级中 |
|||
static const int START_UPGRADING = 2; // 开始升级 |
|||
static const int UPGRADE_SUCCESS = 3; // 升级成功 |
|||
static const int UPGRADE_FAILED = 4; // 升级失败 |
|||
static const int CONNECTION_DISCONNECTION = 5; // 连接断开 |
|||
static const int CONNECTION_SUCCESS = 6; // 连接成功 |
|||
static const int DOWNLOADING_UP_FILES = 7; // 下载升级文件 |
|||
|
|||
/// 获取状态描述信息 |
|||
/// [type] 状态类型 |
|||
/// 返回对应的状态描述文本 |
|||
static String getStatusMessage(int type) { |
|||
switch (type) { |
|||
case NOT_STARTED: |
|||
return "未开始".tr; |
|||
case VALIDATION_FILE: |
|||
return "验证文件中".tr; |
|||
case ONUPGRADE: |
|||
return "升级中".tr; |
|||
case START_UPGRADING: |
|||
return "开始升级".tr; |
|||
case UPGRADE_SUCCESS: |
|||
return "升级成功".tr; |
|||
case UPGRADE_FAILED: |
|||
return "升级失败".tr; |
|||
case CONNECTION_DISCONNECTION: |
|||
return "连接断开".tr; |
|||
case CONNECTION_SUCCESS: |
|||
return "连接成功".tr; |
|||
case DOWNLOADING_UP_FILES: |
|||
return "下载升级文件".tr; |
|||
default: |
|||
return "未知状态".tr; |
|||
} |
|||
} |
|||
} |
|||
@ -1,114 +0,0 @@ |
|||
import 'package:logger/web.dart'; |
|||
import '../../../data/services/ble_manager.dart'; |
|||
import '../../../data/models/appconfig.dart'; |
|||
import '../../../data/models/appconfig_model.dart'; |
|||
import 'package:get/get.dart'; |
|||
|
|||
/// 版本管理服务 |
|||
/// 负责处理设备版本信息获取、版本比较等功能 |
|||
class VersionManager { |
|||
final BleManager _bleManager = Get.find<BleManager>(); |
|||
final int maxRetryAttempts = 3; |
|||
int currentRetryCount = 0; |
|||
|
|||
/// 获取当前设备版本信息 |
|||
/// 返回包含当前版本、产品ID和设备信息的Map |
|||
/// 抛出异常如果获取失败 |
|||
Future<Map<String, dynamic>> getCurrentVersionInfo() async { |
|||
DeviceInfo? deviceInfo = _bleManager.deviceInfo.value; |
|||
|
|||
// 重试机制获取设备信息 |
|||
while (currentRetryCount < maxRetryAttempts) { |
|||
deviceInfo = _bleManager.deviceInfo.value; |
|||
|
|||
if (deviceInfo != null && |
|||
deviceInfo.firmwareVersion.isNotEmpty && |
|||
deviceInfo.firmwareProductId.isNotEmpty) { |
|||
break; |
|||
} |
|||
|
|||
await _bleManager.fetchDeviceInfo(); |
|||
await Future.delayed(const Duration(seconds: 5)); |
|||
currentRetryCount++; |
|||
} |
|||
|
|||
if (deviceInfo == null || |
|||
deviceInfo.firmwareVersion.isEmpty || |
|||
deviceInfo.firmwareProductId.isEmpty) { |
|||
throw "获取设备信息失败，请检查连接"; |
|||
} |
|||
|
|||
// 验证固件版本格式 |
|||
final firmwareParts = deviceInfo.firmwareVersion.split('.'); |
|||
final firstPart = firmwareParts.sublist(0, 3).join('.'); |
|||
final secondPart = firmwareParts.sublist(3).join('.'); |
|||
|
|||
Logger().d("firstPart: $firstPart, secondPart: $secondPart"); |
|||
|
|||
if (firstPart != secondPart) { |
|||
throw "固件版本格式错误：${deviceInfo.firmwareVersion}"; |
|||
} |
|||
|
|||
return { |
|||
'currentVersion': firstPart, |
|||
'productId': deviceInfo.firmwareProductId, |
|||
'deviceInfo': deviceInfo, |
|||
}; |
|||
} |
|||
|
|||
/// 获取最新版本信息 |
|||
/// 返回包含最新版本、更新描述和更新包地址的Map |
|||
/// 抛出异常如果获取失败 |
|||
Future<Map<String, dynamic>> getLatestVersionInfo() async { |
|||
DBProduct? product = AppConfig.getproduct("DeapSound"); |
|||
|
|||
if (product == null) { |
|||
throw "无法获取产品信息"; |
|||
} |
|||
|
|||
return { |
|||
'latestVersion': product.version ?? "", |
|||
'updateDescription': product.updatedescription ?? "", |
|||
'updatePackageAddress': product.updatepackageaddress ?? "", |
|||
}; |
|||
} |
|||
|
|||
/// 比较版本号，判断是否有新版本可用 |
|||
/// [currentVersion] 当前版本号 |
|||
/// [latestVersion] 最新版本号 |
|||
/// 返回true表示有新版本可用（支持升级和降级） |
|||
bool isNewVersionAvailable(String currentVersion, String latestVersion) { |
|||
try { |
|||
List<int> currentParts = currentVersion |
|||
.split('.') |
|||
.map((e) => int.parse(e.trim())) |
|||
.toList(); |
|||
List<int> latestParts = |
|||
latestVersion.split('.').map((e) => int.parse(e.trim())).toList(); |
|||
|
|||
// 确保两个版本号长度一致，短的用0补齐 |
|||
int maxLength = currentParts.length > latestParts.length |
|||
? currentParts.length |
|||
: latestParts.length; |
|||
|
|||
while (currentParts.length < maxLength) { |
|||
currentParts.add(0); |
|||
} |
|||
while (latestParts.length < maxLength) { |
|||
latestParts.add(0); |
|||
} |
|||
|
|||
// 比较每一段，只要有不同就返回true（支持升级和降级） |
|||
for (int i = 0; i < maxLength; i++) { |
|||
if (latestParts[i] != currentParts[i]) { |
|||
return true; |
|||
} |
|||
} |
|||
|
|||
return false; |
|||
} catch (e) { |
|||
Logger().d('版本比较错误: $e'); |
|||
return false; |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,933 @@ |
|||
import Foundation |
|||
import MicrosoftCognitiveServicesSpeech |
|||
import AVFoundation |
|||
import os.log |
|||
|
|||
/** |
|||
* 整合的语音翻译服务 |
|||
* 集成ASR语音识别、翻译服务和TTS语音合成 |
|||
* 实现音频输入 -> 语音识别 -> 翻译 -> 语音合成 -> 音频输出的完整流程 |
|||
*/ |
|||
@objc public class IntegratedSpeechTranslationService: NSObject { |
|||
|
|||
// MARK: - Constants |
|||
private static let TAG = "IntegratedSpeechService" |
|||
// 音频源配置 |
|||
public enum AudioSourceType { |
|||
/** 使用设备麦克风 */ |
|||
case microphone |
|||
|
|||
/** 使用外部提供的音频数据 */ |
|||
case external |
|||
} |
|||
|
|||
// 音频配置常量 |
|||
private static let SAMPLE_RATE: UInt32 = 16000 |
|||
private static let CHANNELS: UInt32 = 1 |
|||
private static let BITS_PER_SAMPLE: UInt32 = 16 |
|||
private static let BUFFER_SIZE = 4096 |
|||
|
|||
// 超时配置 |
|||
private static let END_SILENCE_TIMEOUT = "300" |
|||
private static let SEGMENTATION_SILENCE_TIMEOUT = "300" |
|||
private static let INITIAL_SILENCE_TIMEOUT = "200" |
|||
|
|||
// MARK: - Properties |
|||
private let log = OSLog(subsystem: "com.azure.speech", category: "IntegratedSpeechService") |
|||
|
|||
// Azure服务组件 |
|||
private var speechConfig: SPXSpeechConfiguration? |
|||
private var recognizer: SPXSpeechRecognizer? |
|||
private var synthesizer: SPXSpeechSynthesizer? |
|||
|
|||
// 翻译服务 |
|||
private var translationService: TranslationServiceInterface? |
|||
|
|||
// 音频处理 |
|||
private var audioProcessor: SimpleAudioReceiver? |
|||
private var audioConfig: SPXAudioConfiguration? |
|||
|
|||
// 录音文件处理 |
|||
private var recordFile: RecordFile? |
|||
private var filePath: String? |
|||
|
|||
// 配置管理 |
|||
private var serviceConfig = ServiceConfiguration() |
|||
|
|||
// 状态管理 |
|||
private let serviceState = ServiceState() |
|||
|
|||
// 事件回调 |
|||
private weak var eventCallback: ServiceEventCallback? |
|||
|
|||
// 语音映射缓存 |
|||
private var voiceCache: [String: String] = [:] |
|||
|
|||
// 处理队列 |
|||
private let processingQueue = DispatchQueue(label: "com.azure.speech.processing", qos: .userInitiated) |
|||
|
|||
// MARK: - Configuration Structures |
|||
|
|||
/** |
|||
* 服务配置类 |
|||
*/ |
|||
public struct ServiceConfiguration { |
|||
var sourceLanguage: String = "zh-CN" |
|||
var targetLanguage: String = "en-US" |
|||
var currentVoice: String = "en-US-AriaNeural" |
|||
var speechRate: String = "0%" |
|||
var speechPitch: String = "0%" |
|||
var speechVolume: String = "100%" |
|||
var enableContinuousRecognition: Bool = true |
|||
var enableAutoLanguageDetection: Bool = false |
|||
var maxRetryAttempts: Int = 3 |
|||
var translationTimeout: TimeInterval = 10.0 |
|||
// 新增：控制是否播放合成的音频 |
|||
var enableAudioPlayback: Bool = false |
|||
|
|||
public init( |
|||
sourceLanguage: String = "zh-CN", |
|||
targetLanguage: String = "en-US", |
|||
currentVoice: String = "en-US-AriaNeural", |
|||
speechRate: String = "0%", |
|||
speechPitch: String = "0%", |
|||
speechVolume: String = "100%", |
|||
enableContinuousRecognition: Bool = true, |
|||
enableAutoLanguageDetection: Bool = false, |
|||
maxRetryAttempts: Int = 3, |
|||
translationTimeout: TimeInterval = 10.0, |
|||
enableAudioPlayback: Bool = false |
|||
) { |
|||
self.sourceLanguage = sourceLanguage |
|||
self.targetLanguage = targetLanguage |
|||
self.currentVoice = currentVoice |
|||
self.speechRate = speechRate |
|||
self.speechPitch = speechPitch |
|||
self.speechVolume = speechVolume |
|||
self.enableContinuousRecognition = enableContinuousRecognition |
|||
self.enableAutoLanguageDetection = enableAutoLanguageDetection |
|||
self.maxRetryAttempts = maxRetryAttempts |
|||
self.translationTimeout = translationTimeout |
|||
self.enableAudioPlayback = enableAudioPlayback |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 服务状态类 |
|||
*/ |
|||
public class ServiceState { |
|||
private let queue = DispatchQueue(label: "com.azure.speech.state") |
|||
private var _isInitialized = false |
|||
private var _isRecognizing = false |
|||
private var _isSynthesizing = false |
|||
private var _isTranslating = false |
|||
|
|||
var isInitialized: Bool { |
|||
get { queue.sync { _isInitialized } } |
|||
set { queue.sync { _isInitialized = newValue } } |
|||
} |
|||
|
|||
var isRecognizing: Bool { |
|||
get { queue.sync { _isRecognizing } } |
|||
set { queue.sync { _isRecognizing = newValue } } |
|||
} |
|||
|
|||
var isSynthesizing: Bool { |
|||
get { queue.sync { _isSynthesizing } } |
|||
set { queue.sync { _isSynthesizing = newValue } } |
|||
} |
|||
|
|||
var isTranslating: Bool { |
|||
get { queue.sync { _isTranslating } } |
|||
set { queue.sync { _isTranslating = newValue } } |
|||
} |
|||
} |
|||
|
|||
// MARK: - Protocols |
|||
|
|||
/** |
|||
* 服务事件回调接口 |
|||
*/ |
|||
public protocol ServiceEventCallback: AnyObject { |
|||
func onServiceInitialized() |
|||
func onRecognizing(text: String, language: String, confidence: Float) |
|||
func onRecognized(text: String, language: String, confidence: Float) |
|||
func onTranslated(originalText: String, translatedText: String, targetLanguage: String) |
|||
func onTranslationStarted(text: String) |
|||
func onTranslationFailed(text: String, error: String) |
|||
func onSynthesisStarted(text: String) |
|||
func onSynthesisCompleted(text: String) |
|||
func onSynthesisFailed(text: String, error: String) |
|||
func onSynthesisProgress(text: String, progress: Float) |
|||
func onRecognitionStarted() |
|||
func onRecognitionStopped() |
|||
func onStateChanged(component: String, isActive: Bool) |
|||
func onError(component: String, error: String) |
|||
// 新增：返回合成的音频数据 |
|||
func onSynthesisAudioGenerated(text: String, audioData: Data) |
|||
} |
|||
|
|||
/** |
|||
* 翻译服务接口 |
|||
*/ |
|||
public protocol TranslationServiceInterface { |
|||
func initialize(config: [String: String]) async -> Bool |
|||
func translateText( |
|||
text: String, |
|||
sourceLanguage: String, |
|||
targetLanguage: String |
|||
) async -> TranslationResult |
|||
func dispose() |
|||
} |
|||
|
|||
/** |
|||
* 翻译结果类 |
|||
*/ |
|||
public struct TranslationResult { |
|||
let success: Bool |
|||
let translatedText: String? |
|||
let error: String? |
|||
let confidence: Float |
|||
|
|||
public init(success: Bool, translatedText: String? = nil, error: String? = nil, confidence: Float = 0.0) { |
|||
self.success = success |
|||
self.translatedText = translatedText |
|||
self.error = error |
|||
self.confidence = confidence |
|||
} |
|||
} |
|||
|
|||
// MARK: - Initialization |
|||
|
|||
public override init() { |
|||
super.init() |
|||
} |
|||
|
|||
/** |
|||
* 初始化整合服务 |
|||
*/ |
|||
public func initialize( |
|||
azureConfig: AzureConfiguration, |
|||
translationConfig: TranslationConfiguration, |
|||
serviceConfig: ServiceConfiguration? = nil, |
|||
callback: ServiceEventCallback |
|||
) async -> Bool { |
|||
|
|||
do { |
|||
self.eventCallback = callback |
|||
|
|||
if let config = serviceConfig { |
|||
self.serviceConfig = config |
|||
} |
|||
|
|||
os_log("开始初始化整合服务", log: log, type: .info) |
|||
|
|||
// 初始化Azure语音服务 |
|||
if !initializeAzureServices(azureConfig: azureConfig) { |
|||
await MainActor.run { |
|||
callback.onError(component: "Initialization", error: "Azure服务初始化失败") |
|||
} |
|||
return false |
|||
} |
|||
|
|||
// 初始化翻译服务 |
|||
if !(await initializeTranslationService(translationConfig: translationConfig)) { |
|||
await MainActor.run { |
|||
callback.onError(component: "Initialization", error: "翻译服务初始化失败") |
|||
} |
|||
return false |
|||
} |
|||
|
|||
// 初始化音频处理器 |
|||
initializeAudioProcessor() |
|||
|
|||
// 设置语音识别器 |
|||
setupSpeechRecognizer() |
|||
|
|||
// 设置语音合成器 |
|||
setupSpeechSynthesizer() |
|||
|
|||
serviceState.isInitialized = true |
|||
os_log("整合服务初始化成功", log: log, type: .info) |
|||
|
|||
await MainActor.run { |
|||
callback.onServiceInitialized() |
|||
} |
|||
|
|||
recordFile = RecordFile() |
|||
return true |
|||
|
|||
} catch { |
|||
os_log("初始化失败: %@", log: log, type: .error, error.localizedDescription) |
|||
await MainActor.run { |
|||
callback.onError( |
|||
component: "Initialization", |
|||
error: "初始化失败: \(error.localizedDescription)" |
|||
) |
|||
} |
|||
return false |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 初始化Azure服务 |
|||
*/ |
|||
private func initializeAzureServices(azureConfig: AzureConfiguration) -> Bool { |
|||
do { |
|||
os_log("开始初始化Azure服务", log: log, type: .info) |
|||
|
|||
speechConfig = try SPXSpeechConfiguration(subscription: azureConfig.subscriptionKey, region: azureConfig.region) |
|||
|
|||
guard let config = speechConfig else { |
|||
return false |
|||
} |
|||
|
|||
config.speechRecognitionLanguage = serviceConfig.sourceLanguage |
|||
config.speechSynthesisVoiceName = getVoiceForLanguage(serviceConfig.targetLanguage) |
|||
config.setSpeechSynthesisOutputFormat(.riff16Khz16BitMonoPcm) |
|||
|
|||
// 优化配置 |
|||
config.setPropertyTo(Self.END_SILENCE_TIMEOUT, byName: "SpeechServiceConnection_EndSilenceTimeoutMs") |
|||
config.setPropertyTo(Self.SEGMENTATION_SILENCE_TIMEOUT, byName: "Speech_SegmentationSilenceTimeoutMs") |
|||
config.setPropertyTo(Self.INITIAL_SILENCE_TIMEOUT, byName: "SpeechServiceConnection_InitialSilenceTimeoutMs") |
|||
config.setPropertyTo("INTERACTIVE", byName: "SpeechServiceConnection_RecoMode") |
|||
|
|||
// 启用详细结果 |
|||
config.setPropertyTo("true", byName: "SpeechServiceResponse_RequestDetailedResultTrueFalse") |
|||
|
|||
// 自动语言检测 |
|||
if serviceConfig.enableAutoLanguageDetection { |
|||
config.setPropertyTo("Continuous", byName: "SpeechServiceConnection_LanguageIdMode") |
|||
} |
|||
|
|||
os_log("Azure语音服务配置完成", log: log, type: .info) |
|||
return true |
|||
|
|||
} catch { |
|||
os_log("Azure服务初始化失败: %@", log: log, type: .error, error.localizedDescription) |
|||
return false |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 初始化翻译服务 |
|||
*/ |
|||
private func initializeTranslationService(translationConfig: TranslationConfiguration) async -> Bool { |
|||
do { |
|||
translationService = VolcanoTranslationServiceImpl() |
|||
let success = await translationService?.initialize(config: translationConfig.toConfigMap()) ?? false |
|||
|
|||
if success { |
|||
os_log("翻译服务初始化完成", log: log, type: .info) |
|||
} |
|||
|
|||
return success |
|||
|
|||
} catch { |
|||
os_log("翻译服务初始化失败: %@", log: log, type: .error, error.localizedDescription) |
|||
return false |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 初始化音频处理器 |
|||
*/ |
|||
private func initializeAudioProcessor() { |
|||
audioProcessor = SimpleAudioReceiver(parentHelper: self as! AzureAsrHelper) |
|||
audioProcessor?.initAudioRecord() |
|||
// 检查音频配置是否已存在 |
|||
if audioConfig == nil, let pushStream = audioProcessor?.pushAudioStream { |
|||
audioConfig = SPXAudioConfiguration(streamInput: pushStream) |
|||
os_log("设置麦克风流完成", log: log, type: .info) |
|||
} |
|||
|
|||
os_log("音频处理器初始化完成", log: log, type: .info) |
|||
} |
|||
|
|||
/** |
|||
* 设置语音识别器 |
|||
*/ |
|||
private func setupSpeechRecognizer() { |
|||
guard let speechConfig = speechConfig, let audioConfig = audioConfig else { |
|||
return |
|||
} |
|||
|
|||
do { |
|||
recognizer = try SPXSpeechRecognizer(speechConfiguration: speechConfig, audioConfiguration: audioConfig) |
|||
|
|||
// 识别中事件 |
|||
recognizer?.addRecognizingEventHandler { [weak self] (_, event) in |
|||
guard let self = self else { return } |
|||
let result = event.result |
|||
guard let text = result.text, !text.isEmpty else { return } |
|||
let confidence = self.extractConfidence(from: result) |
|||
os_log("识别中事件: %@", log: self.log, type: .debug, text) |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onRecognizing( |
|||
text: text, |
|||
language: self.serviceConfig.sourceLanguage, |
|||
confidence: confidence |
|||
) |
|||
} |
|||
} |
|||
|
|||
// 识别完成事件 |
|||
recognizer?.addRecognizedEventHandler { [weak self] (_, event) in |
|||
guard let self = self else { return } |
|||
let result = event.result |
|||
|
|||
switch result.reason { |
|||
case .recognizedSpeech: |
|||
if let text = result.text, !text.isEmpty { |
|||
let confidence = self.extractConfidence(from: result) |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onRecognized( |
|||
text: text, |
|||
language: self.serviceConfig.sourceLanguage, |
|||
confidence: confidence |
|||
) |
|||
} |
|||
|
|||
os_log("识别完成事件: %@", log: self.log, type: .info, text) |
|||
|
|||
// 触发翻译流程 |
|||
Task { |
|||
await self.processTranslationAndSynthesis(text: text) |
|||
} |
|||
} |
|||
|
|||
case .noMatch: |
|||
os_log("未识别到语音", log: self.log, type: .debug) |
|||
|
|||
default: |
|||
os_log("识别结果: %@", log: self.log, type: .info, String(describing: result.reason)) |
|||
} |
|||
} |
|||
|
|||
// 会话开始事件 |
|||
recognizer?.addSessionStartedEventHandler { [weak self] (recognizer, event) in |
|||
guard let self = self else { return } |
|||
|
|||
os_log("会话开始事件", log: self.log, type: .info) |
|||
self.serviceState.isRecognizing = true |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onRecognitionStarted() |
|||
self.eventCallback?.onStateChanged(component: "Recognition", isActive: true) |
|||
} |
|||
} |
|||
|
|||
// 会话停止事件 |
|||
recognizer?.addSessionStoppedEventHandler { [weak self] (recognizer, event) in |
|||
guard let self = self else { return } |
|||
|
|||
os_log("会话停止事件", log: self.log, type: .info) |
|||
self.serviceState.isRecognizing = false |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onRecognitionStopped() |
|||
self.eventCallback?.onStateChanged(component: "Recognition", isActive: false) |
|||
} |
|||
} |
|||
|
|||
// 取消事件 |
|||
recognizer?.addCanceledEventHandler { [weak self] (recognizer, event) in |
|||
guard let self = self else { return } |
|||
|
|||
os_log("取消事件", log: self.log, type: .info) |
|||
self.serviceState.isRecognizing = false |
|||
|
|||
let errorDetails = event.errorDetails ?? "未知错误" |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onError(component: "Recognition", error: "识别被取消: \(errorDetails)") |
|||
self.eventCallback?.onStateChanged(component: "Recognition", isActive: false) |
|||
} |
|||
} |
|||
|
|||
os_log("语音识别器设置完成", log: log, type: .info) |
|||
|
|||
} catch { |
|||
os_log("语音识别器设置失败: %@", log: log, type: .error, error.localizedDescription) |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 设置语音合成器 |
|||
*/ |
|||
private func setupSpeechSynthesizer() { |
|||
guard let speechConfig = speechConfig else { |
|||
return |
|||
} |
|||
|
|||
do { |
|||
// 根据配置决定音频输出方式 |
|||
let audioConfig: SPXAudioConfiguration? |
|||
if serviceConfig.enableAudioPlayback { |
|||
audioConfig = SPXAudioConfiguration() |
|||
} else { |
|||
// 不输出到扬声器，只生成音频数据 |
|||
audioConfig = nil |
|||
} |
|||
|
|||
synthesizer = try SPXSpeechSynthesizer(speechConfiguration: speechConfig, audioConfiguration: audioConfig) |
|||
|
|||
// 合成开始事件 |
|||
synthesizer?.addSynthesisStartedEventHandler { [weak self] (synthesizer, event) in |
|||
guard let self = self else { return } |
|||
|
|||
os_log("合成开始事件", log: self.log, type: .info) |
|||
self.serviceState.isSynthesizing = true |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onStateChanged(component: "Synthesis", isActive: true) |
|||
} |
|||
} |
|||
|
|||
// 合成进行中事件 |
|||
synthesizer?.addSynthesizingEventHandler { [weak self] (synthesizer, event) in |
|||
guard let self = self else { return } |
|||
|
|||
os_log("合成进行中事件", log: self.log, type: .debug) |
|||
// 计算进度（简化版） |
|||
let progress: Float = 0.5 |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onSynthesisProgress(text: "", progress: progress) |
|||
} |
|||
} |
|||
|
|||
// 合成完成事件 |
|||
synthesizer?.addSynthesisCompletedEventHandler { [weak self] (synthesizer, event) in |
|||
guard let self = self else { return } |
|||
|
|||
os_log("合成完成事件", log: self.log, type: .info) |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onStateChanged(component: "Synthesis", isActive: false) |
|||
} |
|||
} |
|||
|
|||
// 合成取消事件 |
|||
synthesizer?.addSynthesisCanceledEventHandler { [weak self] (synthesizer, event) in |
|||
guard let self = self else { return } |
|||
|
|||
os_log("合成取消事件", log: self.log, type: .info) |
|||
self.serviceState.isSynthesizing = false |
|||
|
|||
// 修复：移除可选链，因为event.result不是可选类型 |
|||
let reason = event.result.reason |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onError(component: "Synthesis", error: "语音合成取消: \(reason)") |
|||
self.eventCallback?.onStateChanged(component: "Synthesis", isActive: false) |
|||
} |
|||
} |
|||
|
|||
os_log("语音合成器设置完成，播放模式: %@", log: log, type: .info, serviceConfig.enableAudioPlayback ? "启用" : "禁用") |
|||
|
|||
} catch { |
|||
os_log("语音合成器设置失败: %@", log: log, type: .error, error.localizedDescription) |
|||
} |
|||
} |
|||
|
|||
// MARK: - Public Methods |
|||
|
|||
/** |
|||
* 开始连续语音翻译 |
|||
*/ |
|||
public func startContinuousTranslation() -> Bool { |
|||
os_log("尝试启动连续翻译，当前状态：初始化=%@, 识别中=%@", log: log, type: .info, |
|||
serviceState.isInitialized ? "true" : "false", |
|||
serviceState.isRecognizing ? "true" : "false") |
|||
|
|||
guard serviceState.isInitialized else { |
|||
eventCallback?.onError(component: "Service", error: "服务未初始化") |
|||
return false |
|||
} |
|||
|
|||
if serviceState.isRecognizing { |
|||
os_log("语音识别已在进行中", log: log, type: .info) |
|||
return true |
|||
} |
|||
|
|||
do { |
|||
// 启动音频处理器 |
|||
audioProcessor?.startAudioRecord( audioSourceType: .external, |
|||
audioDataCallback: nil) |
|||
|
|||
if serviceConfig.enableContinuousRecognition { |
|||
os_log("启动连续识别", log: log, type: .info) |
|||
try recognizer?.startContinuousRecognition() |
|||
serviceState.isRecognizing = true |
|||
} |
|||
|
|||
os_log("连续语音翻译启动成功", log: log, type: .info) |
|||
return true |
|||
|
|||
} catch { |
|||
os_log("启动连续翻译失败: %@", log: log, type: .error, error.localizedDescription) |
|||
eventCallback?.onError(component: "Service", error: "启动失败: \(error.localizedDescription)") |
|||
return false |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 启用录音 |
|||
*/ |
|||
public func enableRecord(filePath: String) { |
|||
os_log("开启录音: %@", log: log, type: .info, filePath) |
|||
|
|||
recordFile?.closeFile(isSave: true) |
|||
recordFile?.creatingFiles(atPath: filePath) |
|||
} |
|||
|
|||
/** |
|||
* 停止连续语音翻译 |
|||
*/ |
|||
public func stopContinuousTranslation() { |
|||
do { |
|||
try recognizer?.stopContinuousRecognition() |
|||
audioProcessor?.stopMicrophoneCapture() |
|||
recordFile?.closeFile(isSave: true) |
|||
|
|||
// 等待当前处理完成 |
|||
while serviceState.isTranslating || serviceState.isSynthesizing { |
|||
Thread.sleep(forTimeInterval: 0.1) |
|||
} |
|||
|
|||
os_log("停止连续语音翻译", log: log, type: .info) |
|||
|
|||
} catch { |
|||
os_log("停止翻译失败: %@", log: log, type: .error, error.localizedDescription) |
|||
eventCallback?.onError(component: "Service", error: "停止失败: \(error.localizedDescription)") |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 处理翻译和合成流程 |
|||
*/ |
|||
private func processTranslationAndSynthesis(text: String) async { |
|||
os_log("翻译状态: %@", log: log, type: .debug, serviceState.isTranslating ? "进行中" : "空闲") |
|||
|
|||
if serviceState.isTranslating { |
|||
os_log("翻译正在进行中，跳过当前请求", log: log, type: .info) |
|||
return |
|||
} |
|||
|
|||
serviceState.isTranslating = true |
|||
|
|||
await MainActor.run { |
|||
eventCallback?.onTranslationStarted(text: text) |
|||
eventCallback?.onStateChanged(component: "Translation", isActive: true) |
|||
} |
|||
|
|||
os_log("翻译开始: %@", log: log, type: .info, text) |
|||
|
|||
do { |
|||
let translationResult = try await withTimeout(self.serviceConfig.translationTimeout) { |
|||
// 修复：在闭包中显式使用self |
|||
return await self.translationService?.translateText( |
|||
text: text, |
|||
sourceLanguage: self.serviceConfig.sourceLanguage, |
|||
targetLanguage: self.serviceConfig.targetLanguage |
|||
) |
|||
} |
|||
|
|||
serviceState.isTranslating = false |
|||
|
|||
await MainActor.run { |
|||
eventCallback?.onStateChanged(component: "Translation", isActive: false) |
|||
} |
|||
|
|||
if let result = translationResult, result.success, let translatedText = result.translatedText, !translatedText.isEmpty { |
|||
os_log("翻译成功: %@", log: log, type: .info, translatedText) |
|||
|
|||
await MainActor.run { |
|||
eventCallback?.onTranslated( |
|||
originalText: text, |
|||
translatedText: translatedText, |
|||
targetLanguage: serviceConfig.targetLanguage |
|||
) |
|||
} |
|||
|
|||
// 进行语音合成 |
|||
if let audioData = synthesizeText(translatedText) { |
|||
await MainActor.run { |
|||
eventCallback?.onSynthesisAudioGenerated(text: translatedText, audioData: audioData) |
|||
} |
|||
} |
|||
} else { |
|||
let errorMessage = translationResult?.error ?? "翻译失败" |
|||
os_log("翻译失败: %@", log: log, type: .error, errorMessage) |
|||
|
|||
await MainActor.run { |
|||
eventCallback?.onTranslationFailed(text: text, error: errorMessage) |
|||
} |
|||
} |
|||
|
|||
} catch { |
|||
serviceState.isTranslating = false |
|||
|
|||
await MainActor.run { |
|||
eventCallback?.onStateChanged(component: "Translation", isActive: false) |
|||
eventCallback?.onTranslationFailed(text: text, error: "翻译超时或异常: \(error.localizedDescription)") |
|||
} |
|||
|
|||
os_log("翻译异常: %@", log: log, type: .error, error.localizedDescription) |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 语音合成 |
|||
* @param text 要合成的文本 |
|||
* @return 返回合成的音频数据，如果合成失败则返回nil |
|||
*/ |
|||
/** |
|||
* 合成文本为音频数据 |
|||
*/ |
|||
private func synthesizeText(_ text: String) -> Data? { |
|||
guard let synthesizer = synthesizer else { |
|||
os_log("语音合成器未初始化", log: log, type: .error) |
|||
return nil |
|||
} |
|||
|
|||
do { |
|||
let ssml = buildSSML(text: text) |
|||
os_log("开始合成语音: %@", log: log, type: .info, text) |
|||
|
|||
serviceState.isSynthesizing = true |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onSynthesisStarted(text: text) |
|||
self.eventCallback?.onStateChanged(component: "Synthesis", isActive: true) |
|||
} |
|||
|
|||
let result = try synthesizer.speakSsml(ssml) |
|||
|
|||
serviceState.isSynthesizing = false |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onStateChanged(component: "Synthesis", isActive: false) |
|||
} |
|||
|
|||
if result.reason == .synthesizingAudioCompleted { |
|||
os_log("语音合成成功", log: log, type: .info) |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onSynthesisCompleted(text: text) |
|||
} |
|||
|
|||
return result.audioData |
|||
} else { |
|||
let errorMessage = "合成失败: \(result.reason)" |
|||
os_log("%@", log: log, type: .error, errorMessage) |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onSynthesisFailed(text: text, error: errorMessage) |
|||
} |
|||
|
|||
return nil |
|||
} |
|||
|
|||
} catch { |
|||
serviceState.isSynthesizing = false |
|||
|
|||
let errorMessage = "合成异常: \(error.localizedDescription)" |
|||
os_log("%@", log: log, type: .error, errorMessage) |
|||
|
|||
DispatchQueue.main.async { |
|||
self.eventCallback?.onSynthesisFailed(text: text, error: errorMessage) |
|||
self.eventCallback?.onStateChanged(component: "Synthesis", isActive: false) |
|||
} |
|||
|
|||
return nil |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 构建SSML |
|||
*/ |
|||
private func buildSSML(text: String) -> String { |
|||
let voice = getVoiceForLanguage(serviceConfig.targetLanguage) |
|||
|
|||
return """ |
|||
<speak version="1.0" xmlns="http://www.w3.org/2001/10/synthesis" xml:lang="\(serviceConfig.targetLanguage)"> |
|||
<voice name="\(voice)"> |
|||
<prosody rate="\(serviceConfig.speechRate)" pitch="\(serviceConfig.speechPitch)" volume="\(serviceConfig.speechVolume)"> |
|||
\(text) |
|||
</prosody> |
|||
</voice> |
|||
</speak> |
|||
""" |
|||
} |
|||
|
|||
/** |
|||
* 根据语言获取对应的语音 |
|||
*/ |
|||
private func getVoiceForLanguage(_ language: String) -> String { |
|||
if let cachedVoice = voiceCache[language] { |
|||
return cachedVoice |
|||
} |
|||
|
|||
let voice: String |
|||
switch language { |
|||
case "zh-CN": |
|||
voice = "zh-CN-XiaoxiaoNeural" |
|||
case "en-US": |
|||
voice = "en-US-AriaNeural" |
|||
case "ja-JP": |
|||
voice = "ja-JP-NanamiNeural" |
|||
case "ko-KR": |
|||
voice = "ko-KR-SunHiNeural" |
|||
case "fr-FR": |
|||
voice = "fr-FR-DeniseNeural" |
|||
case "de-DE": |
|||
voice = "de-DE-KatjaNeural" |
|||
case "es-ES": |
|||
voice = "es-ES-ElviraNeural" |
|||
default: |
|||
voice = "en-US-AriaNeural" |
|||
} |
|||
|
|||
voiceCache[language] = voice |
|||
return voice |
|||
} |
|||
|
|||
/** |
|||
* 提取置信度 |
|||
*/ |
|||
private func extractConfidence(from result: SPXSpeechRecognitionResult) -> Float { |
|||
// 从结果中提取置信度，这里简化处理 |
|||
return 0.9 |
|||
} |
|||
|
|||
/** |
|||
* 更新配置 |
|||
*/ |
|||
public func updateConfiguration(newConfig: ServiceConfiguration) { |
|||
serviceConfig = newConfig |
|||
|
|||
// 更新语音配置 |
|||
speechConfig?.speechRecognitionLanguage = newConfig.sourceLanguage |
|||
speechConfig?.speechSynthesisVoiceName = getVoiceForLanguage(newConfig.targetLanguage) |
|||
|
|||
os_log("服务配置已更新", log: log, type: .info) |
|||
} |
|||
|
|||
/** |
|||
* 切换语言 |
|||
*/ |
|||
public func switchLanguages() { |
|||
let newConfig = ServiceConfiguration( |
|||
sourceLanguage: serviceConfig.targetLanguage, |
|||
targetLanguage: serviceConfig.sourceLanguage, |
|||
currentVoice: getVoiceForLanguage(serviceConfig.sourceLanguage), |
|||
speechRate: serviceConfig.speechRate, |
|||
speechPitch: serviceConfig.speechPitch, |
|||
speechVolume: serviceConfig.speechVolume, |
|||
enableContinuousRecognition: serviceConfig.enableContinuousRecognition, |
|||
enableAutoLanguageDetection: serviceConfig.enableAutoLanguageDetection, |
|||
maxRetryAttempts: serviceConfig.maxRetryAttempts, |
|||
translationTimeout: serviceConfig.translationTimeout, |
|||
enableAudioPlayback: serviceConfig.enableAudioPlayback |
|||
) |
|||
|
|||
updateConfiguration(newConfig: newConfig) |
|||
|
|||
os_log("语言已切换: %@ <-> %@", log: log, type: .info, newConfig.sourceLanguage, newConfig.targetLanguage) |
|||
} |
|||
|
|||
/** |
|||
* 推送外部音频数据 |
|||
*/ |
|||
public func pushAudioData(audioData: Data) { |
|||
audioProcessor?.saveAudioDataTo(data:audioData) |
|||
} |
|||
|
|||
/** |
|||
* 获取服务状态 |
|||
*/ |
|||
public func getServiceStatus() -> [String: Bool] { |
|||
return [ |
|||
"isInitialized": serviceState.isInitialized, |
|||
"isRecognizing": serviceState.isRecognizing, |
|||
"isTranslating": serviceState.isTranslating, |
|||
"isSynthesizing": serviceState.isSynthesizing |
|||
] |
|||
} |
|||
|
|||
/** |
|||
* 释放资源 |
|||
*/ |
|||
public func dispose() { |
|||
os_log("开始释放服务资源", log: log, type: .info) |
|||
|
|||
// 停止所有操作 |
|||
stopContinuousTranslation() |
|||
|
|||
// 释放Azure组件 |
|||
recognizer = nil |
|||
synthesizer = nil |
|||
speechConfig = nil |
|||
audioConfig = nil |
|||
|
|||
// 释放其他组件 |
|||
audioProcessor?.releaseAudioResources() |
|||
audioProcessor = nil |
|||
|
|||
translationService?.dispose() |
|||
translationService = nil |
|||
|
|||
recordFile?.closeFile(isSave: false) |
|||
recordFile = nil |
|||
|
|||
// 清理缓存 |
|||
voiceCache.removeAll() |
|||
|
|||
// 重置状态 |
|||
serviceState.isInitialized = false |
|||
serviceState.isRecognizing = false |
|||
serviceState.isTranslating = false |
|||
serviceState.isSynthesizing = false |
|||
|
|||
// 清理回调 |
|||
eventCallback = nil |
|||
|
|||
os_log("服务资源释放完成", log: log, type: .info) |
|||
} |
|||
} |
|||
|
|||
// MARK: - Helper Extensions |
|||
|
|||
/** |
|||
* 超时错误 |
|||
*/ |
|||
struct TimeoutError: Error { |
|||
let message: String |
|||
} |
|||
|
|||
/** |
|||
* 带超时的异步操作 |
|||
*/ |
|||
func withTimeout<T>(_ timeout: TimeInterval, operation: @escaping () async throws -> T) async throws -> T { |
|||
return try await withThrowingTaskGroup(of: T.self) { group in |
|||
group.addTask { |
|||
return try await operation() |
|||
} |
|||
|
|||
group.addTask { |
|||
try await Task.sleep(nanoseconds: UInt64(timeout * 1_000_000_000)) |
|||
throw TimeoutError(message: "操作超时") |
|||
} |
|||
|
|||
guard let result = try await group.next() else { |
|||
throw TimeoutError(message: "操作被取消") |
|||
} |
|||
|
|||
group.cancelAll() |
|||
return result |
|||
} |
|||
} |
|||
@ -0,0 +1,510 @@ |
|||
import Foundation |
|||
import CryptoKit |
|||
import os.log |
|||
|
|||
/** |
|||
* 火山翻译服务实现 |
|||
*/ |
|||
public class VolcanoTranslationServiceImpl: IntegratedSpeechTranslationService.TranslationServiceInterface { |
|||
|
|||
// MARK: - Constants |
|||
private let tag = "VolcanoTranslationService" |
|||
private let log = OSLog(subsystem: "com.azure.speech", category: "VolcanoTranslationService") |
|||
private let baseURL = "https://translate.volcengineapi.com" |
|||
private let endpoint = "/" |
|||
private let service = "translate" |
|||
private let version = "2020-06-01" |
|||
private let action = "TranslateText" |
|||
private let algorithm = "HMAC-SHA256" |
|||
|
|||
// MARK: - Properties |
|||
private var isInitialized = false |
|||
private var accessKey = "" |
|||
private var secretKey = "" |
|||
private var region = "cn-north-1" |
|||
private var maxRetryAttempts = 3 |
|||
private var timeout: TimeInterval = 10.0 |
|||
|
|||
// HTTP客户端 |
|||
private lazy var urlSession: URLSession = { |
|||
let config = URLSessionConfiguration.default |
|||
config.timeoutIntervalForRequest = 10.0 |
|||
config.timeoutIntervalForResource = 30.0 |
|||
return URLSession(configuration: config) |
|||
}() |
|||
|
|||
// 语言代码映射 |
|||
private let languageCodeMap: [String: String] = [ |
|||
"zh-CN": "zh", |
|||
"zh-TW": "zh-Hant", |
|||
"en-US": "en", |
|||
"en-GB": "en", |
|||
"ja-JP": "ja", |
|||
"ko-KR": "ko", |
|||
"fr-FR": "fr", |
|||
"de-DE": "de", |
|||
"es-ES": "es", |
|||
"ru-RU": "ru", |
|||
"ar-SA": "ar", |
|||
"pt-BR": "pt", |
|||
"it-IT": "it", |
|||
"th-TH": "th", |
|||
"vi-VN": "vi", |
|||
"hi-IN": "hi" |
|||
] |
|||
|
|||
// MARK: - TranslationServiceInterface Implementation |
|||
|
|||
/** |
|||
* 初始化翻译服务 |
|||
*/ |
|||
public func initialize(config: [String: String]) async -> Bool { |
|||
guard let accessKey = config["accessKey"], |
|||
let secretKey = config["secretKey"] else { |
|||
os_log("翻译服务配置缺失", log: log, type: .error) |
|||
return false |
|||
} |
|||
|
|||
self.accessKey = accessKey |
|||
self.secretKey = secretKey |
|||
self.region = config["region"] ?? "cn-north-1" |
|||
|
|||
if let maxRetryStr = config["maxRetryAttempts"], let maxRetry = Int(maxRetryStr) { |
|||
self.maxRetryAttempts = maxRetry |
|||
} |
|||
|
|||
if let timeoutStr = config["timeout"], let timeoutValue = Double(timeoutStr) { |
|||
self.timeout = timeoutValue |
|||
} |
|||
|
|||
isInitialized = true |
|||
os_log("火山翻译服务初始化成功", log: log, type: .info) |
|||
return true |
|||
} |
|||
|
|||
/** |
|||
* 翻译文本 |
|||
*/ |
|||
public func translateText( |
|||
text: String, |
|||
sourceLanguage: String, |
|||
targetLanguage: String |
|||
) async -> IntegratedSpeechTranslationService.TranslationResult { |
|||
|
|||
guard isInitialized else { |
|||
return IntegratedSpeechTranslationService.TranslationResult( |
|||
success: false, |
|||
error: "翻译服务未初始化" |
|||
) |
|||
} |
|||
|
|||
guard !text.trimmingCharacters(in: .whitespacesAndNewlines).isEmpty else { |
|||
return IntegratedSpeechTranslationService.TranslationResult( |
|||
success: false, |
|||
error: "翻译文本为空" |
|||
) |
|||
} |
|||
|
|||
os_log("开始翻译: %@ -> %@, 文本: %@", log: log, type: .info, sourceLanguage, targetLanguage, text) |
|||
|
|||
return await performTranslationWithRetry( |
|||
text: text, |
|||
sourceLanguage: sourceLanguage, |
|||
targetLanguage: targetLanguage |
|||
) |
|||
} |
|||
|
|||
/** |
|||
* 释放资源 |
|||
*/ |
|||
public func dispose() { |
|||
isInitialized = false |
|||
urlSession.invalidateAndCancel() |
|||
os_log("火山翻译服务已释放", log: log, type: .info) |
|||
} |
|||
|
|||
// MARK: - Private Methods |
|||
|
|||
/** |
|||
* 带重试的翻译执行 |
|||
*/ |
|||
private func performTranslationWithRetry( |
|||
text: String, |
|||
sourceLanguage: String, |
|||
targetLanguage: String |
|||
) async -> IntegratedSpeechTranslationService.TranslationResult { |
|||
|
|||
var lastError: String = "未知错误" |
|||
|
|||
for attempt in 1...maxRetryAttempts { |
|||
os_log("翻译尝试 %d/%d", log: log, type: .debug, attempt, maxRetryAttempts) |
|||
|
|||
let result = await performTranslation( |
|||
text: text, |
|||
sourceLanguage: sourceLanguage, |
|||
targetLanguage: targetLanguage |
|||
) |
|||
|
|||
if result.success { |
|||
os_log("翻译成功，尝试次数: %d", log: log, type: .info, attempt) |
|||
return result |
|||
} |
|||
|
|||
lastError = result.error ?? "翻译失败" |
|||
os_log("翻译尝试 %d 失败: %@", log: log, type: .default, attempt, lastError) |
|||
|
|||
// 最后一次尝试不需要等待 |
|||
if attempt < maxRetryAttempts { |
|||
let delay = TimeInterval(attempt) // 递增延迟 |
|||
try? await Task.sleep(nanoseconds: UInt64(delay * 1_000_000_000)) |
|||
} |
|||
} |
|||
|
|||
os_log("翻译最终失败，已尝试 %d 次", log: log, type: .error, maxRetryAttempts) |
|||
return IntegratedSpeechTranslationService.TranslationResult( |
|||
success: false, |
|||
error: "翻译失败，已重试 \(maxRetryAttempts) 次。最后错误: \(lastError)" |
|||
) |
|||
} |
|||
|
|||
/** |
|||
* 执行翻译 |
|||
*/ |
|||
private func performTranslation( |
|||
text: String, |
|||
sourceLanguage: String, |
|||
targetLanguage: String |
|||
) async -> IntegratedSpeechTranslationService.TranslationResult { |
|||
|
|||
do { |
|||
// 转换语言代码 |
|||
let sourceCode = getLanguageCode(languageCode: sourceLanguage) |
|||
let targetCode = getLanguageCode(languageCode: targetLanguage) |
|||
|
|||
// 构建请求体 |
|||
let requestBody: [String: Any] = [ |
|||
"TargetLanguage": targetCode, |
|||
"TextList": [text] |
|||
] |
|||
|
|||
// 如果源语言不是自动检测，则添加源语言 |
|||
var finalRequestBody = requestBody |
|||
if sourceCode != "auto" { |
|||
finalRequestBody["SourceLanguage"] = sourceCode |
|||
} |
|||
|
|||
let jsonData = try JSONSerialization.data(withJSONObject: finalRequestBody) |
|||
|
|||
// 构建查询参数 |
|||
let queryParams: [String: String] = [ |
|||
"Action": action, |
|||
"Version": version |
|||
] |
|||
|
|||
// 生成签名 |
|||
let headers = try generateSignature( |
|||
method: "POST", |
|||
requestBody: finalRequestBody, |
|||
queryParams: queryParams |
|||
) |
|||
|
|||
// 构建URL |
|||
var urlComponents = URLComponents(string: baseURL + endpoint)! |
|||
urlComponents.queryItems = queryParams.map { URLQueryItem(name: $0.key, value: $0.value) } |
|||
|
|||
guard let url = urlComponents.url else { |
|||
throw TranslationError.invalidURL |
|||
} |
|||
|
|||
// 创建请求 |
|||
var request = URLRequest(url: url) |
|||
request.httpMethod = "POST" |
|||
request.httpBody = jsonData |
|||
request.setValue("application/json", forHTTPHeaderField: "Content-Type") |
|||
|
|||
// 添加签名头 |
|||
for (key, value) in headers { |
|||
request.setValue(value, forHTTPHeaderField: key) |
|||
} |
|||
|
|||
os_log("发送翻译请求到: %@", log: log, type: .debug, url.absoluteString) |
|||
|
|||
// 发送请求 |
|||
let (data, response) = try await urlSession.data(for: request) |
|||
|
|||
guard let httpResponse = response as? HTTPURLResponse else { |
|||
throw TranslationError.invalidResponse |
|||
} |
|||
|
|||
os_log("翻译响应状态码: %d", log: log, type: .debug, httpResponse.statusCode) |
|||
|
|||
if httpResponse.statusCode == 200 { |
|||
// 解析响应 |
|||
guard let jsonObject = try JSONSerialization.jsonObject(with: data) as? [String: Any] else { |
|||
throw TranslationError.invalidJSON |
|||
} |
|||
|
|||
if let translatedText = extractTranslation(jsonResponse: jsonObject) { |
|||
os_log("翻译成功: %@", log: log, type: .info, translatedText) |
|||
return IntegratedSpeechTranslationService.TranslationResult( |
|||
success: true, |
|||
translatedText: translatedText, |
|||
confidence: 0.9 |
|||
) |
|||
} else if let error = extractError(jsonResponse: jsonObject) { |
|||
os_log("翻译API返回错误: %@", log: log, type: .error, error) |
|||
return IntegratedSpeechTranslationService.TranslationResult( |
|||
success: false, |
|||
error: error |
|||
) |
|||
} else { |
|||
throw TranslationError.noTranslationFound |
|||
} |
|||
} else { |
|||
let errorMessage = "HTTP错误: \(httpResponse.statusCode)" |
|||
if let errorData = String(data: data, encoding: .utf8) { |
|||
os_log("HTTP错误响应: %@", log: log, type: .error, errorData) |
|||
} |
|||
return IntegratedSpeechTranslationService.TranslationResult( |
|||
success: false, |
|||
error: errorMessage |
|||
) |
|||
} |
|||
|
|||
} catch { |
|||
os_log("翻译请求异常: %@", log: log, type: .error, error.localizedDescription) |
|||
return IntegratedSpeechTranslationService.TranslationResult( |
|||
success: false, |
|||
error: "翻译请求异常: \(error.localizedDescription)" |
|||
) |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 获取语言代码 |
|||
*/ |
|||
private func getLanguageCode(languageCode: String) -> String { |
|||
return languageCodeMap[languageCode] ?? languageCode |
|||
} |
|||
|
|||
/** |
|||
* 提取翻译结果 |
|||
*/ |
|||
private func extractTranslation(jsonResponse: [String: Any]) -> String? { |
|||
guard let responseMetadata = jsonResponse["ResponseMetadata"] as? [String: Any], |
|||
let error = responseMetadata["Error"] as? [String: Any] else { |
|||
// 没有错误，尝试提取翻译结果 |
|||
if let translationList = jsonResponse["TranslationList"] as? [[String: Any]], |
|||
let firstTranslation = translationList.first, |
|||
let translation = firstTranslation["Translation"] as? String { |
|||
return translation |
|||
} |
|||
return nil |
|||
} |
|||
|
|||
// 有错误信息 |
|||
return nil |
|||
} |
|||
|
|||
/** |
|||
* 提取错误信息 |
|||
*/ |
|||
private func extractError(jsonResponse: [String: Any]) -> String? { |
|||
if let responseMetadata = jsonResponse["ResponseMetadata"] as? [String: Any], |
|||
let error = responseMetadata["Error"] as? [String: Any] { |
|||
|
|||
let code = error["Code"] as? String ?? "UnknownError" |
|||
let message = error["Message"] as? String ?? "未知错误" |
|||
return "\(code): \(message)" |
|||
} |
|||
return nil |
|||
} |
|||
|
|||
/** |
|||
* 生成签名 |
|||
*/ |
|||
private func generateSignature( |
|||
method: String, |
|||
requestBody: [String: Any], |
|||
queryParams: [String: String] |
|||
) throws -> [String: String] { |
|||
|
|||
let now = Date() |
|||
let dateFormatter = DateFormatter() |
|||
dateFormatter.dateFormat = "yyyyMMdd'T'HHmmss'Z'" |
|||
dateFormatter.timeZone = TimeZone(abbreviation: "UTC") |
|||
let timestamp = dateFormatter.string(from: now) |
|||
|
|||
let shortDateFormatter = DateFormatter() |
|||
shortDateFormatter.dateFormat = "yyyyMMdd" |
|||
shortDateFormatter.timeZone = TimeZone(abbreviation: "UTC") |
|||
let shortDate = shortDateFormatter.string(from: now) |
|||
|
|||
// 构建规范请求 |
|||
let httpRequestMethod = method |
|||
let canonicalURI = endpoint |
|||
|
|||
// 构建规范查询字符串 |
|||
let sortedQueryParams = queryParams.sorted { $0.key < $1.key } |
|||
let canonicalQueryString = sortedQueryParams |
|||
.map { "\($0.key)=\($0.value.addingPercentEncoding(withAllowedCharacters: .urlQueryAllowed) ?? $0.value)" } |
|||
.joined(separator: "&") |
|||
|
|||
// 构建规范头部 |
|||
let host = URL(string: baseURL)!.host! |
|||
let canonicalHeaders = "host:\(host)\nx-date:\(timestamp)\n" |
|||
let signedHeaders = "host;x-date" |
|||
|
|||
// 计算请求体哈希 |
|||
let requestBodyData = try JSONSerialization.data(withJSONObject: requestBody) |
|||
let hashedRequestPayload = sha256(data: requestBodyData) |
|||
|
|||
// 构建规范请求 |
|||
let canonicalRequest = "\(httpRequestMethod)\n\(canonicalURI)\n\(canonicalQueryString)\n\(canonicalHeaders)\n\(signedHeaders)\n\(hashedRequestPayload)" |
|||
|
|||
// 创建待签字符串 |
|||
let credentialScope = "\(shortDate)/\(region)/\(service)/request" |
|||
let stringToSign = "\(algorithm)\n\(timestamp)\n\(credentialScope)\n\(sha256(string: canonicalRequest))" |
|||
|
|||
// 计算签名 |
|||
let kSecret = Data(secretKey.utf8) |
|||
let kDate = try hmacSha256(key: kSecret, data: shortDate) |
|||
let kRegion = try hmacSha256(key: kDate, data: region) |
|||
let kService = try hmacSha256(key: kRegion, data: service) |
|||
let kSigning = try hmacSha256(key: kService, data: "request") |
|||
let signature = try hmacSha256(key: kSigning, data: stringToSign) |
|||
let signatureHex = signature.map { String(format: "%02x", $0) }.joined() |
|||
|
|||
// 构建授权头 |
|||
let authorization = "\(algorithm) Credential=\(accessKey)/\(credentialScope), SignedHeaders=\(signedHeaders), Signature=\(signatureHex)" |
|||
|
|||
return [ |
|||
"Content-Type": "application/json", |
|||
"X-Date": timestamp, |
|||
"Authorization": authorization, |
|||
"Host": host |
|||
] |
|||
} |
|||
|
|||
/** |
|||
* SHA256哈希函数（字符串输入） |
|||
*/ |
|||
private func sha256(string: String) -> String { |
|||
let data = Data(string.utf8) |
|||
return sha256(data: data) |
|||
} |
|||
|
|||
/** |
|||
* SHA256哈希函数（数据输入） |
|||
*/ |
|||
private func sha256(data: Data) -> String { |
|||
let hash = SHA256.hash(data: data) |
|||
return hash.compactMap { String(format: "%02x", $0) }.joined() |
|||
} |
|||
|
|||
/** |
|||
* HMAC-SHA256函数 |
|||
*/ |
|||
private func hmacSha256(key: Data, data: String) throws -> Data { |
|||
let dataToSign = Data(data.utf8) |
|||
let symmetricKey = SymmetricKey(data: key) |
|||
let signature = HMAC<SHA256>.authenticationCode(for: dataToSign, using: symmetricKey) |
|||
return Data(signature) |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 翻译错误枚举 |
|||
*/ |
|||
enum TranslationError: Error { |
|||
case invalidURL |
|||
case invalidResponse |
|||
case invalidJSON |
|||
case noTranslationFound |
|||
case networkError(String) |
|||
case authenticationError |
|||
case rateLimitExceeded |
|||
case serviceUnavailable |
|||
|
|||
var localizedDescription: String { |
|||
switch self { |
|||
case .invalidURL: |
|||
return "无效的URL" |
|||
case .invalidResponse: |
|||
return "无效的响应" |
|||
case .invalidJSON: |
|||
return "无效的JSON格式" |
|||
case .noTranslationFound: |
|||
return "未找到翻译结果" |
|||
case .networkError(let message): |
|||
return "网络错误: \(message)" |
|||
case .authenticationError: |
|||
return "认证失败" |
|||
case .rateLimitExceeded: |
|||
return "请求频率超限" |
|||
case .serviceUnavailable: |
|||
return "服务不可用" |
|||
} |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 配置扩展 |
|||
*/ |
|||
extension TranslationConfiguration { |
|||
func toConfigMap() -> [String: String] { |
|||
var config: [String: String] = [ |
|||
"accessKey": accessKey, |
|||
"secretKey": secretKey, |
|||
"region": region |
|||
] |
|||
|
|||
if let maxRetry = maxRetryAttempts { |
|||
config["maxRetryAttempts"] = String(maxRetry) |
|||
} |
|||
|
|||
if let timeoutValue = timeout { |
|||
config["timeout"] = String(timeoutValue) |
|||
} |
|||
|
|||
return config |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 翻译配置类 |
|||
*/ |
|||
public struct TranslationConfiguration { |
|||
let accessKey: String |
|||
let secretKey: String |
|||
let region: String |
|||
let maxRetryAttempts: Int? |
|||
let timeout: TimeInterval? |
|||
|
|||
public init( |
|||
accessKey: String, |
|||
secretKey: String, |
|||
region: String = "cn-north-1", |
|||
maxRetryAttempts: Int? = nil, |
|||
timeout: TimeInterval? = nil |
|||
) { |
|||
self.accessKey = accessKey |
|||
self.secretKey = secretKey |
|||
self.region = region |
|||
self.maxRetryAttempts = maxRetryAttempts |
|||
self.timeout = timeout |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* Azure配置类 |
|||
*/ |
|||
public struct AzureConfiguration { |
|||
let subscriptionKey: String |
|||
let region: String |
|||
|
|||
public init(subscriptionKey: String, region: String) { |
|||
self.subscriptionKey = subscriptionKey |
|||
self.region = region |
|||
} |
|||
} |
|||
Loading…
Reference in new issue