src/Services/Transaction/Workflow/EventSubscriber/Internal/UpdateCreditorsJsonSubscriber.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\Services\Transaction\Workflow\EventSubscriber\Internal;
  5. use App\Entity\Client;
  6. use App\Entity\Transaction;
  7. use Doctrine\ORM\EntityManager;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\Workflow\Event\Event;
  12. class UpdateCreditorsJsonSubscriber implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var EntityManager
  16.      */
  17.     private $entityManager;
  19.     public function __construct(EntityManagerInterface $entityManager)
  20.     {
  21.         /** @var EntityManager $em */
  22.         $em = $entityManager;
  23.         $this->entityManager = $em;
  24.     }
  26.     public static function getSubscribedEvents()
  27.     {
  28.         return [
  29.             'workflow.internal_transaction_creating.entered.created' => 'prepareToUpdateCreditorsJson',
  30.             'workflow.sepa_transaction_creating.entered.created' => 'prepareToUpdateCreditorsJson',
  31.             'workflow.starling_payment_outbound.entered.created' => 'prepareToUpdateCreditorsJson',
  32.             'workflow.swift_outbound.entered.created' => 'prepareToUpdateCreditorsJson',
  33.         ];
  34.     }
  36.     public function prepareToUpdateCreditorsJson(Event $event)
  37.     {
  38.         /** @var Transaction $transaction */
  39.         $transaction = $event->getSubject()->getEntity();
  40.         /** @var Client $debitor */
  41.         if (!$debitor = $transaction->getDebtorClient()) {
  42.             return;
  43.         }
  45.         if ($debitor->isPerson()) {
  46.             $settings = $debitor->getPerson()->getPersonSettings();
  47.             if (!$settings) {
  48.                 return;
  49.             }
  50.             $settings->setCreditorsPrepareAt($transaction->getCreatedAt());
  51.             $this->entityManager->persist($settings);
  52.             $this->entityManager->flush($settings);
  54.             return;
  55.         }
  57.         $settings = $debitor->getCompany()->getCompanySettings();
  58.         if (!$settings) {
  59.             return;
  60.         }
  61.         $settings->setCreditorsPrepareAt($transaction->getCreatedAt());
  63.         $this->entityManager->persist($settings);
  64.         $this->entityManager->flush($settings);
  65.     }
  66. }