debug

src/core/voip/bot.py

@@ -437,44 +437,63 @@ class ToTextBotAgent:
         self.to_quest(self.request_data)
 
 
-    def to_quest(self, request: BotChatRequest):
-        headers = {'Content-Type': 'application/json'}
+    def to_quest(self, request: BotChatRequest, try_count = 3):
         request_data = request.to_json_string()
         url = f"http://{SERVE_HOST}:40072/botservice"
         start_time = time.time()
         self.call_agent.logger.info(f"请求数据：{request_data},url:{url}")
         with requests.Session() as session:
             session.headers.update({'Content-Type': 'application/json'})
-            try:
-                response = session.post(url=url, json=json.loads(request_data), timeout=10)
-                # response = requests.post(url=url,  json=json.loads(request_data), headers=headers, timeout=10)  # 使用占位URL
-                self.call_agent.logger.info(f"sessionId={ self.call_agent.session_id}, chat::request:{request_data}, response：{response.text}")
-                if response.status_code == 200:
-                    response_data = response.json()
-                    if "data" in response_data and response_data["code"]==0:
-                        data = response_data["data"]
-                        parsed_response = ChatMessage.from_json(data)
-                        self.call_agent.message_queue.put(parsed_response)
+            response = None
+            while try_count > 0:
+                try:
+                    try_count = try_count - 1
+                    response = session.post(url=url, json=json.loads(request_data), timeout=.5)
+                    # response = requests.post(url=url,  json=json.loads(request_data), headers=headers, timeout=10)  # 使用占位URL
+                    self.call_agent.logger.info(f"sessionId={ self.call_agent.session_id}, chat::request:{request_data}, response：{response.text}")
+                    if response.status_code == 200:
+                        response_data = response.json()
+                        if "data" in response_data and response_data["code"]==0:
+                            data = response_data["data"]
+                            parsed_response = ChatMessage.from_json(data)
+                            self.call_agent.message_queue.put(parsed_response)
+                        else:
+                            self.call_agent.logger.info("响应中没有 'data' 字段")
                     else:
-                        self.call_agent.logger.info("响应中没有 'data' 字段")
-                else:
-                    # 错误处理
-                    response={"node_id":"100.01","contents":[{"content_type":"voice","content":"感谢您的来电，祝您生活愉快，再见！","voice_url":"/root/aibot/dm/voice/buy.wav","voice_content":""}],"wait_time":1,"action":{"action_code":"hang","action_content":"机器人挂断"},"inputType":"0"}
-                    parsed_response = ChatMessage.from_json(response)
-                    self.call_agent.message_queue.put(parsed_response)
-                    self.call_agent.logger.info(f"请求失败，状态码: {response.status_code}, 响应内容: {response.text}")
-            except requests.RequestException as e:
-                traceback.print_exc()
-                self.call_agent.logger.error(f"TaskId={request.taskId}, 请求发生异常: {e}, URL: {url}")
-                response={"node_id":"100.01","contents":[{"content_type":"voice","content":"感谢您的来电，祝您生活愉快，再见！","voice_url":"/root/aibot/dm/voice/buy.wav","voice_content":""}],"wait_time":1,"action":{"action_code":"hang","action_content":"机器人挂断"},"inputType":"0"}
-                parsed_response = ChatMessage.from_json(response)
-                self.call_agent.message_queue.put(parsed_response)
-            finally:
-                latency = (time.time() - start_time)
-                registry.BOT_REQUEST_COUNT.inc()
-                registry.BOT_REQUEST_LATENCY.labels(request.taskId).observe(latency)
-                session.close()
-
+                        self.call_agent.logger.info(f"请求失败，状态码: {response.status_code}, 响应内容: {response.text}")
+                    break
+                except requests.RequestException as e:
+                    traceback.print_exc()
+                    self.call_agent.logger.error(f"TaskId={request.taskId}, 请求发生异常: {e}, URL: {url}")
+
+            if not response or response.status_code != 200:
+                self.call_agent.message_queue.put(self.get_default_response())
+
+            latency = (time.time() - start_time)
+            registry.BOT_REQUEST_COUNT.inc()
+            registry.BOT_REQUEST_LATENCY.labels(request.taskId).observe(latency)
+            session.close()
+
+    def get_default_response(self):
+        response = {
+                    "node_id": "100.01",
+                    "contents": [
+                        {
+                            "content_type": "voice",
+                            "content": "感谢您的来电，祝您生活愉快，再见！",
+                            "voice_url": "/root/aibot/dm/voice/buy.wav",
+                            "voice_content": ""
+                        }
+                    ],
+                    "wait_time": 1,
+                    "action": {
+                        "action_code": "hang",
+                        "action_content": "机器人挂断"
+                    },
+                    "inputType": "0"
+                }
+        parsed_response = ChatMessage.from_json(response)
+        return parsed_response
 
 # 模拟接口请求返回
     def test_request(self, params: BotChatRequest):