custom/plugins/ShopWithMeUI/src/Controller/AppStorefrontController.php line 242

Open in your IDE?
  1. <?php
  3. namespace ShopWithMe\UI\Controller;
  5. use Divante\Nuvei\Service\Handler\NuveiSubscriptionPaymentHandler;
  6. use Econsor\Amity\Services\AmityPosts\AmityPostService;
  7. use Econsor\Amity\Services\Stream\StreamSorter;
  8. use Econsor\Shopware\SearchBar\Storefront\Controller\EconsorTagSaverController;
  9. use EconsorAppStorefront\Core\Validator\Duplications;
  10. use EconsorAppStorefront\Services\CustomerDataService;
  11. use EconsorAppStorefront\Services\DiscountCodeGenerator;
  12. use EconsorAppStorefront\Storefront\registration\RegistrationAppPageLoader;
  13. use Psr\Log\LoggerInterface;
  14. use Shopware\Core\Checkout\Cart\CartCalculator;
  15. use Shopware\Core\Checkout\Cart\CartPersisterInterface;
  16. use Shopware\Core\Checkout\Cart\Exception\CustomerNotLoggedInException;
  17. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  18. use Shopware\Core\Checkout\Cart\Order\OrderPersister;
  19. use Shopware\Core\Checkout\Cart\Order\Transformer\CustomerTransformer;
  20. use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
  21. use Shopware\Core\Checkout\Customer\Aggregate\CustomerAddress\CustomerAddressEntity;
  22. use Shopware\Core\Checkout\Customer\CustomerDefinition;
  23. use Shopware\Core\Checkout\Customer\CustomerEntity;
  24. use Shopware\Core\Checkout\Customer\Exception\AddressNotFoundException;
  25. use Shopware\Core\Checkout\Customer\SalesChannel\AbstractListAddressRoute;
  26. use Shopware\Core\Checkout\Customer\SalesChannel\AccountService;
  27. use Shopware\Core\Checkout\Customer\Validation\Constraint\CustomerEmailUnique;
  28. use Shopware\Core\Checkout\Customer\Validation\CustomerValidationFactory;
  29. use Shopware\Core\Checkout\Document\FileGenerator\FileTypes;
  30. use Shopware\Core\Checkout\Document\Struct\DocumentGenerateOperation;
  31. use Shopware\Core\Checkout\Document\Service\DocumentGenerator;
  32. use Shopware\Core\Checkout\Payment\PaymentMethodEntity;
  33. use Shopware\Core\Content\Media\File\MediaFile;
  34. use Shopware\Core\Defaults;
  35. use Shopware\Core\Framework\Context;
  36. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  37. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  38. use Shopware\Core\Framework\DataAbstractionLayer\Validation\EntityExists;
  39. use Shopware\Core\Framework\Feature;
  40. use Shopware\Core\Framework\Routing\RequestContextResolverInterface;
  41. use Shopware\Core\Framework\Struct\ArrayStruct;
  42. use Shopware\Core\Framework\Uuid\Exception\InvalidUuidException;
  43. use Shopware\Core\Framework\Uuid\Uuid;
  44. use Shopware\Core\Framework\Validation\DataBag\DataBag;
  45. use Shopware\Core\Framework\Validation\DataBag\RequestDataBag;
  46. use Shopware\Core\Framework\Validation\DataValidationDefinition;
  47. use Shopware\Core\Framework\Validation\DataValidator;
  48. use Shopware\Core\Framework\Validation\Exception\ConstraintViolationException;
  49. use Shopware\Core\System\Language\LanguageEntity;
  50. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextFactory;
  51. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  52. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  53. use Shopware\Core\System\SystemConfig\SystemConfigService;
  54. use Shopware\Storefront\Controller\RegisterController;
  55. use Shopware\Storefront\Controller\StorefrontController;
  56. use Shopware\Storefront\Framework\Cache\Annotation\HttpCache;
  57. use Shopware\Storefront\Framework\Routing\Router;
  58. use Shopware\Storefront\Page\Address\AddressEditorModalStruct;
  59. use Shopware\Storefront\Page\Address\Listing\AddressBookWidgetLoadedHook;
  60. use Shopware\Storefront\Page\Address\Listing\AddressListingPageLoader;
  61. use Shopware\Storefront\Page\GenericPageLoader;
  62. use Shopware\Storefront\Page\Product\ProductPageLoadedHook;
  63. use Shopware\Storefront\Page\Product\ProductPageLoader;
  64. use ShopWithMe\LP\Service\RankingService;
  65. use ShopWithMe\Reward\Entities\Enums\RewardPointType;
  66. use ShopWithMe\Reward\Entities\Enums\RewardShipLaterType;
  67. use ShopWithMe\Reward\Service\RewardPointService;
  68. use ShopWithMe\Reward\Service\RewardShipLaterService;
  69. use ShopWithMe\UI\Service\CustomerBusinessNameService;
  70. use ShopWithMe\UI\Service\HomePageService;
  71. use Divante\Nuvei\Controller\NuveiSubscriptionController;
  72. use Symfony\Component\HttpFoundation\RedirectResponse;
  73. use Symfony\Component\HttpFoundation\Request;
  74. use Symfony\Component\HttpFoundation\Response;
  75. use Symfony\Component\Routing\Annotation\Route;
  76. use Symfony\Component\Validator\Constraints\Email;
  77. use Symfony\Component\Validator\Constraints\Length;
  78. use Symfony\Component\Validator\Constraints\NotBlank;
  79. use Shopware\Storefront\Page\Navigation\NavigationPageLoaderInterface;
  80. use Shopware\Storefront\Page\Navigation\NavigationPageLoadedHook;
  81. use Shopware\Core\Checkout\Customer\SalesChannel\AbstractChangeCustomerProfileRoute;
  82. use Shopware\Core\Checkout\Customer\SalesChannel\AbstractChangeEmailRoute;
  83. use Shopware\Core\System\SalesChannel\SuccessResponse;
  84. use Shopware\Storefront\Page\Address\Detail\AddressDetailPageLoader;
  85. use Shopware\Storefront\Page\Address\Detail\AddressDetailPageLoadedHook;
  86. use Shopware\Storefront\Page\Account\Profile\AccountProfilePageLoader;
  87. use Shopware\Storefront\Page\Account\Profile\AccountProfilePageLoadedHook;
  88. use Shopware\Core\Checkout\Customer\SalesChannel\AbstractUpsertAddressRoute;
  89. use Shopware\Core\Content\Newsletter\SalesChannel\AbstractNewsletterSubscribeRoute;
  90. use Shopware\Core\Content\Newsletter\SalesChannel\AbstractNewsletterUnsubscribeRoute;
  91. use Shopware\Storefront\Framework\Routing\RequestTransformer;
  92. use Shopware\Storefront\Page\Account\Overview\AccountOverviewPageLoadedHook;
  93. use Shopware\Storefront\Page\Account\Overview\AccountOverviewPageLoader;
  94. use EconsorAppStorefront\Services\AccountService as EconsorAccountService;
  95. use Shopware\Storefront\Page\Account\Order\AccountOrderPageLoader;
  96. use Shopware\Storefront\Page\Account\Order\AccountOrderPageLoadedHook;
  97. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  98. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  99. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  100. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  101. use Shopware\Core\Content\Newsletter\Aggregate\NewsletterRecipient\NewsletterRecipientEntity;
  102. use Symfony\Component\Validator\Constraints\NotEqualTo;
  103. use Symfony\Component\Validator\Validation;
  104. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  105. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\OrFilter;
  106. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  107. use ShopWithMe\MobileApi\Service\AIStreamService;
  108. use ShopWithMe\Reward\Service\LuckyWheelService\LuckyWheelApiService;
  109. use Symfony\Component\HttpFoundation\JsonResponse;
  110. use Shopware\Core\Checkout\Payment\Cart\AsyncPaymentTransactionStruct;
  111. use Shopware\Core\Checkout\Payment\PaymentService;
  112. use Shopware\Core\Checkout\Cart\Transaction\Struct;
  113. use ShopWithMe\UI\Service\SubscriptionService;
  114. use Shopware\Core\System\StateMachine\StateMachineRegistry;
  115. use Shopware\Core\System\StateMachine\Transition;
  116. use Shopware\Core\Checkout\Order\OrderDefinition;
  117. use Doctrine\DBAL\Connection;
  119. #[Route(defaults: ['_routeScope' => ['storefront']])]
  120. class AppStorefrontController extends StorefrontController
  121. {
  122.     private const ADDRESS_TYPE_BILLING = 'billing';
  123.     private const ADDRESS_TYPE_SHIPPING = 'shipping';
  124.     const LIMIT = 100;
  127.     /**
  128.      * @var RegistrationAppPageLoader
  129.      */
  130.     private $registrationAppPageLoader;
  132.     /**
  133.      * @var RegisterController
  134.      */
  135.     private $registerController;
  137.     /**
  138.      * @var CustomerValidationFactory
  139.      */
  140.     private $customerValidationFactory;
  142.     /**
  143.      * @var DataValidator
  144.      */
  145.     private $dataValidator;
  147.     /**
  148.      * @var SystemConfigService
  149.      */
  150.     private $systemConfigService;
  152.     /**
  153.      * @var RequestContextResolverInterface
  154.      */
  155.     private $contextResolver;
  157.     /**
  158.      * @var EconsorTagSaverController
  159.      */
  160.     private $tagSaverController;
  162.     /**
  163.      * @var EntityRepository
  164.      */
  165.     private $customerEntity;
  167.     /**
  168.      * @var Router
  169.      */
  170.     private $router;
  172.     private NavigationPageLoaderInterface $navigationPageLoader;
  174.     private AbstractChangeCustomerProfileRoute $changeCustomerProfileRoute;
  176.     private AbstractChangeEmailRoute $changeEmailRoute;
  178.     private AddressDetailPageLoader $addressDetailPageLoader;
  181.     private AccountOverviewPageLoader $overviewPageLoader;
  182.     private AccountProfilePageLoader $profilePageLoader;
  185.     private AbstractUpsertAddressRoute $updateAddressRoute;
  187.     /**
  188.      * @var AbstractNewsletterSubscribeRoute
  189.      */
  190.     private $newsletterSubscribeRoute;
  192.     /**
  193.      * @var AbstractNewsletterUnsubscribeRoute
  194.      */
  195.     private $newsletterUnsubscribeRoute;
  197.     private EconsorAccountService $econsorAccountService;
  199.     private AccountOrderPageLoader $orderPageLoader;
  201.     /**
  202.      * @var EntityRepositoryInterface
  203.      */
  204.     private $newsletterRecipientRepository;
  206.     protected EntityRepositoryInterface $languageRepository;
  208.     protected EntityRepositoryInterface $countryRepository;
  210.     protected $homepageService;
  212.     private LoggerInterface $logger;
  214.     private StreamSorter $amityService;
  216.     private EntityRepositoryInterface $luckyWheelTurnRepository;
  218.     private EntityRepositoryInterface $productBundleItemsRepository;
  220.     protected SalesChannelRepositoryInterface $salesChannelProductRepository;
  222.     protected NuveiSubscriptionController $nuveiSubscriptionController;
  224.     protected PaymentService $paymentService;
  226.     private EntityRepositoryInterface $orderRepository;
  228.     private EntityRepository $subscriptionRepository;
  230.     private EntityRepository $subscriptionOrderRepository;
  232.     private StateMachineRegistry $stateMachineRegistry;
  234.     private Connection $connection;
  236.     private EntityRepository $stateMachineStateRepository;
  238.     private DocumentGenerator $documentGenerator;
  240.     private EntityRepository $documentRepository;
  242.     public function __construct(
  243.         RegistrationAppPageLoader                    $registrationAppPageLoader,
  244.         RegisterController                           $registerController,
  245.         CustomerValidationFactory                    $customerValidationFactory,
  246.         DataValidator                                $dataValidator,
  247.         SystemConfigService                          $systemConfigService,
  248.         RequestContextResolverInterface              $contextResolver,
  249.         EconsorTagSaverController                    $tagSaverController,
  250.         EntityRepository                             $customerEntity,
  251.         Router                                       $router,
  252.         NavigationPageLoaderInterface                $navigationPageLoader,
  253.         AbstractChangeCustomerProfileRoute           $changeCustomerProfileRoute,
  254.         AbstractChangeEmailRoute                     $changeEmailRoute,
  255.         AddressDetailPageLoader                      $addressDetailPageLoader,
  256.         AccountProfilePageLoader                     $profilePageLoader,
  257.         AbstractUpsertAddressRoute                   $updateAddressRoute,
  258.         AbstractNewsletterSubscribeRoute             $newsletterSubscribeRoute,
  259.         AbstractNewsletterUnsubscribeRoute           $newsletterUnsubscribeRoute,
  260.         AccountOverviewPageLoader                    $overviewPageLoader,
  261.         EconsorAccountService                        $econsorAccountService,
  262.         AccountOrderPageLoader                       $orderPageLoader,
  263.         EntityRepositoryInterface                    $newsletterRecipientRepository,
  264.         EntityRepositoryInterface                    $languageRepository,
  265.         EntityRepositoryInterface                    $countryRepository,
  266.         HomePageService                              $homePageService,
  267.         LoggerInterface                              $logger,
  268.         protected AmityPostService                   $postService,
  269.         protected ProductPageLoader                  $productPageLoader,
  270.         protected DiscountCodeGenerator              $discountCodeGenerator,
  271.         protected CustomerDataService                $customerDataService,
  272.         protected EntityRepository                   $customerNotificationRepository,
  273.         protected AccountService                     $accountService,
  274.         protected AddressListingPageLoader           $addressListingPageLoader,
  275.         protected AbstractChangeCustomerProfileRoute $updateCustomerProfileRoute,
  276.         protected AbstractListAddressRoute           $listAddressRoute,
  277.         EntityRepositoryInterface                    $luckyWheelTurnRepository,
  278.         protected CustomerBusinessNameService        $customerBusinessNameService,
  279.         protected EntityRepositoryInterface          $videoRecordRepository,
  280.         protected EntityRepository                   $inviteFriendHistory,
  281.         protected AIStreamService                    $aiStreamService,
  282.         protected RankingService                     $rankingService,
  283.         EntityRepository                             $customerAcceptCookieRepository,
  284.         protected LuckyWheelApiService               $luckyWheelApiService,
  285.         protected RewardShipLaterService             $rewardShipLaterService,
  286.         protected EntityRepository                   $product,
  287.         protected CartService                        $cartService,
  288.         protected OrderPersister                     $orderPersister,
  289.         protected EntityRepository                   $paymentMethodRepository,
  290.         SalesChannelRepositoryInterface              $salesChannelProductRepository,
  291.         protected EntityRepositoryInterface          $customerAddressRepository,
  292.         protected NuveiSubscriptionPaymentHandler    $nuveiSubscriptionPaymentHandler,
  293.         NuveiSubscriptionController                  $nuveiSubscriptionController,
  294.         PaymentService                               $paymentService,
  295.         protected SubscriptionService                $subscriptionService,
  296.         EntityRepositoryInterface                    $orderRepository,
  297.         EntityRepository                             $subscriptionRepository,
  298.         EntityRepository                             $subscriptionOrderRepository,
  299.         StateMachineRegistry                         $stateMachineRegistry,
  300.         Connection                                   $connection,
  301.         EntityRepository                             $stateMachineStateRepository,
  302.         protected GenericPageLoader                  $genericLoader,
  303.         EntityRepositoryInterface                    $productBundleItemsRepository = null,
  304.         protected SalesChannelRepositoryInterface    $countrySalesChannel,
  305.         DocumentGenerator                            $documentGenerator,
  306.         EntityRepository                             $documentRepository,
  307.     )
  308.     {
  309.         $this->registrationAppPageLoader = $registrationAppPageLoader;
  310.         $this->registerController = $registerController;
  311.         $this->customerValidationFactory = $customerValidationFactory;
  312.         $this->dataValidator = $dataValidator;
  313.         $this->systemConfigService = $systemConfigService;
  314.         $this->contextResolver = $contextResolver;
  315.         $this->tagSaverController = $tagSaverController;
  316.         $this->customerEntity = $customerEntity;
  317.         $this->router = $router;
  318.         $this->navigationPageLoader = $navigationPageLoader;
  319.         $this->changeCustomerProfileRoute = $changeCustomerProfileRoute;
  320.         $this->changeEmailRoute = $changeEmailRoute;
  321.         $this->addressDetailPageLoader = $addressDetailPageLoader;
  322.         $this->profilePageLoader = $profilePageLoader;
  323.         $this->overviewPageLoader = $overviewPageLoader;
  324.         $this->updateAddressRoute = $updateAddressRoute;
  325.         $this->newsletterSubscribeRoute = $newsletterSubscribeRoute;
  326.         $this->newsletterUnsubscribeRoute = $newsletterUnsubscribeRoute;
  327.         $this->econsorAccountService = $econsorAccountService;
  328.         $this->orderPageLoader = $orderPageLoader;
  329.         $this->newsletterRecipientRepository = $newsletterRecipientRepository;
  330.         $this->languageRepository = $languageRepository;
  331.         $this->countryRepository = $countryRepository;
  332.         $this->homepageService = $homePageService;
  333.         $this->logger = $logger;
  334.         $this->luckyWheelTurnRepository = $luckyWheelTurnRepository;
  335.         $this->customerAcceptCookieRepository = $customerAcceptCookieRepository;
  336.         $this->product = $product;
  337.         $this->cartService = $cartService;
  338.         $this->orderPersister = $orderPersister;
  339.         $this->salesChannelProductRepository = $salesChannelProductRepository;
  340.         $this->nuveiSubscriptionController = $nuveiSubscriptionController;
  341.         $this->paymentService = $paymentService;
  342.         $this->orderRepository = $orderRepository;
  343.         $this->subscriptionRepository = $subscriptionRepository;
  344.         $this->subscriptionOrderRepository = $subscriptionOrderRepository;
  345.         $this->customerAddressRepository = $customerAddressRepository;
  346.         $this->stateMachineRegistry = $stateMachineRegistry;
  347.         $this->connection = $connection;
  348.         $this->stateMachineStateRepository = $stateMachineStateRepository;
  349.         $this->productBundleItemsRepository = $productBundleItemsRepository;
  350.         $this->documentGenerator = $documentGenerator;
  351.         $this->documentRepository = $documentRepository;
  352.     }
  354.     #[Route('/product/search', name: 'frontend.product.search', options: ["seo" => false], defaults: ['XmlHttpRequest' => true], methods: ['POST'])]
  355.     public function searchProduct(Request $request, SalesChannelContext $context): Response
  356.     {
  357.         $products = $this->homepageService->searchProduct($request->request->get('keyword') ?? $request->query->get('keyword'), $context);
  358.         return $this->renderStorefront('@Storefront/storefront/component/header/product-search-result.html.twig', ['products' => $products]);
  359.     }
  361.     #[Route('/app/login', name: 'frontend.econsor.app.storefront.login')]
  362.     public function showApp(Request $request, SalesChannelContext $context): Response
  363.     {
  364.         $url = $this->router->generate('frontend.account.login');
  365.         return $this->redirect($url);
  367.         if ($context->getCustomer() != null) {
  368.             $url = $this->router->generate('frontend.current-deals');
  369.             return $this->redirect($url);
  370.         }
  372.         if ($request->isMethod('POST')) {
  373.             if ($request->request->has('register')) {
  374.                 $url = $this->router->generate('frontend.econsor.app.storefront.register');
  375.                 return $this->redirect($url);
  376.             } else if ($request->request->has('login')) {
  377.                 $url = $this->router->generate('frontend.account.login');
  378.                 return $this->redirect($url);
  379.             } else if ($request->request->has('loginFacebook')) {
  380.                 $url = $this->router->generate('frontend.account.login');
  381.                 return $this->redirect($url);
  382.             }
  383.         }
  385.         $request->getSession()->remove('before-login-video-seen');
  387.         $page = $this->registrationAppPageLoader->load($request, $context);
  389.         return $this->renderStorefront('@Storefront/storefront/page/account/register/index.html.twig', [
  390.             'page' => $page,
  391.             'salesChannelContext' => $context,
  392.             'controllerName' => 'EconsorAppStorefrontController',
  393.             'controllerAction' => 'showApp'
  394.         ]);
  395.     }
  397.     #[Route('/app/register', name: 'frontend.econsor.app.storefront.register')]
  398.     public function registration(Request $request, SalesChannelContext $context): Response
  399.     {
  400.         if ($context->getCustomer() != null) {
  401.             $url = $this->router->generate('frontend.current-deals');
  402.             return $this->redirect($url);
  403.         }
  405.         $page = $this->registrationAppPageLoader->load($request, $context);
  407.         return $this->renderStorefront('@Storefront/storefront/page/custom/register/index.html.twig', ['page' => $page]);
  408.     }
  410.     #[Route('/app/google/login/finish', name: 'frontend.google.login')]
  411.     public function googleLoginFinish(Request $request, SalesChannelContext $context): Response
  412.     {
  413.         if ($context->getCustomer() != null) {
  414.             $url = $this->router->generate('frontend.current-deals');
  415.             return $this->redirect($url);
  416.         }
  418.         $data = $request->query->all();
  419.         $page = $this->registrationAppPageLoader->load($request, $context);
  421.         return $this->renderStorefront('@Storefront/storefront/page/custom/google-login/google-login-finish.html.twig', [
  422.             'page' => $page,
  423.             'salesChannelContext' => $context,
  424.             'tag' => array_key_exists('tag', $data) ? $data['tag'] : [],
  425.             'salutationId' => array_key_exists('salutationId', $data) ? $data['salutationId'] : '',
  426.             'phoneNumber' => array_key_exists('phoneNumber', $data) ? $data['phoneNumber'] : '',
  427.             'firstName' => array_key_exists('firstName', $data) ? $data['firstName'] : '',
  428.             'lastName' => array_key_exists('lastName', $data) ? $data['lastName'] : '',
  429.             'userName' => array_key_exists('email', $data) ? $data['email'] : '',
  430.             'birthday' => array_key_exists('birthday', $data) ? $data['birthday'] : '',
  431.             'email' => array_key_exists('email', $data) ? $data['email'] : '',
  432.             'password' => array_key_exists('password', $data) ? $data['password'] : '',
  433.             'isConfirm' => array_key_exists('isConfirm', $data) ? $data['isConfirm'] : '',
  434.             'violations' => array_key_exists('violations', $data) ? $data['violations'] : [],
  435.             'controllerName' => 'EconsorAppStorefrontController',
  436.             'controllerAction' => 'registration'
  437.         ]);
  438.     }
  441.     #[Route('/app/register/form', name: 'frontend.econsor.app.storefront.register.form')]
  442.     public function registrationInterest(Request $request, SalesChannelContext $context): Response
  443.     {
  444.         if ($context->getCustomer() != null) {
  445.             $url = $this->router->generate('frontend.current-deals');
  446.             return $this->redirect($url);
  447.         }
  449.         $data = $request->query->all();
  450.         $page = $this->registrationAppPageLoader->load($request, $context);
  452.         $criteria = new Criteria();
  454.         $criteria->addFilter(new EqualsFilter('active', true));
  456.         $country = $this->countrySalesChannel->search(new Criteria(), $context)->getElements();
  457.         
  458.         return $this->renderStorefront('@Storefront/storefront/page/custom/register-interest/index.html.twig', [
  459.             'page' => $page,
  460.             'salesChannelContext' => $context,
  461.             'tag' => array_key_exists('tag', $data) ? $data['tag'] : [],
  462.             'salutationId' => array_key_exists('salutationId', $data) ? $data['salutationId'] : '',
  463.             'phoneNumber' => array_key_exists('phoneNumber', $data) ? $data['phoneNumber'] : '',
  464.             'firstName' => array_key_exists('firstName', $data) ? $data['firstName'] : '',
  465.             'lastName' => array_key_exists('lastName', $data) ? $data['lastName'] : '',
  466.             'userName' => array_key_exists('email', $data) ? $data['email'] : '',
  467.             'birthday' => array_key_exists('birthday', $data) ? $data['birthday'] : '',
  468.             'email' => array_key_exists('email', $data) ? $data['email'] : '',
  469.             'password' => array_key_exists('password', $data) ? $data['password'] : '',
  470.             'isConfirm' => array_key_exists('isConfirm', $data) ? $data['isConfirm'] : '',
  471.             'violations' => array_key_exists('violations', $data) ? $data['violations'] : [],
  472.             'controllerName' => 'EconsorAppStorefrontController',
  473.             'country' => $country,
  474.             'controllerAction' => 'registration'
  475.         ]);
  476.     }
  478.     #[Route('/', name: 'frontend.home.page')]
  479.     public function home(Request $request, SalesChannelContext $context): Response
  480.     {
  481. //         $currentLocaleId = $context->getSalesChannel()->getLanguageId();
  482. //         if (!empty($currentLocaleId)) {
  483. //             $localeCriteria = new Criteria([$currentLocaleId]);
  484. //             $localeCriteria->addAssociation('translationCode');
  486. //             /** @var LanguageEntity|null $currentLocale */
  487. //             $currentLocale = $this->languageRepository->search($localeCriteria, $context->getContext())->first();
  488. //             if (!empty(explode('-', $currentLocale->getTranslationCode()->getCode())[1])) {
  489. //                 $isoCode = strtolower(explode('-', $currentLocale->getTranslationCode()->getCode())[1]);
  491. //                 if ($isoCode === 'vn') {
  492. //                     $page = $this->genericLoader->load($request, $context);
  493. //                     return $this->renderStorefront('@Storefront/storefront/page/content/index-vn.html.twig', ['page' => $page]);
  494. //                 }
  495. //                else if ($isoCode === 'hk') {
  496. //                    $page = $this->genericLoader->load($request, $context);
  497. //                    return $this->renderStorefront('@Storefront/storefront/page/content/index-en.html.twig', ['page' => $page]);
  498. //                }
  499. //             }
  500. //         }
  502.         return $this->redirectToRoute('frontend.current-deals');
  503.     }
  505.     #[Route('/account', name: 'frontend.account.home.page', defaults: ['_loginRequired' => true], methods: ['GET'])]
  506.     public function accountOverView(Request $request, SalesChannelContext $context, Context $sale): Response
  507.     {
  508.         if ($request->query->get('confirmDoneOrder')){
  509.             $orderId = $request->query->get('orderIdConfirmDone');
  511.             if ($orderId) {
  512.                 try {
  513.                     // Get current custom fields for the order
  514.                     $orderCriteria = new Criteria([$orderId]);
  515.                     $orderCriteria->addAssociation('stateMachineState');
  516.                     $order = $this->orderRepository->search($orderCriteria, $context->getContext())->first();
  517.                     if (!$order) {
  518.                         throw new \Exception('Order not found');
  519.                     }
  521.                     if ($order->getStateMachineState()->getTechnicalName() === 'completed') {
  522.                         throw new \Exception('Order completed!');
  523.                     }
  524.                     $customFields = $order->getCustomFields() ?? [];
  526.                     // Set the typeDoneOrder field
  527.                     $customFields['typeDoneOrder'] = 'confirm';
  528.                     try {
  529.                         // Update order state to 'complete' using StateMachineRegistry
  530.                         // First update the custom fields
  531.                         $this->orderRepository->update([
  532.                             [
  533.                                 'id' => $orderId,
  534.                                 'customFields' => $customFields
  535.                             ]
  536.                         ], $context->getContext());
  538.                         // Then transition the order state to 'complete'
  539.                         $this->stateMachineRegistry->transition(
  540.                             new Transition(
  541.                                 'order',
  542.                                 $orderId,
  543.                                 'complete',
  544.                                 'stateId'
  545.                             ),
  546.                             $context->getContext()
  547.                         );
  549.                         $this->logger->info('Order state updated successfully', [
  550.                             'orderId' => $orderId,
  551.                             'processState' => 'process',
  552.                             'finalState' => 'complete',
  553.                             'method' => 'StateMachineRegistry transition'
  554.                         ]);
  555.                     } catch (\Exception $dbException) {
  556.                         $this->logger->error('Error updating order state:', [
  557.                             'orderId' => $orderId,
  558.                             'method' => 'StateMachineRegistry transition',
  559.                             'error' => $dbException->getMessage(),
  560.                             'trace' => $dbException->getTraceAsString()
  561.                         ]);
  562.                         throw new \Exception('Failed to update order state: ' . $dbException->getMessage());
  563.                     }
  564.                     // Add a success message for the user with more details
  565.                     $this->addFlash('success', 'Order has been marked as complete successfully and custom fields have been updated using StateMachineRegistry transition.');
  566.                 } catch (\Exception $e) {
  567.                     // Log the error with detailed information
  568.                     $this->logger->error('Failed to update order status:', [
  569.                         'orderId' => $orderId,
  570.                         'error' => $e->getMessage(),
  571.                         'trace' => $e->getTraceAsString()
  572.                     ]);
  574.                     // Add an error message for the user
  575.                     $this->addFlash('danger', 'Failed to update order status: ' . $e->getMessage());
  576.                 }
  577.             }
  578.         }
  579.         $page = $this->genericLoader->load($request, $context);
  580.         $status = $request->query->get('status');
  581.         $orders = $this->homepageService->getCustomerOrderByStatus($status, $context);
  582.         $customerCredit = $this->homepageService->getCustomerCredit($context, $sale);
  583.         $nextCreditProductLevel = $this->homepageService->loadNextCreditProductOfCustomer($customerCredit, $context);
  584.         $customerInvitedCount = $this->homepageService->getCustomerInvitedCount($context);
  585.         $interest = $this->homepageService->getCustomerTag($context);
  586.         $customerSubscriptions = $this->homepageService->getSubscriptions($context);
  587.         $sumPriceSubscriptions = $this->homepageService->sumPriceSubscriptions($customerSubscriptions);
  588.         $customer = $context->getCustomer();
  589.         $isPartner = $customer !== null
  590.             && $customer->getAffiliateCode() !== null
  591.             && $customer->getAffiliateCode() === $customer->getCampaignCode();
  593.         return $this->renderStorefront('@Storefront/storefront/page/custom/account/over-view/index.html.twig', [
  594.             'page' => $page,
  595.             'customer' => $customerCredit,
  596.             'orders' => $orders,
  597.             'interest' => $interest,
  598.             'nextCreditProductLevel' => $nextCreditProductLevel,
  599.             'customerInvitedCount' => $customerInvitedCount,
  600.             'sumPriceSubscriptions' => $sumPriceSubscriptions,
  601.             'isPartner' => $isPartner,
  602.         ]);
  603.     }
  605.     #[Route('/account/dashboard', name: 'frontend.account.dashboard', defaults: ['_loginRequired' => true], methods: ['GET'])]
  606.     public function accountDashboard(Request $request, SalesChannelContext $context, Context $sale): Response
  607.     {
  608.         $page = $this->genericLoader->load($request, $context);
  609.         $customer = $context->getCustomer();
  611.         $dataStreamLiked = $this->postService->fetchStream($context->getCustomer()->getId(), $context, "liked");
  612.         $dataStreamUpload = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "uploaded");
  613.         $dataStreamSaved = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "saved");
  615.         return $this->renderStorefront('@Storefront/storefront/page/account/dashboard/index.html.twig', ['page' => $page, 'dataStreamUpload' => $dataStreamUpload, 'dataStreamLiked' => $dataStreamLiked, 'dataStreamSaved' => $dataStreamSaved, 'dashboardData' => $this->customerDataService->getBoughtProducts($context)]);
  616.     }
  618.     #[Route('/account/order', name: 'frontend.account.order.page', defaults: ['_loginRequired' => true], methods: ['GET'])]
  619.     public function accountMyOrder(Request $request, SalesChannelContext $context): Response
  620.     {
  621.         $status = $request->query->get('status');
  622.         $page = $this->genericLoader->load($request, $context);
  623.         $orders = $this->homepageService->getCustomerOrderByStatus($status, $context);
  624.         $customer = $context->getCustomer();
  625.         $isPartner = $customer !== null
  626.             && $customer->getAffiliateCode() !== null
  627.             && $customer->getAffiliateCode() === $customer->getCampaignCode();
  628.         return $this->renderStorefront('@Storefront/storefront/page/custom/account/my-order/index.html.twig', ['page' => $page, 'orders' => $orders, 'isPartner' => $isPartner]);
  629.     }
  631.     #[Route('/account/partner-dashboard', name: 'frontend.account.partner.dashboard', defaults: ['_loginRequired' => true], methods: ['GET'])]
  632.     public function accountPartnerDashboard(Request $request, SalesChannelContext $context): Response
  633.     {
  634.         $page = $this->genericLoader->load($request, $context);
  635.         $invitedList = $this->homepageService->getCustomerInvitedList($context);
  636.         return $this->renderStorefront('@Storefront/storefront/page/custom/account/partner-dashboard/index.html.twig', [
  637.             'page' => $page,
  638.             'invitedList' => $invitedList,
  639.             'totalVideoWatchedToday' => $this->videoRecordRepository->search((new Criteria())->addFilter(
  640.                 new EqualsFilter('customerId', $context->getCustomerId()),
  641.                 new EqualsFilter('type', 'watch'),
  642.                 new RangeFilter('createdAt', [
  643.                     RangeFilter::GTE => (new \DateTime())->setTime(0, 0)->format('Y-m-d H:i:s'),
  644.                     RangeFilter::LTE => (new \DateTime())->setTime(23, 59, 59)->format('Y-m-d H:i:s')
  645.                 ]),
  646.             ), $context->getContext())->count(),
  647.             'totalVideoSharedToday' => $this->videoRecordRepository->search((new Criteria())->addFilter(
  648.                 new EqualsFilter('customerId', $context->getCustomerId()),
  649.                 new EqualsFilter('type', 'share'),
  650.                 new RangeFilter('createdAt', [
  651.                     RangeFilter::GTE => (new \DateTime())->setTime(0, 0)->format('Y-m-d H:i:s'),
  652.                     RangeFilter::LTE => (new \DateTime())->setTime(23, 59, 59)->format('Y-m-d H:i:s')
  653.                 ]),
  654.             ), $context->getContext())->count(),
  655.         ]);
  656.     }
  658.     #[Route('/account/order-list', name: 'frontend.account.order.page.list', options: ["seo" => false], defaults: ['_loginRequired' => true, 'XmlHttpRequest' => true], methods: ['POST'])]
  659.     public function accountMyOrderList(Request $request, SalesChannelContext $context): Response
  660.     {
  661.         $status = $request->request->get('status');
  662.         $isMobile = $request->request->get('isMobile');
  663.         $orders = $this->homepageService->getCustomerOrderByStatus($status, $context);
  664.         $customer = $context->getCustomer();
  665.         $isPartner = $customer !== null
  666.             && $customer->getAffiliateCode() !== null
  667.             && $customer->getAffiliateCode() === $customer->getCampaignCode();
  668.         return $this->renderStorefront('@Storefront/storefront/page/custom/account/my-order/list-order.html.twig', ['orders' => empty($orders['errorMsg']) ? $orders : [], 'isMobile' => $isMobile, 'isPartner' => $isPartner]);
  669.     }
  671.     #[Route(path: '/notification/list', name: 'frontend.notification.list', defaults: ['_loginRequired' => true, 'XmlHttpRequest' => true], methods: ['POST', 'GET'])]
  672.     public function getNotificationList(Request $request, SalesChannelContext $context): Response
  673.     {
  674.         $customerId = $context->getCustomer()->getId();
  675.         $type = $request->request->get('type', null);
  676.         $criteria = new Criteria();
  677.         $criteria->addFilter(new EqualsFilter('customerId', $customerId));
  678.         $criteria->addAssociation('notification');
  679.         $criteria->addSorting(new FieldSorting('createdAt', FieldSorting::DESCENDING));
  680.         if (!empty($type)) {
  681.             $criteria->addFilter(new EqualsFilter('notification.type', $type));
  682.         }
  683.         $notifications = $this->customerNotificationRepository->search($criteria, $context->getContext());
  685.         // Update view notification of customer
  686.         $unviewNotifications = $notifications->filter(fn($notification) => $notification->getIsView() == 0);
  687.         if (count($unviewNotifications) > 0) {
  688.             foreach ($unviewNotifications as $customerNotification) {
  689.                 $this->customerNotificationRepository->update([
  690.                     [
  691.                         'id' => $customerNotification->getId(),
  692.                         'isView' => 1
  693.                     ]
  694.                 ], $context->getContext());
  695.             }
  696.         }
  698.         // Quantity of lucky wheel
  699.         $criteriaLuckyWheel = new Criteria();
  700.         $currentDate = (new \DateTime())->format('Y-m-d H:i:s');
  701.         $criteriaLuckyWheel->addFilter(
  702.             new MultiFilter(
  703.                 MultiFilter::CONNECTION_AND,
  704.                 [
  705.                     new EqualsFilter('customerId', $customerId),
  706.                     new RangeFilter('amountRemain', [RangeFilter::GT => 0]),
  707.                     new OrFilter([
  708.                         new EqualsFilter('expiredDate', null),
  709.                         new RangeFilter('expiredDate', [RangeFilter::GT => $currentDate])
  710.                     ])
  711.                 ]
  712.             )
  713.         )->addFilter(
  714.             new NotFilter(
  715.                 MultiFilter::CONNECTION_AND,
  716.                 [
  717.                     new EqualsFilter('reason', "Invalid"),
  718.                 ]
  719.             )
  720.         );
  721.         $notificationsLuckyWheel = $this->luckyWheelTurnRepository->search($criteriaLuckyWheel, $context->getContext());
  722.         $quantityLuckyWheel = array_reduce($notificationsLuckyWheel->getEntities()->getElements(), function ($carry, $item) {
  723.             return $carry + $item->get('amountRemain');
  724.         }, 0);
  725.         return $this->renderStorefront('@Storefront/storefront/component/header/notification.html.twig', ['notifications' => $notifications, 'quantityLuckyWheel' => $quantityLuckyWheel]);
  726.     }
  728.     #[Route(path: '/notification/count-not-view', name: 'api.notification.count-not-view', defaults: ['_loginRequired' => true, 'XmlHttpRequest' => true], methods: [Request::METHOD_POST])]
  729.     public function getCountNotificationNotView(SalesChannelContext $context): Response
  730.     {
  731.         $customerId = $context->getCustomer()->getId();
  732.         $countNotViewNotification = 0;
  733.         $criteria = new Criteria();
  734.         $criteria->addFilter(new EqualsFilter('customerId', $customerId));
  735.         $criteria->addFilter(new EqualsFilter('isView', 0));
  736.         $notificationsNotView = $this->customerNotificationRepository->search($criteria, $context->getContext());
  737.         $countNotViewNotification = count($notificationsNotView);
  738.         return new JsonResponse([
  739.             'countNotViewNotification' => $countNotViewNotification
  740.         ]);
  741.     }
  743.     #[Route('/my-deals', name: 'frontend.my.deals', defaults: ['_loginRequired' => true], methods: ['GET'])]
  744.     public function myDeals(Request $request, SalesChannelContext $context): Response
  745.     {
  746.         $page = $this->genericLoader->load($request, $context);
  747.         $customer = $context->getCustomer();
  748.         $activeDeals = [];
  749.         if ($customer) {
  750.             $activeDeals = $this->econsorAccountService->getActiveDeals($customer, $context);
  751.         }
  752.         $credits = $this->homepageService->getCredits($context);
  753.         $redeemedItems = $this->homepageService->getRedeemedItems($context);
  754.         return $this->renderStorefront('@Storefront/storefront/page/custom/my-deal/pageDeal.html.twig', ['page' => $page, 'activeDeals' => $activeDeals, 'customer' => $customer, 'credits' => $credits, 'redeemedItems' => $redeemedItems]);
  755.     }
  757.     #[Route('/ai-stream', name: 'frontend.ai.stream')]
  758.     public function aiStream(Request $request, SalesChannelContext $context)
  759.     {
  760.         $page = $this->genericLoader->load($request, $context);
  761.         $customer = $context->getCustomer();
  762.         $experienceId = $request->query->get('experienceId');
  763.         if ($experienceId) {
  764.             return $this->redirectToRoute('frontend.ai.stream.detail.page', ['id' => $experienceId]);
  765.         }
  767.         $dataStream = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "tags", null, $experienceId);
  768.         $dataStream = $dataStream;
  769.         $targetObject = null;
  770.         $index = -1;
  771.         if ($experienceId !== null) {
  772.             foreach ($dataStream as $key => $value) {
  773.                 if ($value->id == $experienceId) {
  774.                     $index = $key;
  775.                     $targetObject = $value;
  776.                     break;
  777.                 }
  778.             }
  779.             if ($targetObject !== null && $index !== -1) {
  780.                 unset($dataStream[$index]);
  781.                 $dataStream = array_values($dataStream);
  782.                 array_unshift($dataStream, $targetObject);
  783.             }
  784.         }
  785.         return $this->renderStorefront('@Storefront/storefront/page/custom/ai-stream/home/index.html.twig', ['page' => $page, 'customer' => $customer, 'dataStream' => $dataStream, 'dashboardData' => $this->customerDataService->getBoughtProducts($context)]);
  786.     }
  788.     // #[Route('/ai-stream-list', name: 'frontend.ai.stream.page.list', options: ["seo" => false], defaults: ['XmlHttpRequest' => true], methods: ['POST'])]
  789.     // public function aiStreamList(Request $request, SalesChannelContext $context)
  790.     // {
  791.         // $page = $this->genericLoader->load($request, $context);
  792.         // $customer = $context->getCustomer();
  793.         // $experienceId = null;
  794.         // $pageNumber = 2;
  796.         // $dataStream = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "tags", null, $experienceId, $pageNumber);
  797.         // return $this->renderStorefront('@Storefront/storefront/page/custom/ai-stream/home/list-video.html.twig', ['page' => $page, 'customer' => $customer, 'dataStream' => $dataStream['posts'], 'dashboardData' => $this->customerDataService->getBoughtProducts($context), 'totalVideo' => $dataStream['total']]);
  798.         // return 1;
  799.     // }
  801.     #[Route('/ai-stream/liked', name: 'frontend.ai.stream.liked', defaults: ['_loginRequired' => true], methods: ['GET'])]
  802.     public function aiStreamLiked(Request $request, SalesChannelContext $context): Response
  803.     {
  804.         $page = $this->genericLoader->load($request, $context);
  805.         $customer = $context->getCustomer();
  806.         $dataStream = $this->postService->fetchStream($context->getCustomer()->getId(), $context, "liked");
  807.         return $this->renderStorefront('@Storefront/storefront/page/custom/ai-stream/liked/index.html.twig', ['page' => $page, 'customer' => $customer, 'dataStream' => $dataStream, 'dashboardData' => $this->customerDataService->getBoughtProducts($context)]);
  808.     }
  810.     #[Route('/ai-stream/upload/list', name: 'frontend.ai.stream.upload.list', defaults: ['_loginRequired' => true], methods: ['GET'])]
  811.     public function aiStreamUploadList(Request $request, SalesChannelContext $context): Response
  812.     {
  813.         $page = $this->genericLoader->load($request, $context);
  814.         $customer = $context->getCustomer();
  815.         $dataStream = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "uploaded");
  816.         return $this->renderStorefront('@Storefront/storefront/page/custom/ai-stream/upload-list/index.html.twig', ['page' => $page, 'customer' => $customer, 'dataStream' => $dataStream, 'dashboardData' => $this->customerDataService->getBoughtProducts($context)]);
  817.     }
  819.     #[Route('/ai-stream/upload', name: 'frontend.ai.stream.upload', defaults: ['_loginRequired' => true], methods: ['GET'])]
  820.     public function aiStreamUpload(Request $request, SalesChannelContext $context): Response
  821.     {
  822.         $page = $this->genericLoader->load($request, $context);
  823.         $customer = $context->getCustomer();
  824.         return $this->renderStorefront('@Storefront/storefront/page/custom/ai-stream/upload/index.html.twig', ['page' => $page, 'customer' => $customer, 'dashboardData' => $this->customerDataService->getBoughtProducts($context)]);
  825.     }
  827.     #[Route('/story-mode/upload', name: 'frontend.story.mode.upload', defaults: ['_loginRequired' => true], methods: ['GET'])]
  828.     public function storyModeUpload(Request $request, SalesChannelContext $context): Response
  829.     {
  830.         $page = $this->genericLoader->load($request, $context);
  831.         $customer = $context->getCustomer();
  832.         return $this->renderStorefront('@Storefront/storefront/page/custom/story-mode/upload/index.html.twig', ['page' => $page, 'customer' => $customer, 'dashboardData' => $this->customerDataService->getBoughtProducts($context)]);
  833.     }
  835.     #[Route('/dealDetail', name: 'frontend.my.deal.detail', defaults: ['_loginRequired' => true], methods: ['GET'])]
  836.     public function myDealDetail(Request $request, SalesChannelContext $context, Context $sale): Response
  837.     {
  838.         $page = $this->genericLoader->load($request, $context);
  839.         $customer = $this->homepageService->getCustomerCredit($context, $sale);
  840.         $orderId = $request->query->get('orderId');
  841.         $orderData = $this->homepageService->getOrderById($orderId, $context);
  842.         $creditType = $this->homepageService->getOrderCreditType($orderId, $context);
  844.         return $this->renderStorefront('@Storefront/storefront/page/custom/my-deal/pageDealDetail.html.twig', ['page' => $page, 'orderData' => $orderData, 'customer' => $customer, 'creditType' => $creditType]);
  845.     }
  847.     #[Route('/trackingDetail', name: 'frontend.tracking.detail', defaults: ['_loginRequired' => true], methods: ['GET'])]
  848.     public function trackingDetail(Request $request, SalesChannelContext $context): Response
  849.     {
  850.         $page = $this->genericLoader->load($request, $context);
  851.         return $this->renderStorefront('@Storefront/storefront/page/custom/tracking/tracking-detail.html.twig', ['page' => $page]);
  852.     }
  854.     #[Route('/ai-stream/account/{customerId}', name: 'frontend.ai-stream.detail', defaults: ['_loginRequired' => true], methods: ['GET'])]
  855.     public function aistreamDetail(Request $request, SalesChannelContext $context): Response
  856.     {
  857.         $page = $this->genericLoader->load($request, $context);
  858.         $customerId = $request->attributes->get('customerId');
  859.         /** @var CustomerEntity $customer */
  860.         $customer = $this->customerEntity->search(new Criteria([$customerId]), $context->getContext())->first();
  862.         $dataStream = [];
  863.         $topProducts = [];
  864.         if (!empty($customer?->getId())) {
  865.             $topProducts = $this->homepageService->getTopProducts($context);
  866.             $dataStream = $this->postService->fetchStream($customerId, $context, "uploaded");
  867.             $customerStats = $this->postService->fetchCustomerStats($customerId, $context);
  868.             $customer->addArrayExtension('aiStreamStats', $customerStats);
  869.         }
  871.         return $this->renderStorefront('@Storefront/storefront/page/custom/ai-stream/ai-stream-detail/index.html.twig', [
  872.             'page' => $page,
  873.             'dataStream' => $dataStream,
  874.             'topProducts' => $topProducts,
  875.             'aiStreamAccount' => $customer,
  876.             'dashboardData' => $this->customerDataService->getBoughtProducts($context)
  877.         ]);
  878.     }
  880.     #[Route(path: '/lucky-wheel', name: 'frontend.credit.lucky-wheel', defaults: ['_loginRequired' => false], methods: ['GET'])]
  881.     public function luckyWheel(Request $request, SalesChannelContext $context): Response
  882.     {
  883.         $page = $this->genericLoader->load($request, $context);
  884.         return $this->renderStorefront('@Storefront/storefront/page/custom/lucky-wheel/index.html.twig', ['page' => $page]);
  885.     }
  887.     #[Route(path: '/rewards', name: 'frontend.rewards', defaults: ['_loginRequired' => true], methods: ['GET'])]
  888.     public function rewardsPage(Request $request, SalesChannelContext $context): Response
  889.     {
  890.         $page = $this->genericLoader->load($request, $context);
  891.         $customer = $context->getCustomer();
  892.         $prizes = $this->luckyWheelApiService->queryUserPrize(null, null, $customer->getId(), $context)->getElements();
  893.         foreach ($prizes as $key => &$prize) {
  894.             if ($prize->prize == null) {
  895.                 $prize->prize = [];
  896.             }
  897.         }
  898.         return $this->renderStorefront('@Storefront/storefront/page/custom/rewards/index.html.twig', ['page' => $page, 'dashboardData' => $this->customerDataService->getBoughtProducts($context), 'prizes' => $prizes]);
  899.     }
  901.     #[Route(path: '/rewards/add-to-cart', name: 'frontend.addToCart', defaults: ['_loginRequired' => true, 'XmlHttpRequest' => true], methods: ['POST'])]
  902.     public function addToCart(Request $request, SalesChannelContext $context): Response
  903.     {
  904.         $customer = $context->getCustomer();
  905.         $prizeId = $request->request->get('prizeId');
  906.         $prize = $this->luckyWheelApiService->queryUserPrizeById($prizeId, $customer->getId(), $context);
  907.         if (!$prize) {
  908.             return new JsonResponse([
  909.                 'success' => false,
  910.                 'message' => 'Prize not found',
  911.             ], 404);
  912.         }
  914.         if ($prize->getCustomer()->getId() != $customer->getId()) {
  915.             return new JsonResponse([
  916.                 'success' => false,
  917.                 'message' => 'Not authorized',
  918.             ], 403);
  919.         }
  921.         if ($prize->getIsClaimed()) {
  922.             return new JsonResponse([
  923.                 'success' => false,
  924.                 'message' => 'Prize not claimed',
  925.             ], 400);
  926.         }
  928.         if ($prize->getTurn()->getReason() == 'Invalid') {
  929.             return new JsonResponse([
  930.                 'success' => false,
  931.                 'message' => 'Invalid prize',
  932.             ], 400);
  933.         }
  935.         $this->rewardShipLaterService->createRewardShipLater([
  936.             'customerId' => $customer->getId(),
  937.             'fromOrderId' => null,
  938.             'referencedId' => $prize->getPrize()->getProduct()->getId(),
  939.             'payload' => [
  940.                 'productId' => $prize->getPrize()->getProduct()->getId(),
  941.                 'isShipWithNextOrder' => false,
  942.             ],
  943.             'quantity' => 1,
  944.             'isShipped' => false,
  945.             'type' => RewardShipLaterType::LuckyWheel->value
  946.         ]);
  948.         $this->luckyWheelApiService->updateIsClaimedById($prize->getId(), $context);
  950.         return new JsonResponse([
  951.             'success' => true,
  952.             'message' => 'Added to cart successfully'
  953.         ]);
  954.     }
  956.     #[Route(path: '/policy', name: 'frontend.app.policy')]
  957.     public function policy(Request $request, SalesChannelContext $context): Response
  958.     {
  959.         return $this->renderStorefront('@Storefront/storefront/page/condition/index.html.twig');
  960.     }
  962.     /**
  963.      * @HttpCache()
  964.      * @Route("/detail/{productId}", name="frontend.detail.page", methods={"GET"})
  965.      */
  966.     public function productDetail(SalesChannelContext $context, Request $request): Response
  967.     {
  968.         $page = $this->productPageLoader->load($request, $context);
  969.         $this->hook(new ProductPageLoadedHook($page, $context));
  971.         $productId = $request->attributes->get('productId');
  972.         $customerId = $context->getCustomer()?->getId();
  974.         // Check if the customer has an active subscription for this product
  975.         $hasActiveSubscription = $this->subscriptionService->hasActiveSubscription(
  976.             $customerId,
  977.             $productId,
  978.             $context
  979.         );
  981.         $product = $page->getProduct();
  982.         if (isset($product->getCustomFields()['productIsBuyWithCredit']) && $product->getCustomFields()['productIsBuyWithCredit'] === true) {
  983.             $url = $this->router->generate('frontend.shop4free');
  984.             return $this->redirect($url);
  985.         }
  986.         $outOfStock = false;
  987.         if ($product->getAvailableStock() > 0) {
  988.             $customFields = $product->getCustomFields();
  989.             if (isset($customFields['isProductBundle']) && $customFields['isProductBundle'] == true) {
  990.                 $outOfStock = $this->isOutOfStock($product->getId(), $context);
  991.             }
  992.         } else {
  993.             $outOfStock = true;
  994.         }
  995. //        $this->hook(new ProductPageLoadedHook($page, $context));
  997.         return $this->renderStorefront('@Storefront/storefront/page/product-detail/index.html.twig', ['page' => $page, 'ourOfStock' => $outOfStock, 'hasActiveSubscription' => $hasActiveSubscription]);
  998.     }
  1000.     private function isOutOfStock(string $productId, SalesChannelContext $context): bool
  1001.     {
  1002.         // Create criteria to search for bundle items by product ID
  1003.         $criteria = new Criteria();
  1004.         $criteria->addFilter(new EqualsFilter('productId', $productId));
  1005.         $criteria->addAssociation('relatedProduct');
  1006.         $criteria->addAssociation('relatedProduct.swagDynamicAccessRules');
  1007.         $criteria->addAssociation('product.swagDynamicAccessRules');
  1008.         $criteria->addAssociation('product.swagDynamicAccessRules');
  1010.         // Search for bundle items using the repository
  1011.         $bundleItems = $this->productBundleItemsRepository->search($criteria, $context->getContext());
  1013.         // If there are no bundle items, the product is not a bundle
  1014.         if ($bundleItems->count() === 0) {
  1015.             return true;
  1016.         }
  1018.         // Check if any of the bundle items are out of stock
  1019.         $outOfStock = true;
  1020.         foreach ($bundleItems as $bundleItem) {
  1021.             // Get the related product and quantity
  1022.             $relatedProduct = $bundleItem->getRelatedProduct();
  1024.             // If the related product doesn't exist or doesn't have enough stock, the bundle is out of stock
  1025.             if ($relatedProduct && $relatedProduct->getAvailableStock() > 0) {
  1026.                 $rulesProduct = $bundleItem->getProduct()->get('swagDynamicAccessRules');
  1027.                 $rulesRelatedProduct = $bundleItem->getRelatedProduct()->get('swagDynamicAccessRules');
  1028.                 if (count($rulesRelatedProduct) > 0 && count($rulesProduct) > 0) {
  1029.                     foreach ($rulesProduct as $ruleProduct) {
  1030.                         foreach ($rulesRelatedProduct as $ruleRelatedProduct) {
  1031.                             if ($ruleRelatedProduct->getId() === $ruleProduct->getId()) {
  1032.                                 $outOfStock = false;
  1033.                             }
  1034.                         }
  1035.                     }
  1036.                 } elseif (count($rulesRelatedProduct) == 0 && count($rulesProduct) == 0) {
  1037.                     $outOfStock = false;
  1038.                 } else {
  1039.                     return true;
  1040.                 }
  1041.             } else {
  1042.                 return true;
  1043.             }
  1044.         }
  1045.         return $outOfStock;
  1046.     }
  1048.     /**
  1049.      * @HttpCache()
  1050.      * @Route("/ai-stream/{id}", name="frontend.ai.stream.detail.page", methods={"GET"})
  1051.      */
  1053.     #[Route('/ai-stream/{id}', name: 'frontend.ai.stream.detail.page', defaults: ['_loginRequired' => false], methods: ['GET'])]
  1054.     public function aiStreamDetailHomePage(Request $request, SalesChannelContext $context)
  1055.     {
  1056.         $page = $this->genericLoader->load($request, $context);
  1057.         $customer = $context->getCustomer();
  1058.         $experienceId = $request->attributes->get('id');
  1060.         $dataStream = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "tags", null, $experienceId);
  1061.         $targetObject = null;
  1062.         $index = -1;
  1063.         if ($experienceId !== null) {
  1064.             foreach ($dataStream as $key => $value) {
  1065.                 if ($value->id == $experienceId) {
  1066.                     $index = $key;
  1067.                     $targetObject = $value;
  1068.                     break;
  1069.                 }
  1070.             }
  1071.             if ($targetObject !== null && $index !== -1) {
  1072.                 unset($dataStream[$index]);
  1073.                 $dataStream = array_values($dataStream);
  1074.                 array_unshift($dataStream, $targetObject);
  1075.             }
  1076.         }
  1078.         return $this->renderStorefront('@Storefront/storefront/page/custom/ai-stream/home/index.html.twig', ['page' => $page, 'customer' => $customer, 'dataStream' => $dataStream, 'dashboardData' => $this->customerDataService->getBoughtProducts($context)]);
  1079.     }
  1081.     // #[Route('/current-deals', name: 'frontend.current-deals')]
  1083.     /**
  1084.      * @HttpCache()
  1085.      * @Route("/current-deals", name="frontend.current-deals", methods={"GET"})
  1086.      */
  1087.     public function currentDeals(Request $request, SalesChannelContext $context): Response
  1088.     {
  1089.         $arr_productId = [];
  1090.         $page = $this->genericLoader->load($request, $context);
  1092.         $categories = $this->homepageService->getCategories($context);
  1093.         return $this->renderStorefront('@Storefront/storefront/page/content/current-deals.html.twig', ['page' => $page, 'repertusProductReservationOptions' => $arr_productId, 'categories' => $categories]);
  1094.     }
  1096.     #[Route(path: '/data-stream', name: 'frontend.data-stream', defaults: ['XmlHttpRequest' => true])]
  1097.     public function getDataStream(Request $request, SalesChannelContext $context)
  1098.     {
  1099.         $page = $this->genericLoader->load($request, $context);
  1100.         $productId = $request->request->get('productId');
  1101.         $type = $request->request->get('type');
  1103.         if ($type == 'details') {
  1104.             $dataStream = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "tags", $productId, null, 1, 10);
  1105.             return $this->renderStorefront('@Storefront/storefront/page/custom/list-data-stream/list-data-stream-detail.html.twig', ['page' => $page, 'dataStream' => $dataStream]);
  1106.         } else {
  1107.             $dataStream = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "tags", null, null, 1, 10);
  1108.         }
  1110.         return $this->renderStorefront('@Storefront/storefront/page/custom/list-data-stream/list-data-stream.html.twig', ['page' => $page, 'dataStream' => $dataStream]);
  1111.     }
  1113.     // #[Route('/invite-friends', name: 'frontend.invite-friends', defaults: ['_loginRequired' => true], methods: ['GET'])]
  1114.     // public function inviteFriends(Request $request, SalesChannelContext $context): Response
  1115.     // {
  1116.     //     $page = $this->genericLoader->load($request, $context);
  1118.     //     return $this->renderStorefront('@Storefront/storefront/page/custom/invite-friends/index.html.twig', ['page' => $page]);
  1119.     // }
  1121. //    #[Route('/navigation/{navigationId}', name: 'frontend.navigation.page')]
  1122. //    public function index(SalesChannelContext $context, Request $request): Response
  1123. //    {
  1124. //        $page = $this->genericLoader->load($request, $context);
  1125. //        $this->hook(new NavigationPageLoadedHook($page, $context));
  1126. //
  1127. //        return $this->renderStorefront('@Storefront/storefront/page/content/index.html.twig', ['page' => $page]);
  1128. //    }
  1130.     #[Route('/app/register/create-account', name: 'frontend.econsor.app.storefront.register.create-account')]
  1131.     public function register(Request $request, SalesChannelContext $context): Response
  1132.     {
  1133.         if ($request->isMethod('POST')) {
  1134.             if (empty($request->request->get('userName')) && !empty($request->request->get('email'))) {
  1135.                 $request->request->set('userName', $request->request->get('email'));
  1136.             }
  1138.             if (!empty($request->request->get('countryId'))) {
  1139.                 $countryCriteria = new Criteria();
  1140.                 $countryCriteria->addFilter(new EqualsFilter('id', strtoupper($request->request->get('countryId'))));;
  1141.                 $country = $this->countryRepository->search($countryCriteria, $context->getContext())->first();
  1142.                 if (!empty($country)) {
  1143.                     $request->request->set('countryCode', $country->getIso());
  1144.                 }
  1145.             } else {
  1146.                 if (!empty($request->request->get('countryCode'))) {
  1147.                     $countryCriteria = new Criteria();
  1148.                     $countryCriteria->addFilter(new EqualsFilter('iso', strtoupper($request->request->get('countryCode'))));
  1149.                     $country = $this->countryRepository->search($countryCriteria, $context->getContext())->first();
  1150.                     if (!empty($country)) {
  1151.                         $request->request->set('countryId', $country->getId());
  1152.                     }
  1153.                 }
  1154.             }
  1156.             $validation = $this->validateCustomer($request, $context);
  1157.             if ($validation instanceof CustomerEntity) {
  1158.                 if (array_key_exists('tag', $request->request->all())) {
  1159.                     $this->contextResolver->resolve($request);
  1160.                     $context = $request->attributes->get('sw-sales-channel-context');
  1162.                     $this->setInterests($context, $request->request->all()['tag']);
  1163.                     $this->setCustomFields($context, [
  1164.                         'customerCountryCode' => $request->request->get('countryCode'),
  1165.                         'customerLanguageCode' => $request->request->get('languageCode'),
  1166.                         'customerCountryId' => $request->request->get('countryId'),
  1167.                         'customerLanguageId' => $request->request->get('languageId'),
  1168.                     ]);
  1169.                 }
  1171.                 // if (in_array($request->request->get('countryCode'), ['vn'])) {
  1172.                 //     return $this->redirectToRoute('frontend.account.progress');
  1173.                 // }
  1175.                 $url = $this->router->generate('frontend.home.page');
  1177.                 return $this->redirect($url);
  1178.             }
  1180.             return $validation;
  1181.         } else {
  1183.             $url = $this->router->generate('frontend.econsor.app.storefront.register.form');
  1185.             return $this->redirect($url);
  1186.         }
  1187.     }
  1189.     private function validateCustomer(Request $request, SalesChannelContext $context): RedirectResponse|CustomerEntity
  1190.     {
  1191.         $definition = $this->customerValidationFactory->create($context);
  1192.         $minLength = $this->systemConfigService->get('core.loginRegistration.passwordMinLength', $context->getSalesChannel()->getId());
  1193.         $definition->add('password', new NotBlank(), new Length(['min' => $minLength]));
  1194.         $options = ['context' => $context->getContext(), 'salesChannelContext' => $context];
  1195.         $definition->add('email', new CustomerEmailUnique($options));
  1196.         $definition->add('phoneNumber', new NotBlank());
  1197.         $definition->add('salutationId', new NotBlank());
  1198.         $definition->add('userName', new NotBlank());
  1199.         $definition->add('birthday', new NotBlank());
  1200.         $definition->add('tag', new NotBlank());
  1202.         if ($request->getSession()->has('affiliateCode')) {
  1203.             $request->request->set('affiliateCode', $request->getSession()->get('affiliateCode'));
  1204.         }
  1206.         $constraints = $this->getAffiliateCodeConstraints($context->getContext());
  1208.         foreach ($constraints as $constraint) {
  1209.             $definition->add('affiliateCode', $constraint);
  1210.         }
  1212.         $validation = $this->dataValidator->getViolations($request->request->all(), $definition);
  1214.         //check for validation errors.
  1215.         if ($validation->count() > 0) {
  1217.             $violations = ['violations' => []];
  1219.             foreach ($validation as $violation) {
  1221.                 $violations['violations'][$violation->getPropertyPath()] = $violation->getMessage();
  1222.             }
  1224.             $request->request->add($violations);
  1225.             $url = $this->router->generate('frontend.econsor.app.storefront.register.form', $request->request->all());
  1227.             return $this->redirect($url);
  1228.         }
  1230.         //create account
  1231.         $billingAddress = (array)$request->request->get('billingAddress');
  1232.         $billingAddress['phoneNumber'] = $request->request->get('phoneNumber');
  1233.         $billingAddress['countryId'] = $request->request->get('countryId');
  1234.         $request->request->set('billingAddress', $billingAddress);
  1236.         $birthDay = !empty($request->request->get('birthday')) ? date_parse_from_format('Y-m-d', $request->request->get('birthday')) : null;
  1237.         if (!empty($birthDay)) {
  1238.             $request->request->set('birthdayDay', $birthDay['day']);
  1239.             $request->request->set('birthdayMonth', $birthDay['month']);
  1240.             $request->request->set('birthdayYear', $birthDay['year']);
  1241.         }
  1243.         $requestDataBag = new RequestDataBag($request->request->all());
  1244.         $this->registerController->register($request, $requestDataBag, $context);
  1246.         $this->contextResolver->resolve($request);
  1248.         return $request->attributes->get('sw-sales-channel-context')->getCustomer();
  1249.     }
  1251.     /**
  1252.      * @param Context $context
  1253.      * @return array
  1254.      */
  1255.     protected function getAffiliateCodeConstraints(Context $context): array
  1256.     {
  1257.         $notBlankConstraint = new NotBlank();
  1258.         $customerExistsConstraint = new EntityExists([
  1259.             'entity' => CustomerDefinition::ENTITY_NAME,
  1260.             'context' => $context,
  1261.         ]);
  1262.         $customerExistsConstraint->primaryProperty = 'affiliateCode';
  1264.         return [
  1265.             $notBlankConstraint,
  1266.             $customerExistsConstraint
  1267.         ];
  1268.     }
  1270.     private function setCustomFields(SalesChannelContext $context, array $customFields)
  1271.     {
  1272.         $customer = $context->getCustomer();
  1273.         $customerCustomFields = $customer?->getCustomFields() ?? [];
  1275.         foreach ($customFields as $key => $value) {
  1276.             $customerCustomFields[$key] = $value;
  1277.         }
  1279.         $this->customerEntity->update(
  1280.             [
  1281.                 [
  1282.                     'id' => $customer->getId(),
  1283.                     'customFields' => $customerCustomFields,
  1284.                 ]
  1285.             ],
  1286.             $context->getContext()
  1287.         );
  1288.     }
  1290.     private function setInterests(SalesChannelContext $context, array $tags)
  1291.     {
  1292.         $customer = $context->getCustomer();
  1294.         $tagsTemp = [];
  1295.         foreach ($tags as $tag => $ignored) {
  1296.             array_push($tagsTemp, ['id' => $tag]);
  1297.         }
  1299.         $this->customerEntity->update(
  1300.             [
  1301.                 [
  1302.                     'id' => $customer->getId(),
  1303.                     'customerInterests' => [
  1304.                         'id' => $this->getExtensionIdByCustomer($customer),
  1305.                         'customerId' => $customer->getId(),
  1306.                         'tags' => $tagsTemp
  1307.                     ]
  1308.                 ]
  1309.             ],
  1310.             $context->getContext()
  1311.         );
  1312.     }
  1314.     private function getExtensionIdByCustomer(CustomerEntity $customer): string
  1315.     {
  1316.         if (
  1317.             $customer->getExtension('customerInterests') && isset(
  1318.                 $customer->getExtension('customerInterests')->all()['id']
  1319.             )
  1320.         ) {
  1321.             $extensionId = $customer->getExtension('customerInterests')->all()['id'];
  1322.         } else {
  1323.             $extensionId = Uuid::randomHex();
  1324.         }
  1326.         return $extensionId;
  1327.     }
  1329.     #[Route('/app/intro', name: 'frontend.econsor.app.storefront.intro')]
  1330.     public function intro(Request $request, SalesChannelContext $context): Response
  1331.     {
  1332.         if ($context->getCustomer() == null) {
  1333.             $url = $this->router->generate('frontend.econsor.app.storefront.login');
  1334.             return $this->redirect($url);
  1335.         }
  1337.         $page = $this->registrationAppPageLoader->load($request, $context);
  1339.         return $this->renderStorefront('@Storefront/storefront/page/custom/intro/index.html.twig', [
  1340.             'page' => $page,
  1341.             'salesChannelContext' => $context,
  1342.             'request' => $request,
  1343.             'controllerName' => 'EconsorAppStorefrontController',
  1344.             'controllerAction' => 'intro'
  1345.         ]);
  1346.     }
  1348.     #[Route('/termCondition', name: 'frontend.term.condition')]
  1349.     public function termCondition(Request $request, SalesChannelContext $context): Response
  1350.     {
  1351.         $page = $this->registrationAppPageLoader->load($request, $context);
  1353.         return $this->renderStorefront('@Storefront/storefront/page/condition/index.html.twig', ['page' => $page]);
  1354.     }
  1356.     #[Route('/app/wishlist', name: 'frontend.wishlist.modal.note')]
  1357.     public function wishlist(Request $request, SalesChannelContext $context): Response
  1358.     {
  1359.         return new Response("WISHLIST");
  1360.     }
  1362.     #[Route('/upload/create', name: 'frontend.econsor.app.storefront.upload.create', methods: ['GET'], defaults: ['_loginRequired' => true])]
  1363.     public function create(Request $request, SalesChannelContext $context): Response
  1364.     {
  1365.         $page = $this->profilePageLoader->load($request, $context);
  1367. //        $this->hook(new AccountProfilePageLoadedHook($page, $context));
  1369.         return $this->renderStorefront('@Storefront/storefront/page/custom/uploads/index.html.twig', ['page' => $page]);
  1370.     }
  1372.     #[Route('/account/profile', name: 'frontend.account.profile.page', methods: ['GET'], defaults: ['_loginRequired' => true])]
  1373.     public function profileOverview(Request $request, SalesChannelContext $context, CustomerEntity $customer): Response
  1374.     {
  1375.         $page = $this->profilePageLoader->load($request, $context);
  1377.         $request->attributes->set('addressId', $customer->getDefaultBillingAddressId());
  1379.         $country = $this->addressDetailPageLoader->load($request, $context, $customer);
  1380.         $address = $this->homepageService->getCustomerAddress($context);
  1381.         $pendingCustomerBusinessName = $this->customerBusinessNameService->getPendingCustomerBusinessName($customer, $context->getContext());
  1382.         $customer = $context->getCustomer();
  1384. //        $this->hook(new AccountProfilePageLoadedHook($page, $context));
  1386. //        $this->hook(new AddressDetailPageLoadedHook($country, $context));
  1388.         return $this->renderStorefront('@Storefront/storefront/page/account/profile/index.html.twig', [
  1389.             'page' => $page,
  1390.             'address' => $address,
  1391.             'customer' => $customer,
  1392.             'country' => $country,
  1393.             'pendingCustomerBusinessName' => $pendingCustomerBusinessName,
  1394.             'passwordFormViolation' => $request->get('passwordFormViolation'),
  1395.             'emailFormViolation' => $request->get('emailFormViolation'),
  1396.         ]);
  1397.     }
  1399.     #[Route('/account/profile', name: 'frontend.account.profile.save', methods: ['POST'], defaults: ['_loginRequired' => true])]
  1400.     public function saveProfile(Request $request, RequestDataBag $data, SalesChannelContext $context, CustomerEntity $customer): Response
  1401.     {
  1402.         $updateType = $data->get('updateType');
  1404.         if (!empty($updateType)) {
  1405.             switch ($updateType) {
  1406.                 case 'interest':
  1407.                     {
  1408.                         $this->setInterests($context, $request->request->all()['tag']);
  1409.                         return $this->redirectToRoute('frontend.account.home.page');
  1410.                     }
  1411.                     break;
  1412.                 case 'profile':
  1413.                     {
  1414.                         $businessNameUpdateId = $data->get('businessNameUpdateId');
  1415.                         $currentBusinessName = $data->get('currentBusinessName');
  1416.                         $businessName = $data->get('businessName');
  1417.                         $birthDay = !empty($data->get('birthday')) ? date_parse_from_format('Y-m-d', $data->get('birthday')) : null;
  1418.                         $dataProfile = new RequestDataBag([
  1419.                             'firstName' => $data->get('firstName'),
  1420.                             'lastName' => $data->get('lastName'),
  1421.                             'birthdayDay' => $birthDay['day'],
  1422.                             'birthdayMonth' => $birthDay['month'],
  1423.                             'birthdayYear' => $birthDay['year'],
  1424.                         ]);
  1425.                         $customerData = [
  1426.                             'id' => $customer->getId(),
  1427.                             'email' => $data->get('email'),
  1428.                             'customFields' => [
  1429.                                 'phoneNumber' => $data->get('phoneNumber'),
  1430.                                 'countryCode' => $data->get('countryCode'),
  1431.                             ],
  1432.                         ];
  1434.                         if (!empty($data->get('email')) && $data->get('email') != $customer->getEmail()) {
  1435.                             $definition = new DataValidationDefinition('customer.email.update');
  1436.                             $definition->add('email', new CustomerEmailUnique(['context' => $context->getContext(), 'salesChannelContext' => $context]));
  1437.                             $validations = $this->dataValidator->getViolations([
  1438.                                 'email' => $data->get('email'),
  1439.                             ], $definition);
  1441.                             //check for validation errors.
  1442.                             $isValid = true;
  1443.                             if ($validations->count() > 0) {
  1444.                                 foreach ($validations as $validation) {
  1445.                                     if ($validation->getPropertyPath() == '/email') {
  1446.                                         $this->addFlash('danger', $validation->getMessage());
  1447.                                         $isValid = false;
  1448.                                     }
  1449.                                 }
  1450.                             }
  1452.                             if ($isValid) {
  1453.                                 $customerData['email'] = $data->get('email');
  1454.                             }
  1455.                         }
  1457.                         $this->changeCustomerProfileRoute->change($dataProfile, $context, $customer);
  1458.                         $this->customerEntity->update([$customerData], $context->getContext());
  1459.                         if ($businessName != null && (empty($currentBusinessName) || $currentBusinessName != $businessName || !empty($businessNameUpdateId))) {
  1460.                             $this->customerBusinessNameService->store($customer, $businessName, $context->getContext());
  1461.                         }
  1462.                     }
  1463.                     break;
  1464.                 case 'avatar':
  1465.                     {
  1466.                         $avatarFile = $request->files->get('avatar');
  1468.                         if (!empty($avatarFile)) {
  1469.                             $media = $this->homepageService->customerAvatarUpload($avatarFile, $customer, $context);
  1471.                             if (!empty($media?->getId())) {
  1472.                                 $customerData = [
  1473.                                     'id' => $customer->getId(),
  1474.                                     'customFields' => [
  1475.                                         'avatar' => $media?->getId()
  1476.                                     ],
  1477.                                 ];
  1478.                                 $this->customerEntity->update([$customerData], $context->getContext());
  1479.                             }
  1480.                         }
  1481.                     }
  1482.                     break;
  1483.                 case 'newsletter':
  1484.                     {
  1485.                         $dataNewsletter = new RequestDataBag();
  1486.                         $dataNewsletter->set('email', $customer->getEmail());
  1487.                         $dataNewsletter->set('zipCode', ($customer->getDefaultShippingAddress() ? $customer->getDefaultShippingAddress()->getZipCode() : null));
  1488.                         $dataNewsletter->set('title', $customer->getTitle());
  1489.                         $dataNewsletter->set('storefrontUrl', $request->attributes->get(RequestTransformer::STOREFRONT_URL));
  1490.                         $dataNewsletter->set('city', ($customer->getDefaultShippingAddress() ? $customer->getDefaultShippingAddress()->getCity() : null));
  1491.                         $dataNewsletter->set('street', ($customer->getDefaultShippingAddress() ? $customer->getDefaultShippingAddress()->getStreet() : null));
  1493.                         if ($data->get('newsletter') == 'on') {
  1494.                             $dataNewsletter->set('option', 'subscribe');
  1495.                             $this->newsletterSubscribeRoute->subscribe(
  1496.                                 $dataNewsletter,
  1497.                                 $context,
  1498.                                 false
  1499.                             );
  1501.                             $this->setNewsletterFlag($customer, true, $context);
  1502.                         } else if ($this->getNewsletterRecipient($dataNewsletter->get('email'), $context) !== null) {
  1503.                             $dataNewsletter->set('option', 'unsubscribe');
  1504.                             $this->newsletterUnsubscribeRoute->unsubscribe(
  1505.                                 $dataNewsletter,
  1506.                                 $context
  1507.                             );
  1509.                             $this->setNewsletterFlag($customer, false, $context);
  1510.                         }
  1511.                     }
  1512.                     break;
  1513.             }
  1514.         }
  1516.         return $this->redirectToRoute('frontend.account.profile.page');
  1517.     }
  1519.     private function setNewsletterFlag(CustomerEntity $customer, bool $newsletter, SalesChannelContext $context): void
  1520.     {
  1521.         $customer->setNewsletter($newsletter);
  1523.         $this->customerEntity->update(
  1524.             [
  1525.                 ['id' => $customer->getId(), 'newsletter' => $newsletter],
  1526.             ],
  1527.             $context->getContext()
  1528.         );
  1529.     }
  1531.     private function getNewsletterRecipient(string $email, SalesChannelContext $context): ?NewsletterRecipientEntity
  1532.     {
  1533.         $criteria = new Criteria();
  1534.         $criteria->addFilter(
  1535.             new MultiFilter(MultiFilter::CONNECTION_AND),
  1536.             new EqualsFilter('email', $email),
  1537.             new EqualsFilter('salesChannelId', $context->getSalesChannel()->getId())
  1538.         );
  1539.         $criteria->addAssociation('salutation');
  1540.         $criteria->setLimit(1);
  1542.         return $this->newsletterRecipientRepository
  1543.             ->search($criteria, $context->getContext())
  1544.             ->first();
  1545.     }
  1547.     #[Route('/progress', name: 'frontend.account.progress', methods: ['GET'], defaults: ["_loginRequired" => true])]
  1548.     public function progress(Request $request, SalesChannelContext $context, CustomerEntity $customer): Response
  1549.     {
  1550.         $page = $this->overviewPageLoader->load($request, $context, $customer);
  1552. //        $this->hook(new AccountOverviewPageLoadedHook($page, $context));
  1554.         $customerCustomFields = $customer->getCustomFields();
  1555.         if (!empty($customerCustomFields['customerCountryCode']) && in_array(strtolower($customerCustomFields['customerCountryCode']), ['vn'])) {
  1556.             $invites = $this->econsorAccountService->getInvites($customer, $context);
  1557.             $creditBalance = $this->econsorAccountService->getCustomerCreditBalance($customer, $context);
  1559.             $view = '@Storefront/storefront/page/progress/index-vn.html.twig';
  1560.             // if ($customerCustomFields['customerCountryCode'] == 'hk') {
  1561.             //     $view = '@Storefront/storefront/page/progress/index-en.html.twig';
  1562.             // }
  1564.             return $this->renderStorefront($view, [
  1565.                 'page' => $page,
  1566.                 'invites' => $invites,
  1567.                 'creditBalance' => $creditBalance,
  1568.                 'customer' => $customer,
  1569.             ]);
  1570.         }
  1572.         $order = $this->orderPageLoader->load($request, $context);
  1574. //        $this->hook(new AccountOrderPageLoadedHook($order, $context));
  1576.         $activeDeals = $this->econsorAccountService->getActiveDeals($customer, $context);
  1577.         $credits = $this->econsorAccountService->getCredits($customer, $context);
  1578.         $redeemedItems = $this->econsorAccountService->getRedeemedItems($customer, $context);
  1580.         $homepage = $this->genericLoader->load($request, $context);
  1581.         $test = $homepage->getCmsPage()->getSections()->getBlocks()->getSlots('content')->getElements();
  1582.         foreach ($test as $key => $value) {
  1583.             if ($value->getType() == 'product-listing') {
  1584.                 $arr = $value->getData();
  1585.             }
  1586.         }
  1587.         $listing = $arr->getListing()->getElements();
  1589.         return $this->renderStorefront('@Storefront/storefront/page/progress/index.html.twig', ['page' => $page, 'order' => $order, 'activeDeals' => $activeDeals, 'credits' => $credits, 'redeemedItems' => $redeemedItems, 'listing' => $listing, 'customer' => $customer]);
  1590.     }
  1592.     #[Route('/shop4free', name: 'frontend.shop4free')]
  1593.     public function shop4freeCustom(Request $request, SalesChannelContext $context, Context $sale): Response
  1594.     {
  1595.         $page = $this->genericLoader->load($request, $context);
  1597.         $products = $this->homepageService->loadProductsWithCreditOption($context);
  1598.         $customer = $this->homepageService->getCustomerCredit($context, $sale);
  1599.         return $this->renderStorefront('@Storefront/storefront/page/shop4free/index.html.twig', ['page' => $page, 'products' => $products, 'customer' => $customer]);
  1600.     }
  1602.      #[Route('/contact', name: 'frontend.contact')]
  1603.     public function contactCustom(Request $request, SalesChannelContext $context, Context $sale): Response
  1604.     {
  1605.         $page = $this->genericLoader->load($request, $context);
  1607.         $products = $this->homepageService->loadProductsWithCreditOption($context);
  1608.         $customer = $this->homepageService->getCustomerCredit($context, $sale);
  1609.         return $this->renderStorefront('@Storefront/storefront/page/custom/contact/index.html.twig', ['page' => $page, 'products' => $products, 'customer' => $customer]);
  1610.     }
  1613.     //    #[Route('/account/recover', name: 'frontend.account.recover')]
  1614. //    public function accountRecover(Request $request, SalesChannelContext $context): Response
  1615. //    {
  1616. //        $page = $this->genericLoader->load($request, $context);
  1617. //
  1618. //        $this->hook(new NavigationPageLoadedHook($page, $context));
  1619. //        return $this->renderStorefront('@Storefront/storefront/page/account/profile/recover-password.html.twig');
  1620. //    }
  1622.     #[Route('/progress/credits/{creditId}', name: 'frontend.account.progress.credits.detail', methods: ['GET'], defaults: ["_loginRequired" => true])]
  1623.     public function creditDetail(string $creditId, Request $request, SalesChannelContext $context, CustomerEntity $customer): Response
  1624.     {
  1625.         $page = $this->overviewPageLoader->load($request, $context, $customer);
  1627. //        $this->hook(new AccountOverviewPageLoadedHook($page, $context));
  1629.         $order = $this->orderPageLoader->load($request, $context);
  1631. //        $this->hook(new AccountOrderPageLoadedHook($order, $context));
  1633.         $credit = $this->econsorAccountService->getCreditDetail($creditId, $context);
  1635.         return $this->renderStorefront('@Storefront/storefront/page/progress/credits/detail/index.html.twig', ['page' => $page, 'credit' => $credit]);
  1636.     }
  1638.     #[Route('/progress/redeemed-items/{itemId}', name: 'frontend.account.progress.redeemed-items.detail', methods: ['GET'], defaults: ["_loginRequired" => true])]
  1639.     public function redeemedItemDetail(string $itemId, Request $request, SalesChannelContext $context, CustomerEntity $customer): Response
  1640.     {
  1641.         $page = $this->overviewPageLoader->load($request, $context, $customer);
  1643. //        $this->hook(new AccountOverviewPageLoadedHook($page, $context));
  1645.         $order = $this->orderPageLoader->load($request, $context);
  1647. //        $this->hook(new AccountOrderPageLoadedHook($order, $context));
  1649.         $item = $this->econsorAccountService->getRedeemedItemDetail($itemId, $context);
  1651.         return $this->renderStorefront('@Storefront/storefront/page/progress/redeemded-items/detail/index.html.twig', ['page' => $page, 'item' => $item]);
  1652.     }
  1654. //     #[Route('/account/friend-invite', name: 'frontend.friend.invite', defaults: ["XmlHttpRequest" => true], methods: ['POST', 'GET'])]
  1655. //     public function reservationDeal(Request $request, SalesChannelContext $context): Response
  1656. //     {
  1657. //         if ($context->getCustomer() == null) {
  1658. //             $url = $this->router->generate('frontend.econsor.app.storefront.login');
  1659. //             return $this->redirect($url);
  1660. //         }
  1662. //         $violations = [];
  1663. //         $emails = $request->request->has('email') ? array_map('trim', array_filter($request->request->get('email'))) : [];
  1664. //         $schemeAndHost = $request->getSchemeAndHttpHost();
  1665. //         // Parse the scheme and host to get the hostname
  1666. //         $parsedUrl = parse_url($schemeAndHost);
  1667. //         $url = $parsedUrl['scheme'] . '://' . $parsedUrl['host'];
  1669. //         if ($request->isMethod('POST')) {
  1670. //             $validator = Validation::createValidator();
  1671. //             $constraintEmail = new Email([], 'The input {{ value }} is not an valid e-mail address.');
  1672. //             $constraintNotBlank = new NotBlank([], 'The e-mail field should not be blank.');
  1673. //             $constraintUnique = new Duplications();
  1674. //             $constraintNotEqualTo = new NotEqualTo($context->getCustomer()->getEmail(), null, "The e-mail should be of your friends.");
  1676. //             foreach ($emails as $id => $email) {
  1677. //                 if (!array_key_exists($id, $violations)) {
  1678. //                     $violations[$id] = [];
  1679. //                 }
  1681. //                 $violations[$id][] = $validator->validate($email, [$constraintEmail, $constraintNotBlank, $constraintUnique, $constraintNotEqualTo]);
  1682. //             }
  1684. //             $success = count($emails) > 0;
  1685. //             foreach ($violations as $violation) {
  1686. //                 if (count($violation[0]) > 0) {
  1687. //                     $success = false;
  1688. //                 }
  1689. //             }
  1691. //             if ($success && $this->discountCodeGenerator->canGenerate($context, DiscountCodeGenerator::SHARE_WITH_FRIENDS_CODE)) {
  1692. //                 $result = $this->discountCodeGenerator->generateCode($context, DiscountCodeGenerator::SHARE_WITH_FRIENDS_CODE, $emails, $url);
  1694. //                 if (array_key_exists('error', $result)) {
  1695. //                     //add flashes
  1696. //                     if (array_key_exists('flash', $result['error'])) {
  1697. // //                        $this->addFlash($result['error']['flash']['type'], $this->trans($result['error']['flash']['message']));
  1698. //                     }
  1700. //                     return $this->redirectToRoute('frontend.home.page');
  1701. //                 } else if (array_key_exists('success', $result)) {
  1702. //                     $customer = $context->getCustomer();
  1703. //                     $currentEmailsInvited = !empty($customer->getCustomFields()['emailsInvited']) ? (is_array($customer->getCustomFields()['emailsInvited']) ? $customer->getCustomFields()['emailsInvited'] : json_decode($customer->getCustomFields()['emailsInvited'])) : [];
  1704. //                     $currentEmailListInvited = !empty($customer->getCustomFields()['emailListInvited']) ? (is_array($customer->getCustomFields()['emailListInvited']) ? $customer->getCustomFields()['emailListInvited'] : json_decode($customer->getCustomFields()['emailListInvited'])) : [];
  1705. //                     $emailsListInvited = [];
  1706. //                     $emailsListInvite = [];
  1707. //                     foreach ($emails as $email) {
  1708. //                         if (!in_array($email, $currentEmailsInvited)) {
  1709. //                             $currentEmailListInvited[] = [
  1710. //                                 'email' => $email,
  1711. //                                 'inviteDate' => (new \DateTime())->getTimestamp(),
  1712. //                             ];
  1713. //                             $criteria = new Criteria();
  1714. //                             $criteria->addFilter(new EqualsFilter('email', $email));
  1716. //                             $this->inviteFriendHistory->create([
  1717. //                                 [
  1718. //                                     'email' => $email,
  1719. //                                     'customerId' => $context->getCustomerId(),
  1720. //                                 ]
  1721. //                             ], $context->getContext());
  1722. //                             $emailsListInvite[] = $email;
  1724. //                         } else {
  1725. //                             $emailsListInvited[] = $email;
  1726. //                         }
  1727. //                     }
  1728. //                     $uniqueEmails = array_unique(array_merge($currentEmailsInvited, $emailsListInvite));
  1729. //                     $this->customerEntity->update(
  1730. //                         [
  1731. //                             [
  1732. //                                 'id' => $context->getCustomerId(),
  1733. //                                 'customFields' => [
  1734. //                                     'emailsInvited' => $uniqueEmails,
  1735. //                                     'emailListInvited' => $currentEmailListInvited,
  1736. //                                 ],
  1737. //                             ]
  1738. //                         ],
  1739. //                         $context->getContext()
  1740. //                     );
  1741. //                     $wheelCriteria = new Criteria();
  1742. //                     $wheelCriteria->addFilter(new EqualsFilter('customerId', $context->getCustomerId()));
  1743. //                     $wheelCriteria->addFilter(new EqualsFilter('reason', '10 emails invited'));
  1744. //                     if (count($uniqueEmails) >= $this->luckyWheelTurnRepository->search($wheelCriteria, $context->getContext())->count() * 10) {
  1745. //                         $startOfWeek = (new \DateTime('monday this week'))->setTime(0, 0, 0);
  1746. //                         $endOfWeek = (new \DateTime('sunday this week'))->setTime(23, 59, 59);
  1747. //                         $result = $this->luckyWheelTurnRepository->search($wheelCriteria
  1748. //                             ->addFilter(new RangeFilter('createdAt', [
  1749. //                                 RangeFilter::GTE => $startOfWeek->format('Y-m-d H:i:s'),
  1750. //                                 RangeFilter::LTE => $endOfWeek->format('Y-m-d H:i:s')
  1751. //                             ])), $context->getContext());
  1752. //                         if ($result->count() == 0) {
  1753. //                             $this->luckyWheelTurnRepository->create([
  1754. //                                 [
  1755. //                                     'customerId' => $context->getCustomerId(),
  1756. //                                     'amountTotal' => 2,
  1757. //                                     'amountRemain' => 2,
  1758. //                                     'type' => 'awarded',
  1759. //                                     'reason' => '10 emails invited',
  1760. //                                 ]
  1761. //                             ], $context->getContext());
  1762. //                         }
  1763. //                     }
  1764. //                     //                    $records = $this->rewardService->getRewardRecordFromCustomer(
  1765. // //                        $context->getCustomer()->getId(),
  1766. // //                        "10 emails invited"
  1767. // //                    );
  1768. // //                    if ($records->count() === 0) {
  1769. // //                        $this->rewardService->createRewardPoint(
  1770. // //                            $context->getCustomer()->getId(),
  1771. // //                            null,
  1772. // //                            1000,
  1773. // //                            RewardPointType::AwardedPoint,
  1774. // //                            null,
  1775. // //                            null,
  1776. // //                            null,
  1777. // //                            "10 emails invited"
  1778. // //                        );
  1779. // //                    }
  1780. // //                    $this->addFlash('success', $this->trans('app.onboarding.inviteFriendsModal.emailSent'));
  1782. //                     return $this->renderStorefront('@Storefront/storefront/component/account/friend-invite.html.twig', [
  1783. //                         "page" => $this->registrationAppPageLoader->load($request, $context),
  1784. //                         'emailGenerated' => true,
  1785. //                         'emailsInvited' => $uniqueEmails,
  1786. //                         'emailsListInvited' => $emailsListInvited
  1787. //                     ]);
  1788. //                 }
  1789. //             }
  1790. //         }
  1792. //         return $this->renderStorefront('@Storefront/storefront/component/account/friend-invite.html.twig', [
  1793. //             'controllerName' => 'ReservationDealController',
  1794. //             'controllerAction' => 'reservationDeal',
  1795. //             'violations' => $violations,
  1796. //             'emails' => $emails,
  1797. //             "page" => $this->registrationAppPageLoader->load($request, $context)
  1798. //         ]);
  1799. //     }
  1801.     /**
  1802.      * @Route("/account/address/default-{type}/{addressId}", name="frontend.account.address.set-default-address", methods={"POST"}, defaults={"_loginRequired"=true})
  1803.      */
  1804.     public function switchDefaultAddress(Request $request, string $type, string $addressId, SalesChannelContext $context, CustomerEntity $customer): mixed
  1805.     {
  1806.         if (!Uuid::isValid($addressId)) {
  1807.             throw new InvalidUuidException($addressId);
  1808.         }
  1810.         $success = true;
  1812.         try {
  1813.             if ($type === self::ADDRESS_TYPE_SHIPPING) {
  1814.                 $this->accountService->setDefaultShippingAddress($addressId, $context, $customer);
  1815.             } elseif ($type === self::ADDRESS_TYPE_BILLING) {
  1816.                 $this->accountService->setDefaultBillingAddress($addressId, $context, $customer);
  1817.             } else {
  1818.                 $success = false;
  1819.             }
  1820.         } catch (AddressNotFoundException $exception) {
  1821.             $success = false;
  1822.         }
  1824.         if ($request->get('redirectTo') || $request->get('redirectTo') === '') {
  1825.             return $this->createActionResponse($request);
  1826.         }
  1828.         return new RedirectResponse(
  1829.             $this->generateUrl('frontend.account.address.page', ['changedDefaultAddress' => $success])
  1830.         );
  1831.     }
  1833.     /**
  1834.      * @Route("/widgets/account/address-book", name="frontend.account.addressbook", options={"seo"=true}, methods={"POST"}, defaults={"XmlHttpRequest"=true, "_loginRequired"=true, "_loginRequiredAllowGuest"=true})
  1835.      */
  1836.     public function addressBook(Request $request, RequestDataBag $dataBag, SalesChannelContext $context, CustomerEntity $customer): Response
  1837.     {
  1838.         $viewData = new AddressEditorModalStruct();
  1839.         $params = [];
  1841.         try {
  1842.             $this->handleChangeableAddresses($viewData, $dataBag, $context, $customer);
  1843.             $this->handleAddressCreation($viewData, $dataBag, $context, $customer);
  1844.             $this->handleAddressSelection($viewData, $dataBag, $context, $customer);
  1846.             $page = $this->addressListingPageLoader->load($request, $context, $customer);
  1848. //            $this->hook(new AddressBookWidgetLoadedHook($page, $context));
  1850.             $viewData->setPage($page);
  1851.             if (Feature::isActive('FEATURE_NEXT_15957')) {
  1852.                 $this->handleCustomerVatIds($dataBag, $context, $customer);
  1853.             }
  1854.         } catch (ConstraintViolationException $formViolations) {
  1855.             $params['formViolations'] = $formViolations;
  1856.             $params['postedData'] = $dataBag->get('address');
  1857.         } catch (\Exception $exception) {
  1858.             $viewData->setSuccess(false);
  1859.             $viewData->setMessages([
  1860.                 'type' => self::DANGER,
  1861.                 'text' => $this->trans('error.message-default'),
  1862.             ]);
  1863.         }
  1865.         if ($request->get('redirectTo') || $request->get('forwardTo')) {
  1866.             return $this->createActionResponse($request);
  1867.         }
  1868.         $params = array_merge($params, $viewData->getVars());
  1870.         $response = $this->renderStorefront(
  1871.             '@Storefront/storefront/component/address/address-editor-modal.html.twig',
  1872.             $params
  1873.         );
  1875.         $response->headers->set('x-robots-tag', 'noindex');
  1877.         return $response;
  1878.     }
  1880.     private function handleAddressCreation(
  1881.         AddressEditorModalStruct $viewData,
  1882.         RequestDataBag           $dataBag,
  1883.         SalesChannelContext      $context,
  1884.         CustomerEntity           $customer
  1885.     ): void
  1886.     {
  1887.         /** @var DataBag|null $addressData */
  1888.         $addressData = $dataBag->get('address');
  1890.         if ($addressData === null) {
  1891.             return;
  1892.         }
  1894.         $response = $this->updateAddressRoute->upsert(
  1895.             $addressData->get('id'),
  1896.             $addressData->toRequestDataBag(),
  1897.             $context,
  1898.             $customer
  1899.         );
  1901.         $addressId = $response->getAddress()->getId();
  1903.         $addressType = null;
  1905.         if ($viewData->isChangeBilling()) {
  1906.             $addressType = self::ADDRESS_TYPE_BILLING;
  1907.         } elseif ($viewData->isChangeShipping()) {
  1908.             $addressType = self::ADDRESS_TYPE_SHIPPING;
  1909.         }
  1911.         // prepare data to set newly created address as customers default
  1912.         if ($addressType) {
  1913.             $dataBag->set('selectAddress', new RequestDataBag([
  1914.                 'id' => $addressId,
  1915.                 'type' => $addressType,
  1916.                 'isChangeBilling' => $viewData->isChangeBilling(),
  1917.                 'isChangeShipping' => $viewData->isChangeShipping(),
  1918.             ]));
  1919.         }
  1921.         $viewData->setAddressId($addressId);
  1922.         $viewData->setSuccess(true);
  1923.         $viewData->setMessages(['type' => 'success', 'text' => $this->trans('account.addressSaved')]);
  1924.     }
  1926.     private function handleChangeableAddresses(
  1927.         AddressEditorModalStruct $viewData,
  1928.         RequestDataBag           $dataBag,
  1929.         SalesChannelContext      $context,
  1930.         CustomerEntity           $customer
  1931.     ): void
  1932.     {
  1933.         $changeableAddresses = $dataBag->get('changeableAddresses');
  1935.         if ($changeableAddresses === null) {
  1936.             return;
  1937.         }
  1939.         $viewData->setChangeShipping((bool)$changeableAddresses->get('changeShipping'));
  1940.         $viewData->setChangeBilling((bool)$changeableAddresses->get('changeBilling'));
  1942.         $addressId = $dataBag->get('id');
  1944.         if (!$addressId) {
  1945.             return;
  1946.         }
  1948.         $viewData->setAddress($this->getById($addressId, $context, $customer));
  1949.     }
  1951.     /**
  1952.      * @throws CustomerNotLoggedInException
  1953.      * @throws InvalidUuidException
  1954.      */
  1955.     private function handleAddressSelection(
  1956.         AddressEditorModalStruct $viewData,
  1957.         RequestDataBag           $dataBag,
  1958.         SalesChannelContext      $context,
  1959.         CustomerEntity           $customer
  1960.     ): void
  1961.     {
  1962.         $selectedAddress = $dataBag->get('selectAddress');
  1964.         if ($selectedAddress === null) {
  1965.             return;
  1966.         }
  1968.         $isChangeBilling = $selectedAddress->get('isChangeBilling');
  1969.         $isChangeShipping = $selectedAddress->get('isChangeShipping');
  1970.         $addressType = $selectedAddress->get('type');
  1971.         $addressId = $selectedAddress->get('id');
  1973.         if (!Uuid::isValid($addressId)) {
  1974.             throw new InvalidUuidException($addressId);
  1975.         }
  1977.         $success = true;
  1979.         try {
  1980.             if ($isChangeShipping) {
  1981.                 $address = $this->getById($addressId, $context, $customer);
  1982.                 $customer->setDefaultShippingAddress($address);
  1983.                 $this->accountService->setDefaultShippingAddress($addressId, $context, $customer);
  1984.             }
  1985.             if ($isChangeBilling) {
  1986.                 $address = $this->getById($addressId, $context, $customer);
  1987.                 $customer->setDefaultBillingAddress($address);
  1988.                 $this->accountService->setDefaultBillingAddress($addressId, $context, $customer);
  1989.             }
  1990.             if (!$isChangeBilling && !$isChangeShipping) {
  1991.                 $success = false;
  1992.             }
  1993.         } catch (AddressNotFoundException $exception) {
  1994.             $success = false;
  1995.         }
  1997. //        if ($success) {
  1998. //            $this->addFlash(self::SUCCESS, $this->trans('account.addressDefaultChanged'));
  1999. //        } else {
  2000. //            $this->addFlash(self::DANGER, $this->trans('account.addressDefaultNotChanged'));
  2001. //        }
  2003.         $viewData->setSuccess($success);
  2004.     }
  2007.     private function getById(string $addressId, SalesChannelContext $context, CustomerEntity $customer): CustomerAddressEntity
  2008.     {
  2009.         if (!Uuid::isValid($addressId)) {
  2010.             throw new InvalidUuidException($addressId);
  2011.         }
  2013.         $criteria = new Criteria();
  2014.         $criteria->addFilter(new EqualsFilter('id', $addressId));
  2015.         $criteria->addFilter(new EqualsFilter('customerId', $customer->getId()));
  2017.         $address = $this->listAddressRoute->load($criteria, $context, $customer)->getAddressCollection()->get($addressId);
  2019.         if (!$address) {
  2020.             throw new AddressNotFoundException($addressId);
  2021.         }
  2023.         return $address;
  2024.     }
  2026.     private function handleCustomerVatIds(RequestDataBag $dataBag, SalesChannelContext $context, CustomerEntity $customer): void
  2027.     {
  2028.         if (!$dataBag->has('vatIds')) {
  2029.             return;
  2030.         }
  2032.         $newVatIds = $dataBag->get('vatIds')->all();
  2033.         $oldVatIds = $customer->getVatIds() ?? [];
  2034.         if (!array_diff($newVatIds, $oldVatIds) && !array_diff($oldVatIds, $newVatIds)) {
  2035.             return;
  2036.         }
  2038.         $dataCustomer = CustomerTransformer::transform($customer);
  2039.         $dataCustomer['vatIds'] = $newVatIds;
  2040.         $dataCustomer['accountType'] = $customer->getCompany() === null ? CustomerEntity::ACCOUNT_TYPE_PRIVATE : CustomerEntity::ACCOUNT_TYPE_BUSINESS;
  2042.         $newDataBag = new RequestDataBag($dataCustomer);
  2044.         $this->updateCustomerProfileRoute->change($newDataBag, $context, $customer);
  2045.     }
  2047.     /**
  2048.      * @Route("/account/accept-cookie", name="frontend.account.accept-cookie", methods={"POST"}, defaults={"XmlHttpRequest"=true})
  2049.      */
  2050.     public function saveAcceptCookie(Request $request, SalesChannelContext $context): mixed
  2051.     {
  2052.         $isAcceptCookie = $request->get('acceptCookie', false);
  2053.         $ip = $request->getClientIp();
  2054.         $devices = $request->headers->get('user-agent');
  2055.         $acceptCookieId = $request->get('acceptCookieId', 0);
  2057.         if ($customer = $context->getCustomer()) {
  2058.             $criteria = new Criteria();
  2059.             $criteria->addFilter(new EqualsFilter('customerId', $customer->getId()));
  2060.         } else {
  2061.             $criteria = new Criteria();
  2062.             $criteria->addFilter(new EqualsFilter('acceptCookieId', $acceptCookieId));
  2063.             $criteria->addFilter(new NotFilter(NotFilter::CONNECTION_AND, [
  2064.                 new EqualsFilter('acceptCookieId', 0)
  2065.             ]));
  2066.         }
  2068.         $customerAcceptCookie = $this->customerAcceptCookieRepository->search($criteria, $context->getContext())->first();
  2069.         if (!$customerAcceptCookie) {
  2070.             $dataCreate = [
  2071.                 'id' => Uuid::randomHex(),
  2072.                 'customerId' => null,
  2073.                 'acceptCookie' => $isAcceptCookie,
  2074.                 'acceptCookieIp' => $ip,
  2075.                 'acceptCookieId' => $acceptCookieId,
  2076.                 'acceptCookieDevice' => $devices,
  2077.                 'created_at' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  2078.             ];
  2080.             if ($customer) {
  2081.                 $dataCreate['customerId'] = $customer->getId();
  2082.                 $this->customerEntity->update([
  2083.                     [
  2084.                         'id' => $customer->getId(),
  2085.                         'customFields' => [
  2086.                             'customerAcceptCookie' => $isAcceptCookie
  2087.                         ],
  2088.                     ]
  2089.                 ], $context->getContext());
  2090.             }
  2092.             $this->customerAcceptCookieRepository->create([
  2093.                 $dataCreate
  2094.             ], $context->getContext());
  2096.             return new JsonResponse([
  2097.                 'success' => true,
  2098.                 'message' => 'Accept Cookie Saved Successfully!'
  2099.             ], 200);
  2100.         }
  2101.         return new JsonResponse([
  2102.             'success' => true,
  2103.             'message' => 'Cookies already accepted!'
  2104.         ], 200);
  2105.     }
  2107.     #[Route('/video-star-ranking', name: 'frontend.daily.ranking', methods: ['GET'])]
  2108.     public function dailyRanking(Request $request, SalesChannelContext $context): Response
  2109.     {
  2110.         $page = $this->genericLoader->load($request, $context);
  2111.         $topThreeCustomer = $this->rankingService->getTopThreeCustomerByLike($request, $context);
  2112.         $topVideoOfCurrentUser = $this->rankingService->getTopVideoOfCurrentUser($request, $context);
  2113.         return $this->renderStorefront('@Storefront/storefront/page/custom/daily-ranking/index.html.twig', ['page' => $page, 'topThreeCustomer' => $topThreeCustomer, 'topVideoOfCurrentUser' => $topVideoOfCurrentUser]);
  2114.     }
  2116.     #[Route('/sharing-center', name: 'frontend.sharing.center', methods: ['GET'])]
  2117.     public function sharingCenter(Request $request, SalesChannelContext $context): Response
  2118.     {
  2119.         $page = $this->genericLoader->load($request, $context);
  2120.         $customer = $context->getCustomer();
  2121.         $dataStream = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "uploaded");
  2122.         return $this->renderStorefront('@Storefront/storefront/page/custom/sharing-center/index.html.twig', ['page' => $page, 'customer' => $customer, 'dataStream' => $dataStream, 'dashboardData' => $this->customerDataService->getBoughtProducts($context)]);
  2123.     }
  2125.     #[Route('/short-link', name: 'frontend.short.link', defaults: ['XmlHttpRequest' => true], methods: ['POST'])]
  2126.     public function renderShortLink(Request $request, SalesChannelContext $context)
  2127.     {
  2128.         $url = $this->aiStreamService->createShortLink($request, $context);
  2130.         return new JsonResponse(['data' => $url]);
  2131.     }
  2133.     #[Route('/checkout/subscription/{id?}', name: 'frontend.checkout.subscription', defaults: ['XmlHttpRequest' => true, '_loginRequired' => true,], methods: ['GET'])]
  2134.     public function subscriptionPage(Request $request, SalesChannelContext $context, RequestDataBag $dataBag, string $id = null): Response
  2135.     {
  2136.         $id = $id ?? $request->query->get('productId');
  2138.         if ($id === null) {
  2139.             return $this->redirectToRoute('frontend.home.page');
  2140.         }
  2142.         $criteria = new Criteria();
  2143.         $criteria->addFilter(
  2144.             new EqualsFilter('customerId', $context->getCustomer()->getId()),
  2145.             new EqualsFilter('productId', $id),
  2146.             new EqualsFilter('status', 'active')
  2147.         );
  2148.         $subscription = $this->subscriptionRepository->search($criteria, $context->getContext())->first();
  2150.         if ($subscription) {
  2151.             return $this->redirectToRoute('frontend.account.order-subscription', ['status' => 'error-create-order']);
  2152.         }
  2154.         $context->getCustomer()->setAddresses($this->customerAddressRepository->search((new Criteria())->addFilter(new EqualsFilter('customerId', $context->getCustomerId())), $context->getContext())->getEntities());
  2156.         $criteria = new Criteria([$id]);
  2157.         $criteria->addAssociation('cover');
  2158.         $criteria->addAssociation('visibilities');
  2159.         $product = $this->salesChannelProductRepository->search($criteria, $context)->first();
  2160.         if (!$product || !$product->getCustomFields()['isBuyProductSubscription'] || empty($product->getCustomFields()['planId'])) {
  2161.             throw new \RuntimeException('Product not found for the current Sales Channel!');
  2162.         }
  2164.         $productId = $product->getId();
  2165.         $token = NuveiSubscriptionPaymentHandler::SUBSCRIPTION_CART_NAME . "-" . $context->getToken();
  2166.         $cart = $this->cartService->getCart($token, $context, NuveiSubscriptionPaymentHandler::SUBSCRIPTION_CART_NAME);
  2167.         if (!empty($cart->getLineItems())) {
  2168.             foreach ($cart->getLineItems() as $item) {
  2169.                 $item->setRemovable(true);
  2170.                 $this->cartService->remove($cart, $item->getId(), $context);
  2171.             }
  2172.         }
  2174.         $lineItem = new LineItem(
  2175.             $productId,
  2176.             LineItem::PRODUCT_LINE_ITEM_TYPE,
  2177.             $productId,
  2178.         );
  2179.         $lineItem->setLabel($product->getName());
  2180.         $lineItem->setPayloadValue('productId', $product->getId());
  2181.         $lineItem->setPayloadValue('planId', $product->getCustomFields()['planId']);
  2182.         $lineItem->setRemovable(true);
  2183.         $this->cartService->add($cart, [$lineItem], $context);
  2184.         // $cart = $this->cartService->createNew(NuveiSubscriptionPaymentHandler::SUBSCRIPTION_CART_NAME . "-" . $context->getToken(), NuveiSubscriptionPaymentHandler::SUBSCRIPTION_CART_NAME . "-" . $context->getToken());
  2185.         // $cart = $this->cartService->add($cart, [$lineItem], $context);
  2186.         $cart = $this->cartService->recalculate($cart, $context);
  2187.         $page = $this->overviewPageLoader->load($request, $context, $context->getCustomer());
  2188.         return $this->renderStorefront('@Storefront/storefront/page/custom/subscription-checkout/index.html.twig', [
  2189.             'product' => $product,
  2190.             'cart' => $cart,
  2191.             'page' => $page,
  2192.         ]);
  2193.     }
  2195.     #[Route('/order/subscription', name: 'frontend.order.subscription', defaults: ['XmlHttpRequest' => true, '_loginRequired' => true,], methods: ['POST'])]
  2196.     public function createOrderSubscription(RequestDataBag $request, SalesChannelContext $context)
  2197.     {
  2198.         $isConfirm = (bool)$request->get('isConfirm');
  2199.         if (!$isConfirm) {
  2200.             return $this->redirectToRoute('frontend.account.order-subscription', ['status' => 'error']);
  2201.         }
  2202.         $token = NuveiSubscriptionPaymentHandler::SUBSCRIPTION_CART_NAME . "-" . $context->getToken();
  2203.         $paymentMethod = $this->getSubscriptionPaymentMethod($context->getContext());
  2204.         $context->assign([
  2205.             'paymentMethod' => $paymentMethod,
  2206.         ]);
  2207.         $cart = $this->cartService->getCart($token, $context, NuveiSubscriptionPaymentHandler::SUBSCRIPTION_CART_NAME);
  2209.         $lineItem = $cart->getLineItems()->first();
  2210.         $shippingAddressId = $context->getCustomer()->getDefaultShippingAddressId();
  2211.         $request->set('paymentMethodId', $paymentMethod->getId());
  2212.         $request->set('shippingAddressId', $shippingAddressId);
  2214.         $request->set('planId', $lineItem->getPayload()['planId']);
  2216.         $orderId = $this->cartService->order($cart, $context, $request);
  2218.         $criteria = new Criteria();
  2219.         $criteria->addFilter(new EqualsFilter('id', $orderId));
  2220.         $criteria->addAssociation('transactions');
  2221.         $criteria->addAssociation('lineItems');
  2222.         $criteria->addAssociation('deliveries.shippingOrderAddress');
  2223.         $criteria->addAssociation('addresses');
  2225.         $order = $this->orderRepository->search($criteria, $context->getContext())->first();
  2227.         // Update order customFields to mark it as a subscription order
  2228.         $customFields = $order->getCustomFields() ?? [];
  2229.         $customFields['isOrderSubscription'] = true;
  2231.         $this->orderRepository->update([
  2232.             [
  2233.                 'id' => $orderId,
  2234.                 'customFields' => $customFields
  2235.             ]
  2236.         ], $context->getContext());
  2238.         // Get the first line item as the subscription product
  2239.         $lineItem = $order->getLineItems()->first();
  2240.         if (!$lineItem) {
  2241.             throw new \Exception('No line items found in order');
  2242.         }
  2244.         $productId = $lineItem->getProductId();
  2245.         $customerId = $context->getCustomerId();
  2247.         if (!$customerId) {
  2248.             throw new \Exception('Customer not logged in');
  2249.         }
  2250.         $criteria = (new Criteria())
  2251.             ->addFilter(new EqualsFilter('customerId', $context->getCustomerId()))
  2252.             ->addSorting(new FieldSorting('createdAt', FieldSorting::DESCENDING));
  2254.         $addressId = $this->customerAddressRepository
  2255.             ->search($criteria, $context->getContext())
  2256.             ->first()->getId();
  2257.         // Get the Nuvei token from the TransactionSubscription
  2258.         if (!$token) {
  2259.             throw new \Exception('No payment token found in subscription transaction');
  2260.         }
  2261.         // Calculate next payment date (30 days from now)
  2262.         $nextPaymentDate = (new \DateTime())->modify('+1 month');
  2263.         $now = new \DateTime();
  2265.         $subscriptionActive = $this->findSubscription($customerId, $productId, 'active', $context->getContext());
  2266.         if ($subscriptionActive) {
  2267.             return $this->redirectToRoute('frontend.account.order-subscription', [
  2268.                 'status' => 'error-create-order'
  2269.             ]);
  2270.         }
  2272.         $subscriptionPending = $this->findSubscription($customerId, $productId, 'pending', $context->getContext());
  2273.         if ($subscriptionPending) {
  2274.             $this->subscriptionRepository->update([[
  2275.                 'id' => $subscriptionPending->getId(),
  2276.                 'status' => 'cancelled'
  2277.             ]], $context->getContext());
  2278.         }
  2280.         $id = Uuid::randomHex();
  2281.         $this->subscriptionRepository->create([[
  2282.             'id' => $id,
  2283.             'customerId' => $customerId,
  2284.             'productId' => $productId,
  2285.             'addressId' => $addressId,
  2286.             'nextPaymentDate' => $nextPaymentDate,
  2287.             'status' => 'pending',
  2288.             'createdAt' => (new \DateTime())->format('Y-m-d H:i:s')
  2289.         ]], $context->getContext());
  2291.         // Create subscription order
  2292.         $this->subscriptionOrderRepository->create([
  2293.             [
  2294.                 'subscriptionId' => $id,
  2295.                 'orderId' => $orderId,
  2296.                 'createdAt' => $now->format('Y-m-d H:i:s')
  2297.             ]
  2298.         ], $context->getContext());
  2300.         // Use the standard Shopware payment process
  2301.         // The finishUrl will be used after the payment is completed and the finalize method is called
  2302.         // $finishUrl = $this->generateUrl('frontend.checkout.finish.page', ['orderId' => $orderId]);
  2303.         $finishUrl = $this->generateUrl('frontend.account.order-subscription.finish', ['id' => $orderId]);
  2304.         $errorUrl = $this->generateUrl('frontend.account.order-subscription');
  2306.         try {
  2307.             $this->logger->info('Starting payment process for subscription order', [
  2308.                 'orderId' => $orderId,
  2309.                 'customerId' => $context->getCustomerId()
  2310.             ]);
  2312.             // This will generate a payment token and redirect to the payment gateway
  2313.             // The payment gateway will redirect back to /payment/finalize-transaction with the token
  2314.             // which will call the finalize method in NuveiSubscriptionPaymentHandler
  2315.             $response = $this->paymentService->handlePaymentByOrder($orderId, $request, $context, $finishUrl, $errorUrl);
  2317.             if ($response) {
  2318.                 $this->logger->info('Redirecting to payment gateway', [
  2319.                     'orderId' => $orderId,
  2320.                     'redirectUrl' => $response->getTargetUrl()
  2321.                 ]);
  2323.                 return $response;
  2324.             }
  2325.         } catch (\Exception $e) {
  2326.             $this->logger->error('Error processing subscription payment', [
  2327.                 'orderId' => $orderId,
  2328.                 'error' => $e->getMessage(),
  2329.                 'trace' => $e->getTraceAsString()
  2330.             ]);
  2331.             return $this->redirectToRoute('frontend.account.order-subscription', ['status' => 'error']);
  2332.         }
  2334.         return $this->redirectToRoute('frontend.account.order-subscription', ['status' => 'success']);
  2335.     }
  2337.     private function findSubscription(string $customerId, string $productId, string $status, Context $context)
  2338.     {
  2339.         $criteria = new Criteria();
  2340.         $criteria->addFilter(
  2341.             new EqualsFilter('customerId', $customerId),
  2342.             new EqualsFilter('productId', $productId),
  2343.             new EqualsFilter('status', $status)
  2344.         );
  2346.         return $this->subscriptionRepository->search($criteria, $context)->first();
  2347.     }
  2349.     protected function getSubscriptionPaymentMethod(Context $context): PaymentMethodEntity|null
  2350.     {
  2351.         $criteria = new Criteria();
  2352.         $criteria->addFilter(new EqualsFilter('handlerIdentifier', NuveiSubscriptionPaymentHandler::class));
  2354.         return $this->paymentMethodRepository->search($criteria, $context)->getEntities()->first();
  2355.     }
  2357.     #[Route('/account/order-subscription', name: 'frontend.account.order-subscription', defaults: ['_loginRequired' => true], methods: ['GET'])]
  2358.     public function accountMyOrderSubscription(Request $request, SalesChannelContext $context): Response
  2359.     {
  2360.         $errorCode = $request->query->get('error-code');
  2361.         if ($errorCode !== null) {
  2362.             return $this->redirectToRoute('frontend.account.order-subscription');
  2363.         }
  2364.         $page = $this->navigationPageLoader->load($request, $context);
  2365.         $response = $this->nuveiSubscriptionController->searchSubscriptionsByCustomer($request, $context);
  2366.         $data = json_decode($response->getContent(), true);
  2367.         return $this->renderStorefront('@Storefront/storefront/page/custom/account/order-subscription/index.html.twig', [
  2368.             'page' => $page,
  2369.             'subscriptions' => $data['subscriptions']
  2370.         ]);
  2371.     }
  2373.     #[Route('/account/order-subscription/{id}', name: 'frontend.account.order-subscription.detail', defaults: ['_loginRequired' => true], methods: ['GET'])]
  2374.     public function accountMyOrderSubscriptionDetail(String $id, Request $request, SalesChannelContext $context): Response
  2375.     {
  2376.         $page = $this->navigationPageLoader->load($request, $context);
  2377.         $response = $this->nuveiSubscriptionController->searchOrdersByCustomerSubscription($id, $context);
  2378.         if ($response['error'] != 0 ){
  2379.             $subscriptionOrders = [];
  2380.         } else {
  2381.             $subscriptionOrders = $response['subscriptionOrders'];
  2382.         }
  2383.         return $this->renderStorefront('@Storefront/storefront/page/custom/account/subscription-detail/index.html.twig', [
  2384.             'page' => $page,
  2385.             'subscriptionOrders' => $subscriptionOrders
  2386.         ]);
  2387.     }
  2389.     #[Route('/account/order-subscription/finish/{id}', name: 'frontend.account.order-subscription.finish', defaults: ['_loginRequired' => true], methods: ['GET'])]
  2390.     public function accountMyOrderSubscriptionFinish(String $id, Request $request, SalesChannelContext $context): Response
  2391.     {
  2392.         if ($id === null) {
  2393.             return $this->redirectToRoute('frontend.home.page');
  2394.         }
  2395.         $criteria = new Criteria();
  2396.         $criteria->addFilter(new EqualsFilter('id', $id));
  2397.         $criteria->addAssociation('transactions.paymentMethod');
  2398.         $criteria->addAssociation('lineItems.cover');
  2399.         $criteria->addAssociation('deliveries.shippingOrderAddress');
  2400.         $criteria->addAssociation('deliveries.stateId');
  2401.         $criteria->addAssociation('addresses');
  2403.         $order = $this->orderRepository->search($criteria, $context->getContext())->first();
  2405.         $productId = $order->getLineItems()->first()->getproductId();
  2406.         $customerId = $context->getCustomer()?->getId();
  2408.         // Check if the customer has an active subscription for this product
  2409.         $hasActiveSubscription = $this->subscriptionService->hasActiveSubscription(
  2410.             $customerId,
  2411.             $productId,
  2412.             $context
  2413.         );
  2415.         $page = $this->navigationPageLoader->load($request, $context);
  2416.         return $this->renderStorefront('@Storefront/storefront/page/custom/account/subscription-finish/index.html.twig', [
  2417.             'page' => $page,
  2418.             'order' => $order,
  2419.             'hasActiveSubscription' => $hasActiveSubscription
  2420.         ]);
  2421.     }
  2423.     #[Route('/search/orders-by-customer-subscription', name: 'frontend.search.orders_by_customer_subscription', options: ["seo" => false], defaults: ['_loginRequired' => true, 'XmlHttpRequest' => true], methods: ['POST'])]
  2424.     public function accountMyProductSubscription(Request $request, SalesChannelContext $context): Response
  2425.     {
  2426.         $status = $request->request->get('status');
  2427.         $isMobile = $request->request->get('isMobile');
  2428.         $isProduct = $request->request->get('isProduct');
  2429.         // $page = $this->navigationPageLoader->load($request, $context);
  2430.         $response = $this->nuveiSubscriptionController->searchSubscriptionsByCustomer($request, $context);
  2431.         $data = json_decode($response->getContent(), true);
  2432.        return $this->renderStorefront('@Storefront/storefront/page/custom/account/order-subscription/list-product.html.twig', [
  2433.            'subscriptions' => $data['subscriptions'],
  2434.             'isProduct' => $isProduct,
  2435.             'isMobile' => $isMobile,
  2436.             'status' => $status
  2437.         ]);
  2438.     }
  2440.     #[Route('/mobile/order/finish', name: 'frontend.mobile.order.finish', methods: ['GET'])]
  2441.     public function mobileOrderFinish(Request $request, SalesChannelContext $context): Response
  2442.     {
  2443.         $page = $this->navigationPageLoader->load($request, $context);
  2444.         $customer = $context->getCustomer();
  2445.         $this->hook(new NavigationPageLoadedHook($page, $context));
  2446.         return $this->renderStorefront('@Storefront/storefront/page/checkout/finish/mobile/index.html.twig', ['page' => $page, 'customer' => $customer, 'dashboardData' => $this->customerDataService->getBoughtProducts($context)]);
  2447.     }
  2449.     #[Route('/join-app', name: 'frontend.join.app', methods: ['GET'])]
  2450.     public function joinApp(Request $request, SalesChannelContext $context): Response
  2451.     {
  2452.         $page = $this->genericLoader->load($request, $context);
  2453.         return $this->renderStorefront('@Storefront/storefront/page/custom/account/join-app/index.html.twig', ['page' => $page]);
  2454.     }
  2456.     #[Route('/save4more-home', name: 'frontend.save4more.home', methods: ['GET'])]
  2457.     public function save4more(Request $request, SalesChannelContext $context)
  2458.     {
  2459.         $productCriteria = new Criteria();
  2460.         $productCriteria->addFilter(new EqualsFilter('customFields.isBuyProductSubscription', true));
  2461.         $productResult = $this->salesChannelProductRepository->search($productCriteria, $context)->first();
  2462.         $productId = $productResult ? $productResult->getId() : null;
  2464.         $page = $this->navigationPageLoader->load($request, $context);
  2465.         $pageNumber = 1;
  2466.         $this->hook(new NavigationPageLoadedHook($page, $context));
  2467.         $dataStream = $this->postService->fetchStream($context->getCustomer()?->getId(), $context, "details", $productId, null, $pageNumber);
  2468.         return $this->renderStorefront('@Storefront/storefront/page/custom/save-4-more/index.html.twig', ['page' => $page, 'dataStream' => $dataStream, 'productResult' => $productResult]);
  2469.     }
  2471.     #[Route('/save4more-terms-condition', name: 'frontend.save4more.terms', methods: ['GET'])]
  2472.     public function save4moreTerms(Request $request, SalesChannelContext $context)
  2473.     {
  2474.         $page = $this->navigationPageLoader->load($request, $context);
  2475.         $this->hook(new NavigationPageLoadedHook($page, $context));
  2476.         return $this->renderStorefront('@Storefront/storefront/page/custom/save-4-more/terms/index.html.twig', ['page' => $page]);
  2477.     }
  2479.     // Storefront API: Download invoice PDF for an order. If missing, create it first.
  2480.     // Only accessible by the owning customer; requires login (guest allowed).
  2481.     #[Route(
  2482.         path: '/account/order/{orderId}/invoice',
  2483.         name: 'frontend.account.order.invoice.download',
  2484.         methods: ['POST'],
  2485.         defaults: ['_routeScope' => ['storefront'], '_loginRequired' => true, '_loginRequiredAllowGuest' => true, "XmlHttpRequest" => true]
  2486.     )]
  2487.     public function downloadInvoice(Request $request, string $orderId, SalesChannelContext $salesChannelContext): Response
  2488.     {
  2489.         $customer = $salesChannelContext->getCustomer();
  2490.         if ($customer === null) {
  2491.             return new Response('Not Login!', Response::HTTP_UNAUTHORIZED);
  2492.         }
  2493.         $context = $salesChannelContext->getContext();
  2495.         // Try to find latest invoice document for this order
  2496.         $docCriteria = new Criteria();
  2497.         $docCriteria->addFilter(new EqualsFilter('orderId', $orderId));
  2498.         $docCriteria->addFilter(new EqualsFilter('documentType.technicalName', 'invoice'));
  2499.         $docCriteria->addAssociation('documentType');
  2500.         $docCriteria->setLimit(1);
  2501.         // Sort by createdAt DESC (newest first)
  2502.         $docCriteria->addSorting(new \Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting('createdAt', \Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting::DESCENDING));
  2504.         $existing = $this->documentRepository->search($docCriteria, $context)->first();
  2506.         if ($existing) {
  2507.             $documentId = $existing->getId();
  2508.             $deepLinkCode = $existing->getDeepLinkCode();
  2509.         } else {
  2510.             // Create a new invoice document
  2511.             // Avoid duplicated media filename by providing a unique filename
  2512.             $uniqueSuffix = (new \DateTimeImmutable())->format('Ymd_His');
  2513.             $fileName = sprintf('invoice_%s_%s.pdf', $orderId, $uniqueSuffix);
  2515.             $operation = new DocumentGenerateOperation(
  2516.                 $orderId,
  2517.                 FileTypes::PDF,
  2518.                 [
  2519.                     'fileName' => $fileName,
  2520.                 ],
  2521.                 null,
  2522.                 false
  2523.             );
  2525.             $result = $this->documentGenerator->generate('invoice', [$orderId => $operation], $context);
  2526.             $success = $result->getSuccess();
  2528.             if ($success->count() === 0) {
  2529.                 return new Response('Cannot generate invoice', Response::HTTP_INTERNAL_SERVER_ERROR);
  2530.             }
  2532.             /** @var \Shopware\Core\Checkout\Document\DocumentIdStruct $document */
  2533.             $document = $success->first();
  2535.             $deepLinkCode = $document->getDeepLinkCode();
  2536.             $documentId   = $document->getId();
  2537.         }
  2539.         // Build URL to built-in storefront document download route to stream the PDF
  2540.         $url = $this->generateUrl('frontend.account.order.single.document', [
  2541.             'documentId' => $documentId,
  2542.             'deepLinkCode' => $deepLinkCode,
  2543.             'download' => 1,
  2544.         ]);
  2546.         // Return JSON response as requested
  2547.         return new JsonResponse([
  2548.             'url' => $url,
  2549.             'success' => true,
  2550.         ], Response::HTTP_OK);
  2551.     }
  2552. }