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

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\DalBundle\EntityPreWriteValidationEvent;
  16. use Pickware\DalBundle\EntityPreWriteValidationEventDispatcher;
  17. use Pickware\DocumentBundle\Model\DocumentDefinition;
  18. use Pickware\PickwareErpStarter\ImportExport\Model\ImportExportDefinition;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. class DeleteDocumentSubscriber implements EventSubscriberInterface
  24. {
  25.     private EntityManager $entityManager;
  27.     public function __construct(EntityManager $entityManager)
  28.     {
  29.         $this->entityManager = $entityManager;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             ImportExportDefinition::EVENT_DELETED => 'onImportExportDeleted',
  36.             EntityPreWriteValidationEventDispatcher::getEventName(ImportExportDefinition::ENTITY_NAME) => 'onPreWriteValidationEvent',
  37.         ];
  38.     }
  40.     public function onPreWriteValidationEvent($event): void
  41.     {
  42.         if (!($event instanceof EntityPreWriteValidationEvent)) {
  43.             // The subscriber is probably instantiated in its old version (with the Shopware PreWriteValidationEvent) in
  44.             // the container and will be updated on the next container rebuild (next request). Early return.
  45.             return;
  46.         }
  48.         foreach ($event->getCommands() as $command) {
  49.             if ($command instanceof DeleteCommand) {
  50.                 $command->requestChangeSet();
  51.             }
  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. }