custom/plugins/NetiNextGoogleCustomerReviews/src/Subscriber/Checkout.php line 68

Open in your IDE?
  1. <?php
  3. namespace NetInventors\NetiNextGoogleCustomerReviews\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use NetInventors\NetiNextGoogleCustomerReviews\Service\PluginConfig;
  7. use NetInventors\NetiNextGoogleCustomerReviews\Struct\GoogleSurveyOptin;
  8. use Shopware\Core\Checkout\Cart\LineItem\LineItemCollection;
  9. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemCollection;
  10. use Shopware\Core\Content\Product\ProductEntity;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class Checkout implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var PluginConfig
  23.      */
  24.     private $pluginConfig;
  26.     /**
  27.      * @var Connection
  28.      */
  29.     private $db;
  31.     /**
  32.      * @var EntityRepositoryInterface
  33.      */
  34.     private $countryRepository;
  36.     /**
  37.      * @var EntityRepositoryInterface
  38.      */
  39.     private $productRepository;
  41.     /**
  42.      * Checkout constructor.
  43.      *
  44.      * @param PluginConfig              $pluginConfig
  45.      * @param Connection                $db
  46.      * @param EntityRepositoryInterface $countryRepository
  47.      * @param EntityRepositoryInterface $productRepository
  48.      */
  49.     public function __construct(
  50.         PluginConfig $pluginConfig,
  51.         Connection $db,
  52.         EntityRepositoryInterface $countryRepository,
  53.         EntityRepositoryInterface $productRepository
  54.     ) {
  55.         $this->pluginConfig      = $pluginConfig;
  56.         $this->countryRepository = $countryRepository;
  57.         $this->db                = $db;
  58.         $this->productRepository = $productRepository;
  59.     }
  61.     public static function getSubscribedEvents(): array
  62.     {
  63.         return [
  64.             CheckoutFinishPageLoadedEvent::class => 'onFinishPageLoaded',
  65.         ];
  66.     }
  68.     public function onFinishPageLoaded(CheckoutFinishPageLoadedEvent $event): void
  69.     {
  70.         if (!$this->pluginConfig->isActive()) {
  71.             return;
  72.         }
  74.         $order           = $event->getPage()->getOrder();
  75.         $deliverDate     = new \DateTime('now +' . $this->pluginConfig->getDeliveryDate() . ' days');
  76.         $countryId       = current($order->getDeliveries()->getShippingAddress()->getCountryIds());
  77.         $deliveryCountry = $this->getCountryIsoById($countryId, $event->getContext());
  79.         $struct = new GoogleSurveyOptin();
  80.         $struct->setMerchantId($this->pluginConfig->getMerchantId());
  81.         $struct->setOrderId($order->getId());
  82.         $struct->setEmail($order->getOrderCustomer()->getEmail());
  83.         $struct->setDeliveryCountry($deliveryCountry);
  84.         $struct->setEstimatedDeliveryDate($deliverDate);
  85.         $struct->setOptionalFields($this->pluginConfig->getOptionalFields());
  87.         if ($this->pluginConfig->isGtinActive()) {
  88.             $products = $this->loadProducts($order->getLineItems(), $event->getContext());
  90.             $struct->setProducts($products);
  91.         }
  93.         $event->getPage()->addExtension('netiNextGoogleCustomerReviewsFinish', $struct);
  94.     }
  96.     /**
  97.      * @param OrderLineItemCollection $lineItems
  98.      * @param Context                 $context
  99.      *
  100.      * @return array
  101.      * @throws InconsistentCriteriaIdsException
  102.      */
  103.     protected function loadProducts(OrderLineItemCollection $lineItems, Context $context): array
  104.     {
  105.         $productIds = [];
  107.         foreach ($lineItems as $lineItem) {
  108.             if ('product' === $lineItem->getType()) {
  109.                 $productIds[] = $lineItem->getProductId();
  110.             }
  111.         }
  113.         $criteria = new Criteria($productIds);
  114.         $products = $this->productRepository->search($criteria, $context);
  115.         $result   = [];
  117.         /** @var ProductEntity $product */
  118.         foreach ($products as $product) {
  119.             if (!$product->getEan()) {
  120.                 continue;
  121.             }
  123.             $result[] = [
  124.                 'gtin' => $product->getEan(),
  125.             ];
  126.         }
  128.         return $result;
  129.     }
  131.     /**
  132.      * @param string  $countryId
  133.      * @param Context $context
  134.      *
  135.      * @return string|null
  136.      * @throws InconsistentCriteriaIdsException
  137.      */
  138.     protected function getCountryIsoById(string $countryId, Context $context): ?string
  139.     {
  140.         $criteria = new Criteria();
  141.         $criteria->addFilter(new EqualsFilter('id', $countryId));
  143.         $countries = $this->countryRepository->search($criteria, $context);
  145.         if ($countries->count() > 0) {
  146.             return $countries->first()->getIso();
  147.         }
  149.         return null;
  150.     }
  151. }