File: //home/arjun/projects/buyercall/buyercall/blueprints/contacts/__pycache__/models.cpython-310.pyc
o
�e6C � @ sF d dl Zd dlZd dlmZ d dlmZ d dlmZ d dl m
Z
m Z m Z m
Z
d dlmZmZ d dlmZmZmZ d dlmZmZmZmZ d d lmZ d d
lmZm Z m Z d d l m Z m Z d d lm!Z! d d
l"m#Z$ d dl%Z%d dl m
Z
m&Z& d dlmZ d dl'm(Z( d dlmZ d dlmZm)Z) d dlmZmZmZmZ d d lmZ d dl*m+Z+ d dl,m-Z- d dl.m/Z/ d dl0m1Z1 d dl2m3Z3 d dl4m5Z5 d dl6m7Z7 d dl8m9Z9 G dd� de9e7j:�Z;G d d � d e9e7j:�Z<G d d � d e9e7j:�Z=G d d!� d!e9e7j:�Z>G d"d#� d#e9e7j:�Z?G d$d%� d%e9e7j:�Z@G d&d'� d'e9e7j:�ZAG d(d)� d)e9e7j:�ZBG d*d+� d+e9e7j:�ZCG d,d-� d-e9e7j:�ZDG d.d/� d/e9e7j:�ZEG d0d1� d1e7j:�ZFe7�Gd2e7jHd3e7�Id4�d5d6�e7jHd7e7�Id8�d5d6��ZJe7�Gd9e7jHd3e7�Id4�d5d6�e7jHd:e7�Id;�d5d6��ZKG d<d=� d=e9e7j:�ZLG d>d?� d?e9e7j:�ZMG d@dA� dAe9e7j:�ZNG dBdC� dCe9e7j:�ZOdS )D� N)� OrderedDict)�datetime)�
postgresql)�and_�extract�Date�cast)�hybrid_property�
hybrid_method)� load_only�
joinedload�column_property)�select�func�case�exists)�update)r �date� timedelta)� AESCipher�EncryptedValue)�
Comparator)� current_app)r �desc)�UUID)r )r
�backref)� Appointment)�format_phone_number_bracket)�FormLead)�Lead)�Message)�User)�db)�
ResourceMixinc @ s� e Zd ZdZejejdd�Zejejejddd�dd�Z eje
d �dd
d �Z eje� d �dd
d �Z
eje� d �dd
d �Zejejdd
d �Zejejdd
d �Zeje� d �dd
d �Zejejdd
d �Zeje
d �dd
d �Zeje� d �dd
d �Zeje� d �dd
d �Zeje� d�dd
d �Zeje� d�dd
d �Zejejdd
d �Zejejdd�Zeje� d�dd
d �Zejejdd
d �Z eje� d �dd
d �Z eje� d�dd
d �Z e dd� �Z e dd� �Z!d
S )�ContactVehicle�contact_vehiclesT�� primary_key� contacts.id�contact_vehicles_fkey��nameF��nullable�@ � �r- �server_default� N� � � c
C s� zLt di d|�d|�d|�d|�d|�d|�d|�d|�d | �d
|
�d | �d | �d
|
�d|�d|�d|�d|�d|�d|��}tj�|� tj�� W dS tyg } zt�d�|�� W Y d}~dS d}~ww )zC
Create a contact vehicle (and interested vehicle)
�
contact_id� current_vin� current_make�
current_model� current_year�current_mileage�current_condition�
current_value� interest_vin�
interest_make�interest_model�
interest_year�
interest_trim�interest_stock�interest_price�interest_status�interest_mileage�interest_condition�interest_listing_urlTz)Error creating contact vehicle. Error: {}NF� ) r$ r" �session�add�commit� Exception�log�error�format)�clsr6 r7 r8 r9 r: r; r< r= r> r? r@ rA rB rC rD rE rF rG rH �contact_vehicle�erI rI �F/home/arjun/projects/buyercall/buyercall/blueprints/contacts/models.py�createN s` �������� �
� � �
�������
��zContactVehicle.createc C s� d}t j�tt j|k���� }|rr|r||_|r||_|r ||_|r%||_ |r*||_
|r/||_ |r4||_ | r9| |_
|
r>|
|_| rC| |_|rH||_| rM| |_|
rR|
|_|rW||_|r\||_|ra||_|rf||_|rk||_tj�� d}|S )zA
Update a contact vehicle
:return: bool
FT)r$ �query�filterr r6 �firstr7 r8 r9 r: r; r< r= r> r? r@ rA rB rC rD rE rF rG rH r" rJ rL )rQ r6 r7 r8 r9 r: r; r< r= r> r? r@ rB rC rA rD rE rF rG rH �resultrR rI rI rT r t s\
�
zContactVehicle.update)"�__name__�
__module__� __qualname__�
__tablename__r" �Column�Integer�id�
ForeignKeyr6 r r7 �Stringr8 r9 r: r; r< �Numericr= r> r? r@ rB rC rA rD rE rF rG rH � classmethodrU r rI rI rI rT r$ # s4
%r$ c @ � e Zd ZdZejejdd�Zeje�d�dd�Z eje�d�dd�Z
ejde� � ddd �Z e
d
d � �Ze
d d
� �Ze
dd� �Ze
dd� �Ze
dd� �Ze
dd� �Ze
dd� �Ze
dd� �ZdS )� BdcStatuses� bdc_statusesTr& � Fr, �default�0r0 c
C � zat j�t�t j�|�� k��� }|r=t�|j |� tj�tj
|j k�� d�� � }t
|�dkr:d|_tj�� W dS W dS t � }|�� |_||_d|_tj�|� tj�� |j }t�||� W dS ty} } zt�dt|� � W Y d}~dS d}~ww )z(
Create new bdc status
� � TFz Error adding bdc status. Error: N)rf rV rW r �lower�statusrX � BdcStatusPartnershipAccountTie�add_status_tier` �
bdc_status_id�limit�all�lenri r" rJ rL � display_namerK �flushrM rN rO �str)rQ rv �partnership_account_idr � tie_count�new_bdc_status� status_idrS rI rI rT �
add_status� �: �
� �
��zBdcStatuses.add_statusc C �J t j�t j|k��� }|D ]
}t�|| |� q
|du r#t�|� dS dS )z8
Add bdc status to partnership account
N)rp rV rW ry rX rf �
add_source�add_status_defaults_to_tie�rQ � status_dictry �
ties_exist�sdrI rI rT �add_status_dict� � ��zBdcStatuses.add_status_dictc C �^ t j�t j��t jdk��� }tj�tj��tj |k��� }|D ] }||vr,t�
||� q dS )zA
Add bdc status to defaults partnership account
TN) rf rV �
with_entitiesr` rW ri rt rp rr ry rq �rQ ry �default_statuses� status_ties�dsrI rI rT r� �" � � ��z&BdcStatuses.add_status_defaults_to_tiec
C � z<t �||� t j�t j|k��� }|dkr4tj�tj|k��� }|r7|j s:t
j � |� t
j �
� W dS W dS W dS W dS tyX } zt�dt|� � W Y d}~dS d}~ww )z$
Delete bdc status.
r �&Error removing bdc status tie. Error: N)rp �remove_status_tierV rW rr �countrf r` rX ri r" rJ �deleterL rM rN rO rx �rQ r| ry rz r rS rI rI rT �
remove_status �, � �
� ��zBdcStatuses.remove_statusc C sJ t j�t��tj|k��� }|rt|�dkr|S t j�t jdk��� }|S )z&
Get bdc status list.
r T) rf rV �joinrp rW ry rt ru ri )rQ ry �statuses�sourcesrI rI rT �get_assigned_status_list2 � � �z$BdcStatuses.get_assigned_status_listc C �x i }t j�t��t jt j��tj|k�� � }|r t
|�dkr/t j�t jt j��t j dk�� � }|D ]}|j||j< q1|S )z4
Get bdc status list as dictionary.
r T) rf rV r� rp r� ro rv rW ry rt ru ri �rQ ry rY r� �srI rI rT � get_assigned_status_list_as_dictF �$ � �z,BdcStatuses.get_assigned_status_list_as_dictc C �4 i }t j�t jt j��� }|D ]}|j||j< q|S )zD
Get list of all bdc statuses in dictionary format.
)rf rV r� ro rv rt �rQ � status_listr� r� rI rI rT � get_complete_status_list_as_dict` � �z,BdcStatuses.get_complete_status_list_as_dictc C �( d}|r|r||v r|| }|S |}|S �zg
Takes in a dictionary of statuses and a value.
Returns suitable display text.
r/ rI �rQ �list�valuerY rI rI rT �get_formatted_statusp � �z BdcStatuses.get_formatted_statusN)rZ r[ r\ r] r" r^ r_ r` rb ro rv �Booleanri rd r} r� r� r� r� r� r� r� rI rI rI rT rf � �,
&
rf c @ �X e Zd ZdZejeje�d�dd�Zejeje�d�dd�Z e
dd� �Z e
dd � �Z d
S ) rp �"bdc_status_partnership_account_tiezbdc_statuses.idTr& �partnership_accounts.idc
C s� z+t j�t j|kt j|k��� }|s)t � }||_||_tj� |� tj�
� W dS W dS t yG } zt �
dt|� � W Y d}~dS d}~ww )z,
Create new bdc status tie.
z$Error adding bdc status tie. Error: N)rp rV rW rr ry rX �marketing_source_idr" rJ rK rL rM rN rO rx �rQ r| ry � existing_tie�new_status_tierS rI rI rT rq � �&
�� � ��z-BdcStatusPartnershipAccountTie.add_status_tiec
C �h zt j�t j|kt j|k��� tj�� W dS t y3 } zt
� dt |� � W Y d}~dS d}~ww )z(
Delete bdc status tie.
r� N)
rp rV rW rr ry r� r" rJ rL rM rN rO rx �rQ r| ry rS rI rI rT �remove_source_tie� �
� ��z0BdcStatusPartnershipAccountTie.remove_source_tieN)
rZ r[ r\ r] r" r^ r_ ra rr ry rd rq r� rI rI rI rT rp � �
rp c @ s� e Zd ZdZejejdd�Zeje�d�dd�Z ejde�
� ddd �Z e d
d � �Z
e d d
� �Ze dd� �Ze dd� �Ze dd� �Ze dd� �Ze dd� �Ze dd� �Ze dd� �Ze d d � �Ze d d � �Zd S )!� Campaigns� campaignsTr& rh Fr, ri rj r0 c C s$ |� � �dd�}|dkr|rdS dS )N� r/ �
nocampaignTF)rn �replace)rQ rv �test_display_namerI rI rT �is_not_default_campaign� s z!Campaigns.is_not_default_campaignc
C s d}zdt �|�rdt j�t�t j�|�� k��� }|rDt� |j
|� |j
}tj�tj |j
k�� d��
� }t|�dkrAd|_tj�� |W S t � }||_d|_tj�|� tj�� |j
}t� ||� |W S W |S ty� } zt�dt|� � W Y d}~|S d}~ww )z*
Create new add campaign
���rl rm TFz Error adding campaign. Error: N)r� r� rV rW r rn rv rX � CampaignPartnershipAccountTie�add_campaign_tier` � campaign_idrs rt ru ri r" rJ rL rK rw rM rN rO rx )rQ rv ry r� r rz � new_campaignrS rI rI rT � add_campaign� sF
�
�
�
�"� ��zCampaigns.add_campaignc
C s� z*t j�t��tj|k��t j|k��� }|r%|js(||_ t
j � � W dS W dS W dS t
yF } zt�dt|� � W Y d}~dS d}~ww )z+
Update existing campaign
Tz Error updating campaign. Error: NF)r� rV r� r� rW ry r` rX ri rv r" rJ rL rM rN rO rx )rQ r` rv ry r rS rI rI rT �update_campaign� s, �
�
� � ��zCampaigns.update_campaignc C sT | j r&tj�tj|k��� }|D ]
}t�|| |� q|du r(t�|� dS dS dS )z;
Add campaign_dict to partnership account
N) r� r� rV rW ry rX r� r� � add_campaign_defaults_to_tie)rQ �
campaign_dictry r� r� rI rI rT �add_campaign_dict s �� zCampaigns.add_campaign_dictc C r� )z?
Add campaign to defaults partnership account
TN) r� rV r� r` rW ri rt r� r� ry r� )rQ ry �default_campaigns�
campaign_tiesr� rI rI rT r� r� z&Campaigns.add_campaign_defaults_to_tiec
C r� )z"
Delete campaign.
r �$Error removing campaign tie. Error: N)r� �remove_campaign_tierV rW r� r� r� r` rX ri r" rJ r� rL rM rN rO rx )rQ r� ry rz r rS rI rI rT �remove_campaign+ r� zCampaigns.remove_campaignc C sR t j�t��tj|k��� }|rt|�dkr|dfS t j�t jdk��� }|dfS )z$
Get campaign list.
r FT) r� rV r� r� rW ry rt ru ri )rQ ry r� rI rI rT �get_assigned_campaign_listE s � �z$Campaigns.get_assigned_campaign_listc C sn i }d}t j�t��tj|k��� }|rt|�dkr&t j�t jdk��� }nd}|D ]}|j ||j
< q*||fS )z2
Get campaign list as dictionary.
Tr F) r� rV r� r� rW ry rt ru ri rv r` )rQ ry rY �defaultCampaignsr� r� rI rI rT �"get_assigned_campaign_list_as_dictY s$ � �z,Campaigns.get_assigned_campaign_list_as_dictc C s0 i }t j�t j��� }|D ]}|j||j< q
|S )z@
Get list of all campaign in dictionary format.
)r� rV r� rv rt r` )rQ �
campaign_listr� r� rI rI rT �"get_complete_campaign_list_as_dictt s �z,Campaigns.get_complete_campaign_list_as_dictc C r� )zh
Takes in a dictionary of campaigns and a value.
Returns suitable display text.
r/ rI r� rI rI rT �get_formatted_campaign� r� z Campaigns.get_formatted_campaignc C s t j�t��tj|k��� }d S �N)r� rV r� r� rW ry rt )rQ r� ry r� rI rI rT �get_campaign_by_name� s �z Campaigns.get_campaign_by_nameN)rZ r[ r\ r] r" r^ r_ r` rb rv r� ri rd r� r� r� r� r� r� r� r� r� r� r� rI rI rI rT r� � s6
,
r� c @ r� ) r� � campaign_partnership_account_tiez campaigns.idTr& r� c
C � z+t j�t j|kt j|k��� }|s)t � }||_||_tj�|� tj� � W dS W dS t
yG } zt � dt
|� � W Y d}~dS d}~ww )z*
Create new campaign tie.
z"Error adding campaign tie. Error: N)r� rV rW r� ry rX r" rJ rK rL rM rN rO rx )rQ r� ry r� �new_campaign_tierS rI rI rT r� � s&
�� � ��z.CampaignPartnershipAccountTie.add_campaign_tiec
C r� )z&
Delete campaign tie.
r� N)
r� rV rW r� ry r� r" rJ rL rM rN rO rx )rQ r� ry rS rI rI rT r� � r� z1CampaignPartnershipAccountTie.remove_campaign_tieN)
rZ r[ r\ r] r" r^ r_ ra r� ry rd r� r� rI rI rI rT r� � s
r� c @ re )�MarketingSources�marketing_sourcesTr& rh Fr, ri rj r0 c
C rk )z.
Create new marketing source
rl rm TFz&Error adding marketing source. Error: N)r� rV rW r rn �sourcerX �$MarketingSourcePartnershipAccountTie�add_source_tier` r� rs rt ru ri r" rJ rL rv rK rw rM rN rO rx )rQ rv ry r rz �new_marketing_source� source_idrS rI rI rT r� � r~ zMarketingSources.add_sourcec C r )z>
Add marketing source to partnership account
N)r� rV rW ry rX r� r� �add_source_defaults_to_tie)rQ � source_dictry r� r� rI rI rT �add_source_dict� r� z MarketingSources.add_source_dictc C r� )zG
Add marketing source to defaults partnership account
TN) r� rV r� r` rW ri rt r� r� ry r� )rQ ry �default_sources� source_tiesr� rI rI rT r� r� z+MarketingSources.add_source_defaults_to_tiec
C r� )z*
Delete marketing source.
r �,Error removing marketing source tie. Error: N)r� r� rV rW r� r� r� r` rX ri r" rJ r� rL rM rN rO rx )rQ r� ry rz r rS rI rI rT �
remove_source r� z MarketingSources.remove_sourcec C �J t j�t��tj|k��� }|rt|�dkr|S t j�t jdk��� }|S )z,
Get marketing source list.
r T) r� rV r� r� rW ry rt ru ri )rQ ry r� rI rI rT �get_assigned_source_list6 r� z)MarketingSources.get_assigned_source_listc C r� )z0
Get source list as dictionary.
r T) r� rV r� r� r� r� rv rW ry rt ru ri )rQ ry rY r� r� rI rI rT � get_assigned_source_list_as_dictJ r� z1MarketingSources.get_assigned_source_list_as_dictc C r� )zI
Get list of all marketing sources in dictionary format.
)r� rV r� r� rv rt )rQ � source_listr� r� rI rI rT � get_complete_source_list_as_dictd r� z1MarketingSources.get_complete_source_list_as_dictc C r� )zf
Takes in a dictionary of sources and a value.
Returns suitable display text.
r/ rI r� rI rI rT �get_formatted_sourcet r� z%MarketingSources.get_formatted_sourceN)rZ r[ r\ r] r" r^ r_ r` rb r� rv r� ri rd r� r� r� r� r� r� r� r� rI rI rI rT r� � r� r� c @ r� ) r� �(marketing_source_partnership_account_tiezmarketing_sources.idTr& r� c
C r� )z2
Create new marketing source tie.
z*Error adding marketing source tie. Error: N)r� rV rW r� ry rX r" rJ rK rL rM rN rO rx )rQ r� ry r� �new_marketing_tierS rI rI rT r� � r� z3MarketingSourcePartnershipAccountTie.add_source_tiec
C r� )z.
Delete marketing source tie.
r� N)
r� rV rW r� ry r� r" rJ rL rM rN rO rx )rQ r� ry rS rI rI rT r� � r� z6MarketingSourcePartnershipAccountTie.remove_source_tieN)
rZ r[ r\ r] r" r^ r_ ra r� ry rd r� r� rI rI rI rT r� � r� r� c @ re )�Statusr� Tr& rh Fr, ri rj r0 c C r )z6
Add statuses to partnership account
N)�StatusPartnershipAccountTierV rW ry rX r� r} r� r� rI rI rT r� � r� zStatus.add_status_dictc
C rk )z$
Create new status
rl rm TFz Error adding status. Error: N)r� rV rW r rn ro rX r� rq r` r| rs rt ru ri r" rJ rL rv rK rw rM rN rO rx )rQ rv ry r rz �
new_statusr| rS rI rI rT r} � r~ zStatus.add_statusc C r� )z=
Add status to defaults partnership account
TN) r� rV r� r` rW ri rt r� r| ry rq r� rI rI rT r� � r� z!Status.add_status_defaults_to_tiec
C r� )z
Delete status.
r �"Error removing status tie. Error: N)r� r� rV rW r| r� r� r` rX ri r" rJ r� rL rM rN rO rx r� rI rI rT r� r� zStatus.remove_statusc C r� )z"
Get status list.
r T) r� rV r� r� rW ry rt ru ri )rQ ry r� rI rI rT r� r� z Status.get_assigned_status_listc C r� )z0
Get status list as dictionary.
r T) r� rV r� r� r� ro rv rW ry rt ru ri r� rI rI rT r� 4 r� z'Status.get_assigned_status_list_as_dictc C r� )z@
Get list of all statuses in dictionary format.
)r� rV r� ro rv rt r� rI rI rT r� N s
z'Status.get_complete_status_list_as_dictc C r� r� rI r� rI rI rT r� [ r� zStatus.get_formatted_statusN)rZ r[ r\ r] r" r^ r_ r` rb ro rv r� ri rd r� r} r� r� r� r� r� r� rI rI rI rT r� � s,
&
r� c @ r� ) r� � status_partnership_account_tiez statuses.idTr& r� c
C r� )z(
Create new status tie.
z Error adding status tie. Error: N)r� rV rW r| ry rX r" rJ rK rL rM rN rO rx r� rI rI rT rq q r� z*StatusPartnershipAccountTie.add_status_tiec
C r� )z$
Delete status tie.
r� N)
r� rV rW r| ry r� r" rJ rL rM rN rO rx r� rI rI rT r� � r� z-StatusPartnershipAccountTie.remove_status_tieN)
rZ r[ r\ r] r" r^ r_ ra r| ry rd rq r� rI rI rI rT r� l r� r� c @ s� e Zd ZdZejejdd�Zeje�d�dddd�Z eje�d�dddd�Z
eje�d �dddd�Z eje�d
�dddd�Z eje�d �dddd�Z
eje�d�dddd�Zeje�d�dddd�Zeje�d �dddd�Zejd e�� dd
d�Zejde�� dd
d�Zejejddd�Zejejejdddd�ddd�Zejejejdddd�ddd�Zedd� �Ze dd� �Z e dd� �Z e d d � �Z e d d � �Z e d d!� �Z!e d"d#� �Z"e d$d%� �Z#d&S )'�
CreditReports�credit_reportsTr& rh Fr/ ��indexr- r1 i r3 r. r5 �
is_successfulrj r0 � is_approvedz{}r( �CASCADE��onupdate�ondelete�r� r- r� c C s( | j }t�d�}|�|�}|�d�}|S )z; Return the date/time this credit report was added
z
US/Eastern�%Y-%m-%d %H:%M:%S)�
created_on�pytz�timezone�
astimezone�strftime)�selfr �tz�local_dt�est_timerI rI rT �created_datetime� s
z CreditReports.created_datetimec C s4 t j�| ��| j|k| j|k��� }|dur|S dS )�Z
Find and return the a partnership account's contact credit score object.
N)r" rJ rV rW ry r6 rt )rQ �cid�paid�credit_score_objectrI rI rT �contact_credit_score_object� s
��z)CreditReports.contact_credit_score_objectc C s4 t j�| ��| j|k| j|k��� }|dur|S dS )r Nr )r" rJ rV rW ry r6 r� )rQ r r �credit_report_countrI rI rT �contact_credit_report_count� s
��z)CreditReports.contact_credit_report_countc C sf t �� j}t �� j}| j�t| j|k| jdkt d| j
�|kt d| j
�|k��� | j ��
� }|r1|S dS )�F
Get equifax lead count for current month per account
�
Offerlogix�year�monthr �r �nowr r rV rW r ry �service_providerr r �distinctr6 r� �rQ r r: �
current_monthr� rI rI rT �$current_month_eq_credit_report_count� s
� �z2CreditReports.current_month_eq_credit_report_countc C �j t �� j}t �� jd }| j�t| j|k| jdkt d| j
�|kt d| j
�|k��� | j ��
� }|r3|S dS )zG
Get equifax lead count for previous month per account
rm r r r r r �rQ r r: �
last_monthr� rI rI rT �!last_month_eq_credit_report_count� �
� �z/CreditReports.last_month_eq_credit_report_countc C r )zI
Get equifax lead count for previous 2 month per account
rl r r r r r r! rI rI rT �%last_two_month_eq_credit_report_count r$ z3CreditReports.last_two_month_eq_credit_report_countc C sH | j �t| j|k| jdkt| jt�t� � k���
| j �� � }|r"|S dS )r r r )
rV rW r ry r r r r r �todayr r6 r� �rQ r r� rI rI rT � today_eq_credit_report_count s � �z*CreditReports.today_eq_credit_report_countc
C sR | j �t| j|k| jdkt| jt�t� � t
dd� k��� | j ��
� }|r'|S dS )z6
Get equifax lead count for yesterday
r rm ��daysr )rV rW r ry r r r r r r& r r r6 r� r' rI rI rT � yesterday_eq_credit_report_count" s � �z.CreditReports.yesterday_eq_credit_report_countN)$rZ r[ r\ r] r" r^ r_ r` rb r �
iframe_url�transaction_id� credit_score�score_card_name�
credit_bureau� product_type� descriptionr� r� r� �pg�JSON�tradesra r6 ry �propertyr
rd r r r r# r% r( r+ rI rI rI rT r� � sT ����
r� c @ s� e Zd ZdZejejdd�Zeje�d�ddd�Z eje�d�ddd�Z
eje�d�ddd�Z eje�d�ddd�Z eje�d�ddd�Z
ejd e�� dd
�Zejejejd d d
�ddd�Zejejejddd
�ddd�ZdS )�CreditReportsReporting�credit_reports_reportingTr& rh Fr r3 r5 r� r, r( �(credit_reports_reporting_contact_id_fkeyr* r� �1credit_reports_reporting_partnership_account_fkeyN)rZ r[ r\ r] r" r^ r_ r` rb r r- r0 r1 r2 r� r� ra r6 ry rI rI rI rT r7 1 s" � �
�r7 c @ sB e Zd ZdZejejdd�Zejedd�de j
dd�Z eje� � dd�Z
eje� � dd�Zejeje�d�dd�Zejejdd�Zeje�� dd d
�Zejd dd �Zejejejd
dddd�ddd�Zejejejddddd�ddd�Zedd� �Zedd� �Zedd� �Z e dd� �Z e d d � �Z e d d � �Z!e!j"d d � �Z!d!S )"� ContactNotes�
contact_notesTr& ��as_uuid��uniqueri r� Fr, r( r/ r0 r! �r zusers.id�contact_notes_user_id_fkeyr� �r+ r r r r� �%contact_note_partnership_account_fkeyc C s( |}t j�tdi |��� t j�� dS )zk
Return whether or not the agent schedule was created successfully.
:return: bool
TNrI )r" rJ rK r; rL )rQ �note� contactnoterI rI rT rU k s
zContactNotes.createc C sf |rt j�t�j|d��||||d�� t j�� dS t j�t�j|d��|||d�� t j�� dS )z]
Return whether the contact was updated successfully.
:return: bool
�r` )�
updated_on�text�
is_enabled�user_id)rH rJ rK T)r" rJ rV r; � filter_byr rL )rQ �contact_note_id�contact_note_text�contact_note_updated_date�contact_note_user_id�contact_note_enabledrI rI rT r x s$ ��
���
zContactNotes.updatec C s> zt j�t�j|d��� }t j�� W dS ty Y dS w )zSReturn whether the contact was deleted successfully.
:return: bool
rG TF)r" rJ rV r; rL r� rL rM )rQ rM �_deletedrI rI rT r� � s
�zContactNotes.deletec C � | j �d�S )z. Return the date the note was created
r �rH r �r rI rI rT � date_edited� � zContactNotes.date_editedc C s | j jd | j j S �z@ Return the full name of the user that created the note
r� ��user� firstname�lastnamerU rI rI rT �
user_fullname� s zContactNotes.user_fullnamec C s | j j� d| j j� �S )Nr� rY rU rI rI rT r+ � s zContactNotes.namec C s2 t t�tjdtj��d�g��tj| j k��d�S )Nr� r+ rZ )
r r �concatr! r[ r\ �label�wherer` rK �rQ rI rI rT r+ � s
��N)#rZ r[ r\ r] r" r^ r_ r` r �uuid�uuid4�sid�DateTimer rH ra r6 r� rJ �TextrI � relationshiprZ rK ry rd rU r r� r6 rV r] r r+ �
expressionrI rI rI rT r; C sX �� ��
r; �contact_agent_associationr6 r( Tr& �agent_idz agents.id�contact_tag_association�tag_idzcontact_tag.idc @ sL e Zd ZdZejejdd�Zejedd�de j
dd�Z eje d�ddd �Z
eje d�ddd �Zeje d�ddd �Zeje d
�ddd �Zeje d
�ddd �Zeje d�ddd �Zeje d�ddd �Zeje d�ddd �Zeje�d
�ddd �Zeje�d
�ddd �Zeje d
�ddd �Zeje�d
�ddd �Zeje�d �ddd �Zeje�d �ddd �Zejejej d d
ddd�ddd�Z ejde� � ddd �Z ejde� � ddd �Z eje�d�dd�Z!eje�d�dddd�Z"eje�d�dddd�Z#eje�d�dddd�Z$ejejdd�Z%ejejdd�Z&eje d
�ddd �Z'eje�d�ddd �Z(eje�d�ddd �Z)eje� � dddd�Z*ejejdd�Z+eje�,� dd�Z-eje� � dddd�Z.ejde� � ddd �Z/ej0e1dd �Z2ej0e3ddd �Z4ej0e5dddd �Z6ej0e7ddd �Z8ej0e9dd �Z:ej0e;ddd �Z<ej0d e=e>dd d!�d d"�Z?e@eAeB�Ce1j�D� �g��EeFe1jGeke1j e k���Hd#�dd$�ZIe@eAeB�Ce7j�D� �g��EeFe7jGeke7j e k���Hd%�dd$�ZJe@eAeB�Ce3j�D� �g��EeFe3jGeke3j e k���Hd&�dd$�ZKe@eAeB�Ce1j�D� �g��EeFe1jGeke1j e k���Hd'�dd$�ZLe@eAe3j�D� g��EeFe3jGeke3j e k���Md(��Hd)�dd$�ZNe@ejB�OePeB�Qe�d*kd+fgdd,�ePeB�Qe�d-kd.fgdd,�ePeB�Qe�d/kd0fgdd,�ePeB�Qe�d1kd2fgdd,�ePe/d3kd4fgdd,�ePeIjRd5kd6fgdd,�ePeKjRd5kd7fgdd,�ePeJjRd5kd8fgdd,���ZSe@eAeTjUg��EeFeTjGekeTj e keTjV�Wd����XeTjY�Z� ��Md(��Hd9��ZUejejddd5d�Z[e\d:d;� �Z]e^d<d=� �Z_e]jRd>d;� �Z]e`d�d@dA��Zae`dBdC� �Zbe\dDdE� �Zce^dFdG� �Zde^dHdI� �Zee^dJdK� �Zfe^dLdM� �Zge^dNdO� �Zhe^dPdQ� �Zie^dRdS� �Zje^dTdU� �Zke^dVdW� �Zle`dXdY� �Zme`dZd[� �Zne`d\d]� �Zoe`d^d_� �Zpe`d`da� �Zqe`dbdc� �Zre`ddde� �Zse`dfdg� �Zte`dhdi� �Zue`djdk� �Zve`dldm� �Zwe`dndo� �Zxe`dpdq� �Zydrds� Zzdtdu� Z{dvdw� Z|dxdy� Z}dzd{� Z~e`d|d}� �Ze`d~d� �Z�e`d�d�� �Z�e`d�d�� �Z�d�d�� Z�d?S )��Contact�contactsTr& r= r? rh Fr/ r0 r. r2 r� � contact_partnership_account_fkeyr� rC r �is_do_not_callrj �is_unsubscriber, � no statusr� � no sourcer5 �r- r1 ri �
is_eq_lead�contactrA )r �passive_deletes)r �uselistrw �Agent�dynamic��lazy)� secondaryr r| � sms_count)�deferred�
form_count� phone_count�
sms_sourcerm � phone_source�apizapi-)�else_�importzimport-�mobilezmobile-�
adf_importzadf-�1zcredit-r zsms-zphone-�formr. c C �V d}| j r| jrd�| j | j�}|S | j r | js | j }|S | j s)| js)| jr)| j}|S �N�Unknownz{} {})r[ r\ rP � caller_id�r rY rI rI rT r+ S � ��z Contact.namec C s | j dk rdS | j dk rdS dS )N� �cold�< �warm�hot)� intent_scorerU rI rI rT �get_intent_state^ s
zContact.get_intent_statec C sJ | j r| jr| j d | j S | j r| js| j S | j s#| js#| jr#| jS dS )Nr� r� )r[ r\ r� ra rI rI rT r+ g s Nc C sR |r| j �| j|k��� }|r|S |r'| j �| j|k| j|kB ��� }|r'|S d S r� )rV rW �emailrX �
phonenumber_1�
phonenumber_2)rQ r� �phonerv rI rI rT �findq s z Contact.findc C s: | � }||_ d|_d|_||_|�d�d |_|�� |S )N�new�lead�@r )r� ro �
bdc_statusry �splitr[ �save)rQ r� r rv rI rI rT �create_from_mail} s zContact.create_from_mailc C r� r� )r[ r\ rP r� r� rI rI rT � message_name� r� zContact.message_namec C s | j d | j S rX )r[ r\ rU rI rI rT r] � s zContact.user_fullnamec C s. t t�tj�g��ttj| jktj| jk��S r� ) r r r� r r` r` r r6 ry rU rI rI rT � total_calls� s �zContact.total_callsc C s* t j�t��| jt jkt jdk��� }|S )z4 Return the number of notes for this number
T) r; rV r� rm rW r` r6 rJ r� )r � count_resultrI rI rT �
note_count� s
��zContact.note_countc C rS )z7 Return the date/time this contact was created
r )r r rU rI rI rT r
� rW zContact.created_datetimec C rS )z7 Return the date/time this contact was updated
r rT rU rI rI rT �updated_datetime� rW zContact.updated_datetimec C s | j r | j �d�S dS )z? Return the date/time this contact was deactivated on.
r r/ )�deactivated_onr rU rI rI rT �deactivated_on_datetime� s z Contact.deactivated_on_datetimec C s$ | j rt| j �S | jrt| j�S dS )z,Return formatted phonenumber for the contact� unavailable)r� r r� rU rI rI rT � phonenumber� s
zContact.phonenumberc C � | j rt| j �S dS �z.Return formatted phonenumber_1 for the contactr/ )r� r rU rI rI rT �formatted_phonenumber_1� �
z Contact.formatted_phonenumber_1c C r� r� )r� r rU rI rI rT �formatted_phonenumber_2� r� z Contact.formatted_phonenumber_2c C s` t �� j}t �� j}| j�t| j|k| j� d�t
d| j �|kt
d| j �|k��� � }|r.|S dS )�:
Get equifax lead count for current month
Tr r r �
r r r r rV rW r ry ru �is_r r r� r rI rI rT � current_month_equifax_lead_count� s
��z(Contact.current_month_equifax_lead_countc C s| t �� j}t �� jd }|dkrd| }|d }| j�t| j|k| j� d�t
d| j �|kt
d| j �|k��� � }|r<|S dS )�;
Get equifax lead count for previous month
rm r � Tr r r� �rQ r r r" r� rI rI rT � last_month_equifax_lead_count� �
��z%Contact.last_month_equifax_lead_countc C �| t �� j}t �� jd }|dkrd| }|d }| j�t| j|k| j� d�t
d| j �|kt
d| j �|k��� � }|r<|S dS )r� rl r r� rm Tr r r� r� rI rI rT �!last_two_month_equifax_lead_count� r� z)Contact.last_two_month_equifax_lead_countc C r� )r� � r r� rm Tr r r� r� rI rI rT �#last_three_month_equifax_lead_count r� z+Contact.last_three_month_equifax_lead_countc C sB | j �t| j|k| j�d�t| jt�t �
� k��� � }|r |S dS )r� Tr ) rV rW r ry ru r� r r r r r& r� r' rI rI rT �today_equifax_lead_count s
��z Contact.today_equifax_lead_countc
C �T | j �t| j|k| j�d�t| jt�t �
� t dd� k��� � }t
|� |r(|S dS )r� Trm r) r �rV rW r ry ru r� r r r r r& r r� �printr' rI rI rT � yesterday_equifax_lead_count, �
��z$Contact.yesterday_equifax_lead_countc
C r� )zC
Get equifax lead count for 2 days back from today
Trl r) r r� r' rI rI rT � day_before_equifax_lead_count: r� z%Contact.day_before_equifax_lead_countc
C s| d}z t di |��}d|_tj�|� tj�� |j}tj�� W |S ty= } zt �
d� |�� W Y d}~dS d}~ww )zD
Create contacts via the API.
:return: int
r� Tz!Error creating contact. Error: {}NrI ) rm �
api_sourcer" rJ rK rw r` rL rM rN rO rP )rQ �paramsr6 rv rS rI rI rT �
api_createH s
���zContact.api_createc C s| d}t j�tt j|kt j|k���� }|dur�d|_|dur%|dur%||_|dur0|dur0||_ |dur;|dur;||_
|durB||_ |durI||_ | durP| |_
|
durW|
|_| dur^| |_| dure| |_|
durl|
|_|durs||_|durz||_|dur�||_|dur�||_|dur�||_|dur�||_|dur�||_|dur�||_|dur�||_|dur�||_||_ t j � � d}|S )zE
Update contacts via the API.
:return: bool
FNTr/ ) rm rV rW r ry r` rX r� r[ r\ r� rj �birthday�avatar� large_avatarr� � address_1� address_2�city�state�country�zip�ip�is_deactivatedro rp rq r� � api_token_idr" rJ rL )rQ ry r� r6 r[ r\ r� rj r� r� r� r� r� r� r� r� r� r� r� r� ro rp rq r� rY rv rI rI rT �
api_update_ sh �
zContact.api_updatec
C sx z$| j �| j�|���� }|D ]
}||_tjtj d�|_
qt j �
� W dS ty; } z t|� W Y d }~dS d }~ww )N)r
FT)rV rW rd �in_rt ro r r r �utcrH r" rJ rL rM r� )rQ r� � contact_sids�leadsr� rS rI rI rT �update_manual_status� s ���z Contact.update_manual_statusc C sL t j�tt j|kt j|k���� }|dur$d|_t� � |_
t j �
� dS dS )ze
Deactivate contact. The is_active flag will be set to false.
:return: bool
NTF)rm rV rW r r` ry rX r� r r r� r" rJ rL )rQ r` ry rv rI rI rT �api_deactivate� s �
zContact.api_deactivatec
K s� t j�tt j|kt j|k���� }|rbz7dD ]}||�� v r(t||d� ||= qt||d� q|� � D ]
\}}t|||� q3t
� � |_ t
j�� W dS tya } z t|� W Y d}~dS d}~ww dS )zL
Update contacts via the mobile API.
:return: bool
)rq rp TFN)rm rV rW r r` ry rX �keys�setattr�itemsr r r� r" rJ rL rM r� ) rQ r` ry �kwargsrv �arg�keyr� rS rI rI rT �mobile_api_update� s0 ��
��zContact.mobile_api_updatec C s t j�tt j|kt j|k���� }|r�|r tj�tj|k��� }|r/tj�tj|� � k��� }|r�|r>|j|_t
j � � dS |du r^t
t��tj|k�j|jd�}t
j �|� t
j � � dS |du r�|j|_t
j � � t
t��tj|k�j|jd�}t
j �|� t
j � � dS dS dS dS )zB
Update the contact status in contacts and leads.
F)�progress_statusN)rm rV rW r r` ry rX r� ro rn r" rJ rL r r r` r6 �values�execute) rQ r` r| � status_textry �
on_contactrv ro � update_stmtrI rI rT �
update_status� sH �� ��
� zContact.update_statusc C � dd� | j D �S )Nc S � g | ]
}|j d kr|j�qS )�primary��tag_typer+ ��.0�tagrI rI rT �
<listcomp> � z,Contact.get_primary_tags.<locals>.<listcomp>�� contact_tagsrU rI rI rT �get_primary_tags � zContact.get_primary_tagsc C r� )Nc S r� �r} r� r� rI rI rT r� r� z3Contact.get_secondary_tag_names.<locals>.<listcomp>r� rU rI rI rT �get_secondary_tag_names r� z Contact.get_secondary_tag_namesc C r� )Nc S s g | ] }|j d kr|�qS r� )r� r� rI rI rT r� # s z5Contact.get_secondary_tag_objects.<locals>.<listcomp>r� rU rI rI rT �get_secondary_tag_objects" r� z!Contact.get_secondary_tag_objectsc C r� )Nc S r� r� )r� rd r� rI rI rT r� & r� z.Contact.get_secondary_tags.<locals>.<listcomp>r� rU rI rI rT �get_secondary_tags% r� zContact.get_secondary_tagsc C r� )Nc S r� )�customr� r� rI rI rT r� ) r� z+Contact.get_custom_tags.<locals>.<listcomp>r� rU rI rI rT �get_custom_tags( r� zContact.get_custom_tagsc C s | j �| j�|��S r� )rV rW r` r� )rQ � contact_idsrI rI rT �get_by_id_list+ s zContact.get_by_id_listc C s | j �| j|�� k��� S r� )rV rW ro rn rt )rQ ro rI rI rT �
get_by_status/ s zContact.get_by_statusc C sz | � |�\}}| j�| j�|��}|r|�| j|k�}|r%|�| j|k�}|r3|�| j|k| j|k �}|�t | j
��� � S r� ) � _get_intent_scores_from_staterV rW r` r� r� ro r� �order_byr rH rt )rQ �_type�idsro � intent_state�intent_score_min�intent_score_maxrV rI rI rT � get_leads3 s zContact.get_leadsc C s( |dkrdS |dkr dS |dkrdS dS )Nr� )r r� r� )r� r� r� )r� �e )r r rI )rQ r rI rI rT r ? s z%Contact._get_intent_scores_from_statec C s. ddl m} |�|�}| j�|� | �� | S )Nr )ry )�"buyercall.blueprints.agents.modelsry �
get_from_sids�assigned_agents�extendr� )r �
agent_sidsry �agentsrI rI rT �
assign_agentsJ s
zContact.assign_agents)NN)�rZ r[ r\ r] r" r^ r_ r` r rb rc rd r r[ r\ r� r� r� r� r� r� rb r� r� r� r� r� �external_source_typera ry r� rp rq �agent_assignedro r� �marketing_sourcer� rj r� r� r� r� r� re r� r� ru rg r �messagesr r� r$ �vehicler �
form_leadsr; � note_listr � appointments�
contact_agentr r r
r r r� r r` r r6 r_ r~ r� r� r� rs r� r^ r rn rh r� r� r. r� r� r r r r� r r+ r6 r� rd r� r� r� r] r� r� r
r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r rI rI rI rT rm � sl ' ����� �
���������������
���
W
%
rm c @ s� e Zd ZdZejejdd�Zejedd�de j
dd�Z ejejej dddd�dd d
�Z
ejd d d
�Zejejej dddd�ddd
�Zejejej dddd�ddd
�Zejdd d
�Zejejej dddd�ddd
�Zejdd d
�Zejejej dddd�ddd
�Zejejej dddd�ddd
�Zejejej dddd�ddd
�Zejejd d dd�Zeje�d�dd�Zdd� Z e d d � �Z e d d � �Z d S )!�ContactChannelTie�contact_channels_tieTr& r= r? r( r� r� Fr rm �contact_channel_tiesrA z
channel.idzleads.idr z messages.idr zchat.idzemail.idz
form_leads.id�false)r- ri r1 �d r, c C s t | jj�pdS )Nr/ )rx � contact_objrd rU rI rI rT �__str__� r� zContactChannelTie.__str__c C � | j S r� )� is_bannedrU rI rI rT ro � s zContactChannelTie.statusc C s | j �t��tj|k��� S r� )rV r� rm rW ry rt )rQ r rI rI rT �get_by_partnership_account� s z,ContactChannelTie.get_by_partnership_accountN)!rZ r[ r\ r] r" r^ r_ r` r rb rc rd ra rv rg r �
channel_id�call�call_obj�message� message_obj�chatr� �web_formr� r" rb �
banned_reasonr r6 ro rd r# rI rI rI rT r R st �������
�
r c @ s� e Zd Zeg d��ZdZejejdd�Z eje
dd�de j dd�Z
eje�d�dd �Zejejed
d i�ddd d
�Zeje�� dddd�Zejdedejddd�d�Zdd� Zed dd��Zed dd��Zed d d ��Z dS ) � ContactTags))r� �Primary)r} � Secondary)r� �Custom� contact_tagTr& r= r? rh Fr, r+ � tag_typesr� r� r� rt rm �subqueryr� r{ )r} r| r c C r! r� r* rU rI rI rT r � s zContactTags.__str__Nc C �: |rz
| j �| j�|���� W S ty g Y S w g S r� )rV rW rd r� rt rM )rQ �sidsrI rI rT � get_by_sids� � �zContactTags.get_by_sidsc C s6 |rz | j �| j|k��� W S ty Y d S w d S r� )rV rW r+ rX rM )rQ r+ rI rI rT � get_by_name� s �zContactTags.get_by_namec C r3 r� )rV rW r+ �anyrt rM )rQ �namesrI rI rT � get_by_names� r6 zContactTags.get_by_namesr� ) rZ r[ r\ r � TAG_TYPESr] r" r^ r_ r` r rb rc rd rb r+ �Enumr� r� � is_activerg �
contacts_tagsr rn r rd r5 r7 r: rI rI rI rT r, � s( �
� r, c @ sv e Zd ZdZejejdd�Zeje�d�ddd�Z eje�d�ddd�Z
eje d�ddd�Z eje�d�ddd�Z
ejejejd d
d �ddd �Zejd
e�� ddd�Zejde�� ddd�Zeje�d�dd�Zeje�d�ddd �Zeje�d�dddd�Zeje�d�dddd�Zejejdd�Zejejdd�Zeje�� dddd�Zejejdd�Zejde�� ddd�ZdS )�ContactReporting�contacts_reportingTr& r. Fr/ r0 r2 r� �*contact_reporting_partnership_account_fkeyr* r rp rj rq rh r, rr r� rs rt ru N) rZ r[ r\ r] r" r^ r_ r` rb r� r� r r� r ra ry r� rp rq r ro r� r r� rj r� r� ru rI rI rI rT r? � s2 ���r? )P�loggingrN rb � collectionsr r �sqlalchemy.dialectsr r3 �
sqlalchemyr r r r �sqlalchemy.ext.hybridr r
�sqlalchemy.ormr r r
�sqlalchemy.sqlr r r r �sqlalchemy.sql.expressionr r r �buyercall.lib.util_cryptor r r �flaskr �appr r � sqlalchemy.dialects.postgresqlr r �(buyercall.blueprints.appointments.modelsr � buyercall.blueprints.filtersr �&buyercall.blueprints.form_leads.modelsr �!buyercall.blueprints.leads.modelsr � buyercall.blueprints.sms.modelsr � buyercall.blueprints.user.modelsr! �buyercall.extensionsr" � buyercall.lib.util_sqlalchemyr# �Modelr$ rf rp r� r� r� r� r� r� r� r7 r; �Tabler^ ra r r> rm r r, r? rI rI rI rT �<module> s� ! ?, q* ?, <, t�� Q9