Directory:~$ /home/lmsyaran/public_html/joomla5/administrator/components/com_fabrik/controllers/

Upload File

[Home] [System Details] [Kill Me]

<?php
/**
 * Cron list controller class.
 *
 * @package     Joomla.Administrator
 * @subpackage  Fabrik
 * @copyright   Copyright (C) 2005-2020  Media A-Team, Inc. - All rights
reserved.
 * @license     GNU/GPL http://www.gnu.org/copyleft/gpl.html
 * @since       3.0
 */

// No direct access
defined('_JEXEC') or die('Restricted access');

use Joomla\CMS\Factory;
use Joomla\Utilities\ArrayHelper;

require_once 'fabcontrolleradmin.php';

/**
 * Cron list controller class.
 *
 * @package     Joomla.Administrator
 * @subpackage  Fabrik
 * @since       3.0
 */
class FabrikAdminControllerCrons extends FabControllerAdmin
{
	/**
	 * The prefix to use with controller messages.
	 *
	 * @var	string
	 */
	protected $text_prefix = 'COM_FABRIK_CRONS';

	/**
	 * View item name
	 *
	 * @var string
	 */
	protected $view_item = 'crons';

	protected $runningId = null;

	/**
	 * Proxy for getModel.
	 *
	 * @param   string  $name    model name
	 * @param   string  $prefix  model prefix
	 * @param   array   $config  Configuration array for model. Optional.
	 *
	 * @return  J model
	 */
	public function getModel($name = 'Cron', $prefix =
'FabrikAdminModel', $config = array())
	{
		$model = parent::getModel($name, $prefix,
array('ignore_request' => true));

		return $model;
	}

	public function shutdownHandler()
	{
		$id = $this->runningId;
		if (@is_array($e = @error_get_last())) {
			$code = isset($e['type']) ? $e['type'] : 0;
			$msg = isset($e['message']) ? $e['message'] :
'';
			$file = isset($e['file']) ? $e['file'] :
'';
			$line = isset($e['line']) ? $e['line'] :
'';
			if ($code>0) {
				$this->log->message = "$code,$msg,$file,$line";
				$this->log->store();
			}
		}
	}


	/**
	 * Run the selected cron plugins
	 *
	 * @return  void
	 */
	public function run()
	{
		$mailer = Factory::getMailer();
		$config = Factory::getApplication()->getConfig();
		$db = FabrikWorker::getDbo(true);
		$app = Factory::getApplication();
		$input = $app->input;
		$cid = $input->get('cid', array(), 'array');
		$cid = ArrayHelper::toInteger($cid);
		$cid = implode(',', $cid);
		$query = $db->getQuery(true);
		$query->select('*')->from('#__fabrik_cron')->where('id
IN (' . $cid . ')');
		$db->setQuery($query);
		$rows = $db->loadObjectList();
		$adminListModel =
Factory::getApplication()->bootComponent('com_fabrik')->getMVCFactory()->createModel('List',
'FabrikAdminModel');
		$pluginManager =
Factory::getApplication()->bootComponent('com_fabrik')->getMVCFactory()->createModel('Pluginmanager',
'FabrikFEModel');
		$listModel =
Factory::getApplication()->bootComponent('com_fabrik')->getMVCFactory()->createModel('List',
'FabrikFEModel');
		$c = 0;
		$this->log = FabTable::getInstance('Log',
'FabrikTable');

		register_shutdown_function(array($this, 'shutdownHandler'));

		foreach ($rows as $row)
		{
			// Load in the plugin
			$rowParams = json_decode($row->params);
			$this->log->message = '';
			$this->log->id = null;
			$this->log->referring_url = '';
			$this->log->message_type = 'plg.cron.' .
$row->plugin;
			$plugin = $pluginManager->getPlugIn($row->plugin,
'cron');
			$table = FabTable::getInstance('cron',
'FabrikTable');
			$table->load($row->id);
			$plugin->setRow($table);
			$pluginParams = $plugin->getParams();
			$thisListModel = clone ($listModel);
			$thisAdminListModel = clone ($adminListModel);
			$tid = (int) $rowParams->table;

			if ($tid !== 0)
			{
				$thisListModel->setId($tid);
				$this->log->message .= "\n\n$row->plugin\n listid =
" . $thisListModel->getId();

				if ($plugin->requiresTableData())
				{
					$cron_row_limit =
(int)$pluginParams->get('cron_row_limit', 100);
					$thisListModel->setLimits(0, $cron_row_limit);
					$thisListModel->getPagination(0, 0, $cron_row_limit);
					$data = $thisListModel->getData();
				}
			}
			else
			{
				$data = array();
			}

			$this->runningId = $row->id;
			// $$$ hugh - added table model param, in case plugin wants to do
further table processing
			$c = $c + $plugin->process($data, $thisListModel,
$thisAdminListModel);

			$this->log->message = $plugin->getLog() . "\n\n" .
$this->log->message;

			if ($plugin->getParams()->get('log', 0) == 1)
			{
				$this->log->store();
			}

			// Email log message
			$recipient = $plugin->getParams()->get('log_email',
'');

			if ($recipient != '')
			{
				$recipient = explode(',', $recipient);
				$subject = $config->get('sitename') . ': ' .
$row->plugin . ' scheduled task';
				$mailer->sendMail($config->get('mailfrom'),
$config->get('fromname'), $recipient, $subject,
$this->log->message, true);
			}

			if ($pluginParams->get('cron_reschedule_manual',
'0') === '1')
			{
				$table->lastrun = Factory::getDate()->toSql();
				$table->store();
			}
		}

		$this->setRedirect('index.php?option=com_fabrik&view=crons',
$c . ' records updated');
	}
}