src/Order/Workflow/OrderSubscriber.php line 47

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Order\Workflow;
  7. use App\Order\Doctrine\Entity\Detail;
  8. use App\Order\Doctrine\Entity\Order;
  9. use Doctrine\Common\Collections\Collection;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\Workflow\Event\Event;
  12. use Symfony\Component\Workflow\Event\GuardEvent;
  13. use Symfony\Component\Workflow\WorkflowInterface;
  15. final class OrderSubscriber implements EventSubscriberInterface
  16. {
  17.     public function __construct(private WorkflowInterface $detailStateMachine)
  18.     {
  19.     }
  21.     /**
  22.      * {@inheritdoc}
  23.      */
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             'workflow.order.completed' => ['onCompleted'],
  28.             'workflow.order.completed.cancel' => ['onCompletedCancel'],
  29.             'workflow.order.guard.process' => ['guardProcess'],
  30.         ];
  31.     }
  33.     public function guardProcess(GuardEvent $event): void
  34.     {
  35.         /** @var Order $order */
  36.         $order = $event->getSubject();
  38.         if (
  39.             $order->getDetailsToDeliver()->count() > 0
  40.             || $order->getDetailsToShip()->count() > 0
  41.             || $order->getDetailsToProcess()->count() > 0
  42.         ) {
  43.             $event->setBlocked(true);
  44.         }
  45.     }
  47.     public function onCompletedCancel(Event $event): void
  48.     {
  49.         /** @var Order $order */
  50.         $order = $event->getSubject();
  52.         /** @var Collection<int, Detail> $detailsToCancel */
  53.         $detailsToCancel = $order->getDetails()
  54.             ->filter(fn (Detail $detail) => $this->detailStateMachine->can($detail, 'cancel'));
  56.         foreach ($detailsToCancel as $detail) {
  57.             $this->detailStateMachine->apply($detail, 'cancel');
  58.         }
  60.         $order->addStateHistory($order->getState());
  61.     }
  63.     public function onCompleted(Event $event): void
  64.     {
  65.         /** @var Order $order */
  66.         $order = $event->getSubject();
  68.         $order->addStateHistory($order->getState());
  69.     }
  70. }