vendor/store.shopware.com/swagb2bplatform/components/Order/BridgePlatform/OrderDeleteSubscriber.php line 31

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\B2B\Order\BridgePlatform;
  5. use Shopware\B2B\Common\IdValue;
  6. use Shopware\B2B\Order\Framework\OrderContextService;
  7. use Shopware\Core\Checkout\Order\OrderDefinition;
  8. use Shopware\Core\Defaults;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use function array_walk;
  15. class OrderDeleteSubscriber implements EventSubscriberInterface
  16. {
  17.     protected OrderContextService $orderContextService;
  19.     public function __construct(OrderContextService $orderContextService)
  20.     {
  21.         $this->orderContextService = $orderContextService;
  22.     }
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             EntityWrittenContainerEvent::class => 'onOrderWrittenEvent',
  28.         ];
  29.     }
  31.     public function onOrderWrittenEvent(EntityWrittenContainerEvent $eventContainer): void
  32.     {
  33.         $event = $eventContainer->getEventByEntityName(OrderDefinition::ENTITY_NAME);
  34.         if ($event instanceof EntityDeletedEvent) {
  35.             $this->onOrderDelete($event);
  36.         }
  37.     }
  39.     /**
  40.      * @internal
  41.      */
  42.     protected function onOrderDelete(EntityDeletedEvent $deletedEvent): void
  43.     {
  44.         $list = [];
  45.         $writeResults = $deletedEvent->getWriteResults();
  46.         array_walk($writeResults, function (EntityWriteResult $writeResult) use (&$list) {
  47.             if ($writeResult->getOperation() === EntityWriteResult::OPERATION_DELETE) {
  48.                 $payload = $writeResult->getPayload();
  49.                 if (isset($payload['versionId']) && $payload['versionId'] === Defaults::LIVE_VERSION) {
  50.                     $list[] = IdValue::create($writeResult->getPrimaryKey());
  51.                 }
  52.             }
  53.         });
  54.         $this->orderContextService->deleteContextsByReferencedOrderIds($list);
  55.     }
  56. }