custom/plugins/MyKeje/src/Storefront/Subscriber/OrderCreatedEventSubscriber.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 OrderCreatedEventSubscriber implements EventSubscriberInterface
  13. {
  15.     /** @var EntityRepository $orderRepository */
  16.     private $orderRepository;
  18.     /** @var Connection $connection */
  19.     private $connection;
  21.     public function __construct(
  22.         EntityRepository $orderRepository,
  23.         Connection $connection
  24.     )
  25.     {
  26.         $this->orderRepository = $orderRepository;
  27.         $this->connection = $connection;
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             OrderEvents::ORDER_WRITTEN_EVENT => 'manipulateReferenceTable'
  34.         ];
  35.     }
  37.     public function manipulateReferenceTable(EntityWrittenEvent $event)
  38.     {
  39.         $writeResults = $event->getWriteResults();
  40.         $entityName = $event->getEntityName();
  42.         if( ! $entityName == 'order' || ! $writeResults || ! is_array($writeResults) || count($writeResults) == 0)
  43.             return;
  45.         foreach ($writeResults as $entityWriteResult)
  46.         {
  47.             $orderId = $entityWriteResult->getPrimaryKey();
  49.             $criteria = new Criteria([$orderId]);
  50.             $criteria->addAssociation('order_customer');
  51.             $result = $this->orderRepository->search($criteria, $event->getContext());
  53.             if($result->count() !== 1)
  54.                 continue;
  56.             $order = $result->getEntities()->first();
  58.             $customerId = $order->getOrderCustomer()->getCustomerId();
  60.             $this->connection->executeStatement(sprintf("
  61.                 DELETE FROM `oo_mykeje_reference` WHERE `customer_id` = UNHEX('%s') AND `order_id` = UNHEX('%s') AND `order_line_item_id` = NULL;
  62.             ", $customerId, $orderId));
  64.             if(is_array($order->getCustomFields()) && array_key_exists('oo_checkout_extra_data_reference', $order->getCustomFields()) && !is_null($order->getCustomFields()['oo_checkout_extra_data_reference']))
  65.             {
  66.                 $reference = addslashes($order->getCustomFields()['oo_checkout_extra_data_reference']);
  68.                 $this->connection->executeStatement(sprintf("
  69.                     INSERT INTO `oo_mykeje_reference` (`customer_id`, `order_id`, `order_line_item_id`, `reference`) VALUES (UNHEX('%s'), UNHEX('%s'), NULL, '%s');
  70.                 ", $customerId, $orderId, $reference));
  72.             }
  73.         }
  74.     }
  75. }