src/Queue/ProcedureQueueSubscriber.php line 83

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\Queue;
  15. use App\Connector\DriverRegistry;
  16. use App\Entity\Media;
  17. use App\Entity\Procedure;
  18. use App\Service\Sendinblue\SMTPApi;
  19. use App\Service\UrlGeneratorService;
  20. use DateTime;
  21. use Doctrine\ORM\EntityManagerInterface;
  22. use Exception;
  23. use JMS\Serializer\Serializer;
  24. use JMS\Serializer\SerializerInterface;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. use Symfony\Component\HttpFoundation\File\File;
  27. use function Sentry\captureException;
  29. class ProcedureQueueSubscriber implements EventSubscriberInterface
  30. {
  31.     public const EMAIL_TEMPLATE_ID = '26';
  33.     /**
  34.      * @var SMTPApi
  35.      */
  36.     protected $smtp;
  38.     /**
  39.      * @var SerializerInterface|Serializer
  40.      */
  41.     protected $serializer;
  43.     /**
  44.      * @var DriverRegistry
  45.      */
  46.     protected $driverRegistry;
  48.     /**
  49.      * @var UrlGeneratorService
  50.      */
  51.     protected $urlGenerator;
  53.     /**
  54.      * @var EntityManagerInterface
  55.      */
  56.     protected $entityManager;
  58.     public function __construct(
  59.         SMTPApi $smtp,
  60.         SerializerInterface $serializer,
  61.         DriverRegistry $driverRegistry,
  62.         UrlGeneratorService $urlGenerator,
  63.         EntityManagerInterface $entityManager
  64.     )
  65.     {
  66.         $this->smtp           = $smtp;
  67.         $this->serializer     = $serializer;
  68.         $this->driverRegistry = $driverRegistry;
  69.         $this->urlGenerator   = $urlGenerator;
  70.         $this->entityManager  = $entityManager;
  71.     }
  73.     /**
  74.      * @inheritDoc
  75.      */
  76.     public static function getSubscribedEvents()
  77.     {
  78.         return [
  79.             ProcedureQueueEvent::PROCEDURE_QUEUE_CLOSE => 'onClose'
  80.         ];
  81.     }
  83.     public function onClose(ProcedureQueueEvent $event): void
  84.     {
  85.         // SEND EMAIL NOTIFICATION TO DEBTOR TO NOTIFY HIM ABOUT THE CLOSURE.
  86.         $procedure = $event->getProcedure();
  87.         $invoice   = $procedure->getInvoice();
  89.         if ($procedure->isClosed() &&
  90.             null !== $procedure->getConnector() &&
  91.             $procedure->getCloseReason() === Procedure::CLOSE_REASON_PAID) {
  92.             // Here we need to update the remote invoice status.
  93.             $loader = $this->driverRegistry->connect($procedure->getConnector());
  94.             try {
  95.                 $loader->createPayment($invoice);
  97.                 sleep(2); // Wait until the third-part system update the invoice file.
  99.                 // Update invoice file.
  100.                 $invoiceFile = $loader->getInvoiceFile($invoice);
  101.                 if (is_string($invoiceFile)) {
  102.                     $invoice->setFileUrl($invoiceFile);
  103.                 }
  105.                 if ($invoiceFile instanceof File) {
  106.                     // Set the pdf file
  107.                     if (null !== $invoiceMedia = $invoice->getInvoiceFile()) {
  108.                         $invoiceMedia->setFile($invoiceFile);
  109.                     } else {
  110.                         $invoice->setInvoiceFile(
  111.                             (new Media())->setFile($invoiceFile)
  112.                         );
  113.                     }
  114.                 }
  116.                 $this->entityManager->flush();
  118.             } catch (Exception $exception) {
  119.                 captureException($exception);
  120.                 $event->setFailed(true, $exception->getMessage());
  122.                 return;
  123.             }
  124.         }
  126.         if (!$procedure->hasStepsSentToCustomer()) {
  127.             return;
  128.         }
  130.         $logo = null;
  132.         if (null !== $logoMedia = $invoice->getAccount()->getLogo()) {
  133.             $logo = $this->urlGenerator->getMediaFileUrl($logoMedia);
  134.         }
  136.         $invoiceSerialized = $this->serializer->toArray($invoice);
  138.         if (null !== $invoice->getInvoiceFile()) {
  139.             $invoiceSerialized['full_file_url'] = $this->urlGenerator->generate('app_page_procedure_invoice', [
  140.                 'procedure' => $procedure->getId()
  141.             ]);
  142.         }
  144.         $parameters = [
  145.             'invoice' => $invoiceSerialized,
  146.             'reason'  => $procedure->getCloseReason(),
  147.             'info'    => [
  148.                 'now' => (new DateTime())->format(DATE_ATOM)
  149.             ],
  150.             'logo'    => $logo
  151.         ];
  153.         $contacts = $invoice->getActiveCustomerContacts();
  155.         if ($contacts->isEmpty()) {
  156.             $this->smtp->send(
  157.                 $invoice->getDebtorName(),
  158.                 $invoice->getDebtorEmail(),
  159.                 self::EMAIL_TEMPLATE_ID,
  160.                 $parameters,
  161.                 []
  162.             );
  163.         } else {
  164.             $this->smtp->sendToContacts(
  165.                 $contacts,
  166.                 self::EMAIL_TEMPLATE_ID,
  167.                 $parameters,
  168.                 []
  169.             );
  170.         }
  171.     }
  172. }