# # data_ast_content_service.py
# from datetime import datetime
# from utils.log_util import logger
# from collections import defaultdict
# from sqlalchemy.ext.asyncio import AsyncSession
# from exceptions.exception import ServiceException
# from module_admin.dao.data_ast_content_dao import DataAstInfoDAO
# from module_admin.entity.vo.common_vo import CrudResponseModel
# from module_admin.entity.vo.data_ast_content_vo import DataAstInfoRequest, DataAstInfoResponse, DataAstInfoPageQueryModel

# class DataAstInfoService:
#     """
#     数据资产信息模块服务层
#     """

#     @classmethod
#     async def add_data_ast_info_services(cls, query_db: AsyncSession, request: DataAstInfoRequest):
#         """
#         新增数据资产信息service

#         :param query_db: orm对象
#         :param request: 新增数据资产信息请求对象
#         :return: 新增数据资产信息操作结果
#         """
#         data_ast_info_data = {
#             'data_ast_eng_name': request.data_ast_eng_name,
#             'data_ast_cn_name': request.data_ast_cn_name,
#             'data_ast_type': request.data_ast_type,
#             'data_ast_stat': request.data_ast_stat,
#             'data_ast_desc': request.data_ast_desc,
#             'data_ast_clas': request.data_ast_clas,
#             'data_ast_cont': request.data_ast_cont,
#             'data_ast_faq': request.data_ast_faq,
#             'data_ast_src': request.data_ast_src,
#             'ast_no': request.ast_no
#         }

#         try:
#             new_data_ast_info = await DataAstInfoDAO.add_data_ast_info_dao(query_db, data_ast_info_data)
#             await query_db.commit()
#             return CrudResponseModel(is_success=True, message='新增成功', data=new_data_ast_info)
#         except Exception as e:
#             await query_db.rollback()
#             raise ServiceException(message=f"创建数据资产信息时发生错误: {str(e)}")

#     @classmethod
#     async def add_data_ast_info_batch_services(cls, query_db: AsyncSession, request_list: List[DataAstInfoRequest]):
#         """
#         批量新增数据资产信息service

#         :param query_db: orm对象
#         :param request_list: 新增数据资产信息请求对象列表
#         :return: 新增数据资产信息操作结果
#         """
#         data_ast_info_list = [
#             {
#                 'data_ast_eng_name': request.data_ast_eng_name,
#                 'data_ast_cn_name': request.data_ast_cn_name,
#                 'data_ast_type': request.data_ast_type,
#                 'data_ast_stat': request.data_ast_stat,
#                 'data_ast_desc': request.data_ast_desc,
#                 'data_ast_clas': request.data_ast_clas,
#                 'data_ast_cont': request.data_ast_cont,
#                 'data_ast_faq': request.data_ast_faq,
#                 'data_ast_src': request.data_ast_src,
#                 'ast_no': request.ast_no
#             }
#             for request in request_list
#         ]

#         try:
#             new_data_ast_info_list = await DataAstInfoDAO.add_data_ast_info_batch_dao(query_db, data_ast_info_list)
#             await query_db.commit()
#             return CrudResponseModel(is_success=True, message='批量新增成功', data=new_data_ast_info_list)
#         except Exception as e:
#             await query_db.rollback()
#             raise ServiceException(message=f"批量创建数据资产信息时发生错误: {str(e)}")

#     @classmethod
#     async def get_data_ast_info_list_services(cls, query_db: AsyncSession, query_object: DataAstInfoPageQueryModel, is_page: bool = False):
#         """
#         获取数据资产信息列表service

#         :param query_db: orm对象
#         :param query_object: 查询参数对象
#         :param is_page: 是否开启分页
#         :return: 数据资产信息列表信息对象
#         """
#         data_ast_info_list_result = await DataAstInfoDAO.get_data_ast_info_list(query_db, query_object, is_page)
#         return data_ast_info_list_result