custom/plugins/MagmodulesWebshopnl/src/MagmodulesWebshopnl.php line 17

  1. <?php
  2. declare(strict_types=1);
  4. namespace MagmodulesWebshopnl;
  6. use Doctrine\DBAL\Connection;
  7. use Shopware\Core\Defaults;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\Plugin;
  13. use Shopware\Core\Framework\Plugin\Context\InstallContext;
  14. use Shopware\Core\Framework\Plugin\Context\UninstallContext;
  15. use Shopware\Core\Framework\Plugin\Util\PluginIdProvider;
  16. use Shopware\Core\Framework\Uuid\Uuid;
  18. class MagmodulesWebshopnl extends Plugin
  19. {
  20.     const SHIPPING_METHOD_NAME = 'webshopnl';
  22.     public function install(InstallContext $installContext): void
  23.     {
  24.         parent::install($installContext);
  25.         $this->addConfigurationToken();
  26.         $this->addPaymentMethod($installContext->getContext());
  27.         $this->addShippingMethod($installContext->getContext());
  28.     }
  30.     /**
  31.      * @param  UninstallContext  $uninstallContext
  32.      *
  33.      * @return void
  34.      */
  35.     public function uninstall(UninstallContext $uninstallContext): void
  36.     {
  37.         /* Keep UserData? Then do nothing here */
  38.         if ($uninstallContext->keepUserData()) {
  39.             return;
  40.         }
  42.         /**
  43.          * @var Connection $connection
  44.          */
  45.         $connection = $this->container->get(Connection::class);
  47.         $connection->executeStatement(
  48.             'DELETE FROM system_config WHERE configuration_key LIKE :domain',
  49.             [
  50.                 'domain' => '%MagmodulesWebshopnl.settings%',
  51.             ]
  52.         );
  53.         $connection->executeStatement('DROP TABLE IF EXISTS `magmodules_wevshopnl_product_feed`');
  54.         $connection->executeStatement('DROP TABLE IF EXISTS `magmodules_webshopnl_order`');
  55.     }
  57.     public function addShippingMethod(Context $context)
  58.     {
  59.         /**
  60.          * @var EntityRepository $shippingMethodRepository
  61.          */
  62.         $shippingMethodRepository = $this->container->get('shipping_method.repository');
  64.         $shippingMethodRepository->upsert([
  65.             $this->createDataPayload($shippingMethodRepository, $context),
  66.         ], $context);
  67.     }
  69.     private function addRule($rulesRepository, Context $context): string
  70.     {
  71.         $ruleIdInsert = Uuid::randomHex();
  72.         $data = [
  73.             'id' => $ruleIdInsert,
  74.             'name' => 'All customers',
  75.             'priority' => 1,
  76.             'invalid' => false,
  77.         ];
  78.         $rulesRepository->upsert([$data], $context);
  80.         return $ruleIdInsert;
  81.     }
  83.     public function createDataPayload($shippingMethodRepository, $context): array
  84.     {
  85.         $rulesRepository = $this->container->get('rule.repository');
  87.         $ruleId = $rulesRepository->searchIds(
  88.             (new Criteria())->addFilter(new EqualsFilter('name', 'All customers')),
  89.             $context
  90.         )->firstId();
  92.         if (!$ruleId) {
  93.             $ruleId = $rulesRepository->searchIds(
  94.                 (new Criteria())->setLimit(1),
  95.                 $context
  96.             )->firstId();
  97.         }
  99.         if ($ruleId === null) {
  100.             $ruleId = $this->addRule($rulesRepository, $context);
  101.         }
  103.         $deliveryTimeRepository = $this->container->get('delivery_time.repository');
  105.         $deliveryTimeEntityId = $deliveryTimeRepository->searchIds(
  106.             (new Criteria())->setLimit(1),
  107.             $context
  108.         )->firstId();
  110.         if ($deliveryTimeEntityId === null) {
  111.             $deliveryTimeEntityId = $this->addDeliveryTime($deliveryTimeRepository, $context);
  112.         }
  114.         $id = $this->getExistingShippingMethodId($shippingMethodRepository, $context);
  116.         return [
  117.             'id' => $id ?? Uuid::randomHex(),
  118.             'translations' => [
  119.                 'en-GB' => [
  120.                     'name' => self::SHIPPING_METHOD_NAME,
  121.                 ],
  122.                 'nl-NL' => [
  123.                     'name' => self::SHIPPING_METHOD_NAME,
  124.                 ],
  125.                 'de-DE' => [
  126.                     'name' => self::SHIPPING_METHOD_NAME,
  127.                 ],
  128.             ],
  129.             'active' => false,
  130.             'availabilityRuleId' => $ruleId,
  131.             'deliveryTimeId' => $deliveryTimeEntityId,
  132.             'prices' => [
  133.                 [
  134.                     'price' => 0,
  135.                     'currencyId' => Defaults::CURRENCY,
  136.                     'calculation' => 0,
  137.                     'quantityStart' => 0,
  138.                     'currencyPrice' => [
  139.                         [
  140.                             'currencyId' => Defaults::CURRENCY,
  141.                             'net' => 0,
  142.                             'gross' => 0,
  143.                             'linked' => false,
  144.                         ],
  145.                     ],
  146.                 ],
  147.             ],
  148.         ];
  149.     }
  151.     private function getExistingShippingMethodId($shippingMethodRepository, $context): ?string
  152.     {
  153.         $criteria = (new Criteria())
  154.             ->addFilter(new EqualsFilter('name', self::SHIPPING_METHOD_NAME));
  156.         return $shippingMethodRepository->searchIds($criteria, $context)->firstId();
  157.     }
  159.     private function addDeliveryTime($deliveryTimeRepository, Context $context): string
  160.     {
  161.         $deliveryIdInsert = Uuid::randomHex();
  163.         $deliveryTimeRepository->upsert([
  164.             [
  165.                 'id' => $deliveryIdInsert,
  166.                 'name' => 'All customers',
  167.                 'min' => 1,
  168.                 'max' => 5,
  169.                 'unit' => 'day',
  170.             ],
  171.         ], $context);
  173.         return $deliveryIdInsert;
  174.     }
  176.     public function addPaymentMethod(Context $context): void
  177.     {
  178.         $paymentMethodExists = $this->getPaymentMethodId($context);
  180.         /* Payment method exists already, no need to continue here */
  181.         if ($paymentMethodExists) {
  182.             return;
  183.         }
  185.         /**
  186.          * @var PluginIdProvider $pluginIdProvider
  187.          */
  188.         $pluginIdProvider = $this->container->get(PluginIdProvider::class);
  189.         $pluginId = $pluginIdProvider->getPluginIdByBaseClass(static::class, $context);
  191.         $webshopnlData = [
  192.             'name' => 'webshopnl',
  193.             'pluginId' => $pluginId,
  194.             'afterOrderEnabled' => false,
  195.             'translations' => [
  196.                 'de-DE' => [
  197.                     'name' => 'webshopnl',
  198.                     'description' => 'webshopnl',
  199.                 ],
  200.                 'en-GB' => [
  201.                     'name' => 'webshopnl',
  202.                     'description' => 'webshopnl',
  203.                 ],
  204.             ],
  205.         ];
  207.         /**
  208.          * @var EntityRepository $paymentRepository
  209.          */
  210.         $paymentRepository = $this->container->get('payment_method.repository');
  211.         $paymentRepository->create([$webshopnlData], $context);
  212.     }
  214.     private function getPaymentMethodId(Context $context): ?string
  215.     {
  216.         /**
  217.          * @var EntityRepository $paymentRepository
  218.          */
  219.         $paymentRepository = $this->container->get('payment_method.repository');
  221.         /* Fetch ID for update */
  222.         $paymentCriteria = (new Criteria())->addFilter(new EqualsFilter('name', 'webshopnl'));
  223.         $paymentIds = $paymentRepository->searchIds($paymentCriteria, $context);
  225.         if ($paymentIds->getTotal() === 0) {
  226.             return null;
  227.         }
  229.         return $paymentIds->getIds()[0];
  230.     }
  232.     private function addConfigurationToken()
  233.     {
  234.         $config = $this->container->get('Shopware\Core\System\SystemConfig\SystemConfigService');
  236.         $token = $this->getRandomStringRand(25);
  237.         $config->set('MagmodulesWebshopnl.settings.integrationToken', $token);
  238.     }
  240.     function getRandomStringRand($length)
  241.     {
  242.         $stringSpace = '0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ';
  243.         $stringLength = strlen($stringSpace);
  244.         $randomString = '';
  245.         for ($i = 0; $i < $length; $i++) {
  246.             $randomString = $randomString . $stringSpace[rand(0, $stringLength - 1)];
  247.         }
  249.         return $randomString;
  250.     }
  251. }