U `g@s^ddlmZmZmZddlmZddlmZddlTddlm Z m Z m Z Gddde j Z dS) )datetime timedeltatimezone)uuid1) dataclass)*) cmf_notify CmfRelationCmfTypecseZdZdZdZdZiZee j e j de j e j dgZeed<ejfeZejjddd gZeGd d d Zed d ZeddZeddZedd'd(Z"ed?d)d*Z#ed+d,Z$e%e&d!d!d-d.d/Z'e%e&d!d!d-d0d1Z(ed2d3Z)ed4d5Z*ed6d7Z+e%e&d!d!d8d9d:d;Z,Z-S)@ CmfNotifyZNotifyZdeskZNTFzcommon/templatesz cmf/templatesloaderclose_open_notifiesconfirm_unconfirmed_notifies place_notifyc@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__rrrintrboolrrrrrrrrrrr r!r"r#r$r%r&r'r(commentsr2r2./cmf/models/cmf_notify.py NotifyCtxs2                        r4cCsl|jp |j}d|jd|jd|j}|}|r<|}|j|}|j|d}t |j |||gddS)N[] () )ctxargs) r#r$rrr+get_default_mail_notification_template_name _jinja_env get_templaterenderschedule_deferred_job process_email)cls notify_ctxobjrcpt_tosubject mail_templatetemplate email_bodyr2r2r3send_email_notify_old@s   zCmfNotify.send_email_notify_oldcCstdd}|jp|j}t|dkr4|ddd}|d|jd||j}|jpZ|j}|svtd|jddSt |j ||gddS) NTZfull_urlz... 4SMS уведомление пользователю _ не отправлено, не указан номер мобильного телефона.r9) app_base_hrefrmsglenrr r! cmf_alertr"r? process_sms)rArBurlsubjrphoner2r2r3send_sms_notify_oldOs    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<|rtdd}|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_fromr%r&r'r(УведомлениеrrrPrr first_name last_namerrrTrJrrrparentrrrVr! phone_mobiler r"emailr#loginr$)rnowrutcpopgcurrent_personidvaluercoder` isinstancer current_user load_fieldsr[r\rOhrefhasattrr]models CmfPersonget_notify_opt_cachedr4) rArCrkwargsrYZ notify_ownerrT notify_optsr8r2r2r3prepare_notify_ctx_old]sL         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}|r|jjnd}tj*j jtj*jjtj*j jtj*j-j|dt.j/t0j1d2t./3d||dt4|dd }|j(5|d|_6|jp||_| d!|_7| d"|_8| d#p.| d$|_9| d%pB| d&|_:| sRd |_|;| d'sp|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 = FalseNroTFemail_if_self_changesr]rhopenclosedobj_id==rstatus cron_done confirmed unread_cntr1 cron_forcefilterfieldsrZru + еще rr)rfrrhr`ZinitialsrXz%H:%Mz CmfComment:)Z cmf_ownerZcmf_created_atZcmf_created_at_formatted msg_type_textrrf parent_name log_level notify_smsZ notify_emailr^rVr_r`Z notify_os1z notify-os)rcommentrZ event_persons2znotify-important-)?rddisable_notifydebugcmfutilZget_obj_id_by_anyrnrorprerfr] is_definedrhrkgetr r}rr~rzZpriotityrrrZset_nowrrxrui_nameZ obj_ui_namermrgrrlrloadrir Zobj_status_namer-r1rQrjr[r\r`rrarrbZ isoformatstrftimerappendr{person_notify_smsperson_notify_emailr!r#savercmf_emit_eventr|)rArPpersonrrrCforce_notify_current_personforcerrrqrrrZ desk_notifynotifyZ filter_statusrrrr2r2r3rs              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 rtNrP.uУкажите msgruУкажите person_idrrCr]rhrrlrzphone_mobile.numberz phone.numberrfruВ метод place_notify пришел отсутствующий или удаленный пользователь person_id= recipient_opt)rdrrAssertionErrorrerfrrcrkrnroZCmfPersonNotifyOptZcheck_permission_notify_eventZprepare_notify_ctxZcreate_desk_notifysend_email_notifysend_sms_notify) rArqrCrrrZnotify_allowedrBrr2r2r3stol_place_notify<s8        zCmfNotify.stol_place_notify)event_type_codecCst}t|drL|jdkrL|jr,|jdsL|D]}dh||jj<q4|S|j}|jdkrd|jj}t|dsrd}tj ||jd|}|stj |d|}|sdSg}|dD].}|j |d d } | dkr| |t ||dq| D]} tj| jj} | dkrq| js(|| | | jjt d } |d krX| d rXd } nx|dkrr| drrd } n^|dkr| drd } nD|dkr| drd } n*|dkr| drd } || jjd| r|| jjdqq|rbtjjdd} tjj|j| dgd}|D]H}t|tjjr2|j}|jj|kr|r||dkr||jj=q|dr|jdkr||d|dD]}||sqtt||tjjr||D]*}| |jjt ||jjdqn,| ||jjt |||jjdq|D]n}|drDtd|d dt j!r"tjj|d gd!}|r"|j"r"|j"jdr"td"|d dq"|S)#uY Рассчитываем набор юзеров и их галочек logic_prefixZ CmfProjectz CmfProject:r_N.z AllModels.Znotify_membersT)Zall_nested_personsFz var:authorZemail_if_authorz var:ownerZemail_if_owner)zvar:responsiblez var:executorsZemail_if_responsiblezvar:spectatorsZemail_if_spectatorzvar:current_userrurjsdesk-client:default)rhmembers) parent_idZproject_role_idrZnotify_custom_fieldCmfTaskzvar:zDEV: Var user in notify! )abortrhrz DEV: Var user person in notify! )#dictrm class_namer startswithZall_relation_personsrfrgrnZCmfProjectNotifySchemeZget_notify_rule_data_cachedZextract_var_obj setdefaultsetaddrorp user_localrZCmfProjectRolerZCmfProjectRoleAssignr]ricmfrZCmfRelationBaserk issubclasstypeZ CmfM2MBaserRconfigDEBUGrh)rArCrZ recipientsuZ tmp_parent_idZ rule_dataZnon_local_personsZuser_idZ var_usersZvar_userrrr_Z proj_roleZproj_role_assignuser field_nameir2r2r3get_notify_membersus       "    zCmfNotify.get_notify_memberscCs t|tjr|dkrXd|jjd}d|jjd}d}d|||jdd|||jdgS|dkrd|jjd}d|jjd}d }d|||jdd|||jdgSt|tjr|jjrd }d }d||d gS|j jrd }d}d||d gS|j jr|dkr6d|jd}d}d}d|||j j dd||d gS|dkr|j r|d|jd}d}d}d|||j j dd||d gS|j j rd|jd}d}d}d|||j j dd||d gS|dkrd}d}d||d gS|dkrd}d}d||d gS|dkrd}d}d||d gS|d krNd!}|d"|j 7}d#}d||d gS|d$kr|jd%krz|jd%krzd&}d'}nDd(}|jj|jj } |d)| 7}|jj|jj } |d*| 7}d+}d||d gS|d,krd-}|d"|j jd.|j jr|j jnd/7}d0}d||d gS|d1krR|jrRd2}|d"|j 7}d3}d||d gS|d4krd5}|d"|j jd.|j jr|j jnd/7}d6}d||d gS|d7kr|jrd8}|d9|j7}d:}d||d gS|d;krd<}|d9|j7}d=}d||d gS|d>kr$d?}d@}d||d gS|dAkrL|jrLdB}dC}d||d gS|dDkrldE}dF}d||d gS|dGkrdH}|jj r|dI|jj j7}|jr|dJ|jj7}dK}d||d gS|dLkrg} |jjr`dM} |jr|jj} dM} |jr|jj} dN| }| | kr&|dO| 7}|dP7}|jj rJ|d9|jj 7}dQ}| dR||d |jjrt|jt|jj }|rdSdTdU|D}dN|dP}|jj r|d9|jj 7}dV}| dR||d | S|dWkrdX}dRdY|d gS|dZkr.d[}|jj rt|jj }d\}dR||d gS|d]krdd^}|jj rRt|jj }d_}dR||d gS|d`krda}|jj rt|jj }db}dR||d gS|dckrdd}|jj rt|jj }de}dR||d gS|dfkr|jj r|jr|jj j|jjkrgS|jdgkr"d\}dRdh|d gSdM} |jr6|jj} di|jjdj| dP}|jj rh|d9|jj 7}|jj r|jrdk|jj jdl|jjdm}ndn}dR||d gS|dokrdp|}dq}dR||d gS|drkrds}dt}dR||d gS|dukrdv|dw}dx}dR||d gS|dykr8dz}d{}dR||d gS|d|krd}}d~}|jjD]$}||jj krR|d|j7}qR|jj D]$}||jjkr|d|j7}qdR||d gSdddddg}|dk rgggd}|j ddD]j\}}|j!sq|j |j k r q||k rq|"|}|dk r0q|}|r|||qg} d}|d r~| dd"|d|d |dR r| dRd"|dR|d |d r| dd"|d|d | S|}dRd|d|j|d gS)u  Логика: - по спец. событиям типа assigned, придет и assigned и updated, поэтому поля спец.событий дополнительно нужно отфильтровывать в updated Zcreatedu6Установлена связь с задачей «»u/установил связь с задачей)rr message_titler]Zdeletedu.Удалена связь с задачей «u)удалил связь с задачейu7Изменена плановая дата началаu5изменил плановую дату начала)rrru?Изменена плановая дата завершенияu=изменил плановую дату завершенияu$Создана подзадача «uСозданаuсоздал подзадачуupdatedu(Добавлена подзадача «uДобавленаu!добавил подзадачуu$Удалена подзадача «uУдаленаuудалил подзадачуZrestoreduВосстановленоuвосстановилuУдаленоu удалилuСозданоu создалZ publishedu9Выпущены изменения в документеz
u!выпустил документZshareddefaultu[Отменен публичный доступ к документу в интернете.u9отменил публикацию в интернетеuiДокумент опубликован для публичного доступа в интернете.u
Анонимные: u"
Авторизованные: u,опубликовал в интернетеZcomment_createdu$Комментарий создан.: ru%написал комментарийZcomment_updatedu&Комментарий изменен.u%изменил комментарийZcomment_deletedu#Комментарий удаленu#удалил комментарийZattachment_createdu#Добавлено вложение uдобавил вложениеZattachment_deleteduУдалено вложениеuудалил вложениеZworklog_createdu+Сделана запись о работеu)сделал запись о работеZworklog_updatedu&Журнал работ измененu&изменил журнал работZworklog_deletedu$Журнал работ удаленu$удалил журнал работZmoveduПеремещеноu из проекта u в проект u1переместил в другой проектassigneduНе установленu%Задача назначена на u, ожидает ru'назначил исполнителяrz, cSsg|]}t|jqSr2)r-r).0er2r2r3 sz5CmfNotify._prepare_notify_message..u-назначил соисполнителейZresolveduдобавил решениеu1В задаче добавлено решениеrwuЗадача завершена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!подтвердил запросZspectators_changedu'изменены наблюдателиu4Изменен состав наблюдателейu
добавлен: u
удален: responsiblerzZviewsZ result_textr])rrrT) is_changedruизменилuПришло событие u по объекту )#rirnCmfRelationOptionin_linkrZout_linkrZplan_start_daterZ plan_end_dateZ parent_taskrgoldr html_diffZperm_policy_anonymousZperm_policy_guestchoicesZcaptionnewr]r waiting_forrzr executorsrjoinr-rhZcache_status_typeZ spectatorsitemsrZ_get_field_log_level)rArCrZin_msgZout_msgrrPZparent_task_msgZtask_msgZ anonymousZguestresrrZ new_executorsrZ spectatorZskip_field_namesZtmp_listrZ field_objrrr2r2r3_prepare_notify_messages                * *                           &                   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-комментариев )rfreadF)initial_acl_keyZ object_modelZobject_owner_idZ object_idZobject_parent_idZ access_levelZ raise_errorchecking_personrN CmfComment)Zcheck_for_userT)Zperm_effective_acl_idrgr cmf_owner_idrfrrnrorZ CmfAccessListZ check_accessZCmfACLNotInitializedErrorZCmfACLNotFoundErrorr:ZprivaterZcheck_visibility) rArC member_id obj_commentrZ obj_parent_idrZself_idrrrr2r2r3_check_perm_for_notify"s>  z CmfNotify._check_perm_for_notifyT)rauditc Os:|jr dS|sdS|sdS|js$dStjr.dSd}|dkr>d}d}d} |jdkr|}|jj}t|drt|j rtdS|j dkrdS|jdkr|}|jj}|jdkr|} |jj}|jd kr|j sdS|jd kr|} |j j}|jd kr|} |j j}|r|||} n | r|| |} n |||} |jd krl|sl| D]2} | d |} tj| | d| ddjddq8|svdS| D]} | ddkrqz|||} tjjd| dd|j}| rz| D]h\}}|j|||dsqtjj6tjj|||| d| dd|krdnd|dW5QRXqȐqzdS)NF)rrTris_dummyrZ CmfAttachmentZCmfTimeTrackerHistoryroZ CmfGanttTaskr)rZ CmfDocumentr]rr)r]rr)r)rrrr)rrj)rCrrrPrrr)Z disable_auditZ smart_notifyrdrrr]rgrmrrrrZtaskrrrrnrrrrer verbose_namerrrutilrZ disable_aclr r)rArCrrrr:rqrrZ dependent_objZmsg_listZmsg_datar]rrrZ email_setr2r2r3smart_all_place_notifyLs           z CmfNotify.smart_all_place_notifycs<tj||td|jd|jji|jgddS)Nznotify-person-Z notify_idr)superemitrrrrfrg)selfr:rq __class__r2r3rs zCmfNotify.emitcCsd|stjjj}dd|gdddgg}|r8|dd|jg|j|dgd}|D]}d|_|qLdS)Nrryrzz!=rwrxr)rdrerfrgrlistrzr)rArrCZ_filternotifiesrr2r2r3r s zCmfNotify.close_open_notifiescCsD|s tjj}|jdd|gdddggd}|D]}d|_|q,dS)Nrryr|False)rT)rdrerfrr|r)rArrrr2r2r3rsz&CmfNotify.confirm_unconfirmed_notifiescCs|jdkr|j}n&|jdkr,|g}ntd|jdS|D]H}tj|jj }|dksD|dsjqDtj j |||j d|j dqDdS)NZCmfPersonGrouproz,DEV: handle_mention_event unknown obj type: Zemail_if_mentionsuВас упомянули в )rCrrrP)rZ rg_membersrZ all_nestedrRrnrorprfrgr rrrlower)rArCZ event_personZpersonsrrrr2r2r3handle_mention_events   zCmfNotify.handle_mention_event) only_once system_jobcOstj}|j|||ddS)NrE)rnCmfPluginMailBoxget_local_mailbox send_message)Zrctp_torErHr:rqmail_boxr2r2r3r@s zCmfNotify.process_emailcOstj}|||dS)N)rnCmfPluginSMSGateget_local_smsgater)rVrr:rqsms_gater2r2r3rSs zCmfNotify.process_smscCs\tjj|jdgd}|rV|jrV|jdrV|j|jddsVd|j d|j d|j S|j S) Nrrztask.sdr)ZprojectZ role_code/z/?obj=:) rnrorrrrrZin_project_roler] ui_modulerrhr)rArrCrr2r2r3_calc_notify_obj_links zCmfNotify._calc_notify_obj_linkc Cs|js dS|jj}d|jd|jd|j}|}|rB|}|j||d}tdd||_|j |}|j |d}t j } | j|||ddS) Nr5r6r7)rrCTrJ)rr)r#rgrrrr;rrOrr<r=r>rnrrr) rArrCrDrErFrlrGrHrr2r2r3rs   zCmfNotify.send_email_notifycCsf|jstd|jddStdd|j}|j}|d|}|jj}tj }| ||dS)NrMrNTrJrL) r!rRrrOrrrgrnrrr)rArrCrTrUrrVrr2r2r3rs  zCmfNotify.send_sms_notifyz @minutely)rrZschedulec 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--rxr{ryFr~T)rrcSsh|] }|jqSr2)rx)rrCr2r2r3 1sz1CmfNotify.celery_minutely_hook..ORZcmf_modified_at<)ZminutesINr)rrZorder_byuBОбработка отправки уведомлений для rr)Zinclude_deletedruОтправляем СМСz"models.CmfNotify.send_sms_notify: uОтправляем emailz$models.CmfNotify.send_email_notify: )rnr ZslistrrrarprintrfrxrZ get_obj_by_idrrZsms_done ExceptionZloggingZ exceptionrrZ email_doner{rZdpZcommit)r:rqZ force_objectsZforce_object_idsrrCrr2r2r3celery_minutely_hook*sL  " "zCmfNotify.celery_minutely_hook)NrNFFrN)N)NN)N).r)r*r+rrZ code_prefixZ_optionsZjinja2ZFileSystemLoaderospathrrZ PROJECT_DIRZ_loaderZ Environmentr<rr Z api_methodsrr4 classmethodrIrWrsrrr-rrrrrr rr staticmethodZcmf_deferred_jobr@rSrrrr __classcell__r2r2rr3r s &   5 ) 8kB )f            r N) rrrZuuidrZ dataclassesrZ cmf.includeZ cmf.fieldsrr r r r2r2r2r3s