i B d dl Z d dlZd dlZd dlZd dl G d d Zy) N)*c e Zd ZU dZeed< d Z ej ej e
dd d Z de fd Z
d
Zd Zd Zd
Zd Zd Zd Z fdZe fd Zd Z xZS )CmfPluginCsvTasksMixinr
has_errorsc 6 |j |dz |f g dfS uT
Базовый метод для обработки группировки строк.
Вызывается, когда миксин тест-кейсов не распознал объект.
Просто добавляет строку в очередь для обычной обработки.
r putselfrowimport_settingsirows row_queuei_heads 8./modules/settings/models/cmf_plugin_csv_mixins/tasks.py_process_grouped_rowsz,CmfPluginCsvTasksMixin._process_grouped_rows
!
q1ucl#1u
) max_triesmax_timec | j j d }| j ||t j }| j | }|r|r|j
d s t d ||d< |j
d rW| j |d |d< |d j j d r$t j j
|d |d
< |j
d r| j | |j
d r|d |d < |j
d r|j
d s|d = d
D ]u }|j
| }|s|j
d r't j j
dd|d g }n t j j d:i |}|sq|||< w dD ]7 }|j
| }|st | j dv s3d||< 9 | j j! d| |j# dd }dd| j j$ gg ddd|d gg} | j j j& j
dd }
| j j j& j
dd } | rp|j
d r_|j
d j | j j( j& s!| j j( d |d |d< |j
d r d}
d d|d g} n$|j
d rd}
d d d|d gdd|d gg} |
st+ j, |j
d |j
d d z |j
dd z d z j/ j1 } | j2 j4 j7 | d!" }
|
5 | j9 | j t j || |
# \ }}d d d n1| j9 | j t j || |
# \ }}rt j; d$| j< j> d%| j< j@ d&| j j d'd(| j d)* }|jC d)+ tE | j j! d,| d-|j
d d.|j
d d/|j
d d0 nU| j j! d1 d-|j
d d.|j
d d/|j
d d0 | jG || | j j j& j
d2 rNt jH j
| j j j& j
d2 3 }n| jK || }|r5|jL jO |jL jQ | |r| jS |d | |_* n| j || j j d t jV }|rN|j
d xs$ |j
d xs |j
d }| jS || |_* |jX r|jC d)+ |jZ j& jX r |jZ jC d)+ tE | j ||t j: }|r|j
d4 rz|j
d5 ri||d< | j9 | j t j: | \ }}n5|r3| j j] d6d7d8 | xj^ d9z
c_/ | ja | tE y # 1 sw Y xY w);Nr nameu: Не указано наименование задачи!parent
logic_typeCmfTask task.epicepic tree_parentsys_typer$ status parent_task)
cmf_author cmf_ownercmf_modified_by responsible waiting_forext_idloginILIKEfilter) is_milestone)u нетFu_ Пытаемся создать или обновить задачу по параметрам
componentszcmf_import.plugin==)import_originalr4 Tmerge_identic_namesext_id_per_import:codeOR z.lockx )timeout)
filter_obj dont_updateuB Задача импортирована из файла: z () T)text log_levelr
cmf_importr5 save_importu' Создали новую задачу z ext_id=z code=z name=''u Нашли задачу target_list_id)idcmf_created_atrB u Невозможно импортировать задачу без проекта, создайте проект и укажите ID в файлеzERR-0079obj_typer )1rD
json_settings _map_objectmodelsr _get_projectget Exception_process_logic_typer9
startswith CmfFolder_calc_workflow CmfPersonstrlowerlogpoppluginvaluerI hashlibsha256encode hexdigestredis_dbredislockprocess_any_table_fields
CmfComment import_fileurlr save
cmf_commit_process_ganttCmfList _get_sprintlistsloadappend_get_componentsr3 CmfComponent
is_changed
op_gantt_task log_error _has_errors_process_timetracker)r
r r task project_objkeyvalpersontask_components_filterr? r7 lock_keyre task_obj task_is_newcomment
sprint_objcomponent_datacomponent_identifier comment_objcomment_is_news r _process_rowz#CmfPluginCsvTasksMixin._process_row s
//778IJ _fnnE'', 488F# \]] (DNxx %%)%=%=dI%N\" %**55kB*0*:*:*>*>;ag*>*hD 'xx!##D)xx &*6l]#xx
&txx/? 'c
+hhsmwwx(!'!1!1!5!5gwPST\P]=^!5!_!'!1!1!5!5!<!< $*S
+ )
&hhsm3s8>>+|; %DI
&
OO #B CG BH !I
J #hh|T :O %dDOO,B,BC/tF|,G #oo ; ; A A E EF[]b ccK $ = = C C G GH[]b c TXXh%7@R@]@]^b^m^m^p^p^v^v@w$(OO$6$6#7qh 8H!IXxx # !4f 6(# # T4>2 tT(^4 #>>XXf%(<*>?SU`*aH'""
$
/%%++66&&+++= L&&sOV=N=NOG7;;'78W[[=P$,!.2.K.KDOOLRL]L]LS/U+ ^ OO % % g"
&
! !!#& } s ,2`66a projectsc v |j D ]% }|d }|j d }|s|j d sd|d< |j d s$t j j d |d< n| j |d |d< |j d sJt j
j d
|d < n&|j d r| j |d |d< |j d r| j
| |d < |r|}n8| j | j t j | \ }}t |s=||d < | j |d
| }|r||_ |j | j |d | | j |d | | j! |d | | j# |d | | j$ j' |j( j+ j, j. | j0 j3 | ( y )Ndata existing_obj project_typeprojectr zproject.agile:defaultr9
CmfProject scheme_wfsoftdev:defaultactivityrz workflowssprintsr3 companiespersons)valuesrR rP CmfLogicTyperT CmfSchemeWf_process_activityrf rD r rk _process_workflowsr rj _process_sprints_process_components_process_companies_process_personsgantt_project_idsaddmain_gantt_projectrp rI r^ project_objsrq )r
r r project_dataexisting_projectrz is_newworkflow_schemes r _process_projectsz(CmfPluginCsvTasksMixin._process_projects s ( ( 6G"6?L &{{> : ##''73 L'' (d?d@dAdBdCdDdEdFdG }|j3 D ]< \ }}||j v s|j j+ || || < n |dHk( sd || < dID ]* } | |vs|| s
|| }t5 t! | }||| < , |D ]& } t7 |j8 j: | || ( |j dJ s|j- g dK |j8 j< r|j8 j> rt j@ jC |j8 jE |j8 j< j: |j8 j> j: |j8 jF j: L }||j8 _$ |j8 jK dMN y y c c} w c c} w c c} w # tL $ rM}tO | j j dO| dP| dQd)* | xj d+z
c_
Y d }~y d }~ww xY w)RNr outline_number фиксированная0-constu как можно раньше1-earlyu как можно позже2-latter не раньше3-after не позже4-beforeu начало не позднееu начало не ранее& окончание не позднее2-before" окончание не ранее1-after' фиксированное начало- фиксированное окончание фн фоu кмрu кмпu ннрu ннп) онр онп) u фиксированныйr r r r r r r r constrain_start_typeconstrain_start_date)r r r r )r r constrain_finish_typeconstrain_finish_date)r r r "uG Не найден тип ограничения даты начала "u, ". Укажите один из типов: z, zERR-0082 CmfGanttTaskrK r )r r r uM Не найден тип ограничения даты окончания "zERR-0083)
sched_work
const_work agregat_work actual_workactual_myself_worku ч< )sched_durationactual_duration?u* (\d+[\.,]?\d*)\s*(?:д|дней|день)?,. zop_gantt_task.)sched_start_datesched_finish_dateactual_start_dateactual_finish_dater r janfebmaraprmayjunjulaugsepoctnovdec) u январьu февральu мартu апрельu майu июньu июльu августu сентябрьu октябрьu ноябрьu декабрьu НД)actual_completer )z op_gantt_task.sched_start_datez op_gantt_task.sched_finish_datez op_gantt_task.sched_durationzop_gantt_task.is_manual)calendarfrom_dtto_dtforce_include_endsT from_importu: Не удалось импортировать Гантт u для задачи zERR-0072)(rO rD rN rP r rR striprZ r choicesr rv joinrw r endswithfloatresearch
IGNORECASEgroupreplace load_fields
isinstancedatetimeitemsintsetattrru r^ r r CmfCalendarget_duration_minutes
_get_calendar is_manualr check_gantt_projectrS commit_with_event)r
r r gantt constrain_start_type_mapping constrain_finish_type_mappingr constrain_start_type_rawr ttypesconstrain_finish_type_rawr{ patternmatchr| _vmappingmonth_rumonth_encalendar_durationes r rl z%CmfPluginCsvTasksMixin._process_gantt sd doo&C&CDU&VX^XkXkl u $&' m
&00)0 5i0 3J 0
( 0 &z
0 7
0 3I0 =j0 9)0 >y0 DY0 I 0 I!0" i#0$ j%0& i'0( j)0* ( (-0,6 3<)2'1EN:C>H % ' (
1- 99 34+0995K+L(/45K/L/R/R/T/Z/Z/\,+G+K+KLd+e(+/]]8L 45-1HH8A 458< 459M 569M 56-:3 8I I``056M0N0T0T0V0\0\0^-5R5V5VWp5qE12 45=__393F3F3\3\3d3d3k3k3m na1QCq n n 11 k mF lG GHHL RWHXGY [ &%3 2 ((A-(l 2248).3 )<)B)B)DE#J%*5:%6%;c
< C =C yy~ :++-66s; !&c
$"O " '5:r}} M "'++a."8"8c"BC).sa ")>8CYCYCkCk,2,>,>,S,S%-%;%;%I%I%K$,$:$:$K$K$Q$Q"*"8"8"J"J"P"P/7/E/E/O/O/U/U -T -) AR..=&&::t:LM B !n !o6 &Ov
&!#))PQVPWWlmulvw + *
A%
&si DW!
W,CW! >
W A W! ,A1W! AW! 1AW! 7 W A-W! 1+W! E3W! W! ! X7*AX22X7c | j j j d t | j }d}t j }| j D ]~ }| j j r y | j j j | d| |dz
}ddd|gdd|gg}t j j |dd g
}|s7| j j d | d d
| xj dz
c_ | j | D ]1 } ddd|gdd|gg}t j j |g d
} || _
| j j j! d s%| j j j! d r| j | _ | j% d | j& j) | j& j+ | j& j- d | j& j. j0 r | j& j% d 4 |j j j! d s!t j j5 dg dg dgdd|ggd g
} t7 | |_ |j0 sm|j% d t j |z
} | j j j d | d d y # t2 $ rA}
| j j d| dd
| xj dz
c_ Y d }
~
Dd }
~
ww xY w) Nu5 Привяжем подзадачи к задачамr из r: r- r4 r9 r tree_node_is_branchr1 fieldsuE Не удалось найти родительскую задачу zERR-0073r rK )r' r$ r task.subprojectr! TrE r u4 Не удалось привязать задачу zERR-0074)r r! )logic_type.codeLIKEztask.subproject%)r r z
task.epic%r$ =--u< Обработка подзадач выполнена за .3f сек.) rD loggerinfolensubtaskstime monotonic is_cancelrP r rR rv rw r' r r9 rU r$ rj ru r save_preload_fieldsr r^ rt rS sgetboolr )
r
totalr t1
parent_ext_idr r' child_ext_id
_filter_childry r
r t2s
r _process_subtasksz(CmfPluginCsvTasksMixin._process_subtasks s2 ##$[\DMM"
^^
!]] 9 7M((* OO " " ' '1#VE7(; <
FAhm [\G ..,, ) - K ))[\i[jk & *
A% $
m <
* *%)HdL+IFTXZfKg$hM!>>--]Kw-xD'2D$++667HI # 3 3 > >{ K+/+;+;(II$I/&&2243E3E3Y3Y3[\&&::t:L))//:: **//D/A
*, %%**556VW!>>.. ! K E
'[9
!6 /
37x. / )) $$$6s9 7v ^^
" ##&bcefibjjr$st3 ! *OO--N|n]"!* .
$$)$$
*s 'D-L!! M+*6M&&M+c | j j j d t | j }d}t j }| j D ] } | j j r y | j j j | d| |dz
}t j j |d }|s&t j j dd|d g }|s;| j j d |d d
d d
| xj dz
c_ t j j dd|d g }|s;| j j d|d dd
| xj dz
c_ ;t j j dd|d g }|s;| j j d|d dd
| xj dz
c_ t j j ||| }|sRt j |||| j d }d|v r
|d |_ d|v r
|d |_ |j# d t j |z
} | j j j d | d d! y # | j j d | d d
| xj dz
c_ Y xY w)"Nu& Создадим связи задачr r typer r r r0 u2 Не удалось найти тип связи "r zERR-0075CmfRelationTyperK r- in_linku= Не удалось найти входящую задачу zERR-0076r out_linku? Не удалось найти исходящую задачу zERR-0077)
relation_typer. r/ T)r0 r. r/ rD r5
constrain_lagconstrain_lag_pctrE u. Не удалось создать связь zERR-0078CmfRelationOptionu8 Обработка связей выполнена за r r )rD r r r relationsr r r rP r- rR rv rw r r3 r1 r2 rj )
r
r$ r r%
relation_datar0 r. r/ relation_optionr) s
r _process_relationsz)CmfPluginCsvTasksMixin._process_relations s ##$LMDNN#
^^
!^^ @ &M?
&??,,.&&++qcw,?@Q & 6 6 : :
f@U : V
$$*$:$:$>$>vsTabhTiFj$>$kM$OO--Mm\bNcMddfg"!2 .
$$)$ ..,,XsMR[D\4],^ OO--WXefoXpWqr"!* .
$$)$ !>>--h]S]E^5_-` OO--YZghrZsYtu"!* .
$$)$ "(":":">">"/ # % #? #
'&,&>&>&3 '!)#'??(, '? 'O '-78Eo8V5*m;B6J65A!J6A!J6;A6J668K1c d|d j d|d j }d|d j d|d j }t j j dd|g }|s| j
j j d
t j j d d |d j j d
d dg }|s t j j d }t j ||| j
d }||_ |j r|j d t j j |d d }|s/dd|d d gg dg}t j j | }|s(t j |d d | j
d }|d d |_
|j d }|s|d d }| j | } | |_ |d d |_ |j r|j d |j d|d d }
t j j |
} | s(t j j d d|gd d|gg } | s.t j j dd|d d gd d|gg } | sH| j
j j d t j! || j
|d } |
| _
|d d | _ || _ | | _ | j r| j d d|d j } d |d d }
t j$ j | }|sCt j$ j d! }t j% | || j
d }|
|_ t' |d j d"v r||_ |j r|j d t j* j |d ||d#$ }|s=|d |d#|| j
dd%}t j* d&i |}|j d ||| fS )'NzCSV::r ::r u БП для проекта u
и типа r- r r0 u/ Не нашли БП, создаем новыйr9 r r8 r %zdefault.system:defaultr T)r- templaterD r5 rE r& r- r r4 r- r4 N)r rD r5 cache_status_typeworkflow status_codeu7 Не нашли статус, создаем новый)r? rD r@ r5 u% CSV-схема для проекта r )ztask.agile:defaultztask.base:defaultr )r targer_workflowr cmf_model_name)r target_workflowrB r rD r5 rM )rI r rP CmfWorkflowrR rD r r r9 splitrt rj
CmfStatusCoder- calc_status_type status_type CmfStatusr@ r rY default_task_workflowCmfSchemeWfRule)r
ry r- r r? r; cmf_status_coder r> rH
status_ext_id task_status
scheme_ext_id scheme_nameschemerule rule_dicts r _process_workflowz(CmfPluginCsvTasksMixin._process_workflow2 s h **+2d<.@.C.C-DE,T(^-@-@,A tT`OaOfOfNgh%%))(C1H)I OO " " ' '(Y Z ))--fflI[I`I`IfIfgjIklmInHoopFq5r-sH!--117O1P )) ! ?? $ * H
MMdM + ..22$x.:R2S d8nX&>?AWXG $ 2 2 6 6g 6 FO $ 2 2(^H- ?? $ 3 O
"&h !9 HH%8 9 $Xx 8 ))*;< &1# #H~h 7 % % T 2#;;-r$x.*B)CD
&&**-*@ **..S(+ _57. K
**..d8nU]F^7_3=tX2N7P. QK OO " " ' '(a b **! ?? + $ + K + >(3 "1 "- ! ! . X 1 1 23
=d8nV>T=UV ##''}'= ))--3D-EH''$! ?? $ ( F " tL!&& '+V V+3F ( KKDK )%%))T,5GYa4:9 * V "< 0#+"+ # "oo#'
I ))6I6D II$I 'x,,r c d }d }d }d }|j d r*|d j d r|d d j }|r!t j j ddd| dg }|s| j j
j
d| d t j j d d
|gdg }|sN| j j
j
d | d t j j d
d|gdg }|r@|j rd| |j |_ n d| d|_ |j d |r|d d j }| j j
j
d| d d d
|gg dg}t j j | }|r*dd
|gdd
|gg}t j j | }|s*dd
|gd d
|gg}t j j | }|sS| j j
j
d| d dd
|gd
d|gg}t j j | }|sL|j d r| j | \ }}}n%| j j
j d ||d< ||d< |S )Nr? r- r z%::z::%r0 u Ищем БП по коду "r r9 r r u Ищем БП по имени "r r/ r9 TrE r& u- Ищем статус в БП по коду "r= r@ u/ Ищем статус в БП по имени "r ut Невозможно создать БП и статус, не указан логический тип задачи)
rR r rP rD rD r r r- rj rF rI rT warning) r
ry r workflow_ext_idr? rN rM filter_r@ s r rW z%CmfPluginCsvTasksMixin._calc_workflow s 88J D$4$8$8$B ": .x 8 > > @O ))--h#oM^^aHb5c-dH&&++.KOK\\],^_!--11	W:B 2 E OO**//2QRaQbbc0de % 1 1 5 5fg=_>FZ 6 IH ,..??P*Q,..?r*B MMdM3 $Xx 8 > > @
&&++.[\i[jjk,lm "C 79OP $ 2 2 6 6g 6 F *C :]CQ\<] ^G"("2"2"6"6g"6"FK" *C :VS-| j j
j
d| d|d< | j |d< d|d< |j d r,t j j d d
|d d g |d< |j d
r)t j j |d
d |d
< t j di |}|j rR|j rF|j j t j |j j z |_ |j! d y t# t% d rt$ | M | y y )Nr u Грузим журнал closedr& rD Tr5 r( r. r/ r- r0 r r< )minutesrE r rM )rO rD rN rP CmfTimeTrackerHistoryr r rR rX r
start_date
time_spentr^ r timedeltaend_daterj hasattrsuperr )r
r timetracker_historyhistory __class__s r rx z+CmfPluginCsvTasksMixin._process_timetracker s " . .s/3/L/LM^/_/5/K/K M OO " " ' '*DEXDY(Z [,4 )04 -59 1 2"&&|44:4D4D4H4H #W.A,.OPX.YZ 5I 5#L1 #&&x0060B0B.x8B 1C 1#H- 22I5HIG!!g&8&8#*#5#5#;#;h>P>PY`YkYkYqYq>r#r LLTL *
UWn
- G % .r c
t t d rt | }ni }|j i dddddddddd ddd
d ddd d
ddddddddddddddddddddddddddddddd d ddd d ddd d!ddd"d#ddd$d%ddi d&d'ddd(d)ddd*d+ddd,dd-dd.dd-dd/d0d-dd1d d-dd2d3d-dd4dd5dd6d7ddd8d7ddd9dd:dd;dd?d=dd@dAd=ddBdCd=ddDdEd=ddFd=ddGd=ddHd=ddId=dddJddK |j i dLdId=ddMddddNddddOdPd=ddQdRdSddTd?d=ddUdAd=ddVdGd=ddWdXd=ddYdHd=ddZd[d=dd\d]d=dd^d
ddd_dCd=dd`dmky?z=)
>
5EWgu6v?)
@
;K^n|<}A)
B
>ljx?yC)
D
AQ_o}B~E)
F I]VdzfL]m{=|4HXf%g }M ]k nl5;<&XQ)
) T +
%5^T+
()D+
,FR[-\ +
'7GWe(f
+
-YVi.j+
$4FVd%e+
*:M]k+l+
*
2BScq3r++
,
2BUes3t-+
.
8H\lz9{/+
4
,Tdr/s7+
<
(8HXa)b=+
>
FVb sA HB?+
B
>mky?zC+
P
~YOQ+
+ X r c 6 |j |dz |f g dfS r r
r s r r z,CmfPluginCsvTasksMixin._process_grouped_rowsu r r )__name__
__module__ __qualname__r r __annotations__r backoff on_exceptionexporS r dictr rl r* r7 rT rW r r rx classmethodro
__classcell__)rm s @r r r s Js W',,#$&#%(f (fP)6$ )6Vs&jCuJJqX`-D< |8 &6 \ \ | r r )r r r_ r cmf.includer rM r r r s v
v
r