discount.php

См. документацию.

<?php
 
use Bitrix\Main;
use Bitrix\Catalog;
 
require_once($_SERVER['DOCUMENT_ROOT'].'/bitrix/modules/catalog/general/discount.php');
 
class CCatalogDiscount extends CAllCatalogDiscount
{
    public static function _Add(&$arFields)
    {
        global $DB;
 
        if (!CCatalogDiscount::CheckFields("ADD", $arFields, 0))
            return false;
 
        $arInsert = $DB->PrepareInsert("b_catalog_discount", $arFields);
 
        $strSql = "INSERT INTO b_catalog_discount(".$arInsert[0].") VALUES(".$arInsert[1].")";
        $DB->Query($strSql);
 
        $ID = (int)$DB->LastID();
 
        if (isset($arFields['HANDLERS']))
            self::updateDiscountHandlers($ID, $arFields['HANDLERS'], false);
 
        return $ID;
    }
 
    public static function _Update($ID, &$arFields)
    {
        global $DB;
        global $APPLICATION;
 
        $ID = (int)$ID;
        if ($ID <= 0)
            return false;
 
        if (!CCatalogDiscount::CheckFields("UPDATE", $arFields, $ID))
            return false;
 
        if (isset($arFields['VALUE']) != isset($arFields['VALUE_TYPE']))
        {
            $rsDiscounts = CCatalogDiscount::GetList(array(),array('ID' => $ID), false, array('nTopCount' => 1), array('ID', 'VALUE', 'VALUE_TYPE'));
            if ($arDiscount = $rsDiscounts->Fetch())
            {
                if (!isset($arFields['VALUE']))
                    $arFields['VALUE'] = doubleval($arDiscount['VALUE']);
                if (!isset($arFields['VALUE_TYPE']))
                    $arFields['VALUE_TYPE'] = $arDiscount['VALUE_TYPE'];
                if (self::TYPE_PERCENT == $arFields['VALUE_TYPE'] && 100 < $arFields['VALUE'])
                {
                    $APPLICATION->ThrowException(GetMessage("BT_MOD_CATALOG_DISC_ERR_BAD_VALUE"), "VALUE");
                    return false;
                }
            }
            else
            {
                $APPLICATION->ThrowException(str_replace('#ID#', $ID, GetMessage("BT_MOD_CATALOG_DISC_ERR_BAD_ID")), "ID");
                return false;
            }
        }
 
        $strUpdate = $DB->PrepareUpdate("b_catalog_discount", $arFields);
        if (!empty($strUpdate))
        {
            $strSql = "UPDATE b_catalog_discount SET ".$strUpdate." WHERE ID = ".$ID." AND TYPE = ".self::ENTITY_ID;
            $DB->Query($strSql);
 
            if (isset($arFields['HANDLERS']))
                self::updateDiscountHandlers($ID, $arFields['HANDLERS'], true);
        }
 
        return $ID;
    }
 
    public static function Delete($ID)
    {
        global $DB;
 
        $ID = (int)$ID;
        if ($ID <= 0)
            return false;
 
        foreach (GetModuleEvents("catalog", "OnBeforeDiscountDelete", true) as $arEvent)
        {
            if (false === ExecuteModuleEventEx($arEvent, array($ID)))
                return false;
        }
 
        $DB->Query("delete from b_catalog_discount2iblock where DISCOUNT_ID = ".$ID);
        $DB->Query("delete from b_catalog_discount2section where DISCOUNT_ID = ".$ID);
        $DB->Query("delete from b_catalog_discount2product where DISCOUNT_ID = ".$ID);
        Catalog\DiscountRestrictionTable::deleteByDiscount($ID);
        Catalog\DiscountModuleTable::deleteByDiscount($ID);
        Catalog\DiscountEntityTable::deleteByDiscount($ID);
        Catalog\DiscountCouponTable::deleteByDiscount($ID);
 
        $DB->Query("delete from b_catalog_discount where ID = ".$ID." and TYPE = ".self::ENTITY_ID);
 
        foreach (GetModuleEvents("catalog", "OnDiscountDelete", true) as $arEvent)
        {
            ExecuteModuleEventEx($arEvent, array($ID));
        }
 
        return true;
    }

    public static function GetByID($ID)
    {
        global $DB;
 
        $ID = (int)$ID;
        if ($ID <= 0)
            return false;
 
        $strSql =
            "SELECT CD.ID, CD.SITE_ID, CD.ACTIVE, CD.NAME, CD.MAX_USES, ".
            "CD.COUNT_USES, CD.COUPON, CD.SORT, CD.MAX_DISCOUNT, CD.VALUE_TYPE, ".
            "CD.VALUE, CD.CURRENCY, CD.MIN_ORDER_SUM, CD.NOTES, CD.RENEWAL, ".
            $DB->DateToCharFunction("CD.TIMESTAMP_X", "FULL")." as TIMESTAMP_X, ".
            $DB->DateToCharFunction("CD.ACTIVE_FROM", "FULL")." as ACTIVE_FROM, ".
            $DB->DateToCharFunction("CD.ACTIVE_TO", "FULL")." as ACTIVE_TO, ".
            "CD.CREATED_BY, CD.MODIFIED_BY, ".$DB->DateToCharFunction('CD.DATE_CREATE', 'FULL').' as DATE_CREATE, '.
            "CD.PRIORITY, CD.LAST_DISCOUNT, CD.VERSION, CD.CONDITIONS, CD.UNPACK, CD.SALE_ID ".
            "FROM b_catalog_discount CD WHERE CD.ID = ".$ID." AND CD.TYPE = ".self::ENTITY_ID;
 
        $db_res = $DB->Query($strSql);
        if ($res = $db_res->Fetch())
            return $res;
 
        return false;
    }

    public static function PrepareSection4Where($val, $key, $operation, $negative, $field, $arField, $arFilter)
    {
        $val = (int)$val;
        if ($val <= 0)
            return false;
 
        $dbSection = CIBlockSection::GetByID($val);
        if ($arSection = $dbSection->Fetch())
        {
            $arIDs = array(0);
            $dbSectionTree = CIBlockSection::GetList(
                array("LEFT_MARGIN" => "DESC"),
                array(
                    "IBLOCK_ID" => $arSection["IBLOCK_ID"],
                    "ACTIVE" => "Y",
                    "GLOBAL_ACTIVE" => "Y",
                    "IBLOCK_ACTIVE" => "Y",
                    ">=LEFT_BORDER" => $arSection["LEFT_MARGIN"],
                    "<=RIGHT_BORDER" => $arSection["RIGHT_MARGIN"]
                )
            );
            while ($arSectionTree = $dbSectionTree->Fetch())
            {
                $arIDs[] = intval($arSectionTree["ID"]);
            }
 
            return "(CDS.SECTION_ID ".(($negative == "Y") ? "NOT " : "")."IN (".implode(',',$arIDs)."))";
        }
 
        return false;
    }

    public static function GetList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
    {
        global $DB;
 
        $arFields = array(
            "ID" => array("FIELD" => "CD.ID", "TYPE" => "int"),
            "XML_ID" => array("FIELD" => "CD.XML_ID", "TYPE" => "string"),
            "SITE_ID" => array("FIELD" => "CD.SITE_ID", "TYPE" => "string"),
            "TYPE" => array("FIELD" => "CD.TYPE", "TYPE" => "int"),
            "ACTIVE" => array("FIELD" => "CD.ACTIVE", "TYPE" => "char"),
            "ACTIVE_FROM" => array("FIELD" => "CD.ACTIVE_FROM", "TYPE" => "datetime"),
            "ACTIVE_TO" => array("FIELD" => "CD.ACTIVE_TO", "TYPE" => "datetime"),
            "RENEWAL" => array("FIELD" => "CD.RENEWAL", "TYPE" => "char"),
            "NAME" => array("FIELD" => "CD.NAME", "TYPE" => "string"),
            "MAX_USES" => array("FIELD" => "CD.MAX_USES", "TYPE" => "int"),
            "COUNT_USES" => array("FIELD" => "CD.COUNT_USES", "TYPE" => "int"),
            "SORT" => array("FIELD" => "CD.SORT", "TYPE" => "int"),
            "MAX_DISCOUNT" => array("FIELD" => "CD.MAX_DISCOUNT", "TYPE" => "double"),
            "VALUE_TYPE" => array("FIELD" => "CD.VALUE_TYPE", "TYPE" => "char"),
            "VALUE" => array("FIELD" => "CD.VALUE", "TYPE" => "double"),
            "CURRENCY" => array("FIELD" => "CD.CURRENCY", "TYPE" => "string"),
            "MIN_ORDER_SUM" => array("FIELD" => "CD.MIN_ORDER_SUM", "TYPE" => "double"),
            "TIMESTAMP_X" => array("FIELD" => "CD.TIMESTAMP_X", "TYPE" => "datetime"),
            "MODIFIED_BY" => array("FIELD" => "CD.MODIFIED_BY", "TYPE" => "int"),
            "DATE_CREATE" => array("FIELD" => "CD.DATE_CREATE", "TYPE" => "datetime"),
            "CREATED_BY" => array("FIELD" => "CD.CREATED_BY", "TYPE" => "int"),
            "NOTES" => array("FIELD" => "CD.NOTES", "TYPE" => "string"),
            "PRIORITY" => array("FIELD" => "CD.PRIORITY", "TYPE" => "int"),
            "LAST_DISCOUNT" => array("FIELD" => "CD.LAST_DISCOUNT", "TYPE" => "char"),
            "VERSION" => array("FIELD" => "CD.VERSION", "TYPE" => "int"),
            "CONDITIONS" => array("FIELD" => "CD.CONDITIONS", "TYPE" => "string"),
            "UNPACK" => array("FIELD" => "CD.UNPACK", "TYPE" => "string"),
            "SALE_ID" => array("FIELD" => "CD.SALE_ID", "TYPE" => "int"),
            "USE_COUPONS" => array("FIELD" => "CD.USE_COUPONS", "TYPE" => "char"),
 
            "PRODUCT_ID" => array("FIELD" => "CDP.PRODUCT_ID", "TYPE" => "int", "FROM" => "LEFT JOIN b_catalog_discount2product CDP ON (CD.ID = CDP.DISCOUNT_ID)"),
            "SECTION_ID" => array("FIELD" => "CDS.SECTION_ID", "TYPE" => "int", "FROM" => "LEFT JOIN b_catalog_discount2section CDS ON (CD.ID = CDS.DISCOUNT_ID)", "WHERE" => array("CCatalogDiscount", "PrepareSection4Where")),
            "SECTION_LIST" => array("FIELD" => "CDSL.SECTION_ID", "TYPE" => "int", "FROM" => "LEFT JOIN b_catalog_discount2section CDSL ON (CD.ID = CDSL.DISCOUNT_ID)"),
            "IBLOCK_ID" => array("FIELD" => "CDI.IBLOCK_ID", "TYPE" => "int", "FROM" => "LEFT JOIN b_catalog_discount2iblock CDI ON (CD.ID = CDI.DISCOUNT_ID)"),
            "GROUP_ID" => array("FIELD" => "CDC.USER_GROUP_ID", "TYPE" => "int", "FROM" => "LEFT JOIN b_catalog_discount_cond CDC ON (CD.ID = CDC.DISCOUNT_ID)"),
            "USER_GROUP_ID" => array("FIELD" => "CDC.USER_GROUP_ID", "TYPE" => "int", "FROM" => "LEFT JOIN b_catalog_discount_cond CDC ON (CD.ID = CDC.DISCOUNT_ID)"),
            "CATALOG_GROUP_ID" => array("FIELD" => "CDC.PRICE_TYPE_ID", "TYPE" => "int", "FROM" => "LEFT JOIN b_catalog_discount_cond CDC ON (CD.ID = CDC.DISCOUNT_ID)"),
            "PRICE_TYPE_ID" => array("FIELD" => "CDC.PRICE_TYPE_ID", "TYPE" => "int", "FROM" => "LEFT JOIN b_catalog_discount_cond CDC ON (CD.ID = CDC.DISCOUNT_ID)"),
 
            "COUPON" => array("FIELD" => "CDCP.COUPON", "TYPE" => "string", "FROM" => "LEFT JOIN b_catalog_discount_coupon CDCP ON (CD.ID = CDCP.DISCOUNT_ID)"),
            "COUPON_ACTIVE" => array("FIELD" => "CDCP.ACTIVE", "TYPE" => "char", "FROM" => "LEFT JOIN b_catalog_discount_coupon CDCP ON (CD.ID = CDCP.DISCOUNT_ID)"),
            "COUPON_ONE_TIME" => array("FIELD" => "CDCP.ONE_TIME", "TYPE" => "char", "FROM" => "LEFT JOIN b_catalog_discount_coupon CDCP ON (CD.ID = CDCP.DISCOUNT_ID)"),
        );
 
        if (!is_array($arFilter))
            $arFilter = array();
        if (!empty($arFilter))
        {
            $filterKeys = array_keys($arFilter);
            foreach ($filterKeys as &$oneKey)
            {
                if (
                    preg_match('/^\!?\+.{0,2}(GROUP_ID|USER_GROUP_ID|CATALOG_GROUP_ID|PRICE_TYPE_ID)$/', $oneKey) == 1
                )
                {
                    if (is_array($arFilter[$oneKey]))
                    {
                        $arFilter[$oneKey][] = -1;
                    }
                    else
                    {
                        $arFilter[$oneKey] = array($arFilter[$oneKey], -1);
                    }
                }
            }
            unset($oneKey, $filterKeys);
        }
        $arFilter['TYPE'] = self::ENTITY_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_discount CD ".$arSqls["FROM"];
            if (!empty($arSqls["WHERE"]))
                $strSql .= " WHERE ".$arSqls["WHERE"];
            if (!empty($arSqls["GROUPBY"]))
                $strSql .= " GROUP BY ".$arSqls["GROUPBY"];
 
            $dbRes = $DB->Query($strSql);
            if ($arRes = $dbRes->Fetch())
                return $arRes["CNT"];
            else
                return false;
        }
 
        $strSql = "SELECT ".$arSqls["SELECT"]." FROM b_catalog_discount 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_discount 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);
            $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);
        }
 
        return $dbRes;
    }

    public static function GetDiscountGroupsList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
    {
        return self::__GetDiscountEntityList($arOrder, $arFilter, $arGroupBy, $arNavStartParams, $arSelectFields);
    }

    public static function GetDiscountCatsList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
    {
        return self::__GetDiscountEntityList($arOrder, $arFilter, $arGroupBy, $arNavStartParams, $arSelectFields);
    }

    public static function GetDiscountProductsList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
    {
        global $DB;
 
        $arFields = array(
            "ID" => array("FIELD" => "DG.ID", "TYPE" => "int"),
            "DISCOUNT_ID" => array("FIELD" => "DG.DISCOUNT_ID", "TYPE" => "int"),
            "PRODUCT_ID" => array("FIELD" => "DG.PRODUCT_ID", "TYPE" => "int")
        );
 
        $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_discount2product DG ".$arSqls["FROM"];
            if (!empty($arSqls["WHERE"]))
                $strSql .= " WHERE ".$arSqls["WHERE"];
            if (!empty($arSqls["GROUPBY"]))
                $strSql .= " GROUP BY ".$arSqls["GROUPBY"];
 
            $dbRes = $DB->Query($strSql);
            if ($arRes = $dbRes->Fetch())
                return $arRes["CNT"];
            else
                return false;
        }
 
        $strSql = "SELECT ".$arSqls["SELECT"]." FROM b_catalog_discount2product DG ".$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_discount2product DG ".$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);
            $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);
        }
 
        return $dbRes;
    }

    public static function GetDiscountSectionsList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
    {
        global $DB;
 
        $arFields = array(
            "ID" => array("FIELD" => "DG.ID", "TYPE" => "int"),
            "DISCOUNT_ID" => array("FIELD" => "DG.DISCOUNT_ID", "TYPE" => "int"),
            "SECTION_ID" => array("FIELD" => "DG.SECTION_ID", "TYPE" => "int")
        );
 
        $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_discount2section DG ".$arSqls["FROM"];
            if (!empty($arSqls["WHERE"]))
                $strSql .= " WHERE ".$arSqls["WHERE"];
            if (!empty($arSqls["GROUPBY"]))
                $strSql .= " GROUP BY ".$arSqls["GROUPBY"];
 
            $dbRes = $DB->Query($strSql);
            if ($arRes = $dbRes->Fetch())
                return $arRes["CNT"];
            else
                return false;
        }
 
        $strSql = "SELECT ".$arSqls["SELECT"]." FROM b_catalog_discount2section DG ".$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_discount2section DG ".$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);
            $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);
        }
 
        return $dbRes;
    }

    public static function GetDiscountIBlocksList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
    {
        global $DB;
 
        $arFields = array(
            "ID" => array("FIELD" => "DG.ID", "TYPE" => "int"),
            "DISCOUNT_ID" => array("FIELD" => "DG.DISCOUNT_ID", "TYPE" => "int"),
            "IBLOCK_ID" => array("FIELD" => "DG.IBLOCK_ID", "TYPE" => "int")
        );
 
        $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_discount2iblock DG ".$arSqls["FROM"];
            if (!empty($arSqls["WHERE"]))
                $strSql .= " WHERE ".$arSqls["WHERE"];
            if (!empty($arSqls["GROUPBY"]))
                $strSql .= " GROUP BY ".$arSqls["GROUPBY"];
 
            $dbRes = $DB->Query($strSql);
            if ($arRes = $dbRes->Fetch())
                return $arRes["CNT"];
            else
                return false;
        }
 
        $strSql = "SELECT ".$arSqls["SELECT"]." FROM b_catalog_discount2iblock DG ".$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_discount2iblock DG ".$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);
            $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);
        }
 
        return $dbRes;
    }

    protected static function __GetDiscountEntityList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
    {
        global $DB;
 
        $arFields = array(
            "ID" => array("FIELD" => "DC.ID", "TYPE" => "int"),
            "DISCOUNT_ID" => array("FIELD" => "DC.DISCOUNT_ID", "TYPE" => "int"),
            "CATALOG_GROUP_ID" => array("FIELD" => "DC.PRICE_TYPE_ID", "TYPE" => "int"),
            "PRICE_TYPE_ID" => array("FIELD" => "DC.PRICE_TYPE_ID", "TYPE" => "int"),
            "USER_GROUP_ID" => array("FIELD" => "DC.USER_GROUP_ID", "TYPE" => "int"),
            "GROUP_ID" => array("FIELD" => "DC.USER_GROUP_ID", "TYPE" => "int"),
        );
 
        $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_discount_cond DC ".$arSqls["FROM"];
            if (!empty($arSqls["WHERE"]))
                $strSql .= " WHERE ".$arSqls["WHERE"];
            if (!empty($arSqls["GROUPBY"]))
                $strSql .= " GROUP BY ".$arSqls["GROUPBY"];
 
            $dbRes = $DB->Query($strSql);
            if ($arRes = $dbRes->Fetch())
                return $arRes["CNT"];
            else
                return false;
        }
 
        $strSql = "SELECT ".$arSqls["SELECT"]." FROM b_catalog_discount_cond DC ".$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_discount_cond DC ".$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);
            $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);
        }
 
        return $dbRes;
    }

    public static function SaveFilterOptions()
    {
        COption::SetOptionString("catalog", "do_use_discount_product", 'Y');
 
        COption::SetOptionString("catalog", "do_use_discount_section", 'Y');
 
        COption::SetOptionString("catalog", "do_use_discount_iblock", 'Y');
 
        self::__SaveFilterForEntity(array('ENTITY_ID' => 'PRICE_TYPE_ID', 'OPTION_ID' => 'do_use_discount_cat_group'));
        self::__SaveFilterForEntity(array('ENTITY_ID' => 'USER_GROUP_ID', 'OPTION_ID' => 'do_use_discount_group'));
    }

    protected static function __SaveFilterForEntity($arParams)
    {
        global $DB;
 
        if (!is_array($arParams) || empty($arParams))
            return;
        $strFilter = 'N';
        $arDiscList = array();
        $strQuery = str_replace('#ENTITY_ID#', $arParams['ENTITY_ID'], "SELECT DISCOUNT_ID FROM b_catalog_discount_cond WHERE #ENTITY_ID# != -1");
        $rsDiscounts = $DB->Query($strQuery);
        while ($arDiscount = $rsDiscounts->Fetch())
        {
            $arDiscList[] = intval($arDiscount['DISCOUNT_ID']);
        }
        if (!empty($arDiscList))
        {
            $arDiscList = array_unique($arDiscList);
            $strQuery = "SELECT 'x' FROM b_catalog_discount D WHERE ID IN (".implode(',', $arDiscList).") AND D.ACTIVE = 'Y' AND (D.ACTIVE_TO > ".$DB->CurrentTimeFunction()." OR D.ACTIVE_TO IS NULL) LIMIT 0, 1";
            $rsDiscounts = $DB->Query($strQuery);
            if ($arDiscount= $rsDiscounts->Fetch())
                $strFilter = 'Y';
        }
        COption::SetOptionString("catalog", $arParams['OPTION_ID'], $strFilter);
    }
 
    protected static function __UpdateSubdiscount($intDiscountID, &$arConditions, $active = '')
    {
        global $DB;
 
        $arMsg = array();
        $boolResult = true;
 
        $intDiscountID = (int)$intDiscountID;
        if ($intDiscountID <= 0)
        {
            $arMsg[] = array('id' => 'ID', "text" => GetMessage('BT_MOD_CATALOG_DISC_ERR_DISCOUNT_ID_ABSENT'));
            $boolResult = false;
        }
        if (empty($arConditions) || !is_array($arConditions))
        {
            $arMsg[] = array('id' => 'SUBDISCOUNT', "text" => GetMessage('BT_MOD_CATALOG_DISC_ERR_SUBDISCOUNT_ROWS_ABSENT'));
            $boolResult = false;
        }
 
        $active = (string)$active;
        if ($active !== 'Y' && $active !== 'N')
        {
            $strQuery = 'select ID, ACTIVE from b_catalog_discount where ID = '.$intDiscountID;
            $rsActive = $DB->Query($strQuery);
            if ($activeFromDatabase = $rsActive->Fetch())
            {
                $active = $activeFromDatabase['ACTIVE'];
            }
            else
            {
                $arMsg[] = array('id' => 'ID', "text" => GetMessage('BT_MOD_CATALOG_DISC_ERR_DISCOUNT_ID_ABSENT'));
                $boolResult = false;
            }
        }
 
        $arEmptyRow = array(
            'DISCOUNT_ID' => $intDiscountID,
            'ACTIVE' => $active,
            'USER_GROUP_ID' => -1,
            'PRICE_TYPE_ID' => -1,
        );
 
        if ($boolResult)
        {
            $strQuery = 'DELETE from b_catalog_discount_cond where DISCOUNT_ID = '.$intDiscountID;
            $DB->Query($strQuery);
 
            foreach ($arConditions as $arOneCondition)
            {
                $arRow = $arEmptyRow;
                if (!empty($arOneCondition['EQUAL']) && is_array($arOneCondition['EQUAL']))
                {
                    foreach ($arOneCondition['EQUAL'] as $strKey => $intOneEntity)
                    {
                        $arRow[$strKey] = $intOneEntity;
                    }
                }
                $arInsert = $DB->PrepareInsert("b_catalog_discount_cond", $arRow);
                $strInserCond = "INSERT INTO b_catalog_discount_cond(".$arInsert[0].") VALUES(".$arInsert[1].")";
                $DB->Query($strInserCond);
            }
            if (isset($arOneCondition))
                unset($arOneCondition);
        }
 
        return $boolResult;
    }
 
    protected static function __GetDiscountID($arFilter)
    {
        global $DB;
 
        $arResult = array();
        $boolRest = array_key_exists('RESTRICTIONS', $arFilter);
 
        $arFields = array(
            "DISCOUNT_ID" => array("FIELD" => "DC.DISCOUNT_ID", "TYPE" => "int"),
            "ACTIVE" => array("FIELD" => "DC.ACTIVE", "TYPE" => "char"),
            "USER_GROUP_ID" => array("FIELD" => "DC.USER_GROUP_ID", "TYPE" => "int"),
            "PRICE_TYPE_ID" => array("FIELD" => "DC.PRICE_TYPE_ID", "TYPE" => "int"),
        );
 
        if (!isset($arFilter['USER_GROUP_ID']))
            $arFilter['USER_GROUP_ID'] = array();
        elseif (!is_array($arFilter['USER_GROUP_ID']))
            $arFilter['USER_GROUP_ID'] = array($arFilter['USER_GROUP_ID']);
        if (!empty($arFilter['USER_GROUP_ID']))
        {
            if (!in_array(-1, $arFilter['USER_GROUP_ID']))
                $arFilter['USER_GROUP_ID'][] = -1;
        }
        else
        {
            unset($arFilter['USER_GROUP_ID']);
        }
 
        if (!isset($arFilter['PRICE_TYPE_ID']))
            $arFilter['PRICE_TYPE_ID'] = array();
        elseif (!is_array($arFilter['PRICE_TYPE_ID']))
            $arFilter['PRICE_TYPE_ID'] = array($arFilter['PRICE_TYPE_ID']);
        if (!empty($arFilter['PRICE_TYPE_ID']))
        {
            if (!in_array(-1, $arFilter['PRICE_TYPE_ID']))
                $arFilter['PRICE_TYPE_ID'][] = -1;
        }
        else
        {
            unset($arFilter['PRICE_TYPE_ID']);
        }
 
        $active = 'Y';
        if (array_key_exists('ACTIVE', $arFilter))
        {
            if ($arFilter['ACTIVE'] === null)
                $active = '';
            elseif ($arFilter['ACTIVE'] == 'Y' || $arFilter['ACTIVE'] == 'N')
                $active = $arFilter['ACTIVE'];
            unset($arFilter['ACTIVE']);
        }
        if ($active != '')
            $arFilter['ACTIVE'] = $active;
 
        if (array_key_exists('DISCOUNT_ID', $arFilter))
            unset($arFilter['DISCOUNT_ID']);
 
        $arSelectFields = array('DISCOUNT_ID');
        if ($boolRest)
        {
            $arSelectFields[] = 'USER_GROUP_ID';
            $arSelectFields[] = 'PRICE_TYPE_ID';
            unset($arFilter['RESTRICTIONS']);
        }
 
        $arSqls = CCatalog::PrepareSql($arFields, array('DISCOUNT_ID' => 'ASC'), $arFilter, false, $arSelectFields);
 
        $arSqls["SELECT"] = str_replace("%%_DISTINCT_%%", "", $arSqls["SELECT"]);
        if (empty($arSqls["WHERE"]))
            $arSqls["WHERE"] = "1=1";
 
        $strQuery = "SELECT ".$arSqls["SELECT"]." FROM b_catalog_discount_cond DC WHERE ".$arSqls["WHERE"];
 
        $arDiscountID = array();
        $rsDiscounts = $DB->Query($strQuery);
        if ($boolRest)
        {
            $arRestrictions = array();
            while ($arDiscount = $rsDiscounts->Fetch())
            {
                $arDiscount['DISCOUNT_ID'] = (int)$arDiscount['DISCOUNT_ID'];
                $arDiscountID[$arDiscount['DISCOUNT_ID']] = true;
                if (!isset($arRestrictions[$arDiscount['DISCOUNT_ID']]))
                {
                    $arRestrictions[$arDiscount['DISCOUNT_ID']] = array(
                        'USER_GROUP' => array(),
                        'PRICE_TYPE' => array(),
                    );
                }
                $arDiscount['USER_GROUP_ID'] = (int)$arDiscount['USER_GROUP_ID'];
                $arDiscount['PRICE_TYPE_ID'] = (int)$arDiscount['PRICE_TYPE_ID'];
                $arRestrictions[$arDiscount['DISCOUNT_ID']]['USER_GROUP'][$arDiscount['USER_GROUP_ID']] = true;
                $arRestrictions[$arDiscount['DISCOUNT_ID']]['PRICE_TYPE'][$arDiscount['PRICE_TYPE_ID']] = true;
            }
            if (!empty($arDiscountID))
            {
                $arDiscountID = array_keys($arDiscountID);
                foreach ($arRestrictions as $intKey => $arOneRestrictions)
                {
                    if (array_key_exists(-1, $arOneRestrictions['USER_GROUP']))
                        $arOneRestrictions['USER_GROUP'] = array();
                    if (array_key_exists(-1, $arOneRestrictions['PRICE_TYPE']))
                        $arOneRestrictions['PRICE_TYPE'] = array();
                    $arRestrictions[$intKey] = $arOneRestrictions;
                }
            }
            $arResult = array(
                'DISCOUNTS' => $arDiscountID,
                'RESTRICTIONS' => $arRestrictions,
            );
        }
        else
        {
            while ($arDiscount = $rsDiscounts->Fetch())
            {
                $arDiscount['DISCOUNT_ID'] = (int)$arDiscount['DISCOUNT_ID'];
                $arDiscountID[$arDiscount['DISCOUNT_ID']] = true;
            }
            if (!empty($arDiscountID))
                $arResult = array_keys($arDiscountID);
        }
        return $arResult;
    }
 
    protected static function __UpdateOldEntities($ID, &$arFields, $boolUpdate)
    {
        $ID = intval($ID);
        if (0 >= $ID)
            return;
        CCatalogDiscount::__UpdateOldOneEntity($ID, $arFields,
            array(
                'ENTITY_ID' => 'IBLOCK_IDS',
                'TABLE_ID' => 'b_catalog_discount2iblock',
                'FIELD_ID' => 'IBLOCK_ID',
            ),
            $boolUpdate
        );
        CCatalogDiscount::__UpdateOldOneEntity($ID, $arFields,
            array(
                'ENTITY_ID' => 'SECTION_IDS',
                'TABLE_ID' => 'b_catalog_discount2section',
                'FIELD_ID' => 'SECTION_ID',
            ),
            $boolUpdate
        );
        CCatalogDiscount::__UpdateOldOneEntity($ID, $arFields,
            array(
                'ENTITY_ID' => 'PRODUCT_IDS',
                'TABLE_ID' => 'b_catalog_discount2product',
                'FIELD_ID' => 'PRODUCT_ID',
            ),
            $boolUpdate
        );
    }
 
    protected static function __FillArrays($intDiscountID, &$arFields, $strEntityID)
    {
        $boolResult = false;
        $intDiscountID = intval($intDiscountID);
        if (0 >= $intDiscountID)
            return $boolResult;
        $strEntityID = trim(strval($strEntityID));
        if (!empty($strEntityID) && ('GROUP_IDS' == $strEntityID || 'CATALOG_GROUP_IDS' == $strEntityID))
        {
            $boolCheck = false;
            $strEntityResult = ('GROUP_IDS' == $strEntityID ? 'USER_GROUP_ID' : 'PRICE_TYPE_ID');
            $arValues = array();
            $rsDiscounts = self::__GetDiscountEntityList(
                array(),
                array('DISCOUNT_ID' => $intDiscountID),
                false,
                false,
                array('ID', 'DISCOUNT_ID', $strEntityResult)
            );
            while ($arDiscount = $rsDiscounts->Fetch())
            {
                $boolCheck = true;
                $intValue = intval($arDiscount[$strEntityResult]);
                if (0 < $intValue)
                    $arValues[$intValue] = true;
            }
            if ($boolCheck)
            {
                $arFields[$strEntityID] = (!empty($arValues) ? array_keys($arValues) : array());
                $boolResult = true;
            }
        }
        return $boolResult;
    }
 
    protected static function updateDiscountHandlers($discountID, $handlers, $update)
    {
        global $DB;
 
        $discountID = (int)$discountID;
        if ($discountID <= 0 || empty($handlers) || !is_array($handlers))
        {
            return;
        }
        if (isset($handlers['MODULES']))
        {
            if ($update)
            {
                $sqlQuery = 'delete from b_catalog_discount_module where DISCOUNT_ID = '.$discountID;
                $DB->Query($sqlQuery);
            }
            if (!empty($handlers['MODULES']))
            {
                foreach ($handlers['MODULES'] as &$oneModuleID)
                {
                    $fields = array(
                        'DISCOUNT_ID' => $discountID,
                        'MODULE_ID' => $oneModuleID
                    );
                    $insert = $DB->PrepareInsert('b_catalog_discount_module', $fields);
                    $sqlQuery = "insert into b_catalog_discount_module(".$insert[0].") values(".$insert[1].")";
                    $DB->Query($sqlQuery);
                }
                unset($oneModuleID);
            }
        }
    }
 
    protected static function getDiscountHandlers($discountList)
    {
        global $DB;
 
        $defaultRes = array(
            'MODULES' => array(),
            'EXT_FILES' => array()
        );
        $result = array();
        Main\Type\Collection::normalizeArrayValuesByInt($discountList, true);
        if (!empty($discountList))
        {
            $result = array_fill_keys($discountList, $defaultRes);
            $discountRows = array_chunk($discountList, 500);
            foreach ($discountRows as &$oneRow)
            {
                $sqlQuery = 'select * from b_catalog_discount_module where DISCOUNT_ID IN ('.implode(', ', $oneRow).')';
                $resQuery = $DB->Query($sqlQuery);
                while ($row = $resQuery->Fetch())
                {
                    $row['DISCOUNT_ID'] = (int)$row['DISCOUNT_ID'];
                    $result[$row['DISCOUNT_ID']]['MODULES'][] = $row['MODULE_ID'];
                }
                if (isset($row))
                    unset($row);
                unset($resQuery, $sqlQuery);
            }
            unset($oneRow, $discountRows);
        }
 
        return $result;
    }
}