资产展示

master
Yueng 2024-09-05 17:54:03 +08:00
parent 0bf8e8962b
commit d6c96d5ec5
3 changed files with 2 additions and 114 deletions

View File

@ -120,15 +120,7 @@ public class DataRunNameController {
return success(list);
}
/**
*
* @return
*/
@PostMapping("/extractDataTableNames")
public Result extractDataTableNames(@RequestBody AssetAuthorization assetAuthorization){
List<TableNames> list = dataRunNameService.extractDataTableNames(assetAuthorization);
return success(list);
}
/**
*

View File

@ -67,15 +67,9 @@ public interface DataRunNameService {
*/
List<SysDept> selectDeptList(SysDept dept);
/**
*
* @return
*/
List<TableNames> extractDataTableNames(AssetAuthorization assetAuthorization);
/**
*
* @param req
* @param authorization
* @return
*/
boolean addUserAssetAuthorization(AssetAuthorization authorization);

View File

@ -442,104 +442,6 @@ public class DataRunNameServiceImpl implements DataRunNameService {
return dataRunNameMapper.selectDeptList(dept);
}
/**
*
* @return
*/
@Override
public List<TableNames> extractDataTableNames(AssetAuthorization assetAuthorization) {
HashSet<TableNames> hashSet = new HashSet<>();
tableIdAndBasicIdByUserId.forEach(assetAuthorization1 -> {
//获取资产信息中的基本ID
Integer basicId = assetAuthorization1.getBasicId();
//获取资产信息中的表ID
Integer tableId = assetAuthorization1.getTableId();
//如果当前表ID主键不为空则进行查询
if (null != tableId) {
//调用服务方法根据表ID获取TableInfo对象
TableNames tableInfoById = tableRunNameService.getById(tableId);
//将查询到的TableInfo对象添加到HashSet集合中
hashSet.add(tableInfoById);
//获取TableInfo对象的父ID
Integer parentId = tableInfoById.getId();
//如果父ID不为空则根据父ID查询父TableInfo对象
TableNames tableInfoByIdParentId = tableRunNameService.getById(parentId);
//将父TableInfo对象添加到HashSet集合中
hashSet.add(tableInfoByIdParentId);
}
hashSet.forEach(tableNames -> {
HashSet<TableFie> tableFies = new HashSet<>();
//如果基本原来表的ID不为空则进行查询
if (null != basicId) {
//创建一个LambdaQueryWrapper用于构建查询条件
LambdaQueryWrapper<TableFie> queryWrapper = new LambdaQueryWrapper<>();
//添加查询条件筛选出基本ID等于当前基本ID的TableInfo对象
queryWrapper.eq(TableFie::getId, basicId);
//调用服务方法获取符合条件的TableInfo列表
List<TableFie> tableInfoBasicIdList = tableFieldService.list(queryWrapper);
//将查询结果添加到HashSet集合中
tableFies.addAll(tableInfoBasicIdList);
ArrayList<TableFie> fieArrayList = new ArrayList<>();
fieArrayList.addAll(tableFies);
tableNames.setTableFie(fieArrayList);
}
});
});
//遍历包含用户授权信息的集合这个集合可能是根据部门ID获取的
idByDeptId.forEach(assetAuthorization1 -> {
//获取资产信息中的基本ID
Integer basicId = assetAuthorization1.getBasicId();
//获取资产信息中的表ID
Integer tableId = assetAuthorization1.getTableId();
//如果当前表ID主键不为空则进行查询
if (null != tableId) {
//调用服务方法根据表ID获取TableInfo对象
TableNames tableInfoById = tableRunNameService.getById(tableId);
//将查询到的TableInfo对象添加到HashSet集合中
hashSet.add(tableInfoById);
//获取TableInfo对象的父ID
Integer parentId = tableInfoById.getId();
//如果父ID不为空则根据父ID查询父TableInfo对象
TableNames tableInfoByIdParentId = tableRunNameService.getById(parentId);
//将父TableInfo对象添加到HashSet集合中
hashSet.add(tableInfoByIdParentId);
}
hashSet.forEach(tableNames -> {
HashSet<TableFie> tableFies = new HashSet<>();
//如果基本原来表的ID不为空则进行查询
if (null != basicId) {
//创建一个LambdaQueryWrapper用于构建查询条件
LambdaQueryWrapper<TableFie> queryWrapper = new LambdaQueryWrapper<>();
//添加查询条件筛选出基本ID等于当前基本ID的TableInfo对象
queryWrapper.eq(TableFie::getId, basicId);
//调用服务方法获取符合条件的TableInfo列表
List<TableFie> tableInfoBasicIdList = tableFieldService.list(queryWrapper);
//将查询结果添加到HashSet集合中
tableFies.addAll(tableInfoBasicIdList);
ArrayList<TableFie> fieArrayList = new ArrayList<>();
fieArrayList.addAll(tableFies);
tableNames.setTableFie(fieArrayList);
}
});
});
List<TableNames> list = hashSet.stream().filter(tableNames -> tableNames.getId() == 0)
.map(tableNames -> {
tableNames.tableNamesBuild(tableNames);
ArrayList<TableFie> tableFie = tableNames.getTableFie();
tableFie.stream().filter(tableFie1 -> tableFie1.getId() == 0)
.map(tableFie1 -> {
return tableFie1.customerBuildName(tableFie1);
});
return tableNames;
})
.toList();
return list;
}
/**
*
* @param authorization