<?php
/*
+--------------------------------------------------------------------+
- | CiviCRM version 4.3 |
+ | CiviCRM version 4.5 |
+--------------------------------------------------------------------+
- | Copyright CiviCRM LLC (c) 2004-2013 |
+ | Copyright CiviCRM LLC (c) 2004-2014 |
+--------------------------------------------------------------------+
| This file is a part of CiviCRM. |
| |
* by every scheduled job (cron task) in CiviCRM.
*
* @package CRM
- * @copyright CiviCRM LLC (c) 2004-2013
+ * @copyright CiviCRM LLC (c) 2004-2014
* $Id$
*
*/
/*
* Class constructor
- *
+ *
* @param void
* @access public
- *
+ *
+ */
+ /**
+ *
*/
public function __construct() {
$config = CRM_Core_Config::singleton();
}
/*
- *
+ *
* @param void
* @access private
- *
+ *
+ */
+ /**
+ * @param bool $auth
*/
public function execute($auth = TRUE) {
/*
* Class destructor
- *
+ *
* @param void
* @access public
- *
+ *
*/
public function __destruct() {}
+ /**
+ * @param $entity
+ * @param $action
+ */
public function executeJobByAction($entity, $action) {
$job = $this->_getJob(NULL, $entity, $action);
$this->executeJob($job);
}
+ /**
+ * @param $id
+ */
public function executeJobById($id) {
$job = $this->_getJob($id);
$this->executeJob($job);
/*
* Retrieves the list of jobs from the database,
* populates class param.
- *
+ *
* @param void
* @return array ($id => CRM_Core_ScheduledJob)
* @access private
- *
+ *
+ */
+ /**
+ * @return array
*/
private function _getJobs() {
$jobs = array();
$dao = new CRM_Core_DAO_Job();
$dao->orderBy('name');
+ $dao->domain_id = CRM_Core_Config::domainID();
$dao->find();
while ($dao->fetch()) {
$temp = array();
/*
* Retrieves specific job from the database by id
* and creates ScheduledJob object.
- *
+ *
* @param void
* @access private
- *
+ *
+ */
+ /**
+ * @param null $id
+ * @param null $entity
+ * @param null $action
+ *
+ * @return CRM_Core_ScheduledJob
+ * @throws Exception
*/
private function _getJob($id = NULL, $entity = NULL, $action = NULL) {
if (is_null($id) && is_null($action)) {
return $job;
}
+ /**
+ * @param $entity
+ * @param $job
+ * @param $params
+ * @param null $source
+ */
public function setSingleRunParams($entity, $job, $params, $source = NULL) {
$this->_source = $source;
$key = strtolower($entity . '_' . $job);
$this->singleRunParams[$key] = $params;
$this->singleRunParams[$key]['version'] = 3;
}
-
+
/*
*
* @return array|null collection of permissions, null if none
* @access public
*
*/
+ /**
+ * @param $message
+ */
public function logEntry($message) {
$domainID = CRM_Core_Config::domainID();
$dao = new CRM_Core_DAO_JobLog();
$dao->save();
}
+ /**
+ * @param $apiResult
+ *
+ * @return string
+ */
private function _apiResultToMessage($apiResult) {
$status = $apiResult['is_error'] ? ts('Failure') : ts('Success');
$msg = CRM_Utils_Array::value('error_message', $apiResult, 'empty error_message!');
}
}
+/**
+ * @param $message
+ *
+ * @throws Exception
+ */
function CRM_Core_JobManager_scheduledJobFatalErrorHandler($message) {
throw new Exception("{$message['message']}: {$message['code']}");
}