| Server IP : 37.220.80.31 / Your IP : 18.216.197.92 Web Server : Apache/2.4.52 (Ubuntu) System : Linux 3051455-guretool.twc1.net 5.15.0-107-generic #117-Ubuntu SMP Fri Apr 26 12:26:49 UTC 2024 x86_64 User : www-root ( 1010) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/www-root/data/www/dev.artlot24.ru/bitrix/modules/catalog/general/ |
Upload File : |
<?
use Bitrix\Main,
Bitrix\Main\Localization\Loc,
Bitrix\Catalog;
Loc::loadMessages(__FILE__);
class CAllPrice
{
/**
* @deprecated deprecated since catalog 17.6.0
*
* @param string $ACTION
* @param array &$arFields
* @param int $ID
* @return bool
*/
public static function CheckFields($ACTION, &$arFields, $ID = 0)
{
global $APPLICATION;
$currency = false;
if ($ACTION == "ADD")
{
if (!isset($arFields['PRODUCT_ID']))
{
$APPLICATION->ThrowException(Loc::getMessage("KGP_EMPTY_PRODUCT"), "EMPTY_PRODUCT_ID");
return false;
}
if (!isset($arFields['CATALOG_GROUP_ID']))
{
$APPLICATION->ThrowException(Loc::getMessage("KGP_EMPTY_CATALOG_GROUP"), "EMPTY_CATALOG_GROUP_ID");
return false;
}
if (!isset($arFields['CURRENCY']))
{
$APPLICATION->ThrowException(Loc::getMessage("KGP_EMPTY_CURRENCY"), "EMPTY_CURRENCY");
return false;
}
if (!isset($arFields['PRICE']))
$arFields['PRICE'] = 0;
if (!isset($arFields['QUANTITY_FROM']))
$arFields['QUANTITY_FROM'] = false;
if (!isset($arFields['QUANTITY_TO']))
$arFields['QUANTITY_TO'] = false;
}
$priceExist = isset($arFields['PRICE']);
$currencyExist = isset($arFields['CURRENCY']);
if (isset($arFields['PRODUCT_ID']))
{
$arFields['PRODUCT_ID'] = (int)$arFields['PRODUCT_ID'];
if ($arFields['PRODUCT_ID'] <= 0)
{
$APPLICATION->ThrowException(Loc::getMessage("KGP_EMPTY_PRODUCT"), "EMPTY_PRODUCT_ID");
return false;
}
}
if (isset($arFields['CATALOG_GROUP_ID']))
{
$arFields['CATALOG_GROUP_ID'] = (int)$arFields['CATALOG_GROUP_ID'];
if ($arFields['CATALOG_GROUP_ID'] <= 0)
{
$APPLICATION->ThrowException(Loc::getMessage("KGP_EMPTY_CATALOG_GROUP"), "EMPTY_CATALOG_GROUP_ID");
return false;
}
}
if ($priceExist)
$arFields['PRICE'] = (float)$arFields['PRICE'];
if ($currencyExist)
{
$currency = CCurrency::GetByID($arFields['CURRENCY']);
if (empty($currency))
{
$APPLICATION->ThrowException(Loc::getMessage("KGP_NO_CURRENCY", array('#ID#' => $arFields["CURRENCY"])), "CURRENCY");
return false;
}
}
if (isset($arFields['PRICE_SCALE']))
{
$arFields['PRICE_SCALE'] = (float)$arFields['PRICE_SCALE'];
}
else
{
if ($priceExist != $currencyExist)
{
$iterator = Catalog\PriceTable::getList(array(
'select' => array('PRICE', 'CURRENCY'),
'filter' => array('=ID' => $ID)
));
$currentValues = $iterator->fetch();
if (!empty($currentValues))
{
$currentPrice = ($priceExist ? $arFields['PRICE'] : (float)$currentValues['PRICE']);
$currentCurrency = ($currencyExist ? $arFields['CURRENCY'] : $currentValues['CURRENCY']);
$currency = CCurrency::GetByID($currentCurrency);
if (!empty($currency))
$arFields['PRICE_SCALE'] = $currentPrice*$currency['CURRENT_BASE_RATE'];
unset($currentCurrency, $currentPrice);
}
unset($currentValues, $iterator);
}
elseif ($priceExist && $currencyExist)
{
$arFields['PRICE_SCALE'] = $arFields['PRICE']*$currency['CURRENT_BASE_RATE'];
}
}
unset($currencyExist, $priceExist, $currency);
if (isset($arFields['QUANTITY_FROM']) && $arFields['QUANTITY_FROM'] !== false)
{
$arFields['QUANTITY_FROM'] = (int)$arFields['QUANTITY_FROM'];
if ($arFields['QUANTITY_FROM'] <= 0)
$arFields['QUANTITY_FROM'] = false;
}
if (isset($arFields['QUANTITY_TO']) && $arFields['QUANTITY_TO'] !== false)
{
$arFields['QUANTITY_TO'] = (int)$arFields['QUANTITY_TO'];
if ($arFields['QUANTITY_TO'] <= 0)
$arFields['QUANTITY_TO'] = false;
}
return true;
}
/**
* @param int $id
* @return array|false
*/
public static function GetByID($id)
{
global $USER;
$id = (int)$id;
if ($id <= 0)
return false;
$price = Catalog\PriceTable::getById($id)->fetch();
if (empty($price))
return false;
if ($price['TIMESTAMP_X'] instanceof Main\Type\DateTime)
$price['TIMESTAMP_X'] = $price['TIMESTAMP_X']->toString();
$priceTypes = CCatalogGroup::GetListArray();
$price['CATALOG_GROUP_NAME'] = null;
if (isset($priceTypes[$price['CATALOG_GROUP_ID']]))
{
$price['CATALOG_GROUP_NAME'] = ($priceTypes[$price['CATALOG_GROUP_ID']]['NAME_LANG'] !== null
? $priceTypes[$price['CATALOG_GROUP_ID']]['NAME_LANG']
: $priceTypes[$price['CATALOG_GROUP_ID']]['NAME']
);
}
unset($priceTypes);
$price['CAN_ACCESS'] = 'N';
$price['CAN_BUY'] = 'N';
$iterator = Catalog\GroupAccessTable::getList(array(
'select' => array('ACCESS'),
'filter' => array(
'=CATALOG_GROUP_ID' => $price['CATALOG_GROUP_ID'],
'@GROUP_ID' => (CCatalog::IsUserExists() ? $USER->GetUserGroupArray() : array(2))
)
));
while ($row = $iterator->fetch())
{
if ($row['ACCESS'] == Catalog\GroupAccessTable::ACCESS_BUY)
$price['CAN_ACCESS'] = 'Y';
elseif ($row['ACCESS'] == Catalog\GroupAccessTable::ACCESS_VIEW)
$price['CAN_BUY'] = 'Y';
}
unset($row, $iterator);
return $price;
}
/**
* @deprecated deprecated since catalog 17.6.0
* @see \Bitrix\Catalog\Model\Price::add
*
* @param array $fields
* @param bool $recount
* @return bool|int
*/
public static function Add($fields, $recount = false)
{
if (!is_array($fields))
return false;
if (!isset($fields['PRICE']))
$fields['PRICE'] = 0;
self::normalizeFields($fields);
$data = array(
'fields' => $fields
);
$recount = ($recount === true);
if ($recount)
$data['actions'] = array('OLD_RECOUNT' => true);
$result = Catalog\Model\Price::add($data);
unset($data);
$id = false;
if (!$result->isSuccess())
self::convertErrors($result);
else
$id = (int)$result->getId();
unset($result);
return $id;
}
/**
* @deprecated deprecated since catalog 17.6.0
* @see \Bitrix\Catalog\Model\Price::update
*
* @param $id
* @param array $fields
* @param bool $recount
* @return bool|int
*/
public static function Update($id, $fields, $recount = false)
{
$id = (int)$id;
if ($id <= 0 || !is_array($fields))
return false;
self::normalizeFields($fields);
$data = array(
'fields' => $fields
);
$recount = ($recount === true);
if ($recount)
$data['actions'] = array('OLD_RECOUNT' => true);
$result = Catalog\Model\Price::update($id, $data);
unset($data);
if (!$result->isSuccess())
{
$id = false;
self::convertErrors($result);
}
return $id;
}
/**
* @deprecated deprecated since catalog 17.6.0
* @see \Bitrix\Catalog\Model\Price::delete
*
* @param $id
* @return bool
*/
public static function Delete($id)
{
$id = (int)$id;
if ($id <= 0)
return false;
$result = Catalog\Model\Price::delete($id);
$success = $result->isSuccess();
if (!$success)
self::convertErrors($result);
unset($result);
return $success;
}
/**
* @deprecated deprecated since catalog 17.6.0
* @see \Bitrix\Catalog\Model\Price::getList
*
* @param $productID
* @param bool $quantityFrom
* @param bool $quantityTo
* @param bool $boolExt
* @return array|bool|false|mixed|null
*/
public static function GetBasePrice($productID, $quantityFrom = false, $quantityTo = false, $boolExt = true)
{
$productID = (int)$productID;
if ($productID <= 0)
return false;
$arBaseType = CCatalogGroup::GetBaseGroup();
if (empty($arBaseType))
return false;
$arFilter = array(
'PRODUCT_ID' => $productID,
'CATALOG_GROUP_ID' => $arBaseType['ID']
);
if ($quantityFrom !== false)
$arFilter['QUANTITY_FROM'] = (int)$quantityFrom;
if ($quantityTo !== false)
$arFilter['QUANTITY_TO'] = (int)$quantityTo;
if ($boolExt === false)
{
$arSelect = array('ID', 'PRODUCT_ID', 'EXTRA_ID', 'CATALOG_GROUP_ID', 'PRICE', 'CURRENCY', 'TIMESTAMP_X',
'QUANTITY_FROM', 'QUANTITY_TO', 'TMP_ID'
);
}
else
{
$arSelect = array('ID', 'PRODUCT_ID', 'EXTRA_ID', 'CATALOG_GROUP_ID', 'PRICE', 'CURRENCY', 'TIMESTAMP_X',
'QUANTITY_FROM', 'QUANTITY_TO', 'TMP_ID',
'PRODUCT_QUANTITY', 'PRODUCT_QUANTITY_TRACE', 'PRODUCT_CAN_BUY_ZERO',
'PRODUCT_NEGATIVE_AMOUNT_TRACE', 'PRODUCT_WEIGHT', 'ELEMENT_IBLOCK_ID'
);
}
$db_res = CPrice::GetListEx(
array('QUANTITY_FROM' => 'ASC', 'QUANTITY_TO' => 'ASC'),
$arFilter,
false,
array('nTopCount' => 1),
$arSelect
);
if ($res = $db_res->Fetch())
{
$res['BASE'] = 'Y';
$res['CATALOG_GROUP_NAME'] = $arBaseType['NAME'];
return $res;
}
return false;
}
/**
* @deprecated deprecated since catalog 17.6.0
* @see \Bitrix\Catalog\Model\Price::add and \Bitrix\Catalog\Model\Price::update
*
* @param int $ProductID
* @param int|float $Price
* @param string $Currency
* @param bool $quantityFrom
* @param bool $quantityTo
* @param bool $bGetID
* @return bool|int
*/
public static function SetBasePrice($ProductID, $Price, $Currency, $quantityFrom = false, $quantityTo = false, $bGetID = false)
{
$bGetID = ($bGetID == true);
$arFields = array();
$arFields["PRICE"] = (float)$Price;
$arFields["CURRENCY"] = $Currency;
$arFields["QUANTITY_FROM"] = ($quantityFrom == false ? false : (int)$quantityFrom);
$arFields["QUANTITY_TO"] = ($quantityTo == false ? false : (int)$quantityTo);
$arFields["EXTRA_ID"] = false;
if ($arBasePrice = CPrice::GetBasePrice($ProductID, $quantityFrom, $quantityTo, false))
{
$ID = CPrice::Update($arBasePrice["ID"], $arFields);
}
else
{
$arBaseGroup = CCatalogGroup::GetBaseGroup();
$arFields["CATALOG_GROUP_ID"] = $arBaseGroup["ID"];
$arFields["PRODUCT_ID"] = $ProductID;
$ID = CPrice::Add($arFields);
}
if (!$ID)
return false;
return ($bGetID ? $ID : true);
}
public static function ReCalculate($TYPE, $ID, $VAL)
{
$ID = (int)$ID;
if ($ID <= 0)
return;
$iblockList = array();
if ($TYPE == 'EXTRA')
{
$baseType = CCatalogGroup::GetBaseGroup();
if (empty($baseType))
return;
$db_res = CPrice::GetListEx(
array(),
array('EXTRA_ID' => $ID),
false,
false,
array('ID', 'PRODUCT_ID', 'EXTRA_ID', 'QUANTITY_FROM', 'QUANTITY_TO')
);
while ($res = $db_res->Fetch())
{
$parentFilter = array(
'PRODUCT_ID' => $res['PRODUCT_ID'],
'CATALOG_GROUP_ID' => $baseType['ID'],
'QUANTITY_FROM' => ($res['QUANTITY_FROM'] === null ? false : $res['QUANTITY_FROM']),
'QUANTITY_TO' => ($res['QUANTITY_TO'] === null ? false : $res['QUANTITY_TO'])
);
$parentIterator = CPrice::GetListEx(
array(),
$parentFilter,
false,
false,
array('ID', 'PRODUCT_ID', 'PRICE', 'CURRENCY', 'ELEMENT_IBLOCK_ID')
);
$basePrice = $parentIterator->Fetch();
if (!empty($basePrice))
{
$basePrice['ELEMENT_IBLOCK_ID'] = (int)$basePrice['ELEMENT_IBLOCK_ID'];
$fields = array(
'PRICE' => roundex($basePrice['PRICE'] * (1 + 1 * $VAL / 100), 2),
'CURRENCY' => $basePrice['CURRENCY']
);
CPrice::Update($res['ID'], $fields);
unset($arFields);
$iblockList[$basePrice['ELEMENT_IBLOCK_ID']] = $basePrice['ELEMENT_IBLOCK_ID'];
}
unset($basePrice, $parentIterator);
}
unset($res, $db_res, $baseType);
}
else
{
$db_res = CPrice::GetListEx(
array(),
array("PRODUCT_ID" => $ID),
false,
false,
array('ID', 'PRODUCT_ID', 'EXTRA_ID', 'ELEMENT_IBLOCK_ID')
);
while ($res = $db_res->Fetch())
{
$res['ELEMENT_IBLOCK_ID'] = (int)$res['ELEMENT_IBLOCK_ID'];
$res["EXTRA_ID"] = (int)$res["EXTRA_ID"];
if ($res["EXTRA_ID"] > 0)
{
$res1 = CExtra::GetByID($res["EXTRA_ID"]);
$arFields = array(
"PRICE" => $VAL * (1 + 1 * $res1["PERCENTAGE"] / 100),
);
CPrice::Update($res["ID"], $arFields);
$iblockList[$res['ELEMENT_IBLOCK_ID']] = $res['ELEMENT_IBLOCK_ID'];
}
}
unset($res, $db_res);
}
if (!empty($iblockList) && Main\Loader::includeModule('iblock'))
{
foreach ($iblockList as &$iblock)
CIblock::clearIblockTagCache($iblock);
unset($iblock);
}
unset($iblockList);
}
public static function OnCurrencyDelete($Currency)
{
global $DB;
if ($Currency == '')
return false;
$strSql = "DELETE FROM b_catalog_price WHERE CURRENCY = '".$DB->ForSql($Currency)."'";
return $DB->Query($strSql, true);
}
/**
* @deprecated deprecated since catalog 17.6.0
* @see \Bitrix\Catalog\Model\Product::delete
*
* @param int $ProductID
* @return bool
*/
public static function OnIBlockElementDelete($ProductID)
{
return true;
}
public static function DeleteByProduct($ProductID, $arExceptionIDs = array())
{
global $DB;
$ProductID = (int)$ProductID;
if ($ProductID <= 0)
return false;
foreach (GetModuleEvents("catalog", "OnBeforeProductPriceDelete", true) as $arEvent)
{
if (ExecuteModuleEventEx($arEvent, array($ProductID, &$arExceptionIDs))===false)
return false;
}
if (!empty($arExceptionIDs))
Main\Type\Collection::normalizeArrayValuesByInt($arExceptionIDs);
if (!empty($arExceptionIDs))
{
$strSql = "DELETE FROM b_catalog_price WHERE PRODUCT_ID = ".$ProductID." AND ID NOT IN (".implode(',',$arExceptionIDs).")";
}
else
{
$strSql = "DELETE FROM b_catalog_price WHERE PRODUCT_ID = ".$ProductID;
}
$mxRes = $DB->Query($strSql, true);
foreach (GetModuleEvents("catalog", "OnProductPriceDelete", true) as $arEvent)
ExecuteModuleEventEx($arEvent, array($ProductID,$arExceptionIDs));
Catalog\Product\Sku::calculatePrice($ProductID, null, null, array());
return $mxRes;
}
/**
* @deprecated deprecated since catalog 17.6.0
* @see \Bitrix\Catalog\Model\Price::add and \Bitrix\Catalog\Model\Price::update
*
* @param array &$arFields
* @return void
*/
public static function ReCountForBase(&$arFields)
{
static $arExtraList = array();
$arFilter = array('PRODUCT_ID' => $arFields['PRODUCT_ID'],'!CATALOG_GROUP_ID' => $arFields['CATALOG_GROUP_ID']);
if (isset($arFields['QUANTITY_FROM']))
$arFilter['QUANTITY_FROM'] = $arFields['QUANTITY_FROM'];
if (isset($arFields['QUANTITY_TO']))
$arFilter['QUANTITY_TO'] = $arFields['QUANTITY_TO'];
$rsPrices = CPrice::GetListEx(
array('CATALOG_GROUP_ID' => 'ASC',"QUANTITY_FROM" => "ASC", "QUANTITY_TO" => "ASC"),
$arFilter,
false,
false,
array('ID','EXTRA_ID')
);
while ($arPrice = $rsPrices->Fetch())
{
$arPrice['EXTRA_ID'] = (int)$arPrice['EXTRA_ID'];
if ($arPrice['EXTRA_ID'] > 0)
{
$boolSearch = isset($arExtraList[$arPrice['EXTRA_ID']]);
if (!$boolSearch)
{
$arExtra = CExtra::GetByID($arPrice['EXTRA_ID']);
if (!empty($arExtra))
{
$boolSearch = true;
$arExtraList[$arExtra['ID']] = (float)$arExtra['PERCENTAGE'];
}
}
if ($boolSearch)
{
$arNewPrice = array(
'CURRENCY' => $arFields['CURRENCY'],
'PRICE' => roundEx($arFields["PRICE"] * (1 + $arExtraList[$arPrice['EXTRA_ID']]/100), CATALOG_VALUE_PRECISION),
);
CPrice::Update($arPrice['ID'],$arNewPrice,false);
}
unset($boolSearch);
}
}
}
/**
* @deprecated deprecated since catalog 17.6.0
* @see \Bitrix\Catalog\Model\Price::add and \Bitrix\Catalog\Model\Price::update
*
* @param array &$arFields
* @param bool &$boolBase
* @return void
*/
public static function ReCountFromBase(&$arFields, &$boolBase)
{
$arBaseGroup = CCatalogGroup::GetBaseGroup();
if (!empty($arBaseGroup))
{
if ($arFields['CATALOG_GROUP_ID'] == $arBaseGroup['ID'])
{
$boolBase = true;
}
else
{
if (!empty($arFields['EXTRA_ID']) && intval($arFields['EXTRA_ID']) > 0)
{
$arExtra = CExtra::GetByID($arFields['EXTRA_ID']);
if (!empty($arExtra))
{
$arExtra["PERCENTAGE"] = (float)$arExtra["PERCENTAGE"];
$arFilter = array('PRODUCT_ID' => $arFields['PRODUCT_ID'],'CATALOG_GROUP_ID' => $arBaseGroup['ID']);
if (isset($arFields['QUANTITY_FROM']))
$arFilter['QUANTITY_FROM'] = $arFields['QUANTITY_FROM'];
if (isset($arFields['QUANTITY_TO']))
$arFilter['QUANTITY_TO'] = $arFields['QUANTITY_TO'];
$rsBasePrices = CPrice::GetListEx(
array("QUANTITY_FROM" => "ASC", "QUANTITY_TO" => "ASC"),
$arFilter,
false,
array('nTopCount' => 1),
array('PRICE','CURRENCY')
);
if ($arBasePrice = $rsBasePrices->Fetch())
{
$arFields['CURRENCY'] = $arBasePrice['CURRENCY'];
$arFields['PRICE'] = roundEx($arBasePrice["PRICE"] * (1 + $arExtra["PERCENTAGE"]/100), CATALOG_VALUE_PRECISION);
$currency = CCurrency::GetByID($arBasePrice['CURRENCY']);
if (!empty($currency))
$arFields['PRICE_SCALE'] = $arFields['PRICE']*$currency['CURRENT_BASE_RATE'];
}
else
{
$arFields['EXTRA_ID'] = 0;
}
}
else
{
$arFields['EXTRA_ID'] = 0;
}
}
}
}
}
private static function convertErrors(Main\Entity\Result $result)
{
global $APPLICATION;
$oldMessages = array();
foreach ($result->getErrorMessages() as $errorText)
$oldMessages[] = array('text' => $errorText);
unset($errorText);
if (!empty($oldMessages))
{
$error = new CAdminException($oldMessages);
$APPLICATION->ThrowException($error);
unset($error);
}
unset($oldMessages);
}
private static function normalizeFields(array &$fields)
{
if (isset($fields['QUANTITY_FROM']))
{
if (is_string($fields['QUANTITY_FROM']) && $fields['QUANTITY_FROM'] === '')
$fields['QUANTITY_FROM'] = null;
elseif ($fields['QUANTITY_FROM'] === false || $fields['QUANTITY_FROM'] === 0)
$fields['QUANTITY_FROM'] = null;
}
if (isset($fields['QUANTITY_TO']))
{
if (is_string($fields['QUANTITY_TO']) && $fields['QUANTITY_TO'] === '')
$fields['QUANTITY_TO'] = null;
elseif ($fields['QUANTITY_TO'] === false || $fields['QUANTITY_TO'] === 0)
$fields['QUANTITY_TO'] = null;
}
if (isset($fields['EXTRA_ID']))
{
if (is_string($fields['EXTRA_ID']) && $fields['EXTRA_ID'] === '')
$fields['EXTRA_ID'] = null;
elseif ($fields['EXTRA_ID'] === false)
$fields['EXTRA_ID'] = null;
}
}
}