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; static readonly object locker = new(); /// /// Взаимодействие с хранилищем клиентов /// private readonly IClientStorage _clientStorage; /// /// Бизнес-логика для отправки писем /// private readonly AbstractMailWorker _mailLogic; /// /// Конструктор /// /// /// /// /// public OrderLogic(ILogger logger, IOrderStorage orderStorage, IClientStorage clientStorage, AbstractMailWorker mailLogic) { _logger = logger; _orderStorage = orderStorage; _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) { lock (locker) { 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) { _logger.LogWarning("Change status operation failed"); return false; } model.Status = newStatus; if (element.ImplementerId.HasValue) { model.ImplementerId = element.ImplementerId; } if (model.Status == OrderStatus.Готов) { 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 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 = $"Ваш заказ №{order.Id} от {order.DateCreate} на сумму {order.Sum} был принят!" }; } else { mailModel = new MailSendInfoBindingModel { MailAddress = client.Email, Subject = $"Order №{order.Id}", Text = $"Заказ №{order.Id} изменен статус на {order.Status}" }; } _mailLogic.MailSendAsync(mailModel); } } }