Merge branch 'develop' of ssh://gitlab.fuxicarbon.com:1111/client_service/voice-gateway-service into develop

src/core/callcenter/data_handler.py

@@ -19,7 +19,7 @@ class DataHandleServer:
             "service_category": service_category,
             "user_id":user_id,
             "user_name": user_name,
-            'status': 0
+            'status': 1 if category==0 and call_type == 1 else 0  # 如果通话类型啥呼入并且走到ai 是接通状态 否则默认是未接通
         }
         call_record = CallRecord()
         self.app.logger.info(f"创建通话记录: {call_info}")

src/core/callcenter/esl/client.py

@@ -184,7 +184,7 @@ class InboundClient:
 
             self.cache.add_call_info(call_info)
             self.hangup_call(call_id, device_id, CallCause.CALL_TIMEOUT)
-            self.dataHandleServer.update_record(call_id, status= 0)
+            # self.dataHandleServer.update_record(call_id, status= 0)
 
     def exec_when_play_timeout(self, call_id):
         call_info = self.cache.get_call_info(call_id)
@@ -213,7 +213,7 @@ class InboundClient:
             next_command = NextCommand(device_id = device_id, next_type=NextType.NEXT_HANGUP.code)
             call_info.next_commands = [next_command]
             self.cache.add_call_info(call_info)
-            self.dataHandleServer.update_record(call_id, status= 0)
+            # self.dataHandleServer.update_record(call_id, status= 0)
             self.logger.info("waitingTimeOut 开始播放结束音乐 callId:%s customerDeviceId:%s playFile:%s", call_id,
                              device_id, WaitingHangupMusicPath)
 

src/core/callcenter/esl/handler/channel_hangup_handler.py

@@ -162,10 +162,10 @@ class ChannelHangupHandler(EslEventHandler):
     def _update_record_in_thread(self, call_id, records, sip_status, hangup_cause, answer_count):
         """用于在独立线程中执行 update_record"""
         try:
-            status = 0 if answer_count <= 0 else 1
+            # status = 0 if answer_count <= 0 else 1
             if len(records) == 0:
                 self.logger.warning("没有录音文件，直接更新记录: call_id=%s, sip_status=%s, hangup_cause=%s", call_id, sip_status, hangup_cause)
-                self.dataHandleServer.update_record(call_id, time_end=datetime.now(), sip_status=sip_status, sip_hangup_cause=hangup_cause, status=status)
+                self.dataHandleServer.update_record(call_id, time_end=datetime.now(), sip_status=sip_status, sip_hangup_cause=hangup_cause)
                 return
             merge_record = self.merge_audio_files(records) if len(records) > 1 else records[0]
             # try:
@@ -175,7 +175,7 @@ class ChannelHangupHandler(EslEventHandler):
             # except Exception as chmod_error:
             #     self.logger.error("设置文件权限失败: %s, error: %s", merge_record, str(chmod_error))
 
-            self.dataHandleServer.update_record(call_id, time_end=datetime.now(), url=merge_record, sip_status=sip_status, sip_hangup_cause=hangup_cause, status=status)
+            self.dataHandleServer.update_record(call_id, time_end=datetime.now(), url=merge_record, sip_status=sip_status, sip_hangup_cause=hangup_cause)
             self.logger.info("更新录音记录完成: call_id=%s", call_id)
         except Exception as e:
             self.logger.error("更新录音记录失败: call_id=%s, error=%s", call_id, str(e))