feat: Add LdapUsersAccountAsync (#1338)

src/Contracts/Masa.Auth.Contracts.Admin/Subjects/GetLdapUsersAccountDto.cs

@@ -0,0 +1,9 @@
+// Copyright (c) MASA Stack All rights reserved.
+// Licensed under the Apache License. See LICENSE.txt in the project root for license information.
+
+namespace Masa.Auth.Contracts.Admin.Subjects;
+
+public class GetLdapUsersAccountDto
+{
+    public List<Guid> UserIds { get; set; } = new();
+}

src/Services/Masa.Auth.Service.Admin/Application/Subjects/Queries/LdapUsersAccountQuery.cs

@@ -0,0 +1,9 @@
+// Copyright (c) MASA Stack All rights reserved.
+// Licensed under the Apache License. See LICENSE.txt in the project root for license information.
+
+namespace Masa.Auth.Service.Admin.Application.Subjects.Queries;
+
+public record LdapUsersAccountQuery(List<Guid> UserIds) : Query<Dictionary<Guid, string>>
+{
+    public override Dictionary<Guid, string> Result { get; set; } = new();
+}

src/Services/Masa.Auth.Service.Admin/Application/Subjects/QueryHandler.cs

@@ -795,4 +795,24 @@ public async Task GetImpersonatedUserAsync(ImpersonatedUserQuery query)
         query.Result = cacheItem;
         //await _distributedCacheClient.RemoveAsync(key);
     }
+
+    [EventHandler]
+    public async Task GetLdapUsersAccountAsync(LdapUsersAccountQuery query)
+    {
+        var identityProvider = await _authDbContext.Set<IdentityProvider>().FirstOrDefaultAsync(x => x.Name == "Ldap");
+        MasaArgumentException.ThrowIfNull(identityProvider, nameof(IdentityProvider));
+
+        var tpUsers = await _thirdPartyUserRepository.GetListAsync(x => x.ThirdPartyIdpId == identityProvider.Id && query.UserIds.Contains(x.UserId));
+
+        var options = new JsonSerializerOptions
+        {
+            PropertyNameCaseInsensitive = true
+        };
+
+        query.Result = tpUsers.ToDictionary(x => x.UserId, x =>
+        {
+            var ldapUser = JsonSerializer.Deserialize<LdapUser>(x.ExtendedData, options);
+            return ldapUser?.SamAccountName ?? string.Empty;
+        });
+    }
 }

src/Services/Masa.Auth.Service.Admin/Services/ThirdPartyUserService.cs

@@ -9,6 +9,7 @@ public ThirdPartyUserService() : base("api/thirdPartyUser")
     {
         MapGet(GetAsync, "");
         MapPost(RegisterAsync, "register");
+        MapPost(LdapUsersAccountAsync, "ldapUsersAccount");
     }
 
     private async Task<PaginationDto<ThirdPartyUserDto>> GetListAsync(IEventBus eventBus, GetThirdPartyUsersDto tpu)
@@ -92,4 +93,11 @@ private async Task RemoveByThridPartyIdentityAsync(IEventBus eventBus, [FromBody
     {
         await eventBus.PublishAsync(new RemoveThirdPartyUserByThridPartyIdentityCommand(dto.ThridPartyIdentity));
     }
+
+    private async Task<Dictionary<Guid, string>> LdapUsersAccountAsync(IEventBus eventBus, [FromBody] GetLdapUsersAccountDto dto)
+    {
+        var query = new LdapUsersAccountQuery(dto.UserIds);
+        await eventBus.PublishAsync(query);
+        return query.Result;
+    }
 }