custom/static-plugins/AlphaplanPriceConnector/src/Subscriber/ApOrderLineItemSubscriber.php line 38

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace AlphaplanPriceConnector\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  7. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  8. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  9. use Shopware\Core\Defaults;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\RetryableQuery;
  11. use Shopware\Core\Framework\Uuid\Uuid;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class ApOrderLineItemSubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var Connection
  18.      */
  19.     private $connection;
  21.     public function __construct(
  22.         Connection $connection
  23.     )
  24.     {
  25.         $this->connection = $connection;
  26.     }
  28.     /**
  29.      * Returns a list of custom business events to listen where the product maybe changed
  30.      */
  31.     public static function getSubscribedEvents()
  32.     {
  33.         return [
  34.             CheckoutOrderPlacedEvent::class => 'ApOrderPlaced'
  35.         ];
  36.     }
  38.     public function ApOrderPlaced(CheckoutOrderPlacedEvent $event): void
  39.     {
  40.         foreach ($event->getOrder()->getLineItems() as $lineItem) {
  41.             if ($lineItem->getType() !== LineItem::PRODUCT_LINE_ITEM_TYPE) {
  42.                 continue;
  43.             }
  44.             $this->apCreateOrderLineItem($lineItem);
  45.         }
  46.     }
  48.     private function apCreateOrderLineItem(OrderLineItemEntity $lineItem): bool
  49.     {
  50.         if (array_key_exists('customFields', $lineItem->getPayload())) {
  51.             $apCustomFields = $lineItem->getPayload()['customFields'];
  52.             $query = new RetryableQuery(
  53.                 $this->connection->prepare('INSERT INTO `cvs_order_line_item` (`id`, `order_line_itemId`, `Rabatt1`, `Rabatt2`, `Rabatt3`, `Zuschlag1`, `Zuschlag2`, `Zuschlag3`,`created_at`,`taxId`)
  54.                     VALUES (:id, :order_line_itemId, :Rabatt1, :Rabatt2, :Rabatt3, :Zuschlag1, :Zuschlag2, :Zuschlag3, :created_at, :taxId)')
  55.             );
  56.             $query->execute([
  57.                 'id' => Uuid::randomBytes(),
  58.                 'order_line_itemId' => Uuid::fromHexToBytes($lineItem->getId()),
  59.                 'Rabatt1' => isset($apCustomFields['Rabatt1']) ? $apCustomFields['Rabatt1'] : 0,
  60.                 'Rabatt2' => isset($apCustomFields['Rabatt2']) ? $apCustomFields['Rabatt2'] : 0,
  61.                 'Rabatt3' => isset($apCustomFields['Rabatt3']) ? $apCustomFields['Rabatt3'] : 0,
  62.                 'Zuschlag1' => isset($apCustomFields['Zuschlag1']) ? $apCustomFields['Zuschlag1'] : 0,
  63.                 'Zuschlag2' => isset($apCustomFields['Zuschlag2']) ? $apCustomFields['Zuschlag2'] : 0,
  64.                 'Zuschlag3' => isset($apCustomFields['Zuschlag3']) ? $apCustomFields['Zuschlag3'] : 0,
  65.                 'taxId' => isset($apCustomFields['apTaxId']) ? Uuid::fromHexToBytes($apCustomFields['apTaxId']) : Uuid::fromHexToBytes($lineItem->getPayload()['taxId']),
  66.                 'created_at' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  67.             ]);
  69.         }
  70.         return true;
  71.     }
  72. }