U /Df@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<ejfeZeGdddZed d Zed d Zed dZed9ddZeddZeedddZeedddZed:ddZedddedd d!Zfd"d#Zed;d$d%Zedr?urlsubjrphoner/r/r0send_sms_notify_oldIs    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_fromr"r#r$r%УведомлениеrrrNrr first_name last_namerrrrGrrrparentrr rTr phone_mobilerremailr loginr!)rnowrutcpopgcurrent_personidvaluercoder^ isinstancer current_user load_fieldsrYrZrLrMhrefhasattrr[models CmfPersonget_notify_opt_cachedr1) r>r@r kwargsrWZ notify_ownerrR notify_optsr5r/r/r0prepare_notify_ctx_oldWsL         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 = FalseNrmTFemail_if_self_changesr[rfopenclosedobj_id==r status cron_done confirmed unread_cntr. cron_forcefilterfieldsrXru + еще rr)rdrrfr^ZinitialsrVz%H:%Mz CmfComment:)Z cmf_ownerZcmf_created_atZcmf_created_at_formatted msg_type_textrrd parent_name log_level notify_smsZ notify_emailr\rTr]r^Z notify_os1z notify-os)r commentrZ event_persons2znotify-important-)?rbdisable_notifydebugcmfutilZget_obj_id_by_anyrlrmrnrcrdr[ is_definedrfrigetr r{rr|rxZpriotityr rrZset_nowrrvrui_nameZ obj_ui_namerkrerrjrloadrgr Zobj_status_namer*r.rOrhrYrZr^rr_rr`Z isoformatstrftimerappendryperson_notify_smsperson_notify_emailrr savercmf_emit_eventrz)r>rNpersonrrr@force_notify_current_personforcerrror rpZ desk_notifynotifyZ filter_statusrrrr/r/r0 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 rrNrN.uУкажите msgr uУкажите person_idrr@r[rfrrjrzphone_mobile.numberz phone.numberrdruВ метод place_notify пришел отсутствующий или удаленный пользователь person_id= recipient_opt)rbrrAssertionErrorrcrdrrarirlrmZCmfPersonNotifyOptZcheck_permission_notify_eventZprepare_notify_ctxZcreate_desk_notifysend_email_notifysend_sms_notify) r>ror@r rrZnotify_allowedr?rr/r/r0stol_place_notify6s8        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_userrsrhsdesk-client:default)rfmembers) parent_idZproject_role_idrZnotify_custom_fieldCmfTaskzvar:zDEV: Var user in notify! )abortrfrz DEV: Var user person in notify! )#dictrk class_namer startswithZall_relation_personsrdrerlZCmfProjectNotifySchemeZget_notify_rule_data_cachedZextract_var_obj setdefaultsetaddrmrn user_localrZCmfProjectRolerZCmfProjectRoleAssignr[rgZcmfrZCmfRelationBaseri issubclasstypeZ CmfM2MBaserPrLDEBUGrf)r>r@rZ recipientsuZ tmp_parent_idZ rule_dataZnon_local_personsZuser_idZ var_usersZvar_userrpr]Z proj_roleZproj_role_assignuser field_nameir/r/r0get_notify_membersos       "    zCmfNotify.get_notify_memberscCs*|dkrd}d}d||dgS|dkrd(}|d%|j 7}d)}d||dgS|d*kr^d+}d,}d||dgS|d-kr|jrd.}d/}d||dgS|d0krd1}d2}d||dgS|d3krd4}|j j r|d5|j j j 7}|j r|d6|j j 7}d7}d||dgS|d8krg}|j jrd9}|j r*|j j }d9} |j r>|j j } d:|}|| kr`|d;| 7}|d<7}|jjr|d%|jj7}d=}|d>||d|jjrt|jt|jj } | rd?d@dA| D} d:| d<}|jjr|d%|jj7}dB}|d>||d|S|dCkr2dD}d>dE|dgS|dFkrhdG}|jjrVt|jj}dH}d>||dgS|dIkrdJ}|jjrt|jj}dK}d>||dgS|dLkrdM}|jjrt|jj}dN}d>||dgS|dOkr dP}|jjrt|jj}dQ}d>||dgS|dRkr|jj r>|jr>|jj j|jjkr>gS|jdSkr\dH}d>dT|dgSd9} |j rp|j j } dU|jj dV| d<}|jjr|d%|jj7}|jj r|jrdW|jj j dX|jj dY}ndZ}d>||dgS|d[kr d\|}d]}d>||dgS|d^kr*d_}d`}d>||dgS|dakrRdb|dc}dd}d>||dgS|dekrrdf}dg}d>||dgS|dhkrdi}dj}|jjD]$} | |jj kr|dk| j 7}q|jj D]$} | |jjkr|dl| j 7}qd>||dgSdmdndodpdqg} |drkrgggds}|jdtduD]j\}}|js2q|j|j krDq|| krRq||}|dvkrjq|}|r|||qg}dw}|dvr|dvd|dv|d|d>r|d>d|d>|d|dr|dd|d|d|S|}d>dx|dy|j |dgS)zu  Логика: - по спец. событиям типа assigned, придет и assigned и updated, поэтому поля спец.событий дополнительно нужно отфильтровывать в updated ZrestoreduВосстановленоuвосстановил)rr message_titleZdeleteduУдаленоu удалилZcreateduСоздано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|jqSr/)r*r).0er/r/r0 Wsz5CmfNotify._prepare_notify_message..u-назначил соисполнителейZresolveduдобавил решениеu1В задаче добавлено решениеruuЗадача завершена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
удален: responsiblerxZviewsZ result_textr[updated)rrrT) is_changedruизменилuПришло событие u по объекту )r html_diffZperm_policy_anonymousZperm_policy_guestchoicesreZcaptionnewrrr[oldr waiting_forrxr executorsrjoinr*rfZcache_status_typeZ spectatorsitemsrZ_get_field_log_level)r>r@rrNrZ anonymousZguestresrrZ new_executorsrZ spectatorZskip_field_namesZtmp_listrZ field_objrrr/r/r0_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-комментариев )rdreadF)initial_acl_keyZ object_modelZobject_owner_idZ object_idZobject_parent_idZ access_levelZ raise_errorchecking_personrN CmfComment)Zcheck_for_userT)Zperm_effective_acl_idrer cmf_owner_idrdrrlrmrZ CmfAccessListZ check_accessZCmfACLNotInitializedErrorZCmfACLNotFoundErrorr7ZprivaterZcheck_visibility) r>r@ member_id obj_commentrZ obj_parent_idrZself_idrrrr/r/r0_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|}|jj}|jdkr|jsdS|jd kr|} |j j}|r| ||} n| r| | |} n | ||} |jd kr.|s.| D]&} t j || d | d d j ddq|s8dS| D]} | d dkrRq<|||} tjjd| dd|j} | r<| D]P\}}|j|||dsqt jj|| || d | dd|krdnd|dqqr@rrrr7rorrZ dependent_objZmsg_listZmsg_datarrrZ email_setr/r/r0smart_all_place_notifys         z CmfNotify.smart_all_place_notifycs<tj||td|jd|jji|jgddS)Nznotify-person-Z notify_idr)superemitrr rrdre)selfr7ro __class__r/r0rds zCmfNotify.emitcCsd|stjjj}dd|gdddgg}|r8|dd|jg|j|dgd}|D]}d|_|qLdS)Nr rwrxz!=rurvr})rbrcrdrerlistrxr)r>r r@Z_filternotifiesrr/r/r0close_open_notifiesls zCmfNotify.close_open_notifiescCsD|s tjj}|jdd|gdddggd}|D]}d|_|q,dS)Nr rwrzFalse)r~T)rbrcrdrrzr)r>r rrr/r/r0confirm_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)NZCmfPersonGrouprmz,DEV: handle_mention_event unknown obj type: Zemail_if_mentionsuВас упомянули в )r@rrrN)rZ rg_membersrZ all_nestedrPrlrmrnrdrer rrrlower)r>r@Z event_personZpersonsrrpr/r/r0handle_mention_events   zCmfNotify.handle_mention_event) only_once system_jobcOstj}|j|||ddS)NrB)rlCmfPluginMailBoxget_local_mailbox send_message)Zrctp_torBrEr7romail_boxr/r/r0r=s zCmfNotify.process_emailcOstj}|||dS)N)rlCmfPluginSMSGateget_local_smsgater)rTrr7rosms_gater/r/r0rQs 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=:) rlrmrr rrrZin_project_roler[ ui_modulerrfr)r>rr@rr/r/r0_calc_notify_obj_links zCmfNotify._calc_notify_obj_linkc Cs|js dS|jj}d|jd|jd|j}|}|rB|}|j||d}dtj||_ |j |}|j |d}t j} | j|||ddS)Nr2r3r4)rr@rG)rr)r rerrrr8rrLrMrr9r:r;rlrrr) r>rr@rArBrCrjrDrErr/r/r0rs   zCmfNotify.send_email_notifycCsd|jstd|jddSdtj|j}|j}|d|}|jj}tj }| ||dS)NrJrKrGrI) rrPr rLrMrrrerlrrr)r>rr@rRrSrrTrr/r/r0rs  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--rvryrwFr|T)rr~cSsh|] }|jqSr/)rv)rr@r/r/r0 sz1CmfNotify.celery_minutely_hook..ORZcmf_modified_at<)ZminutesINr)r~rZorder_byuBОбработка отправки уведомлений для rr)Zinclude_deletedruОтправляем СМСz"models.CmfNotify.send_sms_notify: uОтправляем emailz$models.CmfNotify.send_email_notify: )rlr Zslistrrr_rprintrdrvrZ get_obj_by_idrrZsms_done ExceptionZloggingZ exceptionrrZ email_doneryrZdpZcommit)r7roZ force_objectsZforce_object_idsrr@rr/r/r0celery_minutely_hooksL  " "zCmfNotify.celery_minutely_hook)NrNFFrN)N)NN)N)+r&r'r(rrZ code_prefixZ_optionsZjinja2ZFileSystemLoaderospathrrLZ PROJECT_DIRZ_loaderZ Environmentr9rr1 classmethodrFrUrqrrr*rrrrrrrr staticmethodZcmf_deferred_jobr=rQrrrr __classcell__r/r/rr0r sx &   5 ) 8k )]            r N) rrrZuuidrZ dataclassesrZ cmf.includeZ cmf.fieldsrr r r r/r/r/r0s