| Server IP : 37.220.80.31 / Your IP : 3.144.2.218 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/mysql/ |
Upload File : |
<?php
require_once($_SERVER["DOCUMENT_ROOT"]."/bitrix/modules/catalog/general/store_docs.php");
class CCatalogDocs extends CAllCatalogDocs
{
/**
* @static
* @param $arFields
* @return bool|int
*/
public static function add($arFields)
{
global $DB;
foreach(GetModuleEvents("catalog", "OnBeforeDocumentAdd", true) as $arEvent)
if(ExecuteModuleEventEx($arEvent, array(&$arFields)) === false)
return false;
if(array_key_exists('DATE_CREATE', $arFields))
unset($arFields['DATE_CREATE']);
if(array_key_exists('DATE_MODIFY', $arFields))
unset($arFields['DATE_MODIFY']);
$arFields['~DATE_MODIFY'] = $DB->GetNowFunction();
$arFields['~DATE_CREATE'] = $DB->GetNowFunction();
if(!self::checkFields('ADD', $arFields))
return false;
$arInsert = $DB->PrepareInsert("b_catalog_store_docs", $arFields);
$strSql = "INSERT INTO b_catalog_store_docs (".$arInsert[0].") VALUES(".$arInsert[1].")";
$res = $DB->Query($strSql, False, "File: ".__FILE__."<br>Line: ".__LINE__);
if(!$res)
return false;
$lastId = intval($DB->LastID());
if(isset($arFields["ELEMENT"]) && is_array($arFields["ELEMENT"]))
{
foreach($arFields["ELEMENT"] as $arElement)
{
$lastDocElementId = 0;
if(isset($arElement["ID"]))
unset($arElement["ID"]);
$arElement["DOC_ID"] = $lastId;
if(is_array($arElement))
$lastDocElementId = CCatalogStoreDocsElement::add($arElement);
if(isset($arElement["BARCODE"]) && $lastDocElementId)
{
if(is_array($arElement["BARCODE"]))
foreach($arElement["BARCODE"] as $barcode)
CCatalogStoreDocsBarcode::add(array("DOC_ELEMENT_ID" => $lastDocElementId, "BARCODE" => $barcode));
}
}
}
foreach(GetModuleEvents("catalog", "OnDocumentAdd", true) as $arEvent)
ExecuteModuleEventEx($arEvent, array($lastId, $arFields));
return $lastId;
}
public static function getList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
{
global $DB;
if (empty($arSelectFields))
$arSelectFields = array("ID", "DOC_TYPE", "SITE_ID", "CONTRACTOR_ID", "CURRENCY", "STATUS", "DATE_DOCUMENT", "TOTAL", "DATE_STATUS", "COMMENTARY");
$arFields = array(
"ID" => array("FIELD" => "CD.ID", "TYPE" => "int"),
"DOC_TYPE" => array("FIELD" => "CD.DOC_TYPE", "TYPE" => "char"),
"SITE_ID" => array("FIELD" => "CD.SITE_ID", "TYPE" => "string"),
"CURRENCY" => array("FIELD" => "CD.CURRENCY", "TYPE" => "string"),
"CONTRACTOR_ID" => array("FIELD" => "CD.CONTRACTOR_ID", "TYPE" => "int"),
"DATE_CREATE" => array("FIELD" => "CD.DATE_CREATE", "TYPE" => "datetime"),
"DATE_MODIFY" => array("FIELD" => "CD.DATE_MODIFY", "TYPE" => "datetime"),
"DATE_DOCUMENT" => array("FIELD" => "CD.DATE_DOCUMENT", "TYPE" => "datetime"),
"DATE_STATUS" => array("FIELD" => "CD.DATE_STATUS", "TYPE" => "datetime"),
"CREATED_BY" => array("FIELD" => "CD.CREATED_BY", "TYPE" => "int"),
"MODIFIED_BY" => array("FIELD" => "CD.MODIFIED_BY", "TYPE" => "int"),
"STATUS_BY" => array("FIELD" => "CD.STATUS_BY", "TYPE" => "int"),
"STATUS" => array("FIELD" => "CD.STATUS", "TYPE" => "string"),
"TOTAL" => array("FIELD" => "CD.TOTAL", "TYPE" => "double"),
"COMMENTARY" => array("FIELD" => "CD.COMMENTARY", "TYPE" => "string"),
"PRODUCTS_ID" => array("FIELD" => "DE.ID", "TYPE" => "int", "FROM" => "INNER JOIN b_catalog_docs_element DE ON (CD.ID = DE.DOC_ID)"),
"PRODUCTS_DOC_ID" => array("FIELD" => "DE.DOC_ID", "TYPE" => "int", "FROM" => "INNER JOIN b_catalog_docs_element DE ON (CD.ID = DE.DOC_ID)"),
"PRODUCTS_STORE_FROM" => array("FIELD" => "DE.STORE_FROM", "TYPE" => "int", "FROM" => "INNER JOIN b_catalog_docs_element DE ON (CD.ID = DE.DOC_ID)"),
"PRODUCTS_STORE_TO" => array("FIELD" => "DE.STORE_TO", "TYPE" => "int", "FROM" => "INNER JOIN b_catalog_docs_element DE ON (CD.ID = DE.DOC_ID)"),
"PRODUCTS_ELEMENT_ID" => array("FIELD" => "DE.ELEMENT_ID", "TYPE" => "int", "FROM" => "INNER JOIN b_catalog_docs_element DE ON (CD.ID = DE.DOC_ID)"),
"PRODUCTS_AMOUNT" => array("FIELD" => "DE.AMOUNT", "TYPE" => "double", "FROM" => "INNER JOIN b_catalog_docs_element DE ON (CD.ID = DE.DOC_ID)"),
"PRODUCTS_PURCHASING_PRICE" => array("FIELD" => "DE.PURCHASING_PRICE", "TYPE" => "double", "FROM" => "INNER JOIN b_catalog_docs_element DE ON (CD.ID = DE.DOC_ID)"),
);
$arSqls = CCatalog::PrepareSql($arFields, $arOrder, $arFilter, $arGroupBy, $arSelectFields);
$arSqls["SELECT"] = str_replace("%%_DISTINCT_%%", "", $arSqls["SELECT"]);
if (empty($arGroupBy) && is_array($arGroupBy))
{
$strSql = "SELECT ".$arSqls["SELECT"]." FROM b_catalog_store_docs CD ".$arSqls["FROM"];
if (!empty($arSqls["WHERE"]))
$strSql .= " WHERE ".$arSqls["WHERE"];
if (!empty($arSqls["GROUPBY"]))
$strSql .= " GROUP BY ".$arSqls["GROUPBY"];
$dbRes = $DB->Query($strSql, false, "File: ".__FILE__."<br>Line: ".__LINE__);
if ($arRes = $dbRes->Fetch())
return $arRes["CNT"];
else
return false;
}
$strSql = "SELECT ".$arSqls["SELECT"]." FROM b_catalog_store_docs CD ".$arSqls["FROM"];
if (!empty($arSqls["WHERE"]))
$strSql .= " WHERE ".$arSqls["WHERE"];
if (!empty($arSqls["GROUPBY"]))
$strSql .= " GROUP BY ".$arSqls["GROUPBY"];
if (!empty($arSqls["ORDERBY"]))
$strSql .= " ORDER BY ".$arSqls["ORDERBY"];
$intTopCount = 0;
$boolNavStartParams = (!empty($arNavStartParams) && is_array($arNavStartParams));
if ($boolNavStartParams && array_key_exists('nTopCount', $arNavStartParams))
{
$intTopCount = intval($arNavStartParams["nTopCount"]);
}
if ($boolNavStartParams && 0 >= $intTopCount)
{
$strSql_tmp = "SELECT COUNT('x') as CNT FROM b_catalog_store_docs CD ".$arSqls["FROM"];
if (!empty($arSqls["WHERE"]))
$strSql_tmp .= " WHERE ".$arSqls["WHERE"];
if (!empty($arSqls["GROUPBY"]))
$strSql_tmp .= " GROUP BY ".$arSqls["GROUPBY"];
$dbRes = $DB->Query($strSql_tmp, false, "File: ".__FILE__."<br>Line: ".__LINE__);
$cnt = 0;
if (empty($arSqls["GROUPBY"]))
{
if ($arRes = $dbRes->Fetch())
$cnt = $arRes["CNT"];
}
else
{
$cnt = $dbRes->SelectedRowsCount();
}
$dbRes = new CDBResult();
$dbRes->NavQuery($strSql, $cnt, $arNavStartParams);
}
else
{
if ($boolNavStartParams && 0 < $intTopCount)
{
$strSql .= " LIMIT ".$intTopCount;
}
$dbRes = $DB->Query($strSql, false, "File: ".__FILE__."<br>Line: ".__LINE__);
}
return $dbRes;
}
public static function synchronizeStockQuantity($storeId, $iblockId = 0)
{
global $DB;
$storeId = (int)$storeId;
if ($storeId <= 0)
return false;
$internalSql = 'select CP.QUANTITY + IFNULL(CP.QUANTITY_RESERVED, 0), CP.ID, '.$storeId.' ';
$iblockId = (int)$iblockId;
if ($iblockId <= 0)
$internalSql .= 'from b_catalog_product CP where 1 = 1';
else
$internalSql .= 'from b_catalog_product CP inner join b_iblock_element IE on (CP.ID = IE.ID) where IE.IBLOCK_ID = '.$iblockId;
return $DB->Query(
"insert into b_catalog_store_product (AMOUNT, PRODUCT_ID, STORE_ID) (".$internalSql.")",
true,
"File: ".__FILE__."<br>Line: ".__LINE__
);
}
}