无法将类型为“ System.Linq.EnumerableQuery”的对象转换为类型为“ MongoDB.Driver.Linq.IMongoQueryable”的

如何解决无法将类型为“ System.Linq.EnumerableQuery”的对象转换为类型为“ MongoDB.Driver.Linq.IMongoQueryable”的

我有一个带有以下方法句柄的SendNotificationsToSubscribersCommandHandler类，并且我具有测试方法 GetAllSubscriptionsWithCorrectParamsProductId（），以检查Handle方法是否返回正确的列表。

我收到以下错误：

Message: 
    Test method Grand.Services.Tests.Commands.Handlers.Catalog.SendNotificationsToSubscribersCommandHandlerTest.GetAllSubscriptionsWithCorrectParamsProductId threw exception: 
    system.invalidCastException: Unable to cast object of type 'System.Linq.EnumerableQuery`1[Grand.Domain.Catalog.BackInStockSubscription]' to type 'MongoDB.Driver.Linq.IMongoQueryable`1[Grand.Domain.Catalog.BackInStockSubscription]'.
  Stack Trace: 
    MongoQueryable.Where[TSource](IMongoQueryable`1 source,Expression`1 predicate)

SendNotificationsToSubscribersCommandHandler

public class SendNotificationsToSubscribersCommandHandler : IRequestHandler<SendNotificationsToSubscribersCommand,IList<BackInStockSubscription>>
    {
        private readonly ICustomerService _customerService;
        private readonly IWorkflowMessageService _workflowMessageService;
        private readonly IRepository<BackInStockSubscription> _backInStockSubscriptionRepository;

        public SendNotificationsToSubscribersCommandHandler(
            ICustomerService customerService,IWorkflowMessageService workflowMessageService,IRepository<BackInStockSubscription> backInStockSubscriptionRepository)
        {
            _customerService = customerService;
            _workflowMessageService = workflowMessageService;
            _backInStockSubscriptionRepository = backInStockSubscriptionRepository;
        }

        public async Task<IList<BackInStockSubscription>> Handle(SendNotificationsToSubscribersCommand request,CancellationToken cancellationToken)
        {
            if (request.Product == null)
                throw new ArgumentNullException("product");

            int result = 0;

            var query = _backInStockSubscriptionRepository.Table;
            //product
            query = query.Where(biss => biss.ProductId == request.Product.Id);

            //warehouse
            if (!string.IsNullOrEmpty(request.Warehouse))
                query = query.Where(biss => biss.WarehouseId == request.Warehouse);

            //warehouse
            if (!string.IsNullOrEmpty(request.AttributeXml))
                query = query.Where(biss => biss.AttributeXml ==  request.AttributeXml);

            query = query.OrderByDescending(biss => biss.CreatedOnUtc);
            var subscriptions = await query.ToListAsync();
            //var subscriptions = await GetAllSubscriptionsByProductId(request.Product.Id,request.AttributeXml,request.Warehouse);
            foreach (var subscription in subscriptions)
            {
                var customer = await _customerService.GetCustomerById(subscription.CustomerId);
                //ensure that customer is registered (simple and fast way)
                if (customer != null && CommonHelper.IsValidEmail(customer.Email))
                {
                    var customerLanguageId = customer.GetAttributeFromEntity<string>(SystemCustomerAttributeNames.LanguageId,subscription.StoreId);
                    await _workflowMessageService.SendBackInStockNotification(customer,request.Product,subscription,customerLanguageId);
                    result++;
                }
            }

            return subscriptions;

        }
}

我的测试方法：

    [TestClass()]
        public class SendNotificationsToSubscribersCommandHandlerTest
        {
            private Mock<ICustomerService> _mockCustomerService;
            private Mock<IRepository<BackInStockSubscription>> _mockBackInStockSubscriptionRepository;
            private Mock<IMongoQueryable<BackInStockSubscription>> _mongoQueryableMock;
            private IQueryable<BackInStockSubscription> _expectedQueryable;
            private List<BackInStockSubscription> _expected;
            private Mock<IWorkflowMessageService> _mockWorkflowMessageService;
            private SendNotificationsToSubscribersCommandHandler _handler;
            private SendNotificationsToSubscribersCommand _sendNotificationsToSubscribersCommand;
    
            [Testinitialize()]
            public void Init()
            {
                _expected = new List<BackInStockSubscription>
                {
                    new BackInStockSubscription { WarehouseId = "11",ProductId = "11" },new BackInStockSubscription { WarehouseId = "11",ProductId = "11" }
                };
                _mockCustomerService = new Mock<ICustomerService>();
                _mockBackInStockSubscriptionRepository = new Mock<IRepository<BackInStockSubscription>>();
                _expectedQueryable = _expected.AsQueryable();
    
                _mongoQueryableMock = new Mock<IMongoQueryable<BackInStockSubscription>>();
 _mongoQueryableMock.As<IEnumerable<BackInStockSubscription>>();
                _mongoQueryableMock.Setup(x => x.ElementType).Returns(_expectedQueryable.ElementType);
                _mongoQueryableMock.Setup(x => x.Expression).Returns(_expectedQueryable.Expression);
                _mongoQueryableMock.Setup(x => x.Provider).Returns(_expectedQueryable.Provider);
                _mongoQueryableMock.Setup(x => x.GetEnumerator()).Returns(_expectedQueryable.GetEnumerator());
                _mockBackInStockSubscriptionRepository.Setup(x => x.Table).Returns(_mongoQueryableMock.Object);
    
                _mockWorkflowMessageService = new Mock<IWorkflowMessageService>();
                _sendNotificationsToSubscribersCommand = new SendNotificationsToSubscribersCommand { Product = new Product { Id = "11"},Warehouse = "11" };
    
                _handler = new SendNotificationsToSubscribersCommandHandler(_mockCustomerService.Object,_mockWorkflowMessageService.Object,_mockBackInStockSubscriptionRepository.Object);
            }
    
            [TestMethod()]
            public async Task GetAllSubscriptionsWithCorrectParamsProductId()
            {
                var result = await _handler.Handle(_sendNotificationsToSubscribersCommand,default);
                var resultList = result.ToList();
                Assert.AreEqual(resultList,_expected);
            }
        }

我在线上出错

query = query.Where(biss => biss.ProductId == productId);

更新

当我调试应用程序时，属性_backInStockSubscriptionRepository.Table具有Expression.Value = {aggregate([])} 如果我调试测试方法属性，则“模拟对象”表的两个对象都具有 Expression.Value ，其中Value = System.Collections.Generic.List<Grand.Domain.Catalog.BackInStockSubscription>。

非常感谢您的帮助

解决方法

在这里看看：How to mock a class that implements multiple interfaces

尝试这样的事情：

_mongoQueryableMock = new Mock<IMongoQueryable<BackInStockSubscription>>();
_mongoQueryableMock.As<IEnumerable<BackInStockSubscription>>();
...