<?php

//
// Open Web Analytics - An Open Source Web Analytics Framework
//
// Copyright 2006 Peter Adams. All rights reserved.
//
// Licensed under GPL v2.0 http://www.gnu.org/copyleft/gpl.html
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
// $Id$
//

if(!class_exists('owa_observer')) {
	require_once(OWA_DIR.'owa_observer.php');
}	
require_once(OWA_DIR.'owa_lib.php');

/**
 * Session Commerce Summary Event handlers
 *
 * Listens for commerce.transaction event and does an idempotent update of the session's
 * commerce realted summary columns.
 * 
 * @author      Peter Adams <peter@openwebanalytics.com>
 * @copyright   Copyright &copy; 2006-2011 Peter Adams <peter@openwebanalytics.com>
 * @license     http://www.gnu.org/copyleft/gpl.html GPL v2.0
 * @category    owa
 * @package     owa
 * @version		$Revision$	      
 * @since		owa 1.4.0
 */

class owa_sessionCommerceSummaryHandlers extends owa_observer {
    	
    /**
     * Notify handler method
     *
     * @param 	object	$event
     * @access 	public
     * @return	boolean
     */
    function notify($event) {
				
    	$s = owa_coreAPI::entityFactory( 'base.session' );
		$pk = $event->get( 'session_id' );
		
		// just in case events slip thorugh that have no session_id
		// look for the original session id param
		if ( ! $pk ) {
			$pk = $event->get( 'original_session_id' );
			if ($pk) {
				$event->set('session_id', $pk);
			}
		}
		
		$s->getByPk( 'id', $pk );
		$id = $s->get('id'); 
		
		if ($id) {
			// summarze the transaction
			$summary = owa_coreAPI::summarize(array(
    			'entity'		=> 'base.commerce_transaction_fact',
    			'columns'		=> array(
    					'id' 		=> 'count',
    					'total_revenue'		=> 'sum',
    					'tax_revenue'		=> 'sum',
    					'shipping_revenue'	=> 'sum'),
    			'constraints'	=> array( 'session_id' => $id ) ) );
			
			$s->set( 'commerce_trans_count', $summary['id_count'] );
			$s->set( 'commerce_trans_revenue', $summary['total_revenue_sum'] );
			$s->set( 'commerce_tax_revenue', $summary['tax_revenue_sum'] );
			$s->set( 'commerce_shipping_revenue', $summary['shipping_revenue_sum'] );
			
			// check for items and summarize if needed.
			$items = $event->get('ct_line_items');
			
			if ( ! empty( $items ) ) {
				$summary = owa_coreAPI::summarize(array(
    			'entity'		=> 'base.commerce_line_item_fact',
    			'columns'		=> array(
    					'sku' 				=> 'count_distinct',
    					'item_revenue'		=> 'sum',
    					'quantity'			=> 'sum'),
    			'constraints'	=> array( 'session_id' => $id ) ) );
			
				$s->set( 'commerce_items_count', $summary['sku_dcount'] );
				$s->set( 'commerce_items_revenue', $summary['item_revenue_sum'] );
				$s->set( 'commerce_items_quantity', $summary['quantity_sum'] );	
			}
			
			$ret = $s->update();
			
			if ($ret) {
				return OWA_EHS_EVENT_HANDLED;	
			} else {
				return OWA_EHS_EVENT_FAILED;
			}
			
		} else {
		
			owa_coreAPI::debug('Not Updating session commerce transaction properties. Session does not exist yet.');
			return OWA_EHS_EVENT_FAILED;
		}	
    }
}

?>