i51j92ddlddlmZddlmZddlmZddlmZddl m Z m Z m Z ddl mZdZej ej"ej$ej&ej(ej*ej,fZhd ZGd d ej2Zy ) )*fields) cmf_roadmapRoadmapExportDataManager)aliased)funcselect nullslast) defaultdict> ft_sourcesft_bql_sourcesui_view_form_optionsceZdZdZej j dgzZdZdZfdZ fdZ ddfd Z fd Z dfd Z eedd dd dZedZedZedZedZedZedZedZedZedZe ddZedZedfd ZxZS) CmfRoadmapTncget_filtered_roadmap_by_levelcFfd|jjS)Nc|sy|jdk(r|S|jj|jjS)N CmfProject) class_name tree_parentloadvalue)child root_parents './modules/project/models/cmf_roadmap.pyrz,CmfRoadmap._calc_parent..root_parent sE</ !!&&("5#4#4#:#:;;)rr)selfrs @r _calc_parentzCmfRoadmap._calc_parents! <4++1122rcX|jjs |jsyd|_y)Ngantt) logic_type is_changedis_new ui_view_form)r s r_calc_ui_view_formzCmfRoadmap._calc_ui_view_form+s!**;; #rc*t|ddgzS)Nzmembers.responsibleztree_parent.activity)supersave_preload_fields)r __class__s rr+zCmfRoadmap.save_preload_fields1sw*,0EG]/^^^rc|js|j|_|jr|jjgd|jsK|jr?|jjj r|jj|_|jsK|jr?|jjj r|jj|_|js&t jjdd|_|jr|jr-|jjs|jxsd|_ n|jr%|jjjdsV|jr2|jjdk(rd |jxsd|_ nd |jxsd|_ |jr9|j j"s|j$j"r t'd d t)|T|i|}|jr>t j,j/|t j0j/||j j"r#t3t j4j6|jj"rj|jr^|j D]O}|jj |jk7s+|j|_|j*|d di|Q|S)N) cmf_ownercmf_owner_assistantsactivity logic_prefixadd_object_typer productionT)codecache_inmemory1)RoadmapuДорожная картаz project.baseuДорожная карта zRoadmap uLНельзя изменять memrers и tasks у корневого RoadmapabortnotifyF)parentr! load_fieldsr0rrmodels CmfActivitygetr&r2namer startswithr1systemmembersr%tasks cmf_alertr*saveCmfRoadmapQuickTransformscaffold_defaultsCmfRoadmapViewschedule_deferred_jobrrecalculate_cache)r argskwargsresmemberr,s rrFzCmfRoadmap.save4s\{{++-DK ;; KK # #k $  }}!1!1d6F6F6O6O6T6T6V ,,55DM}}1E1E1J1J1L KK00DM}}"..22 UY2ZDM ;;{{4;;#>#>#yy/C0 YYdiioo&@&@Ak&l;;4;;#;#;~#M">tyy?OC>P QDI"*499+;*< =DI ;;||&&$***?*?hptuglD+F+ ;;  + + = =d C  ! ! 3 3D 9 << " " !&"3"3"E"E F ;; ! !dkk,, ?==%%'4;;6$(KKFMFKK>e>v> ? rF)skip_owner_checkc tjj|D]}|j|ddi|tjj|D]}|j|ddi|t | |d|i|S)N)r;rPT)r=rGlistdeleterIr*)r rPrLrMqtviewr,s rrSzCmfRoadmap.deletefs1166d6C >B BIIt =d =f = >))..d.; @D DKK ? ? ? @w~tQ6FQ&QQrct||i|}tjj |dD]}|j|i|tj j |dD]}|j|i||S)NT)r;include_deleted)r*restorer=rGrRrI)r rLrMrNrTrUr,s rrXzCmfRoadmap.restoremsgot.v.1166dTX6Y (B BJJ ' ' ())..dD.Q *D DLL$ )& ) * rct|||tjry|j gd|j sy|*|j dDchc]}|j}}n t|}|tzsytj|jvrytjjdycc}w)N)manage_by_owner_onlyr.r/r;T)r%uНе достаточно прав на управление Диаграммой Ганта. Обратитесь к администратору или владельцу проекта)message)r*check_edit_permgdisable_permissionsr<rZvaluesrsetGENERATOR_FIELDScurrent_person get_ownersr= CmfAccessListcheck_admin_mode)r changed_fields_to_checkadditional_error_msgfchangedr,s rr\zCmfRoadmap.check_edit_permus  79MN  `a((  " *-1[[D[-IJq||JGJ12G**   t0 0 --u . KsC<) only_oncesoft_time_limit system_jobpriorityc Vtj}d}d}|jddgD]}|dz }t|j}|j |k7r|dz }t jd|j d|d|j||_|jd |jj|j jd }td |j|td ||dzdk(stt jd|d|d|S)u;Актуализация кеша кол-ва членов.rcache_members_countrCrzUpdate cache_members_count z ->  T) only_data)node_idelements_countztree-node-count-changes-ztree-node-count-changes2z Recalculate /z roadmaps caches) r=rrRlenrCrqr]debugidrFrcmf_emit_event cmf_commit)_kwargscls total_count calc_countr real_count event_datas rrKzCmfRoadmap.recalculate_caches-  88,A9+M8N K 1 K[001J..*<a 5k6U6U5VVZ[eZffghshvhvgwxy2< /   40)4)=)=Q\QpQpQvQvw !9+..9IJJW!8:FB!#   ,zl!K=8HIJrcg}g}|D]Y}|}|j|} | r|n|} | rtjntj} |} d} | r|j ddd}t | |d}|t d|d| jdt|tst d|ddt | |drt | |} | j| } nat |d d r5t|tjstj| | ||| } nt|tjtj frt | |d zd} nt|tjr|j#}|j%|}|j&}|j(rd }d }nd }d }t+j,t+j.|j0|d}t3|gj5|j0|| j6k(j9j| } | 8|j;| |j;|\||fS)N.rru Поле "u" не найдено в Tr8u&Группировка по полю "u#" не поддерживаетсяcustom_table_nor_idright_idleft_id)rAr= CmfGanttTaskCmfTasksplitgetattrrEr issubclassALLOWED_GROUP_TYPESlabelr CmfM2MBaser_ext_scalar_column CmfRelationCmfGenericRelation m2m_model_clsdp_model __table__rightr array_remove array_aggcr wherer{ as_scalarappend) query_fields gantt_prefix sa_task_modelsa_gantt_model data_driverto_be_selected_cols final_fieldsfield field_name is_gantt_taskSaModelCmfModelaliascol field_cls m2m_model sa_m2m_modeltblmy_id_field_namesub_id_field_nameaggs r_select_group_fieldszCmfRoadmap._select_group_fieldss=  !0 0EJ!,,\:M(5n=G.;v**HEC C+A.%6I Jzl2KHL_L_K`aimni)<=B:,Nqrz~wt,gu-ii&9&7;JyZ`ZkZkDl$77'9V[]bcC F,>,>@Y@Y+Z[!'55=$?C 6+<+<= ) 7 7 9I#.#7#7 #BL&00C +5(,5)+4(,6)++DNN355AR;S,TVZ[C!3%=..suu5E/F'**/TU%IKe #**3/##J/a0 0d#L00rcz|sxtt}tt|d<|ddj|Dchc]}|d c}|Dcgc] }|dd|dfc}|d<|j ||S|d}tt}|D]^}||}t |tr3|r|D]}||j |6|dj |K||j |`t } |jD]"\}} tj| |dd|| |<$| Scc}wcc}w)utСтроит рекурсивные группы Roadmap без потери задач с пустыми M2M. Пустые M2M-значения сохраняются отдельным ключом, чтобы экспорт вывел их в группе «Не назначено», а не пропустил при обходе групп. maprrr{Nr) r rRr`updater isinstancedictitemsr_nested_grouping) rrfinal_items_groupsitems_by_levelitemrgroupedkeyelrN sub_itemss rrzCmfRoadmap._nested_groupingsQ(.N$/$4N5 ! 5 !! $ + +E,JDT$Z,J KLQ RD$t*dDJ!? RN1   % %n 5! !q d# *Du+C#t$!1 **401 DM((. ##D) *f%mmo ^NC!229fQRjJ\]CH ^ 3-K Rs D3D8c|jjj}tt|j jj}|j rd\}}nd\}}ttj|jjgj|j||j||jjk(j|j||jk(j|jj dk(j#j%|S)uКлюч сортировки по m2m-полю: первое по алфавиту имя среди связанных сущностей)rr)rrF)rrrrr=modelrr r minrr@ select_fromjoinr{r cmf_deletedrr)rsa_modelrm2m_tblrel_tblrrs r_m2m_sort_columnzCmfRoadmap._m2m_sort_columns))+44>>&)//2;;EE ??2G / /2G / /012W\\'799=N3OSZS\S\S_S_3_`awyy!12hkkABwyy,,56UU5\  +rct|dd}|rt|tjry|jj j ||}t|tjtjf}|r|dzn|}t|j|gj|jj|jk(jj|S)uWКолонка из внешней таблицы для кастомных полей rrNr)rrrrdpr ext_sa_modelrrr rrr{rr) cmf_modelrrrrext_noext_tblis_relcol_names rrzCmfRoadmap._ext_scalar_columns$5q9Iv/@/@A,,**77 6JI(:(:F}|||D]1\}}|||f}||vs|j ||j |3@|dkDr2||dz r|j ||dz |r|j ||rx|dkDrb| r`||dz Dcgc]^}}|}}}g}||jD]#\}}|D]}||vs|j |#%d|dd|gdd|gg}|j ||r;|s| r6|j|jj|j|jj|} | r)| j||j|jk(} |r7|j|t j"|| \} }!| j|!} | rt$j'||| | | | } | j)}"g}t }|"D]C}#|#d}|||D]1\}}|||f}||vs|j ||j |3E|||<|}n|rt|ddD]}$||$s t ||$dz }%g}&||$D]R\}'}(})||$dz j+|(gD]1\}*}+|(|*|+f}||%vs|%j ||&j |3T|&sz||$dz |&z||$dz <| st-t},||$dz D]\}}-}|,|j |-|f|j|jj|j|jjt|,}.| r)|.j||j|jk(}.t$j'|||.| | | }.|.j)D#-cgc]}#|,|#dD] \}-}|#d|-|fc}}-}#||$dz <||fScc}}wcc}}-}#w) NrrrORparent_task_idINr{ in_filterrrr)range MAX_LEVELSrRkeysr`addrrrr{rfilterin_rop_gantt_task_idcollect_filter_expr=rrrallr?r )/sessionTask GanttTaskr levels_dictadditional_levels_dictfiltersglobal_bql_listchild_task_filterrrshow_sub_itemsneed_gantt_joinrfinal_levels_dict max_levellevelconds level_idslevel_ids_with_parent seen_triplestask_id parent_taskroot_idtripletid_previous_level_idsadditonal_tasks_of_prev_level add_task_idadd_task_parent_idsadd_task_parent_idquery_n query_filter filtered_idsrowl level_triples added_triplesr parent_id_rootgrand_parent_id grand_root parents_by_idr resort_querys/ r_filter_levelszCmfRoadmap._filter_levelsCs#  1j1n-H EE[/4467I%' !5L$ =,7,>w,G=(K%{G+ICw { g~#!%%c*+ +!-'$H % rc Z tjj}tttt }t tdfdfdfd} fd} t dtdzD]} | dz D cgc]} | | dz r| } } | s(|D]u} | | jdtkDr| d }| jd d }|d k(r|j|j|jj|jd k(|j|k(|jj| j!}|Dcgc] \}}||f }}}n|j|j|jj|jd k(|j|k(|jj| j!}|Dcgc] \}}||f }}}|D]\}}| | ||s|| ||x|st j| dz ij#|j| dz t z}|D cgc]} | | dz s| }} |s|j$j||jd k(|j&d k(g}|s|j)|j*d k(|j|j,|j$j|j!}|D]$\}}| | ||s|| j/|&t0j3ddj5dj7Dz fScc} wcc}}wcc}}wcc} w)u@ Раскрывает дерево по связям: для каждого уровня берёт задачи с предыдущего уровня, находит их связанные задачи через CmfRelationOption, добавляет на текущий уровень Параллельно ищет циклы: если связанная задача уже встречается в своей ветке выше то это цикл, помечаем как цикл и не раскрываем дальше c ttSN)r r`rrz2CmfRoadmap._process_linked_items..s +c2Brc |j|g}j|i}|Dchc]$\}}||j|tvs#|&c}}Scc}}w)u Возвращает set root_id веток, в которых задача есть на уровне lvl и при этом ещё не помечена циклом )r?r`)r r%entriescycle_at_level_pr(rlink_cycle_per_roots r_get_non_cycled_brancheszBCmfRoadmap._process_linked_items.._get_non_cycled_branchess_ "#&**7B7G044S"=N)0cXRG>CUCUVZ\_\aCb4bDc ccs $AAct||f}||vr |g||<y|||vr||j|yy)uNКладет (parent, root) в levels_dict[level][task_id] без дублейNr)rr rr entryrs r_add_levels_entryz;CmfRoadmap._process_linked_items.._add_levels_entrysZ#W-Ek%00/4g E"7+k%099E"7+2259:rc^|}||vr|||vr||j|yy|g||<y)uQКладет parent в additional_levels_dict[level][task_id] без дублейNr6)rr rbucketrs r_add_additional_entryz?CmfRoadmap._process_linked_items.._add_additional_entrysF+E2F& !87O**>:9$2"2wrcd}||dz D]Y}tj|||dz |}|r, j|||f ||j|nd}||||[|S)u Кладёт связь parent -> task в каждую незацикленную ветку родителя, циклы помечает в link_cycle_per_root Возвращает True, если хотя бы одна ветка без цикла FrrT)rr)r) rrr added_non_cycler is_cycler8r4rr3 link_cycless r _process_pairz7CmfRoadmap._process_linked_items.._process_pairs $O3NEAIN K%33G^UUVYX_almOOWng$FG'.w7;;GD&*O"%.'J K# "rrrlevel_torelation_type_id directionoutinFz8ncget_filtered_roadmap_by_level additional_levels_dict= , c3DK|]\}}d|dt|ywr%=Nry.0r%idss r z3CmfRoadmap._process_linked_items..Os8X_s{svx{Z]^a]bbcdghkdlcmXnX_ )r=CmfRelationOptionrr rr`rrr?r in_link_id out_link_idrrrCrrrris_dummyr cmf_archivedr{rr]rzrr)!rrrshow_linked_itemsshow_child_tasksinclude_archivedRelation_linked_children_idsr;r@rr prev_level_ids relation_typert_idrDresultsin_idout_idpairsrr  candidate_idsids_for_children child_filter child_resultschild_idrr8r4rr3r?s! ` @@@@@r_process_linked_itemsz CmfRoadmap._process_linked_itemss++44!,T!2*3/e )*BC d : 3 # #&1j1n-7 FE +5195+C;N"!2 N =,,ZDD%&89)--k5A $%mmH,?,?AUAUV]] ,,5 11U: ++//?ce  CJJeV_JEJ%mmH,@,@(BUBUV]] ,,5 11U: ,,00@ce  CJJfe_JEJ/4N+NG$UNGD-eWnMN+ N2 .22519bAFFHIL`LdLdejmnenpspuLvv4A#mCD\]`bgjkbkDlC#m #m#++//0@A((E1 .$L ,$++D,=,=,FG$VGMM$''4;N;N$O$V$VXd$e$i$i$kM/<F+)( 8D07;;HEFk7 Fr JdiiX_@V@\@\@^X_O__ `%{22q&KK$nsN"N 1N" 6N(N(c &|r\|gtdtdzD cgc]} t|d| c} z} |jt | dD cgc]$\} } | j j d| d&c} } j|} tdt| D]7} | j| | | | j| | dz j k(} 9| j|j j|} |r)| j||j|j k(} |rtj!||| |||} | j#} n|Dcgc]}|fdtdz zz} }t%t&}| D]p}|d}tdtdzD]S}||dz }|dk(rdn||dz }|||f}|||vr |g|||<2||||vs=|||j)|Ur|Scc} wcc} } wcc}w) NrArrT)r@r%rr,r)rrr rrr{rrry outerjoinrrrrrrrrr rr)rrrfirst_level_idsrrrrWrialiasesarrowsr rrr  level_indexrr7s r_build_levels_dictzCmfRoadmap._build_levels_dictRsE fU1j[\nE]^Qqc7 ;^^G"GMM7@!7LMtq!!$$**s1#S\*Mk$ 1c'l+ d GAJ4M4MQXYZ]^Y^Q_QbQb4bc dLL_!=>E 9d.C.Cy||.ST"--dIukS^`lm99;DL[[WJJN!;;[D["$'  DC!fG$Q Q7 D kAo.)4)9s;QR??S?'1+k"::9>K ,W5+k":7"CC ,W5<t jG|:||;}>|s|retId!9dzD]S}?|4|?D]I\}5}@}A|;D]>}B@|Bd"|?dz vsB|?j|5@Af|Bd"|?j |5@KU|;D]}B|BjKd"tA|>}4tjd#dj+d$|4j=Dz|r8rtM|8|4d%<tjd&|4Scc}3wcc}5w)'ui 1) Делаем большой запрос с 20 JOIN (T1..T20) и узнаём, какие задачи есть на каждом уровне. Сохраняем в levels_dict = {1: {id: [(parent_id, root_id), ...]}, 2: {...}, ...}. 2) Для каждого уровня (1..20) делаем новый запрос, где: - Условие: CmfTask.id IN (levels_dict[level]) - Плюс фильтр по уровню — если он задан - Плюс глобальный фильтр — если он задан 3) Результат: словарь {1: [(id_1, parent_id_1, root_id_1), ...], 2: [...], ..., 20: [...]}, где лежат уже отфильтрованные задачи на данном уровне. Если обнаружены циклы, возвращаем по ключу 'link_cycles' список узлов с задачами которые являются началом цикла 4) Реализуем вложеную группировку, если переданы group_by_fields z4ncget_filtered_roadmap_by_level method_start: start=z, end=z, group_by_fields=z, show_linked_items=z, show_sub_items=z, sort_fields=z, sort_orders=rCu+Дублирование relation_type_id: Tr8rr)r1z!=ztask.gantt_project)r==F)rTrsF)rUrsFNzop_gantt_task.)rrrrz2ncget_filtered_roadmap_by_level group_by_fields : c3@K|]}|jywr,rArMrhrs rrOz=CmfRoadmap.ncget_filtered_roadmap_by_level..sRQall<8Rc3@K|]}|jywr,rurvs rrOz=CmfRoadmap.ncget_filtered_roadmap_by_level..s'ZKyzZ[ZfZfgsZtZKrwrz7ncget_filtered_roadmap_by_level : len(first_level_ids)=rrz-ncget_filtered_roadmap_by_level levels_dict= rGc3DK|]\}}d|dt|ywrIrKrLs rrOz=CmfRoadmap.ncget_filtered_roadmap_by_level..s8PLksknpsRUVYUZZ[\_`c\d[ePfPLrPz3ncget_filtered_roadmap_by_level final_levels_dict= c3DK|]\}}d|dt|ywrIrKrMr%rs rrOz=CmfRoadmap.ncget_filtered_roadmap_by_level..#s8RXoyortyTWX[W\\]^abg^h]iRjRXrPr{rArz*ncget_filtered_roadmap_by_level grouping: c3DK|]\}}d|dt|yw)zgroup(z)=NrKr{s rrOz=CmfRoadmap.ncget_filtered_roadmap_by_level..Ds7MWnxnqsxvVYUZZ\]`af]g\hMiMWrPr?z*ncget_filtered_roadmap_by_level method_end)'r]rzr`rErrr=rr _get_filterrrrrSessionr{rranyrrrrrrrslicerryrqrr rrgr!rrpoprR)Dinsert_bql_listr lvl1_bql_list lvl2_bql_list lvl3_bql_list lvl4_bql_list lvl5_bql_list lvl6_bql_list lvl7_bql_list lvl8_bql_list lvl9_bql_listlvl10_bql_listlvl11_bql_listlvl12_bql_listlvl13_bql_listlvl14_bql_listlvl15_bql_listlvl16_bql_listlvl17_bql_listlvl18_bql_listlvl19_bql_listlvl20_bql_listrXrrWrVrstartendrrgroup_by_fieldsseenrr]rrlfltrrrrr to_be_slicedfirst_level_rowsrkto_be_selected_fieldsadditional_fieldsr first_queryrfirst_query_filterrrr rrr?r tasks_lvl1r task_datargrouped_levels_dictrrr final_items_grouprsD @rrz*CmfRoadmap.ncget_filtered_roadmap_by_level~sD*/R)/R-3!'R !'R )/R FugVTWSXXjkzj{|%%6$77HHXXfgrfstBCNBOP Q 5D) /0D= KE7S[_`   =- =- NNNN NNNN  !) `GAt#^^..::6>>HVZK[\]^_  ` $nn//;;FNNXWfLghijkO $nn//;;FNNXWfLghijkO  & 1 1 = =fnnxYjNk lmn o  KL;<89  " "#@ A~~&&''00 nn''33 %%'   $4 $  $$#  ' !%  1;1P1Pl"9+2Q2 . %:c3q6>> I#oJ^I_`a $5L[#\WdG$<#\ a $77y/k ,K GGCdiiPLxCxIxIxKPLGLL M%0%6 "%K 6@6V6VT;0A$&673& ,6+D+Dy+{&!;  , ( y E RX~O~U~U~WRXIXX Y !"B  J!# ' - F )4&?*B C.HAu'*1vIe$.!!),  -#-"="=j/[m"n  #4"1i!m4ME:>9>:>7<.2,048488<L!L!\((DDrrN) cmf.includecmfrmodules.project.fieldsr$modules.project.utils.roadmap_exportrsqlalchemy.ormr sqlalchemyr r r collectionsr r CmfChoice CmfChoiceIntCmfBoolCmfDaterrrrrarr-rrrs.I"..#     NN NN   LG D''G Dr