B fm@sBddlTddlZddlmZddlmZGdddejjj Z dS))*N) CmfEntity)CmfActiveEntitycs<eZdZdZejjjjddddgZe d7dd Z d8d d Z d9d dZ fddZ ddZddZeddZfddZfddZddZddZdd Zd:d!d"Zeed#dd$d%d&Zd;fd'd( Zd)d*Zdd5d6Z!Z"S)? CmfWorkflowT status_listget_default_statusget_related_projects_inforeplaceNFcKsl|s|stddd|s dg}nd|kr2|d|s|dd|g}|rL||g}tjjf||d|} |rx| jdd d | Stj|dd gd } tjj d d| j j gddddgdd} g} |stjjfdd| gdddgg|dd|} t | } xb| j D]X} |r| jsq| jjs,| jj jdd| jDkr| | r| js@q| | jqWt| } | jdd d | S)Nz6DEV: FATAL get_status_list if not obj and not workflowT)abortordernoworkflowz==)filterfieldscSs |jdkS)Nclosed)code)sr./common/models/cmf_workflow.py!z-CmfWorkflow.get_status_list..)keystatus)rid=transztrans.status_to.ordernoztrans.status_fromztrans.trans_sdesk_portal_allow)r rcache_inmemoryallow_empty_transitioncSsg|] }|jjqSr)rvalue).0trrr ;sz/CmfWorkflow.get_status_list..cSs|jjS)N)r r)rrrrrAr) cmf_alertappendmodels CmfStatuslistsortZcmfutilZ get_obj_by_idrgetr rsetrtrans_sdesk_portal_allow status_fromZis_nullrrtrans_filter_ok status_toadd)clsZobj_idZ workflow_idr closed_lastr)rkwargs get_filterresobjr Zvalid_statusesrrrrget_status_listsL       $ zCmfWorkflow.get_status_listcOsDdd|g}|r||g}tjj|d|i|}|r@|jddd|S)Nr z==r cSs |jdkS)Nr)r)rrrrrKrz)CmfWorkflow.status_list..)r)r#r$r%r&)selfr r/argsr0r1r2rrrrDs zCmfWorkflow.status_listOPENc sdg}d}|r$|jdd|g|d}nprN|j|dd}|jdfddd nF|d krzd g}|jd dd gddd gg|d}|s|jd d|g|dd}|r|dS|rtd|d|d|ddS)Nr rz==)r order_byT)r8r/cs>|jjk|jjk|jjk|jjkjdko:|jdkfS)NZ IN_REVIEWCLOSED)rrname status_type)r)rrrr]s     z0CmfWorkflow.get_default_status..)reverserr9z-ordernor;r)r r8r/ru+Отсутствует статус для z status_type=z, status_code=z , status=)rr&ZCmfError)r5r;Z status_coderZ raise_errorr8r2r)rrrPs4    zCmfWorkflow.get_default_statuscstdgS)Nr)supersave_preload_fields)r5) __class__rrr>~szCmfWorkflow.save_preload_fieldsc s|jddgix|jjD]z}|ddg|}d|_|j|_||_|||<x:|jD]0}|dddg|}d|_||_ |qdWqWx<|jj D].}|ddg|}d|_||_fd d |j D|_ |j j r|j |_ ||d d d gx@|jD]6}|ddg|}d|_||_||_|qWx@|jD]6} | ddg| } d| _|| _|| _| q\Wx@|jD]6} | ddg| } d| _|| _|| _| qWqWdS)Nstatusesrz**approve_groupsF approversmaster_approversr*csg|] }|qSrr)rZ_st)status_mappingrrr szACmfWorkflow.scaffold_statuses_and_transitions.. trans_filterstrans_validators trans_actionsZ wz_value_obj)templateZ load_fieldsr@Zclonesystemrr saverAparentrr*r,Z is_not_nullrE transitionrFrG) r5stZst_newZ approve_grZapprove_gr_newrZ trans_newr Z filter_newZ validatorZ validator_newactionZ action_newr)rDr!scaffold_statuses_and_transitionss`     z-CmfWorkflow.scaffold_statuses_and_transitionscCsJ|jsF|jjs>|jjs>|jjs>|jjs>|jjs>|jjs>|jjrFt ddS)u Оповещаем пользователя, если выбранные им галочки не будут активированы uДля работы выбранных опций необходимо активировать "Переопределять опции Simple Logic Проекта". Иначе будут применяться настройки ПроектаN) Zenable_sl_controlZsl_deadline_shift is_changedZsl_only_owner_approveZsl_deny_no_approveZ)sl_allow_executor_change_nofatal_deadlineZsl_task_need_approveZsl_readonly_closed_taskZsl_task_only_owner_closer!)r5rrrsl_consistent_warningsz!CmfWorkflow.sl_consistent_warningcCsttjj|dddS)uPВозвращает есть ли на данном БП утверждениеT)r need_approver)boolr#r$r')r5rrrrRszCmfWorkflow.need_approvecsh|jr|jstddd|jjr.T)r rr)rXr# CmfSchemeWfr%)r5Z scheme_fields filter_schemeZschemesr)r5r_get_related_schemessz CmfWorkflow._get_related_schemesc sz|}tjjddd|gdd|ggd}dddfd d |D}tjjddd|gd d|ggd gd }x>|D]6}|jrn||jj||jjdd7<qnWtj jddd|gd d|ggd gd }x>|D]6}|jr||jj||jjdd7<qWi}xT| D]H\} } | kr:| || j j<n&tj j | dtjj | dd|| j j<qW|rvt |SdS)NraZ scheme_wfrcr z==)r r)tasksdocscsi|]}|qSr)copy)rproject) default_scorerr sz9CmfWorkflow.get_related_projects_info..r_rk)r rrirh)rk)rgr#Z CmfProjectr% CmfDocumentrk setdefaultrrjCmfTaskitemsr:countZjsondumps) r5Zrelated_schemesZrelated_projectsZ projects_dictZ related_docsdocZ related_taskstaskZres_dictrkZ count_dictr)rlrrs4          z%CmfWorkflow.get_related_projects_infoc Kshtjjdddddggdd|jjgdd d |jjd ggd }|rLtd d dttj j|jj|gddS)NZANDrrcopenZ in_progressr:z==Z params_jsonZILIKE%)r ucРабота по замене данного бизнес-процесса уже запущенаT)r )r6) r#ZCmfDeferredJobrsreplace_workflowr:rrr!Zschedule_deferred_jobr)r5new_workflow_idZ_kwargsZreplace_task_existsrrrr s   zCmfWorkflow.replaceu(Смена бизнес-процесса) descriptionZshow_bg_progressbarcs4tjj|dtjj|d}tjjdgd}x.|D]&}|jkr4||_|jddtq4Wdddd d d d d g}ddd|gg}|fdd|D7}tjj||d} xF| D]>} x&|D]} t | | krt | | |qW| jddtqWdd g} xt D]} | j dkrqx| jdgfdd| D| ddgd}|sFPxF|D]>}x*| D]"} t || krVt || |qVW|jddqLWtqWqWxt D]} | j dkrqd| jkrx^| jddgdgddgd}|sPx,|D]$}|jkr||_|jddqWtqWqWdS)N)rrV)rVrF)ZnotifyrYrZr[r\r]r^r_r`rarbrccsg|]}|dgqS)z==r)rrd) old_workflowrrr ;sz0CmfWorkflow.replace_workflow..)r rr )rWrecsg|]}|dgqS)z==r)rrd)r|rrr Lsr)r rslice)r$ZCmfTransActionZCmfTransFilterZ CmfTransValidCmfTransdefault_workflowz==)r#rr'rWr%rVrJZ cmf_commitregetattrsetattrriter_subclasses class_namerrr)Zold_workflow_idrzr6r0Z new_workflowZwf_rulesruleZwf_scheme_fieldsrfZ wf_schemesschemerdZactive_entity_fieldsmodelZobj_listr3r)r|rry"sr                  zCmfWorkflow.replace_workflowc  sZd}g}xFtD]:}||jdd|gd7}|r|s|jdd|gddgd}qW|rr|dtd|d d d x0tjj|||d D]}|j f|d d |qWx.tj j|||dD]}|j fd|i|qW|r>xbtj jddd|gdd|ggddg|dD]6} | j |krd| _ | j |kr,d| _ | jd dqWtj f||d |dS)Nrr r)r )r r~z...uНевозможно удалить используемый бизнес процесс. Данный бизнес процесс используется в u объектахT)r )r include_deletedinclude_system)TEXKOM_db_deleteforce)rVrrrrar_z==r`)r rr)Z only_data)rrrsZslistr"r!r#r$r%deleterWrer_r`rJr=) r5rrr0Z ref_countZ top_usagerrrr)r?rrrhs2     zCmfWorkflow.deletecCs|r|s dSx:tjjddd|jggdd|ggdD]}||r2|Sq2Wx6tjjddddgdd|ggdD]}||rj|SqjWdS)NTr*rcr,r)rr )r#rr%rr+)r5r3r*r,Zpossible_transitionrrrcalc_transitions     zCmfWorkflow.calc_transitionc Cstd}|s dS||||}|s\|j|jsXtd|jd|jd|jd|dddS||||}|S)NFuAНет доступного перехода из статуса u в статус u" у Бизнес-процесса u для объекта T)r )rrloadr!r:r Ztrans_validator_okZtrans_run_actions)r5r3r*r,Zis_task_transition_runZ has_changesrLrrrrun_transitions "  zCmfWorkflow.run_transitionrcCstjj|||ddS)N) obj_version)r# CmfApproveZupdate_approves)r5r3 approve_grouprrrrrecalc_approvegroup_approvessz(CmfWorkflow.recalc_approvegroup_approves)Z only_onceZ system_jobcCsdd|gdddgg}x8tjj|ddgdD] }tj||tj|dq*Wx>tjj|ddd gdD]$}tj||tj||jjqfWdS) Nr z==zstatus.need_approveTrrk)r rrz cur_workflow_version.doc_version) r#rqr%rremove_approvegroup_approves calc_statusrocur_workflow_version doc_version)wfrr rvrurrrrs   z(CmfWorkflow.remove_approvegroup_approvescCstjj|dddgd}dd|gdddgg}x8tjj|d d gd D] }tj||tj|d q@WxFtjj|d d d dgd D]*}tj|||j j tj||j j q~WdS)NrBrCZ min_approvers)rr z==zstatus.need_approveTrrk)r rrrz cur_workflow_version.doc_version) r#CmfApproveGroupr'rqr%rZcreate_approvegroup_approvesrrorr)wf_idapprove_group_idrr rvrurrradd_approvegroup_approvess   z%CmfWorkflow.add_approvegroup_approvesc Csptj|}tjj|ddgd}dd|gdddgg}dd d d d d dddg }xptjj||dD]\}|rtjj|d|dgd} | ddks\| ddkrq\||||jj tj ||jj q\Wxjtj j||dD]V} |r tjj| d|dgd} | ddks| ddkr q|| |tj | dqW|s8|s8dSdddgdd|gdddgdddgdddgd dd!gg} tjj| ddd"gd} | sdSt |t |} t |t |}t }xN| D]F}|r|j jj|kr|td#|jj||jjqW| rltjjd$d%t| gd&} xJ|D]B}x:| D]2}tjj||||jdd'}td(|jjq0Wq&WdS))uj Перезаполняет аппрувы задач/документов на утверждении при изменении состава/свойств апрувгрупп или мастераппруверов статуса Если approve_group==None => поменялся статус. Иначе - аппрувгруппа rBrC)rr z==zstatus.need_approveTrzstatus.master_approverszstatus.approve_groupsz"status.approve_groups.approve_typezstatus.approve_groups.approversz&status.approve_groups.master_approversrkrz cur_workflow_version.doc_version)r rrZ resolution)r3 approve_typerrZapprovedZrejectedrNrrZpersonapproverz!=rr3zobj.cache_status_typer9z obj.statusuУдалили аппрув: rrc)r )r3rrZ obj_statusru(Создали новый аппрув: )r#rr'rror%rrrrrrqr(rrrrgdebugr-r3Z CmfPersonZ_create_or_update_approver)rrZapprovers_old_idsZapprovers_new_idsrrr rruZ aggreg_grouprvZapprove_filterZapprovesZ add_approversZdelete_approversZobj_idsZapprover3Z add_approverZ new_approverrrrecalc_all_approvessb        zCmfWorkflow.recalc_all_approves)NNNFFN)NF)r7NNT)N)FF)F)r)NNN)#__name__ __module__ __qualname__Z api_allowcommonr cmf_workflowrZ api_methods classmethodr4rrr>rOrQpropertyrRrJrUrXrgrr staticmethodZcmf_deferred_jobryrrrrrrr __classcell__rr)r?rrsD  2 . 4   # E!   r) Z cmf.includeZcommon.fields.cmf_workflowrZ cmf.modelsrZcommon.models.cmf_active_entityrrrrrrrrs