U
e} @ st d dl Z d dlZd dlmZmZmZ d dlmZ d dlmZ d dl T d dl
m Z d dl m
Z
mZ G dd d e ZdS )
N)datetimetimezonedate)Path)
BeautifulSoup)*)CmfMessageMixin)before_request cmf_contextc s e Zd Zi Zeeje j
dgZ e ed< ej f eZ
dd fdd
Z fddZd d
Zd d Zed fdd Zdd Zd eedddZd ddZdd Zdd Z ZS ) CmfWhatsappzmodules/voip/templatesloaderr )depthc s t j|d|i|S )Nr
)supersave)selfr
argskwargs __class__ $./modules/crm/models/cmf_whatsapp.pyr s zCmfWhatsapp.savec s t t| j||}| d d S )NZwhatsapp_delete)r r deletesend_cmd)r r r resr r r r s zCmfWhatsapp.deletec C s | d dS )um
Отправляем событие на отключение сессии
:return:
Zwhatsapp_disconnectNr r r r r
disconnect s zCmfWhatsapp.disconnectc C s$ | dg | dd| jji d S )Nload_from_dateZwhatsapp_connect)Z load_fieldsr r Zjsonr r r r connect! s zCmfWhatsapp.connectNc s> |dkr$|sg }|dddgg}dg}t j|f||d|S )Nparentzstatus.status_typez!=ZCLOSEDZ CmfPipeline)filter models_list)r field_options_list)clsZrelation_field_namer r! r r r r r" % s z CmfWhatsapp.field_options_listc C s | d d S )NZwhatsapp_statusr r r r r check_status. s zCmfWhatsapp.check_status)cmddatac C s: |d krt }tj|d< | jj|d< t||dtd d d S )NZorg_nameZcrm_idz /whatsapp) namespaceZ
socket_clientZroom)dictconfigZORG_NAMEidvalueZcmf_emit_eventZ whatsapp_sio)r r% r& r r r r 1 s
zCmfWhatsapp.send_cmdc
O s |sd S | d}d }t j|}t } t|}
g } |
dD ](} d| jddkr>| t| dd q>|
dD ]} | t| d d qr| rV| D ]}
|
d
} | jd }t
d |d
}t j jdd|gdgd}t j |
dd | |dd}t|jd}| }W 5 Q R X t| }|| d< tjd|
dd | d< |
d | d< qn|
}t j || |dd}|r||_d|_||_| |jj | d < |j j | d < |j j | d < |j j | d < | d | |S )!Nz@s.whatsapp.netazcmf-fileclass file)objtypeimgimager0 srcz /files/.*r url==r )r Zfields/Zsending)textchannel client_idmessage_statusrb. mime_typer1 outphonemessageZcrm_message_id
message_idZwhatsapp_message_send)!models CmfPersonZ get_by_phoner( r ZfindAllZattrsgetappendrefindallZ
CmfAttachmentCmfChannelMessagesplitopen file_pathreadbase64Z b64encodedecode mimetypesZ types_mapZget_text chat_message message_flow person_tor r; r+ r9 r* rD r )r Z phone_numberrC rS r r r; channel_msgcontactparamsZsoupfilesr0 Z_fileZfull_urlZurl_pathZ
attachmentfr2 Z plain_msgr r r send_message9 s^
zCmfWhatsapp.send_messagec
O s | j | jdd tjj |d | jd}|r.d S t|d }| | jk rNd S tj|d}| |_|d |_ |d |_
|j
dd }tj j
|d
d d gd
}|d rd|_d|_||_n d|_||_d}d} |d r|d d|j d|jj }
| |d |
|d }d| } |d dkr.|d |_n|d dkrd| jd } t| dd } | jf | |_nL|d d krd | d |_n.|d d!krd"| d |d d#|_nd$|_| |S )%NT)Z
for_updateZId)rD Z
channel_idZ Timestamp) message_rawZ RemoteJid@r Z
user_localr6 F)r ZFromMerA sentinr. r/ z
%Y%m%d_%H%M%S_r@ z/filesr1 r9 ZTextZaudioz record.html)r5 r9 r3 z
Zdocumentz s