custom/plugins/SwagCommercial/src/MultiWarehouse/Subscriber/CartConvertedSubscriber.php line 34

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Commercial\MultiWarehouse\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Commercial\Licensing\License;
  7. use Shopware\Core\Checkout\Cart\Order\CartConvertedEvent;
  8. use Shopware\Core\Defaults;
  9. use Shopware\Core\Framework\Uuid\Uuid;
  10. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. /**
  14.  * @internal
  15.  *
  16.  * @package inventory
  17.  */
  18. class CartConvertedSubscriber implements EventSubscriberInterface
  19. {
  20.     private Connection $connection;
  22.     public function __construct(Connection $connection)
  23.     {
  24.         $this->connection = $connection;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             CartConvertedEvent::class => 'onCartConverted',
  31.         ];
  32.     }
  34.     public function onCartConverted(CartConvertedEvent $event): void
  35.     {
  36.         if (!License::get('MULTI_INVENTORY-3749997')) {
  37.             return;
  38.         }
  40.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  41.             return;
  42.         }
  44.         $ids = $this->getAvailableWarehouseGroups($event->getSalesChannelContext());
  45.         if (empty($ids)) {
  46.             return;
  47.         }
  49.         $cartData = $event->getConvertedCart();
  51.         $cartData['warehouseGroups'] = \array_map(
  52.             static fn (string $id) => ['warehouseGroupId' => $id],
  53.             $ids
  54.         );
  56.         $event->setConvertedCart($cartData);
  57.     }
  59.     /**
  60.      * @return list<string>
  61.      */
  62.     private function getAvailableWarehouseGroups(SalesChannelContext $context): array
  63.     {
  64.         /** @var list<string> $groups */
  65.         $groups = $this->connection->fetchFirstColumn(
  66.             'SELECT LOWER(HEX(warehouse_group.id)) FROM warehouse_group WHERE warehouse_group.rule_id IN (:ids)',
  67.             ['ids' => Uuid::fromHexToBytesList($context->getRuleIds())],
  68.             ['ids' => Connection::PARAM_STR_ARRAY]
  69.         );
  71.         return $groups;
  72.     }
  73. }