src/InvoiceBundle/Listener/WorkFlowSubscriber.php line 46

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of SolidInvoice project.
  7.  *
  8.  * (c) Pierre du Plessis <open-source@solidworx.co>
  9.  *
  10.  * This source file is subject to the MIT license that is bundled
  11.  * with this source code in the file LICENSE.
  12.  */
  14. namespace SolidInvoice\InvoiceBundle\Listener;
  16. use Carbon\Carbon;
  17. use Doctrine\Persistence\ManagerRegistry;
  18. use SolidInvoice\InvoiceBundle\Entity\Invoice;
  19. use SolidInvoice\InvoiceBundle\Entity\RecurringInvoice;
  20. use SolidInvoice\InvoiceBundle\Model\Graph;
  21. use SolidInvoice\InvoiceBundle\Notification\InvoiceStatusNotification;
  22. use SolidInvoice\NotificationBundle\Notification\NotificationManager;
  23. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. use Symfony\Component\Workflow\Event\Event;
  25. use Symfony\Component\Workflow\Transition;
  27. /**
  28.  * @see \SolidInvoice\InvoiceBundle\Tests\Listener\WorkFlowSubscriberTest
  29.  */
  30. class WorkFlowSubscriber implements EventSubscriberInterface
  31. {
  32.     public function __construct(
  33.         private readonly ManagerRegistry $registry,
  34.         private readonly NotificationManager $notification
  35.     ) {
  36.     }
  38.     public static function getSubscribedEvents()
  39.     {
  40.         return [
  41.             'workflow.invoice.entered' => 'onWorkflowTransitionApplied',
  42.             'workflow.recurring_invoice.enter' => 'onWorkflowTransitionApplied',
  43.         ];
  44.     }
  46.     public function onWorkflowTransitionApplied(Event $event): void
  47.     {
  48.         /** @var Invoice|RecurringInvoice $invoice */
  49.         $invoice = $event->getSubject();
  51.         if (($transition = $event->getTransition()) instanceof Transition) {
  52.             if (Graph::TRANSITION_PAY === $transition->getName()) {
  53.                 $invoice->setPaidDate(Carbon::now());
  54.             }
  56.             if (Graph::TRANSITION_ARCHIVE === $transition->getName()) {
  57.                 $invoice->archive();
  58.             }
  59.         }
  61.         $em = $this->registry->getManager();
  62.         $em->persist($invoice);
  63.         $em->flush();
  65.         if (Graph::STATUS_NEW !== $invoice->getStatus()) {
  66.             $this->notification->sendNotification('invoice_status_update', new InvoiceStatusNotification(['invoice' => $invoice]));
  67.         }
  68.     }
  69. }