custom/plugins/AcrisCmsPreviewCS/src/AcrisCmsPreviewCS.php line 19

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\CmsPreview;
  6. use Acris\CmsPreview\DependencyInjection\CompilerPass\CmsPreviewCacheCompilerPass;
  7. use Doctrine\DBAL\Connection;
  8. use Shopware\Core\Defaults;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  14. use Shopware\Core\Framework\Plugin;
  15. use Shopware\Core\Framework\Plugin\Context\UninstallContext;
  16. use Shopware\Core\Framework\Plugin\Context\ActivateContext;
  17. use Symfony\Component\DependencyInjection\ContainerBuilder;
  19. class AcrisCmsPreviewCS extends Plugin
  20. {
  21.     public function activate(ActivateContext $context): void
  22.     {
  23.         $this->insertDefaultPreviewProfiles($context->getContext());
  24.     }
  26.     public function build(ContainerBuilder $container): void
  27.     {
  28.         parent::build($container);
  30.         $container->addCompilerPass(new CmsPreviewCacheCompilerPass());
  31.     }
  33.     private function insertDefaultPreviewProfiles(Context $context): void
  34.     {
  35.         /** @var EntityRepositoryInterface $previewRepository */
  36.         $previewRepository = $this->container->get('acris_cms_preview_profile.repository');
  38.         $salesChannelRepository = $this->container->get('sales_channel.repository');
  40.         $criteria = new Criteria();
  41.         $criteria->addAssociation('domains');
  42.         $salesChannelEntities = $salesChannelRepository->search($criteria, $context)->getEntities();
  44.         $profileData = [];
  45.         foreach ($salesChannelEntities as $channel) {
  46.             if ($channel->getTypeId() !== Defaults::SALES_CHANNEL_TYPE_API) {
  47.                 if (!empty($channel->getDomains()->getElements())) {
  48.                     $profileData[] = [
  49.                         'internalName' => $channel->getName(),
  50.                         'active' => true,
  51.                         'position' => 10,
  52.                         'salesChannelId' => $channel->getId(),
  53.                         'salesChannelDomainId' => $channel->getDomains()->first()->getId(),
  54.                         'currencyId' => $channel->getCurrencyId(),
  55.                         'customerGroupId' => $channel->getCustomerGroupId()
  56.                     ];
  57.                 }
  58.             }
  59.         }
  61.         foreach ($profileData as $profile) {
  62.             $this->createIfNotExists($previewRepository, [['name' => 'internalName', 'value' => $profile['internalName']]], $profile, $context);
  63.         }
  64.     }
  66.     private function createIfNotExists(EntityRepositoryInterface $repository, array $equalFields, array $data, Context $context): void
  67.     {
  68.         $filters = [];
  69.         foreach ($equalFields as $equalField) {
  70.             $filters[] = new EqualsFilter($equalField['name'], $equalField['value']);
  71.         }
  72.         if (sizeof($filters) > 1) {
  73.             $filter = new MultiFilter(MultiFilter::CONNECTION_OR, $filters);
  74.         } else {
  75.             $filter = array_shift($filters);
  76.         }
  78.         $searchResult = $repository->search((new Criteria())->addFilter($filter), $context);
  79.         if (empty($searchResult->first())) {
  80.             $repository->upsert([$data], $context);
  81.         }
  82.     }
  84.     public function uninstall(UninstallContext $context): void
  85.     {
  86.         if ($context->keepUserData()) {
  87.             return;
  88.         }
  90.         $this->cleanupDatabase();
  91.     }
  93.     private function cleanupDatabase(): void
  94.     {
  95.         $connection = $this->container->get(Connection::class);
  97.         $connection->executeStatement('DROP TABLE IF EXISTS acris_cms_preview_profile');
  98.     }
  99. }