package com.vci.ubcs.ddl.service.impl;

import com.alibaba.nacos.client.naming.NacosNamingService;

import com.vci.starter.word.bo.WordMergeStartTableDataBO;
import com.vci.ubcs.ddl.bo.DdlTableBO;
import com.vci.ubcs.ddl.bo.DdlTableInDataBaseBO;
import com.vci.ubcs.ddl.processor.ddl.DdlMapperProcessStrategy;
import com.vci.ubcs.ddl.processor.ddl.DdlMapperProcessor;
import com.vci.ubcs.ddl.processor.dll.DllMapperProcessor;
import com.vci.ubcs.ddl.processor.dll.DllMapperProcessorStrategy;
import com.vci.ubcs.ddl.properties.DdlExportWordFieldProperties;
import com.vci.ubcs.ddl.properties.DdlPropertise;
import com.vci.ubcs.ddl.service.IDdlService;
import com.vci.ubcs.omd.cache.OmdBtmTypeCache;
import com.vci.ubcs.omd.dto.OmdBtmTypeDTO;
import com.vci.ubcs.omd.entity.OsModifyAttributeInfoDO;
import com.vci.ubcs.omd.vo.OmdBtmTypeAttributeVO;
import com.vci.ubcs.omd.vo.OmdBtmTypeVO;
import com.vci.ubcs.omd.vo.OsLinkTypeAttributeVO;
import com.vci.ubcs.omd.vo.OsLinkTypeVO;
import com.vci.ubcs.starter.exception.VciBaseException;
import com.vci.ubcs.starter.web.util.VciBaseUtil;
import org.apache.commons.lang3.StringUtils;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.BeanUtil;
import org.springblade.core.tool.utils.Func;
import org.springblade.core.tool.utils.StringPool;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.*;
import java.util.stream.Collectors;

/**
 * Description: 数据库表操作服务
 *
 * @author LiHang
 * @date 2023/4/24
 */
@Service
public class DdlServiceImpl implements IDdlService {

	/**
	 * 相应的配置
	 */
	@Autowired
	private DdlPropertise ddlProperties;

	/**
	 * word导出的时候的域字段映射
	 */
	@Autowired
	private DdlExportWordFieldProperties wordFieldProperties;

	/**
	 * ddl数据操作服务
	 */
	private final DdlMapperProcessor ddlMapper = DdlMapperProcessStrategy.getProcessor();

	/**
	 * dll数据操作服务
	 */
	private final DllMapperProcessor dllMapper = DllMapperProcessorStrategy.getProcessor();

	/**
	 * 表名前缀
	 */
	private final String TABLE_PREFIX = "PL";

	/**
	 * 校验业务类型的数据库表中是否有数据
	 *
	 * @param pkBtmType 业务类型的主键
	 * @return true表示有数据，false表示没有数据
	 * @throws VciBaseException 参数为空或者查询出错的时候会抛出异常
	 */
	@Override
	public boolean checkTableHasData(String pkBtmType) throws VciBaseException {
		return checkTableHasDataByTableName(getTableNameByBtmTypeOid(pkBtmType));
	}

	/**
	 * 根据业务类型或者链接类型的主键获取数据库表格的名称
	 *
	 * @param pkBtmType 业务类型或者链接类型的主键
	 * @return 数据库表名称
	 */
	@Override
	public String getTableNameByBtmTypeOid(String pkBtmType) {
		VciBaseUtil.alertNotNull(pkBtmType, "业务类型或者链接类型的主键");
		OmdBtmTypeVO btmType = OmdBtmTypeCache.getDetail(pkBtmType);
		String tableName = "";
		if (btmType == null || StringUtils.isBlank(btmType.getOid())) {
			/*OsLinkTypeDO linkTypeDO = linkTypeDOMapper.selectByPrimaryKey(pkBtmType.trim());
			if(linkTypeDO == null || StringUtils.isBlank(linkTypeDO.getOid()) ){
				throw new com.vci.starter.web.exception.VciBaseException("不是业务类型，也不是链接类型，请查证");
			}else{
				tableName = linkTypeService.getTableName(linkTypeDO.getId());
			}*/
		} else {
			tableName = btmType.getTableName();
		}
		return tableName;
	}

	/**
	 * 根据业务类型获取链接类型的英文名称获取数据库表格的名称
	 *
	 * @param id 业务类型获取链接类型的英文名称
	 * @return 数据库表名称
	 */
	@Override
	public String getTableNameByBtmTypeId(String id) {
		VciBaseUtil.alertNotNull(id, "业务类型或者链接类型的英文名称");
		List<OmdBtmTypeVO> btmTypeList = OmdBtmTypeCache.selectByIdCollection(VciBaseUtil.str2List(id));
		String tableName = "";
		if (CollectionUtils.isEmpty(btmTypeList)) {
			/*List<OsLinkTypeDO> linkTypeDOList = linkTypeDOMapper.selectByIdCollection(VciBaseUtil.str2List(id));
			if(CollectionUtils.isEmpty(linkTypeDOList)){
				throw new com.vci.starter.web.exception.VciBaseException("不是业务类型，也不是链接类型，请查证");
			}else{
				tableName = linkTypeService.getTableName(linkTypeDOList.get(0).getId());
			}*/
		} else {
			tableName = btmTypeList.get(0).getTableName();
		}
		return tableName;
	}

	/**
	 * 校验业务类型的数据库表中是否有数据
	 *
	 * @param id 业务类型的英文名称
	 * @return true表示有数据，false表示没有数据
	 * @throws VciBaseException 参数为空或者查询出错的时候会抛出异常
	 */
	@Override
	public boolean checkTableHasDataById(String id) throws VciBaseException {
		return checkTableHasDataByTableName(getTableNameByBtmTypeId(id));
	}

	/**
	 * 批量将业务类型创建数据库表
	 *
	 * @param pkBtmTypes 业务类型的主键
	 * @throws VciBaseException 参数为空或者创建表出现了错误的时候会抛出异常
	 */
	@Override
	public void createDbTables(String pkBtmTypes) throws VciBaseException {
		VciBaseUtil.alertNotNull(pkBtmTypes, "业务类型/链接类型的主键");
		createDbTablesByOidCollection(VciBaseUtil.str2List(pkBtmTypes));
	}

	/**
	 * 批量将业务类型创建数据库表
	 *
	 * @param oidCollection 业务类型的主键集合
	 * @throws VciBaseException 参数为空或者创建表出现了错误的时候会抛出异常
	 */
	@Override
	public void createDbTablesByOidCollection(Collection<String> oidCollection) throws VciBaseException {
		VciBaseUtil.alertCollectionNotNull("业务类型/链接类型的主键集合", oidCollection);
		List<OmdBtmTypeVO> btmTypeVOList = OmdBtmTypeCache.listBtmTypeByOidCollection(oidCollection);
//		List<OsLinkTypeVO> linkTypeVOList = linkTypeService.listLinkTypeByOidCollection(oidCollection);
		if (!CollectionUtils.isEmpty(btmTypeVOList)) {
			//说明是业务类型
			btmTypeVOList.forEach(this::createDbTableForBtm);
		}
		//链接类型
		/*if(!CollectionUtils.isEmpty(linkTypeVOList)){
			linkTypeVOList.stream().forEach( s -> {
				createDbTableForLink(s);
			});
		}*/
	}

	/**
	 * 创建业务类型的表格
	 *
	 * @param btmTypeVO 业务类型的显示对象
	 * @throws VciBaseException 执行出错的时候会抛出异常
	 */
	private void createDbTableForBtm(OmdBtmTypeVO btmTypeVO) throws VciBaseException {
		VciBaseUtil.alertNotNull(btmTypeVO, "要创建表格所属的业务类型", btmTypeVO.getTableName(), "业务类型的表格名称");
		if (btmTypeVO.isViewFlag() && StringUtils.isNotBlank(btmTypeVO.getViewCreateSql())) {
			//说明是视图
			this.createViewBySql("create or replace " + btmTypeVO.getTableName() + " as " + btmTypeVO.getViewCreateSql());
		} else {
			String tableName = btmTypeVO.getTableName();
			if (!checkTableExistByTableName(tableName)) {
				String attributeSql = dllMapper.getCreateSqlByAttributeForBtm(btmTypeVO.getAttributes());
				dllMapper.createTableBySql(tableName, attributeSql);
				if (StringUtils.isNotBlank(btmTypeVO.getName())) {
					dllMapper.commentTable(tableName, btmTypeVO.getName());
				}
				btmTypeVO.getAttributes().stream().forEach(s -> {
					dllMapper.commentColumnTable(tableName, s.getId(), s.getName());
				});
			}
		}
	}

	/**
	 * 批量将业务类型创建数据库表
	 *
	 * @param ids 业务类型的英文名称
	 * @throws VciBaseException 参数为空或者创建表出现了错误的时候会抛出异常
	 */
	@Override
	public void createDbTablesById(String ids) throws VciBaseException {
		VciBaseUtil.alertNotNull(ids, "业务类型/链接类型的英文集合");
		List<OmdBtmTypeVO> btmTypeVOList = OmdBtmTypeCache.selectByIdCollection(VciBaseUtil.str2List(ids));
//		List<OsLinkTypeVO> linkTypeVOList = linkTypeService.listLinkTypeByIdCollection(VciBaseUtil.str2List(ids));
		if (!CollectionUtils.isEmpty(btmTypeVOList)) {
			//说明是业务类型
			btmTypeVOList.forEach(this::createDbTableForBtm);
		}
		/*//试试链接类型
		if(!CollectionUtils.isEmpty(linkTypeVOList)){
			//的确是链接类型
			linkTypeVOList.stream().forEach( s -> {
				createDbTableForLink(s);
			});
		}*/
	}

	/**
	 * 修改业务类型中的属性字段的长度，注意在执行这个方法时就会将以前的事务提交。
	 *
	 * @param modifyLengthAttrVOList 需要修改的属性对象
	 * @throws VciBaseException 执行出错的时候会抛出异常
	 */
	@Override
	public void changeColumnForBtm(List<OmdBtmTypeAttributeVO> modifyLengthAttrVOList) throws VciBaseException {
		VciBaseUtil.alertCollectionNotNull("要修改长度的属性集", modifyLengthAttrVOList);
		Map<String, List<OmdBtmTypeAttributeVO>> btmTypeHasAttributeVOMap = modifyLengthAttrVOList.stream().collect(Collectors.groupingBy(OmdBtmTypeAttributeVO::getPkBtmType));
		btmTypeHasAttributeVOMap.forEach((k, v) -> {
			OmdBtmTypeVO btmTypeVO = OmdBtmTypeCache.getDetail(k);
			if (btmTypeVO == null || StringUtils.isBlank(btmTypeVO.getOid())) {
				throw new VciBaseException("要修改属性列长度的业务类型不存在");
			}
			if (!isCompatibilityTable(btmTypeVO.getId(), null)) {
				//要看看这个链接类型对应的数据库表是否存在
				String tableName = btmTypeVO.getTableName();
				if (checkTableExistByTableName(tableName)) {
					changeColumnsForTable(tableName, v);
				} else {
					createDbTableForBtm(btmTypeVO);
				}
				changeColumnsForTable(btmTypeVO.getTableName(), v);
			}
		});
	}

	/**
	 * 执行SQL语句的修改
	 *
	 * @param tableName       表格的名称
	 * @param attributeVOList 要添加的属性字段
	 */
	private void changeColumnsForTable(String tableName, List<OmdBtmTypeAttributeVO> attributeVOList) {
		String attributeSql = dllMapper.getCreateSqlByAttributeForBtm(attributeVOList);
		//先判断表格是否存在
		boolean tableExist = false;
		try {
			ddlMapper.countAll(tableName);
			tableExist = true;
		} catch (Throwable e) {
			//说明表格就不存在
			createDbTables(attributeVOList.get(0).getPkBtmType());
		}
		if (tableExist) {
			ddlMapper.modifyTableBySqlBase(tableName, attributeSql);
			commentColumnsForTable(tableName, attributeVOList);
		}
	}

	/**
	 * 给表格的字段添加注释
	 *
	 * @param tableName       表格名称
	 * @param attributeVOList 属性对象列表
	 */
	private void commentColumnsForTable(String tableName, List<OmdBtmTypeAttributeVO> attributeVOList) {
		if (StringUtils.isNotBlank(tableName) && !CollectionUtils.isEmpty(attributeVOList)) {
			attributeVOList.stream().forEach(s -> {
				ddlMapper.commentColumnTable(tableName, s.getId(), s.getName());
			});
		}
	}

	/**
	 * 修改链接类型中的属性字段的长度，注意在执行这个方法时就会将以前的事务提交。
	 *
	 * @param modifyLengthAttrDOListForLinkType 需要修改的属性对象
	 * @throws VciBaseException 执行出错的时候会抛出异常
	 */
	@Override
	public void changeColumnForLink(List<OsLinkTypeAttributeVO> modifyLengthAttrDOListForLinkType) throws VciBaseException {

	}

	/**
	 * 添加属性字段到业务类型中，注意在执行这个方法时就会将以前的事务提交。
	 *
	 * @param addAttrDOList 需要添加的属性对象
	 * @throws VciBaseException 执行出错的时候会抛出异常
	 */
	@Override
	public void addColumn2TableForBtm(List<OmdBtmTypeAttributeVO> addAttrDOList) throws VciBaseException {
		VciBaseUtil.alertCollectionNotNull("要添加到数据库表中的属性集", addAttrDOList);
		Map<String, List<OmdBtmTypeAttributeVO>> btmTypeHasAttributeVOMap = addAttrDOList.stream().collect(Collectors.groupingBy(OmdBtmTypeAttributeVO::getPkBtmType));
		btmTypeHasAttributeVOMap.forEach((k, v) -> {
			OmdBtmTypeVO btmTypeVO = OmdBtmTypeCache.getDetail(k);
			if (btmTypeVO == null || StringUtils.isBlank(btmTypeVO.getOid())) {
				throw new VciBaseException("要修改属性列长度的业务类型不存在");
			}
			if (!isCompatibilityTable(btmTypeVO.getId(), null)) {
				addColumnForTable(btmTypeVO.getTableName(), v);
			}
		});
	}

	/**
	 * 添加字段到表格中
	 *
	 * @param tableName       表格名称
	 * @param attributeVOList 属性的显示对象
	 * @throws VciBaseException 执行或者获取sql语句的时候出现错误会抛出异常
	 */
	private void addColumnForTable(String tableName, List<OmdBtmTypeAttributeVO> attributeVOList) throws VciBaseException{
		String attributeSql = dllMapper.getCreateSqlByAttributeForBtm(attributeVOList);
		//先判断表格是否存在
		if (!checkTableExistByTableName(tableName)) {
			OmdBtmTypeAttributeVO attributeVO = attributeVOList.get(0);
			createDbTables(attributeVO.getPkBtmType());
		} else {
			ddlMapper.addColumn2TableBySql(tableName, attributeSql);
			commentColumnsForTable(tableName, attributeVOList);
		}
	}

	/**
	 * 添加属性字段到链接类型中，注意在执行这个方法时就会将以前的事务提交。
	 *
	 * @param addAttrDOListForLinkType 需要添加的属性对象
	 * @throws VciBaseException 执行出错的时候会抛出异常
	 */
	@Override
	public void addColumn2TableForLink(List<OsLinkTypeAttributeVO> addAttrDOListForLinkType) throws VciBaseException {

	}

	/**
	 * 判断表中是否有数据
	 *
	 * @param tableName 表格的名称
	 * @return true表示有数据，false表示没有数据，或者这个表格不存在的时候抛出异常
	 * @throws VciBaseException 参数错误的时候抛出异常
	 */
	@Override
	public boolean checkTableHasDataByTableName(String tableName) throws VciBaseException {
		try {
			int tableCount = ddlMapper.countAll(tableName);
			if (tableCount > 0) {
				return true;
			}
		} catch (Throwable e) {
			throw new VciBaseException("统计某个表是否含有数据出错，可能表不存在");
		}
		return false;
	}

	/**
	 * 创建视图
	 *
	 * @param viewCreateSql 视图的SQL语句
	 * @throws VciBaseException 参数错误或者执行错误的时候会抛出异常，执行错误主要包括SQL语句错误，没有权限等
	 */
	@Override
	public void createViewBySql(String viewCreateSql) throws VciBaseException {
		VciBaseUtil.alertNotNull(viewCreateSql, "视图的SQL");
		ddlMapper.createViewBySql(viewCreateSql);
	}

	/**
	 * 删除表格或者视图
	 *
	 * @param tableName 表格名称或者视图名称
	 * @throws VciBaseException 参数错误或者执行错误的时候会抛出异常
	 */
	@Override
	public void dropTableByName(String tableName) throws VciBaseException {
		VciBaseUtil.alertNotNull(tableName, "要删除的表的名称");
		ddlMapper.dropTable(tableName);
	}

	/**
	 * 删除表格的某一列
	 *
	 * @param tableName  表格名称
	 * @param columnName 列的名称
	 */
	@Override
	public void dropColumnByName(String tableName, String columnName) {
		VciBaseUtil.alertNotNull(tableName, "要删除的表的名称", columnName, "要删除的表字段名称");
		ddlMapper.dropTableColumn(tableName, columnName);
	}

	/**
	 * 校验业务类型或者链接类型的对应的表格是否存在
	 *
	 * @param pkBtmType 业务类型或者链接类型的表格
	 * @return true表示存在，false表示不存在
	 */
	@Override
	public boolean checkTableExist(String pkBtmType) {
		return checkTableExistByTableName(getTableNameByBtmTypeOid(pkBtmType));
	}

	/**
	 * 根据表格的名称判断表格是否存在
	 *
	 * @param tableName 表格名称
	 * @return rue表示存在，false表示不存在
	 */
	@Override
	public boolean checkTableExistByTableName(String tableName) {
		return ddlMapper.checkTableExist(tableName) > 0;
	}

	/**
	 * 校验业务类型或者链接类型所对应的表格是否存在
	 *
	 * @param id 业务类型或者链接类型的英文名称
	 * @return true表示存在，false表示不存在
	 */
	@Override
	public boolean checkTableExistById(String id) {
		return checkTableExistByTableName(getTableNameByBtmTypeId(id));
	}

	/**
	 * 获取数据库和业务类型中的不同的地方
	 *
	 * @param btmTypeVOList  业务类型对象，有属性时需要包含属性
	 * @param linkTypeVOList 链接类型对象，有属性时需要包含属性
	 * @return 不同的地方，每一个业务类型或者链接类型一条数据
	 */
	@Override
	public List<OsModifyAttributeInfoDO> checkDifferent(List<OmdBtmTypeVO> btmTypeVOList, List<OsLinkTypeVO> linkTypeVOList) throws VciBaseException {
		return null;
	}

	/**
	 * 清理业务类型中和数据库里不一样的
	 *
	 * @param differentAttributeList 不同的属性的列表
	 * @throws VciBaseException 参数为空或者执行出错的时候会抛出异常
	 */
	@Override
	public void reflexDifferent(List<OsModifyAttributeInfoDO> differentAttributeList) throws VciBaseException {

	}

	/**
	 * 获取数据库中所有的表格
	 *
	 * @return 表格的名称，全是大写
	 */
	@Override
	public List<String> listAllTableName() {
		return ddlMapper.selectAllTableName();
	}

	/**
	 * 查询数据库中的表格信息
	 *
	 * @param tableNamesCollections 数据库表名集合
	 * @return 在数据库中的信息
	 * @throws VciBaseException 参数为空或者数据库表不存在的时候会抛出异常
	 */
	@Override
	public List<DdlTableBO> listTableInfoInDB(Collection<String> tableNamesCollections) throws VciBaseException {
		VciBaseUtil.alertCollectionNotNull("数据库表名称不能为空", tableNamesCollections);
		List<DdlTableBO> tableBOList = new ArrayList<>();
		tableNamesCollections.stream().forEach(s -> {
			tableBOList.add(ddlMapper.selectTableComment(s));
		});
		return tableBOList;
	}

	/**
	 * 导出数据库中的表格信息到excel文件
	 *
	 * @param tableNamesCollections 表格名称的集合
	 * @param merge                 合并表格名称
	 * @return excel的文件名称
	 * @throws VciBaseException 蚕食为空或者数据库表不存在的时候会抛出异常
	 */
	@Override
	public String exportDataBase2File(Collection<String> tableNamesCollections, boolean merge) throws VciBaseException {
		return null;
	}

	/**
	 * 获取存储文件所需要的临时文件夹，文件夹上已经包含了
	 *
	 * @return 文件夹的地址，如果配置文件没有配置，则默认返回当前项目所在的文件夹
	 */
	@Override
	public String getTempFolder() {
		return null;
	}

	/**
	 * 导出数据库中的表格信息到word文件中
	 *
	 * @param tableNamesCollections 表格名称的集合
	 * @return word的文件名称
	 * @throws VciBaseException 蚕食为空或者数据库表不存在的时候会抛出异常
	 */
	@Override
	public String exportDataBase2Word(List<String> tableNamesCollections) throws VciBaseException {
		return null;
	}

	/**
	 * 拷贝数据到word模板中
	 *
	 * @param tableDataBO 要写入的数据
	 * @return word 文件路径
	 */
	@Override
	public String writeDataToWord(WordMergeStartTableDataBO tableDataBO) {
		return null;
	}

	/**
	 * 判断是否为兼容性的表，这些表不应该被创建和修改
	 *
	 * @param btmTypeId  业务类型的英文名称
	 * @param linkTypeId 业务类型的中文名称
	 * @return true 表示为兼容性的表，用户，角色，部门，权限这些
	 */
	@Override
	public boolean isCompatibilityTable(String btmTypeId, String linkTypeId) {
		return false;
	}

	/**
	 * 业务类型数据库新增或修改表
	 *
	 * @param dto 业务类型传输对象
	 * @return 执行结果
	 */
	@Override
	public R submitBtmType(OmdBtmTypeDTO dto) {
		VciBaseUtil.alertNotNull(dto, "业务类型", dto.getAttributesDTOList(), "业务类型属性");
		OmdBtmTypeVO btmTypeVO = Objects.requireNonNull(BeanUtil.copy(dto, OmdBtmTypeVO.class));
		if (Func.isNotBlank(dto.getTableName())) {
			checkModifyOrCreateTable(btmTypeVO);
		} else {
			if (checkTableExistById(dto.getId())) {
				String tableName = getTableNameByBtmTypeId(dto.getId());
				btmTypeVO.setTableName(tableName);
				checkModifyOrCreateTable(btmTypeVO);
			} else {
				String tableName = TABLE_PREFIX + StringPool.UNDERSCORE + dto.getDomain().toUpperCase(Locale.ROOT) + StringPool.UNDERSCORE + dto.getId().toUpperCase(Locale.ROOT);
				btmTypeVO.setTableName(tableName);
				createDbTableForBtm(btmTypeVO);
			}
		}
		return R.success("000000");
	}

	/**
	 * 检查业务类型的表是否存在，如果存在则比较差别进行修改，不存在则创建
	 *
	 * @param btmTypeVO 业务类型
	 */
	private void checkModifyOrCreateTable(OmdBtmTypeVO btmTypeVO) {
		if (checkTableExistByTableName(btmTypeVO.getTableName())) {
			// 表已存在，校验属性
			List<OmdBtmTypeVO> vos = new ArrayList<>();
			vos.add(btmTypeVO);
			List<OsModifyAttributeInfoDO> differentAttributeList = checkDifferent(vos, null);
			if (CollectionUtils.isEmpty(differentAttributeList)) {
				// 可以直接删除再创建
				dropTableByName(btmTypeVO.getTableName());
				createDbTableForBtm(btmTypeVO);
			} else {
				// TODO: 修改的暂时还没做
			}
		} else {
			createDbTableForBtm(btmTypeVO);
		}
	}

	/**
	 * 按表名获取表信息
	 *
	 * @param tableName 表名
	 * @return 表信息
	 */
	@Override
	public DdlTableBO getTableColumnByTableName(String tableName) {
		VciBaseUtil.alertNotNull(tableName,"表名");
		DdlTableBO tableBO = getTableInfoByTableName(tableName);
		List<DdlTableInDataBaseBO> columnInfo = selectTableColumnInfo(tableName);
		tableBO.setColumns(columnInfo);
		return tableBO;
	}

	/**
	 * 查询数据库中表格的字段信息
	 *
	 * @param tableName 表格的名称
	 * @return 数据库表的字段信息
	 */
	private List<DdlTableInDataBaseBO> selectTableColumnInfo(String tableName) {
		VciBaseUtil.alertNotNull(tableName, "表格名称");
		return ddlMapper.selectTableColumnInfo(tableName);
	}

	/**
	 * 表名获取表信息
	 * @param tableName 表名
	 * @return 表信息
	 */
	private DdlTableBO getTableInfoByTableName(String tableName){
		VciBaseUtil.alertNotNull(tableName, "表格名称");
		return ddlMapper.selectTableComment(tableName);
	}

	/**
	 * 获取所有表信息
	 *
	 * @return 表信息集合
	 */
	@Override
	public List<DdlTableBO> getAllTableInfo() {
		List<String> allTableName = listAllTableName();
		if (!CollectionUtils.isEmpty(allTableName)) {
			List<DdlTableBO> allTableBO = listTableInfoInDB(allTableName);
			allTableBO.forEach(table -> {
				table.setColumns(selectTableColumnInfo(table.getTableName()));
			});
			return allTableBO;
		}
		return new ArrayList<>();
	}
}