911 lines
33 KiB
PHP
911 lines
33 KiB
PHP
<?php
|
|
|
|
use Bitrix\Highloadblock as HL;
|
|
use Bitrix\Main\Entity;
|
|
|
|
IncludeModuleLangFile(__FILE__);
|
|
class RetailCrmICML
|
|
{
|
|
public $profileID;
|
|
public $iblocks;
|
|
public $filename;
|
|
public $serverName;
|
|
public $defaultServerName;
|
|
public $propertiesSKU;
|
|
public $propertiesUnitSKU;
|
|
public $propertiesProduct;
|
|
public $propertiesUnitProduct;
|
|
public $highloadblockSkuProperties;
|
|
public $highloadblockProductProperties;
|
|
public $application;
|
|
public $encoding = 'utf-8';
|
|
public $encodingDefault = 'utf-8';
|
|
public $loadPurchasePrice = false;
|
|
public $productPictures;
|
|
public $skuPictures;
|
|
public $offerPageSize = 50;
|
|
|
|
protected $fp;
|
|
protected $mainSection = 1000000;
|
|
protected $pageSize = 500;
|
|
protected $protocol;
|
|
protected $purchasePriceNull;
|
|
|
|
protected $isLogged = false;
|
|
protected $logFile = '/bitrix/catalog_export/i_crm_load_log.txt';
|
|
protected $fpLog;
|
|
protected $localizedIBlockProps;
|
|
|
|
protected $MODULE_ID = 'intaro.retailcrm';
|
|
protected $CRM_CATALOG_BASE_PRICE = 'catalog_base_price';
|
|
protected $PROTOCOL_OPTION = 'protocol';
|
|
protected $CRM_PURCHASE_PRICE_NULL = 'purchasePrice_null';
|
|
|
|
protected $measurement = array (
|
|
'mm' => 1, // 1 mm = 1 mm
|
|
'cm' => 10, // 1 cm = 10 mm
|
|
'm' => 1000,
|
|
'mg' => 0.001, // 0.001 g = 1 mg
|
|
'g' => 1,
|
|
'kg' => 1000,
|
|
);
|
|
|
|
protected $measurementLink = array (
|
|
'mm' => 'mm',
|
|
'cm' => 'mm',
|
|
'm' => 'mm',
|
|
'mg' => 'g',
|
|
'g' => 'g',
|
|
'kg' => 'g',
|
|
);
|
|
|
|
protected $measure = array (
|
|
'pc. 1' => 'pc',
|
|
'm' => 'm',
|
|
'l' => 'l',
|
|
'kg' => 'kg',
|
|
);
|
|
|
|
public function Load()
|
|
{
|
|
global $USER;
|
|
if (!isset($_SESSION["SESS_AUTH"]["USER_ID"]) || !$_SESSION["SESS_AUTH"]["USER_ID"]) {
|
|
$USER = new CUser();
|
|
}
|
|
|
|
$this->isLogged = true;
|
|
$this->localizedIBlockProps = $this->getLocalizedIBlockProps();
|
|
|
|
$defaultSite = CSite::GetList($by = "def", $order = "desc", array('DEF' => 'Y'))->Fetch();
|
|
$this->encodingDefault = $defaultSite["CHARSET"];
|
|
|
|
$this->protocol = COption::GetOptionString($this->MODULE_ID, $this->PROTOCOL_OPTION);
|
|
$this->purchasePriceNull = COption::GetOptionString($this->MODULE_ID, $this->CRM_PURCHASE_PRICE_NULL);
|
|
|
|
$this->PrepareSettings();
|
|
|
|
$this->fp = $this->PrepareFile($this->filename. '.tmp');
|
|
|
|
if ($this->isLogged) {
|
|
$this->fpLog = $this->PrepareFile($this->logFile);
|
|
$this->WriteLog("Start Loading");
|
|
}
|
|
|
|
$this->PreWriteCatalog();
|
|
|
|
$categories = $this->GetCategories();
|
|
|
|
$this->WriteCategories($categories);
|
|
|
|
$this->PreWriteOffers();
|
|
$this->BuildOffers($categories);
|
|
$this->PostWriteOffers();
|
|
|
|
$this->PostWriteCatalog();
|
|
|
|
if ($this->isLogged) {
|
|
$this->WriteLog("Loading was ended successfully (peek memory usage: " . memory_get_peak_usage() . ")");
|
|
}
|
|
|
|
$this->CloseFile($this->fp);
|
|
$this->CloseFile($this->fpLog);
|
|
unlink($defaultSite['ABS_DOC_ROOT'] . $this->filename);
|
|
rename($defaultSite['ABS_DOC_ROOT'] . $this->filename. '.tmp', $defaultSite['ABS_DOC_ROOT'] . $this->filename);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
private function setSiteAddress($block_id)
|
|
{
|
|
$site = CAllIBlock::GetSite($block_id)->Fetch();
|
|
|
|
if ($site['SERVER_NAME']) {
|
|
$this->serverName = $site['SERVER_NAME'];
|
|
} else {
|
|
$this->serverName = $this->defaultServerName;
|
|
}
|
|
}
|
|
|
|
protected function PrepareSettings()
|
|
{
|
|
foreach ($this->propertiesSKU as $iblock => $arr) {
|
|
foreach ($arr as $id => $sku) {
|
|
$this->propertiesSKU[$iblock][$id] = strtoupper($sku);
|
|
}
|
|
}
|
|
|
|
foreach ($this->propertiesProduct as $iblock => $arr) {
|
|
foreach ($arr as $id => $prod) {
|
|
$this->propertiesProduct[$iblock][$id] = strtoupper($prod);
|
|
}
|
|
}
|
|
}
|
|
|
|
protected function PrepareValue($text)
|
|
{
|
|
$newText = $this->application->ConvertCharset($text, $this->encodingDefault, $this->encoding);
|
|
$newText = strip_tags($newText);
|
|
$newText = str_replace("&", "&", $newText);
|
|
|
|
return $newText;
|
|
}
|
|
|
|
protected function PrepareFile($filename)
|
|
{
|
|
$fullFilename = $_SERVER["DOCUMENT_ROOT"] . $filename;
|
|
CheckDirPath($fullFilename);
|
|
|
|
if ($fp = @fopen($fullFilename, "w")){
|
|
return $fp;
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
protected function PreWriteCatalog()
|
|
{
|
|
@fwrite($this->fp, "<yml_catalog date=\"" . $this->PrepareValue(Date("Y-m-d H:i:s")) . "\">\n
|
|
<shop>\n
|
|
<name>" . $this->PrepareValue(COption::GetOptionString("main", "site_name", ""))."</name>\n
|
|
<company>" . $this->PrepareValue(COption::GetOptionString("main", "site_name", ""))."</company>\n"
|
|
);
|
|
}
|
|
|
|
protected function WriteCategories($categories)
|
|
{
|
|
$stringCategories = "";
|
|
@fwrite($this->fp, "<categories>\n");
|
|
foreach ($categories as $category) {
|
|
$stringCategories .= $this->BuildCategory($category);
|
|
}
|
|
@fwrite($this->fp, $stringCategories);
|
|
@fwrite($this->fp, "</categories>\n");
|
|
}
|
|
protected function PreWriteOffers()
|
|
{
|
|
@fwrite($this->fp, "<offers>\n");
|
|
}
|
|
|
|
protected function PostWriteOffers()
|
|
{
|
|
@fwrite($this->fp, "</offers>\n");
|
|
}
|
|
|
|
protected function WriteOffers($offers)
|
|
{
|
|
@fwrite($this->fp, $offers);
|
|
}
|
|
|
|
protected function WriteLog($text)
|
|
{
|
|
if ($this->isLogged) {
|
|
@fwrite($this->fpLog, Date("Y:m:d H:i:s") . ": " . $text . "\n");
|
|
}
|
|
}
|
|
|
|
protected function PostWriteCatalog()
|
|
{
|
|
@fwrite($this->fp, "</shop>\n
|
|
</yml_catalog>\n");
|
|
}
|
|
|
|
protected function CloseFile($fp)
|
|
{
|
|
@fclose($fp);
|
|
}
|
|
|
|
protected function GetCategories()
|
|
{
|
|
$categories = array();
|
|
foreach ($this->iblocks as $id) {
|
|
$this->setSiteAddress($id);
|
|
$filter = array("IBLOCK_ID" => $id);
|
|
|
|
$dbRes = CIBlockSection::GetList(array("left_margin" => "asc"), $filter);
|
|
$hasCategories = false;
|
|
|
|
while ($arRes = $dbRes->Fetch()) {
|
|
$categories[$arRes['ID']] = $arRes;
|
|
$categories[$arRes['ID']]['SITE'] = $this->protocol . $this->serverName;
|
|
$hasCategories = true;
|
|
}
|
|
|
|
if (!$hasCategories) {
|
|
$iblock = CIBlock::GetByID($id)->Fetch();
|
|
|
|
$arRes = array();
|
|
$arRes['ID'] = $this->mainSection + $id;
|
|
$arRes['IBLOCK_SECTION_ID'] = 0;
|
|
$arRes['NAME'] = sprintf(GetMessage('ROOT_CATEGORY_FOR_CATALOG'), $iblock['NAME']);
|
|
$categories[$arRes['ID']] = $arRes;
|
|
$categories[$arRes['ID']]['SITE'] = $this->protocol . $this->serverName;
|
|
}
|
|
}
|
|
|
|
return $categories;
|
|
}
|
|
|
|
protected function BuildCategory($arCategory)
|
|
{
|
|
$category =
|
|
"<category id=\"" . $this->PrepareValue($arCategory["ID"]) . "\""
|
|
. (intval($arCategory["IBLOCK_SECTION_ID"]) > 0 ?
|
|
" parentId=\"" . $this->PrepareValue($arCategory["IBLOCK_SECTION_ID"]) . "\""
|
|
:"")
|
|
. ">\n\t"
|
|
. "<name>" . $this->PrepareValue($arCategory["NAME"]) . "</name>\n";
|
|
|
|
if (CFile::GetPath($arCategory["DETAIL_PICTURE"])) {
|
|
$category .= "\t<picture>" . $this->getImageUrl($arCategory["DETAIL_PICTURE"]) . "</picture>\n";
|
|
}
|
|
|
|
if (CFile::GetPath($arCategory["PICTURE"])) {
|
|
$category .= "\t<picture>" . $this->getImageUrl($arCategory["PICTURE"]) . "</picture>\n";
|
|
}
|
|
|
|
$category .= "</category>\n";
|
|
|
|
return $category;
|
|
}
|
|
|
|
protected function BuildOffers(&$allCategories)
|
|
{
|
|
$basePriceId = $this->getBasePriceId();
|
|
|
|
foreach ($this->iblocks as $key => $id) {
|
|
$this->setSiteAddress($id);
|
|
$barcodes = $this->getProductBarcodesByIblock($id);
|
|
|
|
// Get Info by infoblocks
|
|
$iblockData = CIBlock::GetByID($id)->Fetch();
|
|
$iblockOffer = CCatalogSKU::GetInfoByProductIBlock($id);
|
|
|
|
$highloadblockSkuProps = $this->getAvailableHighloadOfferSkuProps($iblockOffer['IBLOCK_ID']);
|
|
$highloadblockProductProps = $this->getAvailableHighloadProductProps($id);
|
|
|
|
$arSelect = $this->buildProductQuery($id);
|
|
$arSelectOffer = $this->buildOfferQuery($id, $iblockOffer['SKU_PROPERTY_ID']);
|
|
|
|
// Set filter
|
|
$order = array("id");
|
|
$filter = array(
|
|
"IBLOCK_ID" => $id,
|
|
"ACTIVE" => 'Y',
|
|
);
|
|
$arNavStatParams = array(
|
|
"iNumPage" => 1,
|
|
"nPageSize" => $this->pageSize,
|
|
);
|
|
|
|
// Cycle page to page
|
|
do {
|
|
// Get products on this page
|
|
$elems = array();
|
|
$dbResProductsIds = CIBlockElement::GetList($order, $filter, false, $arNavStatParams, array('ID'));
|
|
|
|
while ($obIds = $dbResProductsIds->Fetch()) {
|
|
$elems[] = $obIds['ID'];
|
|
}
|
|
|
|
foreach ($elems as $elemId) {
|
|
$arFilter = array(
|
|
"IBLOCK_ID" => $id,
|
|
"ID" => array($elemId)
|
|
);
|
|
|
|
$this->ProcessProductOffers(
|
|
$arSelect,
|
|
$arSelectOffer,
|
|
$allCategories,
|
|
$basePriceId,
|
|
$id,
|
|
$iblockData,
|
|
$iblockOffer,
|
|
$barcodes,
|
|
$highloadblockProductProps,
|
|
$highloadblockSkuProps,
|
|
$order,
|
|
$arFilter
|
|
);
|
|
}
|
|
|
|
if ($this->isLogged) {
|
|
$this->WriteLog(
|
|
count($elems)
|
|
. " product(s) has been loaded from " . $id . " IB (memory usage: " . memory_get_usage() . ")"
|
|
);
|
|
}
|
|
|
|
$arNavStatParams['iNumPage'] = $dbResProductsIds->NavPageNomer + 1;
|
|
} while ($dbResProductsIds->NavPageNomer < $dbResProductsIds->NavPageCount);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Process offers for a single product
|
|
*
|
|
* @param array $arSelect Properties to select for order
|
|
* @param array $arSelectOffer Properties to select for offer
|
|
* @param array $allCategories Categories to pick data from
|
|
* @param string $basePriceId Base price ID
|
|
* @param string $iblockId iblock id
|
|
* @param array $iblock iblock data
|
|
* @param array $iblockOffer offer iblock
|
|
* @param array $barcodes Catalog barcodes
|
|
* @param array $highloadblockProductProps Product props
|
|
* @param array $highloadblockSkuProps SKU props
|
|
* @param array $order Order data
|
|
* @param array $arFilter filter
|
|
*/
|
|
protected function ProcessProductOffers(
|
|
$arSelect,
|
|
$arSelectOffer,
|
|
$allCategories,
|
|
$basePriceId,
|
|
$iblockId,
|
|
$iblock,
|
|
$iblockOffer,
|
|
$barcodes,
|
|
$highloadblockProductProps,
|
|
$highloadblockSkuProps,
|
|
$order,
|
|
$arFilter
|
|
) {
|
|
$dbResProducts = CIBlockElement::GetList($order, $arFilter, false, false, $arSelect);
|
|
|
|
$products = [];
|
|
|
|
while ($product = $dbResProducts->GetNext()) {
|
|
// Compile products to array
|
|
$products[$product['ID']] = $product;
|
|
$products[$product['ID']]['offers'] = [];
|
|
}
|
|
|
|
unset($product);
|
|
|
|
if (!empty($iblockOffer['IBLOCK_ID']) && !empty($products)) {
|
|
$arFilterOffer = array(
|
|
'IBLOCK_ID' => $iblockOffer['IBLOCK_ID'],
|
|
'PROPERTY_' . $iblockOffer['SKU_PROPERTY_ID'] => array_keys($products),
|
|
);
|
|
|
|
// Get all offers for products on this page
|
|
$dbResOffers = CIBlockElement::GetList(
|
|
array(),
|
|
$arFilterOffer,
|
|
false,
|
|
array('nTopCount' => $this->pageSize * $this->offerPageSize),
|
|
$arSelectOffer
|
|
);
|
|
|
|
while ($offer = $dbResOffers->GetNext()) {
|
|
// Link offers to products
|
|
$products[$offer['PROPERTY_' . $iblockOffer['SKU_PROPERTY_ID'] . '_VALUE']]['offers'][$offer['ID']] = $offer;
|
|
}
|
|
|
|
unset($offer, $dbResOffers);
|
|
}
|
|
|
|
foreach ($products as $product) {
|
|
$product['PICTURE'] = $this->getProductPicture($iblockId, $product);
|
|
$resPropertiesProduct = $this->getProductProperties($iblockId, $highloadblockProductProps, $product);
|
|
$categories = $this->getProductCategories($allCategories, $iblockId, $product['ID']);
|
|
|
|
$existOffer = false;
|
|
if (!empty($iblockOffer['IBLOCK_ID'])) {
|
|
foreach ($product['offers'] as $offer) {
|
|
$offer['BARCODE'] = isset($barcodes[$offer['ID']]) ? $barcodes[$offer['ID']] : '';
|
|
$offer['PRODUCT_ID'] = $product["ID"];
|
|
$offer['DETAIL_PAGE_URL'] = $product["DETAIL_PAGE_URL"];
|
|
|
|
if (CFile::GetPath($offer["DETAIL_PICTURE"])) {
|
|
$offer['PICTURE'] = $this->getImageUrl($offer["DETAIL_PICTURE"]);
|
|
} elseif (CFile::GetPath($offer["PREVIEW_PICTURE"])) {
|
|
$offer['PICTURE'] = $this->getImageUrl($offer["PREVIEW_PICTURE"]);
|
|
} elseif (
|
|
$this->skuPictures
|
|
&& isset($this->skuPictures[$iblockId])
|
|
&& CFile::GetPath($offer["PROPERTY_" . $this->skuPictures[$iblockId]['picture'] . "_VALUE"])
|
|
) {
|
|
$offer['PICTURE'] = $this->getImageUrl($offer["PROPERTY_" . $this->skuPictures[$iblockId]['picture'] . "_VALUE"]);
|
|
} else {
|
|
$offer['PICTURE'] = $product['PICTURE'];
|
|
}
|
|
|
|
$offer['PRODUCT_NAME'] = $product["NAME"];
|
|
$offer['PRODUCT_ACTIVE'] = $product["ACTIVE"];
|
|
$offer['PRICE'] = $offer['CATALOG_PRICE_' . $basePriceId];
|
|
$offer['PURCHASE_PRICE'] = $offer['CATALOG_PURCHASING_PRICE'];
|
|
$offer['QUANTITY'] = $offer["CATALOG_QUANTITY"];
|
|
|
|
// Get properties of product
|
|
foreach ($this->propertiesSKU[$iblockId] as $key => $propSKU) {
|
|
if ($propSKU != "") {
|
|
if (isset ($offer["PROPERTY_" . $propSKU . "_NAME"])) {
|
|
$offer['_PROP_' . $key] = $offer["PROPERTY_" . $propSKU . "_NAME"];
|
|
} elseif (isset($offer["PROPERTY_" . $propSKU . "_VALUE"])) {
|
|
$offer['_PROP_' . $key] = $offer["PROPERTY_" . $propSKU . "_VALUE"];
|
|
} elseif (isset($offer[$propSKU])) {
|
|
$offer['_PROP_' . $key] = $offer[$propSKU];
|
|
}
|
|
if (array_key_exists($key, $this->propertiesUnitSKU[$iblockId])) {
|
|
$offer['_PROP_' . $key] *= $this->measurement[$this->propertiesUnitSKU[$iblockId][$key]];
|
|
$offer['_PROP_' . $key . "_UNIT"] = $this->measurementLink[$this->propertiesUnitSKU[$iblockId][$key]];
|
|
}
|
|
if (isset($highloadblockSkuProps[$propSKU])) {
|
|
$propVal = $this->getHBprop($highloadblockSkuProps[$propSKU], $offer["PROPERTY_" . $propSKU . "_VALUE"]);
|
|
$tableName = $highloadblockSkuProps[$propSKU]['USER_TYPE_SETTINGS']['TABLE_NAME'];
|
|
$field = $this->highloadblockSkuProperties[$tableName][$iblockId][$key];
|
|
$offer['_PROP_' . $key] = $propVal[$field];
|
|
}
|
|
}
|
|
}
|
|
|
|
foreach ($resPropertiesProduct as $key => $propProduct) {
|
|
if ($this->propertiesProduct[$iblockId][$key] != "" && !isset($offer[$key])) {
|
|
$offer['_PROP_' . $key] = $propProduct;
|
|
}
|
|
}
|
|
|
|
$this->PutOffer($offer, $categories, $iblock, $allCategories);
|
|
$existOffer = true;
|
|
}
|
|
}
|
|
|
|
if (!$existOffer) {
|
|
$offer['BARCODE'] = isset($barcodes[$product["ID"]]) ? $barcodes[$product["ID"]] : '';
|
|
$product['PRODUCT_ID'] = $product["ID"];
|
|
$product['PRODUCT_NAME'] = $product["NAME"];
|
|
$product['PRODUCT_ACTIVE'] = $product["ACTIVE"];
|
|
$product['PRICE'] = $product['CATALOG_PRICE_' . $basePriceId];
|
|
$product['PURCHASE_PRICE'] = $product['CATALOG_PURCHASING_PRICE'];
|
|
$product['QUANTITY'] = $product["CATALOG_QUANTITY"];
|
|
|
|
foreach ($resPropertiesProduct as $key => $propProduct) {
|
|
if ($this->propertiesProduct[$iblockId][$key] != "" || $this->propertiesProduct[$iblockId][str_replace("_UNIT", "", $key)] != "") {
|
|
$product['_PROP_' . $key] = $propProduct;
|
|
}
|
|
}
|
|
|
|
$this->PutOffer($product, $categories, $iblock, $allCategories);
|
|
}
|
|
}
|
|
|
|
unset($products);
|
|
}
|
|
|
|
protected function getProductPicture($iblockId, array $product)
|
|
{
|
|
$picture = '';
|
|
|
|
if (CFile::GetPath($product["DETAIL_PICTURE"])) {
|
|
$picture = $this->getImageUrl($product["DETAIL_PICTURE"]);
|
|
} elseif (CFile::GetPath($product["PREVIEW_PICTURE"])){
|
|
$picture = $this->getImageUrl($product["PREVIEW_PICTURE"]);
|
|
} elseif (
|
|
$this->productPictures
|
|
&& isset($this->productPictures[$iblockId])
|
|
&& CFile::GetPath($product["PROPERTY_" . $this->productPictures[$iblockId]['picture'] . "_VALUE"])
|
|
) {
|
|
$picture = $this->getImageUrl($product["PROPERTY_" . $this->productPictures[$iblockId]['picture'] . "_VALUE"]);
|
|
}
|
|
|
|
return $picture;
|
|
}
|
|
|
|
protected function PutOffer($arOffer, $categories, $iblock, &$allCategories)
|
|
{
|
|
$offerData = $this->BuildOffer($arOffer, $categories, $iblock, $allCategories);
|
|
|
|
if ($offerData !== "") {
|
|
$this->WriteOffers($offerData);
|
|
}
|
|
}
|
|
|
|
protected function BuildOffer($arOffer, $categories, $iblock, &$allCategories)
|
|
{
|
|
$offer = "";
|
|
$offer .= "<offer id=\"" .$this->PrepareValue($arOffer["ID"]) . "\" ".
|
|
"productId=\"" . $this->PrepareValue($arOffer["PRODUCT_ID"]) . "\" ".
|
|
"quantity=\"" . $this->PrepareValue(DoubleVal($arOffer['QUANTITY'])) . "\">\n";
|
|
|
|
if ($arOffer['PRODUCT_ACTIVE'] == "N") {
|
|
$offer .= "<productActivity>" . $this->PrepareValue($arOffer['PRODUCT_ACTIVE']) . "</productActivity>\n";
|
|
}
|
|
|
|
$keys = array_keys($categories);
|
|
if (strpos($arOffer['DETAIL_PAGE_URL'], "#SECTION_PATH#") !== false) {
|
|
if (count($categories) != 0) {
|
|
$category = $allCategories[$keys[0]];
|
|
$path = $category['CODE'];
|
|
|
|
if (intval($category["IBLOCK_SECTION_ID"] ) != 0) {
|
|
while (true) {
|
|
$category = $allCategories[$category['IBLOCK_SECTION_ID']];
|
|
$path = $category['CODE'] . '/' . $path;
|
|
if(intval($category["IBLOCK_SECTION_ID"]) == 0){
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
$arOffer['DETAIL_PAGE_URL'] = str_replace("#SECTION_PATH#", $path, $arOffer['DETAIL_PAGE_URL']);
|
|
}
|
|
|
|
if (isset($arOffer["PICTURE"]) && $arOffer["PICTURE"]) {
|
|
$offer .= "<picture>" . $this->PrepareValue($arOffer["PICTURE"]) . "</picture>\n";
|
|
}
|
|
|
|
$offer .= "<url>" . $this->protocol . $this->serverName . $this->PrepareValue($arOffer['DETAIL_PAGE_URL']) . "</url>\n";
|
|
|
|
$offer .= "<price>" . $this->PrepareValue($arOffer['PRICE']) . "</price>\n";
|
|
|
|
if ($this->loadPurchasePrice) {
|
|
if ($arOffer['PURCHASE_PRICE']) {
|
|
$offer .= "<purchasePrice>" . $this->PrepareValue($arOffer['PURCHASE_PRICE']) . "</purchasePrice>\n";
|
|
} elseif ("Y" == $this->purchasePriceNull) {
|
|
$offer .= "<purchasePrice>0</purchasePrice>\n";
|
|
}
|
|
}
|
|
|
|
foreach ($categories as $category) {
|
|
$offer .= "<categoryId>" . $category['ID'] . "</categoryId>\n";
|
|
}
|
|
|
|
$offer .= "<name>" . $this->PrepareValue($arOffer["NAME"]) . "</name>\n";
|
|
|
|
$offer .= "<xmlId>" . $this->PrepareValue($arOffer["EXTERNAL_ID"]) . "</xmlId>\n";
|
|
$offer .= "<productName>" . $this->PrepareValue($arOffer["PRODUCT_NAME"]) . "</productName>\n";
|
|
|
|
foreach ($this->propertiesProduct[$iblock['ID']] as $key => $propProduct) {
|
|
if ($propProduct != "" && $arOffer['_PROP_' . $key] != null) {
|
|
if ($key === "manufacturer") {
|
|
$offer .= "<vendor>" . $this->PrepareValue($arOffer['_PROP_' . $key]) . "</vendor>\n";
|
|
} else {
|
|
$name = $key;
|
|
|
|
if (isset($this->localizedIBlockProps[$key])) {
|
|
$name = $this->localizedIBlockProps[$key];
|
|
}
|
|
|
|
$offer .= '<param name="' . $this->PrepareValue($name) . '" code="' . $key . '"' . (isset($arOffer['_PROP_' . $key . "_UNIT"]) ? ' unit="' . $arOffer['_PROP_' . $key . "_UNIT"] . '"' : "") . ">" . $this->PrepareValue($arOffer['_PROP_' . $key]) . "</param>\n";
|
|
}
|
|
}
|
|
}
|
|
foreach ($this->propertiesSKU[$iblock['ID']] as $key => $propProduct) {
|
|
if ($propProduct != "" && $arOffer['_PROP_' . $key] != null) {
|
|
if ($key === "manufacturer") {
|
|
$offer .= "<vendor>" . $this->PrepareValue($arOffer['_PROP_' . $key]) . "</vendor>\n";
|
|
} else {
|
|
$name = $key;
|
|
|
|
if (isset($this->localizedIBlockProps[$key])) {
|
|
$name = $this->localizedIBlockProps[$key];
|
|
}
|
|
|
|
$offer .= '<param name="' . $this->PrepareValue($name) . '" code="' . $key . '"' . (isset($arOffer['_PROP_' . $key . "_UNIT"]) ? ' unit="' . $arOffer['_PROP_' . $key . "_UNIT"] . '"' : "") . ">" . $this->PrepareValue($arOffer['_PROP_' . $key]) . "</param>\n";
|
|
}
|
|
}
|
|
}
|
|
if (isset($arOffer["MEASURE"]['SYMBOL_INTL'])) {
|
|
if ($this->measure[$arOffer["MEASURE"]['SYMBOL_INTL']]) {
|
|
$offer .= '<unit code="' . $this->measure[$this->PrepareValue($arOffer["MEASURE"]['SYMBOL_INTL'])] . '" />' . "\n";
|
|
} else {
|
|
$offer .= '<unit code="' . $this->PrepareValue($arOffer["MEASURE"]['SYMBOL_INTL']) . '" name="' . $this->PrepareValue($arOffer["MEASURE"]['MEASURE_TITLE']) . '" sym="' . $this->PrepareValue($arOffer["MEASURE"]['SYMBOL_RUS']) . '" />' . "\n";
|
|
}
|
|
} else {
|
|
$measure = \Bitrix\Catalog\ProductTable::getCurrentRatioWithMeasure($arOffer["ID"]);
|
|
|
|
if ($this->measure[$measure[$arOffer["ID"]]["MEASURE"]['SYMBOL_INTL']]) {
|
|
$offer .= '<unit code="' . $this->measure[$this->PrepareValue($measure[$arOffer["ID"]]["MEASURE"]['SYMBOL_INTL'])] . '" />' . "\n";
|
|
} else {
|
|
$offer .= '<unit code="' . $this->PrepareValue($measure[$arOffer["ID"]]["MEASURE"]['SYMBOL_INTL']) . '" name="' . $this->PrepareValue($measure[$arOffer["ID"]]["MEASURE"]['MEASURE_TITLE']) . '" sym="' . $this->PrepareValue($measure[$arOffer["ID"]]["MEASURE"]['SYMBOL_RUS']) . '" />' . "\n";
|
|
}
|
|
}
|
|
|
|
if ($arOffer["BARCODE"]) {
|
|
$offer.= "<barcode>" . $this->PrepareValue($arOffer["BARCODE"]) . "</barcode>\n";
|
|
}
|
|
|
|
if ((float)$arOffer["CATALOG_VAT"]) {
|
|
$vatRate = $arOffer["CATALOG_VAT"];
|
|
} else {
|
|
$vatRate = 'none';
|
|
}
|
|
|
|
$offer.= "<vatRate>" . $this->PrepareValue($vatRate) . "</vatRate>\n";
|
|
$offer.= "</offer>\n";
|
|
|
|
return $offer;
|
|
}
|
|
|
|
private function getHBprop($hbProp, $xml_id)
|
|
{
|
|
if (CModule::IncludeModule('highloadblock')) {
|
|
$hlblockArr = \Bitrix\Highloadblock\HighloadBlockTable::getList(array(
|
|
'filter' => array('=TABLE_NAME' => $hbProp['USER_TYPE_SETTINGS']['TABLE_NAME'])
|
|
))->fetch();
|
|
|
|
$hlblock = HL\HighloadBlockTable::getById($hlblockArr["ID"])->fetch();
|
|
$entity = HL\HighloadBlockTable::compileEntity($hlblock);
|
|
$entityClass = $entity->getDataClass();
|
|
|
|
$result = $entityClass::getList(array(
|
|
'select' => array('*'),
|
|
'filter' => array('UF_XML_ID' => $xml_id)
|
|
));
|
|
|
|
return $result->fetch();
|
|
}
|
|
|
|
return array();
|
|
}
|
|
|
|
/**
|
|
* Returns products IDs with barcodes by infoblock id
|
|
*
|
|
* @param int $iblockId
|
|
*
|
|
* @return array
|
|
*/
|
|
private function getProductBarcodesByIblock($iblockId)
|
|
{
|
|
$barcodes = array();
|
|
$dbBarCode = CCatalogStoreBarCode::getList(
|
|
array(),
|
|
array("IBLOCK_ID" => $iblockId),
|
|
false,
|
|
false,
|
|
array('PRODUCT_ID', 'BARCODE')
|
|
);
|
|
|
|
while ($arBarCode = $dbBarCode->GetNext()) {
|
|
if (!empty($arBarCode)) {
|
|
$barcodes[$arBarCode['PRODUCT_ID']] = $arBarCode['BARCODE'];
|
|
}
|
|
}
|
|
|
|
return $barcodes;
|
|
}
|
|
|
|
/**
|
|
* Returns necessary product properties
|
|
*
|
|
* @param int $iblockId
|
|
* @param array $highloadblockProductProps
|
|
* @param array $product
|
|
*
|
|
* @return array
|
|
*/
|
|
private function getProductProperties($iblockId, $highloadblockProductProps, $product)
|
|
{
|
|
// Get properties of product
|
|
$resPropertiesProduct = array();
|
|
|
|
foreach ($this->propertiesProduct[$iblockId] as $key => $propProduct) {
|
|
$resPropertiesProduct[$key] = "";
|
|
|
|
if ($propProduct != "") {
|
|
if (isset($product["PROPERTY_" . $propProduct . "_NAME"])) {
|
|
$resPropertiesProduct[$key] = $product["PROPERTY_" . $propProduct . "_NAME"];
|
|
} elseif (isset($product["PROPERTY_" . $propProduct . "_VALUE"])) {
|
|
$resPropertiesProduct[$key] = $product["PROPERTY_" . $propProduct . "_VALUE"];
|
|
} elseif (isset($product[$propProduct])) {
|
|
$resPropertiesProduct[$key] = $product[$propProduct];
|
|
}
|
|
|
|
if (array_key_exists($key, $this->propertiesUnitProduct[$iblockId])) {
|
|
$resPropertiesProduct[$key] *= $this->measurement[$this->propertiesUnitProduct[$iblockId][$key]];
|
|
$resPropertiesProduct[$key . "_UNIT"] = $this->measurementLink[$this->propertiesUnitProduct[$iblockId][$key]];
|
|
}
|
|
|
|
if (isset($highloadblockProductProps[$propProduct])) {
|
|
$propVal = $this->getHBprop($highloadblockProductProps[$propProduct], $product["PROPERTY_" . $propProduct . "_VALUE"]);
|
|
$tableName = $highloadblockProductProps[$propProduct]['USER_TYPE_SETTINGS']['TABLE_NAME'];
|
|
$field = $this->highloadblockProductProperties[$tableName][$iblockId][$key];
|
|
|
|
$resPropertiesProduct[$key] = $propVal[$field];
|
|
}
|
|
}
|
|
}
|
|
|
|
return $resPropertiesProduct;
|
|
}
|
|
|
|
/**
|
|
* @param array $allCategories
|
|
* @param int $iblockId
|
|
* @param string $productId
|
|
*
|
|
* @return array
|
|
*/
|
|
private function getProductCategories(&$allCategories, $iblockId, $productId)
|
|
{
|
|
$categories = array();
|
|
$dbResCategories = CIBlockElement::GetElementGroups($productId, true);
|
|
|
|
while ($arResCategory = $dbResCategories->Fetch()) {
|
|
$categories[$arResCategory["ID"]] = array(
|
|
'ID' => $arResCategory["ID"],
|
|
'NAME' => $arResCategory["NAME"],
|
|
);
|
|
}
|
|
|
|
if (count($categories) == 0) {
|
|
$catId = $this->mainSection + $iblockId;
|
|
$categories[$catId] = $allCategories[$catId];
|
|
}
|
|
|
|
return $categories;
|
|
}
|
|
|
|
private function buildProductQuery($iblockId)
|
|
{
|
|
$arSelect = array(
|
|
"ID",
|
|
"LID",
|
|
"IBLOCK_ID",
|
|
"IBLOCK_SECTION_ID",
|
|
"ACTIVE",
|
|
"NAME",
|
|
"DETAIL_PICTURE",
|
|
"PREVIEW_PICTURE",
|
|
"DETAIL_PAGE_URL",
|
|
"CATALOG_GROUP_" . $this->getBasePriceId()
|
|
);
|
|
|
|
// Set selected properties
|
|
foreach ($this->propertiesProduct[$iblockId] as $key => $propProduct) {
|
|
if ($this->propertiesProduct[$iblockId][$key] != "") {
|
|
$arSelect[] = "PROPERTY_" . $propProduct;
|
|
$arSelect[] = "PROPERTY_" . $propProduct . ".NAME";
|
|
}
|
|
}
|
|
|
|
if ($this->productPictures && isset($this->productPictures[$iblockId])) {
|
|
$arSelect[] = "PROPERTY_" . $this->productPictures[$iblockId]['picture'];
|
|
$arSelect[] = "PROPERTY_" . $this->productPictures[$iblockId]['picture'] . ".NAME";
|
|
}
|
|
|
|
return $arSelect;
|
|
}
|
|
|
|
private function buildOfferQuery($iblockId, $skuPropertyId)
|
|
{
|
|
$arSelectOffer = array(
|
|
'ID',
|
|
"NAME",
|
|
"DETAIL_PAGE_URL",
|
|
"DETAIL_PICTURE",
|
|
"PREVIEW_PICTURE",
|
|
'PROPERTY_' . $skuPropertyId,
|
|
"CATALOG_GROUP_" . $this->getBasePriceId()
|
|
);
|
|
|
|
// Set selected properties
|
|
foreach ($this->propertiesSKU[$iblockId] as $key => $propSKU) {
|
|
if ($this->propertiesSKU[$iblockId][$key] != "") {
|
|
$arSelectOffer[] = "PROPERTY_" . $propSKU;
|
|
$arSelectOffer[] = "PROPERTY_" . $propSKU . ".NAME";
|
|
}
|
|
}
|
|
|
|
if ($this->skuPictures && isset($this->skuPictures[$iblockId])) {
|
|
$arSelectOffer[] = "PROPERTY_" . $this->skuPictures[$iblockId]['picture'];
|
|
$arSelectOffer[] = "PROPERTY_" . $this->skuPictures[$iblockId]['picture'] . ".NAME";
|
|
}
|
|
|
|
return $arSelectOffer;
|
|
}
|
|
|
|
private function getAvailableHighloadProductProps($iblockId)
|
|
{
|
|
$highloadblockProductProps = array();
|
|
$productProps = CIBlockproperty::GetList(array(), array("IBLOCK_ID" => $iblockId));
|
|
|
|
while ($arrProductProps = $productProps->Fetch()) {
|
|
if ($arrProductProps["USER_TYPE"] == 'directory') {
|
|
$highloadblockProductProps[$arrProductProps['CODE']] = $arrProductProps;
|
|
}
|
|
}
|
|
|
|
return $highloadblockProductProps;
|
|
}
|
|
|
|
private function getAvailableHighloadOfferSkuProps($iblockId)
|
|
{
|
|
$highloadblockSkuProps = array();
|
|
$skuProps = CIBlockproperty::GetList(array(), array("IBLOCK_ID" => $iblockId));
|
|
|
|
while ($arrSkuProps = $skuProps->Fetch()) {
|
|
if ($arrSkuProps["USER_TYPE"] == 'directory') {
|
|
$highloadblockSkuProps[$arrSkuProps['CODE']] = $arrSkuProps;
|
|
}
|
|
}
|
|
|
|
return $highloadblockSkuProps;
|
|
}
|
|
|
|
/**
|
|
* Returns base price id
|
|
*
|
|
* @return string
|
|
*/
|
|
private function getBasePriceId()
|
|
{
|
|
$basePriceId = COption::GetOptionString(
|
|
$this->MODULE_ID,
|
|
$this->CRM_CATALOG_BASE_PRICE . '_' . $this->profileID,
|
|
0
|
|
);
|
|
|
|
if (!$basePriceId) {
|
|
$dbPriceType = CCatalogGroup::GetList(
|
|
array(),
|
|
array('BASE' => 'Y'),
|
|
false,
|
|
false,
|
|
array('ID')
|
|
);
|
|
|
|
$result = $dbPriceType->GetNext();
|
|
$basePriceId = $result['ID'];
|
|
}
|
|
|
|
return $basePriceId;
|
|
}
|
|
|
|
private function getLocalizedIBlockProps()
|
|
{
|
|
return array(
|
|
"article" => GetMessage("PROPERTY_ARTICLE_HEADER_NAME"),
|
|
"manufacturer" => GetMessage("PROPERTY_MANUFACTURER_HEADER_NAME"),
|
|
"color" => GetMessage("PROPERTY_COLOR_HEADER_NAME"),
|
|
"size" => GetMessage("PROPERTY_SIZE_HEADER_NAME"),
|
|
"weight" => GetMessage("PROPERTY_WEIGHT_HEADER_NAME"),
|
|
"length" => GetMessage("PROPERTY_LENGTH_HEADER_NAME"),
|
|
"width" => GetMessage("PROPERTY_WIDTH_HEADER_NAME"),
|
|
"height" => GetMessage("PROPERTY_HEIGHT_HEADER_NAME"),
|
|
"picture" => GetMessage("PROPERTY_PICTURE_HEADER_NAME")
|
|
);
|
|
}
|
|
|
|
/**
|
|
* @param $fileId
|
|
* @return string
|
|
*/
|
|
public function getImageUrl($fileId)
|
|
{
|
|
$pathImage = CFile::GetPath($fileId);
|
|
$validation = "/^(http|https):\/\/([A-Z0-9][A-Z0-9_-]*(?:\.[A-Z0-9][A-Z0-9_-]*)+):?(\d+)?\/?/i";
|
|
|
|
if ((bool)preg_match($validation, $pathImage) === false) {
|
|
return $this->protocol . $this->serverName . $pathImage;
|
|
} else {
|
|
return $pathImage;
|
|
}
|
|
}
|
|
}
|