discount_coupon.php

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

<?php
 
use Bitrix\Main,
    Bitrix\Catalog,
    Bitrix\Sale\DiscountCouponsManager;
 
require_once($_SERVER["DOCUMENT_ROOT"]."/bitrix/modules/catalog/general/discount_coupon.php");
 
class CCatalogDiscountCoupon extends CAllCatalogDiscountCoupon
{
    public static function Add($arFields, $bAffectDataFile = true)
    {
        static $eventOnBeforeAddExists = null;
        static $eventOnAddExists = null;
        global $DB;
 
        if ($eventOnBeforeAddExists === true || $eventOnBeforeAddExists === null)
        {
            foreach (GetModuleEvents('catalog', 'OnBeforeCouponAdd', true) as $arEvent)
            {
                $eventOnBeforeAddExists = true;
                if (ExecuteModuleEventEx($arEvent, array(&$arFields, &$bAffectDataFile)) === false)
                    return false;
            }
            if ($eventOnBeforeAddExists === null)
                $eventOnBeforeAddExists = false;
        }
 
        $bAffectDataFile = false;
 
        if (!CCatalogDiscountCoupon::CheckFields("ADD", $arFields, 0))
            return false;
 
        $arInsert = $DB->PrepareInsert("b_catalog_discount_coupon", $arFields);
 
        $strSql = "INSERT INTO b_catalog_discount_coupon(".$arInsert[0].") VALUES(".$arInsert[1].")";
        $DB->Query($strSql);
 
        $ID = (int)$DB->LastID();
 
        if ($ID > 0)
            Catalog\DiscountTable::setUseCoupons($arFields['DISCOUNT_ID'], 'Y');
 
        if ($eventOnAddExists === true || $eventOnAddExists === null)
        {
            foreach (GetModuleEvents('catalog', 'OnCouponAdd', true) as $arEvent)
            {
                $eventOnAddExists = true;
                ExecuteModuleEventEx($arEvent, array($ID, $arFields));
            }
            if ($eventOnAddExists === null)
                $eventOnAddExists = false;
        }
 
        return $ID;
    }
 
    public static function Update($ID, $arFields)
    {
        static $eventOnBeforeUpdateExists = null;
        static $eventOnUpdateExists = null;
        global $DB;
 
        $ID = (int)$ID;
        if ($ID <= 0)
            return false;
 
        if ($eventOnBeforeUpdateExists === true || $eventOnBeforeUpdateExists === null)
        {
            foreach (GetModuleEvents('catalog', 'OnBeforeCouponUpdate', true) as $arEvent)
            {
                $eventOnBeforeUpdateExists = true;
                if (ExecuteModuleEventEx($arEvent, array($ID, &$arFields)) === false)
                    return false;
            }
            if ($eventOnBeforeUpdateExists === null)
                $eventOnBeforeUpdateExists = false;
        }
 
        if (!CCatalogDiscountCoupon::CheckFields("UPDATE", $arFields, $ID))
            return false;
 
        $discountIds = array();
        $strUpdate = $DB->PrepareUpdate("b_catalog_discount_coupon", $arFields);
        if (!empty($strUpdate))
        {
            if (isset($arFields['DISCOUNT_ID']))
            {
                $iterator = Catalog\DiscountCouponTable::getList(array(
                    'select' => array('DISCOUNT_ID', 'ID'),
                    'filter' => array('=ID' => $ID)
                ));
                $row = $iterator->fetch();
                unset($iterator);
                if (!empty($row))
                {
                    $row['DISCOUNT_ID'] = (int)$row['DISCOUNT_ID'];
                    if ($row['DISCOUNT_ID'] != $arFields['DISCOUNT_ID'])
                    {
                        $discountIds[] = $arFields['DISCOUNT_ID'];
                        $discountIds[] = $row['DISCOUNT_ID'];
                    }
                }
                unset($row);
            }
 
            $strSql = "UPDATE b_catalog_discount_coupon SET ".$strUpdate." WHERE ID = ".$ID;
            $DB->Query($strSql);
 
            if (!empty($discountIds))
            {
                $withoutCoupons = array_fill_keys($discountIds, true);
                $withCoupons = array();
                $couponIterator = Catalog\DiscountCouponTable::getList(array(
                    'select' => array('DISCOUNT_ID', new Main\Entity\ExpressionField('CNT', 'COUNT(*)')),
                    'filter' => array('@DISCOUNT_ID' => $discountIds),
                    'group' => array('DISCOUNT_ID')
                ));
                while ($coupon = $couponIterator->fetch())
                {
                    $coupon['CNT'] = (int)$coupon['CNT'];
                    if ($coupon['CNT'] > 0)
                    {
                        $coupon['DISCOUNT_ID'] = (int)$coupon['DISCOUNT_ID'];
                        unset($withoutCoupons[$coupon['DISCOUNT_ID']]);
                        $withCoupons[$coupon['DISCOUNT_ID']] = true;
                    }
                }
                unset($coupon, $couponIterator);
                if (!empty($withoutCoupons))
                {
                    $withoutCoupons = array_keys($withoutCoupons);
                    Catalog\DiscountTable::setUseCoupons($withoutCoupons, 'N');
                }
                if (!empty($withCoupons))
                {
                    $withCoupons = array_keys($withCoupons);
                    Catalog\DiscountTable::setUseCoupons($withCoupons, 'Y');
                }
                unset($withCoupons, $withoutCoupons);
            }
        }
        unset($discountIds);
 
        if ($eventOnUpdateExists === true || $eventOnUpdateExists === null)
        {
            foreach (GetModuleEvents('catalog', 'OnCouponUpdate', true) as $arEvent)
            {
                $eventOnUpdateExists = true;
                ExecuteModuleEventEx($arEvent, array($ID, $arFields));
            }
            if ($eventOnUpdateExists === null)
                $eventOnUpdateExists = false;
        }
 
        return $ID;
    }
 
    public static function Delete($ID, $bAffectDataFile = true)
    {
        static $eventOnBeforeDeleteExists = null;
        static $eventOnDeleteExists = null;
        global $DB;
 
        $ID = (int)$ID;
        if ($ID <= 0)
            return false;
 
        if ($eventOnBeforeDeleteExists === true || $eventOnBeforeDeleteExists === null)
        {
            foreach (GetModuleEvents('catalog', 'OnBeforeCouponDelete', true) as $arEvent)
            {
                $eventOnBeforeDeleteExists = true;
                if (ExecuteModuleEventEx($arEvent, array($ID, &$bAffectDataFile)) === false)
                    return false;
            }
            if ($eventOnBeforeDeleteExists === null)
                $eventOnBeforeDeleteExists = false;
        }
 
        $bAffectDataFile = false;
 
        $iterator = Catalog\DiscountCouponTable::getList(array(
            'select' => array('DISCOUNT_ID', 'ID'),
            'filter' => array('=ID' => $ID)
        ));
        $row = $iterator->fetch();
        unset($iterator);
 
        $DB->Query("DELETE FROM b_catalog_discount_coupon WHERE ID = ".$ID);
 
        if (!empty($row))
        {
            $row['DISCOUNT_ID'] = (int)$row['DISCOUNT_ID'];
            $iterator = Catalog\DiscountCouponTable::getList(array(
                'select' => array('DISCOUNT_ID'),
                'filter' => array('=DISCOUNT_ID' => $row['DISCOUNT_ID']),
                'limit' => 1
            ));
            $existRow = $iterator->fetch();
            unset($iterator);
            Catalog\DiscountTable::setUseCoupons(
                $row['DISCOUNT_ID'],
                (!empty($existRow) ? 'Y' : 'N')
            );
            unset($existRow);
        }
        unset($row);
 
        if ($eventOnDeleteExists === true || $eventOnDeleteExists === null)
        {
            foreach (GetModuleEvents('catalog', 'OnCouponDelete', true) as $arEvent)
            {
                $eventOnDeleteExists = true;
                ExecuteModuleEventEx($arEvent, array($ID));
            }
            if ($eventOnDeleteExists === null)
                $eventOnDeleteExists = false;
        }
 
        return true;
    }
 
    public static function GetByID($ID)
    {
        global $DB;
 
        $ID = intval($ID);
        if ($ID <= 0)
            return false;
 
        $strSql =
            "SELECT CD.ID, CD.DISCOUNT_ID, CD.ACTIVE, CD.COUPON, CD.ONE_TIME, ".
            $DB->DateToCharFunction("CD.DATE_APPLY", "FULL")." as DATE_APPLY, ".
            $DB->DateToCharFunction("CD.TIMESTAMP_X", "FULL")." as TIMESTAMP_X, ".
            "CD.CREATED_BY, CD.MODIFIED_BY, ".$DB->DateToCharFunction('CD.DATE_CREATE', 'FULL').' as DATE_CREATE, '.
            "CD.DESCRIPTION FROM b_catalog_discount_coupon CD WHERE CD.ID = ".$ID;
 
        $db_res = $DB->Query($strSql);
        if ($res = $db_res->Fetch())
            return $res;
 
        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"),
            "DISCOUNT_ID" => array("FIELD" => "CD.DISCOUNT_ID", "TYPE" => "string"),
            "ACTIVE" => array("FIELD" => "CD.ACTIVE", "TYPE" => "char"),
            "ONE_TIME" => array("FIELD" => "CD.ONE_TIME", "TYPE" => "char"),
            "COUPON" => array("FIELD" => "CD.COUPON", "TYPE" => "string"),
            "DATE_APPLY" => array("FIELD" => "CD.DATE_APPLY", "TYPE" => "datetime"),
            "DISCOUNT_NAME" => array("FIELD" => "CDD.NAME", "TYPE" => "string", "FROM" => "LEFT JOIN b_catalog_discount CDD ON (CD.DISCOUNT_ID = CDD.ID)"),
            "DESCRIPTION" => array("FIELD" => "CD.DESCRIPTION","TYPE" => "string"),
            "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"),
        );
 
        $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_coupon 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_coupon 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_coupon 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 CouponApply($intUserID, $strCoupon)
    {
        if (self::$existCouponsManager === null)
            self::initCouponManager();
        if (self::$existCouponsManager)
        {
            $couponList = (is_array($strCoupon) ? $strCoupon : array($strCoupon));
            return DiscountCouponsManager::setApplyByProduct(array('MODULE' => 'catalog'), $couponList, true);
        }
        else
        {
            global $DB;
 
            $mxResult = false;
 
            $intUserID = (int)$intUserID;
            if ($intUserID < 0)
                $intUserID = 0;
 
            $arCouponList = array();
            $arCheck = (is_array($strCoupon) ? $strCoupon : array($strCoupon));
            foreach ($arCheck as &$strOneCheck)
            {
                $strOneCheck = (string)$strOneCheck;
                if ('' != $strOneCheck)
                    $arCouponList[] = $strOneCheck;
            }
            if (isset($strOneCheck))
                unset($strOneCheck);
 
            if (empty($arCouponList))
                return $mxResult;
 
            $strDateFunction = $DB->GetNowFunction();
            $boolFlag = false;
            $couponIterator = Catalog\DiscountCouponTable::getList(array(
                'select' => array('ID', 'TYPE', 'COUPON'),
                'filter' => array('=COUPON' => $arCouponList, '=ACTIVE' => 'Y')
            ));
            while ($arCoupon = $couponIterator->fetch())
            {
                $arCoupon['ID'] = (int)$arCoupon['ID'];
                $arFields = array(
                    "~DATE_APPLY" => $strDateFunction
                );
 
                if ($arCoupon['TYPE'] == Catalog\DiscountCouponTable::TYPE_ONE_ROW)
                {
                    $arFields["ACTIVE"] = "N";
                    if (0 < $intUserID)
                    {
                        CCatalogDiscountCoupon::EraseCouponByManage($intUserID, $arCoupon['COUPON']);
                    }
                    else
                    {
                        CCatalogDiscountCoupon::EraseCoupon($arCoupon['COUPON']);
                    }
                }
                elseif ($arCoupon['TYPE'] == Catalog\DiscountCouponTable::TYPE_ONE_ORDER)
                {
                    $boolFlag = true;
                    if (!isset(self::$arOneOrderCoupons[$arCoupon['ID']]))
                        self::$arOneOrderCoupons[$arCoupon['ID']] = array(
                            'COUPON' => $arCoupon['COUPON'],
                            'USER_ID' => $intUserID,
                        );
                }
 
                $strUpdate = $DB->PrepareUpdate("b_catalog_discount_coupon", $arFields);
                if (!empty($strUpdate))
                {
                    $strSql = "UPDATE b_catalog_discount_coupon SET ".$strUpdate." WHERE ID = ".$arCoupon['ID'];
                    $DB->Query($strSql);
                    $mxResult = true;
                }
            }
            unset($arCoupon, $couponIterator);
            if ($boolFlag)
            {
                AddEventHandler('sale', 'OnBasketOrder', array('CCatalogDiscountCoupon', 'CouponOneOrderDisable'));
                AddEventHandler('sale', 'OnDoBasketOrder', array('CCatalogDiscountCoupon', 'CouponOneOrderDisable'));
            }
            return $mxResult;
        }
    }

    public static function __CouponOneOrderDisable($arCoupons)
    {
        global $DB;
        if (!is_array($arCoupons))
            $arCoupons = array(intval($arCoupons));
        CatalogClearArray($arCoupons, false);
        if (empty($arCoupons))
            return;
        $strSql = "UPDATE b_catalog_discount_coupon SET ACTIVE='N' WHERE ID IN (".implode(', ', $arCoupons).") AND ONE_TIME='".self::TYPE_ONE_ORDER."'";
        $DB->Query($strSql);
    }

    public static function CouponOneOrderDisable($intOrderID = 0)
    {
        if (self::$existCouponsManager === null)
            self::initCouponManager();
        if (self::$existCouponsManager)
            return;
 
        global $DB;
        if (!empty(self::$arOneOrderCoupons))
        {
            $arCouponID = array_keys(self::$arOneOrderCoupons);
            foreach (self::$arOneOrderCoupons as &$arCoupon)
            {
                $arCoupon['USER_ID'] = intval($arCoupon['USER_ID']);
                if (0 < $arCoupon['USER_ID'])
                {
                    CCatalogDiscountCoupon::EraseCouponByManage($arCoupon['USER_ID'], $arCoupon['COUPON']);
                }
                else
                {
                    CCatalogDiscountCoupon::EraseCoupon($arCoupon['COUPON']);
                }
            }
            if (isset($arCoupon))
                unset($arCoupon);
            CatalogClearArray($arCouponID, false);
            if (!empty($arCouponID))
            {
                $strSql = "UPDATE b_catalog_discount_coupon SET ACTIVE='N' WHERE ID IN (".implode(', ', $arCouponID).") AND ONE_TIME='".self::TYPE_ONE_ORDER."' AND ACTIVE='Y'";
                $DB->Query($strSql);
            }
            self::$arOneOrderCoupons = array();
        }
    }

    public static function IsExistCoupon($strCoupon)
    {
        if (self::$existCouponsManager === null)
            self::initCouponManager();
        if (self::$existCouponsManager)
        {
            $result = DiscountCouponsManager::isExist($strCoupon);
            if (!empty($result))
                return true;
            return false;
        }
        else
        {
            global $DB;
 
            if ($strCoupon == '')
                return false;
 
            $strSql = "select ID, COUPON from b_catalog_discount_coupon where COUPON='".$DB->ForSql($strCoupon)."' limit 1";
            $rsCoupons = $DB->Query($strSql);
            if ($arCoupon = $rsCoupons->Fetch())
                return true;
        }
        return false;
    }
}