custom/plugins/MyKeje/src/Storefront/Subscriber/OrderLineItemCreatedEventSubscriber.php line 37

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Okeonline\MyKeje\Storefront\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Checkout\Order\OrderEvents;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class OrderLineItemCreatedEventSubscriber implements EventSubscriberInterface
  13. {
  15.     /** @var EntityRepository $orderLineItemRepository */
  16.     private $orderLineItemRepository;
  18.     /** @var Connection $connection */
  19.     private $connection;
  21.     public function __construct(
  22.         EntityRepository $orderLineItemRepository,
  23.         Connection $connection
  24.     )
  25.     {
  26.         $this->orderLineItemRepository = $orderLineItemRepository;
  27.         $this->connection = $connection;
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             OrderEvents::ORDER_LINE_ITEM_WRITTEN_EVENT => 'manipulateReferenceTable'
  34.         ];
  35.     }
  37.     public function manipulateReferenceTable(EntityWrittenEvent $event)
  38.     {
  39.         $writeResults = $event->getWriteResults();
  40.         $entityName = $event->getEntityName();
  42.         if( ! $entityName == 'order_line_item' || ! $writeResults || ! is_array($writeResults) || count($writeResults) == 0)
  43.             return;
  45.         foreach ($writeResults as $entityWriteResult)
  46.         {
  47.             $orderLineItemId = $entityWriteResult->getPrimaryKey();
  49.             $criteria = new Criteria([$orderLineItemId]);
  50.             $criteria->addAssociation('order');
  51.             $criteria->addAssociation('order.order_customer');
  52.             $criteria->addAssociation('order.order_line_items');
  53.             $result = $this->orderLineItemRepository->search($criteria, $event->getContext());
  55.             if($result->count() !== 1)
  56.                 continue;
  58.             $orderLineItem = $result->getEntities()->first();
  60.             $orderId = $orderLineItem->getOrder()->getId();
  61.             $customerId = $orderLineItem->getOrder()->getOrderCustomer()->getCustomerId();
  63.             $this->connection->executeStatement(sprintf("
  64.                 DELETE FROM `oo_mykeje_reference` WHERE `customer_id` = UNHEX('%s') AND `order_id` = UNHEX('%s') AND `order_line_item_id` = UNHEX('%s');
  65.             ", $customerId, $orderId, $orderLineItemId));
  67.             if(
  68.                 ! is_array($entityWriteResult->getPayload()) ||
  69.                 ! array_key_exists('type', $entityWriteResult->getPayload()) ||
  70.                 ! array_key_exists('label', $entityWriteResult->getPayload()) ||
  71.                 ! array_key_exists('payload', $entityWriteResult->getPayload()) ||
  72.                 ! $entityWriteResult->getPayload()['type'] == 'customized-products-option' ||
  73.                   strtolower($entityWriteResult->getPayload()['label']) !== 'referentie' ||
  74.                 ! is_array($entityWriteResult->getPayload()['payload']) ||
  75.                 ! array_key_exists('value', $entityWriteResult->getPayload()['payload']) ||
  76.                 is_null($entityWriteResult->getPayload()['payload']['value'])
  77.             )
  78.                 continue;
  80.             $reference = $entityWriteResult->getPayload()['payload']['value'];
  82.             $this->connection->executeStatement(sprintf("
  83.                 INSERT INTO `oo_mykeje_reference` (`customer_id`, `order_id`, `order_line_item_id`, `reference`) VALUES (UNHEX('%s'), UNHEX('%s'), UNHEX('%s'), '%s');
  84.             ", $customerId, $orderId, $orderLineItemId, addslashes($reference)));
  86.         }
  87.     }
  88. }