Revisão: código aplicado
A classe contém a lógica para processar novos pedidos. Extrai os pedidos e as posições do banco de dados, depois faz uma chamada HTTP a um microserviço externo Stock, que reserva os produtos de acordo com as posições do pedido. Se todas as reservas forem bem-sucedidas, o microserviço confirma a reserva do pedido em Stock e marca o pedido como processado. O microserviço é executado em várias instâncias, portanto o método Process pode ser executado em paralelo. Para evitar processar as mesmas linhas, utiliza-se um mecanismo de bloqueio pesimista no PostgreSQL Select for update ... skip locked. A implementação de IBus envia mensagens ao RabbitMq.
```csharp
public sealed class PendingOrdersProcessor
{
public async Task PendingOrdersProcessor(ILogger logger, IBus bus, HttpStockService st
{
var env = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
var cs = _cs[env];
_db = new OrdersRepository(cs);
_bus = bus;
logger = logger;
```
```csharp
_stockService = stockService;
}
private readonly ILogger _logger;
private readonly IOrdersRepository _db;
private readonly IStockService _stockService;
private readonly IBus _bus;
private static readonly Dictionary<string, string> _cs = new {
{ "Development",
"User ID=root;Password=myPassword;Host=localhost;Port=5432;Database=myDataBase"
},
{ "Production", "User ID=root;Password=myPassword;Host=prod-db;Port=5432;Database="
"Pooling=true;Min Pool Size=0;Max Pool Size=1;" }
};
```
