讯飞asr测试,debug

src/core/voip/asr.py

@@ -219,7 +219,7 @@ class XfAsr:
         from websocket import create_connection
         # import websocket
         from urllib.parse import quote
-        import logging
+        # import logging
 
         # logging.basicConfig()
 
@@ -250,24 +250,6 @@ class XfAsr:
     def start(self):
         self.trecv.start()
 
-    # def send(self, file_path):
-    #     file_object = open(file_path, 'rb')
-    #     try:
-    #         index = 1
-    #         while True:
-    #             chunk = file_object.read(1280)
-    #             if not chunk:
-    #                 break
-    #             self.ws.send(chunk)
-    #
-    #             index += 1
-    #             time.sleep(0.04)
-    #     finally:
-    #         file_object.close()
-    #
-    #     self.ws.send(bytes(self.end_tag.encode('utf-8')))
-    #     print("send end tag success")
-
     def send_audio(self, chunk):
         self.logger.info('xunfei.Asr.send_audio: call_id: %s, chunk:%s, %s', self.tid, len(chunk), chunk)
         if self.ws:
@@ -281,9 +263,6 @@ class XfAsr:
 
     def recv(self):
         try:
-            # {"seg_id": 0, "cn": {"st": {"rt": [{"ws": [{"cw": [{"sc": 0.00, "w": "凭", "wp": "n", "rl": "0", "wb": 13, "wc": 0.00, "we": 26}], "wb": 0, "we": 0}]}], "bg": "9510", "type": "1", "ed": "0"}}, "ls": false}
-            # {"seg_id": 1, "cn": {"st": {"rt": [{"ws": [{"cw": [{"sc": 0.00, "w": "停水", "wp": "n", "rl": "0", "wb": 26, "wc": 0.00, "we": 52}], "wb": 0,"we": 0}]}], "bg": "9770", "type": "1", "ed": "0"}}, "ls": false}
-            # {"seg_id": 2, "cn": {"st": {"rt": [{"ws": [{"cw": [{"sc": 0.00, "w": "停水", "wp": "n", "rl": "0", "wb": 9, "wc": 0.00, "we": 64}], "wb": 9,"we": 64},{"cw": [{"sc": 0.00, "w": "咨询", "wp": "n", "rl": "0", "wb": 65, "wc": 0.00, "we": 132}], "wb": 65,"we": 132}]}], "bg": "9510", "type": "0", "ed": "10950"}}, "ls": false}
             self.logger.info(f"xunfei.Asr.recv: call_id: {self.tid}, ws.connected:{self.ws.connected}")
             while self.ws and self.ws.connected:
                 message = str(self.ws.recv())
@@ -295,23 +274,6 @@ class XfAsr:
                 if self.message_receiver:
                     self.message_receiver(self.convert_message(message))
 
-                # result_dict = json.loads(result)
-                # # 解析结果
-                # if result_dict["action"] == "started":
-                #     self.logger.info("xunfei.Asr.recv: handshake success, result: " + result)
-                #
-                #
-                # if result_dict["action"] == "result":
-                #     result_1 = result_dict
-                #     # result_2 = json.loads(result_1["cn"])
-                #     # result_3 = json.loads(result_2["st"])
-                #     # result_4 = json.loads(result_3["rt"])
-                #     self.logger.info("xunfei.Asr.recv: rtasr result: " + result_1["data"])
-                #
-                # if result_dict["action"] == "error":
-                #     self.logger.info("xunfei.Asr.recv: rtasr error: " + result)
-                #     self.ws.close()
-                #     return
         except Exception as e:
             traceback.print_exc()
             self.logger.error("xunfei.Asr.recv: receive result end, call_id: %s, message: %s", self.tid, e)