src/V4/EventSubscriber/CustomEventTrigger/CustomEventTriggerPostPersistSubscriber.php line 81

Open in your IDE?
  1. <?php
  3. namespace App\V4\EventSubscriber\CustomEventTrigger;
  5. use App\Service\PreSendSerializer;
  6. use App\V4\Builder\CustomEventTrigger\CustomEventTriggerBuilder;
  7. use App\V4\Entity\CustomEventTrigger;
  8. use App\V4\Event\PostPersistEvent;
  9. use App\V4\EventSubscriber\AbstractSubscriber;
  10. use App\V4\Model\ChildrenAwareInterface;
  11. use App\V4\Model\Prospect\Prospect;
  12. use App\V4\Model\Quote\Quote;
  13. use App\V4\Repository\CustomEventTriggerRepository;
  14. use App\V4\Transformer\FQCNToShortNameTransformer;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\Serializer\Exception\ExceptionInterface;
  18. class CustomEventTriggerPostPersistSubscriber extends AbstractSubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var CustomEventTriggerRepository
  22.      */
  23.     private $customEventTriggerRepository;
  25.     /**
  26.      * @var CustomEventTriggerBuilder
  27.      */
  28.     private $customEventTriggerBuilder;
  30.     /**
  31.      * @var PreSendSerializer
  32.      */
  33.     private $serializer;
  35.     /**
  36.      * @param CustomEventTriggerRepository $customEventTriggerRepository
  37.      * @param CustomEventTriggerBuilder    $customEventTriggerBuilder
  38.      * @param PreSendSerializer            $serializer
  39.      */
  40.     public function __construct(
  41.         customEventTriggerRepository $customEventTriggerRepository,
  42.         CustomEventTriggerBuilder $customEventTriggerBuilder,
  43.         PreSendSerializer $serializer
  44.     ) {
  45.         $this->customEventTriggerRepository = $customEventTriggerRepository;
  46.         $this->customEventTriggerBuilder = $customEventTriggerBuilder;
  47.         $this->serializer = $serializer;
  48.     }
  50.     /**
  51.      * @return string[]
  52.      */
  53.     public static function getSubscribedEvents(): array
  54.     {
  55.         return [
  56.             PostPersistEvent::NAME => 'onPostPersist',
  57.         ];
  58.     }
  60.     /**
  61.      * @param $entity
  62.      *
  63.      * @return bool
  64.      */
  65.     public function supports($entity): bool
  66.     {
  67.         if (!$entity instanceof Quote && !$entity instanceof Prospect) {
  68.             return false;
  69.         }
  71.         if ($entity instanceof ChildrenAwareInterface && $entity->isSplit()) {
  72.             return false;
  73.         }
  75.         return true;
  76.     }
  78.     /**
  79.      * @throws ExceptionInterface
  80.      */
  81.     public function onPostPersist(PostPersistEvent $event): void
  82.     {
  83.         $entity = $event->getAfter();
  85.         if (!$this->supports($entity) || $this->isIdAlreadyManaged($entity->getId(), get_class($this))) {
  86.             return;
  87.         }
  89.         if (method_exists($entity, 'getCustomerFiles')) {
  90.             $files = $entity->getCustomerFiles();
  91.             $entity->setCustomerFiles([]);
  92.         }
  94.         $customEventTriggers = $this
  95.             ->customEventTriggerRepository
  96.             ->searchByEntityAndWhenApply(
  97.                 (new FQCNToShortNameTransformer())->transform(get_class($entity)),
  98.                 CustomEventTrigger::WHEN_POST_PERSIST
  99.             )
  100.         ;
  102.         foreach ($customEventTriggers as $customEventTrigger) {
  103.             $entitySerialized = $this->serializer->serialize($entity);
  105.             $this
  106.                 ->customEventTriggerBuilder
  107.                 ->getBuilder($entitySerialized, $customEventTrigger)
  108.                 ->apply($entitySerialized, $customEventTrigger)
  109.             ;
  110.         }
  112.         if (isset($files)) {
  113.             $entity->setCustomerFiles($files);
  114.         }
  115.     }
  116. }