oxdiscountlist.php

Go to the documentation of this file.

<?php

class oxDiscountList extends oxList
{
    static protected $_instance = null;

    protected $_sUserId = null;

    protected $_blReload = true;


    protected $_hasSkipDiscountCategories = null;

    public function __construct( $sObjectsInListName = 'oxdiscount' )
    {
        parent::__construct( 'oxdiscount' );
    }

    static public function getInstance()
    {
        // disable cashing for test modules
        if ( defined( 'OXID_PHP_UNIT' ) ) {
            self::$_instance = modInstances::getMod( __CLASS__ );
        }

        if ( !isset( self::$_instance ) ) {
            // allow modules
            self::$_instance = oxNew( 'oxDiscountList' );

            if ( defined( 'OXID_PHP_UNIT' ) ) {
                modInstances::addMod( __CLASS__, self::$_instance);
            }
        }

        return self::$_instance;
    }

    protected function _getList( $oUser = null )
    {
        $sUserId = $oUser?$oUser->getId():'';

        if ( $this->_blReload || $sUserId !== $this->_sUserId ) {
            // loading list
            $this->selectString( $this->_getFilterSelect( $oUser ) );

            // setting list proterties
            $this->_blReload = false;    // reload marker
            $this->_sUserId  = $sUserId; // discount list user id
        }

        // resetting array pointer
        $this->rewind();

        return $this;
    }

    public function getCountryId( $oUser )
    {
        $sCountryId = null;
        if ( $oUser ) {
            $sCountryId = $oUser->getActiveCountry();
        }

        return $sCountryId;
    }

    public function forceReload()
    {
        $this->_blReload = true;
    }

    protected function _getFilterSelect( $oUser )
    {
        $oBaseObject = $this->getBaseObject();

        $sTable = $oBaseObject->getViewName();
        $sQ  = "select ".$oBaseObject->getSelectFields()." from $sTable ";
        $sQ .= "where ".$oBaseObject->getSqlActiveSnippet().' ';


        // defining initial filter parameters
        $sUserId    = null;
        $sGroupIds  = null;
        $sCountryId = $this->getCountryId( $oUser );
        $oDb = oxDb::getDb();

        // checking for current session user which gives additional restrictions for user itself, users group and country
        if ( $oUser ) {

            // user ID
            $sUserId = $oUser->getId();

            // user group ids
            foreach ( $oUser->getUserGroups() as $oGroup ) {
                if ( $sGroupIds ) {
                    $sGroupIds .= ', ';
                }
                $sGroupIds .= $oDb->quote( $oGroup->getId() );
            }
        }

        $sUserTable    = getViewName( 'oxuser' );
        $sGroupTable   = getViewName( 'oxgroups' );
        $sCountryTable = getViewName( 'oxcountry' );

        $sCountrySql = $sCountryId?"EXISTS(select oxobject2discount.oxid from oxobject2discount where oxobject2discount.OXDISCOUNTID=$sTable.OXID and oxobject2discount.oxtype='oxcountry' and oxobject2discount.OXOBJECTID=".$oDb->quote( $sCountryId ).")":'0';
        $sUserSql    = $sUserId   ?"EXISTS(select oxobject2discount.oxid from oxobject2discount where oxobject2discount.OXDISCOUNTID=$sTable.OXID and oxobject2discount.oxtype='oxuser' and oxobject2discount.OXOBJECTID=".$oDb->quote( $sUserId ). ")":'0';
        $sGroupSql   = $sGroupIds ?"EXISTS(select oxobject2discount.oxid from oxobject2discount where oxobject2discount.OXDISCOUNTID=$sTable.OXID and oxobject2discount.oxtype='oxgroups' and oxobject2discount.OXOBJECTID in ($sGroupIds) )":'0';

        $sQ .= "and (
            select
                if(EXISTS(select 1 from oxobject2discount, $sCountryTable where $sCountryTable.oxid=oxobject2discount.oxobjectid and oxobject2discount.OXDISCOUNTID=$sTable.OXID and oxobject2discount.oxtype='oxcountry' LIMIT 1),
                        $sCountrySql,
                        1) &&
                if(EXISTS(select 1 from oxobject2discount, $sUserTable where $sUserTable.oxid=oxobject2discount.oxobjectid and oxobject2discount.OXDISCOUNTID=$sTable.OXID and oxobject2discount.oxtype='oxuser' LIMIT 1),
                        $sUserSql,
                        1) &&
                if(EXISTS(select 1 from oxobject2discount, $sGroupTable where $sGroupTable.oxid=oxobject2discount.oxobjectid and oxobject2discount.OXDISCOUNTID=$sTable.OXID and oxobject2discount.oxtype='oxgroups' LIMIT 1),
                        $sGroupSql,
                        1)
            )";

        return $sQ;
    }

    public function getArticleDiscounts( $oArticle, $oUser = null )
    {
        $aList = array();
        foreach ( $this->_getList( $oUser ) as $oDiscount ) {
            if ( $oDiscount->isForArticle( $oArticle ) ) {
                $aList[$oDiscount->getId()] = $oDiscount;
            }
        }

        return $aList;
    }

    public function getBasketItemDiscounts( $oArticle, $oBasket, $oUser = null )
    {
        $aList = array();
        $aDiscounts = $this->_getList( $oUser )->getArray();
        reset($aDiscounts);
        foreach ( $aDiscounts as $oDiscount ) {
            if ( $oDiscount->isForBasketItem( $oArticle ) && $oDiscount->isForBasketAmount( $oBasket ) ) {
                $aList[$oDiscount->getId()] = $oDiscount;
            }
        }

        return $aList;
    }

    public function getBasketDiscounts( $oBasket, $oUser = null )
    {
        $aList = array();
        $oList = $this->_getList( $oUser );
        foreach ( $oList->getArray() as $oDiscount ) {
            if ( $oDiscount->isForBasket( $oBasket ) ) {
                $aList[$oDiscount->getId()] = $oDiscount;
            }
        }

        return $aList;
    }

    public function getBasketItemBundleDiscounts( $oArticle, $oBasket, $oUser = null )
    {
        $aList = array();
        foreach ( $this->_getList( $oUser ) as $oDiscount ) {
            if ( $oDiscount->isForBundleItem( $oArticle, $oBasket ) && $oDiscount->isForBasketAmount($oBasket) ) {
                $aList[$oDiscount->getId()] = $oDiscount;
            }
        }

        return $aList;
    }

    public function getBasketBundleDiscounts( $oBasket, $oUser = null )
    {
        $aList = array();
        $aDiscList = $this->_getList( $oUser )->getArray();
        foreach ( $aDiscList as $oDiscount ) {
            if ( $oDiscount->isForBundleBasket( $oBasket ) ) {
                $aList[$oDiscount->getId()] = $oDiscount;
            }
        }

        return $aList;
    }

    public function applyDiscounts( $oPrice, $aDiscounts )
    {
        reset( $aDiscounts );
        while ( list( , $oDiscount ) = each( $aDiscounts ) ) {
            $oDiscount->applyDiscount( $oPrice );
        }
    }

    public function applyBasketDiscounts( oxPrice $oPrice, $aDiscounts, $dAmount = 1 )
    {
        $aDiscLog = array();
        reset( $aDiscounts );
        //#3587
        $oPrice->multiply($dAmount);

        // price object to correctly perform calculations
        $dOldPrice = $oPrice->getBruttoPrice();

        while (list( , $oDiscount ) = each( $aDiscounts ) ) {
            //#3587
            $oDiscount->applyDiscount( $oPrice, $dAmount );
            $dNewPrice = $oPrice->getBruttoPrice();

            if ( !isset( $aDiscLog[$oDiscount->getId()] ) ) {
                $aDiscLog[$oDiscount->getId()] = $oDiscount->getSimpleDiscount();
            }

            $aDiscLog[$oDiscount->getId()]->dDiscount += $dOldPrice - $dNewPrice;
            //$aDiscLog[$oDiscount->getId()]->dDiscount *= $dAmount;
            $dOldPrice = $dNewPrice;
        }
        $oPrice->divide($dAmount);

        return $aDiscLog;
    }       /*
    public function applyBasketDiscounts( oxPrice $oPrice, $aDiscounts, $dAmount = 1 )
    {
        $aDiscLog = array();
        reset( $aDiscounts );

        //$oPriceCopy = clone $oPrice;

        $oPrice->multiply($dAmount);

        // price object to correctly perform calculations
        $dOldPrice = $oPrice->getBruttoPrice();

        while (list( , $oDiscount ) = each( $aDiscounts ) ) {

            $oDiscount->applyDiscount( $oPrice );
            $dNewPrice = $oPrice->getBruttoPrice();

            if ( !isset( $aDiscLog[$oDiscount->getId()] ) ) {
                $aDiscLog[$oDiscount->getId()] = $oDiscount->getSimpleDiscount();
            }

            $aDiscLog[$oDiscount->getId()]->dDiscount += $dOldPrice - $dNewPrice;
            //$aDiscLog[$oDiscount->getId()]->dDiscount *= $dAmount;
            $dOldPrice = $dNewPrice;
        }

        //setting the correct $oPrice value
        $oPrice->divide($dAmount);

        //$oPrice = clone $oPriceCopy;

        return $aDiscLog;
    }        */

    public function hasSkipDiscountCategories()
    {
        if ( $this->_hasSkipDiscountCategories === null  || $this->_blReload ) {
            $sViewName = getViewName( 'oxcategories' );
            $sQ = "select 1 from {$sViewName} where {$sViewName}.oxactive = 1 and {$sViewName}.oxskipdiscounts = '1' ";

            $this->_hasSkipDiscountCategories = (bool) oxDb::getDb()->getOne( $sQ );
        }
        return $this->_hasSkipDiscountCategories;
    }
}