CRM/Core/JobManager.php

   1 <?php
   2 /*
   3  +--------------------------------------------------------------------+
   4  | CiviCRM version 5                                                  |
   5  +--------------------------------------------------------------------+
   6  | Copyright CiviCRM LLC (c) 2004-2018                                |
   7  +--------------------------------------------------------------------+
   8  | This file is a part of CiviCRM.                                    |
   9  |                                                                    |
  10  | CiviCRM is free software; you can copy, modify, and distribute it  |
  11  | under the terms of the GNU Affero General Public License           |
  12  | Version 3, 19 November 2007 and the CiviCRM Licensing Exception.   |
  13  |                                                                    |
  14  | CiviCRM is distributed in the hope that it will be useful, but     |
  15  | WITHOUT ANY WARRANTY; without even the implied warranty of         |
  16  | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.               |
  17  | See the GNU Affero General Public License for more details.        |
  18  |                                                                    |
  19  | You should have received a copy of the GNU Affero General Public   |
  20  | License and the CiviCRM Licensing Exception along                  |
  21  | with this program; if not, contact CiviCRM LLC                     |
  22  | at info[AT]civicrm[DOT]org. If you have questions about the        |
  23  | GNU Affero General Public License or the licensing of CiviCRM,     |
  24  | see the CiviCRM license FAQ at http://civicrm.org/licensing        |
  25  +--------------------------------------------------------------------+
  26  */
  27
  28 /**
  29  * This interface defines methods that need to be implemented
  30  * by every scheduled job (cron task) in CiviCRM.
  31  *
  32  * @package CRM
  33  * @copyright CiviCRM LLC (c) 2004-2018
  34  */
  35 class CRM_Core_JobManager {
  36
  37   /**
  38    * @var array ($id => CRM_Core_ScheduledJob)
  39    */
  40   var $jobs = NULL;
  41
  42   /**
  43    * @var CRM_Core_ScheduledJob
  44    */
  45   var $currentJob = NULL;
  46
  47   var $singleRunParams = array();
  48
  49   var $_source = NULL;
  50
  51
  52   /**
  53    * Class constructor.
  54    */
  55   public function __construct() {
  56     $config = CRM_Core_Config::singleton();
  57     $config->fatalErrorHandler = 'CRM_Core_JobManager_scheduledJobFatalErrorHandler';
  58
  59     $this->jobs = $this->_getJobs();
  60   }
  61
  62   /**
  63    * @param bool $auth
  64    */
  65   public function execute($auth = TRUE) {
  66
  67     $this->logEntry('Starting scheduled jobs execution');
  68
  69     if ($auth && !CRM_Utils_System::authenticateKey(TRUE)) {
  70       $this->logEntry('Could not authenticate the site key.');
  71     }
  72     require_once 'api/api.php';
  73
  74     // it's not asynchronous at this stage
  75     CRM_Utils_Hook::cron($this);
  76     foreach ($this->jobs as $job) {
  77       if ($job->is_active) {
  78         if ($job->needsRunning()) {
  79           $this->executeJob($job);
  80         }
  81       }
  82     }
  83     $this->logEntry('Finishing scheduled jobs execution.');
  84
  85     // Set last cron date for the status check
  86     $statusPref = array(
  87       'name' => 'checkLastCron',
  88       'check_info' => gmdate('U'),
  89     );
  90     CRM_Core_BAO_StatusPreference::create($statusPref);
  91   }
  92
  93   /**
  94    * Class destructor.
  95    */
  96   public function __destruct() {
  97   }
  98
  99   /**
 100    * @param $entity
 101    * @param $action
 102    */
 103   public function executeJobByAction($entity, $action) {
 104     $job = $this->_getJob(NULL, $entity, $action);
 105     $this->executeJob($job);
 106   }
 107
 108   /**
 109    * @param int $id
 110    */
 111   public function executeJobById($id) {
 112     $job = $this->_getJob($id);
 113     $this->executeJob($job);
 114   }
 115
 116   /**
 117    * @param CRM_Core_ScheduledJob $job
 118    */
 119   public function executeJob($job) {
 120     $this->currentJob = $job;
 121
 122     // CRM-18231 check if non-production environment.
 123     try {
 124       CRM_Core_BAO_Setting::isAPIJobAllowedToRun($job->apiParams);
 125     }
 126     catch (Exception $e) {
 127       $this->logEntry('Error while executing ' . $job->name . ': ' . $e->getMessage());
 128       $this->currentJob = FALSE;
 129       return FALSE;
 130     }
 131
 132     $this->logEntry('Starting execution of ' . $job->name);
 133     $job->saveLastRun();
 134
 135     $singleRunParamsKey = strtolower($job->api_entity . '_' . $job->api_action);
 136
 137     if (array_key_exists($singleRunParamsKey, $this->singleRunParams)) {
 138       $params = $this->singleRunParams[$singleRunParamsKey];
 139     }
 140     else {
 141       $params = $job->apiParams;
 142     }
 143
 144     try {
 145       $result = civicrm_api($job->api_entity, $job->api_action, $params);
 146     }
 147     catch (Exception$e) {
 148       $this->logEntry('Error while executing ' . $job->name . ': ' . $e->getMessage());
 149     }
 150     $this->logEntry('Finished execution of ' . $job->name . ' with result: ' . $this->_apiResultToMessage($result));
 151     $this->currentJob = FALSE;
 152
 153     //Disable outBound option after executing the job.
 154     $environment = CRM_Core_Config::environment(NULL, TRUE);
 155     if ($environment != 'Production' && !empty($job->apiParams['runInNonProductionEnvironment'])) {
 156       Civi::settings()->set('mailing_backend', array('outBound_option' => CRM_Mailing_Config::OUTBOUND_OPTION_DISABLED));
 157     }
 158   }
 159
 160   /**
 161    * Retrieves the list of jobs from the database,
 162    * populates class param.
 163    *
 164    * @return array
 165    *   ($id => CRM_Core_ScheduledJob)
 166    */
 167   private function _getJobs() {
 168     $jobs = array();
 169     $dao = new CRM_Core_DAO_Job();
 170     $dao->orderBy('name');
 171     $dao->domain_id = CRM_Core_Config::domainID();
 172     $dao->find();
 173     while ($dao->fetch()) {
 174       $temp = array();
 175       CRM_Core_DAO::storeValues($dao, $temp);
 176       $jobs[$dao->id] = new CRM_Core_ScheduledJob($temp);
 177     }
 178     return $jobs;
 179   }
 180
 181   /**
 182    * Retrieves specific job from the database by id.
 183    * and creates ScheduledJob object.
 184    *
 185    * @param int $id
 186    * @param null $entity
 187    * @param null $action
 188    *
 189    * @return CRM_Core_ScheduledJob
 190    * @throws Exception
 191    */
 192   private function _getJob($id = NULL, $entity = NULL, $action = NULL) {
 193     if (is_null($id) && is_null($action)) {
 194       CRM_Core_Error::fatal('You need to provide either id or name to use this method');
 195     }
 196     $dao = new CRM_Core_DAO_Job();
 197     $dao->id = $id;
 198     $dao->api_entity = $entity;
 199     $dao->api_action = $action;
 200     $dao->find();
 201     while ($dao->fetch()) {
 202       CRM_Core_DAO::storeValues($dao, $temp);
 203       $job = new CRM_Core_ScheduledJob($temp);
 204     }
 205     return $job;
 206   }
 207
 208   /**
 209    * @param $entity
 210    * @param $job
 211    * @param array $params
 212    * @param null $source
 213    */
 214   public function setSingleRunParams($entity, $job, $params, $source = NULL) {
 215     $this->_source = $source;
 216     $key = strtolower($entity . '_' . $job);
 217     $this->singleRunParams[$key] = $params;
 218     $this->singleRunParams[$key]['version'] = 3;
 219   }
 220
 221   /**
 222    * @param string $message
 223    */
 224   public function logEntry($message) {
 225     $domainID = CRM_Core_Config::domainID();
 226     $dao = new CRM_Core_DAO_JobLog();
 227
 228     $dao->domain_id = $domainID;
 229     $dao->description = substr($message, 0, 235);
 230     if (strlen($message) > 235) {
 231       $dao->description .= " (...)";
 232     }
 233     if ($this->currentJob) {
 234       $dao->job_id = $this->currentJob->id;
 235       $dao->name = $this->currentJob->name;
 236       $dao->command = ts("Entity:") . " " . $this->currentJob->api_entity . " " . ts("Action:") . " " . $this->currentJob->api_action;
 237       $data = "";
 238       if (!empty($this->currentJob->parameters)) {
 239         $data .= "\n\nParameters raw (from db settings): \n" . $this->currentJob->parameters;
 240       }
 241       $singleRunParamsKey = strtolower($this->currentJob->api_entity . '_' . $this->currentJob->api_action);
 242       if (array_key_exists($singleRunParamsKey, $this->singleRunParams)) {
 243         $data .= "\n\nParameters raw (" . $this->_source . "): \n" . serialize($this->singleRunParams[$singleRunParamsKey]);
 244         $data .= "\n\nParameters parsed (and passed to API method): \n" . serialize($this->singleRunParams[$singleRunParamsKey]);
 245       }
 246       else {
 247         $data .= "\n\nParameters parsed (and passed to API method): \n" . serialize($this->currentJob->apiParams);
 248       }
 249
 250       $data .= "\n\nFull message: \n" . $message;
 251
 252       $dao->data = $data;
 253     }
 254     $dao->save();
 255   }
 256
 257   /**
 258    * @param $apiResult
 259    *
 260    * @return string
 261    */
 262   private function _apiResultToMessage($apiResult) {
 263     $status = $apiResult['is_error'] ? ts('Failure') : ts('Success');
 264     $msg = CRM_Utils_Array::value('error_message', $apiResult, 'empty error_message!');
 265     $vals = CRM_Utils_Array::value('values', $apiResult, 'empty values!');
 266     if (is_array($msg)) {
 267       $msg = serialize($msg);
 268     }
 269     if (is_array($vals)) {
 270       $vals = serialize($vals);
 271     }
 272     $message = $apiResult['is_error'] ? ', Error message: ' . $msg : " (" . $vals . ")";
 273     return $status . $message;
 274   }
 275
 276 }
 277
 278 /**
 279  * @param $message
 280  *
 281  * @throws Exception
 282  */
 283 function CRM_Core_JobManager_scheduledJobFatalErrorHandler($message) {
 284   throw new Exception("{$message['message']}: {$message['code']}");
 285 }