351 lines
12 KiB
PHP
351 lines
12 KiB
PHP
<?php
|
||
|
||
namespace Intaro\RetailCrm\Icml;
|
||
|
||
use Bitrix\Catalog\ProductTable;
|
||
use Intaro\RetailCrm\Model\Bitrix\Orm\CatalogIblockInfo;
|
||
use Intaro\RetailCrm\Model\Bitrix\Xml\SelectParams;
|
||
use Intaro\RetailCrm\Model\Bitrix\Xml\XmlData;
|
||
use Intaro\RetailCrm\Model\Bitrix\Xml\XmlOffer;
|
||
use Intaro\RetailCrm\Model\Bitrix\Xml\XmlSetup;
|
||
use Intaro\RetailCrm\Repository\CatalogRepository;
|
||
use Logger;
|
||
use RetailcrmConfigProvider;
|
||
|
||
/**
|
||
* Class IcmlDirector
|
||
* @package Intaro\RetailCrm\Icml
|
||
*/
|
||
class IcmlDirector
|
||
{
|
||
public const INFO = 'INFO';
|
||
public const OFFERS_PART = 500;
|
||
public const FILE_LOG_NAME = 'i_crm_load_log';
|
||
public const DEFAULT_PRODUCT_PAGE_SIZE = 1;
|
||
|
||
/**
|
||
* @var IcmlWriter
|
||
*/
|
||
private $icmlWriter;
|
||
|
||
/**
|
||
* @var \Intaro\RetailCrm\Icml\XmlOfferDirector
|
||
*/
|
||
private $xmlOfferDirector;
|
||
|
||
/**
|
||
* @var \Intaro\RetailCrm\Model\Bitrix\Xml\XmlSetup
|
||
*/
|
||
private $setup;
|
||
|
||
/**
|
||
* @var \Intaro\RetailCrm\Repository\CatalogRepository
|
||
*/
|
||
private $catalogRepository;
|
||
|
||
/**
|
||
* @var string
|
||
*/
|
||
private $shopName;
|
||
|
||
/**
|
||
* @var \Intaro\RetailCrm\Icml\XmlCategoryDirector
|
||
*/
|
||
private $xmlCategoryDirector;
|
||
|
||
/**
|
||
* @var \Intaro\RetailCrm\Icml\QueryParamsMolder
|
||
*/
|
||
private $queryBuilder;
|
||
|
||
/**
|
||
* @var \Intaro\RetailCrm\Model\Bitrix\Xml\XmlData
|
||
*/
|
||
private $xmlData;
|
||
|
||
/**
|
||
* @var \Logger
|
||
*/
|
||
private $logger;
|
||
|
||
/**
|
||
* RetailCrmlXml constructor.
|
||
*
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Xml\XmlSetup $setup
|
||
* @param \Logger $logger
|
||
*/
|
||
public function __construct(XmlSetup $setup, Logger $logger)
|
||
{
|
||
$this->setup = $setup;
|
||
$this->shopName = RetailcrmConfigProvider::getSiteName();
|
||
$this->catalogRepository = new CatalogRepository();
|
||
$this->icmlWriter = new IcmlWriter($this->setup->filePath);
|
||
$this->xmlOfferDirector = new XmlOfferDirector($this->setup);
|
||
$this->xmlCategoryDirector = new XmlCategoryDirector($this->setup->iblocksForExport);
|
||
$this->queryBuilder = new QueryParamsMolder();
|
||
$this->xmlData = new XmlData();
|
||
$this->logger = $logger;
|
||
}
|
||
|
||
/**
|
||
* Основной метод. Генерирует icml файл католога товаров Битрикс
|
||
*/
|
||
public function generateXml(): void
|
||
{
|
||
unlink($this->setup->filePath);
|
||
$this->setXmlData();
|
||
$this->icmlWriter->writeToXmlTop($this->xmlData);
|
||
$this->logger->write(
|
||
self::INFO . ': Start writing categories and header',
|
||
self::FILE_LOG_NAME
|
||
);
|
||
$this->icmlWriter->writeToXmlHeaderAndCategories($this->xmlData);
|
||
$this->logger->write(
|
||
self::INFO . ': End writing categories in XML and Start writing offers',
|
||
self::FILE_LOG_NAME
|
||
);
|
||
$this->writeOffers();
|
||
$this->logger->write(
|
||
self::INFO . ': End writing offers in XML',
|
||
self::FILE_LOG_NAME
|
||
);
|
||
$this->icmlWriter->writeToXmlBottom();
|
||
$this->logger->write(
|
||
self::INFO . ': Loading complete (peak memory usage: ' . memory_get_peak_usage() . ')',
|
||
self::FILE_LOG_NAME
|
||
);
|
||
}
|
||
|
||
/**
|
||
* @return void
|
||
*/
|
||
private function setXmlData(): void
|
||
{
|
||
$this->xmlData->shopName = $this->shopName;
|
||
$this->xmlData->company = $this->shopName;
|
||
$this->xmlData->filePath = $this->setup->filePath;
|
||
$this->xmlData->categories = $this->xmlCategoryDirector->getXmlCategories();
|
||
}
|
||
|
||
/**
|
||
* записывает оферы всех торговых каталогов в xml файл
|
||
*/
|
||
private function writeOffers(): void
|
||
{
|
||
$this->icmlWriter->startOffersBlock();
|
||
|
||
foreach ($this->setup->iblocksForExport as $iblockId) {
|
||
$this->writeIblockOffers($iblockId);
|
||
}
|
||
|
||
$this->icmlWriter->endBlock();
|
||
}
|
||
|
||
/**
|
||
* записывает оферы конкретного торгового каталога товаров в xml файл
|
||
*
|
||
* @param int $productIblockId //ID инфоблока товаров в торговом каталоге
|
||
*/
|
||
private function writeIblockOffers(int $productIblockId): void
|
||
{
|
||
$catalogIblockInfo = $this->catalogRepository->getCatalogIblockInfo($productIblockId);
|
||
|
||
//если нет торговых предложений
|
||
if ($catalogIblockInfo->skuIblockId === null) {
|
||
$selectParams
|
||
= $this->queryBuilder->getSelectParams(
|
||
$this->setup->properties->products->names[$productIblockId],
|
||
$this->setup->basePriceId
|
||
);
|
||
|
||
$selectParams->pageNumber = 1;
|
||
$selectParams->nPageSize = self::OFFERS_PART;
|
||
$selectParams->parentId = null;
|
||
$selectParams->allParams = array_merge($selectParams->configurable, $selectParams->main);
|
||
|
||
while ($xmlOffers = $this->xmlOfferDirector->getXmlOffersPart($selectParams, $catalogIblockInfo)) {
|
||
$this->icmlWriter->writeOffers($xmlOffers, $xmlOffers->activity === 'N');
|
||
$selectParams->pageNumber++;
|
||
}
|
||
|
||
return;
|
||
}
|
||
|
||
//если есть торговые предложения
|
||
$paramsForProduct
|
||
= $this->queryBuilder->getSelectParams(
|
||
$this->setup->properties->products->names[$productIblockId],
|
||
$this->setup->basePriceId
|
||
);
|
||
|
||
$paramsForOffer
|
||
= $this->queryBuilder->getSelectParams(
|
||
$this->setup->properties->sku->names[$productIblockId],
|
||
$this->setup->basePriceId
|
||
);
|
||
|
||
$this->writeOffersAsOffersInXml($paramsForProduct, $paramsForOffer, $catalogIblockInfo);
|
||
}
|
||
|
||
/**
|
||
* Эта стратегия записи используется,
|
||
* когда в каталоге есть торговые предложения
|
||
*
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Xml\SelectParams $paramsForProduct
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Xml\SelectParams $paramsForOffer
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Orm\CatalogIblockInfo $catalogIblockInfo
|
||
*/
|
||
private function writeOffersAsOffersInXml(
|
||
SelectParams $paramsForProduct,
|
||
SelectParams $paramsForOffer,
|
||
CatalogIblockInfo $catalogIblockInfo
|
||
): void {
|
||
$paramsForProduct->pageNumber = 1;
|
||
$paramsForProduct->nPageSize = $this->calculateProductPageSize();
|
||
$paramsForProduct->allParams = array_merge($paramsForProduct->configurable, $paramsForProduct->main);
|
||
|
||
do {
|
||
$productsPart = $this->xmlOfferDirector->getXmlOffersPart($paramsForProduct, $catalogIblockInfo);
|
||
$paramsForProduct->pageNumber++;
|
||
|
||
$this->writeProductsOffers($productsPart, $paramsForOffer, $catalogIblockInfo);
|
||
} while (!empty($productsPart));
|
||
}
|
||
|
||
/**
|
||
* Записывает в файл оферы всех товаров из $products
|
||
*
|
||
* @param XmlOffer[] $products
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Xml\SelectParams $paramsForOffer
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Orm\CatalogIblockInfo $catalogIblockInfo
|
||
*/
|
||
private function writeProductsOffers(
|
||
array $products,
|
||
SelectParams $paramsForOffer,
|
||
CatalogIblockInfo $catalogIblockInfo
|
||
): void {
|
||
$paramsForOffer->nPageSize = $this->calculateOffersPageSize();
|
||
|
||
foreach ($products as $product) {
|
||
$this->writeProductOffers($paramsForOffer, $catalogIblockInfo, $product);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Записывает оферы отдельного продукта в xml файл
|
||
*
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Xml\SelectParams $paramsForOffer
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Orm\CatalogIblockInfo $catalogIblockInfo
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Xml\XmlOffer $product
|
||
*/
|
||
private function writeProductOffers(
|
||
SelectParams $paramsForOffer,
|
||
CatalogIblockInfo $catalogIblockInfo,
|
||
XmlOffer $product
|
||
): void {
|
||
$paramsForOffer->pageNumber = 1;
|
||
$writingOffersCount = 0;
|
||
$paramsForOffer->parentId = $product->id;
|
||
$paramsForOffer->allParams = array_merge($paramsForOffer->configurable, $paramsForOffer->main);
|
||
|
||
do {
|
||
$isNotActiveProduct = false;
|
||
|
||
if ($product->activity === 'N') {
|
||
$isNotActiveProduct = true;
|
||
}
|
||
|
||
//Если каталог проиндексирован, у товара есть Тип и это простой товар, то просто записываем его
|
||
if ($product->productType === ProductTable::TYPE_PRODUCT) {
|
||
$this->icmlWriter->writeOffers([$product], $isNotActiveProduct);
|
||
break;
|
||
}
|
||
|
||
$xmlOffersPart
|
||
= $this->xmlOfferDirector->getXmlOffersBySingleProduct($paramsForOffer, $catalogIblockInfo, $product);
|
||
|
||
// если это "простой товар", у которого нет ТП, то просто записываем его
|
||
if ($paramsForOffer->pageNumber === 1 && count($xmlOffersPart) === 0) {
|
||
$this->icmlWriter->writeOffers([$product], $isNotActiveProduct);
|
||
break;
|
||
}
|
||
|
||
if (!empty($xmlOffersPart)) {
|
||
$xmlOffersPart
|
||
= $this->trimOffersList($writingOffersCount, $xmlOffersPart);
|
||
|
||
$this->icmlWriter->writeOffers($xmlOffersPart, $isNotActiveProduct);
|
||
|
||
$writingOffersCount += count($xmlOffersPart);
|
||
$paramsForOffer->pageNumber++;
|
||
}
|
||
} while ($this->shouldContinueWriting($writingOffersCount, $xmlOffersPart));
|
||
}
|
||
|
||
/**
|
||
* Проверяет,не достигнул ли лимит по записываемым оферам maxOffersValue
|
||
* и обрезает массив до лимита, если он достигнут
|
||
*
|
||
* @param int $writingOffers
|
||
* @param XmlOffer[] $xmlOffers
|
||
*
|
||
* @return XmlOffer[]
|
||
*/
|
||
private function trimOffersList(int $writingOffers, array $xmlOffers): array
|
||
{
|
||
if (!empty($this->setup->maxOffersValue) && ($writingOffers + count($xmlOffers)) > $this->setup->maxOffersValue) {
|
||
$sliceIndex
|
||
= count($xmlOffers) - ($writingOffers + count($xmlOffers) - $this->setup->maxOffersValue);
|
||
return array_slice($xmlOffers, 0, $sliceIndex);
|
||
}
|
||
|
||
return $xmlOffers;
|
||
}
|
||
|
||
/**
|
||
* Возвращает размер страницы для запроса товаров
|
||
*
|
||
* @return int
|
||
*/
|
||
private function calculateProductPageSize(): int
|
||
{
|
||
if (empty($this->setup->maxOffersValue)) {
|
||
return self::DEFAULT_PRODUCT_PAGE_SIZE;
|
||
}
|
||
|
||
return (int) ceil(self::OFFERS_PART / $this->setup->maxOffersValue);
|
||
}
|
||
|
||
/**
|
||
* Возвращает размер страницы для офферов
|
||
*
|
||
* @return int
|
||
*/
|
||
private function calculateOffersPageSize(): int
|
||
{
|
||
if (empty($this->setup->maxOffersValue)) {
|
||
return self::OFFERS_PART;
|
||
}
|
||
|
||
return $this->setup->maxOffersValue < self::OFFERS_PART ?
|
||
$this->setup->maxOffersValue : self::OFFERS_PART;
|
||
}
|
||
|
||
/**
|
||
* Проверяет, нужно ли дальше записывать офферы
|
||
*
|
||
* @param int $writingOffers
|
||
* @param \Intaro\RetailCrm\Model\Bitrix\Xml\XmlOffer[] $xmlOffers
|
||
*
|
||
* @return bool
|
||
*/
|
||
private function shouldContinueWriting(int $writingOffers, array $xmlOffers): bool
|
||
{
|
||
if (empty($this->setup->maxOffersValue)) {
|
||
return !empty($xmlOffers);
|
||
}
|
||
|
||
return !empty($xmlOffers) && $writingOffers < $this->setup->maxOffersValue;
|
||
}
|
||
}
|