using AircraftPlantBusinessLogic.MailWorker; using AircraftPlantContracts.BindingModels; using AircraftPlantContracts.BusinessLogicsContracts; using AircraftPlantContracts.SearchModels; using AircraftPlantContracts.StoragesContracts; using AircraftPlantContracts.ViewModels; using AircraftPlantDataModels.Enums; using AircraftPlantDataModels.Models; using Microsoft.Extensions.Logging; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace AircraftPlantBusinessLogic.BusinessLogics { /// /// Реализация интерфейса бизнес-логики для заказов /// public class OrderLogic : IOrderLogic { /// /// Логгер /// private readonly ILogger _logger; /// /// Взаимодействие с хранилищем заказов /// private readonly IOrderStorage _orderStorage; /// /// Взаимодействие с хранилищем магазинов /// private IShopStorage _shopStorage; /// /// Бизнес-логика магазинов /// private IShopLogic _shopLogic; /// /// Взаимодействие с хранилищем изделий /// private IPlaneStorage _planeStorage; /// /// Взаимодействие с хранилищем клиентов /// private readonly IClientStorage _clientStorage; /// /// Бизнес-логика для отправки писем /// private readonly AbstractMailWorker _mailLogic; /// /// Конструктор /// /// /// /// /// /// /// /// public OrderLogic(ILogger logger, IOrderStorage orderStorage, IShopStorage shopStorage, IShopLogic shopLogic, IPlaneStorage planeStorage, IClientStorage clientStorage, AbstractMailWorker mailLogic) { _logger = logger; _orderStorage = orderStorage; _shopStorage = shopStorage; _shopLogic = shopLogic; _planeStorage = planeStorage; _clientStorage = clientStorage; _mailLogic = mailLogic; } /// /// Получение списка /// /// /// public List? ReadList(OrderSearchModel? model) { _logger.LogInformation("ReadList. Order.Id:{ Id}", model?.Id); var list = model == null ? _orderStorage.GetFullList() : _orderStorage.GetFilteredList(model); if (list == null) { _logger.LogWarning("ReadList return null list"); return null; } _logger.LogInformation("ReadList. Count:{Count}", list.Count); return list; } /// /// Получение отдельной записи /// /// /// /// public OrderViewModel? ReadElement(OrderSearchModel model) { if (model == null) { throw new ArgumentNullException(nameof(model)); } _logger.LogInformation("ReadElement. Id:{ Id}", model.Id); var element = _orderStorage.GetElement(model); if (element == null) { _logger.LogWarning("ReadElement element not found"); return null; } _logger.LogInformation("ReadElement find. Id:{Id}", element.Id); return element; } /// /// Создание заказа /// /// /// public bool CreateOrder(OrderBindingModel model) { CheckModel(model); if (model.Status != OrderStatus.Неизвестен) { _logger.LogWarning("Insert operation failed. Order status incorrect."); return false; } model.Status = OrderStatus.Принят; var order = _orderStorage.Insert(model); if (order == null) { _logger.LogWarning("Insert operation failed"); return false; } SendEmail(order); return true; } /// /// Смена статуса заказа (Выполняется) /// /// /// public bool TakeOrderInWork(OrderBindingModel model) { return StatusUpdate(model, OrderStatus.Выполняется); } /// /// Смена статуса заказа (Выдан) /// /// /// public bool FinishOrder(OrderBindingModel model) { return StatusUpdate(model, OrderStatus.Выдан); } /// /// Смена статуса заказа (Готов) /// /// /// public bool DeliveryOrder(OrderBindingModel model) { return StatusUpdate(model, OrderStatus.Готов); } /// /// Проверка модели заказа /// /// /// private void CheckModel(OrderBindingModel model, bool withParams = true) { if (model == null) { throw new ArgumentNullException(nameof(model)); } if (!withParams) { return; } if (model.PlaneId < 0) { throw new ArgumentNullException("Некорректный идентификатор изделия", nameof(model.PlaneId)); } if (model.Count <= 0) { throw new ArgumentNullException("Количество изделий в заказе должно быть больше 0", nameof(model.Count)); } if (model.Sum <= 0) { throw new ArgumentNullException("Сумма заказа должна быть больше 0", nameof(model.Sum)); } _logger.LogInformation("Order. OrderID:{Id}.Sum:{ Sum}. PlaneId: { PlaneId}", model.Id, model.Sum, model.PlaneId); } /// /// Смена статуса заказа /// /// /// /// private bool StatusUpdate(OrderBindingModel model, OrderStatus newStatus) { var element = _orderStorage.GetElement(new OrderSearchModel { Id = model.Id }); if (element == null) { throw new ArgumentNullException(nameof(model)); } if (element.Status + 1 != newStatus && element.Status != OrderStatus.Ожидание) { _logger.LogWarning("Change status operation failed"); return false; } model.Status = newStatus; if (model.Status == OrderStatus.Готов || element.Status == OrderStatus.Ожидание) { var plane = _planeStorage.GetElement(new PlaneSearchModel { Id = element.PlaneId }); if (plane == null) { _logger.LogWarning("Status change error. Plane not found"); return false; } if (!CheckSupply(plane, element.Count)) { model.Status = OrderStatus.Ожидание; _logger.LogWarning("Status change error. Shop is overflowed"); } else { model.DateImplement = DateTime.Now; } } else { model.DateImplement = element.DateImplement; } CheckModel(model, false); var order = _orderStorage.Update(model); if (order == null) { _logger.LogWarning("Change status operation failed"); return false; } SendEmail(order); return true; } /// /// Проверка заказа /// /// /// /// public bool CheckSupply(IPlaneModel model, int count) { if (count <= 0) { _logger.LogWarning("Check supply operation error. Planes count < 0"); return false; } int sumCapacity = _shopStorage.GetFullList().Select(x => x.MaxPlanes).Sum(); int sumCount = _shopStorage.GetFullList().Select(x => x.ShopPlanes.Select(y => y.Value.Item2).Sum()).Sum(); int free = sumCapacity - sumCount; if (free < count) { _logger.LogWarning("Check supply error. No place for new planes"); return false; } foreach (var shop in _shopStorage.GetFullList()) { free = shop.MaxPlanes; foreach (var plane in shop.ShopPlanes) { free -= plane.Value.Item2; } if (free == 0) { continue; } if (free >= count) { if (_shopLogic.AddPlaneInShop(new() { Id = shop.Id }, model, count)) { count = 0; } else { _logger.LogWarning("Supply error"); return false; } } else { if (_shopLogic.AddPlaneInShop(new() { Id = shop.Id }, model, free)) { count -= free; } else { _logger.LogWarning("Supply error"); return false; } } if (count <= 0) { return true; } } return false; } /// /// Отправить письмо /// /// public void SendEmail(OrderViewModel order) { if (order == null) { return; } var client = _clientStorage.GetElement(new ClientSearchModel { Id = order.ClientId }); if (client == null) { return; } MailSendInfoBindingModel mailModel; if (order.Status == OrderStatus.Принят) { mailModel = new MailSendInfoBindingModel { MailAddress = client.Email, Subject = $"Order №{order.Id}", Text = $"Your order №{order.Id} by {order.DateCreate} on {order.Sum} was accepted!" }; } else { mailModel = new MailSendInfoBindingModel { MailAddress = client.Email, Subject = $"Order №{order.Id}", Text = $"Order №{order.Id} status was changed to {order.Status}" }; } _mailLogic.MailSendAsync(mailModel); } } }