|
|
@@ -84,7 +84,7 @@ class AgentEventService:
|
|
|
called = device_info.called if device_info else None
|
|
|
is_agent = (device_info and DeviceType.AGENT.code == device_info.device_type) if device_info else False
|
|
|
|
|
|
- # self.logger.info('agent_event_channel, event_name=%s, call_id=%s, device_id=%s, is_agent=%s', event_name, call_id, device_id, is_agent)
|
|
|
+ self.logger.info('agent_event_channel, event_name=%s, call_id=%s, device_id=%s, is_agent=%s', event_name, call_id, device_id, is_agent)
|
|
|
agent = self.data_handle_server.get_agent(saas_id, agent_num)
|
|
|
if not agent:
|
|
|
# self.logger.warn("event service channel agent is null %s %s %s %s %s", saas_id, event_name, caller, called, json.loads(event.serialize('json')))
|
|
|
@@ -125,8 +125,8 @@ class AgentEventService:
|
|
|
else:
|
|
|
# 用户侧接起
|
|
|
self.agent_monitor_service.update_calling(agent_monitor)
|
|
|
- # self.push_handler.push_on_agent_work_report(saas_id, flow_id, agent_num, call_id, AgentScene.MANUAL, WorkStatus.AGENT_ANSWER_OUTGOING)
|
|
|
- # self.push_handler.push_on_agent_report(saas_id, agent_num, AgentScene.MANUAL, AgentServiceState.CALLING)
|
|
|
+ self.push_handler.push_on_agent_work_report(saas_id, flow_id, agent_num, call_id, AgentScene.MANUAL, WorkStatus.AGENT_ANSWER_OUTGOING)
|
|
|
+ self.push_handler.push_on_agent_report(saas_id, agent_num, AgentScene.MANUAL, AgentServiceState.CALLING)
|
|
|
|
|
|
#挂断
|
|
|
if CHANNEL_HANGUP == event_name:
|
|
|
@@ -148,10 +148,9 @@ class AgentEventService:
|
|
|
# agentProducer.pushDelayedStatus(statusDto, reprocessingTimeout);
|
|
|
|
|
|
if (CHANNEL_BRIDGE == event_name or PLAYBACK_START == event_name) and is_agent:
|
|
|
- self.logger.info('agent_event_channel, event_name=%s, call_id=%s, device_id=%s, is_agent=%s', event_name, call_id, device_id, is_agent)
|
|
|
self.push_handler.push_on_ring_start(saas_id, flow_id, agent_num, AgentScene.MANUAL, call_id)
|
|
|
- self.push_handler.push_on_agent_work_report(saas_id, flow_id, agent_num, call_id, AgentScene.MANUAL, WorkStatus.AGENT_ANSWER_OUTGOING)
|
|
|
- self.push_handler.push_on_agent_report(saas_id, agent_num, AgentScene.MANUAL, AgentServiceState.CALLING)
|
|
|
+ # self.push_handler.push_on_agent_work_report(saas_id, flow_id, agent_num, call_id, AgentScene.MANUAL, WorkStatus.AGENT_ANSWER_OUTGOING)
|
|
|
+ # self.push_handler.push_on_agent_report(saas_id, agent_num, AgentScene.MANUAL, AgentServiceState.CALLING)
|
|
|
|
|
|
if DETECTED_TONE == event_name and not is_agent:
|
|
|
self.push_handler.push_on_detected_tone(saas_id, flow_id, call_id, AgentScene.MANUAL, call_id)
|
DavidLiu