diff --git a/ConfectionaryBusinessLogic/WorkModeling.cs b/ConfectionaryBusinessLogic/WorkModeling.cs index c4d1bcc..b67e64c 100644 --- a/ConfectionaryBusinessLogic/WorkModeling.cs +++ b/ConfectionaryBusinessLogic/WorkModeling.cs @@ -61,15 +61,44 @@ namespace ConfectioneryBusinessLogic { return; } + // Заказы выполняются по заданию в таком приоритете: + // 1. Сначала заказы, которые в статусе ожидаются + // 2. Потом заказы, которые исполнитель уже выполняет + // 3. Новые заказы + + // Для заказов находящихся в статусе ожидания работник не должен делать никакую работу, а должен просто пытаться перевести их в статус готов + await Task.Run(() => + { + foreach (var order in orders.Where(x => x.Status == OrderStatus.Ожидается && x.ImplementerId == implementer.Id)) + { + try + { + _orderLogic.FinishOrder(new OrderBindingModel + { + Id = order.Id + }); + } + // кто-то мог уже перехватить заказ, игнорируем ошибку + catch (InvalidOperationException ex) + { + _logger.LogWarning(ex, "Error try get work"); + } + // заканчиваем выполнение имитации в случае иной ошибки + catch (Exception ex) + { + _logger.LogError(ex, "Error while do work"); + throw; + } + // отдыхаем + Thread.Sleep(implementer.Qualification * _rnd.Next(10, 100)); + } + }); + await RunOrderInWork(implementer, orders); - await Task.Run(() => RunWorkToOrders(implementer, orders)); - - } - - private void RunWorkToOrders(ImplementerViewModel implementer, List orders) - { - foreach (var order in orders) + await Task.Run(() => + { + foreach (var order in orders.Where(x => x.Status == OrderStatus.Принят)) { try { @@ -102,7 +131,10 @@ namespace ConfectioneryBusinessLogic // отдыхаем Thread.Sleep(implementer.Qualification * _rnd.Next(10, 100)); } - } + }); + + + } /// /// Ищем заказ, которые уже в работе (вдруг исполнителя прервали)