Revue : code appliqué
La classe contient la logique de traitement des nouvelles commandes. Elle extrait les commandes et les positions de la base de données, puis effectue une requête HTTP vers un microservice externe Stock, qui réserve les produits selon les positions de la commande. Si toutes les réservations sont réussies, le microservice confirme la réservation de la commande dans Stock et marque la commande comme traitée. Le microservice est lancé en plusieurs instances, donc la méthode Process peut s'exécuter en parallèle. Pour éviter de traiter les mêmes lignes, un mécanisme de verrouillage pessimiste dans PostgreSQL Select for update ... skip locked est utilisé. L'implémentation de IBus envoie des messages à 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;" }
};
```
