PIbd-22_Chubykina_P.P._Conf.../Confectionery/ConfectioneryBusinessLogic/BusinessLogics/OrderLogic.cs

210 lines
7.1 KiB
C#
Raw Normal View History

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using ConfectioneryContracts.BindingModels;
using ConfectioneryContracts.SearchModels;
using ConfectioneryContracts.ViewModels;
using ConfectioneryContracts.BusinessLogicsContracts;
using ConfectioneryContracts.StoragesContracts;
using Microsoft.Extensions.Logging;
2024-02-27 22:14:35 +04:00
using ConfectioneryDataModels.Enums;
using ConfectioneryBusinessLogic.MailWorker;
2024-02-27 22:14:35 +04:00
namespace ConfectioneryBusinessLogic.BusinessLogics
{
2024-02-27 22:14:35 +04:00
public class OrderLogic : IOrderLogic
{
2024-02-27 22:14:35 +04:00
private readonly ILogger _logger;
private readonly IOrderStorage _orderStorage;
private readonly IClientStorage _clientStorage;
private readonly AbstractMailWorker _mailLogic;
2024-05-05 00:58:09 +04:00
static readonly object locker = new();
public OrderLogic(ILogger<OrderLogic> logger, IOrderStorage orderStorage, IClientStorage clientStorage, AbstractMailWorker mailLogic)
2024-02-27 22:14:35 +04:00
{
_logger = logger;
_orderStorage = orderStorage;
_clientStorage = clientStorage;
_mailLogic = mailLogic;
2024-02-27 22:14:35 +04:00
}
public bool CreateOrder(OrderBindingModel model)
{
2024-02-27 22:14:35 +04:00
CheckModel(model);
if (model.Status != OrderStatus.Неизвестен)
{
_logger.LogWarning("Invalid order status");
return false;
}
model.Status = OrderStatus.Принят;
var order = _orderStorage.Insert(model);
if (order == null)
2024-02-27 22:14:35 +04:00
{
_logger.LogWarning("Insert operation failed");
return false;
}
SendEmail(order);
2024-02-27 22:14:35 +04:00
return true;
}
2024-02-27 22:14:35 +04:00
public List<OrderViewModel>? ReadList(OrderSearchModel? model)
{
2024-02-27 22:14:35 +04:00
_logger.LogInformation("ReadList. OrderId: {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;
}
2024-05-04 23:59:55 +04:00
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;
}
2024-02-27 22:14:35 +04:00
public bool TakeOrderInWork(OrderBindingModel model)
{
2024-05-05 00:58:09 +04:00
lock (locker)
{
return ChangeStatus(model, OrderStatus.Выполняется);
}
}
public bool FinishOrder(OrderBindingModel model)
{
2024-02-27 22:14:35 +04:00
return ChangeStatus(model, OrderStatus.Готов);
}
2024-02-27 22:14:35 +04:00
public bool DeliveryOrder(OrderBindingModel model)
{
2024-02-27 22:14:35 +04:00
return ChangeStatus(model, OrderStatus.Выдан);
}
2024-02-27 22:14:35 +04:00
private void CheckModel(OrderBindingModel model, bool withParams = true)
{
if (model == null)
{
throw new ArgumentNullException(nameof(model));
}
if (!withParams)
{
return;
}
if (model.PastryId <= 0)
{
2024-02-28 10:03:27 +04:00
throw new ArgumentNullException("Некорректный идентификатор выпечки", nameof(model.PastryId));
2024-02-27 22:14:35 +04:00
}
2024-05-05 00:58:09 +04:00
if (model.ClientId <= 0)
{
throw new ArgumentNullException("Некорректный идентификатор клиента", nameof(model.ClientId));
}
2024-02-27 22:14:35 +04:00
if (model.Count <= 0)
{
2024-02-28 10:03:27 +04:00
throw new ArgumentNullException("В заказе должно быть хотя бы одна выпечка", nameof(model.Count));
2024-02-27 22:14:35 +04:00
}
if (model.Sum <= 0)
{
throw new ArgumentNullException("Стоимость заказа должна быть больше 0", nameof(model.Sum));
}
_logger.LogInformation("Order. Id: {Id}. Sum: {Sum}. PastryId: {PastryId}. PastryCount: {Count}", model.Id, model.Sum,
model.PastryId, model.Count);
}
private bool ChangeStatus(OrderBindingModel model, OrderStatus newStatus)
{
2024-02-27 22:14:35 +04:00
CheckModel(model, false);
var order = _orderStorage.GetElement(new OrderSearchModel { Id = model.Id });
if (order == null)
{
_logger.LogWarning("Change status operation failed. Order not found");
return false;
}
if (order.Status + 1 != newStatus)
{
_logger.LogWarning("Change status operation failed. Incorrect new status: {newStatus}. Current status: {currStatus}",
newStatus, order.Status);
return false;
}
model.Status = newStatus;
2024-05-05 00:58:09 +04:00
if (order.ImplementerId.HasValue)
{
model.ImplementerId = order.ImplementerId;
}
2024-02-27 22:14:35 +04:00
if (model.Status == OrderStatus.Готов)
{
model.DateImplement = DateTime.Now;
}
else
{
model.DateImplement = order.DateImplement;
}
order = _orderStorage.Update(model);
if (order == null)
2024-02-27 22:14:35 +04:00
{
_logger.LogWarning("Change status operation failed");
return false;
}
SendEmail(order);
2024-02-27 22:14:35 +04:00
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 = $"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);
}
}
}