vendor/shopware/core/System/Country/CountryTaxFreeDeprecationUpdater.php line 43

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\System\Country;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\RetryableQuery;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  8. use Shopware\Core\Framework\Feature;
  9. use Shopware\Core\Framework\Log\Package;
  10. use Shopware\Core\Framework\Uuid\Uuid;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. /**
  14. * @deprecated tag:v6.5.0 - reason:remove-subscriber - Will be remove on version 6.5.0
  15. */
  16. #[Package('core')]
  17. class CountryTaxFreeDeprecationUpdater implements EventSubscriberInterface
  18. {
  19. private bool $blueGreenEnabled;
  21. private Connection $connection;
  23. /**
  24. * @internal
  25. */
  26. public function __construct(bool $blueGreenEnabled, Connection $connection)
  27. {
  28. $this->blueGreenEnabled = $blueGreenEnabled;
  29. $this->connection = $connection;
  30. }
  32. public static function getSubscribedEvents(): array
  33. {
  34. if (Feature::isActive('v6.5.0.0')) {
  35. return [];
  36. }
  38. return [
  39. CountryEvents::COUNTRY_WRITTEN_EVENT => 'updated',
  40. ];
  41. }
  43. public function updated(EntityWrittenEvent $event): void
  44. {
  45. if ($this->blueGreenEnabled) {
  46. return;
  47. }
  49. $taxFreePort = [];
  50. $companyTaxFreePort = [];
  51. $taxFreeBackport = [];
  52. $companyTaxFreeBackport = [];
  53. foreach ($event->getPayloads() as $payload) {
  54. if (\array_key_exists('customerTax', $payload)) {
  55. $taxFreeBackport[] = $payload['id'];
  56. } elseif (\array_key_exists('taxFree', $payload)) {
  57. $taxFreePort[] = $payload['id'];
  58. }
  60. if (\array_key_exists('companyTax', $payload)) {
  61. $companyTaxFreeBackport[] = $payload['id'];
  62. } elseif (\array_key_exists('companyTaxFree', $payload)) {
  63. $companyTaxFreePort[] = $payload['id'];
  64. }
  65. }
  67. $this->port($taxFreePort, CountryDefinition::TYPE_CUSTOMER_TAX_FREE);
  68. $this->port($companyTaxFreePort, CountryDefinition::TYPE_COMPANY_TAX_FREE);
  69. $this->backport($taxFreeBackport, CountryDefinition::TYPE_CUSTOMER_TAX_FREE);
  70. $this->backport($companyTaxFreeBackport, CountryDefinition::TYPE_COMPANY_TAX_FREE);
  71. }
  73. private function port(array $ids, string $taxFreeType): void
  74. {
  75. $ids = array_unique(array_filter($ids));
  77. if (empty($ids)) {
  78. return;
  79. }
  81. $countries = $this->connection->fetchAllAssociative(
  82. 'SELECT id, tax_free, company_tax_free, customer_tax, company_tax FROM country WHERE id IN (:ids)',
  83. ['ids' => Uuid::fromHexToBytesList($ids)],
  84. ['ids' => Connection::PARAM_STR_ARRAY]
  85. );
  87. if ($taxFreeType === CountryDefinition::TYPE_CUSTOMER_TAX_FREE) {
  88. $query = 'UPDATE `country`
  89. SET `customer_tax` = JSON_OBJECT("enabled", :isTaxFree, "currencyId", :currencyId, "amount", :amount)
  90. WHERE id = :countryId;';
  91. } else {
  92. $query = 'UPDATE `country`
  93. SET `company_tax` = JSON_OBJECT("enabled", :isTaxFree, "currencyId", :currencyId, "amount", :amount)
  94. WHERE id = :countryId;';
  95. }
  97. $update = new RetryableQuery($this->connection, $this->connection->prepare($query));
  99. foreach ($countries as $country) {
  100. if ($taxFreeType === CountryDefinition::TYPE_CUSTOMER_TAX_FREE) {
  101. $tax = json_decode($country['customer_tax'], true);
  102. $isTaxFree = $country['tax_free'];
  103. } else {
  104. $tax = json_decode($country['company_tax'], true);
  105. $isTaxFree = $country['company_tax_free'];
  106. }
  108. if ((bool) $isTaxFree === (bool) $tax['enabled']) {
  109. continue;
  110. }
  112. $update->execute([
  113. 'countryId' => $country['id'],
  114. 'isTaxFree' => $isTaxFree,
  115. 'currencyId' => $tax['currencyId'],
  116. 'amount' => $tax['amount'],
  117. ]);
  118. }
  119. }
  121. private function backport(array $ids, string $taxFreeType): void
  122. {
  123. $ids = array_unique(array_filter($ids));
  125. if (empty($ids)) {
  126. return;
  127. }
  129. $countries = $this->connection->fetchAllAssociative(
  130. 'SELECT id, tax_free, company_tax_free, customer_tax, company_tax FROM country WHERE id IN (:ids)',
  131. ['ids' => Uuid::fromHexToBytesList($ids)],
  132. ['ids' => Connection::PARAM_STR_ARRAY]
  133. );
  135. if ($taxFreeType === CountryDefinition::TYPE_CUSTOMER_TAX_FREE) {
  136. $query = 'UPDATE `country` SET `tax_free` = :isTaxFree WHERE id = :countryId;';
  137. } else {
  138. $query = 'UPDATE `country` SET `company_tax_free` = :isTaxFree WHERE id = :countryId;';
  139. }
  141. $update = new RetryableQuery($this->connection, $this->connection->prepare($query));
  143. foreach ($countries as $country) {
  144. if ($taxFreeType === CountryDefinition::TYPE_CUSTOMER_TAX_FREE) {
  145. $tax = json_decode($country['customer_tax'], true);
  146. $isTaxFree = $country['tax_free'];
  147. } else {
  148. $tax = json_decode($country['company_tax'], true);
  149. $isTaxFree = $country['company_tax_free'];
  150. }
  152. if ((bool) $isTaxFree === (bool) $tax['enabled']) {
  153. continue;
  154. }
  156. $update->execute([
  157. 'countryId' => $country['id'],
  158. 'isTaxFree' => $tax['enabled'],
  159. ]);
  160. }
  161. }
  162. }