File: //home/arjun/projects/buyercall/buyercall/blueprints/sms/__pycache__/models.cpython-310.pyc
o
�we3 � @ s� d dl Zd dlZd dlmZ d dlmZmZ d dlm Z
d dl m Z d dl
mZ d dlmZ d dlmZ G d d
� d
eej�ZG d d � d eej�ZdS )
� N)�hybrid_property)�select�func)�
postgresql)�UUID)�
ResourceMixin)�db)�EncryptedValuec @ sj e Zd ZdZejejdd�Zejedd�de j
dd�Z eje� d�ddd �Z
eje� d�dddd
�Zeje� d �ddd �Zeje� d �ddd �Zejed �dddd �Zejed �dddd �Zejed
�ddd �Zeje� d�dd�Zejed�dd�Zeje� d �ddd �Zeje� d �dd�Zejejdd�Zeje� d�dd�Zeje� d �ddd �Zejejej ddddd�ddd�Z ejejej ddddd�ddd�Z ejejej ddddd�ddd�Z ejed �dddd �Z eje!j"dd d �Z#e$d d � �Z%e$d d � �Z&e&j'd!d � �Z&e$d"d#� �Z(e(j'd$d#� �Z(e$d%d&� �Z)e*d'd(� �Z+e*d)d*� �Z,e-d0d+d,��Z.e-d-d.� �Z/d/S )1�Message�messagesT�� primary_key)�as_uuid)�unique�default�index� F� )�nullable�server_default)r r r �@ )r r r i �
�r i � �phonenumbers.id�message_inbound_fkey�CASCADEzSET NULL)�name�onupdate�ondelete�r r �partnership_accounts.id� message_partnership_account_fkey� contacts.id�message_contact_fkeyz[]c C sb ddl m} g }d}| jr/|j�|j�| j�|j| jk��� }|D ]}|� |j
� q!d� |�}|S )Nr ��Agentr z, ) �"buyercall.blueprints.agents.modelsr& �agent_id�query�filter�id�in_�partnership_account_id�all�append� full_name�join)�selfr& �
agent_list�result�agents�agent� r7 �A/home/arjun/projects/buyercall/buyercall/blueprints/sms/models.py�
message_agentA s �
zMessage.message_agentc C � | j o| j jpdS �Nr ��inbound�
friendly_name�r2 r7 r7 r8 �message_sourceT � ��zMessage.message_sourcec C s� ddl m} ddlm} ddlm} |j�|j| jk�� � }|r9|j
r9t |j �
d�g��|j|j
k��d��
d�S t |j�
d�g��|j| jk��d��
d�S ) N� ��Phoner )�Endpointr% r � �phone)�phonenumbers.modelsrD �"buyercall.blueprints.mobile.modelsrE r' r& r) r* �
inbound_id�firstr( r r0 �label�wherer+ �limitr> )�clsrD rE r& �endpointr7 r7 r8 r@ Z s&
��
� �
� �c C r: r; r< r? r7 r7 r8 �sourcej rA zMessage.sourcec C s ddl m} |jS )NrB rC )rH rD r> )rO rD r7 r7 r8 rQ p s c C s | j ot| j�p dS r; )r= �strrJ r? r7 r7 r8 � source_idv s ��zMessage.source_idc C � | j �d�S )z1 Return the date/time this lead occurred
�%Y-%m-%d %H:%M:%S)�
created_on�strftimer? r7 r7 r8 �interaction_time| � zMessage.interaction_timec C rT )z; Return the date/time this lead record was updated
rU )�
updated_onrW r? r7 r7 r8 � updated_time� rY zMessage.updated_timec C s& t j�t j|k�}|r|�� S |�� S )z|
Get the messages by partnership account id: `paid`
count_only param: Boolean(return count if True)
)r
r) r* r- �countr. )rO �paid�
count_only� text_msgsr7 r7 r8 �get_by_partnership_account� s �z"Message.get_by_partnership_accountc K s | di |��}|� � |S )Nr7 )�save)rO �params�messager7 r7 r8 �create� s zMessage.createN)F)0�__name__�
__module__� __qualname__�
__tablename__r �Column�Integerr+ r �uuid�uuid4�sid�String�type�provider�provider_message_id�provider_message_dater �to�from_� body_text�num_media_files� media_url�status�
delivery_type�
delivery_code�delivery_description� direction�
ForeignKeyrJ r- �
contact_id�originating_number�pg�JSONr( r r9 r@ �
expressionrQ rS �propertyrX r[ � classmethodr` rd r7 r7 r7 r8 r
st �� �� ���
r
c @ s: e Zd ZdZejejdd�Zeje�d�dd�Z eje�d�dd�Z
eje�d�dd�Z eje�d�dd�Z eje�d�dd�Z
eje�d�dd�Zejejdd�Zeje�d�dd�Zeje�d�dd�Zejejejd d
d �dd d
�Zejejejddd �dd d
�Zejejejddd �ddd
�Zejejdd�ZdS )�MessageReporting�messages_reportingTr r r r r r r �!message_reporting_inbound_id_fkey)r Fr r! �*message_reporting_partnership_account_fkeyr# �!message_reporting_contact_id_fkeyN)re rf rg rh r ri rj r+ rn ro rp rq rv rx ry rz r{ r| r} rJ r- r~ r� r� r( r7 r7 r7 r8 r� � s: �� �� ��r� )�logging�logrk �sqlalchemy.ext.hybridr �sqlalchemy.sqlr r �sqlalchemy.dialectsr r� � sqlalchemy.dialects.postgresqlr � buyercall.lib.util_sqlalchemyr �buyercall.extensionsr �buyercall.lib.util_cryptor �Modelr
r� r7 r7 r7 r8 �<module> s