File: //home/arjun/projects/buyercall/buyercall/blueprints/mobile/__pycache__/tasks.cpython-310.pyc
o
�we^ � @ s� d dl Zd dlmZ d dlZd dlZd dlZd dlmZ d dlZd dl m
Z
d dlmZm
Z
mZ d dlmZ d dlmZ d dlmZ d dlZd dlZd dlZd d lmZ d d
lmZ d dlmZ d dlm Z d d
l!m"Z" d dl#m$Z$ d dl%m&Z&m'Z' d dl(m)Z) d dl*m+Z+ d dl,m-Z. d dl/m0Z0 d dl1m2Z2 ddl3m4Z4m5Z5 d dl6m7Z7 d dl8m9Z9 dZ:dZ;dZ<ej=dd�Z>e
e.�Z?e)� Z@e?jAd-dd��ZBe?jAdd � �ZCe?jA d.d!d"��ZDe?jAd#d$� �ZEe?jAd%d&� �ZFe?jAd'd(� �ZGe?jAd)d*� �ZHe?jAd+d,� �ZIdS )/� N)�datetime)�BytesIO)�create_celery_app)�
split_name�CallStorage�InboundCallState)� bw_client)�_try_renderer_template��send_ses_email)�Key)�db)�Lead)�Phone)�Endpoint)�Message)�format_phone_number�format_phone_number_bracket)�WebhookUtil)�current_app)�Contact)�text� ��Partnership�PartnershipAccount)� load_only)�and_i i�Q � �redis)�hostc K sF t j�t j| k��� }tj�tj|jk��� }ddlm}m } | j�| j|j
k��� }
t|�\}}d}
d}|s9|r=|dkrFt�
|j
|�\}}tj�|tjk|j
tj
k��tj�� ��� }tj�td���|tjk|j
tj
k��tj�� ��� }t j�tt j|kt j
|j
k���� }|r�|r�|j}n|}t�d�|�� |d ur�tj�tj|jk��tj
|j
k��� }|j}|j}|j}|j}
|j}|j}nGt |
j!dd�}t"j#�$d d
�r�|j%|dd�}n|�%|�}t�d
�|�� |s�d}t|||||j&d|j
d�}t'j(�)|� t'j(�*� t�d� |j}|�rd}|j}nd}td%i d|j
�d|�d|�d|�d|�d|
�dt+�,� �d|�d|j&�d|�d|�d|j�d|j-�d| �dd �d!|�d"|��}t'j(�)|� t'j(�*� tj�tj|k��tj�� ��� }t�d#�|�� tj�tj.|jk��tj
|j
k��� }|�r�|j/|_/t'j(�*� |jS t�d$� |jS )&Nr r � �Unknown�phonenumberz$The previous lead call number is: {}�mobile)�tn_type�DEBUGFT)�testz(The mobile call cnam lookup returned: {})� firstname�lastname� caller_id�
phonenumber_1�agent_id�email�partnership_account_idzThe contact has been added�outbound�inboundr. r( r* r) r- � starttime�progress_statusr, �call_sid� call_type�my_phone�call_source�
inbound_id�status�ringing�
contact_id�originating_numberzlatest lead: {}zno lead contact exist� )0r �query�filter�id�firstr r7 �'buyercall.blueprints.partnership.modelsr r r. r r �get_last_known_namer# �order_by�
created_on�desc�optionsr r5 r �log�info�formatr r: r( r) r- r8 r* r �partnership_id�celery�conf�get�cnam_lookupr, r
�session�add�commitr �utcnow�
friendly_namer+ �
updated_on)r7 �call_id�phone_number�sip_outbound�caller_name�kwargsr0 �sip_endpointr r �partner_account�
first_name� last_namer- r2 �
previous_lead�previous_operational_lead�operational_number�originating_call_number�contactr: r* �client�new_contact� direction�lead�latest_lead�lead_contactr<