Revisión: código aplicado
La clase contiene la lógica para procesar nuevos pedidos. Extrae los pedidos y las posiciones de la base de datos, luego realiza una llamada HTTP a un microservicio externo Stock, en el cual reserva los productos según las posiciones del pedido. Si todas las reservas se realizan con éxito, el microservicio confirma la reserva del pedido en Stock y marca el pedido como procesado. El microservicio se ejecuta en varias instancias, por lo que el método Process puede ejecutarse en paralelo. Para evitar procesar las mismas líneas, se utiliza un mecanismo de bloqueo pesimista en PostgreSQL Select for update ... skip locked. La implementación de IBus envía mensajes 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;" }
};
```
