mirror of
https://github.com/bdnugget/magento2.git
synced 2026-11-07 09:17:35 +00:00
82 lines
2.2 KiB
PHP
82 lines
2.2 KiB
PHP
<?php
|
|
/**
|
|
* Copyright © Magento, Inc. All rights reserved.
|
|
* See COPYING.txt for license details.
|
|
*/
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace Magento\Downloadable\Model\Sample;
|
|
|
|
use Magento\Catalog\Api\Data\ProductInterface;
|
|
use Magento\Downloadable\Api\SampleRepositoryInterface as SampleRepository;
|
|
use Magento\Downloadable\Model\Product\Type;
|
|
use Magento\Framework\EntityManager\Operation\ExtensionInterface;
|
|
|
|
/**
|
|
* UpdateHandler for downloadable product samples
|
|
*/
|
|
class UpdateHandler implements ExtensionInterface
|
|
{
|
|
private const GLOBAL_SCOPE_ID = 0;
|
|
|
|
/**
|
|
* @var SampleRepository
|
|
*/
|
|
protected $sampleRepository;
|
|
|
|
/**
|
|
* @param SampleRepository $sampleRepository
|
|
*/
|
|
public function __construct(SampleRepository $sampleRepository)
|
|
{
|
|
$this->sampleRepository = $sampleRepository;
|
|
}
|
|
|
|
/**
|
|
* Update samples for downloadable product if exist
|
|
*
|
|
* @param ProductInterface $entity
|
|
* @param array $arguments
|
|
* @return ProductInterface
|
|
* @SuppressWarnings(PHPMD.UnusedFormalParameter)
|
|
*/
|
|
public function execute($entity, $arguments = []): ProductInterface
|
|
{
|
|
$samples = $entity->getExtensionAttributes()->getDownloadableProductSamples();
|
|
|
|
if ($samples && $entity->getTypeId() === Type::TYPE_DOWNLOADABLE) {
|
|
$this->updateSamples($entity, $samples);
|
|
}
|
|
|
|
return $entity;
|
|
}
|
|
|
|
/**
|
|
* Update product samples
|
|
*
|
|
* @param ProductInterface $entity
|
|
* @param array $samples
|
|
* @return void
|
|
*/
|
|
private function updateSamples(ProductInterface $entity, array $samples): void
|
|
{
|
|
$isGlobalScope = (int) $entity->getStoreId() === self::GLOBAL_SCOPE_ID;
|
|
$oldSamples = $this->sampleRepository->getList($entity->getSku());
|
|
|
|
$updatedSamples = [];
|
|
foreach ($samples as $sample) {
|
|
if ($sample->getId()) {
|
|
$updatedSamples[$sample->getId()] = true;
|
|
}
|
|
$this->sampleRepository->save($entity->getSku(), $sample, $isGlobalScope);
|
|
}
|
|
|
|
foreach ($oldSamples as $sample) {
|
|
if (!isset($updatedSamples[$sample->getId()])) {
|
|
$this->sampleRepository->delete($sample->getId());
|
|
}
|
|
}
|
|
}
|
|
}
|