custom/plugins/PickwareErpStarter/src/ImportExport/ModelSubscriber/DeleteDocumentSubscriber.php line 42

Open in your IDE?
  1. <?php
  2. /*
  3.  * Copyright (c) Pickware GmbH. All rights reserved.
  4.  * This file is part of software that is released under a proprietary license.
  5.  * You must not copy, modify, distribute, make publicly available, or execute
  6.  * its contents or parts thereof without express permission by the copyright
  7.  * holder, unless otherwise permitted by law.
  8.  */
  10. declare(strict_types=1);
  12. namespace Pickware\PickwareErpStarter\ImportExport\ModelSubscriber;
  14. use Pickware\DalBundle\EntityManager;
  15. use Pickware\DocumentBundle\Model\DocumentDefinition;
  16. use Pickware\PickwareErpStarter\ImportExport\Model\ImportExportDefinition;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. class DeleteDocumentSubscriber implements EventSubscriberInterface
  23. {
  24.     /**
  25.      * @var EntityManager
  26.      */
  27.     private $entityManager;
  29.     public function __construct(EntityManager $entityManager)
  30.     {
  31.         $this->entityManager = $entityManager;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             ImportExportDefinition::EVENT_DELETED => 'onImportExportDeleted',
  38.             PreWriteValidationEvent::class => 'onPreWriteValidationEvent',
  39.         ];
  40.     }
  42.     public function onPreWriteValidationEvent(PreWriteValidationEvent $event): void
  43.     {
  44.         foreach ($event->getCommands() as $command) {
  45.             if ($command->getDefinition()->getEntityName() !== ImportExportDefinition::ENTITY_NAME) {
  46.                 continue;
  47.             }
  48.             if (!$command instanceof DeleteCommand) {
  49.                 continue;
  50.             }
  51.             $command->requestChangeSet();
  52.         }
  53.     }
  55.     public function onImportExportDeleted(EntityDeletedEvent $event): void
  56.     {
  57.         $documentIdsToRemove = [];
  58.         foreach ($event->getWriteResults() as $writeResult) {
  59.             $changeSet = $writeResult->getChangeSet();
  60.             if ($changeSet->getBefore('document_id') !== null) {
  61.                 $documentIdsToRemove[] = bin2hex($changeSet->getBefore('document_id'));
  62.             }
  63.         }
  64.         $this->entityManager->delete(DocumentDefinition::class, $documentIdsToRemove, $event->getContext());
  65.     }
  66. }