src/EventSubscriber/AudienceSubscriber.php line 33

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Audience;
  6. use App\Entity\User;
  7. use App\Events\AudienceEvent;
  8. use App\Repository\UserRepository;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class AudienceSubscriber implements EventSubscriberInterface
  14. {
  15.     private EntityManagerInterface $em;
  16.     private UserRepository $userRepository;
  18.     public function __construct(
  19.         EntityManagerInterface $em,
  20.         UserRepository         $userRepository
  21.     ) {
  22.         $this->em = $em;
  23.         $this->userRepository = $userRepository;
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             AudienceEvent::class => 'onUpdate'
  30.         ];
  31.     }
  33.     public function onUpdate(AudienceEvent $event): void
  34.     {
  35.         $audience = $event->getAudience();
  38.         if ($audience->getType() === Audience::TYPE_PUBLIC || $audience->getStatus() !== Audience::STATUS_PUBLISHED) {
  39.             return;
  40.         }
  42.         $audience->setIsGenerating(true);
  43.         foreach ($audience->getUsers() as $user) {
  44.             $audience->removeUser($user);
  45.         }
  46.         $this->em->persist($audience);
  47.         $this->em->flush();
  50.         $filter_categories = $audience->getFilterCategories()->map(function ($el) {
  51.             return $el->getId();
  52.         })->getValues();
  54.         $filter_roles = $audience->getFilterRoles()->map(function ($el) {
  55.             return $el->getId();
  56.         })->getValues();
  58.         $filter_tags = $audience->getFilterTags()->map(function ($el) {
  59.             return $el->getId();
  60.         })->getValues();
  62.         $filter_users = $audience->getFilterUsers()->map(function ($el) {
  63.             return $el->getId();
  64.         })->getValues();
  66.         $filter_workgroups = $audience->getFilterWorkgroups()->map(function ($el) {
  67.             return $el->getId();
  68.         })->getValues();
  70.         $filter_workplaces = $audience->getFilterWorkplaces()->map(function ($el) {
  71.             return $el->getId();
  72.         })->getValues();
  74.         $filter_events = $audience->getFilterEvents()->map(function ($el) {
  75.             return $el->getId();
  76.         })->getValues();
  78.         $filters = $audience->getFilters();
  81.         $users = $this->userRepository->findAudienceBy(
  82.             [
  83.                 'headquarter' => $audience->getHeadquarter(),
  84.                 'status' => User::STATUS_PUBLISHED
  85.             ],
  86.             [
  87.                 'filter_categories' => $filter_categories ?? [],
  88.                 'filter_roles' => $filter_roles ?? [],
  89.                 'filter_tags' => $filter_tags ?? [],
  90.                 'filter_users' => $filter_users ?? [],
  91.                 'filter_workgroups' => $filter_workgroups ?? [],
  92.                 'filter_workplaces' => $filter_workplaces ?? [],
  93.                 'filter_gender' => $filters['gender'] ?? false,
  94.                 'filter_events' => $filter_events ?? [],
  95.             ]
  96.         );
  98.         foreach ($users as $user) {
  99.             $audience->addUser($user);
  100.         }
  102.         $audience->setIsGenerating(false);
  103.         $this->em->persist($audience);
  104.         $this->em->flush();
  105.     }
  106. }