Revisione: codice applicato
La classe contiene la logica per elaborare nuovi ordini. Estrae gli ordini e le posizioni dal database, quindi effettua una chiamata HTTP a un microservizio esterno Stock, che riserva i prodotti in base alle posizioni dell'ordine. Se tutte le riserve vengono completate con successo, il microservizio conferma la riserva dell'ordine in Stock e segna l'ordine come elaborato. Il microservizio viene eseguito in più istanze, quindi il metodo Process può essere eseguito in parallelo. Per evitare di elaborare le stesse righe, viene utilizzato un meccanismo di blocco pessimistico in PostgreSQL Select for update ... skip locked. L'implementazione di IBus invia messaggi a 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;" }
};
```
