From 7a73fb118488ff33ea2ad2df8027511719604920 Mon Sep 17 00:00:00 2001 From: liwei1dao Date: Thu, 11 Dec 2025 19:28:50 +0800 Subject: [PATCH] =?UTF-8?q?feat(=E8=AF=AD=E9=9F=B3=E8=AF=86=E5=88=AB):=20?= =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=8C=89=E4=BD=8F=E8=AF=B4=E8=AF=9D=E6=A8=A1?= =?UTF-8?q?=E5=BC=8F=E7=9A=84=E8=AF=86=E5=88=AB=E7=BB=93=E6=9E=9C=E5=A4=84?= =?UTF-8?q?=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 修改AzureAsrHelper中会话结束事件的条件判断，移除外部音频源限制 在AgentService中添加识别结果缓存，改进按住说话模式下的结果拼接和事件发送 --- .../agent_service/AgentService.kt | 85 +++++++++++++------ .../azure_speech/AzureAsrHelper.kt | 4 +- 2 files changed, 63 insertions(+), 26 deletions(-) diff --git a/local_plugins/agent_service/android/src/main/kotlin/com/yunqiinnovation/agent_service/AgentService.kt b/local_plugins/agent_service/android/src/main/kotlin/com/yunqiinnovation/agent_service/AgentService.kt index e931fc06c..710159297 100644 --- a/local_plugins/agent_service/android/src/main/kotlin/com/yunqiinnovation/agent_service/AgentService.kt +++ b/local_plugins/agent_service/android/src/main/kotlin/com/yunqiinnovation/agent_service/AgentService.kt @@ -149,6 +149,8 @@ object AgentService : CoroutineScope { private var isplaymusic = false; //是否保留最终结果 private var isKeepResult = true; + // 识别结果 + private var recognitionResult = "" // 打断防抖相关 private var lastInterruptTime = 0L @@ -643,7 +645,7 @@ object AgentService : CoroutineScope { // 根据模式启动相应的空闲检测 startIdleCheckForMode(mode) - // 设置当前识别模式 + // 设置当前识别模式 currentRecognitionMode = mode Log.d(TAG, "设置语音识别模式: $mode") return true @@ -666,20 +668,33 @@ object AgentService : CoroutineScope { val success = azureAsrHelper?.setupEventListeners(object : AzureAsrHelper.ContinuousRecognizeCallback { override fun onRecognizing(sessionid:String, recognizing: String, detectedLanguage: String) { + Log.d(TAG, "liwei-------- onRecognizing: $sessionid") if (recognizing.isNotEmpty()&&isKeepResult==true) { // 检测到语音，更新状态 _hasSpeechDetected.set(true) Log.d(TAG, "ai识别中重置定时器") restartIdleCheck() - - - sendEvent( - "recognizing", mapOf( - "sessionid" to sessionid, - "text" to recognizing, - "language" to detectedLanguage + var text = "" + if (currentRecognitionMode == "push_to_talk") { + text = recognitionResult + recognizing + sendEvent( + "recognizing", mapOf( + "sessionid" to currsessionId, + "text" to text, + "language" to detectedLanguage + ) ) - ) + }else{ + text = recognizing + sendEvent( + "recognizing", mapOf( + "sessionid" to sessionid, + "text" to text, + "language" to detectedLanguage + ) + ) + } + // 如果TTS正在播放或AI正在生成，检查是否需要打断 if (isTtsSpeaking || isAiStreaming) { @@ -709,45 +724,66 @@ object AgentService : CoroutineScope { } override fun onResult(sessionid:String,result: String, detectedLanguage: String) { + Log.d(TAG, "liwei-------- onResult: $sessionid ") if (result.isNotEmpty()&&isKeepResult==true) {//加入是否结束要输出最后的结果判读 - sendEvent( - "recognition_result", mapOf( - "sessionid" to sessionid, - "text" to result, - "language" to detectedLanguage + // 保存识别结果 + if (currentRecognitionMode == "push_to_talk") { //按住说话 + recognitionResult += result + }else{ + sendEvent( + "recognition_result", mapOf( + "sessionid" to sessionid, + "text" to result, + "language" to detectedLanguage + ) ) - ) - - processWithChatApi(sessionid,result) + processWithChatApi(sessionid,result) + } } - _hasSpeechDetected.set(false) - restartIdleCheck() + restartIdleCheck() } override fun onSessionStarted(sessionid:String) { + Log.d(TAG, "liwei-------- onSessionStarted: $sessionid") sendEvent("recognition_started", mapOf("sessionid" to sessionid, "status" to "started")) // 使用模式感知的空闲检测启动方法 + recognitionResult = "" + currsessionId = sessionid audioPlayer?.playAudio(R.raw.start) - } override fun onSessionStopped(sessionid:String) { - sendEvent("recognition_stopped", mapOf("sessionid" to sessionid, "status" to "stopped")) - _isRecognitionActive.set(false) + Log.d(TAG, "liwei-------- onSessionStopped: $sessionid") + if (currentRecognitionMode == "push_to_talk") { //按住说话 + sendEvent( + "recognition_result", mapOf( + "sessionid" to currsessionId, + "text" to recognitionResult + ) + ) + processWithChatApi(currsessionId,recognitionResult) + + sendEvent("recognition_stopped", mapOf("sessionid" to currsessionId, "status" to "stopped")) + }else{ + sendEvent("recognition_stopped", mapOf("sessionid" to sessionid, "status" to "stopped")) + + audioPlayer?.playAudio(R.raw.stop) + } stopIdleCheck() - audioPlayer?.playAudio(R.raw.stop) + _isRecognitionActive.set(false) + } override fun onCanceled(sessionid: String,reason: String, errorDetails: String) { + Log.d(TAG, "liwei-------- onCanceled: $sessionid $reason $errorDetails") _isRecognitionActive.set(false) stopIdleCheck() - Log.d(TAG, "recognition_canceled:") BleService.closeCodec() sendEvent( "recognition_canceled", mapOf( @@ -759,6 +795,7 @@ object AgentService : CoroutineScope { } override fun onError(sessionid:String, code: Int, error: String) { + Log.d(TAG, "liwei-------- onError: $sessionid $code $error") _isRecognitionActive.set(false) stopIdleCheck() BleService.closeCodec() diff --git a/local_plugins/azure_speech/android/src/main/kotlin/com/yunqiinnovation/azure_speech/AzureAsrHelper.kt b/local_plugins/azure_speech/android/src/main/kotlin/com/yunqiinnovation/azure_speech/AzureAsrHelper.kt index a7fc47c20..58fc353b3 100644 --- a/local_plugins/azure_speech/android/src/main/kotlin/com/yunqiinnovation/azure_speech/AzureAsrHelper.kt +++ b/local_plugins/azure_speech/android/src/main/kotlin/com/yunqiinnovation/azure_speech/AzureAsrHelper.kt @@ -421,10 +421,10 @@ class AzureAsrHelper(private val context: Context) { EventHandler { _, _ -> // 直接在当前线程调用回调 Log.d(tag, "会话结束事件") - if (audioSourceType == AudioSourceType.EXTERNAL) { + // if (audioSourceType == AudioSourceType.EXTERNAL) { callback.onSessionStopped(currsessionid) audioStream?.isContinuousRecognitionActive = false - } + // } } )