The GetMembersCount method add filter

modules/identity/src/Volo.Abp.Identity.Domain/Volo/Abp/Identity/IOrganizationUnitRepository.cs

@@ -67,6 +67,7 @@ namespace Volo.Abp.Identity
 
         Task<int> GetMembersCountAsync(
             OrganizationUnit organizationUnit,
+            string filter = null,
             CancellationToken cancellationToken = default
         );
 

modules/identity/src/Volo.Abp.Identity.EntityFrameworkCore/Volo/Abp/Identity/EntityFrameworkCore/EfCoreOrganizationUnitRepository.cs

@@ -121,33 +121,19 @@ namespace Volo.Abp.Identity.EntityFrameworkCore
             CancellationToken cancellationToken = default
             )
         {
-            var query = from userOu in DbContext.Set<IdentityUserOrganizationUnit>()
-                        join user in DbContext.Users.IncludeDetails(includeDetails) on userOu.UserId equals user.Id
-                        where userOu.OrganizationUnitId == organizationUnit.Id
-                        select user;
+            var query = CreateGetMembersFilteredQuery(organizationUnit, filter);
 
-            if (!filter.IsNullOrWhiteSpace())
-            {
-                query = query.Where(u =>
-                    u.UserName.Contains(filter) ||
-                    u.Email.Contains(filter) ||
-                    (u.PhoneNumber != null && u.PhoneNumber.Contains(filter))
-                    );
-            }
-
-            return await query.OrderBy(sorting ?? nameof(IdentityUser.UserName))
+            return await query.IncludeDetails(includeDetails).OrderBy(sorting ?? nameof(IdentityUser.UserName))
                         .PageBy(skipCount, maxResultCount)
                         .ToListAsync(GetCancellationToken(cancellationToken));
         }
 
         public virtual async Task<int> GetMembersCountAsync(
             OrganizationUnit organizationUnit,
+            string filter = null,
             CancellationToken cancellationToken = default)
         {
-            var query = from userOu in DbContext.Set<IdentityUserOrganizationUnit>()
-                        join user in DbContext.Users on userOu.UserId equals user.Id
-                        where userOu.OrganizationUnitId == organizationUnit.Id
-                        select user;
+            var query = CreateGetMembersFilteredQuery(organizationUnit, filter);
 
             return await query.CountAsync(GetCancellationToken(cancellationToken));
         }
@@ -175,5 +161,24 @@ namespace Volo.Abp.Identity.EntityFrameworkCore
 
             DbContext.Set<IdentityUserOrganizationUnit>().RemoveRange(ouMembersQuery);
         }
+
+        protected virtual IQueryable<IdentityUser> CreateGetMembersFilteredQuery(OrganizationUnit organizationUnit, string filter = null)
+        {
+            var query = from userOu in DbContext.Set<IdentityUserOrganizationUnit>()
+                join user in DbContext.Users on userOu.UserId equals user.Id
+                where userOu.OrganizationUnitId == organizationUnit.Id
+                select user;
+
+            if (!filter.IsNullOrWhiteSpace())
+            {
+                query = query.Where(u =>
+                    u.UserName.Contains(filter) ||
+                    u.Email.Contains(filter) ||
+                    (u.PhoneNumber != null && u.PhoneNumber.Contains(filter))
+                );
+            }
+
+            return query;
+        }
     }
 }

modules/identity/src/Volo.Abp.Identity.MongoDB/Volo/Abp/Identity/MongoDB/MongoOrganizationUnitRepository.cs

@@ -116,15 +116,9 @@ namespace Volo.Abp.Identity.MongoDB
             bool includeDetails = false,
             CancellationToken cancellationToken = default)
         {
-            return await DbContext.Users.AsQueryable()
-                    .Where(u => u.OrganizationUnits.Any(uou => uou.OrganizationUnitId == organizationUnit.Id))
-                    .WhereIf<IdentityUser, IMongoQueryable<IdentityUser>>(
-                    !filter.IsNullOrWhiteSpace(),
-                    u =>
-                        u.UserName.Contains(filter) ||
-                        u.Email.Contains(filter) ||
-                        (u.PhoneNumber != null && u.PhoneNumber.Contains(filter))
-                )
+            var query = CreateGetMembersFilteredQuery(organizationUnit, filter);
+
+            return await query
                 .OrderBy(sorting ?? nameof(IdentityUser.UserName))
                 .As<IMongoQueryable<IdentityUser>>()
                 .PageBy<IdentityUser, IMongoQueryable<IdentityUser>>(skipCount, maxResultCount)
@@ -133,12 +127,12 @@ namespace Volo.Abp.Identity.MongoDB
 
         public virtual async Task<int> GetMembersCountAsync(
             OrganizationUnit organizationUnit,
+            string filter = null,
             CancellationToken cancellationToken = default)
         {
-            return await DbContext.Users.AsQueryable()
-                .Where(u => u.OrganizationUnits.Any(uou => uou.OrganizationUnitId == organizationUnit.Id))
-                .As<IMongoQueryable<IdentityUser>>()
-                .CountAsync(GetCancellationToken(cancellationToken));
+            var query = CreateGetMembersFilteredQuery(organizationUnit, filter);
+
+            return await query.CountAsync(GetCancellationToken(cancellationToken));
         }
 
         public virtual Task RemoveAllRolesAsync(OrganizationUnit organizationUnit, CancellationToken cancellationToken = default)
@@ -160,5 +154,18 @@ namespace Volo.Abp.Identity.MongoDB
                 DbContext.Users.ReplaceOne(u => u.Id == user.Id, user);
             }
         }
+
+        protected virtual IMongoQueryable<IdentityUser> CreateGetMembersFilteredQuery(OrganizationUnit organizationUnit, string filter = null)
+        {
+            return DbContext.Users.AsQueryable()
+                .Where(u => u.OrganizationUnits.Any(uou => uou.OrganizationUnitId == organizationUnit.Id))
+                .WhereIf<IdentityUser, IMongoQueryable<IdentityUser>>(
+                    !filter.IsNullOrWhiteSpace(),
+                    u =>
+                        u.UserName.Contains(filter) ||
+                        u.Email.Contains(filter) ||
+                        (u.PhoneNumber != null && u.PhoneNumber.Contains(filter))
+                );
+        }
     }
 }