Kharlamov/PIbd-23_Kharlamov_A.A._FoodOrders
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Принятая лаба №6

Browse Source
This commit is contained in:
Артем Харламов 2023-05-15 11:23:37 +04:00
parent ea2c698577
commit 643cfa5b07
2 changed files with 112 additions and 107 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

205
FoodOrders/AbstractFoodOrdersBusinessLogic/BusinessLogics/OrderLogic.cs
View File

@ -15,33 +15,35 @@ namespace AbstractFoodOrdersBusinessLogic.BusinessLogics
{ {
public class OrderLogic : IOrderLogic public class OrderLogic : IOrderLogic
{ {
private readonly ILogger _logger; private readonly ILogger _logger;
private readonly IOrderStorage _orderStorage; private readonly IOrderStorage _orderStorage;
static readonly object _locker = new object(); static readonly object _locker = new object();
public OrderLogic(ILogger<OrderLogic> logger, IOrderStorage orderStorage) public OrderLogic(ILogger<OrderLogic> logger, IOrderStorage orderStorage)
{ {
_logger = logger; _logger = logger;
_orderStorage = orderStorage; _orderStorage = orderStorage;
} }
public List<OrderViewModel>? ReadList(OrderSearchModel? model) public List<OrderViewModel>? ReadList(OrderSearchModel? model)
{ {
_logger.LogInformation("ReadList. OrderId:{Id}", model?.Id); _logger.LogInformation("ReadList. ClientId:{ClientId}.Status:{Status}.ImplementerId:{ImplementerId}.DateFrom:{DateFrom}.DateTo:{DateTo}OrderId:{Id}",
var list = model == null ? _orderStorage.GetFullList() : _orderStorage.GetFilteredList(model); model?.ClientId, model?.OrderStatus, model?.ImplementerId, model?.DateFrom, model?.DateTo, model?.Id);
if (list == null) var list = model == null ? _orderStorage.GetFullList() : _orderStorage.GetFilteredList(model);
{ if (list == null)
_logger.LogWarning("ReadList return null list"); {
return null; _logger.LogWarning("ReadList return null list");
} return null;
_logger.LogInformation("ReadList. Count:{Count}", list.Count); }
return list; _logger.LogInformation("ReadList. Count:{Count}", list.Count);
} return list;
public OrderViewModel? ReadElement(OrderSearchModel? model) }
public OrderViewModel? ReadElement(OrderSearchModel model)
{ {
if (model == null) if (model == null)
{ {
throw new ArgumentNullException(nameof(model)); throw new ArgumentNullException(nameof(model));
} }
_logger.LogInformation("ReadElement. ImplementerId:{ImplementerId}. OrderStatus:{OrderStatus}. Id:{Id}", model.ImplementerId, model.OrderStatus, model.Id); _logger.LogInformation("ReadElement. ClientId:{ClientId}.Status:{Status}.ImplementerId:{ImplementerId}.DateFrom:{DateFrom}.DateTo:{DateTo}OrderId:{Id}",
model.ClientId, model.OrderStatus, model.ImplementerId, model.DateFrom, model.DateTo, model.Id);
var element = _orderStorage.GetElement(model); var element = _orderStorage.GetElement(model);
if (element == null) if (element == null)
{ {
@ -52,89 +54,92 @@ namespace AbstractFoodOrdersBusinessLogic.BusinessLogics
return element; return element;
} }
public bool CreateOrder(OrderBindingModel model) public bool CreateOrder(OrderBindingModel model)
{ {
CheckModel(model); CheckModel(model);
if (model.Status != OrderStatus.Неизвестен) if (model.Status != OrderStatus.Неизвестен)
return false; return false;
model.Status = OrderStatus.Принят; model.Status = OrderStatus.Принят;
if (_orderStorage.Insert(model) == null) if (_orderStorage.Insert(model) == null)
{ {
_logger.LogWarning("Insert operation failed"); _logger.LogWarning("Insert operation failed");
return false; return false;
} }
return true; return true;
} }
public bool TakeOrderInWork(OrderBindingModel model) public bool TakeOrderInWork(OrderBindingModel model)
{ {
lock (_locker) lock (_locker)
{ {
return ChangeStatus(model, OrderStatus.Выполняется); return ChangeStatus(model, OrderStatus.Выполняется);
} }
} }
public bool FinishOrder(OrderBindingModel model) public bool FinishOrder(OrderBindingModel model)
{ {
return ChangeStatus(model, OrderStatus.Готов); return ChangeStatus(model, OrderStatus.Готов);
} }
public bool DeliveryOrder(OrderBindingModel model) public bool DeliveryOrder(OrderBindingModel model)
{ {
return ChangeStatus(model, OrderStatus.Выдан); return ChangeStatus(model, OrderStatus.Выдан);
} }
private void CheckModel(OrderBindingModel model, bool withParams = true) private void CheckModel(OrderBindingModel model, bool withParams = true)
{ {
if (model == null) if (model == null)
{ {
throw new ArgumentNullException(nameof(model)); throw new ArgumentNullException(nameof(model));
} }
if (!withParams) if (!withParams)
{ {
return; return;
} }
if (model.Count <= 0) if (model.Count <= 0)
{ {
throw new ArgumentException("Колличество изделий в заказе не может быть меньше 1", nameof(model.Count)); throw new ArgumentException("Колличество изделий в заказе не может быть меньше 1", nameof(model.Count));
} }
if (model.Sum <= 0) if (model.Sum <= 0)
{ {
throw new ArgumentException("Стоимость заказа на может быть меньше 1", nameof(model.Sum)); throw new ArgumentException("Стоимость заказа на может быть меньше 1", nameof(model.Sum));
} }
if (model.DateImplement.HasValue && model.DateImplement < model.DateCreate) if (model.DateImplement.HasValue && model.DateImplement < model.DateCreate)
{ {
throw new ArithmeticException($"Дата выдачи заказа {model.DateImplement} не может быть раньше даты его создания {model.DateCreate}"); throw new ArithmeticException($"Дата выдачи заказа {model.DateImplement} не может быть раньше даты его создания {model.DateCreate}");
} }
_logger.LogInformation("Reinforced. ReinforcedId:{ReinforcedId}.Count:{Count}.Sum:{Sum}Id:{Id}", _logger.LogInformation("Reinforced. ReinforcedId:{ReinforcedId}.Count:{Count}.Sum:{Sum}Id:{Id}",
model.DishId, model.Count, model.Sum, model.Id); model.DishId, model.Count, model.Sum, model.Id);
} }
private bool ChangeStatus(OrderBindingModel model, OrderStatus requiredStatus) private bool ChangeStatus(OrderBindingModel model, OrderStatus requiredStatus)
{ {
CheckModel(model, false); CheckModel(model, false);
var element = _orderStorage.GetElement(new OrderSearchModel() var element = _orderStorage.GetElement(new OrderSearchModel()
{ {
Id = model.Id Id = model.Id
}); });
if (element == null) if (element == null)
{ {
throw new ArgumentNullException(nameof(element)); throw new InvalidOperationException(nameof(element));
} }
model.DateCreate = element.DateCreate; model.DateCreate = element.DateCreate;
model.DishId = element.DishId; model.DishId = element.DishId;
model.DateImplement = element.DateImplement; model.DateImplement = element.DateImplement;
model.Status = element.Status; model.ClientId = element.ClientId;
model.Count = element.Count; if (!model.ImplementerId.HasValue)
model.Sum = element.Sum; model.ImplementerId = element.ImplementerId;
if (requiredStatus - model.Status == 1) model.Status = element.Status;
{ model.Count = element.Count;
model.Status = requiredStatus; model.Sum = element.Sum;
if (model.Status == OrderStatus.Готов) if (requiredStatus - model.Status == 1)
model.DateImplement = DateTime.Now; {
if (_orderStorage.Update(model) == null) model.Status = requiredStatus;
{ if (model.Status == OrderStatus.Готов)
_logger.LogWarning("Update operation failed"); model.DateImplement = DateTime.Now;
return false; if (_orderStorage.Update(model) == null)
} {
return true; _logger.LogWarning("Update operation failed");
} return false;
_logger.LogWarning("Changing status operation faled: Current-{Status}:required-{requiredStatus}.", model.Status, requiredStatus); }
throw new ArgumentException($"Невозможно приствоить статус {requiredStatus} заказу с текущим статусом {model.Status}"); return true;
} }
} _logger.LogWarning("Changing status operation faled: Current-{Status}:required-{requiredStatus}.", model.Status, requiredStatus);
throw new InvalidOperationException($"Невозможно приствоить статус {requiredStatus} заказу с текущим статусом {model.Status}");
}
}
} }

14
FoodOrders/AbstractFoodOrdersBusinessLogic/BusinessLogics/WorkModeling.cs
View File

@ -12,7 +12,7 @@ using System.Threading.Tasks;
namespace AbstractFoodOrdersBusinessLogic.BusinessLogics namespace AbstractFoodOrdersBusinessLogic.BusinessLogics
{ {
public class WorkModeling: IWorkProcess public class WorkModeling : IWorkProcess
{ {
private readonly ILogger _logger; private readonly ILogger _logger;
@ -39,9 +39,8 @@ namespace AbstractFoodOrdersBusinessLogic.BusinessLogics
if (orders == null || orders.Count == 0) if (orders == null || orders.Count == 0)
{ {
_logger.LogWarning("DoWork. Orders is null or empty"); _logger.LogWarning("DoWork. Orders is null or empty");
return;
} }
_logger.LogDebug("DoWork for {Count} orders", orders.Count); _logger.LogDebug("DoWork for {Count} orders", orders?.Count);
foreach (var implementer in implementers) foreach (var implementer in implementers)
{ {
Task.Run(() => WorkerWorkAsync(implementer, orders)); Task.Run(() => WorkerWorkAsync(implementer, orders));
@ -55,11 +54,12 @@ namespace AbstractFoodOrdersBusinessLogic.BusinessLogics
/// <param name="orders"></param> /// <param name="orders"></param>
private async Task WorkerWorkAsync(ImplementerViewModel implementer, List<OrderViewModel>? orders) private async Task WorkerWorkAsync(ImplementerViewModel implementer, List<OrderViewModel>? orders)
{ {
if (_orderLogic == null || implementer == null || orders == null) if (_orderLogic == null || implementer == null)
{ {
return; return;
} }
await RunOrderInWork(implementer); await RunOrderInWork(implementer);
if (orders == null || orders.Count == 0) if (orders == null || orders.Count == 0)
return; return;
@ -83,6 +83,8 @@ namespace AbstractFoodOrdersBusinessLogic.BusinessLogics
{ {
Id = order.Id Id = order.Id
}); });
// отдыхаем
await Task.Delay(implementer.Qualification * _rnd.Next(10, 100));
} }
// кто-то мог уже перехватить заказ, игнорируем ошибку // кто-то мог уже перехватить заказ, игнорируем ошибку
catch (InvalidOperationException ex) catch (InvalidOperationException ex)
@ -95,8 +97,6 @@ namespace AbstractFoodOrdersBusinessLogic.BusinessLogics
_logger.LogError(ex, "Error while do work"); _logger.LogError(ex, "Error while do work");
throw; throw;
} }
// отдыхаем
await Task.Delay(implementer.Qualification * _rnd.Next(10, 100));
} }
}); });
} }
@ -133,7 +133,7 @@ namespace AbstractFoodOrdersBusinessLogic.BusinessLogics
Id = runOrder.Id Id = runOrder.Id
}); });
// отдыхаем // отдыхаем
await Task.Delay(implementer.Qualification * _rnd.Next(10, 100)); Thread.Sleep(implementer.Qualification * _rnd.Next(10, 100));
} }
// заказа может не быть, просто игнорируем ошибку // заказа может не быть, просто игнорируем ошибку
catch (InvalidOperationException ex) catch (InvalidOperationException ex)