custom/plugins/NimbitsPriceOnRequestNext/src/Controller/PriceRequestController.php line 90

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Nimbits\NimbitsPriceOnRequestNext\Controller;
  5. use Nimbits\NimbitsPriceOnRequestNext\Events\MailBeforeSendEvent;
  6. use Nimbits\NimbitsPriceOnRequestNext\Setting\Service\SettingService;
  7. use Shopware\Core\Checkout\Cart\Price\Struct\CartPrice;
  8. use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
  9. use Shopware\Core\Content\Mail\Service\AbstractMailService;
  10. use Shopware\Core\Content\Mail\Service\MailService;
  11. use Shopware\Core\Content\MailTemplate\MailTemplateEntity;
  12. use Shopware\Core\Framework\Adapter\Translation\Translator;
  13. use Shopware\Core\Framework\Context;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityCollection;
  15. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  18. use Shopware\Core\Framework\Event\BusinessEventDispatcher;
  19. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  20. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  21. use Shopware\Storefront\Controller\StorefrontController;
  22. use Shopware\Storefront\Framework\Captcha\Annotation\Captcha;
  23. use Symfony\Component\HttpFoundation\RedirectResponse;
  24. use Symfony\Component\HttpFoundation\Request;
  25. use Symfony\Component\HttpFoundation\Response;
  26. use Symfony\Component\Routing\Annotation\Route;
  28. /**
  29.  * @RouteScope(scopes={"storefront"})
  30.  */
  31. class PriceRequestController extends StorefrontController
  32. {
  33.     private $recaptchaverifyurl = "https://www.google.com/recaptcha/api/siteverify";
  34.     /**
  35.      * @var SettingService
  36.      */
  37.     private SettingService $settingService;
  39.     /**
  40.      * @var CartService
  41.      */
  42.     private CartService $cartService;
  44.     /**
  45.      * @var MailService
  46.      */
  47.     private $mailService;
  49.     /**
  50.      * @var \Twig\Environment $twig
  51.      */
  52.     private $twig;
  54.     /**
  55.      * @var BusinessEventDispatcher
  56.      */
  57.     private BusinessEventDispatcher $businesseventdispatcher;
  59.     private Translator $translation;
  61.     /**
  62.      * @var EntityRepositoryInterface
  63.      */
  64.     private EntityRepositoryInterface $mailTemplateRepository;
  66.     public function __construct(
  67.         SettingService            $settingService,
  68.         CartService               $cartService,
  69.         AbstractMailService       $mailService,
  70.         \Twig\Environment         $twig,
  71.         BusinessEventDispatcher   $businesseventdispatcher,
  72.         Translator                $translation,
  73.         EntityRepositoryInterface $mailTemplateRepository
  74.     )
  75.     {
  76.         $this->settingService = $settingService;
  77.         $this->cartService = $cartService;
  78.         $this->mailService = $mailService;
  79.         $this->twig = $twig;
  80.         $this->businesseventdispatcher = $businesseventdispatcher;
  81.         $this->translation = $translation;
  82.         $this->mailTemplateRepository = $mailTemplateRepository;
  83.     }
  85.     /**
  86.      * @Route("/nimbits/pricerequest/finish", name="frontend.action.nimbits.price-request-finish", options={"seo"="false"}, methods={"GET"})
  87.      */
  88.     public function priceRequestFinished(Request $request, SalesChannelContext $context): Response
  89.     {
  90.         return $this->renderStorefront('@NimbitsPriceOnRequestNext/storefront/page/pricerequest/finish.html.twig', []);
  91.     }
  93.     /**
  94.      * @Route("/nimbits/pricerequest/fail", name="frontend.action.nimbits.price-request-fail", options={"seo"="false"}, methods={"GET"})
  95.      */
  96.     public function priceRequestFailed(Request $request, SalesChannelContext $context): Response
  97.     {
  98.         return $this->renderStorefront('@NimbitsPriceOnRequestNext/storefront/page/pricerequest/fail.html.twig', []);
  99.     }
  101.     private function getMailTemplate(SalesChannelContext $salesChannelContext, string $technicalName)
  102.     {
  103.         $criteria = new Criteria();
  104.         $criteria->addFilter(new EqualsFilter('mailTemplateType.technicalName', $technicalName));
  105.         $criteria->setLimit(1);
  107.         /** @var MailTemplateEntity|null $mailTemplate */
  108.         $mailTemplate = $this->mailTemplateRepository->search($criteria, $salesChannelContext->getContext())->first();
  111.         return $mailTemplate;
  112.     }
  115.     private function getProductIdByNumber($productNumber)//return id or null
  116.     {
  117.         /** @var EntityRepositoryInterface $productRepository */
  118.         $productRepository = $this->container->get('product.repository');
  119.         $product = $productRepository->search(
  120.             (
  121.             new Criteria()
  122.             )->addFilter(new EqualsFilter('productNumber', $productNumber)),
  123.             \Shopware\Core\Framework\Context::createDefaultContext()
  124.         )->first();
  126.         if ($product == NULL)
  127.             return NULL;
  129.         return $product->getId();
  130.     }
  132.     private function insertRequest(array $requestData)
  133.     {
  134.         /** @var EntityRepositoryInterface $nimbits_pricerequest */
  135.         $nimbits_pricerequests = $this->container->get('nimbits_pricerequests.repository');
  136.         $retval = $nimbits_pricerequests->create(
  137.             [
  138.                 [
  139.                     'salutation' => $requestData["salutation"],
  140.                     'firstname' => $requestData["firstname"],
  141.                     'surname' => $requestData["surname"],
  142.                     'mail' => $requestData["mail"],
  143.                     'desiredprice' => $requestData["desiredprice"],
  144.                     'desiredpricecurrency' => $requestData["desiredpricecurrency"],
  145.                     'address' => $requestData["address"],
  146.                     'company' => $requestData["company"],
  147.                     'comment' => $requestData["comment"],
  148.                     'phonenumber' => $requestData["phonenumber"],
  149.                     'additional_info' => Null,
  150.                 ],
  151.             ],
  152.             \Shopware\Core\Framework\Context::createDefaultContext()
  153.         );
  155.         $nimbits_pricerequest_uuid = $retval->getEvents()->getElements()[0]->getIds()[0];
  157.         foreach ($requestData["lineItems"] as $item) {
  159.             $nimbits_pricerequests_baskets = $this->container->get('nimbits_pricerequests_baskets.repository');
  161.             $name = $item->name;
  162.             if (!empty($item->variant)) {
  163.                 $name = $name . " (" . $item->variant . ")";
  164.             }
  166.             $retval_basket = $nimbits_pricerequests_baskets->create(
  167.                 [
  168.                     [
  169.                         'pricerequest_id' => $nimbits_pricerequest_uuid,
  170.                         'article_name' => $name,
  171.                         'article_amount' => "" . $item->quantity,
  172.                         'article_ordernumber' => $item->number,
  173.                         'article_id' => $this->getProductIdByNumber($item->number),
  174.                         'additional_info' => NULL,
  175.                     ],
  176.                 ],
  177.                 \Shopware\Core\Framework\Context::createDefaultContext()
  178.             );
  180.             if (count($retval_basket->getEvents()->getElements()) > 0 && count($retval_basket->getEvents()->getElements()[0]->getPayloads()) > 0) {
  181.                 $insertData = [];
  182.                 $parentId = $retval_basket->getEvents()->getElements()[0]->getPayloads()[0]['id'];
  184.                 if (isset($item->children)) {
  186.                     foreach ($item->children as $child) {
  187.                         $name = $child->name;
  188.                         if (!empty($child->variant)) {
  189.                             $name = $name . " (" . $child->variant . ")";
  190.                         }
  192.                         $insertData[] = [
  193.                             'pricerequest_id' => $nimbits_pricerequest_uuid,
  194.                             'parentId' => $parentId,
  195.                             'article_name' => $name,
  196.                             'article_amount' => "" . $child->quantity,
  197.                             'article_ordernumber' => $child->number,
  198.                             'article_id' => $this->getProductIdByNumber($child->number),
  199.                             'additional_info' => NULL,
  200.                         ];
  201.                     }
  203.                     $nimbits_pricerequests_baskets->create(
  204.                         $insertData,
  205.                         \Shopware\Core\Framework\Context::createDefaultContext()
  206.                     );
  208.                 }
  209.             }
  210.         }
  212.         return $nimbits_pricerequest_uuid;
  213.     }
  215.     private function sendCustomerMail(SalesChannelContext $salesChannelContext, Context $context, array $settings, array $requestData)
  216.     {
  217.         if (!$settings["nbporsendmailtocustomer"]) {
  218.             return;
  219.         }
  221.         //mail validation
  222.         if (!isset($requestData["mail"]) || !filter_var($requestData["mail"], FILTER_VALIDATE_EMAIL)) {
  223.             return;
  224.         }
  226.         $receiver = "";
  228.         if (!empty($requestData["firstname"])) {
  229.             $receiver = $requestData["firstname"];
  230.         }
  232.         if (!empty($requestData["surname"])) {
  233.             $receiver = $receiver . " " . $requestData["surname"];
  234.         }
  236.         if (empty($receiver)) {
  237.             $receiver = "Anonym";
  238.         }
  240.         $mailsendbeforeevent = new MailBeforeSendEvent($salesChannelContext, $requestData);
  242.         $this->businesseventdispatcher->dispatch($mailsendbeforeevent);
  244.         $requestData = $mailsendbeforeevent->getMailvars();
  246.         $data = [];
  247.         $data['recipients'] = [$requestData["mail"] => $receiver];
  249.         $mailtemplate = $this->getMailTemplate($salesChannelContext, "nimbits_por_emailcustomer");
  251.         $data['contentHtml'] = $mailtemplate->getContentHtml() ?? $mailtemplate->getTranslated()['contentHtml'];
  252.         $data['contentPlain'] = $mailtemplate->getContentPlain() ?? $mailtemplate->getTranslated()['contentPlain'];
  253.         $data['subject'] = $mailtemplate->getSubject() ?? $mailtemplate->getTranslated()['subject'];
  256.         $data['salesChannelId'] = $salesChannelContext->getSalesChannel()->getId();
  258.         //sender name
  259.         $data['senderName'] = $this->translation->trans("nimbits-pricerequest.mail.customersendername");
  260.         if ($this->getMailTemplate($salesChannelContext, "nimbits_por_emailcustomer")->getSenderName() !== null) {
  261.             $data['senderName'] = $this->getMailTemplate($salesChannelContext, "nimbits_por_emailcustomer")->getSenderName();
  262.         }
  264.         $this->mailService->send(
  265.             $data,
  266.             $context,
  267.             [
  268.                 'salesChannelId' => $salesChannelContext->getSalesChannel()->getId(),
  269.                 'requestData' => $requestData
  270.             ]
  271.         );
  272.     }
  274.     private function sendRequestMail(SalesChannelContext $salesChannelContext, Context $context, array $settings, array $requestData)
  275.     {
  276.         //mail validation
  277.         if (!isset($settings['requestmail']) || !filter_var($settings['requestmail'], FILTER_VALIDATE_EMAIL)) {
  278.             return;
  279.         }
  282.         $mailsendbeforeevent = new MailBeforeSendEvent($salesChannelContext, $requestData);
  284.         $this->businesseventdispatcher->dispatch($mailsendbeforeevent);
  286.         $requestData = $mailsendbeforeevent->getMailvars();
  288.         $data = [];
  289.         $data['recipients'] = [];
  290.         $data['recipients'][$settings['requestmail']] = $this->translation->trans("nimbits-pricerequests.mail.shopownersendername");
  292.         if (isset($settings['requestmail2']) && filter_var($settings['requestmail2'], FILTER_VALIDATE_EMAIL)) {
  293.             $data['recipients'][$settings['requestmail2']] = $this->translation->trans("nimbits-pricerequests.mail.shopownersendername");
  294.         }
  296.         if (isset($settings['requestmail3']) && filter_var($settings['requestmail3'], FILTER_VALIDATE_EMAIL)) {
  297.             $data['recipients'][$settings['requestmail3']] = $this->translation->trans("nimbits-pricerequests.mail.shopownersendername");
  298.         }
  300.         $mailtemplate = $this->getMailTemplate($salesChannelContext, "nimbits_por_emailshopowner");
  302.         $data['contentHtml'] = $mailtemplate->getContentHtml() ?? $mailtemplate->getTranslated()['contentHtml'];
  303.         $data['contentPlain'] = $mailtemplate->getContentPlain() ?? $mailtemplate->getTranslated()['contentPlain'];
  304.         $data['subject'] = $mailtemplate->getSubject() ?? $mailtemplate->getTranslated()['subject'];
  306.         $data['salesChannelId'] = $salesChannelContext->getSalesChannel()->getId();
  308.         //sender name
  309.         $data['senderName'] = $this->translation->trans("nimbits-pricerequests.mail.shopownersendername");
  310.         if ($this->getMailTemplate($salesChannelContext, "nimbits_por_emailshopowner")->getSenderName() !== null) {
  311.             $data['senderName'] = $this->getMailTemplate($salesChannelContext, "nimbits_por_emailcustomer")->getSenderName();
  312.         }
  314.         $this->mailService->send(
  315.             $data,
  316.             $context,
  317.             [
  318.                 'salesChannelId' => $salesChannelContext->getSalesChannel()->getId(),
  319.                 'requestData' => $requestData
  320.             ]
  321.         );
  322.     }
  324.     private function getAttributesByNumber($number)
  325.     {
  326.         /** @var EntityRepositoryInterface $productRepository */
  327.         $productRepository = $this->container->get('product.repository');
  329.         /** @var EntityCollection $entities */
  330.         $products = $productRepository->search(
  331.             (
  332.             new Criteria()
  333.             )->addFilter(new EqualsFilter('productNumber', $number)),
  334.             \Shopware\Core\Framework\Context::createDefaultContext()
  335.         );
  337.         $product = $products->getEntities()->getElements();
  339.         return $product;
  341.     }
  343.     private function doPricingForItem($salesChannelContext, $context, $item)
  344.     {
  345.         $productID = array_key_first($item->attributes);
  347.         //no valid product ID => virtual product
  348.         if (empty($productID)) {
  350.             $item->netprice = 0;
  351.             $item->grossprice = 0;
  353.             $currency = $salesChannelContext->getCurrency();
  355.             $item->currencysymbol = $currency->getSymbol();
  357.             return $item;
  358.         }
  360.         //CartPrice::TAX_STATE_GROSS, CartPrice::TAX_STATE_NET, CartPrice::TAX_STATE_FREE
  361.         $taxState = $context->getTaxState();
  362.         if ($taxState == CartPrice::TAX_STATE_NET && property_exists($item, "netprice")) {
  363.             $item->grossprice = $item->netprice;
  364.         }
  366.         $currency = $salesChannelContext->getCurrency();
  368.         $price = $item->attributes[$productID]->getPrice();
  369.         if (!empty($price)) {
  370.             foreach ($price as $p) {
  372.                 if ($p->getCurrencyId() == $currency->getId()) {
  373.                     $item->netprice = round($p->getNet(), 2);
  374.                     $item->grossprice = round($p->getGross(), 2);
  376.                 }
  377.             }
  378.         }
  379.         $item->currencysymbol = $currency->getSymbol();
  381.         return $item;
  382.     }
  385.     /**
  386.      * @Route("/nimbits/pricerequest/request", name="frontend.action.nimbits.price-request-request", options={"seo"="false"}, methods={"POST"}, defaults={"_captcha"=true})
  387.      */
  389.     public function priceRequest(Request $request, SalesChannelContext $salesChannelContext, Context $context): Response
  390.     {
  391.         $finishUrl = $request->get('nbpr_form_sourceurl');
  393.         $settings = $this->settingService->getSettingsAsArray($salesChannelContext->getSalesChannel()->getId());
  395.         $lineitems = json_decode($request->get('nb_pricerequest_form_lineitems'));
  397.         foreach ($lineitems as &$item) {
  398.             if (isset($item->children)) {
  399.                 foreach ($item->children as &$child) {
  400.                     $child->attributes = $this->getAttributesByNumber($child->number);
  401.                     $child = $this->doPricingForItem($salesChannelContext, $context, $child);
  402.                 }
  403.             }
  404.             $item->attributes = $this->getAttributesByNumber($item->number);
  406.             $item = $this->doPricingForItem($salesChannelContext, $context, $item);
  407.         }
  409.         $isCartRequest = true;
  410.         $productID = null;
  411.         $cartItems = $this->cartService->getCart($salesChannelContext->getToken(), $salesChannelContext)->getLineItems()->getElements();
  412.         if (count($lineitems) == 1) {
  413.             $isCartRequest = false;
  415.             foreach ($lineitems as &$item) {
  416.                 $productID = array_key_first($item->attributes);
  417.             }
  418.         }
  420.         $address = json_encode([
  421.             "street" => $request->get('nbpr_street'),
  422.             "housenumber" => $request->get('nbpr_housenumber'),
  423.             "zipcode" => $request->get('nbpr_zipcode'),
  424.             "city" => $request->get('nbpr_city'),
  425.             "country" => $request->get('nbpr_country')
  426.         ]);
  428.         $requestData = [
  429.             'lineItems' => $lineitems,
  430.             'isCartRequest' => $isCartRequest,
  431.             'salutation' => $request->get('nbpr_salutation'),
  432.             'company' => $request->get('nbpr_company'),
  433.             'firstname' => $request->get('nbpr_firstname'),
  434.             'surname' => $request->get('nbpr_surname'),
  435.             'mail' => $request->get('nbpr_mail'),
  436.             'desiredprice' => $request->get('nbpr_desiredprice'),
  437.             'desiredpricecurrency' => $request->get('nbpr_desiredpricecurrency'),
  438.             'address' => $address,
  439.             'comment' => $request->get('nbpr_comment'),
  440.             'phonenumber' => $request->get('nbpr_phonenumber'),
  441.             'vars' => $request->request->all()
  442.         ];
  444.         //try inserting request but fail if it doesnt work
  445.         try{
  446.             $poruuid = $this->insertRequest($requestData);
  447.         }
  448.         catch (\Exception $e){
  449.             return new RedirectResponse($finishUrl."?nb_por_success=0");
  450.         }
  452.         $requestData["uuid"] = $poruuid;
  453.         $requestData["date"] = date('d.m.Y H:i:s');
  455.         $addressdata = json_decode($requestData["address"], true);
  457.         $addresscleaned = $addressdata["street"] . " " . $addressdata["housenumber"] . ", " . $addressdata["zipcode"] . " " . $addressdata["city"] . ", " . $addressdata["country"];
  459.         $tmpaddress = preg_replace('/\s+/', '', $addresscleaned);
  460.         if (strlen(str_replace(',', '', $tmpaddress)) > 0) {
  461.             $requestData["address"] = $addresscleaned;
  462.         } else {
  463.             $requestData["address"] = "";
  464.         }
  466.         try{
  467.             $this->sendRequestMail($salesChannelContext, $context, $settings, $requestData);
  468.         }
  469.         catch (\Exception $e){
  470.         }
  472.         try{
  473.             $this->sendCustomerMail($salesChannelContext, $context, $settings, $requestData);
  474.         }
  475.         catch (\Exception $e){
  476.         }
  478.         if ($request->get('nbpr_deletecart') == "1") {
  479.             $this->cartService->deleteCart($salesChannelContext);
  480.         }
  482.         if (isset($settings["nbproredirecturlcartsuccess"])) {
  483.             if (filter_var($settings["nbproredirecturlcartsuccess"], FILTER_VALIDATE_URL) !== FALSE) {
  484.                 $finishUrl = $settings["nbproredirecturlcartsuccess"];
  485.             }
  486.         }
  488.         if (!$isCartRequest && !empty($productID)) {
  489.             $finishUrl = $this->getRedirectForArticle($item->attributes[array_key_first($item->attributes)], $productID);
  490.         }
  492.         if ($finishUrl == "") {
  493.             $finishUrl = $this->generateUrl('frontend.action.nimbits.price-request-finish');
  494.         }
  496.         return new RedirectResponse($finishUrl."?nb_por_success=1");
  497.     }
  499.     public function getRedirectForArticle($attributes, $productID)
  500.     {
  501.         $finishUrl = $this->generateUrl('frontend.detail.page', ['productId' => $productID]);
  503.         //check if individual redirect is set for category
  504.         try {
  505.             $categoryTree = $attributes->getCategoryTree();
  506.             foreach ($categoryTree as $categoryid) {
  507.                 //the lower we find a redirect the more imporant it is
  508.                 $tmpfinish = $this->checkCategoryForRedirectURL($categoryid);
  510.                 if ($tmpfinish != false) {
  511.                     $finishUrl = $this->generateUrl($tmpfinish);
  512.                 }
  513.             }
  514.         } catch (\Exception $e) {
  516.         }
  517.         //check if individual redirect is set for article
  518.         try {
  519.             $finishUrlArticle = $attributes->getCustomFields()["custom_nimbits_priceonrequest_redirectarticle"];
  520.             if (filter_var($finishUrlArticle, FILTER_VALIDATE_URL)) {
  521.                 $finishUrl = $this->generateUrl($finishUrlArticle);
  522.             }
  523.         } catch (\Exception $e) {
  525.         }
  527.         return $finishUrl;
  528.     }
  530.     public function checkCategoryForRedirectURL($categoryid)
  531.     {
  532.         /** @var EntityRepositoryInterface $categoryRepository */
  533.         $categoryRepository = $this->container->get('category.repository');
  535.         /** @var EntityCollection $entities */
  536.         $category = $categoryRepository->search(
  537.             (
  538.             new Criteria()
  539.             )->addFilter(new EqualsFilter('id', $categoryid)),
  540.             \Shopware\Core\Framework\Context::createDefaultContext()
  541.         );
  543.         $category = $category->getEntities()->getElements();
  545.         $finishUrlCategory = $category[array_key_first($category)]->getCustomFields()["custom_nimbits_priceonrequest_customredirectarticle"];
  547.         if (filter_var($finishUrlCategory, FILTER_VALIDATE_URL)) {
  548.             return $finishUrlCategory;
  549.         }
  551.         return false;
  552.     }
  553. }