File Metadata

Created: Sun, Aug 3, 5:00 AM

email_queue_eh.php
View Options

	<?php
	/**
	* @version $Id: email_queue_eh.php 16252 2015-09-27 06:34:45Z alex $
	* @package In-Portal
	* @copyright Copyright (C) 1997 - 2013 Intechnic. All rights reserved.
	* @license GNU/GPL
	* In-Portal is Open Source software.
	* This means that this software may have been modified pursuant
	* the GNU General Public License, and as distributed it includes
	* or is derivative of works licensed under the GNU General Public License
	* or other free or open source software licenses.
	* See http://www.in-portal.org/license for copyright notices and details.
	*/

	defined('FULL_PATH') or die('restricted access!');

	class EmailQueueEventHandler extends kDBEventHandler {

	/**
	* Allows to override standard permission mapping
	*
	* @return void
	* @access protected
	* @see kEventHandler::$permMapping
	*/
	protected function mapPermissions()
	{
	parent::mapPermissions();

	$permissions = Array (
	'OnProcessAjax' => Array ('self' => 'view'),
	'OnProcess' => Array ('self' => true),
	);

	$this->permMapping = array_merge($this->permMapping, $permissions);
	}

	/**
	* Process emails from queue
	*
	* @param kEvent $event
	* @return void
	* @access protected
	*/
	protected function OnProcessAjax(kEvent $event)
	{
	$mailing_list_helper = $this->Application->recallObject('MailingListHelper');
	/* @var $mailing_list_helper MailingListHelper */

	$emails_sent = 0;
	$email_queue_progress = $this->Application->RecallVar('email_queue_progress');

	if ( $email_queue_progress === false ) {
	$total_emails = $mailing_list_helper->getMessages(true);

	$this->Application->StoreVar('email_queue_progress', $emails_sent . ':' . $total_emails);
	}
	else {
	list ($emails_sent, $total_emails) = explode(':', $email_queue_progress);
	}

	$message_count = $mailing_list_helper->processQueue();

	if ( !$message_count ) {
	// no messages left to send in queue
	$this->Application->RemoveVar('email_queue_progress');
	$this->Application->Redirect($this->Application->GetVar('finish_template'));

	return;
	}

	$emails_sent += $message_count;

	if ( $emails_sent >= $total_emails ) {
	$this->Application->RemoveVar('email_queue_progress');
	$this->Application->Redirect($this->Application->GetVar('finish_template'));
	}

	$this->Application->StoreVar('email_queue_progress', $emails_sent . ':' . $total_emails);
	$event->status = kEvent::erSTOP;

	echo ($emails_sent / $total_emails) * 100;
	}

	/**
	* [SCHEDULED TASK] Process email queue from cron
	*
	* @param kEvent $event
	*
	* @return void
	*/
	protected function OnProcess(kEvent $event)
	{
	$mailing_list_helper = $this->Application->recallObject('MailingListHelper');
	/* @var $mailing_list_helper MailingListHelper */

	$mailing_list_helper->processQueue();
	}
	}

email_queue_eh.php
No OneTemporary
Actions

File Metadata

email_queue_eh.php
View Options

Event Timeline

email_queue_eh.phpNo OneTemporaryActions

File Metadata

email_queue_eh.phpView Options

Event Timeline

email_queue_eh.php
No OneTemporary
Actions

email_queue_eh.php
View Options