using Grand.Business.Core.Queries.Catalog;
using Grand.Infrastructure.Caching;
using Grand.Infrastructure.Caching.Constants;
using Grand.Domain.Customers;
using Grand.Domain.Data;
using MediatR;

namespace Grand.Business.Catalog.Queries.Handlers
{
    public class GetPriceByCustomerProductQueryHandler : IRequestHandler<GetPriceByCustomerProductQuery, double?>
    {
        private readonly ICacheBase _cacheBase;
        private readonly IRepository<CustomerProductPrice> _customerProductPriceRepository;

        public GetPriceByCustomerProductQueryHandler(ICacheBase cacheBase, IRepository<CustomerProductPrice> customerProductPriceRepository)
        {
            _cacheBase = cacheBase;
            _customerProductPriceRepository = customerProductPriceRepository;
        }

        public async Task<double?> Handle(GetPriceByCustomerProductQuery request, CancellationToken cancellationToken)
        {
            var key = string.Format(CacheKey.CUSTOMER_PRODUCT_PRICE_KEY_ID, request.CustomerId, request.ProductId);
            var productPrice = _cacheBase.Get(key, () =>
            {
                var pp = _customerProductPriceRepository.Table
                    .FirstOrDefault(x => x.CustomerId == request.CustomerId && x.ProductId == request.ProductId);
                return pp == null ? (null, false) : (pp, true);
            });

            if (!productPrice.Item2)
                return await Task.FromResult(default(double?));
            return await Task.FromResult(productPrice.pp.Price);
        }
    }
}
