productModelRepository = $productModelRepository; $this->connection = $connection; $this->eventDispatcher = $eventDispatcher; $this->clearer = $clearer; } public function forAttributeCodes(array $attributeCodes, array $productModelIdentifiers): void { $this->removeValuesForAttributeCodes($attributeCodes, $productModelIdentifiers); $this->dispatchProductModelSaveEvents($productModelIdentifiers); $this->clearer->clear(); } private function removeValuesForAttributeCodes(array $attributeCodes, array $productModelIdentifiers): void { $paths = implode( ',', array_map(fn ($attributeCode) => $this->connection->quote(sprintf('$."%s"', $attributeCode)), $attributeCodes) ); $this->connection->executeQuery( << $productModelIdentifiers, ], [ 'identifiers' => Connection::PARAM_STR_ARRAY, ] ); } private function dispatchProductModelSaveEvents($productModelIdentifiers): void { $productModels = $this->productModelRepository->findBy(['code' => $productModelIdentifiers]); foreach ($productModels as $productModel) { $this->eventDispatcher->dispatch( new GenericEvent($productModel, [ 'unitary' => false, ]), StorageEvents::POST_SAVE ); } $this->eventDispatcher->dispatch( new GenericEvent($productModels, [ 'unitary' => false, ]), StorageEvents::POST_SAVE_ALL ); } }