src/EventSubscriber/CustomerWorkflowChangedSubscriber.php line 57

Open in your IDE?
  1. <?php
  2. /**
  3.  * This file is part of the CosaVostra, TrackPay package.
  4.  *
  5.  * (c) Mohamed Radhi GUENNICHI <rg@mate.tn> <+216 50 711 816>
  6.  *
  7.  * For the full copyright and license information, please view the LICENSE
  8.  * file that was distributed with this source code.
  9.  */
  11. declare(strict_types=1);
  13. namespace App\EventSubscriber;
  15. use App\Entity\Organization;
  16. use App\Entity\Procedure;
  17. use App\Event\CustomerWorkflowChangedEvent;
  18. use App\Manager\ProcedureManager;
  19. use App\Repository\ProcedureRepository;
  20. use Doctrine\ORM\EntityManagerInterface;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. class CustomerWorkflowChangedSubscriber implements EventSubscriberInterface
  24. {
  25.     /**
  26.      * @var ProcedureManager
  27.      */
  28.     protected $procedureManager;
  30.     /**
  31.      * @var ProcedureRepository
  32.      */
  33.     protected $procedureRepository;
  35.     /**
  36.      * @var EntityManagerInterface
  37.      */
  38.     protected $entityManager;
  40.     public function __construct(ProcedureManager $procedureManager, ProcedureRepository $procedureRepository, EntityManagerInterface $entityManager)
  41.     {
  42.         $this->procedureRepository = $procedureRepository;
  43.         $this->entityManager       = $entityManager;
  44.         $this->procedureManager    = $procedureManager;
  45.     }
  47.     /**
  48.      * @inheritDoc
  49.      */
  50.     public static function getSubscribedEvents()
  51.     {
  52.         return [
  53.             CustomerWorkflowChangedEvent::class => 'onWorkflowChanged'
  54.         ];
  55.     }
  57.     public function onWorkflowChanged(CustomerWorkflowChangedEvent $event): void
  58.     {
  59.         // Get procedures with pending/paused status
  60.         $customer   = $event->getCustomer();
  61.         $procedures = $this->getNotActivatedProceduresFor($customer);
  62.         // Remove the pendingStep and dispatchedStep objects
  63.         foreach ($procedures as $procedure) {
  64.             $procedure->setWorkflow(
  65.                 $customer->getWorkflow()
  66.             );
  67.             $procedure->setDispatchedStep(null);
  68.             // Remove the dispatchedStep object, we don't need it anymore here.
  69.             if (null !== $procedure->getPendingStep()) {
  70.                 $this->entityManager->remove($procedure->getPendingStep());
  71.                 $procedure->setPendingStep(null);
  72.             }
  74.             // Flush changes.
  75.             $this->entityManager->flush();
  77.             // Process the new workflow
  78.             $this->procedureManager->proceed($procedure);
  79.         }
  80.     }
  82.     /**
  83.      * @param Organization $customer
  84.      *
  85.      * @return Procedure[]
  86.      */
  87.     protected function getNotActivatedProceduresFor(Organization $customer): array
  88.     {
  89.         $queryBuilder = $this->procedureRepository->createQueryBuilder('o');
  91.         return $queryBuilder
  92.             ->innerJoin('o.invoice', 'invoice')
  93.             ->andWhere(
  94.                 $queryBuilder->expr()->eq('invoice.customer', ':customer')
  95.             )
  96.             ->andWhere(
  97.                 $queryBuilder->expr()->in('o.status', ':status')
  98.             )
  99.             ->andWhere(
  100.                 $queryBuilder->expr()->isNull('o.activatedAt')
  101.             )
  102.             ->setParameters([
  103.                 'customer' => $customer,
  104.                 'status'   => [Procedure::STATUS_PENDING, Procedure::STATUS_PAUSED]
  105.             ])
  106.             ->getQuery()
  107.             ->getResult();
  108.     }
  109. }