Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 24 additions & 0 deletions app/code/Magento/CatalogExportApi/Api/Data/Product.php
Original file line number Diff line number Diff line change
Expand Up @@ -188,6 +188,9 @@ class Product
/** @var bool */
private $lowStock;

/** @var \Magento\CatalogExportApi\Api\Data\UrlRewrite[]|null */
private $urlRewrites;

/**
* Get sku
*
Expand Down Expand Up @@ -1342,4 +1345,25 @@ public function setLowStock(?bool $lowStock): void
{
$this->lowStock = $lowStock;
}

/**
* Get url rewrites
*
* @return \Magento\CatalogExportApi\Api\Data\UrlRewrite[]|null
*/
public function getUrlRewrites(): ?array
{
return $this->urlRewrites;
}

/**
* Set url rewrites
*
* @param \Magento\CatalogExportApi\Api\Data\UrlRewrite[] $urlRewrites
* @return void
*/
public function setUrlRewrites(?array $urlRewrites = null): void
{
$this->urlRewrites = $urlRewrites;
}
}
73 changes: 73 additions & 0 deletions app/code/Magento/CatalogExportApi/Api/Data/UrlRewrite.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,73 @@
<?php

/**
* Copyright © Magento, Inc. All rights reserved.
* See COPYING.txt for license details.
*
* Generated from et_schema.xml. DO NOT EDIT!
*/

declare(strict_types=1);

namespace Magento\CatalogExportApi\Api\Data;

/**
* UrlRewrite entity
*
* phpcs:disable Magento2.PHP.FinalImplementation
* @SuppressWarnings(PHPMD.BooleanGetMethodName)
* @SuppressWarnings(PHPMD.TooManyFields)
* @SuppressWarnings(PHPMD.ExcessivePublicCount)
* @SuppressWarnings(PHPMD.ExcessiveClassComplexity)
* @SuppressWarnings(PHPMD.CouplingBetweenObjects)
*/
class UrlRewrite
{
/** @var string */
private $url;

/** @var \Magento\CatalogExportApi\Api\Data\UrlRewriteParameter[]|null */
private $parameters;

/**
* Get url
*
* @return string
*/
public function getUrl(): ?string
{
return $this->url;
}

/**
* Set url
*
* @param string $url
* @return void
*/
public function setUrl(?string $url): void
{
$this->url = $url;
}

/**
* Get parameters
*
* @return \Magento\CatalogExportApi\Api\Data\UrlRewriteParameter[]|null
*/
public function getParameters(): ?array
{
return $this->parameters;
}

/**
* Set parameters
*
* @param \Magento\CatalogExportApi\Api\Data\UrlRewriteParameter[] $parameters
* @return void
*/
public function setParameters(?array $parameters = null): void
{
$this->parameters = $parameters;
}
}
73 changes: 73 additions & 0 deletions app/code/Magento/CatalogExportApi/Api/Data/UrlRewriteParameter.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,73 @@
<?php

/**
* Copyright © Magento, Inc. All rights reserved.
* See COPYING.txt for license details.
*
* Generated from et_schema.xml. DO NOT EDIT!
*/

declare(strict_types=1);

namespace Magento\CatalogExportApi\Api\Data;

/**
* UrlRewriteParameter entity
*
* phpcs:disable Magento2.PHP.FinalImplementation
* @SuppressWarnings(PHPMD.BooleanGetMethodName)
* @SuppressWarnings(PHPMD.TooManyFields)
* @SuppressWarnings(PHPMD.ExcessivePublicCount)
* @SuppressWarnings(PHPMD.ExcessiveClassComplexity)
* @SuppressWarnings(PHPMD.CouplingBetweenObjects)
*/
class UrlRewriteParameter
{
/** @var string */
private $name;

/** @var string */
private $value;

/**
* Get name
*
* @return string
*/
public function getName(): ?string
{
return $this->name;
}

/**
* Set name
*
* @param string $name
* @return void
*/
public function setName(?string $name): void
{
$this->name = $name;
}

/**
* Get value
*
* @return string
*/
public function getValue(): ?string
{
return $this->value;
}

/**
* Set value
*
* @param string $value
* @return void
*/
public function setValue(?string $value): void
{
$this->value = $value;
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,153 @@
<?php

/**
* Copyright © Magento, Inc. All rights reserved.
* See COPYING.txt for license details.
*/
declare(strict_types=1);

namespace Magento\CatalogUrlRewriteDataExporter\Model\Provider\Product;

use Magento\CatalogUrlRewriteDataExporter\Model\Query\ProductUrlRewritesQuery;
use Magento\DataExporter\Exception\UnableRetrieveData;
use Magento\Framework\App\ResourceConnection;
use Magento\Framework\UrlInterface;
use Magento\Store\Model\StoreManagerInterface;
use Magento\UrlRewrite\Service\V1\Data\UrlRewrite;
use Psr\Log\LoggerInterface;

/**
* UrlRewrites data provider
*/
class UrlRewrites
{
/**
* @var ResourceConnection
*/
private $resourceConnection;

/**
* @var StoreManagerInterface
*/
private $storeManager;

/**
* @var ProductUrlRewritesQuery
*/
private $urlRewritesQuery;

/**
* @var LoggerInterface
*/
private $logger;

/**
* @param ResourceConnection $resourceConnection
* @param StoreManagerInterface $storeManager
* @param ProductUrlRewritesQuery $urlRewritesQuery
* @param LoggerInterface $logger
*/
public function __construct(
ResourceConnection $resourceConnection,
StoreManagerInterface $storeManager,
ProductUrlRewritesQuery $urlRewritesQuery,
LoggerInterface $logger
) {
$this->resourceConnection = $resourceConnection;
$this->urlRewritesQuery = $urlRewritesQuery;
$this->storeManager = $storeManager;
$this->logger = $logger;
}

/**
* Format UrlRewrite data
*
* @throws \Magento\Framework\Exception\NoSuchEntityException
* @param array $urlRewrite
* @param string $storeViewCode
* @return array
*/
private function format(array $urlRewrite, string $storeViewCode) : array
{
$baseUrl = $this->storeManager->getStore($storeViewCode)->getBaseUrl(UrlInterface::URL_TYPE_WEB);

return [
'productId' => $urlRewrite[UrlRewrite::ENTITY_ID],
'storeViewCode' => $storeViewCode,
'url_rewrites' => [
'url' => $baseUrl . $urlRewrite[UrlRewrite::REQUEST_PATH],
'parameters' => $this->getUrlParameters($urlRewrite[UrlRewrite::TARGET_PATH])
]
];
}

/**
* Get provider data
*
* @param array $values
* @return array
* @throws UnableRetrieveData
*/
public function get(array $values): array
{
$output = [];
$queryArguments = [];

try {
foreach ($values as $value) {
$queryArguments['productId'][$value['productId']] = $value['productId'];
$queryArguments['storeViewCode'][$value['storeViewCode']] = $value['storeViewCode'];
}
foreach ($queryArguments['storeViewCode'] as $storeViewCode) {
$urlRewrites = $this->getUrlRewrites($queryArguments, $storeViewCode);
foreach ($urlRewrites ?? [] as $urlRewrite) {
$output[] = $this->format($urlRewrite, $storeViewCode);
}
}
} catch (\Exception $exception) {
$this->logger->error($exception->getMessage());
throw new UnableRetrieveData('Unable to retrieve url rewrites data');
}

return $output;
}

/**
* Get url rewrites for products and given store.
*
* @param array $queryArguments
* @param string $storeViewCode
* @return array
* @throws \Magento\Framework\Exception\NoSuchEntityException
*/
private function getUrlRewrites(array $queryArguments, string $storeViewCode): array
{
$storeId = (int) $this->storeManager->getStore($storeViewCode)->getId();
$urlRewritesSelect = $this->urlRewritesQuery->getQuery($queryArguments['productId'], $storeId);
$connection = $this->resourceConnection->getConnection();

return $connection->fetchAll($urlRewritesSelect);
}

/**
* Parses target path and extracts parameters
*
* @param string $targetPath
* @return array
*/
private function getUrlParameters(string $targetPath): array
{
$urlParameters = [];
$targetPathParts = explode('/', trim($targetPath, '/'));
$targetPathPartsCount = count($targetPathParts);

for ($i = 3; $i < $targetPathPartsCount - 1; $i += 2) {
$urlParameters[] = [
'name' => $targetPathParts[$i],
'value' => $targetPathParts[$i + 1]
];
}

return $urlParameters;
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,59 @@
<?php

/**
* Copyright © Magento, Inc. All rights reserved.
* See COPYING.txt for license details.
*/
declare(strict_types=1);

namespace Magento\CatalogUrlRewriteDataExporter\Model\Query;

use Magento\Framework\DB\Select;
use Magento\Framework\App\ResourceConnection;

/**
* Fetch product url rewrites.
*/
class ProductUrlRewritesQuery
{
/**
* @var ResourceConnection
*/
private $resourceConnection;

/**
* @param ResourceConnection $resourceConnection
*/
public function __construct(
ResourceConnection $resourceConnection
) {
$this->resourceConnection = $resourceConnection;
}

/**
* Return query that fetches a list of products' url rewrites.
*
* @param int[] $productIds
* @param int $storeId
* @return Select
*/
public function getQuery(array $productIds, int $storeId): Select
{
$resourceConnection = $this->resourceConnection;
$connection = $resourceConnection->getConnection();
$urlRewritesTable = $resourceConnection->getTableName('url_rewrite');

return $connection->select()
->from(
['e' => $urlRewritesTable],
[
\Magento\UrlRewrite\Service\V1\Data\UrlRewrite::ENTITY_ID,
\Magento\UrlRewrite\Service\V1\Data\UrlRewrite::REQUEST_PATH,
\Magento\UrlRewrite\Service\V1\Data\UrlRewrite::TARGET_PATH,
]
)
->where('entity_id IN (?)', $productIds)
->where('entity_type = ?', 'product')
->where('store_id = ?', $storeId);
}
}
Loading