custom/plugins/SwagPayPal/src/Pos/MessageQueue/Handler/CloneVisibilityHandler.php line 20

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) shopware AG <info@shopware.com>
  4.  * For the full copyright and license information, please view the LICENSE
  5.  * file that was distributed with this source code.
  6.  */
  8. namespace Swag\PayPal\Pos\MessageQueue\Handler;
  10. use Psr\Log\LoggerInterface;
  11. use Shopware\Core\Content\Product\Aggregate\ProductVisibility\ProductVisibilityCollection;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  15. use Swag\PayPal\Pos\MessageQueue\Handler\Sync\AbstractSyncHandler;
  16. use Swag\PayPal\Pos\MessageQueue\Message\AbstractSyncMessage;
  17. use Swag\PayPal\Pos\MessageQueue\Message\CloneVisibilityMessage;
  18. use Swag\PayPal\Pos\Run\RunService;
  20. class CloneVisibilityHandler extends AbstractSyncHandler
  21. {
  22.     private EntityRepositoryInterface $productVisibilityRepository;
  24.     public function __construct(
  25.         RunService $runService,
  26.         LoggerInterface $logger,
  27.         EntityRepositoryInterface $productVisibilityRepository
  28.     ) {
  29.         parent::__construct($runService, $logger);
  30.         $this->productVisibilityRepository = $productVisibilityRepository;
  31.     }
  33.     /**
  34.      * @param CloneVisibilityMessage $message
  35.      */
  36.     public function sync(AbstractSyncMessage $message): void
  37.     {
  38.         $context = $message->getContext();
  40.         $criteria = new Criteria();
  41.         $criteria->addFilter(new EqualsFilter('salesChannelId', $message->getFromSalesChannelId()));
  42.         $criteria->setLimit($message->getLimit());
  43.         $criteria->setOffset($message->getOffset());
  45.         /** @var ProductVisibilityCollection $existingVisibilities */
  46.         $existingVisibilities = $this->productVisibilityRepository->search($criteria, $context)->getEntities();
  48.         $updates = [];
  49.         foreach ($existingVisibilities as $existingVisibility) {
  50.             $updates[] = [
  51.                 'productId' => $existingVisibility->getProductId(),
  52.                 'salesChannelId' => $message->getToSalesChannelId(),
  53.                 'visibility' => $existingVisibility->getVisibility(),
  54.             ];
  55.         }
  57.         $this->productVisibilityRepository->upsert($updates, $context);
  58.     }
  60.     public static function getHandledMessages(): iterable
  61.     {
  62.         return [
  63.             CloneVisibilityMessage::class,
  64.         ];
  65.     }
  66. }