nsinnovations/erpnext
2
0
Fork 0
mirror of https://github.com/frappe/erpnext.git synced 2026-06-03 04:09:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: Make changes to fix call flow and popup trigger

Browse Source
This commit is contained in:
Suraj Shetty
2019-05-22 15:48:57 +05:30
parent ee7d6e4598
commit 07fe299628
3 changed files with 121 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files

69
erpnext/erpnext_integrations/exotel_integration.py
View File

@@ -6,66 +6,77 @@ import requests
@frappe.whitelist(allow_guest=True)
def handle_incoming_call(*args, **kwargs):
# incoming_phone_number = kwargs.get('CallFrom')
exotel_settings = get_exotel_settings()
if not exotel_settings.enabled: return
employee_email = kwargs.get('AgentEmail')
status = kwargs.get('Status')
if status == 'free' and get_call_status(kwargs.get('CallSid')) == ['ringing', 'in-progress']:
# redirected to other agent number
frappe.publish_realtime('terminate_call_popup', user=employee_email)
return
call_log = get_call_log(kwargs)
# contact = get_document_with_phone_number(incoming_phone_number)
# last_communication = get_last_communication(incoming_phone_number, contact)
call_log = create_call_log(kwargs)
data = frappe._dict({
'call_from': kwargs.get('CallFrom'),
'agent_email': kwargs.get('AgentEmail'),
'call_type': kwargs.get('Direction'),
'call_log': call_log
'call_log': call_log,
'call_status_method': 'erpnext.erpnext_integrations.exotel_integration.get_call_status'
})
frappe.publish_realtime('show_call_popup', data, user=data.agent_email)
if call_log.call_status in ['ringing', 'in-progress']:
frappe.publish_realtime('show_call_popup', data, user=data.agent_email)
def get_last_communication(phone_number, contact):
# frappe.get_all('Communication', filter={})
return {}
def create_call_log(call_payload):
def get_call_log(call_payload):
communication = frappe.get_all('Communication', {
'communication_medium': 'Phone',
'call_id': call_payload.get('CallSid'),
}, limit=1)
if communication:
log = frappe.get_doc('Communication', communication[0].name)
log.call_status = 'Connected'
log.save(ignore_permissions=True)
return log
communication = frappe.get_doc('Communication', communication[0].name)
else:
communication = frappe.new_doc('Communication')
communication.subject = frappe._('Call from {}').format(call_payload.get("CallFrom"))
communication.communication_medium = 'Phone'
communication.phone_no = call_payload.get("CallFrom")
communication.comment_type = 'Info'
communication.communication_type = 'Communication'
communication.sent_or_received = 'Received'
communication.communication_date = call_payload.get('StartTime')
communication.call_id = call_payload.get('CallSid')
communication = frappe.new_doc('Communication')
communication.subject = frappe._('Call from {}').format(call_payload.get("CallFrom"))
communication.communication_medium = 'Phone'
communication.send_email = 0
communication.phone_no = call_payload.get("CallFrom")
communication.comment_type = 'Info'
communication.communication_type = 'Communication'
communication.status = 'Open'
communication.sent_or_received = 'Received'
status = get_call_status(communication.call_id)
communication.call_status = status or 'failed'
communication.status = 'Closed' if status in ['completed', 'failed', 'no-answer'] else 'Open'
communication.call_duration = call_payload.get('Duration') if status in ['completed', 'failed', 'no-answer'] else 0
communication.content = 'call_payload'
communication.call_status = 'Incoming'
communication.communication_date = call_payload.get('StartTime')
communication.call_id = call_payload.get('CallSid')
communication.save(ignore_permissions=True)
frappe.db.commit()
return communication
@frappe.whitelist()
def get_call_status(call_id):
print(call_id)
settings = get_exotel_settings()
response = requests.get('https://{api_key}:{api_token}@api.exotel.com/v1/Accounts/erpnext/{sid}/{call_id}.json'.format(
response = requests.get('https://{api_key}:{api_token}@api.exotel.com/v1/Accounts/erpnext/Calls/{call_id}.json'.format(
api_key=settings.api_key,
api_token=settings.api_token,
call_id=call_id
))
return response.json()
status = response.json().get('Call', {}).get('Status')
return status
@frappe.whitelist(allow_guest=True)
@frappe.whitelist()
def make_a_call(from_number, to_number, caller_id):
settings = get_exotel_settings()
response = requests.post('https://{api_key}:{api_token}@api.exotel.com/v1/Accounts/{sid}/Calls/connect.json'.format(
response = requests.post('https://{api_key}:{api_token}@api.exotel.com/v1/Accounts/{sid}/Calls/connect.json?details=true'.format(
api_key=settings.api_key,
api_token=settings.api_token,
), data={