讯飞实时听写接口,debug

src/core/voip/asr.py

@@ -400,15 +400,15 @@ class XunfeiAsr:
     def start(self):
         self.__th.start()
 
-    def send_audio(self, audio_data=None):
+    def send_audio(self, audio_data=None, latest=False):
         if not self.connected:
             self.logger.info('xunfei.Asr.send_audio:ws_is_None: call_id: %s, chunk:%s, %s', self.__id, len(audio_data), audio_data)
             return
 
-        if not audio_data:
+        if latest:
             self.status = XunfeiAsr.STATUS_LAST_FRAME
         buf = bytes(audio_data) if audio_data else bytes()
-        # self.logger.info('xunfei.Asr.send_audio: call_id: %s, status:%s, chunk:%s, %s', self.__id, status, (len(buf) if buf else 0) , buf)
+        self.logger.info('xunfei.Asr.send_audio: call_id: %s, status:%s, chunk:%s', self.__id, self.status, (len(buf) if buf else 0))
 
         # 第一帧处理
         # 发送第一帧音频，带business 参数
@@ -438,7 +438,7 @@ class XunfeiAsr:
 
     def close(self):
         try:
-            self.send_audio()
+            self.send_audio(latest=True)
             self.ws.close()
         except Exception as e:
             self.logger.info(f"[{self.__id}]Error stopping ASR: {e}")
@@ -446,6 +446,7 @@ class XunfeiAsr:
     # 收到websocket连接建立的处理
     def on_open(self, ws):
         self.connected = True
+        self.status = XunfeiAsr.STATUS_FIRST_FRAME
         self.logger.info("xunfei.Asr.open: call_id: %s", self.__id)
         # self.__event.set()