custom/plugins/SwagPublisher/src/Common/UpdateChangeDetector.php line 37

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) shopware AG <info@shopware.com>
  4.  * For the full copyright and license information, please view the LICENSE
  5.  * file that was distributed with this source code.
  6.  */
  8. namespace SwagPublisher\Common;
  10. use Doctrine\DBAL\Connection;
  11. use Doctrine\DBAL\Platforms\MariaDb1027Platform;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Field\JsonField;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\UpdateCommand;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class UpdateChangeDetector implements EventSubscriberInterface
  18. {
  19.     private Connection $connection;
  21.     /**
  22.      * @var string[]
  23.      */
  24.     private array $activeEntities;
  26.     public function __construct(Connection $connection, array $activeEntities = [])
  27.     {
  28.         $this->connection = $connection;
  29.         $this->activeEntities = $activeEntities;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [PreWriteValidationEvent::class => 'detectChanges'];
  35.     }
  37.     public function detectChanges(PreWriteValidationEvent $event): void
  38.     {
  39.         $commands = $event->getCommands();
  40.         $extension = UpdateChangeContextExtension::extract($event->getContext());
  42.         foreach ($commands as $command) {
  43.             if (!$command instanceof UpdateCommand) {
  44.                 continue;
  45.             }
  47.             if (!\in_array($command->getDefinition()->getClass(), $this->activeEntities, true)) {
  48.                 continue;
  49.             }
  51.             $extension->addResult(
  52.                 $command,
  53.                 $this->containsChanges($command)
  54.             );
  55.         }
  56.     }
  58.     private function containsChanges(UpdateCommand $command): bool
  59.     {
  60.         $payload = $command->getPayload();
  62.         unset($payload['updated_at']);
  64.         $conditions = [];
  65.         $values = [];
  66.         $data = \array_merge($command->getPrimaryKey(), $payload);
  67.         $fields = $command->getDefinition()->getFields();
  69.         $isMariaDb = $this->connection->getDatabasePlatform() instanceof MariaDb1027Platform;
  71.         foreach ($data as $key => $value) {
  72.             $field = $fields->getByStorageName($key);
  74.             if ($field === null) {
  75.                 continue;
  76.             }
  78.             if (!$isMariaDb && $field instanceof JsonField) {
  79.                 $conditions[] = "`$key` = CAST(:$key AS JSON)";
  80.             } else {
  81.                 $conditions[] = "`$key` = :$key";
  82.             }
  84.             $values[$key] = $value;
  85.         }
  87.         $query = \sprintf(
  88.             'SELECT 1 AS id FROM `%s` WHERE %s LIMIT 1',
  89.             $command->getDefinition()->getEntityName(),
  90.             \implode(' AND ', $conditions)
  91.         );
  93.         return $this->connection->fetchColumn($query, $values) !== '1';
  94.     }
  95. }