custom/plugins/AcrisTaxCS/src/AcrisTaxCS.php line 16

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\Tax;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Content\Rule\Aggregate\RuleCondition\RuleConditionEntity;
  7. use Shopware\Core\Framework\Context;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  12. use Shopware\Core\Framework\Plugin;
  13. use Shopware\Core\Framework\Plugin\Context\UninstallContext;
  14. use Shopware\Core\Framework\Plugin\Context\UpdateContext;
  16. class AcrisTaxCS extends Plugin
  17. {
  18.     public function update(UpdateContext $updateContext): void
  19.     {
  20.         if(version_compare($updateContext->getCurrentPluginVersion(), '2.3.0', '<')
  21.             && version_compare($updateContext->getUpdatePluginVersion(), '2.3.0', '>=')) {
  22.             $this->replaceExistingRuleNames($updateContext->getContext());
  23.         }
  24.     }
  27.     public function uninstall(UninstallContext $context): void
  28.     {
  29.         if ($context->keepUserData()) {
  30.             return;
  31.         }
  32.         $this->cleanupDatabase();
  33.     }
  35.     private function cleanupDatabase(): void
  36.     {
  37.         $connection = $this->container->get(Connection::class);
  38.         $connection->executeUpdate('DROP TABLE IF EXISTS acris_tax_customer_group_rule');
  39.         $connection->executeUpdate('DROP TABLE IF EXISTS acris_tax_country_rule');
  41.         try {
  42.             $connection->executeUpdate('ALTER TABLE `customer_group` DROP `acrisRules`');
  43.             $connection->executeUpdate('ALTER TABLE `country` DROP `acrisRules`');
  44.         } catch (\Exception $e) { }
  45.     }
  47.     private function replaceExistingRuleNames(Context $context)
  48.     {
  49.         $ruleConditionRepository = $this->container->get('rule_condition.repository');
  51.         /** @var EntitySearchResult $existingRuleConditionSearchResult */
  52.         $existingRuleConditionSearchResult = $ruleConditionRepository->search((new Criteria())->addFilter(
  53.             new MultiFilter(MultiFilter::CONNECTION_OR, [
  54.                 new EqualsFilter('type', 'customerHasVatIdBillingRule'),
  55.                 new EqualsFilter('type', 'customerHasVatIdShippingRule')
  56.             ])
  57.         ), $context);
  59.         if ($existingRuleConditionSearchResult->count() <= 0) {
  60.             return;
  61.         }
  62.         $changedRuleConditions = [];
  63.         /** @var RuleConditionEntity $ruleConditionEntity */
  64.         foreach ($existingRuleConditionSearchResult->getElements() as $ruleConditionEntity) {
  65.             $value = $ruleConditionEntity->getValue();
  66.             if(!is_array($value)) {
  67.                 continue;
  68.             }
  69.             if(array_key_exists('customerHasVatIdBilling', $value)) {
  70.                 $value = ['customerHasVatId' => $value['customerHasVatIdBilling']];
  71.             } elseif(array_key_exists('customerHasVatIdShipping', $value)) {
  72.                 $value = ['customerHasVatId' => $value['customerHasVatIdShipping']];
  73.             } else {
  74.                 continue;
  75.             }
  77.             $changedRuleConditions[] = [
  78.                 'id' => $ruleConditionEntity->getId(),
  79.                 'type' => 'customerHasVatIdRule',
  80.                 'value' => $value
  81.             ];
  82.         }
  83.         if(!empty($changedRuleConditions)) {
  84.             $ruleConditionRepository->upsert($changedRuleConditions, $context);
  85.         }
  86.     }
  87. }