|
|
@@ -14,11 +14,21 @@ namespace Admin.NET.Core;
|
|
|
[ApiDescriptionSettings(Order = 496)]
|
|
|
public class SysLdapService : IDynamicApiController, ITransient
|
|
|
{
|
|
|
- private readonly SqlSugarRepository<SysLdap> _sysLdapRep;
|
|
|
+ private readonly ISqlSugarClient _db;
|
|
|
+ private SqlSugarRepository<SysLdap> sysLdapRep = null;
|
|
|
|
|
|
- public SysLdapService(SqlSugarRepository<SysLdap> sysLdapRep)
|
|
|
+ public SysLdapService(ISqlSugarClient db)
|
|
|
{
|
|
|
- _sysLdapRep = sysLdapRep;
|
|
|
+ _db = db;
|
|
|
+ }
|
|
|
+
|
|
|
+ public SqlSugarRepository<SysLdap> SysLdapRep
|
|
|
+ {
|
|
|
+ get
|
|
|
+ {
|
|
|
+ sysLdapRep ??= _db.GetRepository<SqlSugarRepository<SysLdap>>();
|
|
|
+ return sysLdapRep;
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
@@ -29,7 +39,7 @@ public class SysLdapService : IDynamicApiController, ITransient
|
|
|
[DisplayName("获取系统域登录配置分页列表")]
|
|
|
public async Task<SqlSugarPagedList<SysLdap>> Page(SysLdapInput input)
|
|
|
{
|
|
|
- return await _sysLdapRep.AsQueryable()
|
|
|
+ return await SysLdapRep.AsQueryable()
|
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u => u.Host.Contains(input.SearchKey.Trim()))
|
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Host), u => u.Host.Contains(input.Host.Trim()))
|
|
|
.OrderBy(u => u.CreateTime, OrderByType.Desc)
|
|
|
@@ -47,7 +57,7 @@ public class SysLdapService : IDynamicApiController, ITransient
|
|
|
{
|
|
|
var entity = input.Adapt<SysLdap>();
|
|
|
entity.BindPass = CryptogramUtil.Encrypt(input.BindPass);
|
|
|
- await _sysLdapRep.InsertAsync(entity);
|
|
|
+ await SysLdapRep.InsertAsync(entity);
|
|
|
return entity.Id;
|
|
|
}
|
|
|
|
|
|
@@ -66,7 +76,7 @@ public class SysLdapService : IDynamicApiController, ITransient
|
|
|
entity.BindPass = CryptogramUtil.Encrypt(input.BindPass); // 加密
|
|
|
}
|
|
|
|
|
|
- await _sysLdapRep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
|
|
+ await SysLdapRep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
@@ -78,8 +88,8 @@ public class SysLdapService : IDynamicApiController, ITransient
|
|
|
[DisplayName("删除系统域登录配置")]
|
|
|
public async Task Delete(DeleteSysLdapInput input)
|
|
|
{
|
|
|
- var entity = await _sysLdapRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
|
|
- await _sysLdapRep.FakeDeleteAsync(entity); // 假删除
|
|
|
+ var entity = await SysLdapRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
|
|
+ await SysLdapRep.FakeDeleteAsync(entity); // 假删除
|
|
|
//await _rep.DeleteAsync(entity); // 真删除
|
|
|
}
|
|
|
|
|
|
@@ -91,7 +101,7 @@ public class SysLdapService : IDynamicApiController, ITransient
|
|
|
[DisplayName("获取系统域登录配置详情")]
|
|
|
public async Task<SysLdap> GetDetail([FromQuery] DetailSysLdapInput input)
|
|
|
{
|
|
|
- return await _sysLdapRep.GetFirstAsync(u => u.Id == input.Id);
|
|
|
+ return await SysLdapRep.GetFirstAsync(u => u.Id == input.Id);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
@@ -101,7 +111,7 @@ public class SysLdapService : IDynamicApiController, ITransient
|
|
|
[DisplayName("获取系统域登录配置列表")]
|
|
|
public async Task<List<SysLdap>> GetList()
|
|
|
{
|
|
|
- return await _sysLdapRep.AsQueryable().Select<SysLdap>().ToListAsync();
|
|
|
+ return await SysLdapRep.AsQueryable().Select<SysLdap>().ToListAsync();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
@@ -114,7 +124,7 @@ public class SysLdapService : IDynamicApiController, ITransient
|
|
|
[NonAction]
|
|
|
public async Task<bool> AuthAccount(long tenantId, string account, string password)
|
|
|
{
|
|
|
- var sysLdap = await _sysLdapRep.GetFirstAsync(u => u.TenantId == tenantId) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
|
|
+ var sysLdap = await SysLdapRep.GetFirstAsync(u => u.TenantId == tenantId) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
|
|
var ldapConn = new LdapConnection();
|
|
|
try
|
|
|
{
|
|
|
@@ -162,7 +172,7 @@ public class SysLdapService : IDynamicApiController, ITransient
|
|
|
[DisplayName("同步域用户")]
|
|
|
public async Task SyncUser(SyncSysLdapInput input)
|
|
|
{
|
|
|
- var sysLdap = await _sysLdapRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
|
|
+ var sysLdap = await SysLdapRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
|
|
var ldapConn = new LdapConnection();
|
|
|
try
|
|
|
{
|
|
|
@@ -294,7 +304,7 @@ public class SysLdapService : IDynamicApiController, ITransient
|
|
|
[DisplayName("同步域组织")]
|
|
|
public async Task SyncDept(SyncSysLdapInput input)
|
|
|
{
|
|
|
- var sysLdap = await _sysLdapRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
|
|
+ var sysLdap = await SysLdapRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
|
|
var ldapConn = new LdapConnection();
|
|
|
try
|
|
|
{
|