custom/plugins/DvsnProductShippingSurcharge/src/Subscriber/Core/Content/ProductExportSubscriber.php line 47

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. /**
  4.  * digitvision
  5.  *
  6.  * @category  digitvision
  7.  * @package   Shopware\Plugins\DvsnProductShippingSurcharge
  8.  * @copyright (c) 2021 digitvision
  9.  */
  11. namespace Dvsn\ProductShippingSurcharge\Subscriber\Core\Content;
  13. use Doctrine\DBAL\Connection;
  14. use Shopware\Core\Content\ProductExport\Event\ProductExportRenderBodyContextEvent;
  15. use Shopware\Core\Content\ProductExport\ProductExportEntity;
  16. use Shopware\Core\Defaults;
  17. use Shopware\Core\Framework\Uuid\Uuid;
  18. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class ProductExportSubscriber implements EventSubscriberInterface
  22. {
  23.     private Connection $connection;
  25.     public function __construct(
  26.         Connection $connection
  27.     ) {
  28.         $this->connection = $connection;
  30.     }
  32.     /**
  33.      * {@inheritDoc}
  34.      */
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             ProductExportRenderBodyContextEvent::class => 'onProductExportRenderBodyContext'
  39.         ];
  40.     }
  42.     /**
  43.      * ...
  44.      *
  45.      * @param ProductExportRenderBodyContextEvent $event
  46.      */
  47.     public function onProductExportRenderBodyContext(ProductExportRenderBodyContextEvent $event)
  48.     {
  49.         /** @var SalesChannelContext $salesChannelContext */
  50.         $salesChannelContext = $event->getContext()['context'];
  52.         /** @var ProductExportEntity $productExport */
  53.         $productExport = $event->getContext()['productExport'];
  55.         $customFields = (array) $productExport->getSalesChannel()->getCustomFields();
  57.         if (!isset($customFields['dvsn_product_shipping_surcharge_sales_channel_status']) || $customFields['dvsn_product_shipping_surcharge_sales_channel_status'] !== true) {
  58.             return;
  59.         }
  61.         $query = $this->connection->createQueryBuilder()
  62.             ->select('LOWER(HEX(product_id)) AS product_id, surcharge')
  63.             ->from('dvsn_product_shipping_surcharge')
  64.             ->where('product_version_id = :versionId')
  65.             ->setParameter('versionId', Uuid::fromHexToBytes(Defaults::LIVE_VERSION))
  66.             ->groupBy('product_id');
  68.         if (isset($customFields['dvsn_product_shipping_surcharge_sales_channel_shipping_method']) && !empty($customFields['dvsn_product_shipping_surcharge_sales_channel_shipping_method'])) {
  69.             $query->andWhere('shipping_method_id = :shippingMethodId')
  70.                 ->setParameter('shippingMethodId', Uuid::fromHexToBytes($customFields['dvsn_product_shipping_surcharge_sales_channel_shipping_method']));
  71.         } else {
  72.             $query->andWhere('shipping_method_id IS NULL');
  73.         }
  75.         if (isset($customFields['dvsn_product_shipping_surcharge_sales_channel_country']) && !empty($customFields['dvsn_product_shipping_surcharge_sales_channel_country'])) {
  76.             $query->andWhere('country_id = :countryId')
  77.                 ->setParameter('countryId', Uuid::fromHexToBytes($customFields['dvsn_product_shipping_surcharge_sales_channel_country']));
  78.         } else {
  79.             $query->andWhere('country_id IS NULL');
  80.         }
  82.         if (isset($customFields['dvsn_product_shipping_surcharge_sales_channel_sales_channel']) && !empty($customFields['dvsn_product_shipping_surcharge_sales_channel_sales_channel'])) {
  83.             $query->andWhere('sales_channel_id = :salesChannelId')
  84.                 ->setParameter('salesChannelId', Uuid::fromHexToBytes($customFields['dvsn_product_shipping_surcharge_sales_channel_sales_channel']));
  85.         } else {
  86.             $query->andWhere('sales_channel_id IS NULL');
  87.         }
  89.         $surcharges = $query->execute()->fetchAllAssociative();
  91.         $arr = [];
  93.         foreach ($surcharges as $surcharge) {
  94.             $arr[$surcharge['product_id']] = (float) $surcharge['surcharge'];
  95.         }
  97.         $context = $event->getContext();
  98.         $context['dvsnProductShippingSurcharge'] = $arr;
  99.         $event->setContext($context);
  100.     }
  101. }