src/Flexy/ShopBundle/EventSubscriber/EventsApiSubscriber.php line 46

  1. <?php
  3. namespace App\Flexy\ShopBundle\EventSubscriber;
  5. use ApiPlatform\Symfony\EventListener\EventPriorities;
  6. use App\Entity\Book;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpFoundation\Request;
  9. use Symfony\Component\HttpKernel\Event\ViewEvent;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  11. use Symfony\Component\Mime\Email;
  12. use Symfony\Component\Mailer\MailerInterface;
  13. use App\Entity\User;
  14. use App\Flexy\ShopBundle\Entity\Customer\Customer;
  15. use App\Flexy\ShopBundle\Entity\Order\Order;
  16. use App\Flexy\ShopBundle\Entity\Shipping\ShippingMethod;
  17. use Doctrine\ORM\EntityManagerInterface;
  18. use Doctrine\ORM\Events;
  19. use Doctrine\Persistence\Event\LifecycleEventArgs;
  20. use Exception;
  21. use Doctrine\Persistence\ManagerRegistry;
  22. use Symfony\Component\HttpFoundation\RequestStack;
  23. use Symfony\Component\Mercure\HubInterface;
  24. use Symfony\Component\Mercure\Update;
  25. use Symfony\Component\Security\Core\Security;
  26. use Symfony\Component\PasswordHasher\Hasher\UserPasswordHasherInterface;
  27. use Symfony\Component\Security\Http\Authentication\UserAuthenticatorInterface;
  28. use App\Security\AppAuthenticator;
  30. final class EventsApiSubscriber implements EventSubscriberInterface
  31. {
  32.     
  34.     public function __construct(private readonly Security $security, protected RequestStack $requestStack, private readonly HubInterface $hub, private readonly UserPasswordHasherInterface $passwordEncoder, private readonly ManagerRegistry $doctrine, private readonly UserAuthenticatorInterface $userAuthenticator, private readonly AppAuthenticator $appAuthenticator)
  35.     {
  36.     }
  38.     
  39.     public static function getSubscribedEvents()
  40.     {
  41.         return [
  42.             KernelEvents::VIEW => ['sendMail', EventPriorities::POST_WRITE],
  43.         ];
  44.     }
  46.     public function sendMail(ViewEvent $event): void
  47.     {
  48.         $entityInstance = $event->getControllerResult();
  49.         $method = $event->getRequest()->getMethod();
  51.         
  53.         if ($entityInstance instanceof Order and Request::METHOD_PUT === $method) {
  55.             
  56.             if($entityInstance->getStatus()=="waiting" and !$entityInstance->getIsChecked()){
  58.                 if($this->security->getUser()){
  59.                     if(in_array("ROLE_CUSTOMER",$this->security->getUser()->getRoles())){
  60.     
  61.                         
  62.                         $customer = $this->doctrine->getManager()->getRepository(Customer::class)->findOneBy(["user"=>$this->security->getUser()]);
  65.                         
  66.                         if($customer){
  67.                             
  68.                             $entityInstance->setCustomer($customer);
  69.                             if(!$entityInstance->getFirstName()){
  70.                                 $entityInstance->setFirstName($customer->getFirstName());
  71.                             }
  72.                             if(!$entityInstance->getLastName()){
  73.                                 $entityInstance->getLastName();
  74.                             }
  75.                             if(!$entityInstance->getEmail()){
  76.                                 $entityInstance->getEmail();
  77.                             }
  78.                             if(!$entityInstance->getTel()){
  79.                                 $entityInstance->getEmail();
  80.                             }
  81.         
  82.         
  83.                             $this->doctrine->getManager()->persist($entityInstance);
  84.                             $this->doctrine->getManager()->flush();
  85.                             
  86.                             
  87.                             
  88.                         }
  89.                     }
  90.                 }
  92.                 $update = new Update(
  93.                     'https://hello.com/books/1',
  94.                     json_encode(
  95.                         [
  96.                             'status' => 'success',
  97.                             'entity'=>'Order',
  98.                             'data'=>$entityInstance,
  99.                         ]
  100.                         )
  101.                 );
  102.                 try {
  103.                     if($entityInstance->getSource() != "ADMIN")
  104.                     $this->hub->publish($update);
  105.                 } catch (Exception) {
  106.                    //dd($e);
  107.                 }
  108.             }
  111.             
  112.             
  113.         }
  116.     }
  117. }