src/EventListener/RequestBaseSubscriber.php line 83

Open in your IDE?
  1. <?php
  4. namespace App\EventListener;
  6. use App\Twig\RequestNotificationAndStatusExtension;
  7. use App\Entity\{Notification, RequestEvents, Transaction, Wallet};
  8. use App\Enum\RequestsNotificationsEnum;
  9. use App\Event\{NotificationEvent, RequestBaseEvent, TransactionEvent};
  10. use App\Service\MailerService;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\Mailer\Exception\TransportExceptionInterface;
  15. use Symfony\Contracts\HttpClient\HttpClientInterface;
  18. class RequestBaseSubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var EntityManagerInterface
  22.      */
  23.     private $entityManager;
  24.     /**
  25.      * @var MailerService
  26.      */
  27.     private $mailerService;
  28.     /**
  29.      * @var HttpClientInterface
  30.      */
  31.     private $httpClient;
  32.     /**
  33.      * @var RequestNotificationAndStatusExtension
  34.      */
  35.     private $twigNotifExtension;
  36.     /**
  37.      * @var ParameterBagInterface
  38.      */
  39.     private $parameterBag;
  41.     public function __construct(
  42.         EntityManagerInterface $entityManager,
  43.         MailerService $mailerService,
  44.         HttpClientInterface $client,
  45.         RequestNotificationAndStatusExtension $twigNotifExtension,
  46.         ParameterBagInterface $parameterBag
  47.     ) {
  48.         $this->entityManager = $entityManager;
  49.         $this->mailerService = $mailerService;
  50.         $this->httpClient = $client;
  51.         $this->twigNotifExtension = $twigNotifExtension;
  52.         $this->parameterBag = $parameterBag;
  53.     }
  55.     public static function getSubscribedEvents()
  56.     {
  57.         return [
  58.             TransactionEvent::class => 'onRequestBaseHandleTransaction',
  59.             NotificationEvent::class => 'onRequestBaseHandleNotification',
  60.             RequestBaseEvent::class => 'onRequestBaseHandleEvent'
  61.         ];
  62.     }
  64.     public function onRequestBaseHandleTransaction(TransactionEvent $event)
  65.     {
  66.         $transaction = new Transaction();
  67.         $transaction
  68.             ->setType($event->type)
  69.             ->setAmount($event->amount)
  70.             ->setStatus($event->status)
  71.             ->setRequestBase($event->requestBase)
  72.             ->setWallet($event->wallet)
  73.             ->setAmountPlatformDescription($event->amountDescription)
  74.             ->setTutorialStudentBackpack($event->tutorialStudentBackpack);
  76.         $this->entityManager->persist($transaction);
  77.     }
  79.     /**
  80.      * @param NotificationEvent $event
  81.      * @throws TransportExceptionInterface
  82.      */
  83.     public function onRequestBaseHandleNotification(NotificationEvent $event)
  84.     {
  85.         // notification
  86.         $notification = new Notification();
  87.         $notification
  88.             ->setType($event->type)
  89.             ->setOwner($event->owner)
  90.             ->setPath($event->path)
  91.             ->setRequestBase($event->requestBase);
  93.         $this->entityManager->persist($notification);
  94.         $this->entityManager->flush();
  96.         $notificationOwnerFirebaseToken = $notification->getOwner()->getFirebaseToken();
  97.         if ($notificationOwnerFirebaseToken) {
  98.             $this->httpClient->request(
  99.                 'POST',
  100.                 'https://fcm.googleapis.com/fcm/send',
  101.                 [
  102.                     'headers' => [
  103.                         'Content-Type' => 'application/json',
  104.                         'Authorization' => 'key=' . $this->parameterBag->get('firebase_server_key')
  105.                     ],
  106.                     'json' => [
  107.                         'to' => $notificationOwnerFirebaseToken,
  108.                         'notification' => [
  109.                             'title' => 'ESNGP',
  110.                             'body' => $notification->getId() . ' - ' . $this->twigNotifExtension->transRequestNotificationStatusLabel(
  111.                                 $notification->getType(),
  112.                                 $notification->getPath()
  113.                             ),
  114.                             'image' => 'https://esngp.school/images/logo_esng.png',
  115.                             'icon' => 'https://esngp.school/images/logo_esng.png',
  116.                             'click_action' => $notification->getPath(),
  117.                         ],
  118.                     ],
  119.                 ]
  120.             );
  121.         }
  123.         $this->mailerService->sendMail(
  124.             $event->tplMailing,
  125.             RequestsNotificationsEnum::$MAP_STATUS[$event->type],
  126.             $event->owner->getEmail(),
  127.             $event->dataMailing,
  128.         );
  129.     }
  131.     public function onRequestBaseHandleEvent(RequestBaseEvent $eventBase)
  132.     {
  133.         $event = new RequestEvents();
  134.         $event->setOwner($eventBase->owner)
  135.             ->setType($eventBase->type)
  136.             ->setRequestBase($eventBase->requestBase);
  138.         $this->entityManager->persist($event);
  139.     }
  140. }