Файловый менеджер

Файловый менеджер - Редактировать - /home/lmsyaran/public_html/joomla5/plugins/system/fabrikcron/fabrikcron.php

Назад
<?php /** * Joomla! Fabrik cron job plugin * * @package Joomla.Plugin * @subpackage System * @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\CMS\Plugin\CMSPlugin; use Joomla\CMS\Factory; jimport('joomla.plugin.plugin'); jimport('joomla.filesystem.file'); /* * Joomla! Fabrik cron job plugin * * @package Joomla.Plugin * @subpackage System * @since 3.0 / class PlgSystemFabrikcron extends CMSPlugin { /* * Row for the currently running plugin, used by the shutdown handler * * @var stdClass / protected $row = null; /* * Log object * * @var Object / protected $log = null; /* * @var JDatabaseDriver / protected $db; /* * @var JDatabaseQuery / protected $query; /* * Plugin model * * @var PlgFabrik_Cron / protected $pluginModel = null; /* * Reschedule the plugin for next run, and republish * * * @return void / protected function reschedule() { $now = Factory::getDate(); $now = $now->toUnix(); $new = Factory::getDate($this->row->nextrun); $tmp = $new->toUnix(); switch ($this->row->unit) { case 'second': $inc = 1; break; case 'minute': $inc = 60; break; case 'hour': $inc = 60 60; break; default: case 'day': $inc = 60 * 60 * 24; break; } while ($tmp + ($inc * $this->row->frequency) < $now) { $tmp = $tmp + ($inc * $this->row->frequency); } // Mark them as being run $nextRun = Factory::getDate($tmp); $this->query->clear(); $this->query->update('#__fabrik_cron'); $this->query->set('lastrun = ' . $this->db->quote($nextRun->toSql())); if ($this->pluginModel->shouldReschedule() && $this->pluginModel->doRunGating()) { $this->query->set("published = '1'"); } if (!$this->pluginModel->shouldReschedule()) { $this->query->set("published = '0'"); $this->log->message .= "\nPlugin has unpublished itself"; } $this->query->where('id = ' . $this->row->id); $this->db->setQuery($this->query); $this->db->execute(); } /** * Catch any fatal errors and log them * Log and reschedule on fatal errors (code==1) only! / public function shutdownHandler() { 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 == 1) { $this->log->message = "$code,$msg,$file,$line"; $this->log->store(); $this->reschedule(); } } } /* * Run all active cron jobs * * @return void / protected function doCron() { $app = Factory::getApplication(); $input = $app->input; //Don't run in backend or on acymailing or falang (throws errors) if ($app->isClient('administrator') \|\| $input->get('option') == 'com_acymailing' \|\| $input->get('option') == 'com_falang') { return; } // $$$ hugh - don't want to run on things like AJAX calls if ($input->get('format', '') == 'raw') { return; } $mailer = Factory::getMailer(); $config = Factory::getApplication()->getConfig(); // Get all active tasks $this->db = FabrikWorker::getDbo(true); $this->query = $this->db->getQuery(true); $now = $input->get('fabrikcron_run', false); $this->log = FabTable::getInstance('Log', 'FabrikTable'); if (!$now) { / $$$ hugh - changed from using NOW() to Factory::getDate(), to avoid time zone issues, see: * http://fabrikar.com/forums/showthread.php?p=102245#post102245 * .. which seems reasonable, as we use getDate() to set 'lastrun' to at the end of this func / $nextRun = "CASE " . "WHEN unit = 'second' THEN DATE_ADD( lastrun, INTERVAL frequency SECOND )\n" . "WHEN unit = 'minute' THEN DATE_ADD( lastrun, INTERVAL frequency MINUTE )\n" . "WHEN unit = 'hour' THEN DATE_ADD( lastrun, INTERVAL frequency HOUR )\n" . "WHEN unit = 'day' THEN DATE_ADD( lastrun, INTERVAL frequency DAY )\n" . "WHEN unit = 'week' THEN DATE_ADD( lastrun, INTERVAL frequency WEEK )\n" . "WHEN unit = 'month' THEN DATE_ADD( lastrun, INTERVAL frequency MONTH )\n" . "WHEN unit = 'year' THEN DATE_ADD( lastrun, INTERVAL frequency YEAR ) END"; $this->query ->select("id, plugin, lastrun, unit, frequency, " . $nextRun . " AS nextrun") ->from('#__fabrik_cron') ->where("published = '1'") ->where("$nextRun < '" . Factory::getDate()->toSql() . "'"); } else { $this->query ->select('id, plugin') ->from("#__fabrik_cron WHERE published = '1'"); } $this->db->setQuery($this->query); $rows = $this->db->loadObjectList(); if (empty($rows)) { return; } // register our shutdownHandler(), so we can re-publish and reschedule the event if the script errors out register_shutdown_function(array($this, 'shutdownHandler')); $this->log->message = ''; BaseDatabaseModel::addIncludePath(JPATH_SITE . '/components/com_fabrik/models'); /* @var FabrikFEModelPluginmanager $pluginManager / $pluginManager = BaseDatabaseModel::getInstance('Pluginmanager', 'FabrikFEModel'); $listModel = BaseDatabaseModel::getInstance('list', 'FabrikFEModel'); foreach ($rows as $row) { // assign $row to $this->row, as we may need it in shutdown handling $this->row = $row; // Load in the plugin $this->pluginModel = $pluginManager->getPluginFromId($this->row->id, 'Cron'); $params = $this->pluginModel->getParams(); $this->log->message = ''; $this->log->id = null; $this->log->referring_url = ''; $this->log->message_type = 'plg.cron.' . $this->row->plugin; if (!$this->pluginModel->queryStringActivated()) { continue; } if ($this->pluginModel->doRunGating()) { $this->query->clear()->update('#__fabrik_cron')->set('published = 0')->where('id = ' . $this->db->quote($this->row->id)); $this->db->setQuery($this->query); $this->db->execute(); } $tid = (int) $params->get('table'); $thisListModel = clone ($listModel); if ($tid !== 0) { $thisListModel->setId($tid); $this->log->message .= "\n\n" . $this->row->plugin . "\n listid = " . $thisListModel->getId(); if ($this->pluginModel->requiresTableData()) { //$table = $thisListModel->getTable(); //$total = $thisListModel->getTotalRecords(); //$nav = $thisListModel->getPagination($total, 0, $total); $cron_row_limit = (int)$params->get('cron_row_limit', 100); $thisListModel->setLimits(0, $cron_row_limit); $thisListModel->getPagination(0, 0, $cron_row_limit); $data = $thisListModel->getData(); // for some reason this hoses up next query //$this->log->message .= "\n" . $thisListModel->buildQuery(); } } else { $data = array(); $this->log->message .= "\n\n" . $this->row->plugin . "\n listid is empty "; } $this->pluginModel->process($data, $thisListModel); $this->log->message = $this->pluginModel->getLog() . "\n\n" . $this->log->message; $this->reschedule(); // Log if asked for if ($params->get('log', 0) == 1) { $this->log->store(); } // Email log message $recipient = explode(',', $params->get('log_email', '')); if (!FArrayHelper::emptyish($recipient)) { $subject = $config->get('sitename') . ': ' . $this->row->plugin . ' scheduled task'; $mailer->sendMail($config->get('mailfrom'), $config->get('fromname'), $recipient, $subject, $this->log->message, true); } } } /* * Perform the actual cron after the page has rendered * * @return void */ public function onAfterRender() { // If system plugin hasn't run, just exit gracefully if (!defined('COM_FABRIK_FRONTEND')) { return; } $this->doCron(); } }

| ver. 1.4 | Github | . | PHP 8.1.33 | Генерация страницы: 0.03 | proxy | phpinfo | Настройка