Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/old/vendor/magento/module-catalog-inventory/Model/Indexer/Stock/ |
<?php
/**
* Copyright © Magento, Inc. All rights reserved.
* See COPYING.txt for license details.
*/
namespace Magento\CatalogInventory\Model\Indexer\Stock;
use Magento\Framework\App\ObjectManager;
use Magento\Framework\App\ResourceConnection;
use Magento\Framework\EntityManager\MetadataPool;
/**
* Abstract action reindex class
*/
abstract class AbstractAction
{
/**
* Resource instance
*
* @var Resource
*/
protected $_resource;
/**
* @var \Magento\CatalogInventory\Model\ResourceModel\Indexer\StockFactory
*/
protected $_indexerFactory;
/**
* @var \Magento\Catalog\Model\Product\Type
*/
protected $_catalogProductType;
/**
* @var \Magento\Framework\DB\Adapter\AdapterInterface
*/
protected $_connection;
/**
* Stock Indexer models per product type
* Sorted by priority
*
* @var array
*/
protected $_indexers = [];
/**
* Flag that defines if need to use "_idx" index table suffix instead of "_tmp"
*
* @var bool
*/
protected $_isNeedUseIdxTable = false;
/**
* @var \Magento\Framework\Indexer\CacheContext
*/
private $cacheContext;
/**
* @var \Magento\Framework\Event\ManagerInterface
*/
private $eventManager;
/**
* @var CacheCleaner
*/
private $cacheCleaner;
/**
* @var MetadataPool
*/
private $metadataPool;
/**
* @param ResourceConnection $resource
* @param \Magento\CatalogInventory\Model\ResourceModel\Indexer\StockFactory $indexerFactory
* @param \Magento\Catalog\Model\Product\Type $catalogProductType
* @param \Magento\Framework\Indexer\CacheContext $cacheContext
* @param \Magento\Framework\Event\ManagerInterface $eventManager
* @param MetadataPool|null $metadataPool
*/
public function __construct(
ResourceConnection $resource,
\Magento\CatalogInventory\Model\ResourceModel\Indexer\StockFactory $indexerFactory,
\Magento\Catalog\Model\Product\Type $catalogProductType,
\Magento\Framework\Indexer\CacheContext $cacheContext,
\Magento\Framework\Event\ManagerInterface $eventManager,
MetadataPool $metadataPool = null
) {
$this->_resource = $resource;
$this->_indexerFactory = $indexerFactory;
$this->_catalogProductType = $catalogProductType;
$this->cacheContext = $cacheContext;
$this->eventManager = $eventManager;
$this->metadataPool = $metadataPool ?: ObjectManager::getInstance()->get(MetadataPool::class);
}
/**
* Execute action for given ids
*
* @param array|int $ids
*
* @return void
*/
abstract public function execute($ids);
/**
* Retrieve connection instance
*
* @return bool|\Magento\Framework\DB\Adapter\AdapterInterface
*/
protected function _getConnection()
{
if (null === $this->_connection) {
$this->_connection = $this->_resource->getConnection();
}
return $this->_connection;
}
/**
* Retrieve Stock Indexer Models per Product Type
*
* @return \Magento\CatalogInventory\Model\ResourceModel\Indexer\Stock\StockInterface[]
*/
protected function _getTypeIndexers()
{
if (empty($this->_indexers)) {
foreach ($this->_catalogProductType->getTypesByPriority() as $typeId => $typeInfo) {
$indexerClassName = isset($typeInfo['stock_indexer']) ? $typeInfo['stock_indexer'] : '';
$indexer = $this->_indexerFactory->create($indexerClassName)
->setTypeId($typeId)
->setIsComposite(!empty($typeInfo['composite']));
$this->_indexers[$typeId] = $indexer;
}
}
return $this->_indexers;
}
/**
* Returns table name for given entity
*
* @param string $entityName
* @return string
*/
protected function _getTable($entityName)
{
return $this->_resource->getTableName($entityName);
}
/**
* Retrieve product relations by children
*
* @param int|array $childIds
* @return array
*/
public function getRelationsByChild($childIds)
{
$connection = $this->_getConnection();
$linkField = $this->metadataPool->getMetadata(\Magento\Catalog\Api\Data\ProductInterface::class)
->getLinkField();
$select = $connection->select()->from(
['cpe' => $this->_getTable('catalog_product_entity')],
'entity_id'
)->join(
['relation' => $this->_getTable('catalog_product_relation')],
'relation.parent_id = cpe.' . $linkField
)->where('child_id IN(?)', $childIds, \Zend_Db::INT_TYPE);
return $connection->fetchCol($select);
}
/**
* Reindex all
*
* @return void
*/
public function reindexAll()
{
$this->useIdxTable(true);
$this->clearTemporaryIndexTable();
foreach ($this->_getTypeIndexers() as $indexer) {
$indexer->reindexAll();
}
$this->_syncData();
}
/**
* Synchronize data between index storage and original storage
*
* @return $this
*/
protected function _syncData()
{
$idxTableName = $this->_getIdxTable();
$tableName = $this->_getTable('cataloginventory_stock_status');
$this->_deleteOldRelations($tableName);
$columns = array_keys($this->_getConnection()->describeTable($idxTableName));
$select = $this->_getConnection()->select()->from($idxTableName, $columns);
$query = $select->insertFromSelect($tableName, $columns);
$this->_getConnection()->query($query);
return $this;
}
/**
* Delete old relations
*
* @param string $tableName
*
* @return void
*/
protected function _deleteOldRelations($tableName)
{
$select = $this->_getConnection()->select()
->from(['s' => $tableName])
->joinLeft(
['w' => $this->_getTable('catalog_product_website')],
's.product_id = w.product_id AND s.website_id = w.website_id',
[]
)
->where('w.product_id IS NULL');
$sql = $select->deleteFromSelect('s');
$this->_getConnection()->query($sql);
}
/**
* Refresh entities index
*
* @param array $productIds
* @return $this
*/
protected function _reindexRows($productIds = [])
{
if (!is_array($productIds)) {
$productIds = [$productIds];
}
$parentIds = $this->getRelationsByChild($productIds);
$productIds = $parentIds ? array_unique(array_merge($parentIds, $productIds)) : $productIds;
$this->getCacheCleaner()->clean($productIds, function () use ($productIds) {
$this->doReindex($productIds);
});
return $this;
}
/**
* Refresh entities index
*
* @param array $productIds
* @return void
*/
private function doReindex($productIds = [])
{
$connection = $this->_getConnection();
// retrieve product types by processIds
$select = $connection->select()
->from($this->_getTable('catalog_product_entity'), ['entity_id', 'type_id'])
->where('entity_id IN(?)', $productIds, \Zend_Db::INT_TYPE);
$pairs = $connection->fetchPairs($select);
$byType = [];
foreach ($pairs as $productId => $typeId) {
$byType[$typeId][$productId] = $productId;
}
$indexers = $this->_getTypeIndexers();
foreach ($indexers as $indexer) {
if (isset($byType[$indexer->getTypeId()])) {
$indexer->reindexEntity($byType[$indexer->getTypeId()]);
}
}
}
/**
* Get cache cleaner object
*
* @return CacheCleaner
*/
private function getCacheCleaner()
{
if (null === $this->cacheCleaner) {
$this->cacheCleaner = ObjectManager::getInstance()->get(CacheCleaner::class);
}
return $this->cacheCleaner;
}
/**
* Set or get what either "_idx" or "_tmp" suffixed temporary index table need to use
*
* @param bool|null $value
* @return bool
*/
public function useIdxTable($value = null)
{
if ($value !== null) {
$this->_isNeedUseIdxTable = (bool)$value;
}
return $this->_isNeedUseIdxTable;
}
/**
* Retrieve temporary index table name
*
* @return string
*/
protected function _getIdxTable()
{
if ($this->useIdxTable()) {
return $this->_getTable('cataloginventory_stock_status_idx');
}
return $this->_getTable('cataloginventory_stock_status_tmp');
}
/**
* Clean up temporary index table
*
* @return void
*/
public function clearTemporaryIndexTable()
{
$this->_getConnection()->delete($this->_getIdxTable());
}
}