332 lines
12 KiB
C#
332 lines
12 KiB
C#
using JNPF.Common.Core.Manager;
|
||
using JNPF.Common.Enums;
|
||
using JNPF.Common.Extension;
|
||
using JNPF.Common.Filter;
|
||
using JNPF.Common.Models;
|
||
using JNPF.Common.Security;
|
||
using JNPF.DependencyInjection;
|
||
using JNPF.DynamicApiController;
|
||
using JNPF.FriendlyException;
|
||
using JNPF.Systems.Entitys.Dto.DbLink;
|
||
using JNPF.Systems.Entitys.Permission;
|
||
using JNPF.Systems.Entitys.System;
|
||
using JNPF.Systems.Interfaces.System;
|
||
using Mapster;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using Microsoft.Extensions.Caching.Memory;
|
||
using SqlSugar;
|
||
|
||
namespace JNPF.Systems;
|
||
|
||
/// <summary>
|
||
/// 数据连接
|
||
/// 版 本：V3.2
|
||
/// 版 权：拓通智联科技有限公司（http://www.tuotong-tech.com）
|
||
/// 日 期：2021-06-01.
|
||
/// </summary>
|
||
[ApiDescriptionSettings(Tag = "System", Name = "DataSource", Order = 205)]
|
||
[Route("api/system/[controller]")]
|
||
public class DbLinkService : IDbLinkService, IDynamicApiController, ITransient
|
||
{
|
||
/// <summary>
|
||
/// 服务基础仓储.
|
||
/// </summary>
|
||
private readonly ISqlSugarRepository<DbLinkEntity> _repository;
|
||
|
||
/// <summary>
|
||
/// 数据字典服务.
|
||
/// </summary>
|
||
private readonly IDictionaryDataService _dictionaryDataService;
|
||
|
||
/// <summary>
|
||
/// 数据库管理.
|
||
/// </summary>
|
||
private readonly IDataBaseManager _dataBaseManager;
|
||
|
||
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())
|
||
{
|
||
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 = "-1",
|
||
parentId = "0",
|
||
fullName = "未分类",
|
||
num = data.FindAll(x => x.parentId == null).Count
|
||
});
|
||
|
||
foreach (var item in dbTypeList)
|
||
{
|
||
var index = data.FindAll(x => x.dbType.Equals(item.EnCode)).Count;
|
||
if (index > 0)
|
||
{
|
||
output.Add(new DbLinkSelectorOutput()
|
||
{
|
||
id = item.Id,
|
||
fullName = item.FullName
|
||
});
|
||
}
|
||
}
|
||
|
||
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()
|
||
{
|
||
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)
|
||
{
|
||
//modified by ly on 20230417
|
||
var model = await _repository.AsSugarClient().CopyNew().Queryable<DbLinkEntity>().FirstAsync(m => m.Id == id && m.DeleteMark == null);
|
||
//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
|
||
} |