B
Y f @ 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
ejdg Zdd fdd
Z fdd Zd
d Zd d
Zed fdd Zdd Zd eedddZd ddZdd Zdd Z Z S ) CmfWhatsappzmodules/voip/templatesloader send_messager )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 Zres)r r r r s zCmfWhatsapp.deletec C s | d dS )um
Отправляем событие на отключение сессии
:return:
Zwhatsapp_disconnectN)r )r r r r
disconnect s zCmfWhatsapp.disconnectc C s$ | dg | dd| jji d S )Nload_from_dateZwhatsapp_connect)Z load_fieldsr r Zjson)r 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_status)r )r r r r check_status1 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 4 s
zCmfWhatsapp.send_cmdc
O s |sd S | d}d }t j|}t } t|}
g } x6|
dD ](} d| jddkr@| t| dd q@W x$|
dD ]} | t| d d qxW | rbx| D ]}
|
d
} | jd }t
d |d
}t j jdd|gdgd}t j |
dd | |dd}t|jd}| }W d Q R X t| }|| d< tjd|
dd | d< |
d | d< qW n|
}t j || |dd}|r||_d|_||_| |jj | d < |j j | d < |j j | d < |j j | d < | d | |S )!Nz@s.whatsapp.netazcmf-fileclass file)objtypeimgimager- srcz /files/.*r urlz==r )r Zfields/Zsending)textchannel client_idmessage_statusrb. mime_typer. 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 r7 r( r5 r' r@ r )r Z phone_numberr? rO r r r7 channel_msgcontactparamsZsoupfilesr- Z_fileZfull_urlZurl_pathZ
attachmentfr/ Z plain_msgr r r r
< sR
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)r@ Z
channel_idZ Timestamp) message_rawZ RemoteJid@r Z
user_localz==F)r ZFromMer= Zsentinr+ r, z
%Y%m%d_%H%M%S_r< z/filesr. r5 ZTextZaudioz record.html)r2 r5 r0 z
Zdocumentz s