src/EventSubscriber/ContainerSubscriber.php line 79

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\JobQueue;
  6. use App\Service\EsJobQueue;
  7. use App\Handler\ContainerHandler;
  8. use App\Event\ContainerPreRemoveEvent;
  9. use App\Event\ContainerPreUpdateEvent;
  10. use App\Event\ContainerPrePersistEvent;
  11. use App\Event\ContainerPostPersistEvent;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Symfony\Contracts\Cache\TagAwareCacheInterface;
  14. use App\Service\JobQueueAction\CloneContainerAction;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class ContainerSubscriber implements EventSubscriberInterface
  18. {
  19.     public function __construct(
  20.         private EntityManagerInterface $_em,
  21.         private ContainerHandler $containerHandler,
  22.         private TagAwareCacheInterface $esComCache,
  23.         private EsJobQueue $esJobQueue,
  24.     ) {
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             ContainerPrePersistEvent::NAME => 'preCreate',
  31.             ContainerPostPersistEvent::NAME => 'onCreate',
  32.             ContainerPreUpdateEvent::NAME => 'onUpdate',
  33.             ContainerPreRemoveEvent::NAME => 'onPreRemove'
  34.         ];
  35.     }
  37.     public function preCreate(ContainerPrePersistEvent $event)
  38.     {
  39.         $object = $event->getObject();
  40.         if ($object->getCloneId() < 1) {
  41.             $object = $this->containerHandler->createDefaultNavigation($object);
  42.             $object = $this->containerHandler->createDefaultUserStaticFields($object);
  43.         }
  44.         $event->setObject($object);
  45.     }
  47.     public function onCreate(ContainerPostPersistEvent $event)
  48.     {
  49.         $object = $event->getObject();
  50.         $oldId = $object->getOldId();
  51.         if ($oldId < 1) {
  52.             $this->containerHandler->createDefaultLanguage($object);
  53.             // $this->containerHandler->createDefaultEmailTemplate($object);
  54.         } else {
  55.             $this->containerHandler->copyLanguage($object, $oldId);
  56.             $this->containerHandler->copyBackground($object, $oldId);
  57.             $this->containerHandler->copyEmailTemplate($object, $oldId);
  58.             // $this->containerHandler->copyInfoPage($object, $oldId);
  59.             $object->removeAllUserGroups();
  60.         }
  61.         $this->containerHandler->createContainerUserGroup($object);
  62.         $this->containerHandler->attachSuperAdminToContainer($object);
  63.         if ($object->getClient()->getIsCommunitySharingEnable()) {
  64.             $this->containerHandler->assignUserGroupAllUser($object);
  65.         }
  67.         if ($oldId > 0) {
  68.             $this->esJobQueue->create(
  69.                 CloneContainerAction::NAME,
  70.                 json_encode([
  71.                     'containerId' => $object->getId()
  72.                 ]),
  73.                 JobQueue::PRIORITY_LOW,
  74.                 $object
  75.             );
  76.         }
  77.     }
  79.     public function onUpdate(ContainerPreUpdateEvent $event)
  80.     {
  81.         $object = $event->getObject();
  82.         //$this->esComCache->invalidateTags(['ES_CONTAINER_'.$object->getId(), 'ES_MY_CONTAINER_'.$object->getId()]);
  83.         $this->esComCache->invalidateTags(['ES_CONTAINER', 'ES_MY_CONTAINER', 'ES_CLIENT_CID']);
  84.     }
  86.     public function onPreRemove(ContainerPreRemoveEvent $event)
  87.     {
  88.         $object = $event->getObject();
  89.         $userGroups = $object->getUserGroups();
  90.         if ($userGroups) {
  91.             foreach ($userGroups as $userGroup) {
  92.                 if ($userGroup->getIsGenerated()) {
  93.                     $this->_em->remove($userGroup);
  94.                 }
  95.             }
  96.             $this->_em->flush();
  97.         }
  98.     }
  99. }