fix: bug

src/core/callcenter/registry.py

@@ -16,7 +16,7 @@ CALL_BOT_ANSWER_REQUESTS = Counter('call_bot_answer_requests', '机器人接听
 CALL_BOT_TRANSFER_REQUESTS = Counter('call_bot_transfer_requests', '机器转人量', ['bucket'])
 CALL_BOT_HANGUP_REQUESTS = Counter('call_bot_hangup_requests', '机器挂机量', ['bucket','sip_status'])
 
-BOT_INTERACTION_ROUNDS = Counter('bot_interaction_rounds',  '机器人交互轮次',['taskId'] )
+
 BOT_REQUEST_COUNT = Counter('bot_request_count',  'Total number of bot requests')
 BOT_ASR_408 = Counter('bot_asr_408', 'ASR408 超时次数',['taskId'])
 
@@ -31,7 +31,7 @@ ESL_EVENT_CALLBACK_LATENCY = Histogram('esl_event_callback_latency', 'Esl Event
 
 BOT_CALL_DURATION = Histogram('bot_call_duration', '通话时长',['taskId'])
 BOT_REQUEST_LATENCY = Histogram('bot_request_latency','请求机器人耗时',['taskId'])
-
+BOT_INTERACTION_ROUNDS = Histogram('bot_interaction_rounds',  '机器人交互轮次',['taskId'] )
 
 
 FLASK_ACTIVE_THREADS = Gauge('flask_active_threads', 'Number of active threads')

src/core/voip/bot.py

@@ -216,6 +216,7 @@ class MyCall(pj.Call):
         self.inputLongStart = time.time()    #长按键开始时间
 
         self.inter_action_total = 0
+        self.statistics_lock = False
 
 
     def wait_time_check(self, current_time, wait_time):
@@ -285,6 +286,8 @@ class MyCall(pj.Call):
                 self.player = None  # 或调用播放器停止方法
             # 远程挂机之后要将分机号回收
             self.agent.release(self.user_part)
+            self.end_statistics()
+
 
     def onCallMediaState(self, prm):
         call_info = self.getInfo()
@@ -361,9 +364,12 @@ class MyCall(pj.Call):
             #更新通话记录
             self.agent.dataHandleServer.update_record(self.session_id, service_category=2)
     def end_statistics(self):
-        latency = (time.time() - self.start_time)
-        registry.BOT_CALL_DURATION.labels(self.taskId).observe(latency)
-        registry.BOT_INTERACTION_ROUNDS.labels(self.taskId).inc(self.inter_action_total)
+        if not self.statistics_lock:
+            self.statistics_lock = True
+            self.logger.info(f"self.inter_action_total:{self.inter_action_total}")
+            latency = (time.time() - self.start_time)
+            registry.BOT_CALL_DURATION.labels(self.taskId).observe(latency)
+            registry.BOT_INTERACTION_ROUNDS.labels(self.taskId).observe(self.inter_action_total)
 
 class ToTextBotAgent:
     def __init__(self, user_asr_text, call_agent):