|
|
@ -6,6 +6,7 @@ from module_admin.entity.vo.meta_vo import MetaPageObject, MetaColObject, Supple |
|
|
|
from module_admin.entity.do.meta_do import MetadataSuppInfo, MetadataFldSuppInfo, MetadataSuppInfoVett, \ |
|
|
|
MetadataFldSuppInfoVett, MetadataExtractInfo, MetadataFldTabExtractInfo |
|
|
|
from module_admin.dao.meta_dao import MetaDao |
|
|
|
from module_admin.dao.datastd_dao import DataStdDao |
|
|
|
from datetime import datetime |
|
|
|
from module_admin.entity.vo.user_vo import CurrentUserModel |
|
|
|
from module_admin.entity.vo.approval_vo import ApplyModel |
|
|
@ -97,6 +98,10 @@ class MetaService: |
|
|
|
oldColumn = await MetaDao.get_supp_column_by_columnInfo(supple.ssys_cd, supple.mdl_name, |
|
|
|
supple.tab_eng_name, |
|
|
|
column.fld_eng_name, result_db) |
|
|
|
data_dict_name = '' |
|
|
|
if oldColumn.data_dict_id and oldColumn.data_dict_id != '': |
|
|
|
oldDict = await DataStdDao.get_data_dict_by_id(result_db, oldColumn.data_dict_id) |
|
|
|
data_dict_name = oldDict.data_dict_cn_name if oldDict else '' |
|
|
|
columnInfo = await MetaDao.get_meta_column(supple.ssys_cd, supple.mdl_name, supple.tab_eng_name, |
|
|
|
column.fld_eng_name, result_db) |
|
|
|
suppColumnInfo = MetadataFldSuppInfoVett() |
|
|
@ -116,7 +121,7 @@ class MetaService: |
|
|
|
suppColumnInfo.rec_subm_prsn = current_user.user.user_name |
|
|
|
suppColumnInfo.apply_time = applyTime |
|
|
|
suppColumnInfo.apply_status = 'waiting' |
|
|
|
suppColumnInfo.oldColumnData = cls.castToColumnStr(oldColumn, columnInfo) |
|
|
|
suppColumnInfo.oldColumnData = cls.castToColumnStr(oldColumn, columnInfo, data_dict_name) |
|
|
|
await MetaDao.insertMetadataFldSuppInfoVett(suppColumnInfo, result_db) |
|
|
|
applyModel = ApplyModel() |
|
|
|
applyModel.businessType = "metaDataInfo" |
|
|
@ -144,15 +149,15 @@ class MetaService: |
|
|
|
recStat=table.rec_stat if table else None, |
|
|
|
tabClas=table.tab_clas if table else None, |
|
|
|
recSubmPrsn=table.rec_subm_prsn if table else None, |
|
|
|
updTime=table.upd_time if table else None |
|
|
|
updTime=table.upd_time.isoformat() if table and table.upd_time else None |
|
|
|
) |
|
|
|
return json.dumps(tableDict) |
|
|
|
|
|
|
|
@classmethod |
|
|
|
def castToColumnStr(cls, column: MetadataFldSuppInfo, columnInfo: MetadataFldTabExtractInfo): |
|
|
|
def castToColumnStr(cls, column: MetadataFldSuppInfo, columnInfo: MetadataFldTabExtractInfo, dictName: str): |
|
|
|
columnDict = dict( |
|
|
|
onum=columnInfo.onum, |
|
|
|
crrctVerNum=column.crrct_ver_num if column else None, |
|
|
|
crrctVerNum=column.crrct_ver_num if column and column.crrct_ver_num else None, |
|
|
|
ssysCd=columnInfo.ssys_cd, |
|
|
|
mdlName=columnInfo.mdl_name, |
|
|
|
tabEngName=columnInfo.tab_eng_name, |
|
|
@ -162,15 +167,16 @@ class MetaService: |
|
|
|
pkFlag=columnInfo.pk_flag, |
|
|
|
requireFlag=columnInfo.require_flag, |
|
|
|
idxFlag=columnInfo.idx_flag, |
|
|
|
fldCrrctName=column.fld_crrct_name if column else None, |
|
|
|
crrctPkFlag=column.crrct_pk_flag if column else None, |
|
|
|
fldDesc=column.fld_desc if column else None, |
|
|
|
pic=column.pic if column else None, |
|
|
|
fldClas=column.fld_clas if column else None, |
|
|
|
fldNullRate=column.fld_null_rate if column else None, |
|
|
|
dataDictId=column.data_dict_id if column else None, |
|
|
|
recStat=column.rec_stat if column else None, |
|
|
|
updTime=column.upd_time.isoformat() if column else None |
|
|
|
fldCrrctName=column.fld_crrct_name if column and column.fld_crrct_name else None, |
|
|
|
crrctPkFlag=column.crrct_pk_flag if column and column.crrct_pk_flag else None, |
|
|
|
fldDesc=column.fld_desc if column and column.fld_desc else None, |
|
|
|
pic=column.pic if column and column.pic else None, |
|
|
|
fldClas=column.fld_clas if column and column.fld_clas else None, |
|
|
|
fldNullRate=column.fld_null_rate if column and column.fld_null_rate else None, |
|
|
|
dataDictId=column.data_dict_id if column and column.data_dict_id else None, |
|
|
|
dataDictName=dictName, |
|
|
|
recStat=column.rec_stat if column and column.rec_stat else None, |
|
|
|
updTime=column.upd_time.isoformat() if column and column.upd_time else None |
|
|
|
) |
|
|
|
return json.dumps(columnDict) |
|
|
|
|
|
|
|