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/mageworx/module-seoxtemplates/Model/DataProvider/Product/ |
<?php
/**
* Copyright © 2016 MageWorx. All rights reserved.
* See LICENSE.txt for license details.
*/
namespace MageWorx\SeoXTemplates\Model\DataProvider\Product;
use Magento\Framework\App\ResourceConnection;
use Magento\Catalog\Model\ResourceModel\Product;
use MageWorx\SeoXTemplates\Model\ConverterProductFactory;
use MageWorx\SeoAll\Helper\LinkFieldResolver;
use MageWorx\SeoXTemplates\Helper\Store as HelperStore;
use Magento\Catalog\Api\Data\ProductInterface;
class Eav extends \MageWorx\SeoXTemplates\Model\DataProvider\Product
{
/**
* @var \Magento\Framework\DB\Adapter\AdapterInterface
*/
protected $_connection;
/**
*
* @var int
*/
protected $_defaultStore;
/**
* Store ID for obtaining and preparing data
*
* @var int
*/
protected $_storeId;
/**
* @var HelperStore
*/
protected $helperStore;
/**
*
* @var array
*/
protected $_attributeCodes = [];
/**
*
* @var \Magento\Framework\Data\Collection
*/
protected $_collection;
/**
* @var \Magento\Catalog\Model\ResourceModel\Product
*/
protected $productResource;
/**
* @var \MageWorx\SeoAll\Helper\LinkFieldResolver
*/
protected $linkFieldResolver;
/**
* @var \MageWorx\SeoXTemplates\Model\ExcludeProductsRegistry
*/
protected $excludeProductsRegistry;
/**
* Eav constructor.
*
* @param ResourceConnection $resource
* @param ConverterProductFactory $converterProductFactory
* @param LinkFieldResolver $linkFieldResolver
* @param Product $productResource
* @param HelperStore $helperStore
*/
public function __construct(
ResourceConnection $resource,
ConverterProductFactory $converterProductFactory,
LinkFieldResolver $linkFieldResolver,
Product $productResource,
HelperStore $helperStore,
\MageWorx\SeoXTemplates\Model\ExcludeProductsRegistry $registry
) {
parent::__construct($resource, $converterProductFactory);
$this->linkFieldResolver = $linkFieldResolver;
$this->productResource = $productResource;
$this->helperStore = $helperStore;
$this->excludeProductsRegistry = $registry;
}
/**
* Retrieve data
*
* @param \Magento\Framework\Data\Collection $collection
* @param \MageWorx\SeoXTemplates\Model\Template\Product $template
* @param int|null $customStoreId
* @return array
*/
public function getData($collection, $template, $customStoreId = null)
{
if (!$collection) {
return false;
}
$this->_collection = $collection;
$this->_storeId = $this->getStoreId($template, $customStoreId);
$this->_attributeCodes = $template->getAttributeCodesByType();
$attributes = [];
$connection = $this->_getConnection();
$select = $connection->select()
->from($this->_resource->getTableName('eav_entity_type'))
->where("entity_type_code = 'catalog_product'");
$productTypeId = $connection->fetchOne($select);
foreach ($this->_attributeCodes as $_attrName) {
$select = $connection->select()
->from($this->_resource->getTableName('eav_attribute'))
->where('entity_type_id = ?', (int)$productTypeId)
->where('attribute_code = ?', $_attrName);
if ($res = $connection->fetchRow($select)) {
$attributes[$_attrName] = $res;
}
}
$productIds = array_keys($this->getCollectionIds());
$data = [];
$linkField = $this->getLinkField();
foreach ($attributes as $attribute) {
$idsByAttribute = [
'insert' => array_fill_keys($productIds, []),
'update' => []
];
$tableName = $this->_resource->getTableName('catalog_product_entity') . '_' . $attribute['backend_type'];
$storeId = $template->getIsSingleStoreMode() ? $template->getStoreId() : $this->_storeId;
$select = $connection->select([$linkField])
->from($tableName)
->where("attribute_id = ?", (int)$attribute['attribute_id'])
->where($linkField . " IN(?)", $productIds)
->where("store_id = ?", (int)$storeId);
$existRecords = $connection->fetchAll($select);
foreach ($existRecords as $record) {
if ($template->isScopeForAll()) {
$idsByAttribute['update'][$record[$linkField]] = ['old_value' => $record['value']];
}
if (!$record['value']) {
$idsByAttribute['update'][$record[$linkField]] = ['old_value' => $record['value']];
}
unset($idsByAttribute['insert'][$record[$linkField]]);
}
$attributeHash = $attribute['attribute_id'] . '#' . $attribute['attribute_code'] . '#' . $attribute['backend_type'];
$data[$attributeHash] = $idsByAttribute;
}
$this->fillData($template, $data);
return $data;
}
/**
* @param \MageWorx\SeoXTemplates\Model\Template\Product $template
* @param \Magento\Catalog\Model\ResourceModel\Product\Collection $collection
* @return mixed|void
*/
public function addFiltersToEntityCollection($template, $collection)
{
if ($template::SCOPE_EMPTY == $template->getScope()) {
$attributes = $template->getAttributeCodesByType();
foreach ($attributes as $attributeCode) {
$collection->addAttributeToFilter(
[
['attribute' => $attributeCode, 'is' => new \Zend_Db_Expr('null')],
['attribute' => $attributeCode, 'eq' => new \Zend_Db_Expr("''")],
],
null,
'left'
);
}
}
return parent::addFiltersToEntityCollection($template, $collection);
}
/**
* You can load collection and add specific data to items here
*
* @param \MageWorx\SeoXTemplates\Model\Template\Product $template
* @param \Magento\Framework\Data\Collection\AbstractDb $collection Non-loaded collection
* @return mixed|void
* @throws \Magento\Framework\Exception\LocalizedException
*/
public function onLoadEntityCollection($template, $collection)
{
/**
* Exclude products with empty generated values from product collection if template scope is "For Empty"
* for avoid loop
*/
$productIds = $this->excludeProductsRegistry->getProducts($template->getId());
if (!empty($productIds)) {
$collection->getSelect()->where('e.entity_id NOT IN (?)', $productIds);
}
return parent::onLoadEntityCollection($template, $collection);
}
/**
* @param \MageWorx\SeoXTemplates\Model\AbstractTemplate $template
* @param int|null $customStoreId
* @return int|null
*/
protected function getStoreId($template, $customStoreId = null)
{
if ($customStoreId) {
return $customStoreId;
}
if ($template->getIsSingleStoreMode()) {
return $this->helperStore->getCurrentStoreId();
}
return $template->getStoreId();
}
/**
* Add data for each entityId
*
* @param \MageWorx\SeoXTemplates\Model\AbstractTemplate $template
* @param array $data
*/
protected function fillData($template, &$data)
{
$storeIdForApply = $template->getIsSingleStoreMode() ? $template->getStoreId() : $this->_storeId;
$connect = $this->getCollectionIds();
$emptyValueProductIds = [];
$linkField = $this->getLinkField();
foreach ($data as $attributeHash => $attributeData) {
list($attributeId, $attributeCode) = explode('#', $attributeHash);
$converter = $this->converterProductFactory->create($attributeCode);
foreach ($attributeData as $insertTypeName => $insertData) {
foreach ($insertData as $entityId => $emptyValue) {
// $microtime = microtime(1);
$attributeValue = '';
$product = $this->_collection->getItemById($connect[$entityId]);
if ($product) {
$attributeValue = $converter->convert(
$product->setStoreId($this->_storeId),
$template->getCode()
);
// Magento also save the empty attribute value as null
if (!$attributeValue) {
$attributeValue = null;
}
if (!$attributeValue && $template::SCOPE_EMPTY == $template->getScope()) {
$emptyValueProductIds = array_merge($emptyValueProductIds, [$product->getId()]);
}
}
// echo "<br><font color = green>" . number_format((microtime(1) - $microtime), 5) . " sec need for " . get_class($this) . "</font>";
$data[$attributeHash][$insertTypeName][$entityId] = array_merge(
$data[$attributeHash][$insertTypeName][$entityId],
[
'attribute_id' => $attributeId,
$linkField => $entityId,
'store_id' => $storeIdForApply,
'value' => $attributeValue,
]
);
}
}
}
$this->excludeProductsRegistry->addProduct($template->getId(), $emptyValueProductIds);
}
/**
* @return array
*/
public function getAttributeCodes()
{
return $this->_attributeCodes;
}
/**
* return array row_id => entity_id or entity_id => entity_id
*/
public function getCollectionIds()
{
$data = [];
$linkField = $this->getLinkField();
foreach ($this->_collection as $item) {
$data[$item->getData($linkField)] = $item->getData('entity_id');
}
return $data;
}
/**
* @return string
*/
protected function getLinkField()
{
return $this->linkFieldResolver->getLinkField(ProductInterface::class, 'entity_id');
}
}