Přejít k obsahu

Podmíněné větvení

Zobrazit jako Markdown Upravit na GitHub Dokumentace na 2cc7b2b

Workflow může na základě výstupu předchozího kroku přeskočit na pojmenovaný krok. Dosáhnete toho vrácením speciálního klíče _next_step v návratové hodnotě kroku.

Pokud chcete na základě stavu workflow skočit zpět na předchozí krok, podívejte se na Opakování. Zpětná vazba tak zůstane výslovně uvedená v definici workflow, místo aby byla skrytá ve třídě kroku.

Pojmenované kroky

Krok pojmenujete druhým argumentem ->then():

PHP
use Queuety\Queuety;

Queuety::workflow( 'process_order' )
    ->then( ValidateOrderHandler::class, 'validate' )
    ->then( ChargePaymentHandler::class, 'charge' )
    ->then( FulfillOrderHandler::class, 'fulfill' )
    ->then( SendConfirmationHandler::class, 'confirm' )
    ->then( HandleFailureHandler::class, 'failure' )
    ->dispatch( [ 'order_id' => 123 ] );

Pokud název neuvedete, kroky se pojmenují podle indexu ('0', '1', '2' atd.).

Klíč _next_step

Krok může vrátit _next_step a přejít tak na pojmenovaný krok, přičemž přeskočí všechny kroky mezi nimi. Kroky za cílem skoku se stále spouštějí v pořadí: bez skoku workflow jednoduše pokračuje dalším krokem v seznamu, takže v příkladu výše úspěšný krok confirm přejde rovnou na failure, pokud nevrátí _next_step, který jej přeskočí, nebo HandleFailureHandler nejprve nezkontroluje klíč error:

PHP
use Queuety\Step;

class ValidateOrderHandler implements Step {
    public function handle( array $state ): array {
        $order = wc_get_order( $state['order_id'] );

        if ( ! $order || $order->get_status() === 'cancelled' ) {
            return [
                'error'  => 'Order is invalid or cancelled',
                '_next_step'  => 'failure',
            ];
        }

        return [
            'order_total' => $order->get_total(),
            'customer_id' => $order->get_customer_id(),
        ];
    }

    public function config(): array {
        return [];
    }
}

Když ValidateOrderHandler vrátí _next_step => 'failure', workflow přeskočí charge, fulfill a confirm a přejde přímo ke kroku failure. Klíč _next_step zpracuje engine workflow a do stavu se neukládá.

Vzory větvení

Přeskočení podle podmínky

PHP
class CheckInventoryHandler implements Step {
    public function handle( array $state ): array {
        $in_stock = check_inventory( $state['sku'] );

        if ( ! $in_stock ) {
            return [
                'reason' => 'Out of stock',
                '_next_step'  => 'notify_backorder',
            ];
        }

        return [ 'inventory_reserved' => true ];
    }

    public function config(): array {
        return [];
    }
}

Předčasné dokončení

Přejděte na poslední krok a přeskočte zbytečné zpracování:

PHP
class CheckCacheHandler implements Step {
    public function handle( array $state ): array {
        $cached = get_transient( "report_{$state['user_id']}" );

        if ( $cached ) {
            return [
                'report_url' => $cached,
                '_next_step'      => 'done',
            ];
        }

        return [ 'cache_miss' => true ];
    }

    public function config(): array {
        return [];
    }
}

Kompletní příklad

PHP
Queuety::workflow( 'content_pipeline' )
    ->then( CheckCacheHandler::class, 'check_cache' )
    ->then( FetchDataHandler::class, 'fetch' )
    ->then( CallLLMHandler::class, 'generate' )
    ->then( SaveResultHandler::class, 'save' )
    ->then( ReturnCachedHandler::class, 'done' )
    ->dispatch( [ 'user_id' => 42 ] );

Pokud kontrola najde data v mezipaměti, workflow přejde z check_cache přímo na done a přeskočí fetch, generate a save. Pokud data nenajde, kroky se spustí v pořadí a save přejde také na done, takže ReturnCachedHandler musí zvládnout obě varianty.