debug

src/core/voip/bot.py

@@ -82,45 +82,45 @@ class MyAudioMediaPort(pj.AudioMediaPort):
                 self.call.logger.info("Received audio frame: %s %s", frame.buf, frame.size)
             self.asr.send_audio(frame.buf)
 
-        try:
-            asr_text = self.get_asr_text()
-            play_complete = self.call.is_play_complete()
-            current_time = time.time() # 实时当前时间
-            if self.call.inputType == '1.0':
-                time_difference = int(current_time - self.call.inputLongStart)
-                # print('current_time - self.call.inputLongStart:',time_difference > 35, self.call.txtLock , play_complete)
-                if time_difference > 35 and play_complete:
-                    self.user_asr_texts.append(f"DTMF({self.call.digit})DTMF")
-                    user_asr_text = self.user_asr_texts[0] if len(self.user_asr_texts) == 1 else '###'.join(self.user_asr_texts)
-                    self.user_asr_texts.clear()
-                    self.call.chat(user_asr_text)
-                    # print("测试超长", user_asr_text)
-                elif asr_text:
-                    self.user_asr_texts.append(asr_text)
-                if time_difference > int(self.call.wait_time):
-                    self.call.reset_wait_time()
-            else:
-                if asr_text and not play_complete:
-                    self.user_asr_texts.append(asr_text)
-                if (asr_text and play_complete) or (play_complete and self.user_asr_texts):
-                    if asr_text:
-                        self.user_asr_texts.append(asr_text)
-                    user_asr_text = self.user_asr_texts[0] if len(self.user_asr_texts) == 1 else '###'.join(self.user_asr_texts)
-                    self.user_asr_texts.clear()
-                    self.call.chat(user_asr_text)
-
-            if self.call.wait_time and self.call.wait_time != "0" and play_complete and not asr_text:
-                self.call.wait_time_check(current_time, self.call.wait_time)
-
-            message_queue_size = self.call.message_queue.qsize()
-            if (message_queue_size > 0 and not self.call.cur_player_file) or (message_queue_size > 0 and play_complete):
-                # self.call.logger.info('onFrameReceived:message_queue_size=', message_queue_size, 'play_complete=', play_complete, asr_text)
-                self.call.cur_player_file, self.call.wait_time, self.call.inputType,self.call.action, self.call.node_id = self.get_player_file()
-                # 重置播放完成标志和超时计时器，确保新的播放从头开始计时
-                self.call.reset_wait_time()
-                self.call.send_bot_speaker(self.call.cur_player_file)
-        except:
-            pass
+        # try:
+        #     asr_text = self.get_asr_text()
+        #     play_complete = self.call.is_play_complete()
+        #     current_time = time.time() # 实时当前时间
+        #     if self.call.inputType == '1.0':
+        #         time_difference = int(current_time - self.call.inputLongStart)
+        #         # print('current_time - self.call.inputLongStart:',time_difference > 35, self.call.txtLock , play_complete)
+        #         if time_difference > 35 and play_complete:
+        #             self.user_asr_texts.append(f"DTMF({self.call.digit})DTMF")
+        #             user_asr_text = self.user_asr_texts[0] if len(self.user_asr_texts) == 1 else '###'.join(self.user_asr_texts)
+        #             self.user_asr_texts.clear()
+        #             self.call.chat(user_asr_text)
+        #             # print("测试超长", user_asr_text)
+        #         elif asr_text:
+        #             self.user_asr_texts.append(asr_text)
+        #         if time_difference > int(self.call.wait_time):
+        #             self.call.reset_wait_time()
+        #     else:
+        #         if asr_text and not play_complete:
+        #             self.user_asr_texts.append(asr_text)
+        #         if (asr_text and play_complete) or (play_complete and self.user_asr_texts):
+        #             if asr_text:
+        #                 self.user_asr_texts.append(asr_text)
+        #             user_asr_text = self.user_asr_texts[0] if len(self.user_asr_texts) == 1 else '###'.join(self.user_asr_texts)
+        #             self.user_asr_texts.clear()
+        #             self.call.chat(user_asr_text)
+        #
+        #     if self.call.wait_time and self.call.wait_time != "0" and play_complete and not asr_text:
+        #         self.call.wait_time_check(current_time, self.call.wait_time)
+        #
+        #     message_queue_size = self.call.message_queue.qsize()
+        #     if (message_queue_size > 0 and not self.call.cur_player_file) or (message_queue_size > 0 and play_complete):
+        #         # self.call.logger.info('onFrameReceived:message_queue_size=', message_queue_size, 'play_complete=', play_complete, asr_text)
+        #         self.call.cur_player_file, self.call.wait_time, self.call.inputType,self.call.action, self.call.node_id = self.get_player_file()
+        #         # 重置播放完成标志和超时计时器，确保新的播放从头开始计时
+        #         self.call.reset_wait_time()
+        #         self.call.send_bot_speaker(self.call.cur_player_file)
+        # except:
+        #     pass
 
     def get_asr_text(self):
         try: