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

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Rhiem\RhiemUserProducts;
  7. use Doctrine\DBAL\Connection;
  8. use Rhiem\RhiemUserProducts\Entities\ProductGroup\ProductGroupCollection;
  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\Plugin;
  13. use Shopware\Core\Framework\Plugin\Context\ActivateContext;
  14. use Shopware\Core\Framework\Plugin\Context\DeactivateContext;
  15. use Shopware\Core\Framework\Plugin\Context\InstallContext;
  16. use Shopware\Core\Framework\Plugin\Context\UninstallContext;
  17. use Shopware\Core\Framework\Plugin\Context\UpdateContext;
  19. class RhiemUserProducts extends Plugin
  20. {
  21.     public const FALLBACK_PRODUCT_GROUP_ID = "0502913fa0a54ee7b24a4128fb2c62bb";
  23.     public function install(InstallContext $installContext): void
  24.     {
  25.         parent::install($installContext);
  26.     }
  28.     public function uninstall(UninstallContext $uninstallContext): void
  29.     {
  30.         parent::uninstall($uninstallContext);
  32.         if ($uninstallContext->keepUserData()) {
  33.             return;
  34.         }
  36.         /**
  37.          * @var Connection $connection
  38.          */
  39.         $connection = $this->container->get(Connection::class);
  41.         $connection->executeStatement('ALTER TABLE customer DROP FOREIGN KEY `fk.customer.rhiem_product_group_id`');
  42.         $connection->executeStatement('ALTER TABLE customer DROP INDEX `fk.customer.rhiem_product_group_id`');
  44.         $connection->executeStatement('DROP TABLE IF EXISTS `rhiem_userproducts_productgroup_product`');
  45.         $connection->executeStatement('DROP TABLE IF EXISTS `rhiem_userproducts_productgroup_customer`');
  46.         $connection->executeStatement('DROP TABLE IF EXISTS `rhiem_userproducts_productgroup`');
  48.         $connection->executeStatement('ALTER TABLE `customer` DROP COLUMN `rhiemProductGroup`');
  49.         $connection->executeStatement('ALTER TABLE `customer` DROP COLUMN `rhiem_product_group_id`');
  50.         $connection->executeStatement('ALTER TABLE `product` DROP COLUMN `product_groups`');
  51.     }
  53.     public function activate(ActivateContext $activateContext): void
  54.     {
  55.         $this->createFallbackProductGroup();
  56.     }
  58.     public function deactivate(DeactivateContext $deactivateContext): void
  59.     {
  60.         parent::deactivate($deactivateContext);
  61.     }
  63.     public function createFallbackProductGroup(): void
  64.     {
  65.         /** @var EntityRepositoryInterface $productGroupRepository */
  66.         $productGroupRepository = $this->container->get('rhiem_userproducts_productgroup.repository');
  68.         /**
  69.          * @var ProductGroupCollection $result
  70.          */
  71.         $result = $productGroupRepository->search(
  72.             new Criteria([self::FALLBACK_PRODUCT_GROUP_ID]),
  73.             Context::createDefaultContext()
  74.         );
  76.         if ($result->getElements()) {
  77.             return;
  78.         }
  80.         $productGroupRepository->upsert(
  81.             [
  82.                 [
  83.                     'id' => self::FALLBACK_PRODUCT_GROUP_ID,
  84.                     'name' => 'Fallback',
  85.                     'groupMode' => 'blacklist',
  86.                     'active' => true,
  87.                     'fallback' => true
  88.                 ]
  89.             ],
  90.             Context::createDefaultContext()
  91.         );
  92.     }
  94.     public function postUpdate(UpdateContext $updateContext): void
  95.     {
  96.         if (version_compare($updateContext->getCurrentPluginVersion(), '1.0.7', '<')) {
  97.             /**
  98.              * @var Connection $connection
  99.              */
  100.             $connection = $this->container->get(Connection::class);
  101.             try {
  102.                 $connection->executeStatement('ALTER TABLE customer DROP FOREIGN KEY `fk.customer.rhiem_product_group_id`');
  103.             } catch (\Exception $e) {
  104.             }
  105.             $sql = "ALTER TABLE customer
  106.   ADD CONSTRAINT `fk.customer.rhiem_product_group_id` FOREIGN KEY (`rhiem_product_group_id`)
  107.   REFERENCES `rhiem_userproducts_productgroup` (`id`) ON DELETE SET NULL ON UPDATE CASCADE";
  108.             /**
  109.              * @var Connection $connection
  110.              */
  111.             $connection->executeStatement($sql);
  112.         }
  115.         parent::postUpdate($updateContext);
  116.     }
  117. }