File: //home/arjun/projects/buyercall/buyercall/blueprints/widgets/__pycache__/routing.cpython-310.pyc
o
�weJ� � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlZd dlmZmZ m
Z
d dl m Z m
Z
d dlmZ d dlZd dlZd dlm mZ d dlmZ d dlmZ d dlmZm Z d d l m Z m Z m Z!m"Z" d d
l#m$Z$ d d l%m&Z& d d
l'm(Z( d dl)m*Z* d dl+m,Z, dZ-dZ.dZ/dZ0dZ1e �2e3�Z4e$� Z5G dd� de6�Z7G dd� de6�Z8d3dd�Z9 d4d d �Z:d d � Z;d!d"� Z<G d#d$� d$e=�Z>G d%d&� d&e>�Z?d'd(� Z@d)d*� ZAd+d,� ZBd-d.� ZCd/d0� ZDd1d2� ZEdS )5� N)�datetime)�url_for� current_app�request)�and_�or_)�TwilioRestException)�db)�_try_renderer_template)�first� to_string)�
BusyAgents� CallStorage�InboundCallState�subaccount_client)� WebhookUtil� )�Agent)�User)�Lead)�format_phone_number� i�Q z Hello ... ..z The lead's name is: {} . {} .zThe lead is asking: {}. c @ � e Zd ZdS )�FileFormatExceptionN��__name__�
__module__� __qualname__� r r �F/home/arjun/projects/buyercall/buyercall/blueprints/widgets/routing.pyr + � r c @ r )�NoAgentsExceptionNr r r r r r! / r r! � c K sz | r;|r;t |�}tj�|tjk| jtjk��ttjd tjktjd tjk��� � }|r;t
� d� | j
|j
|j�� dS dS )N� in-progress�ringingzTCancelling widget {0} call request. Lead {1} with phonenumber {2} currently on call.TF)� normalizer �query�filter� phonenumber�partnership_account_idr �STATUSES�statusr �log�info�format�id)�widget� phoneNumber�kwargs� phone_number� lead_on_callr r r �phonecall_inprogress3 s,
��� ��r5 r$ c K s@ | j d u r
td�| j���| j j} | j j}
| j}t|�} |s)|s)t�| j | �\}}tj
� | tjk| j tj k�� � } | d urD| j
}
| j}nd}
d }tdi d| j �d|�d|�d|�d| �d|
�d |�d
t�� �d d �d
|�d| �d| j�d|�d|�d|�d| �d|
��}tj�|� tj�� ddlm} || |||| j � |S )Nz)Widget {} has no inbound phone associatedz no statusr) � firstname�lastname�emailr( �progress_status�question� starttime� call_type�outboundr+ �my_phone� widget_guid�additional_info� call_source�agent_assigned_id�originating_number�
inbound_id� )� add_contactr )�inbound� Exceptionr. r/ r( �namer% r �get_last_known_namer) r& r' r r9 rB r �utcnow�guidr �session�add�commit�tasksrF )r0 � firstName�lastName� emailAddressr1 � sourceTagr: r+ r2 r> rD r3 �
previous_leadr9 �agent_assigned�leadrF r r r �add_widget_leadJ s|
������������ �
� � �
�����
rX c
C sz t | ��� }} | �d�s| �t �dddddd���}|�d�r"|S t|�dkr,d| S t|�dkr;|�d�r;d| S |S ) z5 Convert a US phone number into an E.123 format.
zsip:r" )� �.�(�-�)�+�
z+1� �1)�str�strip�
startswith� translate� maketrans�len)r3 �strippedr r r r% � s
r% c C s* dd� t | jdd� d�D �}t�|�}|S )z3Return a list of available agent IDs for a widgets.c S s g | ] }|j jr|j�qS r )�agent�
available_now�agent_id)�.0�asgr r r �
<listcomp>� s ��z+get_available_agent_ids.<locals>.<listcomp>c S s | j S �N)�order��xr r r �<lambda>� s z)get_available_agent_ids.<locals>.<lambda>)�key)�sorted� assignmentsr
� filter_from)r0 � agent_ids� free_agentsr r r �get_available_agent_ids� s
�
rz c @ sR e Zd Zdd� Zdd� Zdd� Zdd� Z dd
d �Zd d
� Zdd� Z dd� Z
d S )�Routingc C �
|| _ d S ro ��client��selfr~ r r r �__init__� �
zRouting.__init__c C s� t jtjd tjd d�}t||�}d�|�}|�� � |js#||_n W d � dS W d � n1 s6w Y |�|dd�}|D ] }|� d �\}} t
|�|krbt � d
�|�� | j
j�| � qDtjd |_tj�tj|k��� }
||
_tj�� d S )
z� Save the agent on call to the database for this lead.
Return True if this is the agent chosen for the call, or False
if some other agent picked up first.
�REDIS_CONFIG_URL�REDIS_CONFIG_PORT��host�portzLIST{}NFr ����_z Canceling call for agent {}...�callIdT)�redis� StrictRedis�app�configr r. �lockrk �lrange�split�intr, r- r~ �calls�hangupr �args�agent_call_sidr r& r' r/ r r rM rO ) r� �lead_idrk �redis_db�storage�called_agents_keyr� �call�a�sidrW r r r �save_lead_agent� s,
� � �
zRouting.save_lead_agentc C �� t jtjd tjd d�}t||j�}|jj}|s |jjj}|j |_
|� � t j
|_t�d|j� t|�}|sQt�d�|j�� d|_tj�� t||� t|��|jd r]| � |� |S |jd rgt � |� | � |||� |S � Nr� r� r� �operational_start_callz"No agents available for widget {}.�missed�routeSimultaneously�
routeRandomly� r� r� r� r� r r/ �partnership_account� subscription� partnership�twilio_subaccount_sid�subaccount_sid�clear_callback_cnt�State�NEW�state� webhooker�trigger_generic_webhookrz r, �warningr. r+ r rM rO �send_notify_emailr! �options�schedule_call_parallel�random�shuffle�route_sequential�r� r0 rW r� r� r� rx r r r � call_lead� s.
zRouting.call_leadc C � ddl m} |�|j� d S �NrE )�
call_parallel)rP r� �delayr/ �r� rW r� r r r r� � � z Routing.schedule_call_parallelNc
sP t jtjd tjd d�} tj�tj|k��� } | s!t �
d� dS ddl m }
m
} |j�|j| jk��� }|
j�|
j|jk��� }t| |�}t|j|j�}d}t|j� fdd ��}|sht �d
�� j|j�� dS |jd krq� j}n*|jd krz� j}n!|jd
kr�� j}� jr�d� j nd}ntd�t |j�� j|j���|j j |||||||d�S )�D Call either the agent's phone number, mobile, or extension
r� r� r� z Lead not found in the databaseNr �� Partnership�PartnershipAccountc � | j � jkS ro �rk r/ rq �ri r r rs � z+Routing.call_agent_number.<locals>.<lambda>z2Cannot find agent {} in widget {}'s list of agents�phone�mobile� extension�wwww�1Unknown calling method {} for agent {}, widget {})�to�from_�url�status_callback�status_callback_event� send_digits�timeout) r� r� r� r� r r& r' r/ r r, r� �partnership.modelsr� r� r) �partnership_idr r r� rv �errorr. � full_name�
contact_usingr( r� r� rH �reprr� �create)r� ri r0 r� r� r� �
status_eventsr� r� �
if_machiner2 r� rW r� r� �partner_account�partnerr� �
twilio_clientr� �war� r r� r �call_agent_number� sT
�
��
���zRouting.call_agent_numberc C s~ t jtjd tjd d�}t�|�}d }|r5tj�t tj
|j
ktj |d k��� � }|r-n|dd � }|st
�d�|j�� |rI|d u sI|jdkrwt
�d�|j �� |�d �|j �d
t d � |jdkrud |_tj�� t||� t|� d S |�d
�|j �dt d� zt
�d�|j|j �� | �||||� tj�� W d S t y� t
�d�|d �� | � |dd � ||� Y d S w )Nr� r� r� r rE �The lead call status is: {}� completed�'No more agents available for widget {}.� CONNECT{}r �-1r� �CALL{}� �0�"Trying call from {} to agent {}...z"Error caling agent {}; retrying...) r� r� r� r� r
rw r r& r' r r) r/ r r, r- r. r+ r� �setex�DAYSr rM rO r� �schedule_retries�debugrI �call_agent_sequentialr r� )r� rx r0 rW r� ri r r r r� ' sN
�� � �
�� �zRouting.route_sequentialc
C sZ | j ||td|j|jddd�td|j|j|jt|dd � �ddd�g d�t|jj|jd �S )
N� twilio_api.agent_digit_promptT�https�r� rk � _external�_schemez'twilio_api.agent_sequential_call_statusrE )r? r� rk � other_agentsr� r� �r$ �answeredr� �r� r� r� r� r� r� )r� r r/ rL r �
AGENT_TIMEOUTrG r( �r� rW ri r0 rx r r r r� T s0 �� �z Routing.call_agent_sequentialc C sH | j ||td|j|jddd�td|j|jddd�g d�t|jj|jd�S ) Nr� Tr� r� z%twilio_api.agent_parallel_call_status)rk r� r� r� r� r� )r� r r/ r� rG r( �r� rW ri r0 r r r �call_agent_paralleln s, ���zRouting.call_agent_parallel�NNNNNN) r r r r� r� r� r� r� r� r� r� r r r r r{ � s !#
�7- r{ c @ sL e Zd Zdd� Z dd� Zdd� Z ddd �Zd
d � Zd d
� Zdd� Z dS )�BandwidthRoutingc C r| ro r} r r r r r� � r� zBandwidthRouting.__init__c C r� r� r� r� r r r r� � s.
zBandwidthRouting.call_leadc C r� r� )�bw_tasksr� r� r/ r� r r r r� � r� z'BandwidthRouting.schedule_call_parallelNc
sP |
� dd�} |
� dd�} |
� dd�}
t|j� fdd��}|s.t�d�� j� j|j�� t� �|j dkr7� j
}n |j d kr@� j }n|j d
krI� j
}nt d �t
|j �� j|j���d d
lm} |�|�}|rg|}nt|�}tdd|ddd�}tdd|ddd�}| jjj||| |
| dt||ddddd�d�}t�d�|�� t�|�}|� dd�}|S ) r� �answer_callback_urlr" � answer_fallback_callback_url�disconnect_callback_urlc r� ro r� rq r� r r rs � r� z4BandwidthRouting.call_agent_number.<locals>.<lambda>z7Cannot find agent {} ({}) in widget {}'s list of agentsr� r� r� r� r ��Phonez bw_outbound.manual_amd_webhookri Tr� )�partyr� r� r� z'bw_outbound.manual_amd_fallback_webhookzstart-agent-widget-outboundr� rE �x )� callbackUrl� fallbackUrl�speechThreshold�speechEndThreshold�silenceTimeout�detectionTimeout)�c_from�c_tor r r �tag� call_timeout�machine_detectionz The BW call API error is: {}r� )�getr rv r, r� r. r� r/ �
ValueErrorr� r( r� rH r� �(buyercall.blueprints.phonenumbers.modelsr �mobile_sip_urir r r~ r� r� r� �json�loads)r� ri r0 r� r� r� r� r� r� r� r2 r r r r� r� r �buyercall_sip_lookup�amd_callback_url�amd_fallback_callback_url�
agent_call�json_call_string�
agent_call_idr r� r r� � sz ��
��
����
z"BandwidthRouting.call_agent_numberc
C s� t jtjd tjd d�}t�|�}d }|r5tj�t tj
|j
ktj |d k��� � }|r-n|dd � }|st
�d�|j�� |rI|d u sI|jdkrwt
�d�|j �� |�d �|j �d
t d � |jdkrud |_tj�� t||� t|� d S |�d
�|j �dt d� zt
�d�|j|j �� | �||||� tj�� W dS t y� } z t
�d�|d |�� | � |dd � ||� W Y d }~dS d }~ww )Nr� r� r� r rE r� r� r� r� r r� r� r� r� r� r� z.Error calling agent {}; Error: {}; retrying...r" ) r� r� r� r� r
rw r r& r' r r) r/ r r, r- r. r+ r� r� r� r rM rO r� r� r� rI r� rH r� )r� rx r0 rW r� ri �er r r r� sX �
�� � �
�� � ��z!BandwidthRouting.route_sequentialc C sv | j ||td|j|j|jjddd�td|j|j|jjddd�td|j|j|jjt|dd � �ddd�t|jj|jd �S )
N�0bw_outbound.widget_outbound_agent_answer_webhookTr� �r� rk �from_tnr� r� �9bw_outbound.widget_outbound_agent_answer_fallback_webhookz=bw_outbound.widget_sequence_outbound_agent_disconnect_webhookrE )r� rk r! r� r� r� �r r r r� r� r� )r� r r/ rG r( r r� r� r r r r� 8 s@ ��� �z&BandwidthRouting.call_agent_sequentialc
C sh | j ||td|j|j|jjddd�td|j|j|jjddd�td|j|j|jjddd�t|jj|jd�S )Nr Tr� r r" z=bw_outbound.widget_parallel_outbound_agent_disconnect_webhookr# )r� r r/ rG r( r� r� r r r r� Z s> ����z$BandwidthRouting.call_agent_parallelr� )
r r r r� r� r� r� r� r� r� r r r r r� � s '
�L/ "r� c C s� t jtjd tjd d�}t}|�dt|j� �}|jr&|t �
|j |j �7 }|j
r1|t�
|j
�7 }| j�dd�rC|| j�dd��� 7 }|rN|�d �sN|d
7 }|d urh|dkrh|jd urh|j�� d krh|d
| }|S )z� Builds the text that the call center agent will head before picking up a
call. Agent Text = Custom Lead Message + Fullname + Question + Hidden Information + .
r� r� r� zCUSTOM_LEAD_MESSAGE:�addHiddenInformationF�hiddenInformationr" rZ z. N�adfz . . . )r� r� r� r� �AGENT_WHISPER_HELLOr rb r/ r� �AGENT_WHISPER_LEAD_NAMEr. r6 r7 r: �AGENT_WHISPER_QUESTIONr� rc �endswithrA �lower)r0 rW r� �
agent_text�custom_lead_messager r r �get_agent_text| s �( r. c C s4 | dv rdS | dv r dS | dv rdS | dv r| S dS ) zB Translate a Twilio call status into a Buyercall lead status.
)�busy�failed�canceledr� )z no-answer�
unanswered)� initiated�queuedr$ )r# r� �otherr )� call_statusr r r � to_status� s r7 c C s| ddl m} t| |� |jdu r�t| j��� dkr�d| j }| j}|j }| j
}|j j }ddl
m} |j�|j|jk��� } |d urK|durK|d| 7 }|d urY|durY|d | 7 }|d urg|durg|d
| 7 }|j�d d �r�| jd
u r�|j�dd��� }
|
d ur�|
dur�|
dur�|d|
7 }t| j|�} t| �dkr�t�d� |d ur�t|�dkr�||| jd| d� d S d S d S d S d S d S )Nr ��send_ses_emailTr& �
Call status: )r� r" �, Agent name: �, Call source: �, Phonenumber: r$ Fr� r% rY z, Additional Information: zSending CRM redirect email.zADF lead notification��
recipients�p_id�subject�text) � buyercall.lib.util_ses_emailr9 r� �is_adfrb rA r+ r+ �
agent_name�adf_notification_emails�sourcerG r( �'buyercall.blueprints.partnership.modelsr� r& r' r/ r) r r� r rc �update_adf_commentrg r, r� r� ) rW r0 r9 � comment_textrE �
adf_emails� lead_source�widget_phonenumberr� r� � hidden_info�
email_bodyr r r �after_call_events� sD
�
��rP c
C s� ddl m} tjtjd tjd d�}�z|jd r W d S |jd r*| jdkr*W d S tj �
tj | j ktj tj
�d �tjd
k��� }|j}tj�d �|�� d d
lm}m} |j �
|j| j k��� }|j �
|j|jk��� } t| �}
t� d�} | j � | �� d�|
d< | j � | �� d�|
d< | j!|
d< | j"|
d< | j#|
d< | j$r�d|
d< d�%| j$d| j&f�|
d< | j'r�| j'j�(dd�|
d< | j)r�| j)|
d < | jdkr�t*d;d d i|
��} ||| j| j"d | d!� nt*d<d d i|
��}
||| j| j"d# |
d!� |j+d$u �r$t,| j-��.� d%k�r'| j/}|j0}|j1j2}d&| j |
d'< d|
d(< d|
d)< d|
d*< |j"}|�r+||
d+< nd|
d+< | j}|�r:||
d,< nd|
d,< |�(d-t,| j� �}|d u�rQ||
d(< |�(d.t,| j� �}|d u�rd||
d)< |�(d/t,| j� �}|d u�rw||
d*< |d u�r�|du�r�t3|�d k�r�|
d' d0 | |
d'< | j)d u�r�| j)du�r�| j)|
d1< |
d' d2 | j) |
d'< |d u�r�|du�r�|
d' d3 | |
d'< d|
d4< d |
d5< dd6l4m5}m6} |j �
|j| j7k|j | j k��� }|�r|j8�r|j �
|j|j8k��� }|�rd$|
d5< |j9|
d4< |�r*t3|�dk�r-t*d=d d8i|
��}||| j| j"d9 |d:� W d S W d S W d S W d S W d S t:�yJ } zt;�<t=�>� � W Y d }~d S d }~ww )>Nr r8 r� r� r� �
notifyNone�notifyMissedLeadsr� F�adminzThe email list are {}r r� z
US/Easternz%c�
created_on�
updated_on�adf_updated_on�company� partner_logoz Caller Name:�caller_name_labelr" rY � caller_namer% � referencerA �widgets/mail/missed_lead�ext�htmlz - Missed lead notification)r? r@ rA r^ �widgets/mail/captured_leadz - Answered lead notificationTr& r: �
lead_comments� vehicle_year� vehicle_make�
vehicle_model� vendor_name� call_lead_idzCUSTOM_LEAD_YEAR:zCUSTOM_LEAD_MAKE:zCUSTOM_LEAD_MODEL:r; �receiverr< r= �
campaign_name�campaign_exists)�Contact� Campaigns�widgets/mail/adf_lead�txtz - ADF lead notificationr> )r\ )r_ )rk )?rC r9 r� r� r� r� r� r+ r r& r' r) �active�is_deactivated�is_�roler �emails�loggerr� r. r� r� r� r/ r� �vars�pytz�timezonerT �
astimezone�strftimerU �interaction_timerI �logor6 �joinr7 r0 r rG r
rD rb rA r+ rE rF rG r( rg �$buyercall.blueprints.contacts.modelsri rj �
contact_id� campaign_id� display_namerH r, r� � traceback�
format_exc) rW r0 r9 r� �userrq r� r� r� r� �ctx�eastern�missed_lead_email_template� captured_lead_email_templaterE rK r( �
dealershipre �custom_lead_vehicle_year�custom_lead_vehicle_make�custom_lead_vehicle_modelri rj �contact�campaign�adf_lead_email_templater r r r r� � s�
��
��
"
��
��
� � 8 ��r� c
C sX t jtjd tjd d�}| jdv r t�d| j � d S t|| j�}|j }| j
j d }t |�|ks5|| s7dS t
|| �}t�d�| j|�� d | _tj�� d
d lm} |j�|j| jk��� }z-|jd kr{d
dlm} |j | jg|d d� W dS d
dl m} |j | jg|d d� W dS t y� } zt�d�| j| �� W Y d } ~ dS d } ~ ww )Nr� r� r� )r$ r� z+Cannot schedule retries yet/lead status is � retryRoutingFz/Scheduling retry call for lead {} in {} minutesz
retry-pendingr r � bandwidthrE )�
call_again�< )r� � countdownTz;Unable to perform call-back or retry for lead: {} Error: {}) r� r� r� r� r+ r, r� r r/ � callback_cntr0 r� rg r� r- r. r rM rO �phonenumbers.modelsr r& r' rD r �providerr� r� � apply_asyncrP rH )
rW r� r� �cnt�routing_delaysr� r �numberr� r r r r r� W s<
�
���r� c C s6 t jtjd tjd d�}|�dt| � �}|d kr�t|�dkr�zet�|�}|� d�}|d ks3|dkr~|� d�d urp|� d�}|� d �d urf|� d �j
}t|�dkr]|d
| |� d �_
n|| |� d �_
nt� |d �}||_
nt �
d � tj|d d
d�W S t �
d� W dS ty� t �
dt�� � Y dS w dS )Nr� r� r� zCUSTOM_LEAD_XML:r �prospectr" �customer�commentsz - z!No customer found in the XML lead�utf8�xml)�encoding�methodz!No prospect found in the XML leadz#Error parsing XML file. Exception: )r� r� r� r� r rb rg �et�
fromstring�findrB �
SubElementr, r� �tostringr �sys�exc_info) r� �commentr� �custom_lead_xml� xmlentityr� r� �customer_comments� new_commentr r r rI � s2
��rI )r" )r" r" r" r" r" r" r$ )F�loggingr� r r� r r �flaskr r r� r �
sqlalchemyr r �twilio.base.exceptionsr r� rt �xml.etree.ElementTree�etree� ElementTreer� �buyercall.extensionsr � buyercall.lib.flask_mailplusr
�buyercall.lib.util_listsr r �buyercall.lib.util_twilior
r r r� r �buyercall.lib.util_webhooksr �
agents.modelsr � user.modelsr � leads.modelsr � buyercall.blueprints.filtersr r� r� r' r( r) � getLoggerr r, r� rH r r! r5 rX r% rz �objectr{ r� r. r7 rP r� r� rI r r r r �<module> s^
�< g t + +