From 49d0aa317020f78b9e86c6e443f701c03d4a6f6d Mon Sep 17 00:00:00 2001
From: tanlongsheng <252620078@qq.com>
Date: Mon, 15 Dec 2025 19:45:17 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=AF=AD=E9=9F=B3=E8=AF=86?=
 =?UTF-8?q?=E5=88=AB=E4=BC=9A=E8=AF=9DID=E5=A4=84=E7=90=86=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../agent_service/AgentService.kt             | 25 ++++++++++++++-----
 1 file changed, 19 insertions(+), 6 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 6a6dade10..70018fff2 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
@@ -135,6 +135,7 @@ object AgentService : CoroutineScope {
     // AI流生成相关
     private var currentAiJob: Job? = null
     private var currsessionId: String = ""
+    private var currsessionAsrId: String = ""
 
     private var vipExptime:Int = 0
 
@@ -687,13 +688,14 @@ object AgentService : CoroutineScope {
                                 )
                             )
                         }else{
-                            text = recognitionResult + recognizing
-                            if(recognitionResult.isEmpty()){
-                                currsessionId = sessionid
+                            if(currsessionAsrId.isEmpty()) {
+                                currsessionAsrId = sessionid
                             }
+                            text = recognitionResult + recognizing
+                            
                             sendEvent(
                                     "recognizing", mapOf(
-                                    "sessionid" to currsessionId,
+                                    "sessionid" to currsessionAsrId,
                                     "text" to  text,
                                     "language" to detectedLanguage
                                 )
@@ -742,20 +744,31 @@ object AgentService : CoroutineScope {
                                 )
                             )
                         }else{
+                            if (currsessionAsrId.isEmpty()) {
+                                currsessionAsrId = sessionid
+                            }
                             recognitionResult += result
                             pendingProcessJob?.cancel()
+                            sendEvent(
+                                "recognizing", mapOf(
+                                    "sessionid" to currsessionAsrId,
+                                    "text" to  recognitionResult,
+                                    "language" to detectedLanguage
+                                )
+                            )
                             pendingProcessJob = launch {
                                 delay(2000)
                                 if (recognitionResult.isNotEmpty()) {
                                     sendEvent(
                                         "recognition_result", mapOf(
-                                            "sessionid" to currsessionId,
+                                            "sessionid" to currsessionAsrId,
                                             "text" to recognitionResult,
                                             "language" to detectedLanguage
                                         )
                                     )
-                                    processWithChatApi(currsessionId, recognitionResult)
+                                    processWithChatApi(currsessionAsrId, recognitionResult)
                                     recognitionResult = ""
+                                    currsessionAsrId = ""
                                 }
                             }
                         }