Refactoring Services (#61)

* Refactoring ViewModels into Razor Pages models

* Cleaning up Basket viewcomponent

* Refactoring services.
Fixed bug in basket item counter.

src/ApplicationCore/Services/BasketService.cs

@@ -0,0 +1,81 @@
+using ApplicationCore.Interfaces;
+using System.Threading.Tasks;
+using System.Collections.Generic;
+using ApplicationCore.Specifications;
+using Microsoft.eShopWeb.ApplicationCore.Entities;
+using System.Linq;
+
+namespace ApplicationCore.Services
+{
+    public class BasketService : IBasketService
+    {
+        private readonly IAsyncRepository<Basket> _basketRepository;
+        private readonly IUriComposer _uriComposer;
+        private readonly IAppLogger<BasketService> _logger;
+        private readonly IRepository<CatalogItem> _itemRepository;
+
+        public BasketService(IAsyncRepository<Basket> basketRepository,
+            IRepository<CatalogItem> itemRepository,
+            IUriComposer uriComposer,
+            IAppLogger<BasketService> logger)
+        {
+            _basketRepository = basketRepository;
+            _uriComposer = uriComposer;
+            this._logger = logger;
+            _itemRepository = itemRepository;
+        }
+
+        public async Task AddItemToBasket(int basketId, int catalogItemId, decimal price, int quantity)
+        {
+            var basket = await _basketRepository.GetByIdAsync(basketId);
+
+            basket.AddItem(catalogItemId, price, quantity);
+
+            await _basketRepository.UpdateAsync(basket);
+        }
+
+        public async Task DeleteBasketAsync(int basketId)
+        {
+            var basket = await _basketRepository.GetByIdAsync(basketId);
+
+            await _basketRepository.DeleteAsync(basket);
+        }
+
+        public async Task<int> GetBasketItemCountAsync(string userName)
+        {
+            var basketSpec = new BasketWithItemsSpecification(userName);
+            var basket = (await _basketRepository.ListAsync(basketSpec)).FirstOrDefault();
+            if (basket == null)
+            {
+                _logger.LogInformation($"No basket found for {userName}");
+                return 0;
+            }
+            int count = basket.Items.Sum(i => i.Quantity);
+            _logger.LogInformation($"Basket for {userName} has {count} items.");
+            return count;
+        }
+
+        public async Task SetQuantities(int basketId, Dictionary<string, int> quantities)
+        {
+            var basket = await _basketRepository.GetByIdAsync(basketId);
+            foreach (var item in basket.Items)
+            {
+                if (quantities.TryGetValue(item.Id.ToString(), out var quantity))
+                {
+                    _logger.LogInformation($"Updating quantity of item ID:{item.Id} to {quantity}.");
+                    item.Quantity = quantity;
+                }
+            }
+            await _basketRepository.UpdateAsync(basket);
+        }
+
+        public async Task TransferBasketAsync(string anonymousId, string userName)
+        {
+            var basketSpec = new BasketWithItemsSpecification(anonymousId);
+            var basket = (await _basketRepository.ListAsync(basketSpec)).FirstOrDefault();
+            if (basket == null) return;
+            basket.BuyerId = userName;
+            await _basketRepository.UpdateAsync(basket);
+        }
+    }
+}

src/ApplicationCore/Services/OrderService.cs

@@ -0,0 +1,40 @@
+using ApplicationCore.Interfaces;
+using ApplicationCore.Entities.OrderAggregate;
+using System.Threading.Tasks;
+using Microsoft.eShopWeb.ApplicationCore.Entities;
+using System.Collections.Generic;
+
+namespace ApplicationCore.Services
+{
+    public class OrderService : IOrderService
+    {
+        private readonly IAsyncRepository<Order> _orderRepository;
+        private readonly IAsyncRepository<Basket> _basketRepository;
+        private readonly IAsyncRepository<CatalogItem> _itemRepository;
+
+        public OrderService(IAsyncRepository<Basket> basketRepository,
+            IAsyncRepository<CatalogItem> itemRepository,
+            IAsyncRepository<Order> orderRepository)
+        {
+            _orderRepository = orderRepository;
+            _basketRepository = basketRepository;
+            _itemRepository = itemRepository;
+        }
+
+        public async Task CreateOrderAsync(int basketId, Address shippingAddress)
+        {
+            var basket = await _basketRepository.GetByIdAsync(basketId);
+            var items = new List<OrderItem>();
+            foreach (var item in basket.Items)
+            {
+                var catalogItem = await _itemRepository.GetByIdAsync(item.CatalogItemId);
+                var itemOrdered = new CatalogItemOrdered(catalogItem.Id, catalogItem.Name, catalogItem.PictureUri);
+                var orderItem = new OrderItem(itemOrdered, item.UnitPrice, item.Quantity);
+                items.Add(orderItem);
+            }
+            var order = new Order(basket.BuyerId, shippingAddress, items);
+
+            await _orderRepository.AddAsync(order);
+        }
+    }
+}