vendor/store.shopware.com/spnosalutationorder/src/SpnoSalutationOrder.php line 19

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) webpiloten. <kontakt@web-piloten.de>
  4.  * For the full copyright and license information, please view the LICENSE
  5.  * file that was distributed with this source code.
  6.  */
  8. namespace Spno\SalutationOrder;
  10. use Doctrine\DBAL\Connection;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  14. use Shopware\Core\Framework\Plugin;
  15. use Shopware\Core\Framework\Plugin\Context\InstallContext;
  16. use Shopware\Core\Framework\Plugin\Context\UninstallContext;
  17. use Spno\SalutationOrder\Entity\SalutationPosition\SalutationPositionDefinition;
  19. class SpnoSalutationOrder extends Plugin
  20. {
  21.     public function postInstall(InstallContext $installContext): void
  22.     {
  23.         /** @var EntityRepositoryInterface $salutationRepository */
  24.         $salutationRepository = $this->container->get('salutation.repository');
  26.         $criteria = new Criteria();
  27.         $criteria->addSorting(new FieldSorting('salutationKey', FieldSorting::DESCENDING));
  29.         $salutationIds = $salutationRepository->searchIds($criteria, $installContext->getContext())->getIds();
  31.         $salutations = [];
  32.         $position = 10;
  33.         foreach ($salutationIds as $salutationId) {
  34.             $salutations[] = [
  35.                 'salutationId' => $salutationId,
  36.                 'position' => $position,
  37.             ];
  39.             $position = $position + 10;
  40.         }
  42.         /** @var Connection $connection */
  43.         $connection = $this->container->get(Connection::class);
  45.         foreach ($salutations as $salutation) {
  46.             $connection->executeStatement(\sprintf(
  47.                 "INSERT INTO `%s` (`salutation_id`, `position`, `created_at`) VALUES (UNHEX('%s'), %s, date(now())) ON DUPLICATE KEY UPDATE `salutation_id` = UNHEX('%s')",
  48.                 SalutationPositionDefinition::ENTITY_NAME,
  49.                 $salutation['salutationId'],
  50.                 $salutation['position'],
  51.                 $salutation['salutationId']
  52.             ));
  53.         }
  54.     }
  56.     public function uninstall(UninstallContext $uninstallContext): void
  57.     {
  58.         if ($uninstallContext->keepUserData()) {
  59.             parent::uninstall($uninstallContext);
  61.             return;
  62.         }
  64.         /** @var Connection $connection */
  65.         $connection = $this->container->get(Connection::class);
  66.         $connection->executeStatement(\sprintf('DROP TABLE IF EXISTS `%s`', SalutationPositionDefinition::ENTITY_NAME));
  67.     }
  68. }