File: //home/arjun/projects/buyercall/buyercall/blueprints/phonenumbers/__pycache__/tasks.cpython-310.pyc
o
�we�} � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
m Z d dl Z d dl
mZmZ d dlZd dlmZ d dlmZ d dlmZ d dlmZ d d lm Z d d
l 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+ d dl,m-Z- d dl.m/Z/ d dl0m1Z1m2Z2 d dl3m4Z4m5Z5m6Z6m7Z7 dZ8dZ9dZ:ee�Z;e#� Z<e;j=dd� �Z>e;j=dd� �Z?e;j=dd � �Z@e;j=d d � �ZAe;j=d d � �ZBe;j=d!d"� �ZCe;j=d#d$� �ZDe;j=d%d&� �ZEe;j=d'd(� �ZFe;j=d)d*� �ZGdS )+� N)�BytesIO)� AESCipher)�url_for� current_app)� lazy_gettext)� load_only)�create_celery_app)�_try_renderer_template)�send_ses_email)� CallStorage�subaccount_client�InboundCallState)� WebhookUtil)�db)�Phone)�Lead��Agent)�User)�Contact)�PartnershipAccount� Partnership)�get_available_agents�get_routing_agents�schedule_callback�get_agent_numberi i�Q � c K s� t jtjd tjd d�}t�d� tj�tj ��t
j �� tj
|k��� }t
j� t
j
|jk��� }tj� tj
|jk��� }t| dd�}|sUt�d�|�� d|_tj�� t||�} t�d �t|��� d }
|j j } | sq|j j j } d
| _ t | j |j
�} |D ]�}
z�t |
|�\}}|r�d �|�nd }| �!� �p | j"t#j$t#j%t#j&fv r�| j'j(||j)j*t+d ||
j
dd
d�t+dt,|d �|
j
|dd
d�g d�|t-d�}
| �.|
j
|
j/� |
r�|r�t0j� t0j
|j1k��� }|r�|j2|
j
kr�|
j
|_2|
j3|_4tj�� ddl5m6} ||� W d � n 1 �sw Y W q} t7�y1 } zt�t8�9� � t�d�|
j
�� W Y d }~q}d }~ww |
d u �rAd|_tj�� d S d S )N�REDIS_CONFIG_URL�REDIS_CONFIG_PORT��host�portzParallel call task started.T)�
expand_groupsz+No agents are available to service lead {}.�missed�Calling {} agents...F�wwww{}z!twilio_inbound.agent_digit_prompt�https��lead_id�agent_id� _external�_schemez(twilio_inbound.agent_inbound_call_status� dialDigit��
dial_digitr) r( r* r+ )�ringing�answered� completed��to�from_�url�status_callback�status_callback_event� send_digits�timeoutr )� send_agent_push_notification�Error calling agent {}...):�redis� StrictRedis�celery�conf�log�debugr �query�join�partnership_accountr � partnership�filter�id�one�partnership_account_id�firstr �partnership_idr �warning�format�statusr �session�commitr �len� subscription�is_groupr �twilio_subaccount_sidr �lock�state�State�NEW� LEAD_ONHOLD�CALLBACK_PROMPT�calls�create�inbound� phonenumberr �str�
AGENT_TIMEOUT�push_agent_call�sidr �
contact_idr) � full_name�agent_assigned�!buyercall.blueprints.mobile.utilsr: � Exception� traceback�
format_exc)� agent_idsr( �routing�kwargs�redis_db�lead�partner_account�partner�agents�storage�callrR �
twilio_client�agent� agent_number� extension�digits�contactr: �e� r{ �I/home/arjun/projects/buyercall/buyercall/blueprints/phonenumbers/tasks.py�call_simultaneous, s�
�� �
��
��
� ��%���
�r} c K s t jtjd tjd d�}tj�tj��tj ��
tj | k�� � }tj�
tj |j
k�� � }tj�
tj |jk�� � }|jj}|sC|jj j}t|j|j �}t|| �}|�� �* |jtjkru|jj|jtd| ddd�d� tj |_W d � d S W d � d S 1 s�w Y d S )
z�
If nobody has picked up in 30 seconds, redirect lead to a callback
prompt. See https://trello.com/c/Gbwmo0Ox/ for discussion.
r r r z#twilio_inbound.lead_callback_promptTr& )r( r* r+ )r5 N) r< r= r> r? r rB rC rD r rE rF rG rJ rI r rK rR r rT r rU rV rW rY r[ �route�call_sidr rZ ) r( rl rm rn ro rp rR rt rr r{ r{ r| �redirect_to_callback_prompt� s6 ���
�
�"�r� c K s� t jtjd tjd d�}tj�tj��tj ��tj
�� tj | k��
� }|s(dS tj� tj |jk��
� }tj� tj |jk��
� }t|| �}|j}|sQt�d� dS |jtjkrbt�d�|j�� dS d|d< ||_|jj}|st|jj j}t|j|j �} |� � t |�}
|
s�t�d �| �� t |� dS tj |_d
|_ t�!d �t"|
��� d} t#�$d |j � |
D ]�} z[t%| |�\}
}|r�d
�|�nd}|�&� �< |jtj kr�| j'j(|
|j
j)t*d| | j ddd�t*dt+|d �| j | ddd�ddg|t,d�} |�-| j | j.� W d � n 1 �sw Y W q� t/�y/ } zt�t0�1� � t�d�| j �� W Y d}~q�d}~ww | du �rCd|_2t3j4�5� t |� dS dS )�; Scheduled callbacks for missed leads (1, 6, 12 hours)
r r r Nz,Callback routing missing; canceling callbackz1Lead state {} instead of CALL_ME_BACK; canceling.� simultaneous� callOrder�%No available agents to serve lead {}!Fr$ �operational_start_callr% �"twilio_inbound.agent_callback_leadTr& r' �)twilio_inbound.agent_callback_call_statusr, r- r0 r1 r2 r; r# )6r< r= r> r? r rB rC rD r rE r] rF rG rJ rI r rK r rk r@ rL rV rW � CALL_ME_BACKrM rR r rT �inc_callback_cntr r �CALLBACKrS rA rQ � webhooker�trigger_generic_webhookr rU r[ r\ r^ r r_ r` ra rb rg rh ri rN r rO rP )r( rl rm rn ro rp rr rk rR rt rq rs ru rv rw rx rz r{ r{ r| �
callback_lead� s� ���
�
�
��� �����
�r� c K s0 t jtjd tjd d�}ddlm} tj�tj ��t
j ��tj ��
tj| k��� }|s.dS t
j�
t
j|jk��� }tj�
tj|jk��� }t|| �} || _d| _i | _|j j}
|
s_|j j j}
t|
j|j�} |j�
|j|k��� } | s}t�d� | �� dS t j | _ d | _ t�!d
� |�� d}
zUt"| |�\}}|r�d � |�nd}| �#� �7 | j t j kr�| j$j%||j j&t'd | | jd
dd�t'd| j| d
dd�ddg|t(d�}
| �)| j|
j*� W d � n1 s�w Y W n# t+�y } zt�,t-�.� � t�,d� | j�� W Y d}~nd}~ww |
du �rd|_/t0j1�2� dS dS )r� r r r � r N�Truez Cannot find agent with ID {}!FzCalling agent with ID {}...r% r� Tr& r' r� )r) r( r* r+ r0 r1 r2 r; r# )3r< r= r> r? �
agents.modelsr r rB rC rD r rE r] rF rG rJ rI r rK r rk � manual_call�routing_configrR r rT r@ �errorrM rW r� rV rS rA r rU r[ r\ r^ r r` ra rb rg rL rh ri rN r rO rP )r( r) �
call_settingsrl rm r rn ro rp rr rR rt ru rs rv rw rx rz r{ r{ r| �connect_lead_to_agent s� ���
���� �����
�r� c K st t jtjd tjd d�}|�d�D �]$}t|�d|��}t�� | dt kr7t �
d� ||�� |� d|� qt
j�t
j��tj��t
j��t
j|k��� }|s_t �d� |�� |� d|� qtj�tj|jk��� }tj�tj|jk��� }|jj}|s�|jjj}t |j |j�}t ||�} t j | _!d| _"| j#}
t$|
�} | s�t �d � |�� qt �%d
� t&| ��� d } | D ]�}
z\t'|
|
�\}}|r�d � |�nd }| �(� �= | j!t j k�r|j)j*||jj+t,d
||
jddd�t,dt-|
d �|
j|ddd�ddg|t.d�} | �/|
j| j0� W d � n 1 �s
w Y W q� t1�y6 } zt �t2�3� � t �d� |
j�� W Y d }~q�d }~ww qd S )zu
Task which executes every minute, and tries to call back leads which
have asked to be called back soon.
r r r r� r� zQLead {}, added at {}, is probably not waiting for our callback anymore. Removing.z0Lead {} not found - removing from callback list.Fr� r$ Nr% r� Tr& r' r� r, r- r0 r1 r2 r; )4r< r= r> r? �hkeys�float�hget�time�HOURSr@ �inforM �hdelr rB rC rD r rE r] rF rG rJ rL rI r rK rR r rT r rW r� rV rS rk r rA rQ r rU r[ r\ r^ r r_ r` ra rb rg rh ri )rl rm r( �
time_addedrn ro rp rR rt rr rk rq rs ru rv rw rx rz r{ r{ r| � call_me_backb s� � ���� �
�
�
��� �������r� c
K sp t j�t j|k��� }tj�tj|jk��� }|j}|j}| ||d�}t dddi|��} t
|g|jd| d� d S )N)r^ �company� partner_logo�mail/new_number�ext�htmlz New Phone Number Notification��
recipients�p_id�subjectr� )r� ) r rB rF rG rJ r rK �name�logor r
)
r^ �emailrI rl ro rp �partnership_name�partnership_logo�ctx�tn_email_templater{ r{ r| �send_phonenumber_email� s
�r� c K s` t j�t j| k��� }|}d�|�}t�|�}t� d�|�� |dkr.t�
d�|j�� dS t � � j
}zd�||j|jd|�} t� d�| �� W t� d � nt� d � w tjd
tjd tjd d
�}
|
jt|j�tjd | ddidd� t�d�| �� t j�tdd���t j| k��� }d�tjd | �|_tj� � t�d�|j|j�� t � d|j� dS )za After the call, grab the first recording from Twilio, if any, and
upload to S3.
z{}.wavzThe recording url is {}r z No recordings found for lead {}!Nz{}_{}/{}_{}_{}� recordingzThe recording key is {}z#Could not set key for recording url�s3�AMAZON_ACCESS_KEY�AMAZON_SECRET_KEY)�aws_access_key_id�aws_secret_access_key�RECORDING_BUCKETz Content-Typez audio/wav�private)�Body�Bucket�Key�Metadata�ACLzUploaded file {}rG �
recording_urlz{}::{}z/Lead {} have been updated with recording url {}�operational_end_call) r rB rF rG rJ rM �requests�getr@ rA rL �uuid�uuid4�hexrI �boto3�clientr> r? �
put_objectr �contentr� �optionsr r� r rO rP r� r� ) r( �r_url� partner_namerl rn �r�f�fr� hex_value�keyr� r{ r{ r| �tw_upload_recording� sH
�� ���
r� c K s t j�t j| k��t j�� ��� }t� d�
|�� t j�t j |jk��t j
|k��� }|rLt� d�
|j �� |j|_||_t� d�
|j�� tj�� nt |||| d|d�}tj�|� tj�� t� d� t j�t j |jk��t j
|k��� }|r�|j|_tj�� d S t� d� d S )Nzlatest lead: {}za lead exist with number {}zThe updated date is: {}� )� firstname�lastname� caller_id�
phonenumber_1r� rI zThe contact has been addedzno lead contact exist)r rB rF r^ �order_by�
created_on�descrJ r@ r� rM r r� rI �
updated_onr� r rO rP �addrG rc ) r^ r� r� �
callernamerI rl � latest_leadry � new_contactr{ r{ r| �add_tw_contact sB "
�� �
��r� c #
K s$ t jtjd tjd d�}ddlm} tj�tj | k��
� }t ||j �}|j r/t
j�d� d S tj�tj |jktj|jk��
� }|sDd S |j}|j}|r\d|vsZd|v r\|d dkr\d S g } g }
d } tj�tj|jktjtj�d �tjd
k��
� } | r~| j} d d � |jd
d D �}
dd � tj� t d���tj|jktj � |
��� � D �}t j�t j |jk��
� }t!j�t!j |j"k��
� }|d dkr�|j#dkr�| �$||d �� |d r�| �$|� |d r�| r�| �%| � |d dk�r | �$||d �� |d r�| �$|� |d �r | �r | �%| � | �st
j�&d�'|j#�� d S t(|�}t)�*d�}|j+�,|��-d�|d < |j.�,|��-d�|d < |j/|d < |j0|d < |j1|d < |j2�rY|j2d! t3|j4� |d"< n t5d#|j4d$d%d&�|d"< |j6�rxd'|d(< d)�7|j6d*|j8f�|d+< |j9�r�d,|d-< |j9|d.< t:�;d/�'|j<�� |j<�r�d0|d1< nd|d1< |j=�r�|j=|d2< |j>�r�|j>j�?d3d)�|d4< �z�t
j�d5�'| �� |�?d6��r�|d7 d u�r�|d7 d)u�r�||d7 �}|d u�r�|
�$|� n|
�%|d7 � d8|j# |d9< d)|d:< |j@}|j=}|j>jA}|j1}|�r ||d;< nd)|d;< |j }|�r||d<< nd)|d<< |d u�r7|d)u�r7tB|�dk�r7|d9 d= | |d9< |d u�rO|d)u�rO|d9 d> | |d9< ||d:< |d u�rc|d)u�rc|d9 d? | |d9< d)|d@< d |dA< dBdClCmD}mE} |j�|j |j4k|j|jk��
� }|�r�|jF�r�|j�|j |jFk��
� } | �r�d$|dA< | jG|d@< |
d u�r�tB|
�dBk�r�tHdTdEdFi|��} tI|
|j |j1dG | dH� |j#dk�r�|jJtKjLk�r�tHdUdEdJi|��} tI| |j |j1dK | dL� W d S |j#dk�r|jJtKjMk�rtHdUdEdJi|��} tI| |j |j1dK | dL� W d S |j#dMk�s!|j#dk�r9|jJtKjNk�r9tHdVdEdJi|��} tI| |j |j1dO | dL� W d S |j#dPk�r^|jJtKjOk�r^tHdWdEdJi|��} tI| |j |j1dR | dL� W d S tHdWdEdJi|��}!tI| |j |j1dS |!dL� W d S tP�y� }" zt
j�QtR�S� � W Y d }"~"d S d }"~"ww )XNr r r r� )� split_emailsz Notification email suppressed.� notifyLeads�noneF�adminc S s g | ]}|d �qS )rG r{ ��.0�ar{ r{ r| �
<listcomp>T s �z send_email.<locals>.<listcomp>�defaultRoutingrq c S s g | ]}|j �qS r{ )r� r� r{ r{ r| r� W s ��r� r# �notifyMissedCustom�notifyMissedAgents�notifyMissedMe�all�notifyAllCustom�notifyAllAgents� notifyAllMez%Nowhere to send {} lead notification!z
US/Easternz%cr� r� �adf_updated_onr� r� z/contacts/contact/�lead_contact_urlzcontacts.contact_lead_pageTr& )rG r* r+ z Caller Name:�caller_name_labelr� � � caller_namez
Caller Id:�caller_id_labelr� z The lead recording url is {}�block� vm_div_style� call_source�hiddenInformation� referencezThe email list are {}� notifyAdf�notifyAdfCustomz
Call status: �
lead_comments�receiver� vendor_name� call_lead_idz, Agent name: z, Call source: z, Phonenumber: �
campaign_name�campaign_existsr )r � Campaigns�
mail/adf_leadr� �txtz - ADF lead notification�r� r� r� �text�mail/missed_leadr� z - Missed lead notificationr� z
retry-pending�mail/call_backz% - Missed Call-back lead notificationr1 �mail/captured_leadz - Answered lead notificationz - New lead notification)r )r )r )r )Tr< r= r> r? �widgets.modelsr� r rB rF rG rJ r r� �app�loggerrA r �
inbound_idrI �
notificationsr� r �active�is_deactivated�is_�roler� r r� r �in_r� r r rK rN �extend�appendrL rM �vars�pytz�timezoner� �
astimezone�strftimer� �interaction_timer� r� � partner_urlr_ rc r r� rC r� r� r@ r� r� �sourcer] r� �
agent_namer^ rQ �$buyercall.blueprints.contacts.modelsr r � campaign_id� display_namer r
rV rW �MISSEDr� r� �CAPTUREDrg r� rh ri )#r( rl rm r� rn rr r] r �routings�emails�
adf_emails�
user_email�userrj � agent_emailsro rp r� �eastern�multi_adf_emailsr �
friendly_namer^ �
dealershipr� r r ry �campaign�adf_lead_email_template�missed_lead_email_template� callback_lead_email_template� completed_lead_email_template� captured_lead_email_templaterz r{ r{ r| �
send_email) sh
��
�� �
��
�
�
"
��
��
� � �& � � � ��r4 c
K s6 | d d }| d d }| d d }| d d }| d d }| d d d }||||||d �}d
d l m} m}
m} | j�td ���| j|k�� � } | j�| j
| j k�� � }
t j
d
}|
�| j �}t|�}|�|j�}ztdddi|��}t|g|
j
d|d� W d S ty� } zt�t�� � W Y d }~d S d }~ww )N� Notification�SubscriptionId�Status�Message�OrderId� OrderType�CompletedTelephoneNumbers�TelephoneNumber)�sub_idrN �message�order_id�
order_type�numberr� )r �PartnershipCpaasProviders�(PartnershipCpaasPhoneNumberSubscriptionsrK �CRYPTO_SECRET_KEY� mail/subscription_webhook_emailr� r z'Bandwidth Subscription Webhook Responser )rE )�partnership.modelsr rB rC rB r� r rF �subscription_idrJ rG rK r> r? �!partnership_bandwidth_credentialsr �decrypt�cpaas_api_usernamer r
rg r@ r� rh ri )�datarl r= rN r> r? r@ rA r� r rB �SubscriptionTable�subrp � encrypt_key�
partner_cpaas�cipher�decrypted_email�subscription_email_templaterz r{ r{ r| �send_callback_email s@ ���
� ��rS )Hrh �loggingr@ r� �botor� r� r� �ior �buyercall.lib.util_cryptor r< �flaskr r r r � flask_babelr �_�sqlalchemy.ormr �
buyercall.appr � buyercall.lib.flask_mailplusr � buyercall.lib.util_ses_emailr
�buyercall.lib.util_twilior r r
rW �buyercall.lib.util_webhooksr �buyercall.extensionsr �(buyercall.blueprints.phonenumbers.modelsr �!buyercall.blueprints.leads.modelsr �"buyercall.blueprints.agents.modelsr � buyercall.blueprints.user.modelsr r r �'buyercall.blueprints.partnership.modelsr r �)buyercall.blueprints.phonenumbers.routingr r r r r� �DAYSr` r> r� �taskr} r� r� r� r� r� r� r� r4 rS r{ r{ r{ r| �<module> sj
^
$
`
P
Z
/
'
X