ERP/AccountingBundle/EventSubscriber/WorkflowTransitionNotifier.php line 17

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace ERP\AccountingBundle\EventSubscriber;
  7. use ApiPlatform\Core\EventListener\EventPriorities;
  8. use Doctrine\Common\Collections\ArrayCollection;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use ERP\AccountingBundle\Entity\Invoice;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpKernel\Event\ViewEvent;
  13. use Symfony\Component\HttpKernel\KernelEvents;
  14. use Symfony\Component\Workflow\Registry;
  15. use Symfony\Component\Workflow\Transition;
  17. class WorkflowTransitionNotifier implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var Registry
  21.      */
  22.     private $workflowRegistry;
  24.     /**
  25.      * @var EntityManagerInterface
  26.      */
  27.     private $entityManager;
  29.     public function __construct(
  30.         Registry $workflowRegistry,
  31.         EntityManagerInterface $entityManager
  32.     ) {
  33.         $this->workflowRegistry = $workflowRegistry;
  34.         $this->entityManager = $entityManager;
  35.     }
  37.     /**
  38.      * {@inheritdoc}
  39.      */
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             KernelEvents::VIEW => [
  44.                 ['onCreateEnterDraft', EventPriorities::POST_WRITE],
  45.             ],
  46.             'workflow.invoice.entered' => 'onEntered',
  47.         ];
  48.     }
  50.     public function onCreateEnterDraft(ViewEvent $event): void
  51.     {
  52.         if ('POST' === $event->getRequest()->getMethod() && (($invoice = $event->getControllerResult()) instanceof Invoice)) {
  53.             if (Invoice::STATUS_EXPECTED === $invoice->getStatus()) {
  54.                 $applyTransition = 'create_expected';
  55.             } else {
  56.                 $applyTransition = 'create_unpaid';
  57.             }
  59.             $workflow = $this->workflowRegistry->get($invoice);
  61.             $enabledTransitions = new ArrayCollection($workflow->getEnabledTransitions($invoice));
  62.             if ($enabledTransitions->exists(function ($key, Transition $transition) use ($applyTransition) {
  63.                 return $applyTransition === $transition->getName();
  64.             })) {
  65.                 $transition = $enabledTransitions
  66.                     ->filter(function (Transition $transition) use ($applyTransition) {
  67.                         return $applyTransition === $transition->getName();
  68.                     })
  69.                     ->first();
  71.                 $workflow->apply($invoice, $transition->getName());
  72.                 $this->entityManager->flush();
  73.             }
  74.         }
  75.     }
  76. }