src/Controller/Customer/CustomerController.php line 79

Open in your IDE?
  1. <?php
  4. namespace App\Controller\Customer;
  7. use App\Entity\Addressing\Country;
  8. use App\Entity\Addressing\County;
  9. use App\Entity\Customer\Customer;
  10. use App\Events\Customer\SubscriptionEvent;
  11. use App\Manager\Customer\ConfirmationCommercialNotificationManager;
  12. use App\Model\CustomerModel;
  13. use App\Service\AuthTokenService;
  14. use App\Service\CustomerService;
  15. use App\Service\ReCaptcha;
  16. use App\Validator\RegisterFormValidator;
  17. use FOS\RestBundle\View\View;
  18. use Sylius\Bundle\ResourceBundle\Controller\ResourceController;
  19. use Sylius\Bundle\ResourceBundle\Event\ResourceControllerEvent;
  20. use Sylius\Component\Resource\Exception\UpdateHandlingException;
  21. use Sylius\Component\Resource\ResourceActions;
  22. use Symfony\Component\EventDispatcher\GenericEvent;
  23. use Symfony\Component\HttpFoundation\Request;
  24. use Symfony\Component\HttpFoundation\Response;
  25. use Symfony\Component\HttpKernel\Exception\HttpException;
  26. use Symfony\Component\Security\Http\Event\InteractiveLoginEvent;
  27. use function Sentry\captureException;
  29. class CustomerController extends ResourceController
  30. {
  31.     public function manageCustomerAction(Request $request)
  32.     {
  33.         $customerId = $request->get('customerId');
  34.         $customer = $this->getDoctrine()->getRepository(Customer::class)->find($customerId);
  35.         return $this->render('@templates/AdminCustom/Customer/manage-customer.html.twig', [
  36.             'customer' => $customer
  37.         ]);
  38.     }
  40.     public function createAction(Request $request): Response
  41.     {
  42.         return $this->redirectToRoute('app_shop_customer_register');
  43.     }
  45.     public function disableCustomerAction(Request $request)
  46.     {
  47.         $customerModel = new CustomerModel($this->getDoctrine()->getManager());
  48.         $result = $customerModel->disableCustomer($request, $this->getUser());
  49.         $response = json_encode('Error');
  50.         if ($result == -1) {
  51.             $response = json_encode('Customer is already disabled');
  52.         } elseif ($result == 1) {
  53.             $response = json_encode('Success');
  54.         }
  55.         return new Response($response);
  56.     }
  58.     public function restoreCustomerAction(Request $request)
  59.     {
  60.         $customerModel = new CustomerModel($this->getDoctrine()->getManager());
  61.         $result = $customerModel->restoreCustomer($request);
  62.         $response = json_encode('Error');
  63.         if ($result == -1) {
  64.             $response = json_encode('Customer is already restored or is not disabled');
  65.         } elseif ($result == 1) {
  66.             $response = json_encode('Success');
  67.         }
  68.         return new Response($response);
  69.     }
  71.     public function registerAction()
  72.     {
  73.         $user = $this->getUser();
  74.         if ($user) {
  75.             $this->addFlash('already_logged_in', '1');
  76.             return $this->redirectToRoute('sylius_shop_homepage');
  77.         }
  78.         return $this->render('@templates/Account/register.html.twig', [
  79.             'countries' => $this->getDoctrine()->getRepository(Country::class)->findAll(),
  80.         ]);
  81.     }
  83.     public function submitRegisterAction(Request $request)
  84.     {
  85.         $session = $request->getSession();
  86.         $registerFormValidator = new RegisterFormValidator($this->getDoctrine()->getManager(), $this->container);
  87.         $params = $request->request->all();
  88.         $reCaptcha = new ReCaptcha($_ENV['RECAPTCHA3_SECRET']);
  89.         if ($registerFormValidator->checkForm($request) && $reCaptcha->verify($params['g-recaptcha-response'], $request->getClientIp())) {
  90.             $customerService = new CustomerService($this->getDoctrine()->getManager(), $this->container->get('router'));
  91.            if ($customerService->registerNewCustomer($request)) {
  92.                $customer = $this->getDoctrine()->getRepository(Customer::class)->findOneByEmail($params['customerEmail']);
  93.                $address = $customerService->createNewAddressForCustomer($customer, $params, $this->getDoctrine()->getRepository(County::class));
  94.                if ($address) {
  95.                    $this->getDoctrine()->getManager()->persist($address);
  96.                    $this->getDoctrine()->getManager()->flush();
  97.                }
  98.                if (CustomerService::checkIfCustomerWantToSubscribe($request)) {
  99.                    try {
  100.                        $customerEvent = new GenericEvent($customer);
  101.                        $eventDispatcher = $this->get('event_dispatcher');
  102.                        $eventDispatcher->dispatch($customerEvent, 'app.customer.post_register');
  103.                        $commercialNotificationService = $this->container->get('app.service.customer.commercial_notification');
  104.                        $commercialNotificationService->addToQueueConfirmationEmailForCommercialNotificationForCustomer($customer, ConfirmationCommercialNotificationManager::EMAIL_TYPE_NEW_ACCOUNT_ID);
  105.                    } catch (\Throwable $exception) {
  106.                        captureException($exception);
  107.                    }
  108.                    $customerModel = new CustomerModel($this->getDoctrine()->getManager());
  109.                    $customerModel->subscribeCustomerToNewsletter($customer, $request->getClientIp());
  110.                }
  111.                $token = AuthTokenService::authenticateNewCustomer($customer);
  112.                $this->get('security.token_storage')->setToken($token);
  113.                $event = new InteractiveLoginEvent($request, $token);
  114.                $dispatcher = $this->get('event_dispatcher');
  115.                $dispatcher->dispatch($event, 'security.interactive_login');
  116.                $session->set('_sylius.cart.FASHION_WEB', 180);
  117.                $session->save();
  118.                $response = array('success' => 1);
  119.            } else {
  120.                $response = array('fail' => 1);
  121.            }
  122.         } else {
  123.             if ($session->has('registerErrors')) {
  124.                 $response = json_decode($session->get('registerErrors'));
  125.             } else {
  126.                 $response = array('captcha_error' => 1);
  127.             }
  128.         }
  129.         return new Response(json_encode($response));
  130.     }
  132.     /**
  133.      * @param Request $request
  134.      * @return Response
  135.      * METODA OVERRIDE DIN SYLIUS CONTROLLER
  136.      */
  137.     public function updateAction(Request $request): Response
  138.     {
  139.         $configuration = $this->requestConfigurationFactory->create($this->metadata, $request);
  141.         $this->isGrantedOr403($configuration, ResourceActions::UPDATE);
  142.         $resource = $this->findOr404($configuration);
  144.         $form = $this->resourceFormFactory->create($configuration, $resource);
  146.         if (in_array($request->getMethod(), ['POST', 'PUT', 'PATCH'], true) && $form->handleRequest($request)->isValid()) {
  147.             $resource = $form->getData();
  148.             $event = $this->eventDispatcher->dispatchPreEvent(ResourceActions::UPDATE, $configuration, $resource);
  151.             $customer = $this->findOr404($configuration);
  152.             $subscriptionEvent = new SubscriptionEvent($customer);
  153.             if ($form->has('subscribedToNewsletter')) {
  154.                 if ($form->get('subscribedToNewsletter')->getData()) {
  155.                     $this->get('event_dispatcher')->dispatch($subscriptionEvent, SubscriptionEvent::SUBSCRIBE_CUSTOMER);
  156.                 } else {
  157.                     $this->get('event_dispatcher')->dispatch($subscriptionEvent, SubscriptionEvent::UNSUBSCRIBE_CUSTOMER);
  158.                 }
  159.             }
  161.             if ($event->isStopped() && !$configuration->isHtmlRequest()) {
  162.                 throw new HttpException($event->getErrorCode(), $event->getMessage());
  163.             }
  164.             if ($event->isStopped()) {
  165.                 $this->flashHelper->addFlashFromEvent($configuration, $event);
  167.                 $eventResponse = $event->getResponse();
  168.                 if (null !== $eventResponse) {
  169.                     return $eventResponse;
  170.                 }
  172.                 return $this->redirectHandler->redirectToResource($configuration, $resource);
  173.             }
  175.             try {
  176.                 $this->resourceUpdateHandler->handle($resource, $configuration, $this->manager);
  177.             } catch (UpdateHandlingException $exception) {
  178.                 if (!$configuration->isHtmlRequest()) {
  179.                     return $this->viewHandler->handle(
  180.                         $configuration,
  181.                         View::create($form, $exception->getApiResponseCode())
  182.                     );
  183.                 }
  185.                 $this->flashHelper->addErrorFlash($configuration, $exception->getFlash());
  187.                 return $this->redirectHandler->redirectToReferer($configuration);
  188.             }
  190.             if ($configuration->isHtmlRequest()) {
  191.                 $this->flashHelper->addSuccessFlash($configuration, ResourceActions::UPDATE, $resource);
  192.             }
  194.             $postEvent = $this->eventDispatcher->dispatchPostEvent(ResourceActions::UPDATE, $configuration, $resource);
  196.             if (!$configuration->isHtmlRequest()) {
  197.                 $view = $configuration->getParameters()->get('return_content', false) ? View::create($resource, Response::HTTP_OK) : View::create(null, Response::HTTP_NO_CONTENT);
  199.                 return $this->viewHandler->handle($configuration, $view);
  200.             }
  202.             $postEventResponse = $postEvent->getResponse();
  203.             if (null !== $postEventResponse) {
  204.                 return $postEventResponse;
  205.             }
  207.             return $this->redirectHandler->redirectToResource($configuration, $resource);
  208.         }
  210.         if (!$configuration->isHtmlRequest()) {
  211.             return $this->viewHandler->handle($configuration, View::create($form, Response::HTTP_BAD_REQUEST));
  212.         }
  214.         $initializeEvent = $this->eventDispatcher->dispatchInitializeEvent(ResourceActions::UPDATE, $configuration, $resource);
  215.         $initializeEventResponse = $initializeEvent->getResponse();
  216.         if (null !== $initializeEventResponse) {
  217.             return $initializeEventResponse;
  218.         }
  220.         $view = View::create()
  221.             ->setData([
  222.                 'configuration' => $configuration,
  223.                 'metadata' => $this->metadata,
  224.                 'resource' => $resource,
  225.                 $this->metadata->getName() => $resource,
  226.                 'form' => $form->createView(),
  227.             ])
  228.             ->setTemplate($configuration->getTemplate(ResourceActions::UPDATE . '.html'))
  229.         ;
  231.         return $this->viewHandler->handle($configuration, $view);
  232.     }
  234.     public function updateAccountAction(Request $request): Response
  235.     {
  236.         $customer = CustomerService::retrieveCustomerFromShopUser($this->getUser());
  238.         return $this->render('@templates/Account/Customer/update.html.twig', [
  239.             'customerData' => CustomerService::retrieveCustomerDataForAccount($customer),
  240.             'translations' => CustomerService::retrieveTranslationsForCustomerAccount($this->container->get('translator')),
  241.         ]);
  242.     }
  244.     public function updateProfile(Request $request): Response
  245.     {
  246.         $customer = CustomerService::retrieveCustomerFromShopUser($this->getUser());
  247.         return new Response(json_encode(CustomerService::updateCustomerData($request->request->all(), $customer, $this->getDoctrine()->getManager(), $this->container->get('translator'))));
  248.     }
  250.     public function tryToFindCustomerData(Request $request)
  251.     {
  252.         $customerService = new CustomerService($this->getDoctrine()->getManager(), $this->container->get('router'));
  253.         return new Response(json_encode($customerService->tryToFindCustomerDataByEmailOrPhone($request->get('email'), $request->get('phone'))));
  254.     }
  255. }