custom/plugins/PevrPayeverIntegration/src/EventListener/ProductDeleteEventListener.php line 92

Open in your IDE?
  1. <?php
  3. /**
  4.  * payever GmbH
  5.  *
  6.  * NOTICE OF LICENSE
  7.  *
  8.  * Permission is hereby granted, free of charge, to any person obtaining a copy
  9.  * of this software and associated documentation files (the "Software"), to deal
  10.  * in the Software without restriction, including without limitation the rights
  11.  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  12.  * copies of the Software, and to permit persons to whom the Software is
  13.  * furnished to do so, subject to the following conditions:
  14.  *
  15.  * The above copyright notice and this permission notice shall be included in all
  16.  * copies or substantial portions of the Software.
  17.  *
  18.  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  19.  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  20.  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  21.  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  22.  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  23.  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  24.  * SOFTWARE.
  25.  *
  26.  * DISCLAIMER
  27.  *
  28.  * Do not edit or add to this file if you wish to upgrade payever Shopware package
  29.  * to newer versions in the future.
  30.  *
  31.  * @category    Payever
  32.  * @author      payever GmbH <service@payever.de>
  33.  * @copyright   Copyright (c) 2021 payever GmbH (http://www.payever.de)
  34.  * @license     http://opensource.org/licenses/osl-3.0.php  Open Software License (OSL 3.0)
  35.  */
  37. declare(strict_types=1);
  39. namespace Payever\PayeverPayments\EventListener;
  41. use Shopware\Core\Content\Product\ProductDefinition;
  42. use Shopware\Core\Content\Product\ProductEntity;
  43. use Shopware\Core\Content\Product\ProductEvents;
  44. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  45. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  46. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  47. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  49. class ProductDeleteEventListener extends AbstractProductEventListener implements EventSubscriberInterface
  50. {
  51.     /**
  52.      * @var ProductEntity[]
  53.      */
  54.     private $productsToRemove = [];
  56.     /**
  57.      * {@inheritDoc}
  58.      */
  59.     public static function getSubscribedEvents(): array
  60.     {
  61.         return [
  62.             PreWriteValidationEvent::class => 'preValidate',
  63.             ProductEvents::PRODUCT_DELETED_EVENT => 'onProductDelete',
  64.         ];
  65.     }
  67.     /**
  68.      * @param PreWriteValidationEvent $event
  69.      */
  70.     public function preValidate(PreWriteValidationEvent $event): void
  71.     {
  72.         if (!$this->synchronizationManager->isProductsSyncEnabled()) {
  73.             return;
  74.         }
  75.         foreach ($event->getCommands() as $writeCommand) {
  76.             if ($writeCommand->getDefinition()->getClass() === ProductDefinition::class) {
  77.                 $primaryKey = $writeCommand->getEntityExistence()->getPrimaryKey();
  78.                 $productId = $primaryKey['id'] ?? null;
  79.                 if ($writeCommand instanceof DeleteCommand) {
  80.                     $product = $this->getUncachedProduct($productId);
  81.                     if ($product) {
  82.                         $this->productsToRemove[$productId] = $product;
  83.                     }
  84.                 }
  85.             }
  86.         }
  87.     }
  89.     /**
  90.      * @param EntityDeletedEvent $event
  91.      */
  92.     public function onProductDelete(EntityDeletedEvent $event): void
  93.     {
  94.         if (!$this->synchronizationManager->isProductsSyncEnabled()) {
  95.             $this->productsToRemove = [];
  97.             return;
  98.         }
  99.         if (!$event->getErrors()) {
  100.             $writeResults = $event->getWriteResults();
  101.             if (!empty($writeResults[0])) {
  102.                 $writeResult = $writeResults[0];
  103.                 $existence = $writeResult->getExistence();
  104.                 if ($existence) {
  105.                     $primaryKey = $existence->getPrimaryKey();
  106.                     $productId = $primaryKey['id'] ?? null;
  107.                     if (!empty($this->productsToRemove[$productId])) {
  108.                         $productToRemove = $this->productsToRemove[$productId];
  109.                         $parentId = $productToRemove->getParentId();
  110.                         $parentProduct = $parentId ? $this->getUncachedProduct($parentId) : null;
  111.                         $parentProduct
  112.                             ? $this->synchronizationManager->handleProductSave($parentProduct)
  113.                             : $this->synchronizationManager->handleProductDelete($productToRemove);
  114.                     }
  115.                 }
  116.             }
  117.         }
  118.         $this->productsToRemove = [];
  119.     }
  121.     /**
  122.      * @internal
  123.      * @param array $productsToRemove
  124.      */
  125.     public function setProductsToRemove(array $productsToRemove): void
  126.     {
  127.         $this->productsToRemove = $productsToRemove;
  128.     }
  129. }