*jBdZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl Z ddlmZddlmZddlmZdd lmZdd lmZdd lmZmZmZmZmZmZddl Z!ddl"Z!dd l dd l#dd l$m%Z%ddl&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,eGddZ-GddZ.y)uCustom-field генерация и runtime-синхронизация для CmfCustomClass. Модуль вынесен из base_model.py, чтобы базовая модель не содержала тяжёлую логику custom-field import/reload/delta. base_model.py оставляет re-export CmfCustomField и CmfCustomClass для совместимости старых импортов. N) defaultdict)Mapping) timedelta)RLock)deepcopy) dataclass)ProgrammingError)translit)DictListOptionalSetTupleType)*)cmfutil) BaseModel CmfEntity CmfGM2MModel CmfM2MModelDEFAULT_DATASOURCE camel2snakec$eZdZUdZeed<dZeed<dZeed<dZe eed<dZ e ed<dZ eed<dZ eed<dZeed <dZeed <dZeeed <dZeeed <dZeed <dZeed<dZe eed<dZeed<dZe ed<dZe eed<dZeed<dZeed<dZeed<dZeed<dZeed<dZeed<dZ eed<dZ!eed<dZ"eed<dZ#eed<dZ$e eed<dZ%e eed <dZ&e eed!<d"Z'e(ed#<dZ)eed$<e*d)d%e fd&Z+d)d'Z,d(Z-y)*CmfCustomFieldN class_name field_type ui_group_name ui_groupsui_metacaptioncustomfullsearch_indexdb_typedb_column_name db_table_namewidgetmodelmodelsbackrefchoicesdisabled_choicesFdb_need_create_choice_tabledb_choice_table_namedefaultrightleft placeholdercommentTvisiblereadonlyrequiredoptions_list_paramsoptions_list_show_columnsoptions_list_search_columnsrcustom_table_nocf_field_version field_dictcXt|}i}d}i}|jD]a\}}|dk(r3t|tr#|Dcic]}tj ||}}||j vr|||<|dvr|||<|dk(s`|}c|dd|xs|i|} | j|| Scc}w)Nr*)rrrrr#r$r%required_fieldsr)ritems isinstancelistCmfCustomClasscaption_to_name__dataclass_fields___calc_db_choice_table_name) clsr;r'rui_meta_nativekwargskvchoiceress ./cmf/models/cmf_custom_class.py from_dictzCmfCustomField.from_dictLsj) $$& #DAqI~*Q"5RST^33F;VCTTC,,,q UU I~!" #>.3G>v> &&u- UsB'cZ|d}dj|jjdDcgc]}|jc}}|j||}t |dkDr;t j jddt |jz dd |Scc}w) NCh_@u8Имя поля не должно быть больше u символовTabort)joinrsplit capitalizelencmfinclude cmf_alert)selfr'suffixpr-s rMgen_db_choice_table_namez'CmfCustomField.gen_db_choice_table_nameas >F!ww@U@UVY@Z'[1 '[\"'"2"2!34H3I&R # $r ) KK ! !$\]dehiniyiyez]z\{|M#NVZ ! [## (\sB(ct|dd}|sy|dk(s|dk(rRd|_|dk(rdnd}|j|||_|j|_|j|j d<y||j|k(r||_yy)Nr'CUSTOM_CHOICE_MODELCUSTOM_CHOICE_MODEL_EXTTExt)getattrr,rar-r'r)r^r' rel_modelr_s rMrEz)CmfCustomField._calc_db_choice_table_nameksD'40   - ->W1W/3D ,'+DDU$F(,(E(EeV(TD %22DJ$(JJDLL ! $77> >)2D %?N).__name__ __module__ __qualname__rstr__annotations__rrrr rdictr r!boolr"r#r$r r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9intr: classmethodrNrarEr>rhrMrr)sJJM3ItCyGTGSFD!d!GS$(NHSM(#'M8C='FCE3FDIGSGT"&d3i&(-- $#$GSE4D$KGSGTHdHd%)c)+/tCy/-1c1OS c 4($2rhrc*eZdZdZedZeZiZe dZ e dZ dZ dZ edd d d d d dddddddddhe ZedZdZedefdZe dZedefdZdeeeffdZ ddeeeefeeefffd Zed!edefd"Zdeeeffd#Z e d$edefd%Z!e d&edefd'Z"e d$ed(efd)Z#e d$efd*Z$e d!ed&edefd+Z%e d&efd,Z&e d&edefd-Z'ede(fd.Z)ed$ededefd/Z*d$ede(fd0Z+e d!ed&ede(fd1Z,d!ed$ed&edefd2Z-dd!ed3ed4edefd5Z.d!ed3edefd6Z/ed$ededefd7Z0ed!ed&edefd8Z1d$ededefd9Z2edded$ede3efd:Z4 dd$ed&ed;edZ6dddd?d$edd3ed&efdKZ?ddLZ@d3efdMZAd3efdNZBd3edefdOZCedefdPZDedefdQZEedRedefdSZFd3eddfdTZGddUZHd&eddfdVZId3edefdWZJedefdXZKedRedefdYZLd3eddfdZZMed[eNeddfd\ZOedd]ZPd^efd_ZQd`eeefdaeNedefdbZRdceddfddZSdeeddfdfZTdgedheeefdeNefdiZUdje3edkeeefdefdlZVddeeeffdmZWiZXe dnZYe ddoZZee[dpqdrefdsZ\e ddtZ]ee[duqdvZ^dwe_e`fdxZadye3efdzZbd{Zcd|Zdd}Zed~ZfddZgededefdZhedefdZied&efdZjdZkdZle dZmy)rBu6Вся логика кастом полей здесь)minutesc|j5|jj|tcdddS#1swYyxYw)u{Вернуть локальную gevent-блокировку для атомарной правки меты модели.N)_cf_delta_locks_guard_cf_delta_locks setdefaultr)rFrs rM_cf_delta_lock_for_modelz'CmfCustomClass._cf_delta_lock_for_models> & & G&&11*egF G G Gs $;Ac&|y||jz S)uВернуть нижнюю границу DB-фильтра с нахлёстом для пограничных изменений.N)_CF_DELTA_CHANGED_SINCE_OVERLAP)rF changed_sinces rM_cf_delta_filter_changed_sincez-CmfCustomClass._cf_delta_filter_changed_sinces  sBBBBrh)rr r9r'r(r*r+r.r3r4r5r&r1r2r"r6r7r8r/r0r)r-r,)r'r(r*r+r.r3r4r5r&r1r2r"r6r7r8r/r0r)r9r-rrrrr#r$r%r= internal_type ui_meta_skipinstance_classr!class_full_nameui_form_visibler:ct|d|S)uuДостать сырое значение из Eva field wrapper или вернуть объект как есть.value)rf) raw_values rM_valuezCmfCustomClass._valuesy'955rh)namer rr/r0r1r2r.r3field_readonlyr"r5r(r'r*r+r6r7r8r&field_custom_typeallow_multichoicefilter_cur_projectis_ext_datasourcer9cmf_modified_at cmf_deletedreturncddlm}t|dstj |}|j }t |dd}||S||}|tjdd |S||d <|S) u}Собрать метаданные генерации и времени выполнения из строки CmfCustField.r)format_cf_field_versionget_meta) simple_objectrNz?cf-field-version: cannot normalize CmfCustField.cmf_modified_atWARNINGlevelr:) cmf.snapshot_versionrhasattrr( CmfCustFieldrrfgdebug) cust_fieldrmetaraw_cf_field_versionr:s rM_cust_field_metazCmfCustomClass._cust_field_metas Az:.,,:,FJ""$&z3DdK  'K23GH  # GGU]fG gK#3   rhcj|}t|tr.tfdt |j dDSt|t ttfrS|Dcgc]}j|}}t|trtt |tSt|S|Scc}w)uНормализовать значение для стабильного сравнения сигнатур пользовательских полей.c3JK|]\}}|j|fywri)_normalize_cf_value).0keyitemrFs rM z5CmfCustomClass._normalize_cf_value..s-Cc--d34s #ct|dS)Nr)rm)pairs rMz4CmfCustomClass._normalize_cf_value..sDQRG rh)r) rr@rtuplesortedr?rAsetrrepr)rFrr normalizeds` rMrz"CmfCustomClass._normalize_cf_values 5! eW %!' ;T!U  edE3/ 0DIJD#11$7JJJ%%VJD9::$ $ Ks0CcHt|dd}tt|d|S)uПроверить, что строка CmfCustField является удалённой с учётом wrapper-значений.rFr)rfrp)r raw_deleteds rM_is_deleted_cust_fieldz%CmfCustomClass._is_deleted_cust_fields&j-? GK+>??rh field_mapsc ddlm}m}|}|D]5}|jD] }|t |dd}|||kDs|}"7|S)uПосчитать новый снимок меты после точечной обработки строк БД. Базовая версия берётся из уже загруженных классов полей. Для удаления класса в памяти после применения delta уже не будет, поэтому версию удалённой строки нужно учесть здесь до изменения меты в памяти. r)normalize_cf_versionread_cf_versionr:N)rrrvaluesrf)r^rrrsnapshot_version field_map field_data field_versions rM_cf_delta_snapshot_versionz)CmfCustomClass._cf_delta_snapshot_versionsi O*,# 5I'..0 5 4WZI[]a5b c  ,AQ1Q'4$ 5 5  rhNci}i}dd|jjgg}t|j|}||j dd|gt j j|t|jddD]b}tj|j||j}|j|r|||j<T|||j<d||fS)uЗагрузить из БД строки пользовательских полей для точечной перезагрузки. При обычной догрузке читаем только строки новее снимка меты. Полный список нужен только при отсутствии снимка, когда безопаснее сверить всё состояние модели. cmf_model_name==r>T)filterfieldsinclude_deletedTECHCOM_nocacher') model_clsrtyper~appendr(rslistrA_CF_DELTA_DB_FIELDSrrNrr)r^r} active_fieldsdeleted_fields field_filterfilter_changed_sincerrs rM_load_db_custom_fieldsz%CmfCustomClass._load_db_custom_fieldss )41J1JKL #DzHHW  +   !2C9M N O --33#D445 $ $ 4& BJ (11$2G2G 2S[_[i[i1jJ**:68Bz4457A j334 Bn,,rh field_namec|jdsy|dd}|jj|}t|xrt |t S)uNОпределить FK-компаньон relation-поля вида cf_x_id._idFN)endswithrgetrp issubclassCmfRelationBase)rr primary_name primary_fields rM_is_relation_companionz%CmfCustomClass._is_relation_companion sM""5)!#2 !((,,\: MPj&PQQrhc|jjjDcic]5\}}|jdr|j |j|s||7c}}Scc}}w)usВернуть только основные пользовательские поля текущей меты в памяти. FK-компаньоны вида ``cf_x_id`` не считаются самостоятельными полями: они создаются и удаляются вместе с основным relation-полем. cf_)rrr? startswithr)r^r field_clss rM_runtime_primary_cf_mapz&CmfCustomClass._runtime_primary_cf_mapsb*.)>)>)D)D)F % I$$U+// K  !   s:A&rc|jxsijDcic]\}}||jvr||c}}Scc}}w)uВыделить пользовательскую часть UI-меты для сравнения с классом в памяти.)rr?_UI_META_SIGNATURE_SKIP)rFrrrs rM_ui_meta_signature_from_dataz+CmfCustomClass._ui_meta_signature_from_data"sN *117R>>@ U#555 J   sArcft|dixsi}|j|}|rttj|dnd}t|dixsi}i}|j D]I\}}||j vr|dk7r+||vr'|j ||j ||k(rE|||<K|S)uВыделить из класса в памяти только пользовательские отличия UI-меты. Метакласс поля добавляет дефолтные значения базового типа. Их нельзя считать изменением пользовательского поля, иначе delta будет видеть ложные обновления только из-за метаданных. rNr)rf_field_type_namer[rr?rr) rFr field_metafield_type_namebase_cls base_metaresultrrs rM_ui_meta_signature_from_classz,CmfCustomClass._ui_meta_signature_from_class+sY 26<" ..y9AP73::=VZHi4: $**, JCc111|#y(//6#:Q:QR[\_R`:aaF3K  rhattrc|dk(rt|ddryt||d}|X||jxsivrFt|dd}|rttj|dnd}|t ||r t||S|S)uДостать атрибут сигнатуры из строки БД с учётом дефолтов базового типа поля.r,r-NTr)rfrr[rr)rFrrrrrs rM_signature_attr_from_dataz(CmfCustomClass._signature_attr_from_dataBs 0 0WZI_ae5f D$/ =T**<*<*BC%j,EOETwszz?DAZ^H#$(?x.. rhc|jDcic]}||j||}}|j||d<|j|Scc}w)uСобрать сигнатуру строки БД для проверки изменений только в метаданных.r)_CF_SIGNATURE_ATTRSrrr)rFrrsignature_datas rM!_custom_field_signature_from_dataz0CmfCustomClass._custom_field_signature_from_dataOsf //  #// DA A  %($D$DZ$Py!&&~66  sAc(t|dd}t|dd}|r|s t|ddSt|ttfrdnd} t |j ||}||k(r|St|ddS#t $rt|ddcYSwxYw)uОпределить generated-модель пользовательского справочника по runtime-классу поля.rNr'r-rerr_)rfr CmfM2MExtCmfRelationExtrra Exception)rFrr owner_model model_namer_expected_model_names rM_choice_model_name_from_classz,CmfCustomClass._choice_model_name_from_classYsi)94@ Y6 *9&[]a+bY6Ivt4y)T:$8+/$` ;XZ_(`,88C5 8&&~66rhch|j|xs t|dt|jS)u~Вернуть системный тип поля для сообщений и сравнения формы хранения.r)rrfrrj)rFrs rM_field_kind_from_classz%CmfCustomClass._field_kind_from_classs0##I.l')\SWXaSbSkSk2llrhc|t|ddrt|jSt|ddr |jfSy)uzВернуть модели-цели поля-связи из CmfCustomField или класса в памяти поля.r(Nr'r>)rfrr(r')rs rM_relation_targetsz CmfCustomClass._relation_targetss? :x .**+ + :w -$$& &rhct|trht|ddr3t|dd}t|dd}|r|sy||jS|j|jjSt|t rjt|dd}|syt|ddr t j |j|St|ddr t j ||jSy)u_Посчитать имя runtime-модели связи M2M по данным CmfCustomField.r/Nr'r)r0)r CmfGenericM2MrfrYrCmfM2M_m2m_model_cls_name)rrrrr)s rM_m2m_model_cls_name_from_dataz,CmfCustomClass._m2m_model_cls_name_from_datas j- 0z7D1$Z$? !*i>!$g&8&8&:%;<<**+J,A,A,L,L,N+OP P j& ) Wd;Jz64011)2F2F SSz7D111*i>R>RSSrhcNttj|j}|jxsd}t |t r|j||}|j|dt|ddt|ddt|ddtt|ddxsdt|d d|t||j|j||f St |tr"|jd f}|j|}n|jf}d}|j|||fS) u`Описать физическую форму хранения поля по строке БД.rm2mr0Nr/r'r(r>r)r)rfr[rrr9r CmfM2MBase#_custom_choice_model_name_from_datarrprrrrr)r^rrr9choice_model_nameruntime_columnsrelation_targetss rM_storage_shape_from_dataz'CmfCustomClass._storage_shape_from_datas$SZZ)>)>? $449 j* - $ H HU_ ` %% FD1 GT2 GT2gj(D9?R@ It4!&'224>>:zZ   j/ 2","7"7!8<>O#55jA )446O! %%IYZZrhc |j|}t|ddxsd}t|tr||j }|j ||}||dt|ddt|ddt|ddt t|ddxsd t|d d|t||f St|tr|d f}|j|}n|f}d }||||fS) uyОписать физическую форму хранения уже загруженного поля в памяти.r9rrr0Nr/r'r(r>r)r) rrfrr m2m_model_cls_namerrrprr) rFrrrr9m2m_model_namer r r s rM_storage_shape_from_classz(CmfCustomClass._storage_shape_from_classs..y9!)->BGa i ,&99;N # A A*i X  640 7D1 7D1gi48>B? 9d3!&'   i 1",S13O"44Y? )mO! /CSTTrhcj|j||}|j|}||k(ryd|d|d|S)uПроверить, не меняет ли обновление физическое хранение поля. Точечный путь безопасен только для изменений метаданных. Если меняется тип колонки, ext-таблица, направление M2M или таблица связи, уходим на полный путь генерации/DDL. rQz*unsupported_cf_delta:update_storage_shape::z->)rr)r^rrr old_shape new_shapes rM_storage_shape_update_reasonz+CmfCustomClass._storage_shape_update_reasonsM22:yI 11*=  !;Jwz640GJX^`dDe6@ GT2gjZacgFh j- 0K-2..KOJZLPPBPPI j& )#-J< 52 5 rhactionrcB |xs$ttj|j}t|ddxs|j |}t|ddxs t|dd}|j ||}|duxr|j|||j} |r|dk(r*|(|j|||js dd|d|d fS|j||} | r|j|| r|| d fvr dd|d|d fSt|d d} t|d d} | r| r dd|d|d|fSy | r,t|d d} t|d d} | r| r dd|d|d|fSy t|ddr dd|d|d fSt|ddr dd|d|d fS|dvr dd|d|d fS|dk(r/|-t|tr|j||r dd|d|d fS|dk(r/|-t|tr|j||r dd|d|d fSt|tr dd|d|d|fSt|t r dd|d|d|fSt|tr|r t|d dn t|d d} |r t|d dn t|d d} | s| s dd|d|d|fS|j#||} | Dcgc]}tt$|dr|}}| r|r dd|d|d|fSy t|t&r!|rtt$|ds dd|d|d|fSy t|t(rPt|ddxst|ddxsg} | Dcgc]}tt$|dr|}}|r dd|d|d|fSy #t$rt|dd}dd|d|d|fcYSwxYwcc}wcc}w)uПроверить, поддерживает ли точечный путь add/update/delete для конкретного поля.runknownFzunsupported_cf_delta:rNr'deletez:custom_choicercr0r/TrQr-r,)rcrdr()rfr[rrrrrrrr rrrrr rCmfBackrefBaser#r( CmfRelationCmfGenericRelation)r^rrr$rrkindrcustom_choice_m2m_datacustom_choice_m2m_classr r0r/r"rel_model_namemissings rM_delta_support_statusz$CmfCustomClass._delta_support_statusEs I"Pgcjj*:O:O&PJ z<6a$:U:UV`:aZ$7]7:wX\;] !%!@!@Z!X $  S00z4>>R  "("!- <:88zJ1&4&OO O h &z:644T:F1&4&OO O j) ,1&4&$HH H j. 11&4&$HH H j* -8B7:vt4PZ\bdhHiD:DGJ6'R\^egkJlEE 5fXQtfAdVLLL77 JOK>  '+~~'@'@&A9CWCWBX$Y ! Ir!B!HbI 4d;;TBrhrbaseextrar7r8c |xs |j}|xs$ttj|j}|j j |j jd||jd|jxsdd}|jxsijD]\}} |dvr | ||<|jD]} t|| d} | | || <|r|j|t||f|} |j| | S)uoСоздать runtime-класс пользовательского поля из строки CmfCustomField.r3Tr)rkrlr r!r9)rrrr#r$r%N)rrfr[rrrrkrlr r9rr?_RUNTIME_FIELD_ATTRSupdaterr5) r^rrr7r8 runtime_namer namespacerrrrs rM_make_runtime_field_classz(CmfCustomClass._make_runtime_field_classs4z44 E73::z/D/DE..33#~~::;1\NK!)))99>Q  &--3::< #JCkk"IcN #-- (DJd3E "' $ (    U #{I>  ,,Y7rh rel_field_clsc *t|trM|jdt|jd|j |j ddt|ddd}nzt|tri|jd|jxsgDcgc]}t|dc}|j |j d|jt|ddd}ny t|d drd|d <|j||jd t| Scc}w) uoСоздать скрытое FK-поле cf_x_id для relation-поля, если оно требуется.z ID.idFTr9r)r foreign_keynullableuniquer3indexr9)r foreign_keysrCrDr3rEr9Nno_aclrr6)rr*r rr'rCrDrfr+r(rEr>rCmfTUUID)r^rr?r8rs rM_make_relation_id_field_classz,CmfCustomClass._make_relation_id_field_classs( m[ 1+334C8"-m.A.A"B!C3G)22'.. #*=:KQ#OE '9 :+334C8TaThThTnln pZK $;#rrI)r^rrr8r rruntime_fields id_field_clss rM _runtime_fields_for_custom_fieldz/CmfCustomClass._runtime_fields_for_custom_fieldsSZZ)>)>?   * *:z B $ H HU_ `  .,=22:U2K $//;99*iP  #6BN<22 3rhctgfd}tjdD] }|| ||jS)uПолучить снимок загруженных моделей для проверки общих runtime-моделей. M2M/choice модель в памяти может использоваться полями других загруженных моделей. Если просмотр моделей падает, ошибка уходит в общий fallback точечной перезагрузки на полный reload. cp|yt|}|vryj|j|yri)idaddr)rmarker loaded_modelsseens rM append_oncezACmfCustomClass._loaded_delta_models_snapshot..append_onces9  ]F~ HHV    +rhc.tt|ddS)Nr)rprfrs rMrz>CmfCustomClass._loaded_delta_models_snapshot..sd75RZ\`Ca>brh)rr iter_modelsr)r^rU loaded_modelrSrTs @@rM_loaded_delta_models_snapshotz,CmfCustomClass._loaded_delta_models_snapshotsOu  ,$//0bc &L  % & DNN#rhc#@K|jEd{y7w)u\Итерировать модели из снимка загруженных моделей.N)rY)r^s rM_iter_loaded_delta_modelsz(CmfCustomClass._iter_loaded_delta_models s55777s c#K||j}|D]Q}t|ddxsijD]-}t|ts|j |k7r(||f/Syw)uНайти загруженные M2M/GM2M поля, использующие указанную runtime-модель связи.Nr)r[rfrrr rr^rrSrXrs rM_iter_m2m_fields_for_model_namez.CmfCustomClass._iter_m2m_fields_for_model_names{   ::rrR loaded_fieldrs rMrz:CmfCustomClass._generic_m2m_model_lists..#RL<9,RrNr0r(r/r') rAr^anyrrfrrrrr;rQr) r^rr loaded_fields left_models right_models _loaded_modelrb left_models ` rM_generic_m2m_model_listsz'CmfCustomClass._generic_m2m_model_listssTAA*MN RMRR  ')5Et"L"^PTP^P^`i!j ke u +8 0 'M<lM:|VT2##GL(D$I$ORPw5$\7DA OOJ/ 0k"F<$888rhcFt|j|}tfd|Ds,|jt ddxs |j f|D]p\}}t |trt |tr't |dd}t |dd}t |ddr |r|r||fcSt |ddsf|si|sl||fcSt t ddddxs|j j}t dd}t ddr||fS||fS)uОпределить левую и правую модели общей таблицы связи в памяти обычного M2M.c3,K|] \}}|u ywrir>ras rMrz;CmfCustomClass._ordinary_m2m_model_sides..7rcrdrNrr'r0r/) rAr^rerrfrrrrr)r^rrrfrXrbowner_model_namerelated_model_names ` rM_ordinary_m2m_model_sidesz(CmfCustomClass._ordinary_m2m_model_sides4s6TAA*MN RMRR  ')5Et"L"^PTP^P^`i!j k*7 < &L,lF3z,P]7^&|\4H !(w!E |VT27GL^');;;|Wd38HM_)+;;; <#796F#M|]abfjftftff$Y> 9gt ,%'77 7!333rhc"t|jdd}t|trt}|j ||\}}dd|d|jj |ttd|ttdddttd |ttd ddttd d ttd d d }nt}|j||\}} dd|d|jj |ttd|ttdt|dddttd| ttdt| dddttdd ttdd d }t||f|S)ujСоздать runtime-класс таблицы связи для обычного M2M или GenericM2M. data_sourcesNFTu Объект)r r(uID Объекта)r rCrEuЭлементuID ЭлементаИмя объекта)r rCuИмя элемента) abstractr!rr_cf_delta_runtimerkrlr0left_idr/right_idleft_name_cacheright_name_cacheuЛевый Объект)r r'uID Левого ОбъектаrA)r rBrCrEuПравый Объектu ID Правого Объектаu"Имя левого объектаu$Имя правого объекта)rfrrrrrkrkFieldr+rH CmfStr256rrpr*rr) r^rrrrrrgrhr=left_model_nameright_model_names rM_make_runtime_m2m_model_classz,CmfCustomClass._make_runtime_m2m_model_classJst~~~tD i /#H(,(E(EjR[(\ %K! ,%)"nn77 *0.Q\] 3FQU]ab1;KT`a!(4ITX`de#(#./?#@"A E! $)<`ko#p$))=cnr$s1I4J Y77rhc|jj}t|dd}|t|dd}|r|dnt}ddlm}|||}|j |_||i|_y)uПривязать модель в памяти к текущему data_driver без нового подключения к БД. data_sourceNrrr) DataProvider)rr') rdprfrcmf.data_providers.baser data_driver_dd__dp__)r^ runtime_model data_providerrrrrruntime_providers rM!_bind_runtime_model_data_providerz0CmfCustomClass._bind_runtime_model_data_provider}sn)) m]DA  "=.$GL-9,q/?QK8'K}U,88 +-=> rhct|jdd}ddd|d|jj|ttddddddtt ddd tt d dddd ttdddddd ttddddttddddd ttddddd}t|tf|S)u\Создать runtime-класс generated-справочника для custom-choice M2M.rrNFTu)Идентификатор объектаu3Автоматически генерируется)r r2rC primary_keyr4r3rsalways)r rE load_modeuСортировкаr)r rEr3rCr.uКодu3Код в реальном мире из жизни)r rDr2r4rCru:Код родителя в каскадном выборе)r r4rCrEu Скрытьu!Конфигурация поля)rt api_allowr!rrrurkrlrPrordernocodechoice_parent_id cmf_hiddencust_field_conf_id) rfrrkrzrHr{CmfIntCmfStr64CmfBoolrr)r^rrrr=s rM _make_runtime_choice_model_classz/CmfCustomClass._make_runtime_choice_model_classst~~~tD (!%..33&CM )-DD\de.  M"!&T ! & #(; #e9 tJ i88rhctt|d}|duxs t|dd}|r"|j|}tt||ttj|||j ||j jj}|jj|d|j|jjvrDt|ddr7|j|j}|j||j |j!||S#t"$rt$j'd|dwxYw)uЗарегистрировать runtime-модель пользовательского справочника в models и SA-метаданных.NruFenginez4cf-delta: failed to prepare runtime choice SA model EXCEPTIONr)rfr(rsetattrr[rrrrmodels_registryr4 tablenamedb_metatables_reflect_sa_table!_copy_reflected_table_to_metadatadp_modelrrr)r^rrrebuild_runtime_modelrreflected_tables rM_register_runtime_choice_modelz-CmfCustomClass._register_runtime_choice_models6 D9 T ! B}&95A  ! AA*MM FJ 6 J 6 ..}=nn''33 ##'' D9  " "+*=*=*D*D DQ\^fhlIm"44]5L5LMO  2 2?KDWDW X    /  GGJ:,W_jG k  s D++%Ec|j}|D]P}t|ddxsijD],}t|tt fst|dd|k(s+yRy)u|Проверить, используется ли справочник другими загруженными полями.rNr'TF)rYrfrrr rr]s rM_choice_model_still_usedz'CmfCustomClass._choice_model_still_usedsp::< ) L%lHdCIrQQS !)j/-JK9gt4 B   rhct|tsyt|tsyt |ddxsi}hdt |kS)uПроверить, похож ли класс на generated-модель пользовательского справочника.FrN>rPrrrrrr)r@rrrrfrrrs rM _is_generated_choice_model_classz/CmfCustomClass._is_generated_choice_model_classsC-.-3$7=2hlopvlwwwrhcrt|dd}|dk(xs$|jdxs|jdS)uПроверить, что generated-модель справочника пришла из разрешённого autogen/custom модуля.rkrQ custom_modelscustom.ztmp.__autogen_modelsrfr)r module_names rM&_generated_choice_model_module_allowedz5CmfCustomClass._generated_choice_model_module_allowedsFm\2> ? * >%%i0 >%%&<= rhrnc@|syt|ddj|S)uПроверить, что generated-модель справочника относится к текущей модели-владельцу.TrrQr)rrns rM_choice_model_references_ownerz-CmfCustomClass._choice_model_references_owners% }lB7BBCSTTrhctt|d}|yt|ddxsL|j|xr9|j|xr&|j ||j j }|sy|j jj}|jj|dt|}||jjvr2|jj|jj|tt|d|urtt|tt j|d|urtt j|yy)uУдалить модель пользовательского справочника из памяти. Удаляем только модели, созданные точечным путём или похожие на сгенерированные модели текущей модели-владельца. Ручные пользовательские модели и модели других владельцев не трогаем. NruF)rfr(rrrrrrrrr4rrrremovedelattrr[r^rrcan_unregisterr table_names rM _unregister_runtime_choice_modelz/CmfCustomClass._unregister_runtime_choice_models.   D9   M#6 > 55mDb?? Nb77 t~~G`G`a  nn''33 ##'' D9 , ,,33 3    & &{':':'A'A*'M N 6:t , = FJ ' 3::z4 0M A CJJ + Brhc|jjj}|j}i}t |ddxsij D]N}t |dd}|s|j ddd}||jvs||vr;|j|||<P|jD]\}} |j| |y)ucОтразить FK-таблицы, нужные SQLAlchemy для runtime-модели связи.rNrBr3rtr) rrrrrfrrXrrr?r) r^rrrreflected_tablesr fk_target target_tablerrs rM%_prepare_runtime_m2m_fk_target_tablesz4CmfCustomClass._prepare_runtime_m2m_fk_target_tables#snn''33 %%!-4@FBNNP RI =$?I$??3215Lw~~-AQ1Q-1-C-CL-Q \ * R,<+A+A+C M 'J  2 2?G L Mrhc@|j}tt|d}|duxst|ddxst|t}|r#|j ||}t t||t tj|||j||j||jjj}|jj|d |j|y#t $rt"j%d|dwxYw)ujЗарегистрировать runtime-модель M2M/GenericM2M в models и SA-метаданных.NruFz1cf-delta: failed to prepare runtime M2M SA model rr)rrfr(rrr~rr[rrrrrrr4rrrr)r^rrrrrs rM_register_runtime_m2m_modelz*CmfCustomClass._register_runtime_m2m_model3s113  D9 T ! 4}&95A 4)]3  ! >>z9UM FJ 6 J 6 ..}= 22=Ann''33 ##'' D9    /  GGG |T\gG h  s &C88%Dcf|j}td|j||DS)uПроверить, используется ли runtime-модель связи другими загруженными M2M-полями.c3&K|] \}}d yw)TNr>)rri _field_clss rMrz7CmfCustomClass._m2m_model_still_used..Msy5M:4ys)rYrer^)r^rrSs rM_m2m_model_still_usedz$CmfCustomClass._m2m_model_still_usedJs0::< y9]9]^hjw9xyyyrhct|tsyt|ttfsyt |ddryt |ddxsi}hdt |kS)unПроверить, похож ли класс на generated-модель таблицы связи M2M/GM2M.FrtrN>r0r/rvrwrxry)r@rrrrrfrrs rM_is_generated_m2m_model_classz,CmfCustomClass._is_generated_m2m_model_classOsW-.-+|)DE =*e 4$7=2^beflbmmmrhc|syt|ddj|ryt|ddxsi}dD]:}|j|}t|dd|k(ry|t|ddxsd vs:yy ) uПроверить, что runtime-модель связи относится к текущей модели-владельцу.TrrQrN)r0r/r'r(r>F)rfrr)rrnr side_name side_fields rM_m2m_model_references_ownerz*CmfCustomClass._m2m_model_references_owner[s  =, 3 > >?O P$7=2* II.Jz7D15EEGJ$$G$M2N   rhctt|d}|yt|ddxs9|j|xr&|j||jj }|sy|jj j}|jj|dt|}||jjvr2|jj|jj|tt|d|urtt|ttj|d|urttj|yy)uУдалить M2M-модель из памяти и SA-меты. Удаляем только модели, созданные точечным путём или сгенерированные модели, которые явно ссылаются на текущую модель-владельца. Это защищает чужие общие модели. NruF)rfr(rrrrrrrr4rrrrrr[rs rM_unregister_runtime_m2m_modelz,CmfCustomClass._unregister_runtime_m2m_modelks   D9   M#6 > 22=A_44]DNND]D]^  nn''33 ##'' D9 , ,,33 3    & &{':':'A'A*'M N 6:t , = FJ ' 3::z4 0M A CJJ + Brh column_namesct|D]N}||jjvr |jj|jj|Py#t$ry|jjj |d|jj Dcgc]}|j|k7r|ncc}wc}|jj ddYwxYw)uУдалить устаревшие cf-колонки только из метаданных SQLAlchemy в памяти. В используемой версии SQLAlchemy штатное удаление может не синхронизировать оба внутренних контейнера ColumnCollection, поэтому резервная ветка чистит их явно. N)rA_columns_datarrr4 _all_columnsr)sa_tabler column_namecolumns rM_remove_sa_columnsz!CmfCustomClass._remove_sa_columnss - K("3"3"9"99 !!(():):)@)@)MN   !!''++K>)1):):)G)G5%{{k155!!..q1 s2AAC %B>= C C c|y|j|ury|j|jvr(|j|j|jt |ddxs t |d}||y)uСкопировать отражённую таблицу в рабочую SQLAlchemy metadata при необходимости.N to_metadata tometadata)metadatarrrrf)rtarget_metadata copy_methods rMrz0CmfCustomClass._copy_reflected_table_to_metadatast  "   # # 6    ?#9#9 9  " "?#9#9/:N:N#O Po}dCmw`lGm O$rhrc|jjj}t|ddsyddl}|j }|j ||d|jddS)uVОтразить таблицу из БД во временную SQLAlchemy metadata.rNrTF)autoload autoload_withextend_existing resolve_fks)rrrrf sqlalchemyMetaDataTabler)r^rrr scratch_metas rMrz CmfCustomClass._reflect_sa_tablesfnn''33 {Hd3*z**, z  %,,    rhrKremoved_runtime_namesc|jjj}|j}|jj |jj }ggit|d}|jD]S\}}t|trg} t|ddr| j|j| jt|ddxsgt|ddxsd} | dkDrB|jj d| d} |jj | } | } | |j| } | |d | <nA|| j j"vr)t|t$r|j| } | |d | <| ^|| j j"vrFt|t$s6|j'|j|d}||d j| ||f| D]E}|j)d d d}||jvs'||d vs/|j||d |<G|j'|j||}|0|.||j j"vr|d j||f| D]E}|j)d d d}||jvs'||d vs/|j||d |<GV|S)uПодготовить план изменений метаданных SQLAlchemy без мутаций модели. План строится до блокировки и до изменения меты в памяти. Если выяснится, что нужен полный путь или состояние поменял другой поток, мы не оставим частично изменённые SA-таблицы в памяти. )main_columns_to_addext_columns_to_addrrrBNrFr9r_ext02drrr3rtr)rrrrrrrrr?rr rfrrBextendrrrr_make_sa_columnrX)r^rKrrrrplanr<r fk_targetsr9ext_table_name ext_tablemetadata_ext_table sa_columnrrs rM_prepare_sa_deltaz CmfCustomClass._prepare_sa_deltasnn''33 %%>>%%dnn&>&>?#%"$ "%()>%?   (6';';'=& b #L))Z0Jy-6!!)"7"78   giFL" M%i1BAFK!O"$(NN$<$<#=T/RUAV!W#NN..~> %."$)-)?)?)O&?QD+,^<!););)A)AAjQZ\kFl)-)?)?)O&?QD+,^<&2(0B0K0K0Q0QQ *9o F + ; ;DNNIW[ \I ,1299>>9lRVWiRj>jAEAWAWXdAe/0>f#33DNNI|\I$)=,V^VgVgVmVmBm*+22L)3LM' b (sA6q9 w~~5,dSeNf:f=A=S=ST`=aD+,\: bG& bN rh sa_delta_planc|jjj}|j}|jj |jj }|j dxs t}||r|j||t|jjD]C\}}|j|jj ds/|s2|j||E|j dijD]\}}|j|||j dgD]N\}} } |jj |} | %| | jjvs>| j| P|jj |jj }|E|j dgD]/\} } | |jjvs|j| 1yy)uПрименить подготовленный план SA-метаданных после проверки гонки под блокировкой.rNrrrr)rrrrrrrrrrAr?rrrr append_column) r^rrr main_tablerrrrr<rrs rM_apply_sa_delta_planz#CmfCustomClass._apply_sa_delta_plansnn''33 %%^^''(@(@A - 1 12I J Sce  !&;  # #J0E F$()=)=)?$@ I J$$(@(@'A%FGLa''2GH I,9+<+<=OQS+T+Z+Z+\ M 'J  2 2?G L M3@3D3DEY[]3^ 3 /J i**:6I$Y=O=O=U=U)U'' 2 3^^''(@(@A  !+8+<+<=RTV+W 8' iz':':'@'@@,,Y7 8 "rhrc|jjD]R}t|dd}|stjj |dtj j |dT|jjj}|jj |d|jjy)uИнвалидировать кеши метаданных/запросов после атомарного cf-delta изменения.rN) r__mro__rfAPPall_models_metar4cache_cust_field_config_schemerrrcached_queriesclear)r^rc parent_namers rM_invalidate_caches_for_modelz+CmfCustomClass._invalidate_caches_for_models'' JA!!\48K##'' T:2266{DI  J nn''33 ##'' D9""((*rhr runtime_mapc|h}|j|}|r&t|tr|j|d|S|d|jj vr3|j |j|dr|j|d|S)uВернуть имена runtime-полей, которые нужно удалить вместе с основным полем.r)rrrrQrrr)r^rr runtime_names old_field_clss rM_old_runtime_names_for_primaryz-CmfCustomClass._old_runtime_names_for_primarys% # 5 Z G   c2 3~S !T^^%:%: :t?Z?Z[_[i[inzm{{~k@A   c2 3rh old_fields new_fieldscpt|t|jz}td|DS)u~Понять, затрагивает ли delta relation/M2M поля и требует ли пересчёта RelationCache.c3DK|]}|xrt|tywri)r CmfRelBase)rrs rMrz9CmfCustomClass._relation_cache_touched..s'   ;*Y ; ; s )rArre)r^r r touched_fieldss rM_relation_cache_touchedz&CmfCustomClass._relation_cache_toucheds9j)D1B1B1D,EE +   rhc tjd|jjdt j d|jj} |t j}|j|\}}|j||}|j}t|t|z }|t|t|z }nt|t|z}t|t|zD chc]-} |j|| |j|| k7r| /} } t|D]>} |j|| d| \} } | r tjd | d d | fcSt| D]y} |j|| d | \} } | s tjd | d d | fcS|j!| || || } | s[tjd | d d | fcSt|D]N} |j|j#| || d | \} } | r0tjd | d d | fcS|s'|s%| s#|t _tjddyi} i}t|| zD],} |j%|| }||| <| j'|.|j)D cic]\} }t+|| t,r| ||  }} }t}t}g}t}t}t|D]} |j/| |}|j'||j'||j#| }|j1||s\t+|t,sm|j3|j5|j7| ||js|j9| |}|s|j3|t| D]C} |j'|j/| ||j1|j#| E|j;| |}|j)D cic]\} }| |j|}} }t=|j?|}|5|j}|j)D cic]\} }| |j|}} }||k7r,d|} tjd | d d | fcdddS|D]^}|jj@jC|d|jjDjGdijC|d`|jID]o}|j)D]Z\}}||jj@|<tK|jD|jjDjGdi|<\qt|D]%} |jM| r|jO| 't|D]%}|jQ|r|jS|'|jID]i}|j7|j||jr/|j9|j|}|r|jU||jW|k|jY||j[||jj@jIDchc] }t]|}!}|j_|| }" |"rt`jbjen t`jbjg||!|t _dddtjdtm|dtm| dtm|dycc} wcc}} wcc}} wcc}} wcc}w#th$rI}#dt=|#jj} tjd| dd | fcYd}#~#cdddSd}#~#wwxYw#1swYxYw#th$r;}#tjddd dt=|#jjfcYd}#~#Sd}#~#wwxYw)ueТочечный путь reload_model(delta_only=True), основанный на данных БД.zcf-delta: called for z pid=INFOrNr}rQ)r$rzcf-delta: fall back reason=rFr;r'z5cf-delta: success added=0 changed=0 removed=0 (no-op)r(zcf_delta_race:rzrelation_cache_failed:z cf-delta: rzcf-delta: success added=z changed=z removed=z.cf-delta: DB-backed delta exception, fall backzdb_delta_failed:)7rrrrosgetpidrrrrrrrrrr1rrrMr;r?rr rrrQrrrrrrzrr4rryrrorrrrrrrrrPrr( RelationCachebuild_fields_cachedrop_stale_for_modelrrjrZ)$r^r}ractive_db_fieldsdeleted_db_fieldsrr added_names removed_namesr changed_names supportedreasonnew_runtime_fieldsruntime_fields_by_primaryrKnew_m2m_fieldsruntime_removed_namessa_removed_runtime_namesold_touched_fieldsm2m_model_names_to_unregister choice_model_names_to_unregisterold_runtime_namesrr rrplanned_prestatelockcurrent_runtime_mapcurrent_prestater<r valid_idsrelation_cache_touchedes$ rM_apply_cf_field_deltaz$CmfCustomClass._apply_cf_field_delta$s  '(A(A'B% }U]cd^^.. V @$ # 4 4 262M2M\i2M2j / /#>>?OQbc 668K./#k2BBK$ #K 037G3H H !$$5 6[9I I -01A-BSEU-U)99:J::VW::;z;RSTM %[1 ) $($>$>$Z0Z%?%Q! 6 GG9&B)GT &=(  ) %]3 ) $($>$>$Z0 %?%T! 6 GG9&B)GT &=(:: 0 UWGG9&B)GT &=( )%]3 ) $($>$>%))*5{:7NW_fp%?%r! 6 GG9&B)GT &=(  )}]'7$OW]^!# (* %$[=%@A : !%!F!FGWXbGc!d8F)*5")).9 :3L2Q2Q2S.JnZ8*EN:66N %(E !'*u $!# ,/E )/2u ,$]3 T $($G$G T_$`!%,,->?(//0AB + ; "))-8 Z z%J155m6V6V6XY77 MSWSaSab,0,N,Nz[h,i),<@@ARS T%]3 G %,,T-P-PQ[]h-ij"))+//**EF G!223EG_`M.9->->-@ )J DCCINN    :66zBD3 8&*&B&B&D#2E1J1J1L$- I G G RR$ $$'77-j\:FGG9&B)GT &=3 83 8%:\LNN))--lDANN**55hCGG VZ[\'@&F&F&HpN3A3G3G3Ip/ i>G--l;X\]f]n]nXo..99(BG Upp #))F"GGJ55jA:::FG*00P)QQ%889JK==>OPQ"0!6!6!8@I77 8L8LiY]YgYgh,0,N,NyOcOcen,o), ??@QR44Y? @))-811*=<@NN?? ? @sB*a:2_=7,a:$a:A a:a:+a: ;a:a:')a:Aa:%#`Ba:a:-0b93b>9b>c| td|jj|}|||}||j|<|S)uВернуть кешированный CmfCustomClass для модели или создать новый экземпляр.uCmfCustomClass.get_or_create: model_cls is None (вероятно cmf_model_name не найден через get_model_by_name)r) ValueError_instances_by_modelr)rFrinstances rM get_or_createzCmfCustomClass.get_or_createsZ  c **..y9  Y/H19C # #I .rhc t|jtjj d||}t d|y)u Полная синхронизация кастом полей модели в кластере после изменения их настроек - event CmfCustomClass:custom_field_sync -> custom_fields_gen_meta() - custom_fields_gen_meta() - per host lock and read custom field config - check_meta_version - save_changes() - patch db fixme !!! commit/rollback - save custom/modules/fields/MODEL_NAME.py - apply_changes() - do autogen - event CmfCustomClass:reload_model -> reload_model_handler() - reload_model_handler() - load and patch custom model - cler APP caches - !!! CMF_CACHE.flush_db() fixme !!! per process, drop locks... - models.RelationCache.build_fields_cache() fixme !!! per process z %Y%m%d%H%M%S)r meta_versionforcer CmfCustomClass:custom_field_syncN)rordatetimenowstrftimecmf_emit_server_event)rFrr8r_kwargsdatas rMcustom_field_syncz CmfCustomClass.custom_field_syncs>, ++!00@_np @$Grhr9)channelr?c ^ddlm}ddl}tjt j dz dz }|j}tjd|d|jjd|dd d }|5tjd |jr5|j|d k(rtjd  dddy|j|d t}t!t"|d}t%|} dd|j&gg} |ds;| j)ddd| j*D cgc]} | j&c} ggdgt"j,j/| gddD]h} | j0s-t$j3| || j4j6<nd| _| j:sPd| _| j=dj|s | j8rg} |j?D](}| j)t@jC||*tjd| | jE| tjd|jjdd d 5tjd | jGdddtjd!| jIdddtjd"ycc} w#1swYQxYw#1swY0xYw)#uМетод обновляет файлы с метой на всем кластере Args: data (dict): _description_ r)REDIS_DBNtmpcustom_meta_versionuJcustom_fields_gen_meta берем блокировку per instance lock::z)::cmf__base_model__custom_fields_gen_metazlock::i)timeoutblocking_timeoutu<custom_fields_gen_meta Блокировка полученаr7z-CmfCustomClass:custom_field_sync: already genrr1rrr8ORrzNOT IN)dirtyrT)rparent cmf_ownerT)rrrF) only_datarz(custom_fields_gen_meta run merge_fields uucustom_fields_gen_meta берем блокировку global lock::cmf__base_model__custom_fields_gen_meta_run_alterz7lock::cmf__base_model__custom_fields_gen_meta_run_alteruNcustom_fields_gen_meta блокировка получена. run save_changesz$custom_fields_gen_meta apply_changeszcustom_fields_gen_meta done)%cmf.apprCsocketpathlibPathconfig PROJECT_DIR gethostnamerrredisr)exists read_text write_textrovarsr(rBrr custom_fieldsrrArrrr is_changedrIsaverrrN merge_fields save_changes apply_changes)r?r>rCrN meta_ver_pathhostname redis_lock ui_fieldsrF custom_class_filterfrrYcustom_field_datas rMcustom_fields_gen_metaz%CmfCustomClass.custom_fields_gen_metas % V%7%785@CXX %%' \]e\fgPQ R^^((6(;d)eosGK(L , - GGR S##%-*A*A*CtNG[*[GH , -, -  $ $T.%9 :Iv,tL12C)C8L($?@G=Xl>X>X'Y 'YZ) +, %1166"7$(7 4 "--7E7V7VWa7bIjoo334/3L+##',J$OOdO3 4L33 " )2)9)9);a%!(()A)ABS[^)A)_`aB=/RS))-8PQ^^((+bmqEI(J0GGlm --/0>?**,Y, -Z -.=(Z200Q, -, -sFAL#A0L# LA?L#CL#!&L-L#L#L L##L,ct}dgddd}|j|}| dd|gg|d<tjjd i|D]q}t |j d|j }||vs)|j||jtj| }|jd| sy) uПерезагрузить только модели, чьи пользовательские поля изменились после снимка меты. changed_since фиксируется один раз для всего batch: иначе первая обработанная модель может продвинуть APP.snapshot_version, и следующие модели потеряют свои строки из той же догрузки после форка. rT)rrrNrrrrr1 delta_onlyr}r>) rr~r(rrrfrrQr5rget_model_by_name reload_model)rFr}processed_models slist_kwargsr custom_fieldr custom_models rM reload_modelszCmfCustomClass.reload_models,s5'(## #AA-P  +'8#?S&T%UL ""//55E E XL !rr}rcs rMreload_model_handlerz#CmfCustomClass.reload_model_handlerDs  I)"))+V\]a\bcd,, %33g>W>WX\]mXn>o3p !!T!O G  }UVrhrc||_d|_g|_d|_d|_g|_d|_|j|_|jjd|_ d|_|jjjj|jjDcic]}|djdr|d|c}|_|jj!}|jjjj#|j}|jj%||j%|t't(}|jj*j-Dcgc] }|j.jds|"c}D]}|j1|j.}d} d} d} t3|t4t6frst9t:j1|j<j1d} | r|jjjj?| retA} nZt3|tBr'|j.d} | |vr|jE| nd} n#|j.} | |vr|jE| nd} t:jFj1|j.dg } | s8tHjK|jM| | }| |jjO|}d |_|jDcic]}|j.|c}|_ycc}wcc}wcc}w) uИнициализировать рабочее состояние синхронизации пользовательских полей модели.Nz.bkFrrr'rr)rrrT)(rcurrent_fieldsrY db_columnsrZadd_to_db_fieldscustom_fields_index_get_model_file_pathmodel_file_path with_suffix model_bk_pathrrinspect_table_columnsrrcopyinspect_ext_columnsr;rrArrrrrr)r rXr(r has_tablerorr4rrrNrr)r^rrrwext_colsfields_ui_groupsrJrrr$_db_table_name db_field_info cmf_modelrrs rM__init__zCmfCustomClass.__init__Os">B=?59*.68HL 7;7P7P7R595I5I5U5UV[5\ ..++77MMdnnNfNfg f~((/ 6NF "  __))+ >>$$00DDT^^T x((#'t,&*^^%:%:%A%A%Cfq||G^G^_dGe!f 'I(,,Y-A-ABI!N!N M)nj%AB L,,Y->->-B-B7-KL !2!2!>!>!H!H!S$(FMI7$-$8$8#9!=BPT^B^ ~ >dh !*!5!5BPT^B^ ~ >dh ,,00i6J6JTWSX0YJ'11$2G2G 2S[d1eJ(""))*5"&3 '6Y]XjXj#k*J$9$9:$E#k W g6$ls3!M* M/1M/ M4rc|jDcic]}|j|}}|D]=}|j|j}|s$|jj|d|_|}|j|j j vrX|j|jvs|jdz|jvs|jj|d|_|j j |j}t|dr |j|jk7rd|_t|ds|j|jk7s7d|_@ycc}w)u Получим список новых полей, которые надо создать. Соберём новые группы на основе системного значения и списка полей. Поля удалять нельзя, т.к. данные могут быть бесценны. TODO удалять, если данных нет. Trr*r+N) rYrrrrZrrrwrxrr*r+)r^ro cur_fieldsrrofields rMr\zCmfCustomClass.merge_fieldss2 04/A/AB!allAoB B  +J%>>**?*?@L""))*5"&) &&dnn.C.CC**$//AlF]F]^cFckokzkzFz))00>&*DO--l.E.EF5),1E1E1V&*DO5"45,:W:W[`[q[q:q&*DO# +CsE)c |jjj}|j|j|rb||jj vrIddl}|j||jd|jd|jjy|jj}|j|j||j} |d} |jd|d|d |d |j|j1|j} t+j,d||jd|d|d|d|jt+j,d|d|jd|d|jd|d|d|d|jt+j,d|d |j1|jjjjjy#t $re}|j#t%|j&d r3|j&j(d k(rt+j,d |dnYd}~d}~wwxYw#t.$r|j#wxYw#|j1wxYw#t.$r*|j#t+j2d|wxYw#|j1|jjjjjwxYw)ujСоздание extension-таблицы с двухфазным заполнением строками.)rext_norNTrrr_id_fkeyz ALTER TABLE z ADD CONSTRAINT z FOREIGN KEY (id) REFERENCES z(id) ON DELETE CASCADEpgcode42710z_ensure_ext_table(): FK u5 уже существует — пропускаемuJ_ensure_ext_table(): фаза 1 — массовое заполнение z INSERT INTO z (id) SELECT id FROM z# t WHERE NOT EXISTS (SELECT 1 FROM z e WHERE e.id = t.id)uR_ensure_ext_table(): фаза 2 — финальная синхронизация u с локомz LOCK TABLE z IN SHARE MODEz_ensure_ext_table(): u% создана и заполненаuF_ensure_ext_table(): Ошибка заполнения таблицы )rrrrrrrrrrrradd_custom_ext_modelSessionexecutecommitSAProgrammingErrorrollbackrorigrlogginginforclose exception) r^rrrr base_tablesconstraint_namer.s rM_ensure_ext_tablez CmfCustomClass._ensure_ext_tables2nn''33  4>>& I[%8%8%?%??!   "K$7$7!1C1C$( **002 ^^--  ((@    ! !/ 09O  ">"23&&5%6733=,>TV   GGI    ! A LLefteuv w II~./"",.33A2BBWY  HHJ LLmn|m}~LM N II J<~> ? II~./"",.33A2BBWY  HHJ LL00@@ef g GGI NN   ) ) 8 8 > > @Y&  1668,'1ILL#;O;LMB"CDD    JJL   GGI2  JJL    fgufvw x   GGI NN   ) ) 8 8 > > @sW#J%)+H45B5K4 J"=AJJ%J""J%%KKK3L  LA Mc:|jj}|jdkDrE|jd}|jjd|}|j||j|jjj j |||y)uiСоздать колонку в основной или extension-таблице по `custom_table_no`.rrrN)rrr9rrradd_custom_column)r^rrrrext_nns rM_add_custom_column_routedz(CmfCustomClass._add_custom_column_routeds~~//  % % )"2237F"nn667tF8DL  " "<1K1K L %%77 kS]^rhc|jD]}ttj|j}t |t r t|jrl|jr]t |tr:|jjjj|jnt |trw|jjjj|j|j d}tjj"}|j%|||-|jjjj'|j|jj |j}|jjjj)|t |t*r|jj |j j-}t |ts!|j/|j||xs|}|jjjj)|_t |t0r*|j d}tjj"}n |j }|j%||||j3y)uPСоздадим поля в базе и сохраним файл модели.rN)rxrfr[rrrr)NotImplementedr-r,rrrradd_custom_choice_model_extrrrHradd_custom_choice_modeladd_custom_m2m_modelr rYrr_write_custom_model_file)r^rrrrs rMr]zCmfCustomClass.save_changess%// PJ Z-B-BCJ*n5$&&0099!*i8))55QQR\RqRqr#J?))55QQR\RqRqr)3)>)>(?s&C %(ZZ%8%8 66z;PZ[ ))55MMjNmNmn$(NN$=$=#>z?^?^>_!`JNN%%11FFzRJ 3 $ 9 9::;P;P;[;[;]:^_ !*i8!%!C!CDNNT^`j!k!yoyJ!!--BB:NJ8!+!6!6 7s;  ZZ00 (33  * *:{J O= PF %%'rhcddlm} d} tjd|tjs |d d |jj iy y #tj $rt jd|jrU|jjr;t jd|jj|jnW|jrJ|jjr0t jd|jjntjd|wxYw) u~Запустить autogen и разослать событие перезагрузки модели по процессам.r)r=c8tjtj}dD]C}|dz |z }|j st j d||jEt j dtjgddy)N)z__autogen_models.pyz__autogen_models_tmp.pyz__autogen_models.tsrDu6CmfCustomClass.apply_changes: удаляем мету uFCmfCustomClass.apply_changes: генерируем новую мету)z /usr/bin/envpython3z manage.pyautogenT)check) rOrPrQrRrUrrunlink subprocessrun) project_pathautogen_filenameautogen_file_paths rMapplyz+CmfCustomClass.apply_changes..apply$s"<<6+=+=*>@L$k / $0$67G$G!$++-GGTUfTghi%,,.  / GG\ ] NNNVZ [rhuXCmfCustomClass.apply_changes: пытаемся перегенерировать метуuGОшибка применения новой кастом модели.u=Есть backup file попробуем откатиться.uAПопробуем откатиться удалив custom file.u]CmfCustomClass.apply_changes: Повторный запуск apply() после откатаrrrN) cmf.includer=rrrSubprocessErrorrrr}rUrrenamer{r import_moderr)r^r=rs rMr^zCmfCustomClass.apply_changes s 5Y \   GGn o G}} !"?BRTXTbTbTmTmAn o))    g h!!d&8&8&?&?&A \]""))$*>*>?%%$*>*>*E*E*G `a$$++- GGs t G  s AC>Ec ddlm}ddlm}ddl}ddlm}t jd|j|rY|j|\}} |r(t jd|jyt jd | d t|jjtjd d jd ddd} tj tj"| d} t jd|tj$j'| t|} tj$j)| } | t*j,| <| j.j1| t jdt jdt2j4j6j8D]}t;| |}t=t2|}g}g}|j>D]O}|jAds||j>vr|jC||j>||j>|<Q||j>D]A}|jAds||j>vs$|jC||j>|=Ci}t2j4jEdd|ggddgD]3}|jFjHxsd||jJjH<5|j>jMD]R\}}|jAds|jOdr||vr |dd|vr|dd}n|}|jQ|d|_#T|jR|_)|jT|_*t jd|d|d|t=| D]}|jA|jVjXds?|jA|jVjX|jVjXdsjt[t2|t;| |t jdit\_/it\_0|jVjbjdjfjQ|jVjXr?|jVjbjdjf|jVjX=|jVjbjdjhjk|jVjbjd}|jVjl}||jnjpvr|jnjp|}ts|jVj>ju}tE|jvjxDchc]7}|jJjAdr|jJ|vr |jJ9}}|rv|D](}|jvjzj}|d*|jvjxDcgc]}|jJ|vr|c}|jvjxddddl?}|jVj>jMD]\} }!t;|!d d}"|"s|"jdd!d}#|#|jnjpvrD |j|#|jnd"|jd"#t jd$|#d%| |st jst jd)|jt jd*t2jjt jd+|jyyycc}wcc}w#t$r!t jd&|#d'| d( YTwxYw),u}Перезагрузить пользовательские поля модели. delta_only=True включает точечное обновление меты в памяти без полного importlib.reload сгенерированных модулей. changed_since передаётся из пакетной догрузки после форка и ограничивает чтение БД строками новее снимка меты. При ошибке или неподдержанном типе используется полный путь перезагрузки. r) CMF_CACHE)rN)models_orig_pathuiCmfCustomClass.reload_model: НАЧАЛО - перезагружаем мету в инстансе, PID=ru7CmfCustomClass.reload_model: delta_only УСПЕХ PID=zcf-delta: fall back, reason=rr/rQr3rruPCmfCustomClass.reload_model: загружаем модуль custom_models из uWCmfCustomClass.reload_model: модуль custom_models успешно загруженuCmfCustomClass.reload_model: начинаем обновление кастомных полей для всех моделейrrrrr9)rrrz#CmfCustomClass.reload_model: model=z cf_added=z cf_removed=Cfu[CmfCustomClass.reload_model: сбрасываем кеш меты для фронтендаrBrtTrz1CmfCustomClass.reload_model: reflected FK target z for field uTCmfCustomClass.reload_model: не удалось отразить FK-таблицу u для поля ruECmfCustomClass.reload_model: сбрасываем CMF_CACHE.flushdb()ulCmfCustomClass.reload_model: пересчитываем кеш полей RelationCache.build_fields_cache()ujCmfCustomClass.reload_model: ЗАВЕРШЕНО - мета успешно перезагружена, PID=)HrMrrrcmf.make_modelsrrrrr/rmr{replacerQrR importlibreload import_moduleutilspec_from_file_locationmodule_from_specsysmodulesloader exec_moduler(rrr*rfrXrrrrAr9rrr?rrrui_group_fieldsrrrrrrrrrrrrrrrkeysrrrr4rrXrrrrflushdbrr)$r^ only_reloadrjr}rrrrsuccessr module_pathrspecrrrpraddedremovedrcustom_fields_metacfrr7rrractual_field_namescol stale_namesrrfnamefclsrrs$ rMrlzCmfCustomClass.reload_modelJs &4 {}F|~}F}F}H|IJ K "88}8UOGVQR[RTR[R[R]Q^_` GG26(;9G M$../776;M;M:Na8PRTU]]^acfghkikl 00=>&  bcsbtuv~~55k3GWCXY!77= #0 K   . ij R S --<<DD* nJ"=*=LV Z0IEG*11 S ((/!)9)99 Z03?3F3Fz3RI$$Z0  S #9#3#34 5 ((/JlFYFY4YNN:.!((4  5 "$ ))..)4<= 12/ R574F4F4L4L4QPQ"277==1  R *3)9)9)?)?)A P% I((/#++E2 *2D D *3B3E E)#2)0B0F0FtQ0OI- P"!- 4 4I (4(D(DI % GG9*ZPUwVbcjbkl mU* n\}- PJ$$(A(A'B"%EF*J_J_cgcqcqc|c|b}CMMXX~YY[a\K] GM:,NO P mn -/* >>   ( ( 8 8 < W>WX %%44::< nn''33 NN,,  ++22 2"**11)>00668 KE4mT:I$??3215L{22999     +"5"5!1C1C$( KL>Ydejdklm (1== GG[ \     GGC D  3 3 5 GGABKBDBKBKBMANO P$1{M50 jkwjxyJKPJQR% s <` `-A`&`=<`=r c@|s!tjjdd|j|}t dD]4}d|}|s|j dr|d|z }||j vs2|cStjjd|d |d dy) NuMУ настраиваемого поля не указано названиеTrUdrrrRu#Такое имя уже есть: ())r[r\r]rCrangerrw)rcr name_basennrs rMcalc_field_namezCmfCustomClass.calc_field_names KK ! !"qy} ! ~ 009 * "Byk*JY''."h& !8!88!!  "  CI;aPWyXYZbfgrhcRt|dd}djd|D}|S)NruT) language_codereversedrQc3`K|]&}|jr|jnd(yw)rRN)isalnumlower)rrs rMrz1CmfCustomClass.caption_to_name..s#HaQYY[ c9Hs,.)r rW)r rs rMrCzCmfCustomClass.caption_to_names)tdCwwH4HI rhc|jD]5}t|dd}t|ts!|j ds3|cSy)NrCmf)rrfr@rmr)rrbase_class_names rMrzCmfCustomClass._field_type_namesD")) 'H%h dCO/3/O4N4Nu4U&& 'rhctjd|jtj tj t jjtjdg}d|jd<|jd}|jjD]}|jj!drnd}|jj#r%|jj%|j&|j&j)|j+|| |j&j%|jy) u^Дампим кастомные поля в файл используя шаблон и jinja2uP_write_custom_model_file: Пишем новую кастомную модель z cmf/templates)rcht|tr!dj|jddS|S)Nz'''{}'''z'''z""")r@rmformatr)xs rMrz9CmfCustomClass._write_custom_model_file..s.]ghikn]oz/@/@5RWAX/Yuvrhquotezcmf_model.tmpltrN)r! base_model)rrr{jinja2 EnvironmentFileSystemLoaderrpathrWrQrRfilters get_templater __bases__rkrrUrr}rWrender)r^ jinja_envtemplaters rMrz'CmfCustomClass._write_custom_model_files bcgcwcwbxyz&&**BGGLL9K9K_,]+^_'a &w '"))*;<..22 J((33I> J    & & (  ' '(:(: ; %%hooTjo&YZ !!$"6"67rhctjtjd|jj d}|jj D]}|jjdrXdj|jjddd}tjtjd|d}nYdj|jjddd}tjtjd|d}n|jd d |d z }|js)|jd 5 dddtd |tj!d}dj|j#|jj$Dcgc]}|j'c}}||dz S#1swYxYwcc}w)uYВозвращает путь к файлу где будут кастомные поляz/custom/modules/z/fieldsrrr3Nz/custom/T)parentsexist_okz __init__.pywu Создан z[A-Z][a-z0-9]+rRz.py)rOrPrQrRr ui_modulerrkrrWrXmkdirrUopenprintrecompilefindallrr)r^fields_dir_pathrFpostfixpkg_init_file_path name_word_rewordmodel_filenames rMrzz#CmfCustomClass._get_model_file_paths!,,&*<*<)==MdnnNfNfMggn'op>>++ C~~((3((3>>#7#7#>#7#7#)C)C)E 2 %J 11*=Iy1J, < +55c6J6J;6W_h5i ((// ; <  / / 1 2rhri)NN)rN)FF)FFN)nrjrkrl__doc__rr|rrwrxrrrzr~rr: frozensetr staticmethodrrrorrrprr rmrrrrr CmfTypeMetarrrrrrrrrrrrrrrrrrr r r#r1r5r>rIrMrYr[r^rkrpr~rrrrrrrrrrrrrrrrrrrrrrrr/r3r5r@on_server_eventrgrqrtrrrr\rrr]r^rlrrCrrrzrr>rhrMrBrBs@&/&:#!GOGG CC(o{Iy/+)?   n   kd, >   7>77@s@{@WZ@@$7;77Bm{msmm^Ydil([>[e[6U3U;USXUU8bb'b# b(+ b" 1c 1s 1TW 1cg 1V#V3VSWV  ~  ;  [_    11 1]a11$nZejm[n`deh`i$*.%)P&P#P  P  P  c * PdCCC $ &      $/ >  Wb B>dSVXcScNd$t28 .# .939;9SXY]^aYbdhildmYmSn924C4K4TYZ]_bZbTc4,1818 18f ?=93=9~0 3 4 x4xx   UUPTUU ,3,4,:M [T.zzz  n n n S T  ,,,83s8$ % % C 7S+5E0F7_bcf_g7lp7r8$848. +s +t +3TRUWbRbMchklohp ${2C QUVY[fVfQg lp Z@5s;KZ@x  HH4?@=/T=/A=/~XX.:;W<W9l$y/9lv+4#7+4JAX_%(N&pTYPv hs hs h h 'K''8*6022rhrB)/rrrrrOrr collectionsrcollections.abcrr:rr gevent.lockrrr dataclassesrsqlalchemy.excr r transliterater typingr r r rrr cmf.fieldsr[ cmf.modelsrcmf.utilrcmf.models.base_modelrrrrrrrrBr>rhrMr%s   ##!A"99 R2R2 R2l22rh