Add multiple entity filtering to MongoDbRepositoryFilterer

framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/IMongoDbRepositoryFilterer.cs

@@ -14,5 +14,26 @@ namespace Volo.Abp.Domain.Repositories.MongoDB
         FilterDefinition<TEntity> CreateEntityFilter(TKey id, bool applyFilters = false);
 
         FilterDefinition<TEntity> CreateEntityFilter(TEntity entity, bool withConcurrencyStamp = false, string concurrencyStamp = null);
+
+        /// <summary>
+        /// Creates 'In' filter for mongoDb.
+        /// </summary>
+        /// <remarks>
+        /// Visit https://docs.mongodb.com/manual/reference/operator/query/in/ to get more information about 'in' operator.
+        /// </remarks>
+        /// <param name="entities">Entities to be filtered.</param>
+        /// <param name="applyFilters">Set true to use GlobalFilters. Default is false.</param>
+        /// <returns>Created <see cref="FilterDefinition{TDocument}"/>.</returns>
+        FilterDefinition<TEntity> CreateEntitiesFilter(IEnumerable<TEntity> entities, bool applyFilters = false);
+
+        /// <summary>
+        /// Creates 'In' filter for mongoDb.
+        /// </summary>
+        /// <remarks>
+        /// Visit https://docs.mongodb.com/manual/reference/operator/query/in/ to get more information about 'in' operator.
+        /// </remarks>
+        /// <param name="ids">Entity Ids to be filtered.</param>
+        /// <param name="applyFilters">Set true to use GlobalFilters. Default is false.</param>
+        FilterDefinition<TEntity> CreateEntitiesFilter(IEnumerable<TKey> ids, bool applyFilters = false);
     }
 }

framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepositoryFilterer.cs

@@ -1,4 +1,5 @@
 using System.Collections.Generic;
+using System.Linq;
 using MongoDB.Driver;
 using Volo.Abp.Data;
 using Volo.Abp.Domain.Entities;
@@ -23,13 +24,13 @@ namespace Volo.Abp.Domain.Repositories.MongoDB
         {
             if (typeof(ISoftDelete).IsAssignableFrom(typeof(TEntity)) && DataFilter.IsEnabled<ISoftDelete>())
             {
-                filters.Add(Builders<TEntity>.Filter.Eq(e => ((ISoftDelete) e).IsDeleted, false));
+                filters.Add(Builders<TEntity>.Filter.Eq(e => ((ISoftDelete)e).IsDeleted, false));
             }
 
             if (typeof(IMultiTenant).IsAssignableFrom(typeof(TEntity)))
             {
                 var tenantId = CurrentTenant.Id;
-                filters.Add(Builders<TEntity>.Filter.Eq(e => ((IMultiTenant) e).TenantId, tenantId));
+                filters.Add(Builders<TEntity>.Filter.Eq(e => ((IMultiTenant)e).TenantId, tenantId));
             }
         }
     }
@@ -72,8 +73,28 @@ namespace Volo.Abp.Domain.Repositories.MongoDB
 
             return Builders<TEntity>.Filter.And(
                 Builders<TEntity>.Filter.Eq(e => e.Id, entity.Id),
-                Builders<TEntity>.Filter.Eq(e => ((IHasConcurrencyStamp) e).ConcurrencyStamp, concurrencyStamp)
+                Builders<TEntity>.Filter.Eq(e => ((IHasConcurrencyStamp)e).ConcurrencyStamp, concurrencyStamp)
             );
         }
+
+        public FilterDefinition<TEntity> CreateEntitiesFilter(IEnumerable<TEntity> entities, bool applyFilters = false)
+        {
+            return CreateEntitiesFilter(entities.Select(s => s.Id), applyFilters);
+        }
+
+        public FilterDefinition<TEntity> CreateEntitiesFilter(IEnumerable<TKey> ids, bool applyFilters = false)
+        {
+            var filters = new List<FilterDefinition<TEntity>>()
+            {
+                Builders<TEntity>.Filter.In(e => e.Id, ids),
+            };
+
+            if (applyFilters)
+            {
+                AddGlobalFilters(filters);
+            }
+
+            return Builders<TEntity>.Filter.And(filters);
+        }
     }
 }