|
|
|
@ -19,7 +19,11 @@ class BatchLabelConfigDAO: |
|
|
|
async def get_busi_list(cls, db: AsyncSession, query_object, is_page: bool = False): |
|
|
|
query = select(BatchBusiLabelConfig).where( |
|
|
|
BatchBusiLabelConfig.mdl_name == query_object.mdl_name if query_object.mdl_name else True, |
|
|
|
BatchBusiLabelConfig.ssys_id == query_object.ssys_id if query_object.ssys_id else True, |
|
|
|
BatchBusiLabelConfig.ssys_id.is_(None) if query_object.ssys_id and query_object.ssys_id == -1 else |
|
|
|
BatchBusiLabelConfig.ssys_id == query_object.ssys_id if query_object.ssys_id |
|
|
|
and query_object.ssys_id != -1 |
|
|
|
else True, |
|
|
|
|
|
|
|
).order_by(BatchBusiLabelConfig.upd_time.desc()) |
|
|
|
|
|
|
|
return await PageUtil.paginate(db, query, query_object.page_num, query_object.page_size, is_page) |
|
|
|
@ -28,7 +32,9 @@ class BatchLabelConfigDAO: |
|
|
|
async def get_col_optype_list(cls, db: AsyncSession, query_object, is_page: bool = False): |
|
|
|
query = select(BatchDataopLabelConfig).where( |
|
|
|
BatchDataopLabelConfig.mdl_name.like(f'%{query_object.mdl_name}%') if query_object.mdl_name else True, |
|
|
|
BatchDataopLabelConfig.ssys_id == query_object.ssys_id if query_object.ssys_id else True, |
|
|
|
BatchDataopLabelConfig.ssys_id.is_(None) if query_object.ssys_id and query_object.ssys_id == -1 else |
|
|
|
BatchDataopLabelConfig.ssys_id == query_object.ssys_id if query_object.ssys_id and query_object.ssys_id != -1 |
|
|
|
else True, |
|
|
|
).order_by(BatchDataopLabelConfig.upd_time.desc()) |
|
|
|
|
|
|
|
return await PageUtil.paginate(db, query, query_object.page_num, query_object.page_size, is_page) |
|
|
|
@ -99,7 +105,9 @@ class BatchLabelConfigDAO: |
|
|
|
async def get_datatype_list(cls, db: AsyncSession, query_object, is_page: bool = False): |
|
|
|
query = select(BatchDatatypeLabelConfig).where( |
|
|
|
BatchDatatypeLabelConfig.mdl_name == query_object.mdl_name if query_object.mdl_name else True, |
|
|
|
BatchDatatypeLabelConfig.ssys_id == query_object.ssys_id if query_object.ssys_id else True, |
|
|
|
BatchDatatypeLabelConfig.ssys_id.is_(None) if query_object.ssys_id and query_object.ssys_id == -1 else |
|
|
|
BatchDatatypeLabelConfig.ssys_id == query_object.ssys_id if query_object.ssys_id and query_object.ssys_id != -1 |
|
|
|
else True, |
|
|
|
).order_by(BatchDatatypeLabelConfig.upd_time.desc()) |
|
|
|
|
|
|
|
return await PageUtil.paginate(db, query, query_object.page_num, query_object.page_size, is_page) |
|
|
|
@ -107,10 +115,16 @@ class BatchLabelConfigDAO: |
|
|
|
@classmethod |
|
|
|
async def get_table_rel_list(cls, db: AsyncSession, query_object, is_page: bool = False): |
|
|
|
query = select(BatchTableRelaLabelConfig).where( |
|
|
|
BatchTableRelaLabelConfig.a_mdl_name.like(f'%{query_object.a_mdl_name}%') if query_object.a_mdl_name else True, |
|
|
|
BatchTableRelaLabelConfig.b_mdl_name.like(f'%{query_object.b_mdl_name}%') if query_object.b_mdl_name else True, |
|
|
|
BatchTableRelaLabelConfig.a_ssys_id == query_object.a_ssys_id if query_object.a_ssys_id else True, |
|
|
|
BatchTableRelaLabelConfig.a_ssys_id == query_object.a_ssys_id if query_object.a_ssys_id else True, |
|
|
|
BatchTableRelaLabelConfig.a_mdl_name.like( |
|
|
|
f'%{query_object.a_mdl_name}%') if query_object.a_mdl_name else True, |
|
|
|
BatchTableRelaLabelConfig.b_mdl_name.like( |
|
|
|
f'%{query_object.b_mdl_name}%') if query_object.b_mdl_name else True, |
|
|
|
BatchTableRelaLabelConfig.a_ssys_id.is_(None) if query_object.a_ssys_id and query_object.a_ssys_id == -1 else |
|
|
|
BatchTableRelaLabelConfig.a_ssys_id == query_object.a_ssys_id if query_object.a_ssys_id and query_object.a_ssys_id != -1 |
|
|
|
else True, |
|
|
|
BatchTableRelaLabelConfig.b_ssys_id.is_(None) if query_object.b_ssys_id and query_object.b_ssys_id == -1 else |
|
|
|
BatchTableRelaLabelConfig.b_ssys_id == query_object.b_ssys_id if query_object.b_ssys_id and query_object.b_ssys_id != -1 |
|
|
|
else True, |
|
|
|
).order_by(BatchTableRelaLabelConfig.upd_time.desc()) |
|
|
|
return await PageUtil.paginate(db, query, query_object.page_num, query_object.page_size, is_page) |
|
|
|
|
|
|
|
|