fix:bug

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

@@ -46,7 +46,7 @@ class ChannelAnswerHandler(EslEventHandler):
         device_info.ring_end_time = EslEventUtil.getEventDateTimestamp(event)
         call_info.answer_count = call_info.answer_count + 1
         call_info.next_commands.remove(next_command)
-
+        self.logger.info("ysChannelAnswerHandler call_info.answer_time::%s,time:%s", call_info.answer_time, EslEventUtil.getEventDateTimestamp(event))
         if not call_info.answer_time:
             call_info.answer_time = EslEventUtil.getEventDateTimestamp(event)
             self.dataHandleServer.update_record(call_id, {"status": 1})
@@ -64,6 +64,7 @@ class ChannelAnswerHandler(EslEventHandler):
         self.cache.add_call_info(call_info)
 
         if device_info.device_type == DeviceType.AGENT.code:  # 如果是坐席接听 变更坐席状态
+            self.logger.info('坐席接听')
             self.push_handler.push_on_agent_work_report(call_info.saas_id, call_info.cti_flow_id, call_info.agent_key, call_info.call_id, AgentScene.ROBOT, WorkStatus.AGENT_ANSWER_INCOMING)
             self.dataHandleServer.update_agent_monitor_service_state(call_info.agent_key, AgentServiceState.CALLING.code)
     def call_other(self, call: CallInfo, device: DeviceInfo):

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

@@ -109,13 +109,13 @@ class ChannelHangupHandler(EslEventHandler):
             # 全部挂机以后推送挂机状态
             self.logger.info('yushanghui::call_info.device_list %s', call_info.device_list)
             if len(call_info.device_list) == 0:
+                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)
+                self.push_handler.push_on_agent_work_report(call_info.saas_id, call_info.cti_flow_id,  call_info.agent_key, call_info.call_id, AgentScene.ROBOT, WorkStatus.AGENT_HANG_IDLE)
                 # 计算当前通话时长
                 if call_info.answer_time:
                     call_info.end_time = timestamp
                     call_info.talk_time = int(call_info.end_time) - int(call_info.answer_time)
                     self.dataHandleServer.update_record(call_id, {"time_end": datetime.utcnow(), "times": int(call_info.talk_time / 1_000_000) })
-                    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)
-                    self.push_handler.push_on_agent_work_report(call_info.saas_id, call_info.cti_flow_id,call_info.agent_key, call_info.call_id, AgentScene.ROBOT, WorkStatus.AGENT_HANG_IDLE)
 
                 self.logger.info('全部挂断 %s', device_info.device_type)
                 # 更新坐席状态