debug

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

@@ -6,7 +6,7 @@ import sys
 import traceback
 
 from src.core.callcenter.acd import AcdService
-from src.core.callcenter.call import CallService
+from src.core.callcenter.call_info import CallService
 from src.core.callcenter.enumeration import CallType, DeviceType, AnswerFlag, NextType, CdrType, HangupDir, \
     CallCause,AgentServiceState,AgentScene
 from src.core.callcenter.esl.annotation import EslEventName
@@ -36,23 +36,23 @@ class ChannelHangupHandler(EslEventHandler):
                 self.release(event)
                 self.logger.info("call_id is null")
                 return
-            call = self.cache.get_call_info(call_id)
-            self.logger.info('call_info is %s', call)
-            if not call:
-                self.logger.info("call:%s is null", call_id)
+            call_info = self.cache.get_call_info(call_id)
+            self.logger.info('call_info is %s', call_info)
+            if not call_info:
+                self.logger.info("call_info:%s is null", call_id)
                 return
             device_id = EslEventUtil.getDeviceId(event)
             device_id = device_id if device_id else EslEventUtil.getUniqueId(event)
-            device = call.device_info_map.get(device_id)
+            device_info = call_info.device_info_map.get(device_id)
             # self.logger.info('device_id is ', device_id)
-            if not device:
-                self.logger.info("device:%s is null", device_id)
+            if not device_info:
+                self.logger.info("device_info:%s is null", device_id)
                 return
 
-            count = len(call.device_list)
+            count = len(call_info.device_list)
             self.logger.info('ChannelHangupHandler, call_id=%s, device_id=%s, count=%s'% (call_id, device_id, count))
             try:
-                call.device_list.remove(device_id)
+                call_info.device_list.remove(device_id)
             except:
                 pass
             cause = EslEventUtil.getCallHangupCause(event)
@@ -66,57 +66,56 @@ class ChannelHangupHandler(EslEventHandler):
             hangup_cause = EslEventUtil.getVariableSipHPLIBRAHangupCause(event)
             hangup_reason = EslEventUtil.getLIBRAHangupReason(event)
 
-            device.hangup_cause = cause
-            device.sip_protocol = sip_protocol
-            device.sip_status = sip_status
-            device.channel_name = channel_name
-            device.end_time = timestamp
+            device_info.hangup_cause = cause
+            device_info.sip_protocol = sip_protocol
+            device_info.sip_status = sip_status
+            device_info.channel_name = channel_name
+            device_info.end_time = timestamp
 
             # 计算通话时长
-            if device.answer_time:
-                device.talk_time = int(device.end_time) - int(device.answer_time)
+            if device_info.answer_time:
+                device_info.talk_time = int(device_info.end_time) - int(device_info.answer_time)
             else:
-                device.ring_start_time = device.end_time
+                device_info.ring_start_time = device_info.end_time
             # 计算录音时长
-            if device.record_start_time:
-                device.record_time = int(device.end_time) - int(device.record_start_time)
-            call.device_info_map[device.device_id] = device
-
-            skip_hangup_all = device.device_type == DeviceType.ROBOT.code
+            if device_info.record_start_time:
+                device_info.record_time = int(device_info.end_time) - int(device_info.record_start_time)
+            call_info.device_info_map[device_info.device_id] = device_info
+            skip_hangup_all = device_info.device_type == DeviceType.ROBOT.code
 
             # 更新通话记录
-            # self.dataHandleServer.update_record(call_id, {"time_end": datetime.fromtimestamp(int(device.end_time)),"times":device.talk_time})
+            # self.dataHandleServer.update_record(call_id, {"time_end": datetime.fromtimestamp(int(device_info.end_time)),"times":device_info.talk_time})
 
-            self.logger.info('ChannelHangupHandler, hangup_reason=%s, device_type=%s, cdr_type=%s, end_time=%s, skip_hangup_all=%s' % (hangup_reason, device.device_type, device.cdr_type, call.end_time, skip_hangup_all))
+            self.logger.info('ChannelHangupHandler, hangup_reason=%s, device_type=%s, cdr_type=%s, end_time=%s, skip_hangup_all=%s' % (hangup_reason, device_info.device_type, device_info.cdr_type, call_info.end_time, skip_hangup_all))
             # 如果是转人工
-            # if 'transferToAgent' == hangup_reason and DeviceType.ROBOT.code == device.device_type:
-            #     call.answer_flag = AnswerFlag.TRANSFER_TO_AGENT.code
+            # if 'transferToAgent' == hangup_reason and DeviceType.ROBOT.code == device_info.device_type:
+            #     call_info.answer_flag = AnswerFlag.TRANSFER_TO_AGENT.code
             #     service_id = EslEventUtil.getLIBRAServiceId(event)
-            #     call.transfer_agent = True
-            #     self.cache.add_call_info(call)
+            #     call_info.transfer_agent = True
+            #     self.cache.add_call_info(call_info)
             #     self.logger.info('ChannelHangupHandler, transferToAgent, service_id=%s' % (service_id))
-            #     self.acd_service.transfer_to_agent(call, device_id, service_id)
+            #     self.acd_service.transfer_to_agent(call_info, device_id, service_id)
             #     return
 
             # 如果有下一步
-            # next_command = call.next_commands[0] if len(call.next_commands) > 0 else None
+            # next_command = call_info.next_commands[0] if len(call_info.next_commands) > 0 else None
             # if next_command:
-            #     self.next_cmd(call, device, next_command, cause)
+            #     self.next_cmd(call_info, device_info, next_command, cause)
             #     return
             # 一般情况下，挂断其他所有设备
-            if device.cdr_type <= 4 and not call.end_time and not skip_hangup_all:
-                # call.end_time = device.end_time
-                self.logger.info("liuwei::debugger::hang_all, call_info:%s, device_info:%s"%(call,device))
-                self.call_service.hangup_all(call, CallCause.HANGUP_EVENT)
+            if device_info.cdr_type <= 4 and not call_info.end_time and not skip_hangup_all:
+                # call_info.end_time = device_info.end_time
+                self.logger.info("liuwei::debugger::hang_all, call_info:%s, device_info:%s"%(call_info,device_info))
+                self.call_service.hangup_all(call_info, CallCause.HANGUP_EVENT)
                 # self.inbound_client.hangup_call(call_id, device_id, CallCause.HANGUP_EVENT)
 
             # 判断挂机方向 && 更新缓存
-            self.hangup_dir(call, device, cause)
-            self.cache.add_call_info(call)
+            self.hangup_dir(call_info, device_info, cause)
+            self.cache.add_call_info(call_info)
 
-            if device.device_type == DeviceType.AGENT.code:
+            if device_info.device_type == DeviceType.AGENT.code:
                 self.dataHandleServer.update_agent_monitor_service_state(device_id, AgentServiceState.IDLE.code)
-                self.push_handler.push_on_call_end(call.cti_flow_id,call.agent_key,AgentScene.ROBOT,call.direction, device.device_type)
+                self.push_handler.push_on_call_end(call_info.cti_flow_id,call_info.agent_key,AgentScene.ROBOT,call_info.direction, device_info.device_type)
         except:
             traceback.print_exc()
 
@@ -126,7 +125,7 @@ class ChannelHangupHandler(EslEventHandler):
         self.logger.info(f"release device_id={device_id}, user_part={user_part}")
         self.bot_agent.release(user_part)
 
-    def next_cmd(self, call: CallInfo, device: DeviceInfo, next_command: NextCommand, cause):
+    def next_cmd(self, call_info: CallInfo, device_info: DeviceInfo, next_command: NextCommand, cause):
         # 呼入转到坐席，坐席拒接和坐席sip呼不通的时候，都需要再次转回来到技能组排队。
         if NextType.NEXT_CALL_BRIDGE.code == next_command.next_type or NextType.NEXT_LISTEN_CALL.code == next_command.next_type:
             pass
@@ -136,21 +135,21 @@ class ChannelHangupHandler(EslEventHandler):
             pass
 
         if not next_command or NextType.NEXT_HANGUP.code != next_command.next_type:
-            call.next_commands.remove(next_command)
+            call_info.next_commands.remove(next_command)
 
         # 判断挂机方向 && 更新缓存
-        self.hangup_dir(call, device, cause)
-        self.cache.add_call_info(call)
+        self.hangup_dir(call_info, device_info, cause)
+        self.cache.add_call_info(call_info)
 
-    def hangup_dir(self, call:CallInfo, device:DeviceInfo, cause):
-        if call.hangup_dir or device.cdr_type > CdrType.CONSULT.code:
-            self.logger.info("hangup_dir::hangup_dir :%s, cdr_type :%s", call.hangup_dir, device.cdr_type)
+    def hangup_dir(self, call_info:CallInfo, device_info:DeviceInfo, cause):
+        if call_info.hangup_dir or device_info.cdr_type > CdrType.CONSULT.code:
+            self.logger.info("hangup_dir::hangup_dir :%s, cdr_type :%s", call_info.hangup_dir, device_info.cdr_type)
             return
-        if DeviceType.AGENT.code == device.device_type:
-            call.hangup_dir = HangupDir.HOST_HANGUP.code
-        elif DeviceType.CUSTOMER.code == device.device_type:
-            call.hangup_dir = HangupDir.CUSTOMER_HANGUP.code
-
-        if not call.end_time:
-            call.end_time = device.end_time
-        self.logger.info("hangup_dir::callId: %s, direction:%s, hangupDir:%s, cause:%s, deviceId: %s", call.call_id, call.direction, call.hangup_dir, cause, device.device_id)
+        if DeviceType.AGENT.code == device_info.device_type:
+            call_info.hangup_dir = HangupDir.HOST_HANGUP.code
+        elif DeviceType.CUSTOMER.code == device_info.device_type:
+            call_info.hangup_dir = HangupDir.CUSTOMER_HANGUP.code
+
+        if not call_info.end_time:
+            call_info.end_time = device_info.end_time
+        self.logger.info("hangup_dir::callId: %s, direction:%s, hangupDir:%s, cause:%s, deviceId: %s", call_info.call_id, call_info.direction, call_info.hangup_dir, cause, device_info.device_id)