fix:bug

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

@@ -3,8 +3,8 @@
 import json
 import time
 from datetime import datetime
-from src.core.callcenter.constant import saasId, get_record_prefix
-from src.core.callcenter.enumeration import NextType, AnswerFlag, Direction, DeviceType, AgentScene, CdrType,WorkStatus,AgentServiceState
+from src.core.callcenter.constant import saasId, get_record_prefix,get_record_file_name
+from src.core.callcenter.enumeration import NextType, AnswerFlag, Direction, DeviceType, AgentScene, CdrType,WorkStatus,AgentServiceState,CallStage
 from src.core.callcenter.esl.annotation import EslEventName
 import src.core.callcenter.esl.utils.esl_event_util as EslEventUtil
 from src.core.callcenter.esl.constant.event_names import CHANNEL_ANSWER
@@ -49,13 +49,6 @@ class ChannelAnswerHandler(EslEventHandler):
         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})
-
-            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)
 
         if NextType.NEXT_CALL_OTHER.code == next_command.next_type:
             self.call_other(call_info, device_info, event)
@@ -69,6 +62,14 @@ class ChannelAnswerHandler(EslEventHandler):
             self.logger.warn("can not match command :%s, callId :%s", next_command.next_type, call_id)
         self.cache.add_call_info(call_info)
 
+        if device_info.device_type == DeviceType.AGENT.code:  # 如果是坐席接听 变更坐席状态
+            self.logger.info('坐席接听')
+            self.dataHandleServer.update_record(call_id, {"status": 1})
+            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)
+
+        self.logger.info("lwanswer call_id:%s, call_info:%s, event:%s" % (call_id, call_info, json.loads(event.serialize('json'))))
+
     def call_other(self, call: CallInfo, device: DeviceInfo, event):
         call_id = call.call_id
         device_id = device.device_id