|
@@ -18,14 +18,15 @@ class PushHandler:
|
|
|
# 获取 RedisHandler 实例并发布消息到 Redis 频道
|
|
|
redis_handler = RedisHandler()
|
|
|
redis_handler.publish('socket_channel', message)
|
|
|
- def push_on_agent_work_report(self, saas_id, flow_id, user_id, call_id, scene: AgentScene, work_status: WorkStatus, description=None):
|
|
|
+ def push_on_agent_work_report(self, saas_id, flow_id, user_id, call_id, scene: AgentScene, work_status: WorkStatus, description=None, phone=None):
|
|
|
data = {
|
|
|
'eventName': DownEvent.ON_AGENT_WORK_REPORT.code,
|
|
|
'ext': {'workStatus': work_status.code,
|
|
|
'description': description or work_status.description,
|
|
|
'callId': call_id,
|
|
|
'ctiFlowId': flow_id,
|
|
|
- 'scene': scene.code
|
|
|
+ 'scene': scene.code,
|
|
|
+ 'phone':phone
|
|
|
}
|
|
|
}
|
|
|
self.logger.info("flowId:[%s] OnAgentWorkReport push:[%s].", flow_id, json.dumps(data))
|