src/Listener/V2/AppEventSubscriber.php line 83

Open in your IDE?
  1. <?php
  3. namespace App\Listener\V2;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use App\Entity;
  7. use App\Event;
  9. /**
  10.  * Met à jour les meta data des utilisateurs avec les events custom de l'app
  11.  * Fais les majs des meta data avec des native query pour sortir du lifecycle
  12.  */
  13. class AppEventSubscriber implements EventSubscriberInterface
  14. {
  16.   protected $mailjet;
  18.   public function __construct(\App\Service\Mailjet $mailjet)
  19.   {
  20.     $this->mailjet = $mailjet;
  21.   }
  23.   public static function getSubscribedEvents()
  24.   {
  25.     return [
  26.       Event\UserLoginEvent::NAME  => ['onAppUserLogin', 0],
  27.       Event\UserActionEvent::NAME => ['onAppUserAction', 0],
  28.       Event\EmailSentEvent::NAME  => ['onAppEmailSent', 0],
  29.     ];
  30.   }
  32.   /**
  33.    * Quand un utilisateur se log (utilisé aussi quand il clique sur un lien)
  34.    */
  35.   public function onAppUserLogin(Event\UserLoginEvent $event)
  36.   {
  37.     $em   = $event->getEntityManager();
  38.     $user = $event->getUser();
  39.     if ($user instanceof Entity\User) {
  40.       $date = new \DateTime('now');
  41.       $date = $date->format('Y-m-d H:i:s');
  43.       $em->getConnection()->prepare("INSERT INTO user_meta_data
  44.         SET last_connection = '" . $date . "',
  45.         user_id = '" . $user->getId() . "'
  46.         ON DUPLICATE KEY UPDATE
  47.         last_connection = '" . $date . "'
  48.       ")->execute();
  50.       // Mailetjet dernière connexion
  51.       $this->mailjet->updateContacts($user, [
  52.         'derniere_connexion' => time()
  53.       ]);
  54.     }
  55.   }
  57.   /**
  58.    * Quand un utilisateur fait une action
  59.    */
  60.   public function onAppUserAction(Event\UserActionEvent $event)
  61.   {
  62.     $em     = $event->getEntityManager();
  63.     $user   = $event->getUser();
  64.     $action = $event->getAction();
  65.     if ($user instanceof Entity\User) {
  66.       $date = new \DateTime('now');
  67.       $date = $date->format('Y-m-d H:i:s');
  69.       $em->getConnection()->prepare("INSERT INTO user_meta_data
  70.         SET last_action = '" . $action . "',
  71.         last_action_date = '" . $date . "',
  72.         user_id = '" . $user->getId() . "'
  73.         ON DUPLICATE KEY UPDATE
  74.         last_action = '" . $action . "',
  75.         last_action_date = '" . $date . "'
  76.       ")->execute();
  77.     }
  78.   }
  80.   /**
  81.    * Quand un mail est reçu
  82.    */
  83.   public function onAppEmailSent(Event\EmailSentEvent $event)
  84.   {
  85.     $em      = $event->getEntityManager();
  86.     $dests   = $event->getDests();
  87.     $subject = $event->getSubject();
  88.     $subject = addslashes($subject);
  89.     foreach ($dests as $email => $user) {
  90.       if ($user instanceof Entity\User) {
  91.         $date = new \DateTime('now');
  92.         $date = $date->format('Y-m-d H:i:s');
  94.         $em->getConnection()->prepare("INSERT INTO user_meta_data
  95.           SET last_received_email = '" . $subject . "',
  96.           last_received_email_date = '" . $date . "',
  97.           user_id = '" . $user->getId() . "'
  98.           ON DUPLICATE KEY UPDATE
  99.           last_received_email = '" . $subject . "',
  100.           last_received_email_date = '" . $date . "'
  101.         ")->execute();
  102.       }
  103.     }
  104.   }
  105. }