PIbd-23_Elatomtsev_L.K._Con.../Confectionery/ConfectioneryBusinessLogic/BusinessLogics/OrderLogic.cs

161 lines
6.1 KiB
C#
Raw Normal View History

2024-03-13 14:54:56 +04:00
using ConfectioneryContracts.BindingModels;
2024-05-22 07:00:31 +04:00
using ConfectioneryBusinessLogic.MailWorker;
2024-03-13 14:54:56 +04:00
using ConfectioneryContracts.BusinessLogicsContracts;
using ConfectioneryContracts.SearchModels;
using ConfectioneryContracts.StoragesContracts;
using ConfectioneryContracts.ViewModels;
using ConfectioneryDataModels.Enums;
using Microsoft.Extensions.Logging;
namespace ConfectioneryBusinessLogic.BusinessLogics
{
public class OrderLogic : IOrderLogic
{
private readonly ILogger _logger;
private readonly IOrderStorage _orderStorage;
2024-05-22 07:00:31 +04:00
private readonly AbstractMailWorker _mailWorker;
private readonly IClientLogic _clientLogic;
2024-05-08 15:04:44 +04:00
static readonly object locker = new object();
2024-03-13 14:54:56 +04:00
public OrderLogic(ILogger<OrderLogic> logger,
2024-05-22 07:00:31 +04:00
IOrderStorage orderStorage, AbstractMailWorker mailWorker,
IClientLogic clientLogic)
2024-03-13 14:54:56 +04:00
{
_logger = logger;
_orderStorage = orderStorage;
2024-05-22 07:00:31 +04:00
_mailWorker = mailWorker;
_clientLogic = clientLogic;
2024-03-13 14:54:56 +04:00
}
2024-05-08 15:04:44 +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-03-13 14:54:56 +04:00
public List<OrderViewModel>? ReadList(OrderSearchModel? model)
{
_logger.LogInformation("ReadList. 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 bool CreateOrder(OrderBindingModel model)
{
CheckModel(model);
if (model.Status != OrderStatus.Неизвестен) return false;
model.Status = OrderStatus.Принят;
2024-05-22 07:00:31 +04:00
var res = _orderStorage.Insert(model);
if (res == null)
2024-03-13 14:54:56 +04:00
{
_logger.LogWarning("Insert operation failed");
return false;
}
2024-05-22 07:00:31 +04:00
SendOrderStatusMail(model.ClientId,
$"Изменен статус заказа #{res.Id}", $"Заказ #{res.Id} " +
$"изменен статус на {model.Status}");
2024-03-13 14:54:56 +04:00
return true;
}
public bool ChangeStatus(OrderBindingModel model, OrderStatus status)
{
2024-05-08 15:04:44 +04:00
CheckModel(model, false);
2024-03-13 14:54:56 +04:00
var element = _orderStorage.GetElement(
new OrderSearchModel { Id = model.Id });
if (element == null)
{
_logger.LogWarning("Read operation failed");
return false;
}
if (element.Status != status - 1)
{
_logger.LogWarning("Status change operation failed");
throw new InvalidOperationException("Текущий статус заказа" +
" не может быть переведен в выбранный");
}
model.Status = status;
if (model.Status == OrderStatus.Выдан)
model.DateImplement = DateTime.Now;
2024-05-08 15:04:44 +04:00
if (element.ImplementerId.HasValue) model.ImplementerId
= element.ImplementerId;
2024-05-22 07:00:31 +04:00
var result = _orderStorage.Update(model);
if (result == null)
{
_logger.LogWarning("Update operation failed");
return false;
}
SendOrderStatusMail(result.ClientId,
$"Изменен статус заказа #{result.Id}", $"Заказ #{model.Id} " +
$"изменен статус на {result.Status}");
2024-03-13 14:54:56 +04:00
return true;
}
public bool TakeOrderInWork(OrderBindingModel model)
{
2024-05-08 15:04:44 +04:00
lock (locker)
{
return ChangeStatus(model, OrderStatus.Выполняется);
}
2024-03-13 14:54:56 +04:00
}
public bool FinishOrder(OrderBindingModel model)
{
return ChangeStatus(model, OrderStatus.Готов);
}
public bool DeliveryOrder(OrderBindingModel model)
{
return ChangeStatus(model, OrderStatus.Выдан);
}
private void CheckModel(OrderBindingModel model,
bool withParams = true)
{
if (model == null)
{
throw new ArgumentNullException(nameof(model));
}
if (!withParams)
{
return;
}
if (model.Sum <= 0)
{
throw new ArgumentNullException(
"Цена заказа должна быть больше 0", nameof(model.Sum));
}
if (model.Count <= 0)
{
throw new ArgumentNullException(
"Количество элементов в заказе должно быть больше 0",
nameof(model.Count));
}
_logger.LogInformation("Order. Sum:{ Cost}. Id: { Id}",
model.Sum, model.Id);
}
2024-05-22 07:00:31 +04:00
private bool SendOrderStatusMail(int clientId, string subject,
string text)
{
var client = _clientLogic.ReadElement(new() { Id = clientId });
if (client == null)
{
return false;
}
_mailWorker.MailSendAsync(new()
{
MailAddress = client.Email,
Subject = subject,
Text = text
});
return true;
}
2024-03-13 14:54:56 +04:00
}
}