src/EventSubscriber/OSAdminEventSubscriberSubscriber.php line 31

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\ApplicantReview;
  6. use App\Entity\Applicants;
  7. use App\Entity\Jobs;
  8. use App\Features\Applicant\ApplicantFilter;
  9. use App\Features\Mailer\Exception\IMailerException;
  10. use App\Features\Mailer\IMailer;
  11. use App\Repository\ApplicantsRepository;
  12. use OSAdmin\Event\OSAdminPersistEvent;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  15. use Symfony\Component\Security\Core\Security;
  17. class OSAdminEventSubscriberSubscriber implements EventSubscriberInterface
  18. {
  19.     public function __construct(private readonly ApplicantsRepository $repository,
  20.                                 private IMailer $applicantMailer,
  21.                                 private Security $security,
  22.                                 private UrlGeneratorInterface $generator){}
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             OSAdminPersistEvent::NAME => 'onPersist',
  28.         ];
  29.     }
  31.     public function onPersist(OSAdminPersistEvent $event): void
  32.     {
  33.         $object = $event->getEntity();
  34.         if($object instanceof Jobs){
  35.             $job = $object;
  36.             $activitySectors= $job->getSectors();
  37.             // send mail to all applicant whose sector is in the $activitySectors
  38.             $filter= (new ApplicantFilter())
  39.                 ->setSectors($activitySectors->toArray())
  40.                 ->setEnabled(true);
  42.             $applicants = $this->repository->filter($filter)->getQuery()->getResult();
  43.             // filter applicant who when receive new job notification is true
  44.             $applicants = array_filter($applicants, static fn(Applicants $applicant) => $applicant->getConfig() && $applicant->getConfig()->getReceiveNewJobAlert());
  46.             if($applicants){
  47.                 $jobLink= $this->generator->generate('job-detail', ['uuid' => $job->getUuid()], UrlGeneratorInterface::ABSOLUTE_URL);
  48.                 // send mail to all applicant with message: "Une nouvelle offre d'emploi a été publiée dans votre secteur d'activité. Le lien vers la page de l'offre d'emploi est $jobLink."
  49.                 $text= "Une nouvelle offre d'emploi a été publiée dans votre secteur d'activité. Le lien vers la page de l'offre d'emploi est $jobLink.";
  50.                 $html= "<p>Une nouvelle offre d'emploi a été publiée dans votre secteur d'activité. Le lien vers la page de l'offre d'emploi est <a href='$jobLink'>$jobLink</a></p>";
  52.                 try {
  53.                     $this->applicantMailer->send($html, $text, ...$applicants);
  54.                 } catch (IMailerException $e) {
  56.                 }
  57.             }
  58.         }
  60.         if($object instanceof ApplicantReview){
  61.             $object->setCreatedBy($this->security->getUser());
  62.         }
  63.     }
  64. }