src/Postroyka/AccountBundle/EventListener/AccountChangeEmailListener.php line 29

Open in your IDE?
  1. <?php
  3. namespace Postroyka\AccountBundle\EventListener;
  5. use Doctrine\ORM\EntityManagerInterface;
  6. use Postroyka\AccountBundle\Provider\ExtendedUserProvider;
  7. use Postroyka\ApiBundle\RabbitMQ\B24\Producers\B24ExportUserProducer;
  8. use Submarine\ConfirmationBundle\Event\ConfirmEvent;
  9. use Submarine\UsersBundle\Service\UsersService;
  11. class AccountChangeEmailListener
  12. {
  13.     /**
  14.      * @param EntityManagerInterface $entityManager
  15.      * @param UsersService $usersService
  16.      * @param ExtendedUserProvider $extendedUserProvider
  17.      */
  18.     public function __construct(
  19.         private EntityManagerInterface $entityManager,
  20.         private UsersService $usersService,
  21.         private ExtendedUserProvider $extendedUserProvider,
  22.         private B24ExportUserProducer $b24ExportUserProducer
  23.     )
  24.     {}
  26.     /**
  27.      * @param ConfirmEvent $event
  28.      */
  29.     public function onAccountChangeEmail(ConfirmEvent $event)
  30.     {
  31.         if (!$event->getUserId()) {
  32.             return;
  33.         }
  35.         $user = $this->usersService->getUser($event->getUserId());
  37.         if (!$user->getId()) {
  38.             return;
  39.         }
  41.         $data = $event->getConfirmCode()->getData();
  42.         $checkUser = $this->usersService->getUserByEmail($data['email']);
  44.         if ($checkUser->getId()) {
  45.             return;
  46.         }
  48.         $user->setEmail($data['email']);
  49.         $extendedUser = $this->extendedUserProvider->getByUser($user);
  50.         $extendedUser->setUpdatedAt();
  52.         $this->entityManager->flush();
  54.         $this->b24ExportUserProducer->exportUser($extendedUser);
  55.     }
  56. }