Databázová transakce

Importer obdrží objednávku, jejíž odpověď se může kvůli timeoutu opakovat. V krátké transakci založí objednávku a integrační záznam; položky by vznikaly stejným lokálním krokem. Unikátní constraint nad marketplace a external_order_id chrání proti druhému založení; při duplicitě aplikace načte už existující objednávku.

Po commitu se samostatný worker postará o odeslání informace do dalších systémů. Pokud odeslání selže, nevrací se již hotová objednávka zpět. Retry pracuje s uloženým outbox záznamem a idempotentním významem události.

try {
    $connection->beginTransaction();

    $connection->insert('marketplace_order', [
        'marketplace' => 'example-market',
        'external_order_id' => $externalOrderId,
        'status' => 'new',
    ]);
    $connection->insert('outbox_event', [
        'type' => 'order.imported',
        'payload' => json_encode(['externalOrderId' => $externalOrderId], JSON_THROW_ON_ERROR),
    ]);

    $connection->commit();
} catch (\Throwable $exception) {
    if ($connection->isTransactionActive()) {
        $connection->rollBack();
    }

    throw $exception;
}