U .e@s`ddlZddlmZddlTddlTddlmZddlmZGdddejZe j ej dS)N) dataclass)*) cmf_notify) BaseModelcseZdZdZdZdZiZee j e j de j e j dgZeed<ejfeZeGdddZed d Zed d Zed dZed7ddZeddZeedddZeedddZed8ddZedddedd d!Zfd"d#Zed9d$d%Zed:d&d'Z ed(d)Z!e"e#j$ddd*d+d,Z%e"e#j$ddd*d-d.Z&ed/d0Z'ed1d2Z(e"e#j$ddd*d3d4Z)ed5d6Z*Z+S); CmfNotifyZNotifyZdeskZNTFzcommon/templatesz cmf/templatesloaderc@s*eZdZUdZdZeed<dZeed<dZeed<dZ e ed<dZ e ed <dZ eed <d Zeed <dZeed <dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZ dS)zCmfNotify.NotifyCtxu1 notify_type - тип сообщения возможные варианты: - просто сообщение (default) -- message - редактирование объекта -- obj_edit - создание объекта -- obj_create - удаление объекта -- obj_delete - добавление комментария -- comment_create - редактирование комментария -- comment_edit - удаление комментария -- comment_delete N person_idnametextrpriorityF strikethrough alarm_datemessage notify_typeobj_hrefobj_codeobj_parent_nameobj_linkhtml_changed_fields owner_nameowner_initialsperson_phone_mobile person_phone person_name person_email person_login msg_from_id msg_from_name msg_from_codemsg_from_login)!__name__ __module__ __qualname____doc__rstr__annotations__r r r intr boolr datetimerrrrrrrrrrrrrrrrr commentsr+r+./cmf/models/cmf_notify.py NotifyCtxs2                        r-cCsl|jp |j}d|jd|jd|j}|}|r<|}|j|}|j|d}t |j |||gddS)N[] () )ctxargs) rrrrr +get_default_mail_notification_template_name _jinja_env get_templaterendercmf_deferred_task process_email)cls notify_ctxobjrcpt_tosubject mail_templatetemplate email_bodyr+r+r,send_email_notify_old;s   zCmfNotify.send_email_notify_oldcCsdtj}|jp|j}t|dkr6|ddd}|d|jd||j}|jp\|j}|sxtd|j ddSt |j ||gddS)Nhttps://z... 4SMS уведомление пользователю _ не отправлено, не указан номер мобильного телефона.r2) configAPP_FQDNr msglenrrr cmf_alertrr8 process_sms)r:r;urlsubjrphoner+r+r,send_sms_notify_oldJs    zCmfNotify.send_sms_notify_oldc Ksd|ks|ddkr&tjtjd|d<d|kr:|d}ntj}|jj|d<|j j|d<|j j|d<|j j|d<d |d <|rd |ks|d dkr|j |d <d|ks|ddkrtjtjd|d<t |d t r|d j|d <|d |d <|ptj}|j j|d<|ddg|jr |jjdnd|jr6|jjdnd|d<|rdtj}|j|d<|j |d<||d|d<t|dr|jr|jj j|d<nd|d<tj|}||d<|d|d<|d|d<|d |d<|d |d!<|d"|d#<|jf|}|S)$Nr .Ztzmsg_fromrrrr Уведомлениеr r rJrr first_name last_namerrrrCrrrparentrrrPr phone_mobilerremailrloginr)r)nowtimezoneutcpopgcurrent_personidvaluer coderZ isinstanceZCmfType current_user load_fieldsrUrVrHrIhrefhasattrrWmodels CmfPersonget_notify_opt_cachedr-) r:r<rkwargsrSZ notify_ownerrN notify_optsr1r+r+r,prepare_notify_ctx_oldXsL         4          z CmfNotify.prepare_notify_ctx_oldNrFrc KstjrtddSt|d} tj| } | dkr8dSd} | tjj krb|dkrb| dr^d} ndS|r|j j rv|j j s| ddgd}|rd }| sd }|jd d |j gd d | gdd |gdd dgdd dggdddgd}|st}|sd}|jr|jdkr|d|j}|jr$|jr$|r*||_d |_|jd7_||_| |_d|_| r^| |_n |j|r|j|_|j |_|j |_|j|_t|dr|j r|j jj|_ |j!|_"t|dr|j#rt$|jt%r|jj|_&n t'|j|_&nd|_|j(s g|_(|j(rFt)|j(jdkrF|j(jdddd|krF|Stj*j+r^tj*j+jdndtj*j,rxtj*j,jdnd}tj*j jtj*jjtj*j jtj*j-j|dt.j/t0j1d2t./3d||dt4dd }|j(5|d|_6|jp||_| d!|_7| d"|_8| d#p| d$|_9| d%p.| d&|_:| s>d |_|;| d's\|jst=d-| | gd+|S).u obj: CmfEntity :param obj: :param msg_from: :param person: Идентификатор пользователя которому отправляется сообщение :param name: Наименование объекта уведомления :param msg: Текст сообщения force - форсированная отправка :param priority: :param strikethrough: :param alarm_date: Будильник для уведомлений :param force_notify_current_person: отправить сообщение себе :param notify_type: Тип сообщения. Описание см в структуре NotifyCtx BУведомления отключены g.disable_notify = FalseNrjTFemail_if_self_changesrWrcopenclosedobj_id==rstatus cron_done confirmed unread_cntr* cron_forcefilterfieldsrTru + еще rr )rar rcrZZinitialsrRz%H:%Mz CmfComment:)Z cmf_ownerZcmf_created_atZcmf_created_at_formatted msg_type_textr ra log_level notify_smsZ notify_emailrXrPrYrZZ notify_os1z notify-os)rcommentrZ event_persons2znotify-important-)?r_disable_notifydebugcmfutilZget_obj_id_by_anyrirjrkr`rarW is_definedrcrfgetrrxr ryruZpriotityrr r Zset_nowr rsrui_nameZ obj_ui_namerhrbrrgrloadrdZ CmfRelationZobj_status_namer%r*rKrerUrVrZr)r[r\r]Z isoformatstrftimeZuuid1appendrvperson_notify_smsperson_notify_emailrrsaver cmf_emit_eventrw)r:rJpersonr rr<force_notify_current_personforcer r rlrrmZ desk_notifynotifyZ filter_statusrrr+r+r, place_notifys              zCmfNotify.place_notifyc Ks0tjrtddSd|kr(|ddk s0tdd|krD|ddk sLtd|dtjjkrj|dsjdSd |kr|d }|d d d d gnd}|d}t j j|dddgd}|std|dS|dg}t j ||}|j ||f|}|dkrdS|||}|r,||||||S)u obj: CmfEntity :param obj: :param msg_from: :param person_id: Идентификатор пользователя которому отправляется сообщение :param recipient_opt: Опции получателя для проверки разрешения получать уведомления пользователем :param name: Наименование объекта уведомления :param text: Тема сообщения :param msg: Текст сообщения :param priority: :param strikethrough: :param alarm_date: Будильник для уведомлений :param force_notify_current_person: отправить сообщение себе :param notify_type: Тип сообщения. Описание см в структуре NotifyCtx roNrJ.uУкажите msgruУкажите person_idrr<rWrcrrgrzphone_mobile.numberz phone.number)rar|uВ метод place_notify пришел отсутствующий или удаленный пользователь person_id= recipient_opt)r_rrAssertionErrorr`rarr^rfrirjZCmfPersonNotifyOptZcheck_permission_notify_eventZprepare_notify_ctxZcreate_desk_notifysend_email_notifysend_sms_notify) r:rlr<rrrZnotify_allowedr;rr+r+r,stol_place_notify5s8        zCmfNotify.stol_place_notify)event_type_codecCsrt}t|drB|jr"|jdsB|D]}dh||jj<q*|S|j}t|dsVd}tj ||j d|}|stj |d|}|sdS|dD]}| |}|dkr| |t ||dq|D]} tj| jj} | dkrq| | jjt d} |d kr | d r d } nx|d kr:| d r:d } n^|dkrT| drTd } nD|dkrn| drnd } n*|dkr| drd } || jjd| r|| jjdqq|drn|j dkrn||d|dD]} || sqtt|| tjjr>|| D]*} | | jjt || jjdqn,| || jjt ||| jjdq|S)uY Рассчитываем набор юзеров и их галочек logic_prefixz CmfProject:rYN.z AllModels.Znotify_membersFz var:authorZemail_if_authorTz var:ownerZemail_if_owner)zvar:responsiblez var:executorsZemail_if_responsiblezvar:spectatorsZemail_if_spectatorzvar:current_userrpreZnotify_custom_fieldCmfTask)dictrh parent_id startswithZall_relation_personsrarbriZCmfProjectNotifySchemeZget_notify_rule_data_cached class_nameZextract_var_obj setdefaultsetaddrjrkrf issubclasstypeZcmfr|Z CmfM2MBase)r:r<rZ recipientsuZ tmp_parent_idZ rule_dataZuser_idZ var_usersZvar_userrmrY field_nameuserr+r+r,get_notify_membersnsn      zCmfNotify.get_notify_memberscCs&|dkrd}d}d||dgS|dkr}|jjrt|jj}d?}d5||dgS|d@krdA}|jjrt|jj}dB}d5||dgS|dCkrLdD}|jjr:t|jj}dE}d5||dgS|dFkrdG}|jjrpt|jj}dH}d5||dgS|dIkr\|jj r|jr|jj j|jjkrgS|jdJkrd?}d5dK|dgSd/} |j r|j j } dL|jj dM| d2}|jjr|d3|jj7}|jj rJ|jrJdN|jj j dO|jj dP}ndQ}d5||dgS|dRkrdS|}dT}d5||dgS|dUkrdV}dW}d5||dgS|dXkrdY|dZ}d[}d5||dgS|d\krd]}d^}d5||dgSd_d`dadbdcg} |ddkrgggde} |jdfdgD]j\}}|js.q|j|j kr@q|| krNq||}|dhkrfq|}|r| ||qg}di}| dhr|dhd | dh|d| d5r|d5d | d5|d| dr|dd | d|d|S|}d5dj|dk|j |dgS)lu  Логика: - по спец. событиям типа assigned, придет и assigned и updated, поэтому поля спец.событий дополнительно нужно отфильтровывать в updated ZdeleteduУдаленоu удалил)rr message_titleZcreateduСозданоu создалZ publishedu9Выпущены изменения в документеz
u!выпустил документZshareddefaultu[Отменен публичный доступ к документу в интернете.u9отменил публикацию в интернетеuiДокумент опубликован для публичного доступа в интернете.u
Анонимные: u"
Авторизованные: u,опубликовал в интернетеZcomment_createdu$Комментарий создан.: ru%написал комментарийZcomment_updatedu&Комментарий изменен.u%изменил комментарийZcomment_deletedu#Комментарий удаленu#удалил комментарийZworklog_createdu+Сделана запись о работеu)сделал запись о работеZworklog_updatedu&Журнал работ измененu&изменил журнал работZworklog_deletedu$Журнал работ удаленu$удалил журнал работZmoveduПеремещеноu из проекта u в проект u1переместил в другой проектassigneduНе установленu%Задача назначена на u, ожидает r u'назначил исполнителяr}z, cSsg|]}t|jqSr+)r%r ).0er+r+r, )sz5CmfNotify._prepare_notify_message..u-назначил соисполнителейZresolveduдобавил решениеu1В задаче добавлено решениеrruЗадача завершенаuзавершил задачуZ work_starteduРабота начатаuначал работуZ work_stoppedu#Работа остановленаu%приостановил работуZreopenedu#Задача переоткрытаu!переоткрыл задачуchanged_statusZCLOSEDuЗадача закрытаu!Статус изменен на u, ожидаем uизменил статус c "u" на ""uизменил статусZapprove_startedu.Ожидается подтверждение u+запустил подтверждениеZapprove_rejectedu6Пользователь отклонил запросuотклонил запросZapprove_success_fulluУтверждение u завершеноu)утверждение завершеноZapprove_success_oneu:Пользователь подтвердил запросu!подтвердил запрос responsibleruZviewsZ result_textrWupdated)rr}rT) is_changedruизменилuПришло событие u по объекту )r html_diffZperm_policy_anonymousZperm_policy_guestchoicesrbZcaptionnewrrWoldr r waiting_forrur executorsrjoinr%rcZcache_status_typeitemsrZ_get_field_log_level)r:r<rrJrZ anonymousZguestresrrZ new_executorsrZskip_field_namesZtmp_listrZ field_objrrr+r+r,_prepare_notify_messagesX * *                          &                z!CmfNotify._prepare_notify_messagec Cs|jj}|jj}|jj}|jj}|j}tjj|d} z&tj j |||||dd| dsXWdSWnPt k rpYdSt k r} z| j d|krWY dSW5d} ~ XYnX|jdkr|jrtjj|j| dsdS|r|jdkr|jrtjj|j| dsdSd S) u Проверяет, что у получателя notify есть доступ к объекту Доп. проверяются права у private-комментариев )rareadF)initial_acl_keyZ object_modelZobject_owner_idZ object_idZobject_parent_idZ access_levelZ raise_errorchecking_personr}N CmfComment)Zcheck_for_userT)Zperm_effective_acl_idrbr cmf_owner_idrarrirjrZ CmfAccessListZ check_accessZCmfACLNotInitializedErrorZCmfACLNotFoundErrorr3ZprivaterZcheck_visibility) r:r< member_id obj_commentrZ obj_parent_idrZself_idrrrr+r+r,_check_perm_for_notifys>  z CmfNotify._check_perm_for_notifyT)rauditc Os|jr dS|sdS|sdS|js$dStjr.dSd}|dkr>d}d}d} |jdkrj|}|jj}|jdkrjdS|jdkr|}|jj}|jdkr|jsdS|jdkr|} |j j}|r| ||} n| r| | |} n | ||} |jd kr|s| D]$} t j || d | d d j dd q|s dS| D]} | d dkr:q$|||} tjjd| dd|j} | r$| D]P\}}|j|||dsqrt jj|| || d | dd|krdnd|dqrq$dS)NF)rrTrrZCmfTimeTrackerHistoryrjZ CmfGanttTask)rZ CmfDocumentrr)rWr r)r)r}rrr)rre)r<r rrJrrr)Z disable_auditZ smart_notifyr_rrrWrbrZ user_localtaskrrirrrr`r verbose_namerrrr)r:r<rrrr3rlrrZ dependent_objZmsg_listZmsg_datamembersr rZ email_setr+r+r,smart_all_place_notifys~       z CmfNotify.smart_all_place_notifycs<tj||td|jd|jji|jgddS)Nznotify-person-Z notify_idr)superemitrrrrarb)selfr3rl __class__r+r,r$s zCmfNotify.emitcCsd|stjjj}dd|gdddgg}|r8|dd|jg|j|dgd}|D]}d|_|qLdS)Nrrtruz!=rrrsrz)r_r`rarbrlistrur)r:rr<Z_filternotifiesrr+r+r,close_open_notifies,s zCmfNotify.close_open_notifiescCsD|s tjj}|jdd|gdddggd}|D]}d|_|q,dS)NrrtrwFalse)r{T)r_r`rarrwr)r:rrrr+r+r,confirm_unconfirmed_notifies>sz&CmfNotify.confirm_unconfirmed_notifiescCs|jdkr|j}n&|jdkr,|g}ntd|jdS|D]H}tj|jj }|dksD|dsjqDtj j |||j d|j dqDdS)NZCmfPersonGrouprjz,DEV: handle_mention_event unknown obj type: Zemail_if_mentionsuВас упомянули в )r<rr rJ)rZ rg_membersrZ all_nestedrLrirjrkrarbrrr rlower)r:r<Z event_personZpersonsrrmr+r+r,handle_mention_eventLs   zCmfNotify.handle_mention_event)Z only_onceZ system_taskcOstj}|j|||ddS)Nr>)riCmfPluginMailBoxget_local_mailbox send_message)Zrctp_tor>rAr3rlmail_boxr+r+r,r9cs zCmfNotify.process_emailcOstj}|||dSN)riCmfPluginSMSGateget_local_smsgater)rPrr3rlsms_gater+r+r,rMis zCmfNotify.process_smsc Cs|js dS|jj}d|jd|jd|j}|}|rB|}dtj|j|_ |j |}|j |d}t j}|j|||ddS)Nr.r/r0rC)rr)rrbrrr r4rHrIrrr5r6r7rirrr) r:rr<r=r>r?r@rArr+r+r,ros   zCmfNotify.send_email_notifycCsd|jstd|jddSdtj|j}|j}|d|}|jj}tj }| ||dS)NrFrGrCrE) rrLrrHrIrr rbrirrr)r:rr<rNrOrrPrr+r+r,rs  zCmfNotify.send_sms_notifyc Ostjjddgdddgdddggd}d d |D}tjjdddgd d d ttddgdddgdd|gggdgd gd}|sqtd|jd|d}|j rt j |j ddgd}|j rz tdtj ||d|_Wn4tk r}ztd|W5d}~XYnX|jrrz tdtj||d|_Wn4tk rp}ztd|W5d}~XYnXd|_||jq2dS)Nz--rsrvrtFryT)r|r{cSsh|] }|jqSr+)rs)rr<r+r+r, sz1CmfNotify.celery_minutely_hook..ORZcmf_modified_at<)ZminutesINr)r{r|Zorder_byuBОбработка отправки уведомлений для rr)Zinclude_deletedr|uОтправляем СМСz"models.CmfNotify.send_sms_notify: uОтправляем emailz$models.CmfNotify.send_email_notify: )rirZslistrr)r[Z timedeltaprintrarsrZ get_obj_by_idrrZsms_done ExceptionZloggingZ exceptionrrZ email_donervrZdpZcommit)r3rlZ force_objectsZforce_object_idsrr<rr+r+r,celery_minutely_hooksL  " "zCmfNotify.celery_minutely_hookcCst|jdSr)r8r)r:r+r+r, minutely_hookszCmfNotify.minutely_hook)NrNFFrN)N)NN)N),r!r"r#rZ ui_moduleZ code_prefixZ_optionsZjinja2ZFileSystemLoaderospathrrHZ PROJECT_DIRZ_loaderZ Environmentr5rr- classmethodrBrQrnrrr%rrrrrrrr staticmethodZ celery_apprr9rMrrrr __classcell__r+r+rr,r sv &   5 ' 8Oc )X            *r) r)Z dataclassesrZ cmf.includeZ cmf.fieldsrZ cmf.modelsrrZAPPZHOOK_CRON_MINUTELYrrr+r+r+r,s   ?