SelectProcessor.php

Go to the documentation of this file.

<?php
namespace Magento\Catalog\Model\ResourceModel\Product\Website;

use Magento\Catalog\Model\ResourceModel\Product\BaseSelectProcessorInterface;
use Magento\Framework\DB\Select;
use Magento\Framework\EntityManager\MetadataPool;
use Magento\Catalog\Api\Data\ProductInterface;
use Magento\Framework\App\ResourceConnection;
use Magento\Store\Model\StoreManagerInterface;

class SelectProcessor implements BaseSelectProcessorInterface
{
    private $resource;

    private $metadataPool;

    private $storeManager;

    public function __construct(
        MetadataPool $metadataPool,
        ResourceConnection $resource,
        StoreManagerInterface $storeManager
    ) {
        $this->metadataPool = $metadataPool;
        $this->resource = $resource;
        $this->storeManager = $storeManager;
    }

    public function process(Select $select)
    {
        $linkField = $this->metadataPool->getMetadata(ProductInterface::class)->getLinkField();
        $select->joinInner(
            ['pw' => $this->resource->getTableName('catalog_product_website')],
            'pw.product_id = ' . BaseSelectProcessorInterface::PRODUCT_TABLE_ALIAS . '.' . $linkField
            . ' AND pw.website_id = ' . $this->storeManager->getWebsite()->getId(),
            []
        );

        return $select;
    }
}