Mage_CatalogRule_Model_Mysql4_Rule Class Reference

Inheritance diagram for Mage_CatalogRule_Model_Mysql4_Rule:

List of all members.

Public Member Functions
	_beforeSave (Mage_Core_Model_Abstract $object)
	updateRuleProductData (Mage_CatalogRule_Model_Rule $rule)
	getRuleProductIds ($ruleId)
	removeCatalogPricesForDateRange ($fromDate, $toDate, $productId=null)
	deleteOldData ($date, $productId=null)
	getRuleProductsForDateRange ($fromDate, $toDate, $productId=null)
	applyAllRulesForDateRange ($fromDate=null, $toDate=null, $productId=null)
	getRulePrice ($date, $wId, $gId, $pId)
	getRulesForProduct ($date, $wId, $pId)
	applyToProduct ($rule, $product, $websiteIds)
Public Attributes
const	SECONDS_IN_DAY = 86400
Protected Member Functions
	_construct ()
	_getRuleProductsStmt ($fromDate, $toDate, $productId=null, $websiteId=null)
	_calcRuleProductPrice ($ruleData, $productData=null)
	_saveRuleProductPrices ($arrData)

---

Detailed Description

Catalog rules resource model

Definition at line 30 of file Rule.php.

---

Member Function Documentation

_beforeSave

(

Mage_Core_Model_Abstract $

object

)

Prepare object data for saving

Parameters:

Mage_Core_Model_Abstract

$object

Reimplemented from Mage_Core_Model_Mysql4_Abstract.

Definition at line 47 of file Rule.php.

    {
        if (!$object->getFromDate()) {
            $date = new Zend_Date(Mage::getModel('core/date')->gmtTimestamp());
            $date->setHour(0)
                ->setMinute(0)
                ->setSecond(0);
            $object->setFromDate($date);
        }
        if ($object->getFromDate() instanceof Zend_Date) {
            $object->setFromDate($object->getFromDate()->toString(Varien_Date::DATETIME_INTERNAL_FORMAT));
        }

        if (!$object->getToDate()) {
            $object->setToDate(new Zend_Db_Expr('NULL'));
        }
        else {
            if ($object->getToDate() instanceof Zend_Date) {
                $object->setToDate($object->getToDate()->toString(Varien_Date::DATETIME_INTERNAL_FORMAT));
            }
        }
        parent::_beforeSave($object);
    }

_calcRuleProductPrice	(	$	ruleData,
		$	productData = null
	)			[protected]

Calculate product price based on price rule data and previous information

Parameters:

	array	$ruleData
	null|array	$productData

Returns:

float

Definition at line 611 of file Rule.php.

    {
        if ($productData !== null && isset($productData['rule_price'])) {
            $productPrice = $productData['rule_price'];
        }
        else {
            $websiteId = $ruleData['website_id'];
            if (isset($ruleData['website_'.$websiteId.'_price'])) {
                $productPrice = $ruleData['website_'.$websiteId.'_price'];
            }
            else {
                $productPrice = $ruleData['default_price'];
            }
        }

        $amount = $ruleData['action_amount'];
        switch ($ruleData['action_operator']) {
            case 'to_fixed':
                $productPrice = $amount;
                break;
            case 'to_percent':
                $productPrice= $productPrice*$amount/100;
                break;
            case 'by_fixed':
                $productPrice -= $amount;
                break;
            case 'by_percent':
                $productPrice = $productPrice*(1-$amount/100);
                break;
        }

        $productPrice = max($productPrice, 0);
        return Mage::app()->getStore()->roundPrice($productPrice);
    }

_construct

(

)

[protected]

Initialize main table and table id field

Reimplemented from Mage_Core_Model_Resource_Abstract.

Definition at line 37 of file Rule.php.

    {
        $this->_init('catalogrule/rule', 'rule_id');
    }

_getRuleProductsStmt	(	$	fromDate,
		$	toDate,
		$	productId = null,
		$	websiteId = null
	)			[protected]

Get DB resource statment for processing query result

Parameters:

	int	$fromDate
	int	$toDate
	int|null	$productId
	int|null	$websiteId

Returns:

Zend_Db_Statement_Interface

Sort order is important It used for check stop price rule condition. website_id customer_group_id product_id sort_order 1 1 1 0 1 1 1 1 1 1 1 2 if row with sort order 1 will have stop flag we should exclude all next rows for same product id from price calculation

Join default price and websites prices to result

Definition at line 305 of file Rule.php.

    {
        $read = $this->_getReadAdapter();
        /**
         * Sort order is important
         * It used for check stop price rule condition.
         * website_id   customer_group_id   product_id  sort_order
         *  1           1                   1           0
         *  1           1                   1           1
         *  1           1                   1           2
         * if row with sort order 1 will have stop flag we should exclude
         * all next rows for same product id from price calculation
         */
        $select = $read->select()
            ->from(array('rp'=>$this->getTable('catalogrule/rule_product')))
            ->where($read->quoteInto('rp.from_time=0 or rp.from_time<=?', $toDate)
            ." or ".$read->quoteInto('rp.to_time=0 or rp.to_time>=?', $fromDate))
            ->order(array('rp.website_id', 'rp.customer_group_id', 'rp.product_id', 'rp.sort_order'));

        if (!is_null($productId)) {
            $select->where('rp.product_id=?', $productId);
        }

        /**
         * Join default price and websites prices to result
         */
        $priceAttr  = Mage::getSingleton('eav/config')->getAttribute('catalog_product', 'price');
        $priceTable = $priceAttr->getBackend()->getTable();
        $attributeId= $priceAttr->getId();

        $joinCondition = '%1$s.entity_id=rp.product_id AND (%1$s.attribute_id='.$attributeId.') and %1$s.store_id=%2$s';

        $select->join(
            array('pp_default'=>$priceTable),
            sprintf($joinCondition, 'pp_default', Mage_Core_Model_App::ADMIN_STORE_ID),
            array('default_price'=>'pp_default.value')
        );

        if ($websiteId !== null) {
            $website  = Mage::app()->getWebsite($websiteId);
            $defaultGroup = $website->getDefaultGroup();
            if ($defaultGroup instanceof Mage_Core_Model_Store_Group) {
                $storeId    = $defaultGroup->getDefaultStoreId();
            } else {
                $storeId    = Mage_Core_Model_App::ADMIN_STORE_ID;
            }

            $select->joinInner(
                array('product_website'=>$this->getTable('catalog/product_website')),
                'product_website.product_id=rp.product_id AND product_website.website_id='.$websiteId,
                array()
            );

            $tableAlias = 'pp'.$websiteId;
            $fieldAlias = 'website_'.$websiteId.'_price';
            $select->joinLeft(
                array($tableAlias=>$priceTable),
                sprintf($joinCondition, $tableAlias, $storeId),
                array($fieldAlias=>$tableAlias.'.value')
            );
        } else {
            foreach (Mage::app()->getWebsites() as $website) {
                $websiteId  = $website->getId();
                $defaultGroup = $website->getDefaultGroup();
                if ($defaultGroup instanceof Mage_Core_Model_Store_Group) {
                    $storeId    = $defaultGroup->getDefaultStoreId();
                } else {
                    $storeId    = Mage_Core_Model_App::ADMIN_STORE_ID;
                }

                $storeId    = $defaultGroup->getDefaultStoreId();
                $tableAlias = 'pp'.$websiteId;
                $fieldAlias = 'website_'.$websiteId.'_price';
                $select->joinLeft(
                    array($tableAlias=>$priceTable),
                    sprintf($joinCondition, $tableAlias, $storeId),
                    array($fieldAlias=>$tableAlias.'.value')
                );
            }
        }
        return $read->query($select);
    }

_saveRuleProductPrices

(

$

arrData

)

[protected]

Save rule prices for products to DB

Parameters:

array

$arrData

Returns:

Mage_CatalogRule_Model_Mysql4_Rule

Definition at line 652 of file Rule.php.

    {
        if (empty($arrData)) {
            return $this;
        }
        $header = 'replace into '.$this->getTable('catalogrule/rule_product_price').' (
                rule_date,
                website_id,
                customer_group_id,
                product_id,
                rule_price,
                latest_start_date,
                earliest_end_date
            ) values ';
        $rows = array();
        $productIds = array();
        foreach ($arrData as $data) {
            $productIds[$data['product_id']] = true;
            $data['rule_date']          = $this->formatDate($data['rule_date'], false);
            $data['latest_start_date']  = $this->formatDate($data['latest_start_date'], false);
            $data['earliest_end_date']  = $this->formatDate($data['earliest_end_date'], false);
            $rows[] = '(' . $this->_getWriteAdapter()->quote($data) . ')';
        }
        $query = $header.join(',', $rows);
        $insertQuery = 'REPLACE INTO ' . $this->getTable('catalogrule/affected_product') . ' (product_id)  VALUES ' .
            '(' . join('),(', array_keys($productIds)) . ')';
        $this->_getWriteAdapter()->query($insertQuery);
        $this->_getWriteAdapter()->query($query);
        return $this;
    }

applyAllRulesForDateRange	(	$	fromDate = null,
		$	toDate = null,
		$	productId = null
	)

Generate catalog price rules prices for specified date range If from date is not defined - will be used previous day by UTC If to date is not defined - will be used next day by UTC

Parameters:

	int|string|null	$fromDate
	int|string|null	$toDate
	int	$productId

Returns:

Mage_CatalogRule_Model_Mysql4_Rule

If fromDate not specified we can delete all data oldest than 1 day We have run it for clear table in case when cron was not installed and old data exist in table

Update products rules prices per each website separatly because of max join limit in mysql

Build prices for each day

Build prices for each day

Definition at line 398 of file Rule.php.

    {
        $write = $this->_getWriteAdapter();
        $write->beginTransaction();

        Mage::dispatchEvent('catalogrule_before_apply', array('resource'=>$this));

        $clearOldData = false;
        if ($fromDate === null) {
            $fromDate = mktime(0,0,0,date('m'),date('d')-1);
            /**
             * If fromDate not specified we can delete all data oldest than 1 day
             * We have run it for clear table in case when cron was not installed
             * and old data exist in table
             */
            $clearOldData = true;
        }
        if (is_string($fromDate)) {
            $fromDate = strtotime($fromDate);
        }
        if ($toDate === null) {
            $toDate = mktime(0,0,0,date('m'),date('d')+1);
        }
        if (is_string($toDate)) {
            $toDate = strtotime($toDate);
        }

        $product = null;
        if ($productId instanceof Mage_Catalog_Model_Product) {
            $product = $productId;
            $productId = $productId->getId();
        }

        $this->removeCatalogPricesForDateRange($fromDate, $toDate, $productId);
        if ($clearOldData) {
            $this->deleteOldData($fromDate, $productId);
        }

        try {
            /**
             * Update products rules prices per each website separatly
             * because of max join limit in mysql
             */
            foreach (Mage::app()->getWebsites(false) as $website) {
                $productsStmt = $this->_getRuleProductsStmt(
                   $fromDate,
                   $toDate,
                   $productId,
                   $website->getId()
                );

                $dayPrices  = array();
                $stopFlags  = array();
                $prevKey    = null;

                while ($ruleData = $productsStmt->fetch()) {
                    $ruleProductId = $ruleData['product_id'];
                    $productKey= $ruleProductId . '_'
                       . $ruleData['website_id'] . '_'
                       . $ruleData['customer_group_id'];

                    if ($prevKey && ($prevKey != $productKey)) {
                        $stopFlags = array();
                    }

                    /**
                     * Build prices for each day
                     */
                    for ($time=$fromDate; $time<=$toDate; $time+=self::SECONDS_IN_DAY) {
                        if (($ruleData['from_time']==0 || $time >= $ruleData['from_time'])
                            && ($ruleData['to_time']==0 || $time <=$ruleData['to_time'])) {

                            $priceKey = $time . '_' . $productKey;

                            if (isset($stopFlags[$priceKey])) {
                                continue;
                            }

                            if (!isset($dayPrices[$priceKey])) {
                                $dayPrices[$priceKey] = array(
                                    'rule_date'         => $time,
                                    'website_id'        => $ruleData['website_id'],
                                    'customer_group_id' => $ruleData['customer_group_id'],
                                    'product_id'        => $ruleProductId,
                                    'rule_price'        => $this->_calcRuleProductPrice($ruleData),
                                    'latest_start_date' => $ruleData['from_time'],
                                    'earliest_end_date' => $ruleData['to_time'],
                                );
                            }
                            else {
                                $dayPrices[$priceKey]['rule_price'] = $this->_calcRuleProductPrice(
                                    $ruleData,
                                    $dayPrices[$priceKey]
                                );
                                $dayPrices[$priceKey]['latest_start_date'] = max(
                                    $dayPrices[$priceKey]['latest_start_date'],
                                    $ruleData['from_time']
                                );
                                $dayPrices[$priceKey]['earliest_end_date'] = min(
                                    $dayPrices[$priceKey]['earliest_end_date'],
                                    $ruleData['to_time']
                                );
                            }

                            if ($ruleData['action_stop']) {
                                $stopFlags[$priceKey] = true;
                            }
                        }
                    }

                    $prevKey = $productKey;

                    if (count($dayPrices)>100) {
                        $this->_saveRuleProductPrices($dayPrices);
                        $dayPrices = array();
                    }
                }
                $this->_saveRuleProductPrices($dayPrices);
            }
            $this->_saveRuleProductPrices($dayPrices);
            $write->commit();

            //
//            $dayPrices  = array();
//            $stopFlags  = array();
//            $prevKey    = null;
//            while ($ruleData = $productsStmt->fetch()) {
//                $productId = $ruleData['product_id'];
//                $productKey= $productId . '_' . $ruleData['website_id'] . '_' . $ruleData['customer_group_id'];
//
//                if ($prevKey && ($prevKey != $productKey)) {
//                    $stopFlags = array();
//                }
//
//                /**
//                 * Build prices for each day
//                 */
//                for ($time=$fromDate; $time<=$toDate; $time+=self::SECONDS_IN_DAY) {
//
//                    if (($ruleData['from_time']==0 || $time >= $ruleData['from_time'])
//                        && ($ruleData['to_time']==0 || $time <=$ruleData['to_time'])) {
//
//                        $priceKey = $time . '_' . $productKey;
//
//                        if (isset($stopFlags[$priceKey])) {
//                            continue;
//                        }
//
//                        if (!isset($dayPrices[$priceKey])) {
//                            $dayPrices[$priceKey] = array(
//                                'rule_date'         => $time,
//                                'website_id'        => $ruleData['website_id'],
//                                'customer_group_id' => $ruleData['customer_group_id'],
//                                'product_id'        => $productId,
//                                'rule_price'        => $this->_calcRuleProductPrice($ruleData),
//                                'latest_start_date' => $ruleData['from_time'],
//                                'earliest_end_date' => $ruleData['to_time'],
//                            );
//                        }
//                        else {
//                            $dayPrices[$priceKey]['rule_price'] = $this->_calcRuleProductPrice(
//                                $ruleData,
//                                $dayPrices[$priceKey]
//                            );
//                            $dayPrices[$priceKey]['latest_start_date'] = max(
//                                $dayPrices[$priceKey]['latest_start_date'],
//                                $ruleData['from_time']
//                            );
//                            $dayPrices[$priceKey]['earliest_end_date'] = min(
//                                $dayPrices[$priceKey]['earliest_end_date'],
//                                $ruleData['to_time']
//                            );
//                        }
//
//                        if ($ruleData['action_stop']) {
//                            $stopFlags[$priceKey] = true;
//                        }
//                    }
//                }
//
//                $prevKey = $productKey;
//
//                if (count($dayPrices)>100) {
//                    $this->_saveRuleProductPrices($dayPrices);
//                    $dayPrices = array();
//                }
//            }
//            $this->_saveRuleProductPrices($dayPrices);
//            $write->commit();
        } catch (Exception $e) {
            $write->rollback();
            throw $e;
        }

        $productCondition = Mage::getModel('catalog/product_condition')
            ->setTable($this->getTable('catalogrule/affected_product'))
            ->setPkFieldName('product_id');
        Mage::dispatchEvent('catalogrule_after_apply', array(
            'product'=>$product,
            'product_condition' => $productCondition
        ));
        $write->delete($this->getTable('catalogrule/affected_product'));

        return $this;
    }

applyToProduct	(	$	rule,
		$	product,
		$	websiteIds
	)

Apply catalog rule to product

Parameters:

	Mage_CatalogRule_Model_Rule	$rule
	Mage_Catalog_Model_Product	$product
	array	$websiteIds

Returns:

Mage_CatalogRule_Model_Mysql4_Rule

Definition at line 732 of file Rule.php.

    {
        if (!$rule->getIsActive()) {
            return $this;
        }

        $ruleId = $rule->getId();
        $productId = $product->getId();

        $write = $this->_getWriteAdapter();
        $write->beginTransaction();

        $write->delete($this->getTable('catalogrule/rule_product'), array(
            $write->quoteInto('rule_id=?', $ruleId),
            $write->quoteInto('product_id=?', $productId),
        ));

        if (!$rule->getConditions()->validate($product)) {
            $write->delete($this->getTable('catalogrule/rule_product_price'), array(
                $write->quoteInto('product_id=?', $productId),
            ));
            $write->commit();
            return $this;
        }

        $customerGroupIds = $rule->getCustomerGroupIds();

        $fromTime   = strtotime($rule->getFromDate());
        $toTime     = strtotime($rule->getToDate());
        $toTime     = $toTime ? $toTime+self::SECONDS_IN_DAY-1 : 0;

        $sortOrder      = (int)$rule->getSortOrder();
        $actionOperator = $rule->getSimpleAction();
        $actionAmount   = $rule->getDiscountAmount();
        $actionStop     = $rule->getStopRulesProcessing();

        $rows = array();
        $header = 'replace into '.$this->getTable('catalogrule/rule_product').' (
                rule_id,
                from_time,
                to_time,
                website_id,
                customer_group_id,
                product_id,
                action_operator,
                action_amount,
                action_stop,
                sort_order
            ) values ';
        try {
            foreach ($websiteIds as $websiteId) {
                foreach ($customerGroupIds as $customerGroupId) {
                    $rows[] = "(
                        '$ruleId',
                        '$fromTime',
                        '$toTime',
                        '$websiteId',
                        '$customerGroupId',
                        '$productId',
                        '$actionOperator',
                        '$actionAmount',
                        '$actionStop',
                        '$sortOrder'
                    )";
                    if (sizeof($rows)==100) {
                        $sql = $header.join(',', $rows);
                        $write->query($sql);
                        $rows = array();
                    }
                }
            }

            if (!empty($rows)) {
                $sql = $header.join(',', $rows);
                $write->query($sql);
            }
        } catch (Exception $e) {
            $write->rollback();
            throw $e;

        }
        $this->applyAllRulesForDateRange(null, null, $product);
        $write->commit();
        return $this;
    }

deleteOldData	(	$	date,
		$	productId = null
	)

Delete old price rules data

Parameters:

	int	$maxDate
	mixed	$productId

Returns:

Mage_CatalogRule_Model_Mysql4_Rule

Definition at line 211 of file Rule.php.

    {
        $write = $this->_getWriteAdapter();
        $conds = array();
        $conds[] = $write->quoteInto('rule_date<?', $this->formatDate($date));
        if (!is_null($productId)) {
            $conds[] = $write->quoteInto('product_id=?', $productId);
        }
        $write->delete($this->getTable('catalogrule/rule_product_price'), $conds);
        return $this;
    }

getRulePrice	(	$	date,
		$	wId,
		$	gId,
		$	pId
	)

Get catalog rules product price for specific date, website and customer group

Parameters:

	int|string	$date
	int	$wId
	int	$gId
	int	$pId

Returns:

float | false

Definition at line 693 of file Rule.php.

    {
        $read = $this->_getReadAdapter();
        $select = $read->select()
            ->from($this->getTable('catalogrule/rule_product_price'), 'rule_price')
            ->where('rule_date=?', $this->formatDate($date, false))
            ->where('website_id=?', $wId)
            ->where('customer_group_id=?', $gId)
            ->where('product_id=?', $pId);
        return $read->fetchOne($select);
    }

getRuleProductIds

(

$

ruleId

)

Get all product ids matched for rule

Parameters:

int

$ruleId

Returns:

array

Definition at line 164 of file Rule.php.

    {
        $read = $this->_getReadAdapter();
        $select = $read->select()->from($this->getTable('catalogrule/rule_product'), 'product_id')
            ->where('rule_id=?', $ruleId);
        return $read->fetchCol($select);
    }

getRuleProductsForDateRange	(	$	fromDate,
		$	toDate,
		$	productId = null
	)

Get rules data for all products in specified date range

deprecated

Parameters:

	int|string	$fromDate
	int|string	$toDate
	int|null	$productId

Returns:

false|array

Prepare price information per website

Definition at line 233 of file Rule.php.

    {
        $read = $this->_getReadAdapter();

        $select = $read->select()
            ->from($this->getTable('catalogrule/rule_product'))
            ->where($read->quoteInto('from_time=0 or from_time<=?', strtotime($toDate))
            ." or ".$read->quoteInto('to_time=0 or to_time>=?', strtotime($fromDate)))
            ->order(array('website_id', 'customer_group_id', 'product_id', 'sort_order'));
        // crucial for logic sort order: website_id, customer_group_id, product_id, sort_order
        // had 'from_time', 'to_time' in the beginning before
        if (!is_null($productId)) {
            $select->where('product_id=?', $productId);
        }

        if (!$ruleProducts = $read->fetchAll($select)) {
            return false;
        }
        $productIds = array();
        foreach ($ruleProducts as $p) {
            $productIds[] = $p['product_id'];
        }

        $priceAttr = Mage::getSingleton('eav/config')->getAttribute('catalog_product', 'price');

        $select = $read->select()
            ->from($priceAttr->getBackend()->getTable(), array('entity_id', 'store_id', 'value'))
            ->where('attribute_id=?', $priceAttr->getAttributeId())
            ->where('entity_id in (?)', $productIds)
            ->order('store_id');

        $prices = $read->fetchAll($select);

        /**
         * Prepare price information per website
         */
        $productPrices = array();
        foreach ($prices as $index => $priceData) {
            $websiteId = Mage::app()->getStore($priceData['store_id'])->getWebsiteId();

            if (!isset($productPrices[$priceData['entity_id']])) {
                $productPrices[$priceData['entity_id']] = array(
                    'default'    => $priceData['value'],
                    'websites'   => array($websiteId=>$priceData['value'])
                );
            }
            else {
                $productPrices[$priceData['entity_id']]['websites'][$websiteId] = $priceData['value'];
            }
        }

        foreach ($ruleProducts as &$p) {
            if (isset($productPrices[$p['product_id']]['websites'][$p['website_id']])) {
                $p['price'] = $productPrices[$p['product_id']]['websites'][$p['website_id']];
            }
            elseif (isset($productPrices[$p['product_id']]['default'])) {
                $p['price'] = $productPrices[$p['product_id']]['default'];
            }
        }

        return $ruleProducts;
    }

getRulesForProduct	(	$	date,
		$	wId,
		$	pId
	)

Get data about product prices for all customer groups

Parameters:

	int|string	$date
	int	$wId
	int	$pId

Returns:

array

Definition at line 713 of file Rule.php.

    {
        $read = $this->_getReadAdapter();
        $select = $read->select()
            ->from($this->getTable('catalogrule/rule_product_price'), '*')
            ->where('rule_date=?', $this->formatDate($date, false))
            ->where('website_id=?', $wId)
            ->where('product_id=?', $pId);
        return $read->fetchAll($select);
    }

removeCatalogPricesForDateRange	(	$	fromDate,
		$	toDate,
		$	productId = null
	)

Remove catalog rules product prices for specified date range and product

Parameters:

	int|string	$fromDate
	int|string	$toDate
	int|null	$productId

Returns:

Mage_CatalogRule_Model_Mysql4_Rule

Add information about affected products It can be used in processes which related with product price (like catalog index)

Definition at line 180 of file Rule.php.

    {
        $write = $this->_getWriteAdapter();
        $conds = array();
        $cond = $write->quoteInto('rule_date between ?', $this->formatDate($fromDate));
        $cond = $write->quoteInto($cond.' and ?', $this->formatDate($toDate));
        $conds[] = $cond;
        if (!is_null($productId)) {
            $conds[] = $write->quoteInto('product_id=?', $productId);
        }

        /**
         * Add information about affected products
         * It can be used in processes which related with product price (like catalog index)
         */
        $select = $this->_getWriteAdapter()->select()
            ->from($this->getTable('catalogrule/rule_product_price'), 'product_id')
            ->where(implode(' AND ', $conds));
        $insertQuery = 'REPLACE INTO ' . $this->getTable('catalogrule/affected_product') . ' (product_id)' . $select->__toString();
        $this->_getWriteAdapter()->query($insertQuery);
        $write->delete($this->getTable('catalogrule/rule_product_price'), $conds);
        return $this;
    }

updateRuleProductData

(

Mage_CatalogRule_Model_Rule $

rule

)

Update products which are matched for rule

Parameters:

Mage_CatalogRule_Model_Rule

$rule

Returns:

Mage_CatalogRule_Model_Mysql4_Rule

Definition at line 77 of file Rule.php.

    {
        $ruleId = $rule->getId();
        $write = $this->_getWriteAdapter();
        $write->beginTransaction();

        $write->delete($this->getTable('catalogrule/rule_product'), $write->quoteInto('rule_id=?', $ruleId));

        if (!$rule->getIsActive()) {
            $write->commit();
            return $this;
        }

        $websiteIds = explode(',', $rule->getWebsiteIds());
        if (empty($websiteIds)) {
            return $this;
        }

        $productIds = $rule->getMatchingProductIds();
        $customerGroupIds = $rule->getCustomerGroupIds();

        $fromTime = strtotime($rule->getFromDate());
        $toTime = strtotime($rule->getToDate());
        $toTime = $toTime ? ($toTime + self::SECONDS_IN_DAY - 1) : 0;

        $sortOrder = (int)$rule->getSortOrder();
        $actionOperator = $rule->getSimpleAction();
        $actionAmount = $rule->getDiscountAmount();
        $actionStop = $rule->getStopRulesProcessing();

        $rows = array();
        $header = 'replace into '.$this->getTable('catalogrule/rule_product').' (
                rule_id,
                from_time,
                to_time,
                website_id,
                customer_group_id,
                product_id,
                action_operator,
                action_amount,
                action_stop,
                sort_order
            ) values ';

        try {
            foreach ($productIds as $productId) {
                foreach ($websiteIds as $websiteId) {
                    foreach ($customerGroupIds as $customerGroupId) {
                        $rows[] = "(
                            '$ruleId',
                            '$fromTime',
                            '$toTime',
                            '$websiteId',
                            '$customerGroupId',
                            '$productId',
                            '$actionOperator',
                            '$actionAmount',
                            '$actionStop',
                            '$sortOrder')";
                        if (sizeof($rows)==100) {
                            $sql = $header.join(',', $rows);
                            $write->query($sql);
                            $rows = array();
                        }
                    }
                }
            }
            if (!empty($rows)) {
                $sql = $header.join(',', $rows);
                $write->query($sql);
            }

            $write->commit();
        } catch (Exception $e) {
            $write->rollback();
            throw $e;
        }

        return $this;
    }

---

Member Data Documentation

const SECONDS_IN_DAY = 86400

Definition at line 32 of file Rule.php.

---

The documentation for this class was generated from the following file:

• app/code/core/Mage/CatalogRule/Model/Mysql4/Rule.php