-
Notifications
You must be signed in to change notification settings - Fork 47
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch '2.4-develop' into ACQE-7152-mainline-functional-tests-d…
…eployment
- Loading branch information
Showing
20 changed files
with
731 additions
and
137 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
163 changes: 163 additions & 0 deletions
163
app/code/Magento/Catalog/Model/ResourceModel/Product/Price/BasePrice.php
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,163 @@ | ||
| <?php | ||
| /** | ||
| * Copyright 2024 Adobe | ||
| * All Rights Reserved. | ||
| */ | ||
| declare(strict_types=1); | ||
|
|
||
| namespace Magento\Catalog\Model\ResourceModel\Product\Price; | ||
|
|
||
| use Magento\Catalog\Api\Data\ProductInterface; | ||
| use Magento\Catalog\Model\ResourceModel\Attribute; | ||
| use Magento\Framework\DataObject; | ||
| use Magento\Framework\EntityManager\MetadataPool; | ||
| use Magento\Framework\Exception\CouldNotSaveException; | ||
|
|
||
| class BasePrice | ||
| { | ||
| /** | ||
| * Price storage table. | ||
| * | ||
| * @var string | ||
| */ | ||
| private $table = 'catalog_product_entity_decimal'; | ||
|
|
||
| /** | ||
| * @param Attribute $attributeResource | ||
| * @param MetadataPool $metadataPool | ||
| * @param int $attributeId | ||
| */ | ||
| public function __construct( | ||
| private readonly Attribute $attributeResource, | ||
| private readonly MetadataPool $metadataPool, | ||
| private readonly int $attributeId = 0, | ||
| ) { | ||
| } | ||
|
|
||
| /** | ||
| * Get prices that will need update | ||
| * | ||
| * @param array $priceBunch | ||
| * @return array | ||
| * @throws \Exception | ||
| */ | ||
| private function getExistingPrices(array $priceBunch): array | ||
| { | ||
| $linkField = $this->getEntityLinkField(); | ||
| $connection = $this->attributeResource->getConnection(); | ||
|
|
||
| return $connection->fetchAll( | ||
| $connection->select() | ||
| ->from($this->attributeResource->getTable($this->table)) | ||
| ->where('attribute_id = ?', $this->attributeId) | ||
| ->where('store_id IN (?)', array_unique(array_column($priceBunch, 'store_id'))) | ||
| ->where($linkField . ' IN (?)', array_unique(array_column($priceBunch, $linkField))) | ||
| ); | ||
| } | ||
|
|
||
| /** | ||
| * Get prices that will need update | ||
| * | ||
| * @param DataObject $priceBunchesObject | ||
| * @param array $existingPrices | ||
| * @return array | ||
| * @throws \Exception | ||
| */ | ||
| private function getUpdatablePrices(DataObject $priceBunchesObject, array $existingPrices): array | ||
| { | ||
| $updateData = []; | ||
| $priceBunches = $priceBunchesObject->getPrices(); | ||
| $linkField = $this->getEntityLinkField(); | ||
| foreach ($existingPrices as $existingPrice) { | ||
| foreach ($priceBunches as $key => $price) { | ||
| if ($price[$linkField] == $existingPrice[$linkField] && | ||
| $price['store_id'] == $existingPrice['store_id'] && | ||
| $existingPrice['attribute_id'] == $price['attribute_id'] | ||
| ) { | ||
| $priceBunches[$key]['value_id'] = $existingPrice['value_id']; | ||
| $uniqueKey = $price[$linkField].'_'.$price['attribute_id'].'_'.$price['store_id']; | ||
| $updateData[$uniqueKey] = $priceBunches[$key]; | ||
| } | ||
| } | ||
| } | ||
|
|
||
| $priceBunchesObject->setPrices($priceBunches); | ||
|
|
||
| return $updateData; | ||
| } | ||
|
|
||
| /** | ||
| * Get prices that will need insert | ||
| * | ||
| * @param DataObject $priceBunchesObject | ||
| * @return array | ||
| * @throws \Exception | ||
| */ | ||
| private function getInsertablePrices(DataObject $priceBunchesObject): array | ||
| { | ||
| $insertData = []; | ||
| $priceBunches = $priceBunchesObject->getPrices(); | ||
| $linkField = $this->getEntityLinkField(); | ||
| foreach ($priceBunches as $price) { | ||
| if (!isset($price['value_id'])) { | ||
| $uniqueKey = $price[$linkField].'_'.$price['attribute_id'].'_'.$price['store_id']; | ||
| $insertData[$uniqueKey] = $price; | ||
| } | ||
| } | ||
| return $insertData; | ||
| } | ||
|
|
||
| /** | ||
| * Update existing prices | ||
| * | ||
| * @param array $priceBunches | ||
| * @return void | ||
| * @throws \Exception | ||
| */ | ||
| public function update(array $priceBunches): void | ||
| { | ||
| $priceBunchesObject = new DataObject(['prices' => $priceBunches]); | ||
| $existingPrices = $this->getExistingPrices($priceBunches); | ||
| $updateData = $this->getUpdatablePrices($priceBunchesObject, $existingPrices); | ||
| $insertData = $this->getInsertablePrices($priceBunchesObject); | ||
|
|
||
| $connection = $this->attributeResource->getConnection(); | ||
| $connection->beginTransaction(); | ||
| try { | ||
| if (!empty($updateData)) { | ||
| foreach ($updateData as $row) { | ||
| $this->attributeResource->getConnection()->update( | ||
| $this->attributeResource->getTable($this->table), | ||
| ['value' => $row['value']], | ||
| ['value_id = ?' => (int)$row['value_id']] | ||
| ); | ||
| } | ||
| } | ||
| if (!empty($insertData)) { | ||
| $this->attributeResource->getConnection()->insertMultiple( | ||
| $this->attributeResource->getTable($this->table), | ||
| $insertData | ||
| ); | ||
| } | ||
| $connection->commit(); | ||
| } catch (\Exception $e) { | ||
| $connection->rollBack(); | ||
| throw new CouldNotSaveException( | ||
| __('Could not save Prices.'), | ||
| $e | ||
| ); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Get link field | ||
| * | ||
| * @return string | ||
| * @throws \Exception | ||
| */ | ||
| private function getEntityLinkField(): string | ||
| { | ||
| return $this->metadataPool->getMetadata(ProductInterface::class) | ||
| ->getLinkField(); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.