custom/plugins/SwagMarkets/src/Subscriber/ProductDeleteSubscriber.php line 44

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Swag\Markets\Subscriber;
  5. use Exception;
  6. use Generator;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Shopware\Core\Content\Product\ProductEvents;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. class ProductDeleteSubscriber implements EventSubscriberInterface 
  15. {
  16.     /** @var EntityRepositoryInterface */
  17.     private $productToDeleteRepository;
  19.     /**
  20.      * @param EntityRepositoryInterface $productToDeleteRepository
  21.      */
  22.     public function __construct(EntityRepositoryInterface $productToDeleteRepository)
  23.     {
  24.         $this->productToDeleteRepository = $productToDeleteRepository;
  25.     }
  27.     /**
  28.      * Register events to listen to
  29.      *
  30.      * @return array
  31.      */
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         // Return the events to listen to as array like this:  <event to listen to> => <method to execute>
  35.         return [
  36.             ProductEvents::PRODUCT_DELETED_EVENT => 'onProductsDeleted',
  37.         ];
  38.     }
  40.     /**
  41.      * @param EntityDeletedEvent $event
  42.      * @return void
  43.      */
  44.     public function onProductsDeleted(EntityDeletedEvent $event): void
  45.     {
  46.         try {
  47.             $eventWriteResult = $event->getWriteResults();
  48.             if ($event->getEntityName() === 'product') {
  49.                 $this->storeProductToDelete($eventWriteResult);
  50.             }
  51.         } catch (Exception $e) {
  53.         }
  54.     }
  56.     /**
  57.      * @param array $eventWriteResult
  58.      * @return void
  59.      */
  60.     private function storeProductToDelete(array $eventWriteResult): void
  61.     {
  62.         /** @var EntityWriteResult $entityWriteResult */
  63.         foreach ($this->getEntityWriteResult($eventWriteResult) as $entityWriteResult) {
  64.             $data = [
  65.                 'productId' => $entityWriteResult->getPrimaryKey(),
  66.                 'isVariation' => $entityWriteResult->getExistence()->isChild() ? 1 : 0
  67.             ];
  69.             $this->productToDeleteRepository->upsert([$data], Context::createDefaultContext());
  70.         }
  71.     }
  73.     /**
  74.      * Returns a single EntityWriteResult with every loop to work with.
  75.      *
  76.      * @param array $eventWriteResult
  77.      * @return Generator
  78.      */
  79.     private function getEntityWriteResult(array $eventWriteResult): Generator
  80.     {
  81.         if (count($eventWriteResult) > 0) {
  82.             /** @var EntityWriteResult $entityWriteResult */
  83.             foreach ($eventWriteResult as $entityWriteResult) {
  84.                 if ($entityWriteResult->getEntityName() === 'product' && $entityWriteResult->getOperation() === 'delete') {
  85.                     yield $entityWriteResult;
  86.                 }
  87.             }
  88.         }
  89.     }
  90. }