Преглед: приложен код
Класът съдържа логиката за обработка на нови поръчки. Извлича поръчките и позициите от базата данни, след което прави HTTP заявка към външен микросервис Stock, който резервира продуктите според позициите на поръчката. Ако всички резервации са успешни, микросервисът потвърждава резервацията на поръчката в Stock и маркира поръчката като обработена. Микросервисът работи в няколко екземпляра, затова методът Process може да се изпълнява паралелно. За да се избегне обработката на същите редове, се използва механизъм за песимистично заключване PostgreSQL Select for update ... skip locked. Имплементацията на IBus изпраща съобщения към 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;" }
};
```
