wenkai.chen/tnb.server
Template
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

解决异步查询时，异常

Browse Source
This commit is contained in:
DEVICE8\12494
2023-03-30 09:43:27 +08:00
parent f9e3a01602
commit 401b717fc2
1 changed files with 283 additions and 283 deletions
Download Patch File Download Diff File Expand all files Collapse all files

566
system/Tnb.Systems/System/DbLinkService.cs
View File

@@ -28,303 +28,303 @@ namespace JNPF.Systems;
[Route("api/system/[controller]")]
public class DbLinkService : IDbLinkService, IDynamicApiController, ITransient
{
/// <summary>
/// 服务基础仓储.
/// </summary>
private readonly ISqlSugarRepository<DbLinkEntity> _repository;
/// <summary>
/// 服务基础仓储.
/// </summary>
private readonly ISqlSugarRepository<DbLinkEntity> _repository;
/// <summary>
/// 数据字典服务.
/// </summary>
private readonly IDictionaryDataService _dictionaryDataService;
/// <summary>
/// 数据字典服务.
/// </summary>
private readonly IDictionaryDataService _dictionaryDataService;
/// <summary>
/// 数据库管理.
/// </summary>
private readonly IDataBaseManager _dataBaseManager;
/// <summary>
/// 数据库管理.
/// </summary>
private readonly IDataBaseManager _dataBaseManager;
private readonly IMemoryCache _memCache;
private readonly IMemoryCache _memCache;
/// <summary>
/// 初始化一个<see cref="DbLinkService"/>类型的新实例.
/// </summary>
public DbLinkService(
ISqlSugarRepository<DbLinkEntity> repository,
IDictionaryDataService dictionaryDataService,
IDataBaseManager dataBaseManager,
IMemoryCache memCache)
{
_repository = repository;
_dictionaryDataService = dictionaryDataService;
_dataBaseManager = dataBaseManager;
_memCache = memCache;
}
#region GET
/// <summary>
/// 列表.
/// </summary>
/// <returns></returns>
[HttpGet("")]
public async Task<dynamic> GetList([FromQuery] DbLinkListInput input)
{
var list = await _repository.AsSugarClient().Queryable<DbLinkEntity, UserEntity, UserEntity>(
(a, b, c) => new JoinQueryInfos(JoinType.Left, a.CreatorUserId == b.Id, JoinType.Left, a.LastModifyUserId == c.Id))
.Where((a, b, c) => a.DeleteMark == null)
.WhereIF(input.dbType.IsNotEmptyOrNull(), (a, b, c) => a.DbType == input.dbType)
.WhereIF(input.keyword.IsNotEmptyOrNull(), (a, b, c) => a.FullName.Contains(input.keyword))
.Select((a, b, c) => new DbLinkListOutput()
{
id = a.Id,
creatorTime = a.CreatorTime,
creatorUser = SqlFunc.MergeString(b.RealName, "/", b.Account),
dbType = a.DbType,
enabledMark = a.EnabledMark,
fullName = a.FullName,
host = a.Host,
lastModifyTime = a.LastModifyTime,
lastModifyUser = SqlFunc.MergeString(c.RealName, "/", c.Account),
port = a.Port.ToString(),
sortCode = a.SortCode
}).Distinct().MergeTable().OrderBy((a) => a.sortCode).OrderBy((a) => a.creatorTime, OrderByType.Desc).ToPagedListAsync(input.currentPage, input.pageSize);
return PageResult<DbLinkListOutput>.SqlSugarPageResult(list);
}
/// <summary>
/// 下拉框列表.
/// </summary>
/// <returns></returns>
[HttpGet("Selector")]
public async Task<dynamic> GetSelector([FromQuery] string type)
{
var data = (await GetList()).Adapt<List<DbLinkSelectorOutput>>();
// 数据库分类
var dbTypeList = (await _dictionaryDataService.GetList("dbType")).FindAll(x => x.EnabledMark == 1);
var output = new List<DbLinkSelectorOutput>();
if (type.IsNullOrEmpty())
/// <summary>
/// 初始化一个<see cref="DbLinkService"/>类型的新实例.
/// </summary>
public DbLinkService(
ISqlSugarRepository<DbLinkEntity> repository,
IDictionaryDataService dictionaryDataService,
IDataBaseManager dataBaseManager,
IMemoryCache memCache)
{
output.Add(new DbLinkSelectorOutput()
{
id = "-2",
parentId = "0",
fullName = "",
num = data.FindAll(x => x.parentId == null).Count
});
var defaultDBType = App.GetConfig<ConnectionStringsOptions>("ConnectionStrings", true).DBType;
if (defaultDBType.Equals("Kdbndp"))
{
defaultDBType = "KingbaseES";
}
if (defaultDBType.Equals("Dm"))
{
defaultDBType = "DM8";
}
output.Add(new DbLinkSelectorOutput()
{
id = "0",
parentId = "-2",
fullName = "默认数据库",
dbType = defaultDBType,
num = 1
});
_repository = repository;
_dictionaryDataService = dictionaryDataService;
_dataBaseManager = dataBaseManager;
_memCache = memCache;
}
output.Add(new DbLinkSelectorOutput()
{
id = "-1",
parentId = "0",
fullName = "未分类",
num = data.FindAll(x => x.parentId == null).Count
});
#region GET
foreach (var item in dbTypeList)
/// <summary>
/// 列表.
/// </summary>
/// <returns></returns>
[HttpGet("")]
public async Task<dynamic> GetList([FromQuery] DbLinkListInput input)
{
var index = data.FindAll(x => x.dbType.Equals(item.EnCode)).Count;
if (index > 0)
{
var list = await _repository.AsSugarClient().Queryable<DbLinkEntity, UserEntity, UserEntity>(
(a, b, c) => new JoinQueryInfos(JoinType.Left, a.CreatorUserId == b.Id, JoinType.Left, a.LastModifyUserId == c.Id))
.Where((a, b, c) => a.DeleteMark == null)
.WhereIF(input.dbType.IsNotEmptyOrNull(), (a, b, c) => a.DbType == input.dbType)
.WhereIF(input.keyword.IsNotEmptyOrNull(), (a, b, c) => a.FullName.Contains(input.keyword))
.Select((a, b, c) => new DbLinkListOutput()
{
id = a.Id,
creatorTime = a.CreatorTime,
creatorUser = SqlFunc.MergeString(b.RealName, "/", b.Account),
dbType = a.DbType,
enabledMark = a.EnabledMark,
fullName = a.FullName,
host = a.Host,
lastModifyTime = a.LastModifyTime,
lastModifyUser = SqlFunc.MergeString(c.RealName, "/", c.Account),
port = a.Port.ToString(),
sortCode = a.SortCode
}).Distinct().MergeTable().OrderBy((a) => a.sortCode).OrderBy((a) => a.creatorTime, OrderByType.Desc).ToPagedListAsync(input.currentPage, input.pageSize);
return PageResult<DbLinkListOutput>.SqlSugarPageResult(list);
}
/// <summary>
/// 下拉框列表.
/// </summary>
/// <returns></returns>
[HttpGet("Selector")]
public async Task<dynamic> GetSelector([FromQuery] string type)
{
var data = (await GetList()).Adapt<List<DbLinkSelectorOutput>>();
// 数据库分类
var dbTypeList = (await _dictionaryDataService.GetList("dbType")).FindAll(x => x.EnabledMark == 1);
var output = new List<DbLinkSelectorOutput>();
if (type.IsNullOrEmpty())
{
output.Add(new DbLinkSelectorOutput()
{
id = "-2",
parentId = "0",
fullName = "",
num = data.FindAll(x => x.parentId == null).Count
});
var defaultDBType = App.GetConfig<ConnectionStringsOptions>("ConnectionStrings", true).DBType;
if (defaultDBType.Equals("Kdbndp"))
{
defaultDBType = "KingbaseES";
}
if (defaultDBType.Equals("Dm"))
{
defaultDBType = "DM8";
}
output.Add(new DbLinkSelectorOutput()
{
id = "0",
parentId = "-2",
fullName = "默认数据库",
dbType = defaultDBType,
num = 1
});
}
output.Add(new DbLinkSelectorOutput()
{
id = item.Id,
fullName = item.FullName
id = "-1",
parentId = "0",
fullName = "未分类",
num = data.FindAll(x => x.parentId == null).Count
});
}
}
return new { list = output.Union(data).ToList().ToTree() };
}
/// <summary>
/// 信息.
/// </summary>
/// <param name="id">主键值.</param>
/// <returns></returns>
[HttpGet("{id}")]
public async Task<dynamic> GetInfo_Api(string id)
{
var data = await GetInfo(id);
var oracleParam = data.OracleParam?.ToObject<OracleParamModel>();
var output = data.Adapt<DbLinkInfoOutput>();
if (oracleParam.IsNotEmptyOrNull() && oracleParam.oracleExtend)
{
output.oracleService = oracleParam.oracleService;
output.oracleExtend = oracleParam.oracleExtend;
output.oracleLinkType = oracleParam.oracleLinkType;
output.oracleRole = oracleParam.oracleRole;
}
return output;
}
#endregion
#region POST
/// <summary>
/// 删除.
/// </summary>
/// <param name="id">主键值.</param>
/// <returns></returns>
[HttpDelete("{id}")]
public async Task Delete(string id)
{
var entity = await GetInfo(id);
_ = entity ?? throw Oops.Oh(ErrorCode.COM1005);
var isOk = await _repository.AsUpdateable(entity).CallEntityMethod(m => m.Delete()).UpdateColumns(it => new { it.DeleteMark, it.DeleteTime, it.DeleteUserId }).ExecuteCommandHasChangeAsync();
if (!isOk)
throw Oops.Oh(ErrorCode.COM1002);
}
/// <summary>
/// 创建.
/// </summary>
/// <param name="input">实体对象.</param>
/// <returns></returns>
[HttpPost("")]
public async Task Create_Api([FromBody] DbLinkCrInput input)
{
if (await _repository.IsAnyAsync(x => x.FullName == input.fullName && x.DeleteMark == null))
throw Oops.Oh(ErrorCode.COM1004);
var entity = input.Adapt<DbLinkEntity>();
if (input.oracleExtend)
{
entity.OracleParam = new OracleParamModel()
{
oracleExtend = input.oracleExtend,
oracleRole = input.oracleRole,
oracleLinkType = input.oracleLinkType,
oracleService = input.oracleService
}.ToJsonString();
}
var isOk = await _repository.AsInsertable(entity).IgnoreColumns(ignoreNullColumn: true).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
if (isOk < 1)
throw Oops.Oh(ErrorCode.COM1000);
}
/// <summary>
/// 编辑.
/// </summary>
/// <param name="id">主键值.</param>
/// <param name="input">实体对象.</param>
/// <returns></returns>
[HttpPut("{id}")]
public async Task Update_Api(string id, [FromBody] DbLinkUpInput input)
{
if (await _repository.IsAnyAsync(x => x.Id != id && x.FullName == input.fullName && x.DeleteMark == null))
throw Oops.Oh(ErrorCode.COM1004);
var entity = input.Adapt<DbLinkEntity>();
if (input.oracleExtend)
{
entity.OracleParam = new OracleParamModel()
{
oracleExtend = input.oracleExtend,
oracleRole = input.oracleRole,
oracleLinkType = input.oracleLinkType,
oracleService = input.oracleService
}.ToJsonString();
}
var isOk = await _repository.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandHasChangeAsync();
if (!isOk)
throw Oops.Oh(ErrorCode.COM1001);
}
/// <summary>
/// 测试连接.
/// </summary>
/// <param name="input">实体对象.</param>
[HttpPost("Actions/Test")]
public void TestDbConnection([FromBody] DbLinkActionsTestInput input)
{
var entity = input.Adapt<DbLinkEntity>();
entity.Id = input.id.Equals("0") ? SnowflakeIdHelper.NextId() : input.id;
if (input.oracleExtend)
{
entity.OracleParam = new OracleParamModel()
{
oracleExtend = input.oracleExtend,
oracleRole = input.oracleRole,
oracleLinkType = input.oracleLinkType,
oracleService = input.oracleService
}.ToJsonString();
}
if (!_dataBaseManager.IsConnection(entity))
throw Oops.Oh(ErrorCode.D1507);
}
#endregion
#region PublicMethod
/// <summary>
/// 列表.
/// </summary>
/// <returns></returns>
[NonAction]
public async Task<List<DbLinkListOutput>> GetList()
{
return await _repository.AsSugarClient().Queryable<DbLinkEntity, UserEntity, UserEntity, DictionaryDataEntity, DictionaryTypeEntity>(
(a, b, c, d, e) => new JoinQueryInfos(
JoinType.Left, a.CreatorUserId == b.Id,
JoinType.Left, a.LastModifyUserId == c.Id,
JoinType.Left, a.DbType == d.EnCode && d.DeleteMark == null,
JoinType.Left, d.DictionaryTypeId == e.Id && e.EnCode == "dbType"))
.Where((a, b, c) => a.DeleteMark == null)
.OrderBy((a, b, c) => a.SortCode).OrderBy((a, b, c) => a.CreatorTime, OrderByType.Desc).
Select((a, b, c, d) => new DbLinkListOutput()
foreach (var item in dbTypeList)
{
var index = data.FindAll(x => x.dbType.Equals(item.EnCode)).Count;
if (index > 0)
{
id = a.Id,
parentId = d.Id == null ? "-1" : d.Id,
creatorTime = a.CreatorTime,
creatorUser = SqlFunc.MergeString(b.RealName, "/", b.Account),
dbType = a.DbType,
enabledMark = a.EnabledMark,
fullName = a.FullName,
host = a.Host,
lastModifyTime = a.LastModifyTime,
lastModifyUser = SqlFunc.MergeString(c.RealName, "/", c.Account),
port = SqlFunc.ToString(a.Port),
sortCode = a.SortCode
}).Distinct().ToListAsync();
}
output.Add(new DbLinkSelectorOutput()
{
id = item.Id,
fullName = item.FullName
});
}
}
/// <summary>
/// 信息.
/// </summary>
/// <param name="id">主键值.</param>
/// <returns></returns>
[NonAction]
public async Task<DbLinkEntity> GetInfo(string id)
{
var model = await _memCache.GetOrCreateAsync($"DbLink_{id}", async entry =>
return new { list = output.Union(data).ToList().ToTree() };
}
/// <summary>
/// 信息.
/// </summary>
/// <param name="id">主键值.</param>
/// <returns></returns>
[HttpGet("{id}")]
public async Task<dynamic> GetInfo_Api(string id)
{
//entry.AbsoluteExpiration = DateTime.Now.AddMinutes(60);
entry.SlidingExpiration = TimeSpan.FromSeconds(60);
return await _repository.GetFirstAsync(m => m.Id == id && m.DeleteMark == null);
});
return model;
}
#endregion
var data = await GetInfo(id);
var oracleParam = data.OracleParam?.ToObject<OracleParamModel>();
var output = data.Adapt<DbLinkInfoOutput>();
if (oracleParam.IsNotEmptyOrNull() && oracleParam.oracleExtend)
{
output.oracleService = oracleParam.oracleService;
output.oracleExtend = oracleParam.oracleExtend;
output.oracleLinkType = oracleParam.oracleLinkType;
output.oracleRole = oracleParam.oracleRole;
}
return output;
}
#endregion
#region POST
/// <summary>
/// 删除.
/// </summary>
/// <param name="id">主键值.</param>
/// <returns></returns>
[HttpDelete("{id}")]
public async Task Delete(string id)
{
var entity = await GetInfo(id);
_ = entity ?? throw Oops.Oh(ErrorCode.COM1005);
var isOk = await _repository.AsUpdateable(entity).CallEntityMethod(m => m.Delete()).UpdateColumns(it => new { it.DeleteMark, it.DeleteTime, it.DeleteUserId }).ExecuteCommandHasChangeAsync();
if (!isOk)
throw Oops.Oh(ErrorCode.COM1002);
}
/// <summary>
/// 创建.
/// </summary>
/// <param name="input">实体对象.</param>
/// <returns></returns>
[HttpPost("")]
public async Task Create_Api([FromBody] DbLinkCrInput input)
{
if (await _repository.IsAnyAsync(x => x.FullName == input.fullName && x.DeleteMark == null))
throw Oops.Oh(ErrorCode.COM1004);
var entity = input.Adapt<DbLinkEntity>();
if (input.oracleExtend)
{
entity.OracleParam = new OracleParamModel()
{
oracleExtend = input.oracleExtend,
oracleRole = input.oracleRole,
oracleLinkType = input.oracleLinkType,
oracleService = input.oracleService
}.ToJsonString();
}
var isOk = await _repository.AsInsertable(entity).IgnoreColumns(ignoreNullColumn: true).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
if (isOk < 1)
throw Oops.Oh(ErrorCode.COM1000);
}
/// <summary>
/// 编辑.
/// </summary>
/// <param name="id">主键值.</param>
/// <param name="input">实体对象.</param>
/// <returns></returns>
[HttpPut("{id}")]
public async Task Update_Api(string id, [FromBody] DbLinkUpInput input)
{
if (await _repository.IsAnyAsync(x => x.Id != id && x.FullName == input.fullName && x.DeleteMark == null))
throw Oops.Oh(ErrorCode.COM1004);
var entity = input.Adapt<DbLinkEntity>();
if (input.oracleExtend)
{
entity.OracleParam = new OracleParamModel()
{
oracleExtend = input.oracleExtend,
oracleRole = input.oracleRole,
oracleLinkType = input.oracleLinkType,
oracleService = input.oracleService
}.ToJsonString();
}
var isOk = await _repository.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandHasChangeAsync();
if (!isOk)
throw Oops.Oh(ErrorCode.COM1001);
}
/// <summary>
/// 测试连接.
/// </summary>
/// <param name="input">实体对象.</param>
[HttpPost("Actions/Test")]
public void TestDbConnection([FromBody] DbLinkActionsTestInput input)
{
var entity = input.Adapt<DbLinkEntity>();
entity.Id = input.id.Equals("0") ? SnowflakeIdHelper.NextId() : input.id;
if (input.oracleExtend)
{
entity.OracleParam = new OracleParamModel()
{
oracleExtend = input.oracleExtend,
oracleRole = input.oracleRole,
oracleLinkType = input.oracleLinkType,
oracleService = input.oracleService
}.ToJsonString();
}
if (!_dataBaseManager.IsConnection(entity))
throw Oops.Oh(ErrorCode.D1507);
}
#endregion
#region PublicMethod
/// <summary>
/// 列表.
/// </summary>
/// <returns></returns>
[NonAction]
public async Task<List<DbLinkListOutput>> GetList()
{
return await _repository.AsSugarClient().Queryable<DbLinkEntity, UserEntity, UserEntity, DictionaryDataEntity, DictionaryTypeEntity>(
(a, b, c, d, e) => new JoinQueryInfos(
JoinType.Left, a.CreatorUserId == b.Id,
JoinType.Left, a.LastModifyUserId == c.Id,
JoinType.Left, a.DbType == d.EnCode && d.DeleteMark == null,
JoinType.Left, d.DictionaryTypeId == e.Id && e.EnCode == "dbType"))
.Where((a, b, c) => a.DeleteMark == null)
.OrderBy((a, b, c) => a.SortCode).OrderBy((a, b, c) => a.CreatorTime, OrderByType.Desc).
Select((a, b, c, d) => new DbLinkListOutput()
{
id = a.Id,
parentId = d.Id == null ? "-1" : d.Id,
creatorTime = a.CreatorTime,
creatorUser = SqlFunc.MergeString(b.RealName, "/", b.Account),
dbType = a.DbType,
enabledMark = a.EnabledMark,
fullName = a.FullName,
host = a.Host,
lastModifyTime = a.LastModifyTime,
lastModifyUser = SqlFunc.MergeString(c.RealName, "/", c.Account),
port = SqlFunc.ToString(a.Port),
sortCode = a.SortCode
}).Distinct().ToListAsync();
}
/// <summary>
/// 信息.
/// </summary>
/// <param name="id">主键值.</param>
/// <returns></returns>
[NonAction]
public async Task<DbLinkEntity> GetInfo(string id)
{
var model = await _memCache.GetOrCreateAsync($"DbLink_{id}", async entry =>
{
//entry.AbsoluteExpiration = DateTime.Now.AddMinutes(60);
//entry.SlidingExpiration = TimeSpan.FromSeconds(-1);
return await _repository.AsSugarClient().CopyNew().Queryable<DbLinkEntity>().FirstAsync(m => m.Id == id && m.DeleteMark == null);
});
return model;
}
#endregion
}