src/Flexy/FrontBundle/Themes/IlaveU/EventSubscriber/EventsApiSubscriber.php line 46

  1. <?php
  3. namespace App\Flexy\FrontBundle\Themes\IlaveU\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::PRE_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 User and Request::METHOD_PUT === $method) {
  55.             
  56.             
  57.             
  60.             
  61.             
  62.         }
  65.         if ($entityInstance instanceof Customer and Request::METHOD_PATCH === $method) {
  67.            
  68.             $user = $entityInstance->getUser();
  69.             
  70.             $user->setPassword(
  71.                 $this->passwordEncoder->hashPassword(
  72.                             $user,
  73.                             (string)$user->getPassword()
  74.                          ));
  75.             
  76.             $this->doctrine->getManager()->persist($user);
  77.             $this->doctrine->getManager()->flush();
  78.             
  79.             
  80.         }
  81.         
  82.         
  83.         if ($entityInstance instanceof Customer and Request::METHOD_PUT === $method) {
  84.                 $sponsorshipCustomer = $this->doctrine->getManager()->getRepository(Customer::class)->findOneBy(["email"=>$entityInstance->getSponsorshipCode()]);
  85.                 if(!$sponsorshipCustomer){
  86.                     $entityInstance->setSponsorshipCode(null);
  87.                     $this->doctrine->getManager()->persist($entityInstance);
  88.                     $this->doctrine->getManager()->flush();
  89.                 }
  90.         }
  91.         
  93.         if ($entityInstance instanceof Order and Request::METHOD_PUT === $method) {
  95.             
  96.             if($entityInstance->getStatus()=="waiting" and !$entityInstance->getIsChecked()){
  98.                 if($this->security->getUser()){
  99.                     if(in_array("ROLE_CUSTOMER",$this->security->getUser()->getRoles())){
  100.     
  101.                         
  102.                         $customer = $this->doctrine->getManager()->getRepository(Customer::class)->findOneBy(["user"=>$this->security->getUser()]);
  105.                         
  106.                         if($customer){
  107.                             
  108.                             $entityInstance->setCustomer($customer);
  109.                             if(!$entityInstance->getFirstName()){
  110.                                 $entityInstance->setFirstName($customer->getFirstName());
  111.                             }
  112.                             if(!$entityInstance->getLastName()){
  113.                                 $entityInstance->getLastName();
  114.                             }
  115.                             if(!$entityInstance->getEmail()){
  116.                                 $entityInstance->getEmail();
  117.                             }
  118.                             if(!$entityInstance->getTel()){
  119.                                 $entityInstance->getEmail();
  120.                             }
  121.         
  122.         
  123.                             $this->doctrine->getManager()->persist($entityInstance);
  124.                             $this->doctrine->getManager()->flush();
  125.                             
  126.                             
  127.                             
  128.                         }
  129.                     }
  130.                 }
  132.                 $update = new Update(
  133.                     'https://hello.com/books/1',
  134.                     json_encode(
  135.                         [
  136.                             'status' => 'success',
  137.                             'entity'=>'Order',
  138.                             'data'=>$entityInstance,
  139.                         ]
  140.                         )
  141.                 );
  142.                 try {
  143.                     if($entityInstance->getSource() != "ADMIN")
  144.                     $this->hub->publish($update);
  145.                 } catch (Exception) {
  146.                    //dd($e);
  147.                 }
  148.             }
  151.             
  152.             
  153.         }
  156.     }
  157. }