U
VcY+ @ s d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlZd dlm Z d dl
m Z d dl T d dl
mZ d d lmZ d d
lmZ G d d d ejZdS )
N)copy)Path)urlparse)Linker)
BeautifulSoup)*fields)CmfActiveEntity)cmf_chat_messagec s e Zd Zedd Zedd Zdd Zdd Zd d
Z fd d Z d
d Z
dd Z fddZ fddZ
dd ZdddZ ZS )CmfChatMessagec sT fdd}t jjdd|d gdgd}tjj|d d d
tjjd }| |jk rZd S |d t j d }t jjdd|d gd
|_
|j
j d d |_
d d |_ d d rd|_|jdd }t j|}|sHt jj|d}|s`t j||j
j d}| |||d |j
j d |d d\} |_| d S n|j
|_|jr`| | }
||
_ d d s||
_t j j|jddgd} | r| j| jd gd } | j |
_ n$t j j|jd }
|
r|
|
_ n||
_ ||
j |d |j
j d |d d\} |
_| ||
_ |
t j j t!"d |
j j d d i t j #|
d d S )!Nc s t |}|| }tj| |d}| tj| |}t |j
j ddd t |d} |
t| W 5 Q R X |dkrd|j d}
nd|j d d d
}
||
fS ) N)parentnameT)parentsexist_okzwb+Zimagez
z Z responsibler r: )r@ Zcommentr, rD r r r r? f s z)CmfChatMessage._whatsapp_message_receivedc K s | dddg tjjdd| jgddtjjggd}| j dgd | jjrPg | _tjj j
| jj kr| jj
t
j
jt
jjd
tjj j
tjjj
d |r| | jD ](}|js|jtjjkrqd |_| q| jd
d d
S dS )Nzchannel_messages.channelz channel_messages.cmf_author_idz channel_messages.message_statusr7 r# person_idr' viewsr r& )r1 rE r readTZ only_dataF) load_fieldsr CmfChatTopicUnreadMessager0 r" gZcurrent_personrG is_nullrE r9 Zjsonappendr1 Znowr2 r3 Z isoformatr deleteZchannel_messagesr5 Z
cmf_author_idr. r )selfkwargsZunread_messagemsgr r r mark_readu s,
zCmfChatMessage.mark_readc C s | j r| j jjdkrd S | j jdddg | j| j j_| j j| j j_| j j | j j_
| j | j j_ | j jj
| j jjdd | | j _| j jjr| j d S )NZ CmfChatTopiczgroup.cache_last_topic_codezgroup.cache_last_topic_namezgroup.last_topicTrI )r
r9
class_namerJ r: groupZcache_last_comment_textrE Zcache_last_topic_coder Zcache_last_topic_nameZ
last_topicZcmf_modified_atZset_nowr rB r; rP r r r
_calc_chat s
zCmfChatMessage._calc_chatc
C sr d dd}| j jr| j jr dS tj}dddg|d< d g|d
< d g|d < d
ddg|d< tj}|d |d |d |d |d |d |d |d |d |d
tj| j jtj|d| _ t |gd}|
| j j| _ t | j jd}| d}t
|D ]P\}}|d} | d| |jd | jd< d | jd < d | jd < ||| q| | _ dS ) u
Защита от инжектов которые могу прилететь из внешних систем
:return:
Fc S s. | ds| S t| d }d| d< d| d< | S )N)Nhref_blank)NtargetZexternal)Nclass)r0 r )attrsnewpr r r
set_target s
z.CmfChatMessage._clean_text..set_targetNsrcwidthZheightimgr[ spanr1 timeZcontrolsrE Zaudior^ brZinsdelZfigureZ
figcaption)r: tags
attributes)Z callbacksz html.parserar rX zchat-imgrY rZ )F)r: r; rM bleachZALLOWED_ATTRIBUTESZ ALLOWED_TAGSrN Zcleanr9 r Zlinkifyr Zfind_all enumerateZnew_taginsertr\ Zprettify)
rP r_ rh rg ZlinkerZsoupZimagesirb linkr r r _clean_text s@
zCmfChatMessage._clean_textc s6 | | | | | t j||S N)rW _calc_notify _calc_cachero rS superr )rP argsrQ __class__r r r s zCmfChatMessage.savec K s6 | j r| j jr| jsdS | jr$d| _| | j j dS )u
Отправляем оповещения всем кроме автора комментария
:param kwargs:
:return:
NT)r: r; r
priorityZ importantZall_place_notifyr9 )rP rQ r r r rq s
zCmfChatMessage._calc_notifyc C s( | j r$| j j| _| j j| _| j j| _d S rp )r< ZloginZcache_cmf_author_loginrE Zcache_cmf_author_coder Zcache_cmf_author_namerV r r r rr s
zCmfChatMessage._calc_cachec s. | dg | jr | j tt| d S )Ndeal)rJ rx r> rs r rV ru r r r> s
zCmfChatMessage.emitc s t dddg S )Nz parent.groupr< rx )rs save_preload_fieldsrV ru r r ry s z"CmfChatMessage.save_preload_fieldsc K s\ | j rB| j}|j}tjj| j|d|j d|j d| jj| j d tj || | jd
d S )Nu% Важное сообщение в «u » — « »)objrF r rR rw )Zpersonr Z
chat_topic) rw r
rU r Z CmfNotifyZ place_notifyr r: r9 rK r )rP rF rQ ZctZcgr r r
_place_notify s z CmfChatMessage._place_notifyNc K s | dg | jj S )Nr
)rJ r
Z executorsZ
all_nested)rP r rQ r r r all_relation_persons s z#CmfChatMessage.all_relation_persons)N)__name__
__module__ __qualname__ classmethodrC r? rS rW ro r rq rr r> ry r| r}
__classcell__r r ru r r s
R
/ r )r r1 r r pathlibr Z urllib.parser rj r Zbs4r Z cmf.includeZcmfr Z common.models.cmf_active_entityr
Zmodules.crm.fieldsr r r r r r s