;iJ d dl mZ d dlZd dlZd dl d dlmZ d dlmZ d dl m
Z
d dl m Z m Z m
Z
mZ G d d ej Zy)
)OptionalN)*)fields)cmf_import_plugin) CmfImport)DictUnionListr c l e Zd Z fdZededefd Zededefd Zed Z ededefd Z
ede de e e ffd Z e
d!d ede d
ee deeffd Zd Zdd
d
d
d fd
Zd d fd
Zd Zd Zd Zed Zd Zd Z d Z ed Z d Z d Z ed e!e de fd Z" xZ#S )"CmfImportPluginc t | |i | t j j d | _ t j | _ t j | _
y )Nsoftdev)code) super__init__models CmfActivitygetdefault_activityconfigIMPORT_THREADSthreading_max_forksIMPORT_DOWNLOAD_THREADS download_threading_max_forks)selfargskwargs __class__s $./common/models/cmf_import_plugin.pyr zCmfImportPlugin.__init__
sM
$)&) & 2 2 6 6I 6 F #)#8#8 ,2,J,J) namereturnc g dg dddgg dd}|j D ]$ \ }}|D ] }|| j v s|c c S & y)N)u открытopenu к выполнениюtodonewpausedu
зарегsubmit)u
работprogress
indeterminateactive
inProgressu обсуждdiscusreviewu
ревью)closeu закрытu
готовdonearchived cancelled)OPEN IN_PROGRESS IN_REVIEWCLOSEDr3 itemslower)r! mapping status_typewordswords r calc_status_typez CmfImportPlugin.calc_status_type sj
3!
F #*--/ ' K
'4::<'&&
' '
r c dgdgddgddgg dd}|j D ]$ \ }}|D ] }|| j v s|c c S & y )
u+ Поиск priority по синониму u минu низкu
обычнu нормальнu срокu
высок)u блокирующu
большu крит)r r r7 )r! r: priorityr< r= s r
calc_priorityz CmfImportPlugin.calc_priority? sk
01L)>
'}} $OHe
$4::<'#O
$ $ r c 6 | r|syt | j j }|j D ]Y \ }}|t | j j t | j j fv sW|c S | S )u
Находит ключ по значению или ключу в атрибуте choices у field
Args:
value: Значение для поиска
choices: значения поля
Returns:
Найденный ключ или исходное значение, если ничего не найдено
N)strstripr9 r8 )valuechoices str_valuekey choice_values r calc_choicesz CmfImportPlugin.calc_choicesO s G J$$&,,. ") C S . 4 4 6 < < >C@P@V@V@X YY
r c dgg ddgdgdgd}|j D ]$ \ }}|D ] }|| j v s|c c S & y)ue Поиск программных типов workflow для проектов по синониму agile)baseu основнu классическhelpdesk servicedeskwiki)
project.agilez project.basezproject.helpdeskzproject.servicedeskz project.wikirU r7 )r! r: logic_prefixr< r= s r calc_logic_typez CmfImportPlugin.calc_logic_typee sf &Y L!+ $1? #H
$+==? ( L%
(4::<'''
( ( r
obj_fieldsc 4 i }i }i }|j D ] \ }}t |t t f r| j j | }|dk( r2|j
D cg c] }|j dk( s| c}d } nI|dv r2|j
D cg c] }|j dk( s| c}d } n|j
d } t |t j j r | |d||< | |d||< |||< |||fS c c}w c c}w )Nparent
CmfProjectr ) executors
spectators CmfPerson)modelr ) r8
isinstancedictlistr r related_models__name__
issubclasscmf
CmfM2MBase)
r_ rX related_objs current_objm2m_objs
field_namerI
main_fieldm
related_models
r _get_any_table_fieldsz%CmfImportPlugin._get_any_table_fieldsu s" !+!1!1!3 0 J%$ . "\\ - -j 9
)0:0I0I0K$j1qzz]iOiQ$jkl$mM #>>0:0I0I0K$i1qzz]hOhQ$ijk$lM$.$=$=$?$BM j#***?*?@5Be+THZ(9FRW/XL,*/ J' 0" [(22 %k %js %D:DD0DNF
cmf_import
filter_objc
~
| j || \ }}} |j D ]' \ }
} | j || d | d \ } }
| ||
< ) | j D ] \ }
} |j |
g ||
< g d}|D ] }| d j |d }|st j
d| }|D ] }||j
i}|
j d }| j || d || \ } }
| 6|j d
|j
d |
d d
| d j ||
j | |t j k( r|sd|d< |j dg D cg c] }|j j }}d|v r
d|d< d|d< d|v r:d|vr6t j j dd|d gdg }|r|dfS |d |d< |t j k( r8dd|d gd d|d gg}|j d r|j d d|d g |t j k( r=d d|d gd d|d gd dt" j$ j' |d d! gd"d|d" gg}|r|}ng }g d}|D ]L }|j |d }|s|d#k( r|j d$|d|gd%d|gg n|j |d|g n |s|j D ]{ \ }}|s t) |t* j j, s%t/ t1 || t2 j4 sR|j | d&dt7 |j8 g } d} |r}|j d r9|t j: t j< fv r|j d d'|d g |D cg c] }| } }| j d( |j || } | s0|t j k( r d|vr|j d)| d*d+d, y-| rdnd} |r| r| | fS i } |j d r|d | d < | r| n |d1||j d dd.| } |j D ] \ }}t? | || |rN| j@ rBd} |d1||j d dd.| } |j D ] \ }}t? | || | j@ rI| jB r=| jD r |j d/k( r| jG | jG d0 | } | | fS c c}w c c}w )2u
Создание объектов на основании моделей при импорте
:param CmfImport cmf_import: Объект импорта для хранения настроек, статуса по текущему импорту
:param model: Модель по которой создается объект
:param dict obj_fields: Параметры объекта
:param Optional[list] filter_obj: Фильтр для проверки на существование объекта в БД
:param bool dont_create: Не создавать объект
:param bool dont_update: Не обновлять объект
r_ r )r_ rX N)ext_idr r! emaillogin z[,;]cf_)r_ rX dont_createu& Не найдено значение 'u ' поля ''zERR-0135)obj_typeT
user_local rg_member_ofServiceDeskClientFemail_if_self_changesrt ru ILIKEz**filterr r; ==workflowr! rZ
cmf_authorcmf_created_at)dayfirsttextrs ORr _id=r uN Не удается найти или создать пользователя uf . Проверьте правильность ввода логина/email пользователя. zERR-0115r^ )NF)rp r! import_originalr[ ) save_import )$ro r8 process_any_table_fieldsr resplitrH
startswith log_error
class_nameappendr r^ r rI CmfStatus
CmfCommentdateutilparserparser` rf CmfEntityre getattrr
CmfRelBaserG id CmfComponentCmfListsetattr
is_changedr is_newsave)!clsrp r_ rX rq rx dont_updaterh ri rj main_field_name related_info related_obj_ field_namesrk field_valuevaluesrI related_obj_fieldsrelated_dont_createpgrg_member_of_codeexisted_person_filteruniq_field_namesuniq_field_nameuniq_field_value existing_obj_fieldsr r new_objs! r r z(CmfImportPlugin.process_any_table_fields s2 & /2.G.Gz.Z+ k8 .:-?-?-A 7 )O\ 9 9*LY`LaEQRZE[ : ]NK+6K ( 7
.6^^-= )O\/7/1 O,FK )
*8 4 8 8R H XXg{ ;F!' I.8%++--H*.=.H.H.O+),)E)E &".w"7'9(; *F * Q '. & 0 0"H Wcdscttu v *)5g)>)I)I 1
$O4;;KH!I" +
6 F$$ $Z(,K %9D Y[9\ ]2 ] ]"&77,1 L)7< 34+%g.D!'!1!1!5!5gwP[\cPd=eosnt!5!u!)500'27'; G$ F$$ $ k-&@AT;z#:;J v&!!64V1D"EF F%% %4X!67 t[ %>?!4 )>)>{K[?\gk)>)lm{6 23 J GG K #3
#.???B#G #&(2 FV.WZ`bfhxYy'z{ ?O'PQ
)4):):)< R%J *UCJJ4H4H"I%/z0JFL]L]%^ :,c(:D#ehh-'PQR
x(Uv7J7JFNN6\-\#{8/D EF4?@jz@G@ NN3 99GG9DL ))){*
`ak`l mw x$
!
&D 6 ' ' ??8 $ *8 4F8 #/,E 5
! ( 5
5
"-!2!2!4 0 J GZ / 0 7--F % __V, $ G &1%6%6%8
4!
EU3
4 '"9"9~~%"2"2l"B LLTL * V##i !^h As 8 T5< T:c
| j ryt j d| j | j | j
|||d|}|j
|| _ y)u3
Дает доступ из вне
N)r! typetokenext_url ext_login ext_tokenr )pluginr CmfPluginr r r r )r r r r r r s r _init_secretz CmfImportPlugin._init_secret= sX ;; !! gtyytdgg*1YR[g_eg
r r )depthr r r c d | j r| j ||| t | |d|i|S )Nr )r r r r )r r r r r r r r s r r zCmfImportPlugin.saveH s5 ;; gy) <w|T99&99r )forcec t j j dd| j gg d }|j t | |d|i|S )Nr r )r r r r r r )r r r r deleter )r r r r r r s r r zCmfImportPlugin.deleteM sQ !!%%gtTWW-E-[ & ]
w~t;5;F;;r c t )uJ
Формирование шаблона настроек
NotImplementedr rp s r tmplt_import_settingsz%CmfImportPlugin.tmplt_import_settingsS
r c t )u9
Предпросмотр импорта
r r s r previewzCmfImportPlugin.previewY r r c t )u-
Запуск импорта
r r s r process_importz CmfImportPlugin.process_import_ r r c t )uC
Маппинг полей по умолчанию
r r r r calc_models_settingsz$CmfImportPlugin.calc_models_settingse s
r c t )uK
Тестирование подключения к апи
r )r r r s r testzCmfImportPlugin.testl r r c t Nr r s r
download_dataz CmfImportPlugin.download_datar r c t r r r s r download_filesz CmfImportPlugin.download_filesu r r c
ddl m
dd l}dd l}
fd}t | j
| j j d| j j | j }
d }|j dd |d
d }|j | }|j d
d }d|d< d|d< d|d< ||d< d|d< d|d< |j | |j d
d| j j } |j d
}
|
j || j |j d
d } | j | j j d | j j | j |
| j | |j | t | t j r|j d
d | j" j% j j& j d } d | d< | j" j j j | _ | j | |S )!Nr )
BeautifulSoupc @ ddd}d}| |v r|| } d| dd S ) NztM6,2A2,2 0 0,0 4,4V20A2,2 0 0,0 6,22H18A2,2 0 0,0 20,20V8L14,2H6M6,4H13V9H18V20H6V4M8,12V14H16V12H8M8,16V18H13V16H8Za M19,3H14.82C14.4,1.84 13.3,1 12,1C10.7,1 9.6,1.84 9.18,3H5A2,2 0 0,0 3,5V19A2,2 0 0,0 5,21H19A2,2 0 0,0 21,19V5A2,2 0 0,0 19,3M12,3A1,1 0 0,1 13,4A1,1 0 0,1 12,5A1,1 0 0,1 11,4A1,1 0 0,1 12,3M7,7H17V5H19V19H5V5H7V7M7.5,13.5L9,12L11,14L15.5,9.5L17,11L11,17L7.5,13.5Z) CmfDocumentCmfTaska M6.2 12.3a1 1 0 011.4 1.4l-2.1 2a2 2 0 102.7 2.8l4.8-4.8a1 1 0 000-1.4 1 1 0 111.4-1.3 2.9 2.9 0 010 4L9.6 20a3.9 3.9 0 01-5.5-5.5l2-2zm11.6-.6a1 1 0 01-1.4-1.4l2-2a2 2 0 10-2.6-2.8L11 10.3a1 1 0 000 1.4A1 1 0 119.6 13a2.9 2.9 0 010-4L14.4 4a3.9 3.9 0 015.5 5.5l-2 2zz html.parserfeaturesr )
model_name icon_pathpathr s r get_icon_modelz7CmfImportPlugin.create_tag_link..get_icon_model} sg $Z kI aDY& , $k lp kq q@ "A KX Y
Yr r )hreftitleviewModeobjId modelNamer r ainheritr T)contenteditabler
cmf_convertedspanfalse)r z
data-renderedtruezdata-internal-linkzwiki-link-presentationz data-macroszdata-macros-parameterszwiki-link-wrapclasszwiki-card-textz$inline-card-icon-and-title link-view)class_r zpadding-right: 5px;)stylez: zbackground-color: z; color: #fff;z card-status)bs4r jsonrandomra r r! rI r r new_tagdumpsr r r` r r statusloadcolorstring)objr r r link_paramssouplinklink_params_str span_wrapperr icon_span name_span status_spanr s @r create_tag_linkz CmfImportPlugin.create_tag_linkx s % Y WZW]W]WcWcoro}o}~ m4||CVATdh|i **[1|| # $
)0 _%-3 )*&> ]#1@ -. 0 W (W
D! ||F+QY\YaYaYgYg|hLL( 78LL/DLE CHHNN+2chhnn-=>? I I D c6>> * ,,*3::??+<+B+B+H+H+N+N*O~^ ' K $1K !$!1!1!6!6! intrE rN rW ra ro classmethodr r rb anyboolr r r r r r r r r r r r r r r
r
__classcell__)r s @r r r s K )s )s ) )V
C
C
*
c
c
3 34t:L 3 30 &*l$ l$ l$
TN l$ tl$ l$\ !"444 :
#( < 0 0 f 0d4j 0T 0 0r r )typingr r r cmf.includerf r
common.fieldsr common.models.cmf_importr r r r
r r r r r s5 + . . .h0'77 h0r