custom/plugins/OrcaOci/src/Subscriber/LineItemAddedSubscriber.php line 50

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Orcamultimedia\OciPunchout\Subscriber;
  7. use Orcamultimedia\OciPunchout\Service\OciService;
  8. use Orcamultimedia\OciPunchout\Struct\OciCartData;
  9. use Shopware\Core\Checkout\Cart\Event\BeforeLineItemAddedEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepository;
  12. use Shopware\Core\System\SystemConfig\SystemConfigService;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class LineItemAddedSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var SalesChannelRepository
  19.      */
  20.     private SalesChannelRepository $productRepository;
  22.     /**
  23.      * @var OciService
  24.      */
  25.     private OciService $ociService;
  27.     /**
  28.      * @var SystemConfigService
  29.      */
  30.     private SystemConfigService $systemConfigService;
  32.     public function __construct(
  33.         SalesChannelRepository $productRepository,
  34.         OciService             $ociService,
  35.         SystemConfigService $systemConfigService
  36.     )
  37.     {
  38.         $this->productRepository = $productRepository;
  39.         $this->ociService = $ociService;
  40.         $this->systemConfigService = $systemConfigService;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             BeforeLineItemAddedEvent::class => 'addPayloadValues',
  47.         ];
  48.     }
  50.     public function addPayloadValues(BeforeLineItemAddedEvent $event): void
  51.     {
  52.         if (!$this->ociService->isPunchout()) {
  53.             return;
  54.         }
  56.         $lineItem = $event->getLineItem();
  57.         $context = $event->getSalesChannelContext();
  58.         $config = $this->systemConfigService->get('OciPunchout.config', $context->getSalesChannel()->getId());
  60.         $product = $this->productRepository->search(new Criteria([$lineItem->getReferencedId()]), $context)->first();
  61.         $extensionData = new OciCartData();
  63.         if ($product) {
  64.             $cartDataArray = $this->getCartDataArray($config, $product);
  65.             $extensionData->assign($cartDataArray);
  66.         }
  68.         $lineItem->addExtension(OciCartData::EXTENSION_NAME, $extensionData);
  69.     }
  71.     private function getCartDataArray(array $config, $product): array
  72.     {
  73.         $cartDataArray = [];
  75.         foreach (CheckoutCartSubscriber::CONFIG_KEYS as $key) {
  76.             $configValue = $config[$key] ?? '';
  77.             if (!$configValue || strpos($configValue, '@') === false) {
  78.                 continue;
  79.             }
  81.             $configValue = str_replace('@', '', $configValue);
  83.             if(
  84.                 ($data = $product->getCustomFields()[$configValue] ?? null)
  85.                 || ($data = $product->getVars()[$configValue] ?? null)
  86.             ) {
  87.                 $cartDataArray[$configValue] = $data;
  88.             }
  89.         }
  90.         $cartDataArray['description'] = $product->getDescription();
  92.         return $cartDataArray;
  93.     }
  94. }