Revizuire: cod aplicat
Clasa conține logica pentru procesarea noilor comenzi. Extrage comenzile și pozițiile din baza de date, apoi face o solicitare HTTP către un microserviciu extern Stock, în care rezervă produsele conform pozițiilor comenzii. Dacă toate rezervările sunt efectuate cu succes, microserviciul confirmă rezervarea comenzii în Stock și marchează comanda ca procesată. Microserviciul rulează în mai multe instanțe, așa că metoda Process poate fi executată în paralel. Pentru a evita procesarea aceluiași rând, se utilizează un mecanism de blocare pesimistă în PostgreSQL Select for update ... skip locked. Implementarea IBus trimite mesaje către 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;" }
};
```
