vendor/shopware/core/Content/Rule/DataAbstractionLayer/RulePayloadUpdater.php line 96

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Rule\DataAbstractionLayer;
  5. use Doctrine\DBAL\ArrayParameterType;
  6. use Doctrine\DBAL\Connection;
  7. use Shopware\Core\Content\Rule\DataAbstractionLayer\Indexing\ConditionTypeNotFound;
  8. use Shopware\Core\Framework\App\Event\AppScriptConditionEvents;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\FetchModeHelper;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\RetryableQuery;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Shopware\Core\Framework\Log\Package;
  13. use Shopware\Core\Framework\Rule\Collector\RuleConditionRegistry;
  14. use Shopware\Core\Framework\Rule\Container\AndRule;
  15. use Shopware\Core\Framework\Rule\Container\ContainerInterface;
  16. use Shopware\Core\Framework\Rule\Rule;
  17. use Shopware\Core\Framework\Rule\ScriptRule;
  18. use Shopware\Core\Framework\Uuid\Uuid;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. /**
  22.  * @internal
  23.  */
  24. #[Package('business-ops')]
  25. class RulePayloadUpdater implements EventSubscriberInterface
  26. {
  27.     /**
  28.      * @internal
  29.      */
  30.     public function __construct(
  31.         private readonly Connection $connection,
  32.         private readonly RuleConditionRegistry $ruleConditionRegistry
  33.     ) {
  34.     }
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [
  39.             AppScriptConditionEvents::APP_SCRIPT_CONDITION_WRITTEN_EVENT => 'updatePayloads',
  40.         ];
  41.     }
  43.     /**
  44.      * @param list<string> $ids
  45.      *
  46.      * @return array<string, array{payload: string|null, invalid: bool}>
  47.      */
  48.     public function update(array $ids): array
  49.     {
  50.         $conditions = $this->connection->fetchAllAssociative(
  51.             'SELECT LOWER(HEX(rc.rule_id)) as array_key, rc.*, rs.script, rs.identifier, rs.updated_at as lastModified
  52.             FROM rule_condition rc
  53.             LEFT JOIN app_script_condition rs ON rc.script_id = rs.id AND rs.active = 1
  54.             WHERE rc.rule_id IN (:ids)
  55.             ORDER BY rc.rule_id, rc.position',
  56.             ['ids' => Uuid::fromHexToBytesList($ids)],
  57.             ['ids' => ArrayParameterType::STRING]
  58.         );
  60.         $rules = FetchModeHelper::group($conditions);
  62.         $update = new RetryableQuery(
  63.             $this->connection,
  64.             $this->connection->prepare('UPDATE `rule` SET payload = :payload, invalid = :invalid WHERE id = :id')
  65.         );
  67.         $updated = [];
  68.         /** @var string $id */
  69.         foreach ($rules as $id => $rule) {
  70.             $invalid = false;
  71.             $serialized = null;
  73.             try {
  74.                 $nested = $this->buildNested($rule, null);
  76.                 //ensure the root rule is an AndRule
  77.                 $nested = new AndRule($nested);
  79.                 $serialized = serialize($nested);
  80.             } catch (ConditionTypeNotFound) {
  81.                 $invalid = true;
  82.             } finally {
  83.                 $update->execute([
  84.                     'id' => Uuid::fromHexToBytes($id),
  85.                     'payload' => $serialized,
  86.                     'invalid' => (int) $invalid,
  87.                 ]);
  88.             }
  90.             $updated[$id] = ['payload' => $serialized, 'invalid' => $invalid];
  91.         }
  93.         return $updated;
  94.     }
  96.     public function updatePayloads(EntityWrittenEvent $event): void
  97.     {
  98.         $ruleIds = $this->connection->fetchFirstColumn(
  99.             'SELECT DISTINCT rc.rule_id
  100.                 FROM rule_condition rc
  101.                 INNER JOIN app_script_condition rs ON rc.script_id = rs.id
  102.                 WHERE rs.id IN (:ids)',
  103.             ['ids' => Uuid::fromHexToBytesList(array_values($event->getIds()))],
  104.             ['ids' => ArrayParameterType::STRING]
  105.         );
  107.         if (empty($ruleIds)) {
  108.             return;
  109.         }
  111.         $this->update(Uuid::fromBytesToHexList($ruleIds));
  112.     }
  114.     /**
  115.      * @param array<string, mixed> $rules
  116.      *
  117.      * @return list<Rule>
  118.      */
  119.     private function buildNested(array $rules, ?string $parentId): array
  120.     {
  121.         $nested = [];
  122.         foreach ($rules as $rule) {
  123.             if ($rule['parent_id'] !== $parentId) {
  124.                 continue;
  125.             }
  127.             if (!$this->ruleConditionRegistry->has($rule['type'])) {
  128.                 throw new ConditionTypeNotFound($rule['type']);
  129.             }
  131.             $ruleClass = $this->ruleConditionRegistry->getRuleClass($rule['type']);
  132.             $object = new $ruleClass();
  134.             if ($object instanceof ScriptRule) {
  135.                 $object->assign([
  136.                     'script' => $rule['script'] ?? '',
  137.                     'lastModified' => $rule['lastModified'] ? new \DateTimeImmutable($rule['lastModified']) : null,
  138.                     'identifier' => $rule['identifier'] ?? null,
  139.                     'values' => $rule['value'] ? json_decode((string) $rule['value'], true, 512, \JSON_THROW_ON_ERROR) : [],
  140.                 ]);
  142.                 $nested[] = $object;
  144.                 continue;
  145.             }
  147.             if ($rule['value'] !== null) {
  148.                 $object->assign(json_decode((string) $rule['value'], true, 512, \JSON_THROW_ON_ERROR));
  149.             }
  151.             if ($object instanceof ContainerInterface) {
  152.                 $children = $this->buildNested($rules, $rule['id']);
  153.                 foreach ($children as $child) {
  154.                     $object->addRule($child);
  155.                 }
  156.             }
  158.             $nested[] = $object;
  159.         }
  161.         return $nested;
  162.     }
  163. }