Fulltext.php

Go to the documentation of this file.

<?php
namespace Magento\CatalogSearch\Model\ResourceModel;

use Magento\Catalog\Api\Data\ProductInterface;
use Magento\Framework\App\ObjectManager;
use Magento\Framework\EntityManager\MetadataPool;

class Fulltext extends \Magento\Framework\Model\ResourceModel\Db\AbstractDb
{
    protected $_eventManager;

    private $metadataPool;

    public function __construct(
        \Magento\Framework\Model\ResourceModel\Db\Context $context,
        \Magento\Framework\Event\ManagerInterface $eventManager,
        $connectionName = null,
        MetadataPool $metadataPool = null
    ) {
        $this->_eventManager = $eventManager;
        $this->metadataPool = $metadataPool ? : ObjectManager::getInstance()->get(MetadataPool::class);
        parent::__construct($context, $connectionName);
    }

    protected function _construct()
    {
        $this->_init('catalogsearch_fulltext', 'product_id');
    }

    public function resetSearchResults()
    {
        $connection = $this->getConnection();
        $connection->update($this->getTable('search_query'), ['is_processed' => 0], ['is_processed != 0']);
        $this->_eventManager->dispatch('catalogsearch_reset_search_result');
        return $this;
    }

    public function resetSearchResultsByStore($storeId)
    {
        $storeId = (int) $storeId;
        $connection = $this->getConnection();
        $connection->update(
            $this->getTable('search_query'),
            ['is_processed' => 0],
            ['is_processed != ?' => 0, 'store_id = ?' => $storeId]
        );
        $this->_eventManager->dispatch('catalogsearch_reset_search_result', ['store_id' => $storeId]);
        return $this;
    }

    public function getRelationsByChild($childIds)
    {
        $connection = $this->getConnection();
        $linkField = $this->metadataPool->getMetadata(ProductInterface::class)->getLinkField();
        $select = $connection
            ->select()
            ->from(
                ['relation' => $this->getTable('catalog_product_relation')],
                []
            )->distinct(true)
            ->join(
                ['cpe' => $this->getTable('catalog_product_entity')],
                'cpe.' . $linkField . ' = relation.parent_id',
                ['cpe.entity_id']
            )->where(
                'relation.child_id IN (?)',
                $childIds
            );

        return $connection->fetchCol($select);
    }
}