|
@ -7,7 +7,7 @@ SecuBizConfigQueryModel,SecuBizPermiConfigModel, SecuBizPermiConfigQueryModel,\ |
|
|
TaskBizConfigAddModel, TaskBizConfigQueryModel,TaskBizConfigModel,TaskBizConfigRelaModel |
|
|
TaskBizConfigAddModel, TaskBizConfigQueryModel,TaskBizConfigModel,TaskBizConfigRelaModel |
|
|
from utils.common_util import CamelCaseUtil |
|
|
from utils.common_util import CamelCaseUtil |
|
|
from module_admin.entity.do.metadata_config_do import SecuBizConfigRela,TaskBizConfigRela # ORM 类 |
|
|
from module_admin.entity.do.metadata_config_do import SecuBizConfigRela,TaskBizConfigRela # ORM 类 |
|
|
from exceptions.exception import ServiceException |
|
|
from exceptions.exception import ServiceException,ServiceWarning |
|
|
import uuid |
|
|
import uuid |
|
|
from module_admin.entity.vo.dataSource_vo import ProcessDefinition,ParmScheduleVo,ProcessInstancePage,ParmSchedule |
|
|
from module_admin.entity.vo.dataSource_vo import ProcessDefinition,ParmScheduleVo,ProcessInstancePage,ParmSchedule |
|
|
from typing import List |
|
|
from typing import List |
|
@ -121,6 +121,11 @@ class MetadataConfigService: |
|
|
新增数据安全配置 |
|
|
新增数据安全配置 |
|
|
""" |
|
|
""" |
|
|
try: |
|
|
try: |
|
|
|
|
|
# 校验 secLevelSummary 是否已存在 |
|
|
|
|
|
existing = await MetadataConfigDao.get_by_sec_level_summary( query_db, page_object.sec_level_summary,page_object.onum) |
|
|
|
|
|
if existing: |
|
|
|
|
|
raise ServiceWarning(message=page_object.sec_level_summary+"该等级简称已存在,不能重复") |
|
|
|
|
|
|
|
|
page_object.onum = str(uuid.uuid4()) |
|
|
page_object.onum = str(uuid.uuid4()) |
|
|
await MetadataConfigDao.add_metadata_sec_dao(query_db, page_object) |
|
|
await MetadataConfigDao.add_metadata_sec_dao(query_db, page_object) |
|
|
await query_db.commit() |
|
|
await query_db.commit() |
|
@ -138,6 +143,11 @@ class MetadataConfigService: |
|
|
info = await cls.get_metadata_sec_detail_services(query_db, page_object.onum) |
|
|
info = await cls.get_metadata_sec_detail_services(query_db, page_object.onum) |
|
|
if info.onum: |
|
|
if info.onum: |
|
|
try: |
|
|
try: |
|
|
|
|
|
# 校验 secLevelSummary 是否重复(排除当前记录) |
|
|
|
|
|
existing = await MetadataConfigDao.get_by_sec_level_summary( query_db, page_object.sec_level_summary,page_object.onum) |
|
|
|
|
|
if existing: |
|
|
|
|
|
raise ServiceWarning(message=page_object.sec_level_summary+"该等级简称已存在,不能重复") |
|
|
|
|
|
|
|
|
await MetadataConfigDao.edit_metadata_sec_dao(query_db, page_object.onum, edit_data) |
|
|
await MetadataConfigDao.edit_metadata_sec_dao(query_db, page_object.onum, edit_data) |
|
|
await query_db.commit() |
|
|
await query_db.commit() |
|
|
return CrudResponseModel(is_success=True, message="更新成功") |
|
|
return CrudResponseModel(is_success=True, message="更新成功") |
|
@ -147,6 +157,7 @@ class MetadataConfigService: |
|
|
else: |
|
|
else: |
|
|
raise ServiceException(message="数据安全配置不存在") |
|
|
raise ServiceException(message="数据安全配置不存在") |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@classmethod |
|
|
@classmethod |
|
|
async def delete_metadata_sec_services(cls, query_db: AsyncSession, onum_list: str): |
|
|
async def delete_metadata_sec_services(cls, query_db: AsyncSession, onum_list: str): |
|
|
""" |
|
|
""" |
|
|