Mage_Log_Model_Mysql4_Visitor_Aggregator Class Reference

List of all members.

Public Member Functions
	__construct ()
	update ()
	updateOneshot ($minutes=60, $interval=300)
Protected Member Functions
	_getSummaryTypes ()
	_update ($type)
Protected Attributes
	$_visitorTable
	$_customerTable
	$_urlTable
	$_summaryTable
	$_summaryTypeTable
	$_read
	$_write

---

Detailed Description

Log visitor aggregator resource

Author:

Magento Core Team <core@magentocommerce.com>

Definition at line 33 of file Aggregator.php.

---

Constructor & Destructor Documentation

__construct

(

)

Definition at line 84 of file Aggregator.php.

    {
        $resource = Mage::getSingleton('core/resource');

        $this->_visitorTable    = $resource->getTableName('log/visitor');
        $this->_urlTable        = $resource->getTableName('log/url_table');
        $this->_customerTable   = $resource->getTableName('log/customer');
        $this->_summaryTable    = $resource->getTableName('log/summary_table');
        $this->_summaryTypeTable= $resource->getTableName('log/summary_type_table');

        $this->_read    = $resource->getConnection('log_read');
        $this->_write   = $resource->getConnection('log_write');
    }

---

Member Function Documentation

_getSummaryTypes

(

)

[protected]

Definition at line 106 of file Aggregator.php.

    {
        $types = $this->_read->fetchAll("SELECT type_id, period, period_type FROM {$this->_summaryTypeTable}");
        return $types;
    }

_update

(

$

type

)

[protected]

Definition at line 112 of file Aggregator.php.

    {
        $countSelect = $this->_read->select()
            ->from($this->_summaryTable, 'summary_id')
            ->where('type_id=?', $type['type_id'])
            ->having("('".now()."' - INTERVAL {$type['period']} {$type['period_type']}) <= MAX(add_date)");

        $summaryIds = $this->_read->fetchCol($countSelect);

        $customerSelect = $this->_read->select()
                ->from($this->_customerTable, 'visitor_id')
                ->where("? - INTERVAL {$type['period']} {$type['period_type']} <= login_at", now())
                ->where("logout_at IS NULL OR logout_at <= ? - INTERVAL {$type['period']} {$type['period_type']}", now());

        $customers = $this->_read->fetchCol($customerSelect);

        $customerCount = count($customers);

        $customers = ( $customerCount > 0 ) ? $customers : 0;

        $customersCondition = $this->_read->quoteInto('visitor_id NOT IN(?)', $customers);
        $visitorCount = $this->_read->fetchOne("SELECT COUNT(visitor_id) FROM {$this->_visitorTable} WHERE ('".now()."' - INTERVAL {$type['period']} {$type['period_type']}) <= first_visit_at OR (NOW() - INTERVAL {$type['period']} {$type['period_type']}) <= last_visit_at AND {$customersCondition}");

        if( $customerCount == 0 && $visitorCount == 0 ) {
            return;
        }

        $data = array(
                'type_id' => $type['type_id'],
                'visitor_count' => $visitorCount,
                'customer_count' => $customerCount,
                'add_date' => now()
                );


        if(count($summaryIds)==0) {
            $this->_write->insert($this->_summaryTable, $data);
        } else {
            $conditionSql = $this->_write->quoteInto('summary_id in (?)', $summaryIds);
            $this->_write->update($this->_summaryTable, $data, $conditionSql);
        }

    }

update

(

)

Definition at line 98 of file Aggregator.php.

    {
        $types = $this->_getSummaryTypes();
        foreach( $types as $type ) {
            $this->_update($type);
        }
    }

updateOneshot	(	$	minutes = 60,
		$	interval = 300
	)

Definition at line 156 of file Aggregator.php.

    {
        $last_update = $this->_read->fetchOne("SELECT UNIX_TIMESTAMP(MAX(add_date)) FROM {$this->_summaryTable} WHERE type_id IS NULL");
        $next_update = $last_update + $interval;

        if( time() >= $next_update ) {
            $stats = $this->_read->fetchAssoc("SELECT
                                            u.visit_time,
                                            v.visitor_id,
                                            c.customer_id,
                                            ROUND( (UNIX_TIMESTAMP(u.visit_time) - UNIX_TIMESTAMP(".now()." - INTERVAL {$minutes} MINUTE )) / {$interval} )  as _diff,
                                            COUNT(DISTINCT(v.visitor_id)) as visitor_count,
                                            COUNT(DISTINCT(c.customer_id)) as customer_count
                                        FROM
                                            {$this->_urlTable} u
                                        LEFT JOIN {$this->_visitorTable} v ON(v.visitor_id = u.visitor_id)
                                        LEFT JOIN {$this->_customerTable} c on(c.visitor_id = v.visitor_id)
                                        WHERE
                                            UNIX_TIMESTAMP(u.visit_time) > {$next_update}
                                        group by _diff");

            foreach( $stats as $stat ) {
                $data = array(
                    'type_id' => new Zend_Db_Expr('NULL'),
                    'visitor_count' => $stat['visitor_count'],
                    'customer_count' => $stat['customer_count'],
                    'add_date' => $stat['visit_time']
                );
                $this->_write->insert($this->_summaryTable, $data);
            }
        }

    }

---

Member Data Documentation

$_customerTable [protected]

Definition at line 47 of file Aggregator.php.

$_read [protected]

Definition at line 75 of file Aggregator.php.

$_summaryTable [protected]

Definition at line 61 of file Aggregator.php.

$_summaryTypeTable [protected]

Definition at line 68 of file Aggregator.php.

$_urlTable [protected]

Definition at line 54 of file Aggregator.php.

$_visitorTable [protected]

Definition at line 40 of file Aggregator.php.

$_write [protected]

Definition at line 82 of file Aggregator.php.

---

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

• app/code/core/Mage/Log/Model/Mysql4/Visitor/Aggregator.php