custom/plugins/NetiNextProductDetailCms/src/Decoration/ProductRepositoryDecorator.php line 68

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace NetInventors\NetiNextProductDetailCms\Decoration;
  7. use NetInventors\NetiNextProductDetailCms\Core\Content\Product\Aggregate\ProductCms\ProductCmsDefinition;
  8. use NetInventors\NetiNextProductDetailCms\Service\PluginConfig;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityDefinition;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\AggregationResult\AggregationResultCollection;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\IdSearchResult;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Write\CloneBehavior;
  20. class ProductRepositoryDecorator implements EntityRepositoryInterface
  21. {
  22.     private EntityRepositoryInterface $mainService;
  24.     private PluginConfig              $config;
  26.     private EntityRepositoryInterface $productCmsRepository;
  28.     public function __construct(
  29.         EntityRepositoryInterface $mainService,
  30.         PluginConfig              $config,
  31.         EntityRepositoryInterface $productCmsRepository
  32.     ) {
  33.         $this->mainService          = $mainService;
  34.         $this->config               = $config;
  35.         $this->productCmsRepository = $productCmsRepository;
  36.     }
  38.     public function getDefinition(): EntityDefinition
  39.     {
  40.         return $this->mainService->getDefinition();
  41.     }
  43.     public function aggregate(Criteria $criteria, Context $context): AggregationResultCollection
  44.     {
  45.         return $this->mainService->aggregate($criteria, $context);
  46.     }
  48.     public function searchIds(Criteria $criteria, Context $context): IdSearchResult
  49.     {
  50.         return $this->mainService->searchIds($criteria, $context);
  51.     }
  53.     public function clone(
  54.         string        $id,
  55.         Context       $context,
  56.         ?string       $newId = null,
  57.         CloneBehavior $behavior = null
  58.     ): EntityWrittenContainerEvent {
  59.         $event = $this->mainService->clone($id, $context, $newId, $behavior);
  61.         $this->removeProductCmsRelationIfEnabled($event);
  63.         return $event;
  64.     }
  66.     public function search(Criteria $criteria, Context $context): EntitySearchResult
  67.     {
  68.         return $this->mainService->search($criteria, $context);
  69.     }
  71.     public function update(array $data, Context $context): EntityWrittenContainerEvent
  72.     {
  73.         return $this->mainService->update($data, $context);
  74.     }
  76.     public function upsert(array $data, Context $context): EntityWrittenContainerEvent
  77.     {
  78.         return $this->mainService->upsert($data, $context);
  79.     }
  81.     public function create(array $data, Context $context): EntityWrittenContainerEvent
  82.     {
  83.         return $this->mainService->create($data, $context);
  84.     }
  86.     public function delete(array $data, Context $context): EntityWrittenContainerEvent
  87.     {
  88.         return $this->mainService->delete($data, $context);
  89.     }
  91.     public function createVersion(string $id, Context $context, ?string $name = null, ?string $versionId = null): string
  92.     {
  93.         return $this->mainService->createVersion($id, $context, $name, $versionId);
  94.     }
  96.     public function merge(string $versionId, Context $context): void
  97.     {
  98.         $this->mainService->merge($versionId, $context);
  99.     }
  101.     private function removeProductCmsRelationIfEnabled(EntityWrittenContainerEvent $event): void
  102.     {
  103.         if ($this->config->isDisableCopyAssociation() !== true) {
  104.             return;
  105.         }
  107.         /** @var EntityWrittenEvent $nestedEvent */
  108.         foreach ($event->getEvents() as $nestedEvent) {
  109.             if ($nestedEvent->getEntityName() === ProductCmsDefinition::ENTITY_NAME) {
  110.                 foreach ($nestedEvent->getWriteResults() as $entityWriteResult) {
  111.                     $id = $entityWriteResult->getPrimaryKey();
  113.                     $this->productCmsRepository->delete(
  114.                         [
  115.                             [
  116.                                 'id' => $id,
  117.                             ],
  118.                         ],
  119.                         $event->getContext()
  120.                     );
  121.                 }
  122.             }
  123.         }
  124.     }
  125. }