File: //home/arjun/projects/buyercall/buyercall/blueprints/workflows/__pycache__/models.cpython-310.pyc
o
we] � @ s� d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dl m
Z
G dd� de
ej �Z G d d
� d
e
ej �Z
G d d � d e
ej �ZdS )
� N)�
postgresql)�UUID)�Team)�db)�
ResourceMixinc @ sz e Zd ZdZejejdd�Zejedd�de j
dd�Z eje� d�ddd �Z
eje�� dd
dd �Zd d
� Zedd� �ZdS )�
WordkflowType�
workflow_typeT�� primary_key��as_uuid��unique�default�index�@ F� ��nullable�server_default�1�r r r c C � | j S �N��name��self� r �G/home/arjun/projects/buyercall/buyercall/blueprints/workflows/models.py�__str__ � zWordkflowType.__str__c C � | j �| j|k��� r
dS dS �NTF��query�filterr �first��clsr r r r �is_name_exists � z WordkflowType.is_name_existsN)�__name__�
__module__� __qualname__�
__tablename__r �Column�Integer�idr �uuid�uuid4�sid�Stringr �Boolean� is_activer � classmethodr* r r r r r s r c @ s� e Zd ZdZejejdd�Zejedd�de j
dd�Z eje� � dddd�Z
ejejdd d
�Zejejdd d
�Zejejdd d �Zd d
� Zedd� �Zedd� �ZdS )�WorkflowConditionAction�workflow_condition_actionTr r r
Fr r z{}r �r r c C s
t | j�S r )�strr5 r r r r r % s
z WorkflowConditionAction.__str__c C �$ | j �| j|k��� }|r|jS i S r )r% r& r2 r' �
conditions�r) �aid�detailr r r �get_condition_by_id( � z+WorkflowConditionAction.get_condition_by_idc C r> r )r% r& r2 r' �actionsr@ r r r �get_actions_by_id- rD z)WorkflowConditionAction.get_actions_by_idN)r, r- r. r/ r r0 r1 r2 r r3 r4 r5 r7 �is_new_contactr �JSONr? rE � meta_datar r9 rC rF r r r r r: s
r: c @ s� e Zd ZdZejejdd�Zejedd�de j
dd�Z eje� d�ddd �Z
eje� d
�dd �Zeje�� dd dd
�Zejejddd�Zejejejdddd�ddd�Zejejejdddd�ddd�Zejejejdddd�ddd�Zejejejdddd�ddd�Zejejejdddd�ddd�Zejejejdddd�ddd�Zdd� Zedd� �Zed d � �Z d d � Z d d!� Z d"d#� Z d$d%� Z d&S )'�Workflow�workflowTr r r
r Fr r i )r r r �0r< zworkflow_type.id�CASCADE)�onupdate�ondelete)r r z workflow_condition_action.idzusers.idzpartnership_accounts.idzpartnerships.idc C r r r r r r r r L r! zWorkflow.__str__c C r" r# r$ r( r r r r* O r+ zWorkflow.is_name_existsc C s | j �| j|k| jdk��� S )NT)r% r& �partnership_account_idr8 �all)r) �pa_idr r r �get_by_partnership_accountS r+ z#Workflow.get_by_partnership_accountc C � t �| j�S r )r: rC �workflow_detailr r r r �get_conditionsW s zWorkflow.get_conditionsc C rT )r )r: rF rU r r r r � get_actionsZ s zWorkflow.get_actionsc C s t j�t j| jk��� S r )r: r% r& r2 rU r' r r r r �
get_detail^ s zWorkflow.get_detailc C sL | � � j}|�dg �}|�dg �}|D ] }t�|�}|�|� qtt|��S )N�agentIds�teamIds)rX rI �getr �get_agent_sids_by_team_sid�extend�list�set)r rI � agent_ids�team_ids�tid�team_agent_idsr r r � get_agents_assigned_in_actionsa s
z'Workflow.get_agents_assigned_in_actionsN)!r, r- r. r/ r r0 r1 r2 r r3 r4 r5 r6 r � descriptionr7 r8 �status�
ForeignKeyr rU �
created_by�
updated_byrP �partnership_idr r9 r* rS rV rW rX rd r r r r rJ 3 s^ �������� �� ��
rJ )r3 �sqlalchemy.dialectsr � sqlalchemy.dialects.postgresqlr �"buyercall.blueprints.agents.modelsr �buyercall.extensionsr � buyercall.lib.util_sqlalchemyr �Modelr r: rJ r r r r �<module> s