|
|
@@ -516,11 +516,12 @@ class OutboundClient:
|
|
|
new_device_id = 'D' + str(Snowflake().next_id())
|
|
|
|
|
|
kwargs = json.loads(info.serialize('json'))
|
|
|
+ kwargs['variable_sip_h_P-LIBRA-CallId'] = call_id
|
|
|
destination = self.server.agent.register(**kwargs)
|
|
|
self.server.logger.info("device_id=%s, destination=%s", device_id, destination)
|
|
|
|
|
|
Cache.add_device_user_part(device_id, destination)
|
|
|
- con.execute("bridge", "{sip_h_P-LIBRA-CallId=%s,sip_h_P-LIBRA-DeviceId=%s}user/%s"%(call_id, new_device_id, destination), device_id)
|
|
|
+ con.execute("bridge", "{sip_h_P-LIBRA-CallId=%s,sip_h_P-LIBRA-DeviceId=%s,origination_uuid=%s}user/%s"%(call_id, new_device_id, new_device_id, destination), device_id)
|
|
|
|
|
|
# destination = "user/1001"
|
|
|
# msg = ESL.ESLevent("sendmsg", uuid)
|
|
|
@@ -544,6 +545,24 @@ class OutboundClient:
|
|
|
except:
|
|
|
traceback.print_exc()
|
|
|
|
|
|
+ def build_call_info(self, info):
|
|
|
+ pass
|
|
|
+ # agent = Cache.get_agent_info(Saas, request.agent_id)
|
|
|
+ # route_gateway = Cache.get_route_gateway(request.saas_id)
|
|
|
+ # call_info = CallInfo(cti_flow_id=request.cti_flow_id, call_id=call_id, agent_key=agent.agent_number,
|
|
|
+ # sip_server=agent.sip_server,
|
|
|
+ # caller=agent.agent_number, called=request.called, direction=Direction.INBOUND.code,
|
|
|
+ # caller_display=request.caller_display, called_display=request.called_display,
|
|
|
+ # call_type=request.call_type.code, call_time=now, follow_data=request.follow_data,
|
|
|
+ # uuid1=request.uuid1, uuid2=request.uuid2, saas_id=saasId)
|
|
|
+ # device_info = DeviceInfo(cti_flow_id=request.cti_flow_id, device_id=device_id, call_time=now,
|
|
|
+ # call_id=call_id, device_type=DeviceType.AGENT.code,
|
|
|
+ # agent_key=agent.agent_number, caller_display=route_gateway.name,
|
|
|
+ # cdr_type=CdrType.INBOUND.code)
|
|
|
+ # call_info.device_list.append(device_id)
|
|
|
+ # call_info.next_commands.append(NextCommand(device_id, NextType.NEXT_CALL_OTHER.code))
|
|
|
+ # call_info.device_info_map = {device_id: device_info}
|
|
|
+ # Cache.add_call_info(call_info)
|
|
|
|
|
|
|
|
|
class CustomTCPServer(socketserver.TCPServer):
|
