src/Invoice/EventSubscriber/SendPaymentNotificationSubscriber.php line 55

  1. <?php
  3. declare(strict_types=1);
  4. /**
  5.  * Copyright (c) 2022 TECLA Consulting Group oü.
  6.  * All rights reserved.
  7.  *
  8.  * This unpublished material is proprietary to TECLA Consulting Group oü.
  9.  * All rights reserved. The methods and
  10.  * techniques described herein are considered trade secrets
  11.  * and/or confidential. Reproduction or distribution, in whole
  12.  * or in part, is forbidden except by express written permission
  13.  * of TECLA Consulting Group oü.
  14.  *
  15.  * @author    Matúš Sýkorjak <matus@tecla.no>
  16.  * @copyright 2022 TECLA Consulting Group oü
  17.  */
  19. namespace App\Invoice\EventSubscriber;
  21. use App\Invoice\Event\InvoicePayment\CreatedEvent;
  22. use App\Invoice\Query\InvoicePaymentNotification\FindAllSuitableRecipientsQueryInterface;
  23. use App\Invoice\Util\InvoicePaymentNotificationMailerInterface;
  24. use JetBrains\PhpStorm\ArrayShape;
  25. use Psr\Log\LoggerInterface;
  26. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  27. use Throwable;
  29. final class SendPaymentNotificationSubscriber implements EventSubscriberInterface
  30. {
  31.     private FindAllSuitableRecipientsQueryInterface $findAllSuitableRecipientsQuery;
  33.     private InvoicePaymentNotificationMailerInterface $invoicePaymentNotificationMailer;
  35.     private LoggerInterface $logger;
  37.     public function __construct(
  38.         FindAllSuitableRecipientsQueryInterface $findAllSuitableRecipientsQuery,
  39.         InvoicePaymentNotificationMailerInterface $invoicePaymentNotificationMailer,
  40.         LoggerInterface $logger
  41.     ) {
  42.         $this->findAllSuitableRecipientsQuery = $findAllSuitableRecipientsQuery;
  43.         $this->invoicePaymentNotificationMailer = $invoicePaymentNotificationMailer;
  44.         $this->logger = $logger;
  45.     }
  47.     #[ArrayShape([CreatedEvent::class => 'string'])]
  48.     public static function getSubscribedEvents(): array
  49.     {
  50.         return [
  51.             CreatedEvent::class => 'onCreated',
  52.         ];
  53.     }
  55.     public function onCreated(CreatedEvent $event): void
  56.     {
  57.         $invoicePayment = $event->getInvoicePayment();
  58.         $invoice = $invoicePayment->getInvoice();
  59.         $supplier = $invoice->getSupplier();
  60.         $customer = $invoice->getCustomer();
  62.         $invoicePaymentNotifications = $this->findAllSuitableRecipientsQuery->execute($supplier, $customer);
  64.         foreach ($invoicePaymentNotifications as $invoicePaymentNotification) {
  65.             try {
  66.                 $this->invoicePaymentNotificationMailer->send(
  67.                     $invoicePaymentNotification->getSubscriber(),
  68.                     $invoicePayment
  69.                 );
  70.             } catch (Throwable $e) {
  71.                 $this->logger->error('Failed to send invoice payment notification', [
  72.                     'subscriber' => $invoicePaymentNotification->getSubscriber()->getId()->toRfc4122(),
  73.                     'invoicePayment' => $invoicePayment->getId()->toRfc4122(),
  74.                     'exception' => $e,
  75.                 ]);
  76.             }
  77.         }
  78.     }
  79. }