Directory:~$ /proc/self/root/home/lmsyaran/public_html/joomla5/plugins/fabrik_cron/email/

Upload File

[Home] [System Details] [Kill Me]

<?php
/**
 * A cron task to email records to a give set of users
 *
 * @package     Joomla.Plugin
 * @subpackage  Fabrik.cron.email
 * @copyright   Copyright (C) 2005-2020  Media A-Team, Inc. - All rights
reserved.
 * @license     GNU/GPL http://www.gnu.org/copyleft/gpl.html
 */

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

use Joomla\CMS\MVC\Model\BaseDatabaseModel;
use Joomla\Utilities\ArrayHelper;
use Fabrik\Helpers\Php;

// Require the abstract plugin class
require_once COM_FABRIK_FRONTEND . '/models/plugin-cron.php';

/**
 * A cron task to email records to a give set of users
 *
 * @package     Joomla.Plugin
 * @subpackage  Fabrik.cron.email
 * @since       3.0
 */
class PlgFabrik_Cronemail extends PlgFabrik_Cron
{
	/**
	 * Check if the user can use the plugin
	 *
	 * @param   string $location To trigger plugin on
	 * @param   string $event    To trigger plugin on
	 *
	 * @return  bool can use or not
	 */
	public function canUse($location = null, $event = null)
	{
		return true;
	}

	/**
	 * Do the plugin action
	 *
	 * @param   array &$data data
	 * @param   object  &$listModel  List model
	 * @return  int  number of records updated
	 */
	public function process(&$data, &$listModel)
	{
		jimport('joomla.mail.helper');
		$params = $this->getParams();
		$msg    = $params->get('message');
		FabrikHelperHTML::runContentPlugins($msg, false);
		$to = explode(',', $params->get('to'));

		$w = new FabrikWorker;
		($params->get('cronemail_return', '') !=
'') ? $MailFrom = $params->get('cronemail_return') :
$MailFrom = $this->app->get('mailfrom');
		($params->get('cronemail_from', '') !=
'') ? $FromName = $params->get('cronemail_from') :
$FromName = $this->app->get('fromname');
		($params->get('cronemail_replyto', '') !=
'') ? $replyTo = $params->get('cronemail_replyto') :
$replyTo = $this->app->get('replyto');
		($params->get('cronemail_replytoname', '') !=
'') ? $replyToName =
$params->get('cronemail_replytoname') : $replyToName =
$this->app->get('replytoname');
		$subject   = $params->get('subject', 'Fabrik cron
job');
		$eval      = $params->get('cronemail-eval');
		$condition = $params->get('cronemail_condition',
'');
		$nodups    = $params->get('cronemail_no_dups',
'0') === '1';
		$testMode  = $this->isTestMode();
		$sentIds   = array();
		$failedIds   = array();
		$sentTos = array();
		$this->log = '';
		$x = 0;

		foreach ($data as $group)
		{
			if (is_array($group))
			{
				foreach ($group as $row)
				{
					$x++;
					$row = ArrayHelper::fromObject($row);

					if (!empty($condition))
					{
						$this_condition = $w->parseMessageForPlaceHolder($condition,
$row);

						FabrikWorker::clearEval();
						if (Php::Eval(['code' => $this_condition,
'vars'=>['row'=>$row]]) === false)
						{
							if ($testMode)
							{
								$this->app->enqueueMessage($x . ': Condition returned
false');
							}

							continue;
						}
					}

					foreach ($to as $thisTo)
					{
						$thisTo = trim($w->parseMessageForPlaceHolder($thisTo, $row));

						if ($nodups)
						{
							if (in_array($thisTo, $sentTos))
							{
								if ($testMode)
								{
									$this->app->enqueueMessage($x . ': Found dupe,
skipping: ' . $thisTo);
								}

								continue;
							}
							else
							{
								$sentTos[] = $thisTo;
							}
						}

						if (FabrikWorker::isEmail($thisTo))
						{
							$thisMsg = $w->parseMessageForPlaceHolder($msg, $row);

							if ($eval)
							{
								FabrikWorker::clearEval();
								$thisMsg = Php::Eval(['code' => $thisMsg,
'vars'=>['data'=>$row]]);
								FabrikWorker::logEval($thisMsg, 'Caught exception on eval of
fabrik_cron/email message: %s');
							}

							$thisSubject = $w->parseMessageForPlaceHolder($subject, $row);
							$thisReplyTo = $w->parseMessageForPlaceHolder($replyTo, $row);
							$thisReplyToName = $w->parseMessageForPlaceHolder($replyToName,
$row);

							if ($testMode)
							{
								$this->app->enqueueMessage($x . ': Would send subject:
' . $thisSubject);
								$this->app->enqueueMessage($x . ': Would send to: '
. $thisTo);
								$this->app->enqueueMessage($x . ': Would send Reply to:
' . $thisReplyTo);
								$this->app->enqueueMessage($x . ': Would send Reply to
name: ' . $thisReplyToName);
							}
							else
							{
								$res = FabrikWorker::sendMail(
									$MailFrom,
									$FromName,
									$thisTo,
									$thisSubject,
									$thisMsg,
									true,
									null,
									null,
									null,
									$thisReplyTo,
									$thisReplyToName
								);

								if (!$res)
								{
									//$this->log .= "\n failed sending to $thisTo";
									FabrikWorker::log('plg.cron.email.information',
$row['__pk_val'].' Failed sending to: ' . $thisTo);
									$failedIds[] = $row['__pk_val'];
								}
								else
								{
									//$this->log .= "\n sent to $thisTo";
									FabrikWorker::log('plg.cron.email.information',
$row['__pk_val'].' Sent to: ' . $thisTo.' Replyto:
'.$thisReplyTo);
									$sentIds[] = $row['__pk_val'];
								}
							}
						}
						else
						{
							if ($testMode)
							{
								$this->app->enqueueMessage('Not an email address: '
. $thisTo);
							}
							else
							{
								FabrikWorker::log('plg.cron.email.information', 'Not
an email address: ' . $thisTo);
								$failedIds[] = $row['__pk_val'];
							}
						}
					}
				}
			}
		}

		$sentIds = array_unique($sentIds);
		$field   = $params->get('cronemail-updatefield');

		if (!empty($sentIds) && trim($field) != '')
		{
			// Do any update found
			/** @var FabrikFEModelList $listModel */
			$listModel = BaseDatabaseModel::getInstance('list',
'FabrikFEModel');
			$listModel->setId($params->get('table'));
			$table = $listModel->getTable();
			$field = $params->get('cronemail-updatefield');
			$value = $params->get('cronemail-updatefield-value');

			if ($params->get('cronemail-updatefield-eval',
'0') == '1')
			{
				FabrikWorker::clearEval();
				$value = Php::Eval(['code' => $value,
'vars'=>['listModel'=>$listModel]]);
				FabrikWorker::logEval($value, 'Caught exception on eval of cron
email updatefield : %s');
			}

			$field    = str_replace('___', '.', $field);
			$fabrikDb = $listModel->getDb();
			$query    = $fabrikDb->getQuery(true);
			$query
				->update($table->db_table_name)
				->set($field . ' = ' . $fabrikDb->quote($value))
				->where($table->db_primary_key . ' IN (' .
implode(',', $sentIds) . ')');

			if (!$testMode)
			{
				$this->log .= "\n update query: " . (string)$query;
				$fabrikDb->setQuery($query);
				$fabrikDb->execute();
			}
			else
			{
				$this->app->enqueueMessage('Would run update query: ' .
(string)$query);
			}
		}

		//$this->log .= "\n mails sent: " . count($sentIds) . "
records";

		$field = $params->get('cronemail-update-code');

		if (trim($field) != '')
		{
			if (!$testMode)
			{
				FabrikWorker::clearEval();
				Php::Eval(['code' => $field,
'vars'=>['listModel'=>$listModel]]);
				FabrikWorker::logEval($field, 'Caught exception on eval of cron
email update code : %s');
			}
			else
			{
				$this->app->enqueueMessage('Skipping update code');
			}
		}

		return count($sentIds);
	}

	private function isTestMode()
	{
		return $this->app->isClient('administrator') &&
$this->getParams()->get('cronemail_test_mode',
'0') === '1';
	}
}