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

  1. <?php declare(strict_types=1);
  3. namespace MagmodulesWebshopnl;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Defaults;
  7. use Shopware\Core\Framework\Context;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  11. use Shopware\Core\Framework\Plugin;
  12. use Shopware\Core\Framework\Plugin\Context\InstallContext;
  13. use Shopware\Core\Framework\Plugin\Context\UninstallContext;
  14. use Shopware\Core\Framework\Plugin\Util\PluginIdProvider;
  15. use Shopware\Core\Framework\Uuid\Uuid;
  17. class MagmodulesWebshopnl extends Plugin
  18. {
  19.     const SHIPPING_METHOD_NAME = 'webshopnl';
  21.     public function install(InstallContext $installContext): void
  22.     {
  23.         parent::install($installContext);
  24.         $this->createFolder();
  25.         $this->addConfigurationToken();
  26.         $this->addPaymentMethod($installContext->getContext());
  27.         $this->addShippingMethod($installContext->getContext());
  28.     }
  30.     /**
  31.      * @param UninstallContext $uninstallContext
  32.      * @return void
  33.      */
  34.     public function uninstall(UninstallContext $uninstallContext): void
  35.     {
  36.         /* Keep UserData? Then do nothing here */
  37.         if ($uninstallContext->keepUserData()) {
  38.             return;
  39.         }
  41.         /**
  42.          * @var Connection $connection
  43.          */
  44.         $connection = $this->container->get(Connection::class);
  46.         $connection->executeStatement(
  47.             'DELETE FROM system_config WHERE configuration_key LIKE :domain',
  48.             [
  49.                 'domain' => '%MagmodulesWebshopnl.settings%',
  50.             ]
  51.         );
  52.         $connection->executeStatement('DROP TABLE IF EXISTS `magmodules_wevshopnl_product_feed`');
  53.         $connection->executeStatement('DROP TABLE IF EXISTS `magmodules_webshopnl_order`');
  55.         $folderPath = getcwd().'/';
  56.         $dir = "webshopnl";
  57.         $this->deleteDirectory($dir);
  58.     }
  60.     public function deleteDirectory($dir) {
  62.         if (!file_exists($dir)) {
  63.             return true;
  64.         }
  66.         if (!is_dir($dir)) {
  67.             return unlink($dir);
  68.         }
  70.         foreach (scandir($dir) as $item) {
  71.             if ($item == '.' || $item == '..') {
  72.                 continue;
  73.             }
  75.             if (!$this->deleteDirectory($dir . DIRECTORY_SEPARATOR . $item)) {
  76.                 return false;
  77.             }
  79.         }
  81.         return rmdir($dir);
  82.     }
  84.     public function createFolder(): void
  85.     {
  86.         $folderPath = getcwd().'/webshopnl';
  87.         if(!file_exists($folderPath)){
  88.             if (!mkdir($concurrentDirectory = $folderPath . "webshopnl") && !is_dir($concurrentDirectory)) {
  89.                 throw new \RuntimeException(sprintf('Directory "%s" was not created', $concurrentDirectory));
  90.             }
  91.         }
  92.     }
  94.     public function addShippingMethod(Context $context)
  95.     {
  96.         /**
  97.          * @var EntityRepository $shippingMethodRepository
  98.          */
  99.         $shippingMethodRepository = $this->container->get('shipping_method.repository');
  101.         $shippingMethodRepository->upsert([
  102.             $this->createDataPayload($shippingMethodRepository, $context)
  103.         ], $context);
  104.     }
  106.     private function addRule($rulesRepository, Context $context): string
  107.     {
  108.         $ruleIdInsert = Uuid::randomHex();
  109.         $data = [
  110.             'id' => $ruleIdInsert,
  111.             'name' => 'All customers',
  112.             'priority' => 1,
  113.             'invalid' => false
  114.         ];
  115.         $rulesRepository->upsert([$data], $context);
  116.         return $ruleIdInsert;
  117.     }
  118.     public function createDataPayload($shippingMethodRepository, $context): array
  119.     {
  120.         $rulesRepository = $this->container->get('rule.repository');
  122.         $ruleId = $rulesRepository->searchIds(
  123.             (new Criteria())->addFilter(new EqualsFilter('name', 'All customers')),
  124.             $context
  125.         )->firstId();
  127.         if (!$ruleId) {
  128.             $ruleId = $rulesRepository->searchIds(
  129.                 (new Criteria())->setLimit(1),
  130.                 $context
  131.             )->firstId();
  132.         }
  134.         if ($ruleId === null) {
  135.             $ruleId = $this->addRule($rulesRepository, $context);
  136.         }
  138.         $deliveryTimeRepository = $this->container->get('delivery_time.repository');
  140.         $deliveryTimeEntityId = $deliveryTimeRepository->searchIds(
  141.             (new Criteria())->setLimit(1),
  142.             $context
  143.         )->firstId();
  145.         if ($deliveryTimeEntityId === null) {
  146.             $deliveryTimeEntityId = $this->addDeliveryTime($deliveryTimeRepository, $context);
  147.         }
  149.         $id = $this->getExistingShippingMethodId($shippingMethodRepository, $context);
  151.         return [
  152.             'id' => $id ?? Uuid::randomHex(),
  153.             'translations' => [
  154.                 'en-GB' => [
  155.                     'name' => self::SHIPPING_METHOD_NAME
  156.                 ],
  157.                 'nl-NL' => [
  158.                     'name' => self::SHIPPING_METHOD_NAME
  159.                 ],
  160.                 'de-DE' => [
  161.                     'name' => self::SHIPPING_METHOD_NAME
  162.                 ]
  163.             ],
  164.             'active' => false,
  165.             'availabilityRuleId' => $ruleId,
  166.             'deliveryTimeId' => $deliveryTimeEntityId,
  167.             'prices' => [
  168.                 [
  169.                     'price' => 0,
  170.                     'currencyId' => Defaults::CURRENCY,
  171.                     'calculation' => 0,
  172.                     'quantityStart' => 0,
  173.                     'currencyPrice' => [
  174.                         [
  175.                             'currencyId' => Defaults::CURRENCY,
  176.                             'net' => 0,
  177.                             'gross' => 0,
  178.                             'linked' => false,
  179.                         ],
  180.                     ],
  181.                 ],
  182.             ]
  183.         ];
  184.     }
  186.     private function getExistingShippingMethodId($shippingMethodRepository, $context): ?string
  187.     {
  188.         $criteria = (new Criteria())
  189.             ->addFilter(new EqualsFilter('name', self::SHIPPING_METHOD_NAME));
  191.         return $shippingMethodRepository->searchIds($criteria, $context)->firstId();
  192.     }
  194.     private function addDeliveryTime($deliveryTimeRepository, Context $context): string
  195.     {
  196.         $deliveryIdInsert = Uuid::randomHex();
  198.         $deliveryTimeRepository->upsert([
  199.             [
  200.                 'id' => $deliveryIdInsert,
  201.                 'name' => 'All customers',
  202.                 'min' => 1,
  203.                 'max' => 5,
  204.                 'unit' => 'day'
  205.             ]
  206.         ], $context);
  208.         return $deliveryIdInsert;
  209.     }
  210.     public function addPaymentMethod(Context $context): void
  211.     {
  212.         $paymentMethodExists = $this->getPaymentMethodId($context);
  214.         /* Payment method exists already, no need to continue here */
  215.         if ($paymentMethodExists) {
  216.             return;
  217.         }
  219.         /**
  220.          * @var PluginIdProvider $pluginIdProvider
  221.          */
  222.         $pluginIdProvider = $this->container->get(PluginIdProvider::class);
  223.         $pluginId = $pluginIdProvider->getPluginIdByBaseClass(static::class, $context);
  225.         $webshopnlData = [
  226.             'name' => 'webshopnl',
  227.             'pluginId' => $pluginId,
  228.             'afterOrderEnabled' => false,
  229.             'translations' => [
  230.                 'de-DE' => [
  231.                     'name' => 'webshopnl',
  232.                     'description' => 'webshopnl',
  233.                 ],
  234.                 'en-GB' => [
  235.                     'name' => 'webshopnl',
  236.                     'description' => 'webshopnl',
  237.                 ]
  238.             ]
  239.         ];
  241.         /**
  242.          * @var EntityRepository $paymentRepository
  243.          */
  244.         $paymentRepository = $this->container->get('payment_method.repository');
  245.         $paymentRepository->create([$webshopnlData], $context);
  246.     }
  248.     private function getPaymentMethodId(Context $context): ?string
  249.     {
  250.         /**
  251.          * @var EntityRepository $paymentRepository
  252.          */
  253.         $paymentRepository = $this->container->get('payment_method.repository');
  255.         /* Fetch ID for update */
  256.         $paymentCriteria = (new Criteria())->addFilter(new EqualsFilter('name','webshopnl'));
  257.         $paymentIds = $paymentRepository->searchIds($paymentCriteria, $context);
  259.         if ($paymentIds->getTotal() === 0) {
  260.             return null;
  261.         }
  263.         return $paymentIds->getIds()[0];
  264.     }
  265.     private function addConfigurationToken()
  266.     {
  267.         $config = $this->container->get('Shopware\Core\System\SystemConfig\SystemConfigService');
  269.         $token = $this->getRandomStringRand(25);
  270.         $config->set('MagmodulesWebshopnl.settings.integrationToken', $token);
  271.     }
  273.     function getRandomStringRand($length)
  274.     {
  275.         $stringSpace = '0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ';
  276.         $stringLength = strlen($stringSpace);
  277.         $randomString = '';
  278.         for ($i = 0; $i < $length; $i ++) {
  279.             $randomString = $randomString . $stringSpace[rand(0, $stringLength - 1)];
  280.         }
  281.         return $randomString;
  282.     }
  283. }