File: //home/arjun/projects/buyercall/buyercall/blueprints/widgets/__pycache__/tasks.cpython-310.pyc
o
wey' � @ s d dl Z d dlZd dlZd dlZd dlZd dlmZmZ d dl m
Z
d dl m Z d dl
mZmZmZ d dlmZ d dlZd dlmZ d dlmZ d d lmZmZ d d
l m Z d d l m Z d Z e
e�Z e �!� d
d� �Z"e j!dd� �Z#e j!dd� �Z$e j!dd� �Z%e j!dd� �Z&e j!ddd��Z'dS )� N)�url_for� current_app)�create_celery_app)�db)� CallStorage�InboundCallState�subaccount_client)�Key)�Lead)�Agent)�PartnershipAccount� Partnership)�Contact)�
ses_clienti�Q c
K s t jtjd tjd d�}ddlm}m} t�d� t j
� t j �� t
j��t j| k��� }|s9t�d�| �� d S t
j
�t
j|jk��� }tj
�tj|jk��� }|j j}|s\|j jj}|jrjt�d�|j�� d S |jd v rvt�d
� d S t||j�} | � � d | _ d d � t |j j d
d� d�D �}
|
s�t�d� d S d|_| j!d7 _!t"j#�$� |j j%d r�t&|j� d S |j j%d r�t'�(|
� |j)} t*| |j�} || �}
z |
�+|
|j |� W d S t,�y } z t�-t.�/� � d|_t"j#�$� |||j � W Y d }~d S d }~ww )N�REDIS_CONFIG_URL�REDIS_CONFIG_PORT��host�port� )�Routing�after_call_eventsz Trying to call lead again...zLead {} not available.z0Partnership account {} has exceeded their quota.)�ringing� completedz!Lead is currently in another callc S s g | ] }|j jr|j�qS � )�agent�
available_now�agent_id)�.0�asgr r �D/home/arjun/projects/buyercall/buyercall/blueprints/widgets/tasks.py�
<listcomp>H s ��z call_again.<locals>.<listcomp>c S s | j S �N)�order)�xr r r �<lambda>J s z call_again.<locals>.<lambda>)�keyz*No agents were configured for this widget.r �routeSimultaneously�
routeRandomly�missed)0�redis� StrictRedis�celery�conf�routingr r �log�infor
�query�join�partnership_accountr � partnership�filter�id�first�warning�format�partnership_account_idr
�partnership_id� subscription�usage_over_limit�status�debugr �inc_callback_cntr �sorted�widget� assignments�
call_countr �session�commit�options�
call_parallel�random�shuffle�twilio_subaccount_sidr �route_sequential� Exception�error� traceback�
format_exc)�lead_id�kwargs�redis_dbr r �lead�partner_account�partnerr< �storage� agent_ids�subaccount_sid�client�r�er r r �
call_again sf
&�
�
�
��r] c K s� t jtjd tjd d�}ddlm}m}m} t� d� t
j � t
j
��t
j| k��� }tj �tj|jk��� }tj �tj|jk��� }|j
} || �}
td�|
�� |
sjt�d�| j�� d |_tj� � |||j
� t || �} t j | _ | �!� d
�| �} d �| �}
d �| �}|�"|
d
t# d� |�"|d
t# d� t$j �t$j�%|
���&� }t� d�t'|��� d }| j(j)}|s�| j(j*j)}|j+}t,||j�}||�}|D ]h}zC|�-||| �}| �.� �- | j/r�| j/t0|j�kr�|�1� W d � W nA|�2| d�|j|j3�� W d � n 1 �s w Y W q� t4�y2 } zt�t5�6� � t�d�|j�� W Y d }~q�d }~ww |d u �s>|j3d u �rO|�"|d
t# d� d |_tj� � |�7| d
t# � d S )Nr r r r )r r �get_available_agent_idszParallel call task started.z
Agent ids: {}z&No agents are available for widget {}.r) zLIST{}zSUCC{}z CONNECT{}� �0zCalling {} agents...z{}_{}zError calling agent {}...z-1)8r* r+ r, r- r. r r r^ r/ r0 r
r1 r2 rB r5 r6 �oner r: r7 r
r; �printr9 r8 r> r rE rF r �State�NEW�state�clear_retry_cnt�setex�DAYSr �in_�all�lenr3 r< r4 rK r �call_agent_parallel�lockr �str�hangup�lpush�sidrM rO rP �expire)rQ rR rS r r r^ rT rU rV rB rX rW �called_agents_key�lead_capture_key� connect_key�agents�callr< rY rZ r[ r r\ r r r rH k st
�
�� �����
rH c
K s� t j�t j��t j| k��� }tj�tj|jk�� � }t
j�t
j|j k�� � }|j}|j j
}|s5|j jj
}|j}t||j�} | jj|jj|jtd|j|ddd�td|jddd�d� d S )Nztwilio_api.lead_greetingT�https)rQ r � _external�_schemez$twilio_api.lead_outbound_call_status)rQ ry rz )�from_�to�url�status_callback)r
r1 r2 rB r5 r6 ra r r: r7 r
r; r3 r< r4 rK r �calls�create�inbound� phonenumberr )
rQ r rR rT rU rV rB r< rY rZ r r r � call_lead� s8 �
��
�r� c K s@ t j�t j| k��t j�� ��� }t� d�
|�� t j�t j |jk��t j
|k��� }|rat� d�
|j �� |j|_|jdkrB||_|jdkrJ||_|jdkrR||_t� d�
|j�� tj�� nt ||| ||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�
phonenumber_1�emailr: zThe contact has been addedzno lead contact exist)r
r1 r5 r� �order_by�
created_on�descr7 r/ r0 r9 r r� r: �
updated_onr� r� r� r rE rF �addr6 �
contact_id) r� r� r� r� r: rR � latest_lead�contact� new_contactr r r � add_contact� sF "�
�
�r� c K s� zd� | |d||�}t�d� |�� W t�d� nt�d� w t|d��6}t�tjd tjd �}|�tjd �} t | �}
||
_
|
� |� |
� d � t�
d
� |
j
�� W d � n1 s]w Y t�|� |
jd d
d�} | S )z, Upload the given MMS Image file to S3.
z
{}_{}/{}_{}{}� widget_imagezThe widget image key is {}z&Could not set key for widget image url�rb�AMAZON_ACCESS_KEY�AMAZON_SECRET_KEY�
WIDGET_BUCKETz public-readzUploaded file {}Nr F)�
expires_in�
query_auth)r9 r/ r? �open�boto�
connect_s3r, r- �
get_bucketr r& �set_contents_from_file�set_aclr0 �os�remove� generate_url) � partner_namer: � file_name� file_path�file_extrR r& �f�conn�bucket�k�
widget_urlr r r �upload_widget_image s(
� �
�
r� c O s t �| ||||�}|S r" )r �
send_email)�
recipients�subject�data�sender�argsrR � mail_statusr r r r� + s r� r" )(r� �loggingr/ rI rO r* �flaskr r �
buyercall.appr �buyercall.extensionsr �buyercall.lib.util_twilior r rc r � boto.s3.keyr r� �!buyercall.blueprints.leads.modelsr
�"buyercall.blueprints.agents.modelsr �'buyercall.blueprints.partnership.modelsr r
�$buyercall.blueprints.contacts.modelsr r rh r, �taskr] rH r� r� r� r� r r r r �<module> s<
L
R
$
+