custom/plugins/AcrisRuleSurchargeDiscountCS/src/AcrisRuleSurchargeDiscountCS.php line 18

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\RuleSurchargeDiscount;
  5. use Acris\RuleSurchargeDiscount\Custom\SurchargeDiscountEntity;
  6. use Doctrine\DBAL\Connection;
  7. use Shopware\Core\Defaults;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  14. use Shopware\Core\Framework\Plugin;
  15. use Shopware\Core\Framework\Plugin\Context\UninstallContext;
  16. use Shopware\Core\Framework\Uuid\Uuid;
  18. class AcrisRuleSurchargeDiscountCS extends Plugin
  19. {
  20.     const DEFAULT_VALUE_OFFSET = 0;
  22.     const DEFAULT_CRITERIA_LIMIT = 50;
  24.     const DEFAULT_MAIL_TEMPLATE_TYPE_SURCHARGE_DISCOUNT = 'acris_surcharge_discount.order_confirmation';
  26.     public function update(Plugin\Context\UpdateContext $updateContext): void
  27.     {
  28.         if (version_compare($updateContext->getCurrentPluginVersion(), '3.2.0', '<') && version_compare($updateContext->getUpdatePluginVersion(), '3.2.0', '>=')) {
  29.             $this->insertDefaultMailTemplate($updateContext->getContext());
  30.         }
  31.     }
  33.     public function postUpdate(Plugin\Context\UpdateContext $updateContext): void
  34.     {
  35.         if (version_compare($updateContext->getCurrentPluginVersion(), '3.7.0', '<') && version_compare($updateContext->getUpdatePluginVersion(), '3.7.0', '>=') && $updateContext->getPlugin()->isActive() === true) {
  36.             $this->updateExistingSurchargeDiscounts($updateContext->getContext());
  37.         }
  38.     }
  40.     public function activate(Plugin\Context\ActivateContext $activateContext): void
  41.     {
  42.         $this->insertDefaultMailTemplate($activateContext->getContext());
  43.         $this->updateExistingSurchargeDiscounts($activateContext->getContext());
  44.     }
  46.     public function uninstall(UninstallContext $uninstallContext): void
  47.     {
  48.         if ($uninstallContext->keepUserData()) {
  49.             return;
  50.         }
  51.         $this->cleanupDatabase();
  52.         $this->removeDefaultMailTemplate($uninstallContext->getContext());
  53.     }
  55.     private function cleanupDatabase(): void
  56.     {
  57.         $connection = $this->container->get(Connection::class);
  58.         if($this->columnExists($connection, 'media', 'acrisSurchargeDiscounts')) {
  59.             $connection->executeStatement('ALTER TABLE media DROP COLUMN acrisSurchargeDiscounts');
  60.         }
  61.         if($this->columnExists($connection, 'rule', 'discountSurchargeDiscount')) {
  62.             $connection->executeStatement('ALTER TABLE rule DROP COLUMN discountSurchargeDiscount');
  63.         }
  64.         if($this->columnExists($connection, 'rule', 'surchargeDiscount')) {
  65.             $connection->executeStatement('ALTER TABLE rule DROP COLUMN surchargeDiscount');
  66.         }
  67.         if($this->columnExists($connection, 'sales_channel', 'surchargeDiscount')) {
  68.             $connection->executeStatement('ALTER TABLE sales_channel DROP COLUMN surchargeDiscount');
  69.         }
  71.         $connection->executeStatement('DROP TABLE IF EXISTS acris_rule_s_d_discount_rules');
  72.         $connection->executeStatement('DROP TABLE IF EXISTS acris_rule_s_d_delivery_rules');
  73.         $connection->executeStatement('DROP TABLE IF EXISTS acris_rule_s_d_sales_channel');
  74.         $connection->executeStatement('DROP TABLE IF EXISTS acris_rule_s_d_rules');
  75.         $connection->executeStatement('DROP TABLE IF EXISTS acris_rule_s_d_translation');
  76.         $connection->executeStatement('DROP TABLE IF EXISTS acris_rule_s_d');
  77.     }
  79.     protected function columnExists(Connection $connection, string $table, string $column): bool
  80.     {
  81.         $exists = $connection->fetchOne(
  82.             'SHOW COLUMNS FROM `' . $table . '` WHERE `Field` LIKE :column',
  83.             ['column' => $column]
  84.         );
  86.         return !empty($exists);
  87.     }
  89.     private function insertDefaultMailTemplate(Context $context): void
  90.     {
  91.         $mailTemplateTypeRepository = $this->container->get('mail_template_type.repository');
  93.         $mailTemplateTypePartialDeliverySearchResult = $mailTemplateTypeRepository->searchIds((new Criteria())->addFilter(new EqualsFilter('technicalName', self::DEFAULT_MAIL_TEMPLATE_TYPE_SURCHARGE_DISCOUNT)), $context);
  94.         if(empty($mailTemplateTypePartialDeliverySearchResult->firstId())) {
  95.             $mailTemplateTypePartialDeliveryId = Uuid::randomHex();
  96.             $mailTemplatePartialDeliveryId = Uuid::randomHex();
  97.             $mailTemplateTypePartialDeliveryData = [
  98.                 'id' => $mailTemplateTypePartialDeliveryId,
  99.                 'technicalName' => self::DEFAULT_MAIL_TEMPLATE_TYPE_SURCHARGE_DISCOUNT,
  100.                 'availableEntities' => [ "order" => "order", "salesChannel" =>"sales_channel", "editOrderUrl" =>null ],
  101.                 'translations' => [
  102.                     'de-DE' => [
  103.                         'name' => 'ACRIS Zuschläge und Rabatte'
  104.                     ],
  105.                     'en-GB' => [
  106.                         'name' => 'ACRIS Surcharge Discount'
  107.                     ],
  108.                     [
  109.                         'name' => 'Surcharge Discount',
  110.                         'languageId' => Defaults::LANGUAGE_SYSTEM
  111.                     ]
  112.                 ],
  113.                 'mailTemplates' => [
  114.                     [
  115.                         'id' => $mailTemplatePartialDeliveryId,
  116.                         'systemDefault' => true,
  117.                         'translations' => [
  118.                             'de-DE' => [
  119.                                 'senderName' => '{{ salesChannel.name }}',
  120.                                 'subject' => 'Bestellbestätigung - ACRIS Zuschläge und Rabatte',
  121.                                 'description' => 'Standard-E-Mail-Vorlage für ACRIS Zuschläge und Rabatte.',
  122.                                 'contentHtml' => file_get_contents($this->path . '/Resources/mail-template/html/de-DE/order-confirmation.html.twig'),
  123.                                 'contentPlain' => 'Kein Inhalt.'
  124.                             ],
  125.                             'en-GB' => [
  126.                                 'senderName' => '{{ salesChannel.name }}',
  127.                                 'subject' => 'Order confirmation - ACRIS Surcharge and Discounts',
  128.                                 'description' => 'Default E-mail template for ACRIS surcharge and discounts.',
  129.                                 'contentHtml' => file_get_contents($this->path . '/Resources/mail-template/html/en-GB/order-confirmation.html.twig'),
  130.                                 'contentPlain' => 'No content.'
  131.                             ],
  132.                             [
  133.                                 'senderName' => '{{ salesChannel.name }}',
  134.                                 'subject' => 'Order confirmation - ACRIS Surcharge and Discounts',
  135.                                 'description' => 'Default E-mail template for ACRIS surcharge and discounts.',
  136.                                 'contentHtml' => file_get_contents($this->path . '/Resources/mail-template/html/en-GB/order-confirmation.html.twig'),
  137.                                 'contentPlain' => 'No content.',
  138.                                 'languageId' => Defaults::LANGUAGE_SYSTEM
  139.                             ]
  140.                         ],
  141.                     ]
  142.                 ]
  143.             ];
  144.             $mailTemplateTypeRepository->upsert([$mailTemplateTypePartialDeliveryData], $context);
  145.         }
  146.     }
  148.     private function removeDefaultMailTemplate(Context $context): void
  149.     {
  150.         $mailTemplateTypeRepository = $this->container->get('mail_template_type.repository');
  151.         $mailTemplateTypePartialDeliverySearchResult = $mailTemplateTypeRepository->searchIds((new Criteria())->addFilter(new EqualsFilter('technicalName', self::DEFAULT_MAIL_TEMPLATE_TYPE_SURCHARGE_DISCOUNT)), $context);
  152.         if($mailTemplateTypePartialDeliverySearchResult->firstId()) {
  153.             $mailTemplateRepository = $this->container->get('mail_template.repository');
  154.             $mailTemplateSearchResult = $mailTemplateRepository->searchIds((new Criteria())->addFilter(new EqualsFilter('mailTemplateTypeId', $mailTemplateTypePartialDeliverySearchResult->firstId())), $context);
  155.             $templateAssigned = false;
  156.             foreach ($mailTemplateSearchResult->getIds() as $id) {
  157.                 $eventActionRepository = $this->container->get('event_action.repository');
  158.                 $eventActionSearchResult = $eventActionRepository->searchIds((new Criteria())->addFilter(new EqualsFilter('config.mail_template_id', $id)), $context);
  159.                 if($eventActionSearchResult->firstId() && $eventActionSearchResult->getTotal() > 0) $templateAssigned = true;
  160.             }
  162.             if ($templateAssigned !== true) {
  163.                 foreach ($mailTemplateSearchResult->getIds() as $id) {
  164.                     $mailTemplateRepository->delete([['id'=>$id]], $context);
  165.                 }
  166.                 $mailTemplateTypeRepository->delete([['id'=>$mailTemplateTypePartialDeliverySearchResult->firstId()]], $context);
  167.             }
  168.         }
  169.     }
  171.     private function updateExistingSurchargeDiscounts(Context $context): void
  172.     {
  173.         /** @var EntityRepositoryInterface $surchargeDiscountRepository */
  174.         $surchargeDiscountRepository = $this->container->get('acris_rule_s_d.repository');
  175.         $criteria = (new Criteria())->addFilter(new MultiFilter(MultiFilter::CONNECTION_AND, [
  176.             new EqualsFilter('price', null),
  177.             new NotFilter(NotFilter::CONNECTION_AND, [
  178.                 new EqualsFilter('value', null)
  179.             ])
  180.         ]));
  182.         $offset = self::DEFAULT_VALUE_OFFSET;
  183.         $load = true;
  185.         $updateData = [];
  187.         while ($load) {
  188.             $criteria->setOffset($offset);
  189.             $searchResult = $surchargeDiscountRepository->search($criteria, $context);
  191.             if ($searchResult->getTotal() > 0) {
  192.                 /** @var SurchargeDiscountEntity $surchargeDiscount */
  193.                 foreach ($searchResult->getEntities()->getElements() as $surchargeDiscount) {
  194.                     $updateData[] = [
  195.                         'id' => $surchargeDiscount->getId(),
  196.                         'price' => [Defaults::CURRENCY => [
  197.                             'currencyId' => Defaults::CURRENCY,
  198.                             'net' => $surchargeDiscount->getValue(),
  199.                             'gross' => $surchargeDiscount->getValue(),
  200.                             'linked' => true
  201.                         ]]
  202.                     ];
  203.                 }
  204.             }
  206.             $offset += self::DEFAULT_CRITERIA_LIMIT;
  207.             if ($searchResult->getTotal() < self::DEFAULT_CRITERIA_LIMIT) $load = false;
  208.         }
  210.         if (!empty($updateData)) {
  211.             $surchargeDiscountRepository->update($updateData, $context);
  212.         }
  213.     }
  214. }