Изменена имитация работы исполнителя
This commit is contained in:
parent
ba7af57051
commit
d3d50c01aa
@ -61,15 +61,44 @@ namespace ConfectioneryBusinessLogic
|
|||||||
{
|
{
|
||||||
return;
|
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 RunOrderInWork(implementer, orders);
|
||||||
|
|
||||||
await Task.Run(() => RunWorkToOrders(implementer, orders));
|
await Task.Run(() =>
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
private void RunWorkToOrders(ImplementerViewModel implementer, List<OrderViewModel> orders)
|
|
||||||
{
|
{
|
||||||
foreach (var order in orders)
|
foreach (var order in orders.Where(x => x.Status == OrderStatus.Принят))
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
@ -102,6 +131,9 @@ namespace ConfectioneryBusinessLogic
|
|||||||
// отдыхаем
|
// отдыхаем
|
||||||
Thread.Sleep(implementer.Qualification * _rnd.Next(10, 100));
|
Thread.Sleep(implementer.Qualification * _rnd.Next(10, 100));
|
||||||
}
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
Loading…
x
Reference in New Issue
Block a user