src/Core/Content/Rule/DataAbstractionLayer/RulePayloadUpdater.php line 93

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