mirror of
https://github.com/FH-Complete/FHC-Core.git
synced 2026-07-25 16:44:28 +00:00
workerqueues (JQW_Controller and JobsQueueLib.php): added getJobsByTypeStatus method
This commit is contained in:
@@ -47,6 +47,19 @@ abstract class JQW_Controller extends JOB_Controller
|
|||||||
return $jobs;
|
return $jobs;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* To get all the jobs specified by the given parameters
|
||||||
|
*/
|
||||||
|
protected function getJobsByTypeStatus($type, $status)
|
||||||
|
{
|
||||||
|
$jobs = $this->jobsqueuelib->getJobsByTypeStatus($type, $status);
|
||||||
|
|
||||||
|
// If an error occurred then log it in database
|
||||||
|
if (isError($jobs)) $this->logError(getError($jobs), array($type, $status));
|
||||||
|
|
||||||
|
return $jobs;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* To get all the jobs specified by the given parameters
|
* To get all the jobs specified by the given parameters
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -56,6 +56,18 @@ class JobsQueueLib
|
|||||||
return $this->_ci->JobsQueueModel->loadWhere(array('status' => self::STATUS_NEW, 'type' => $type));
|
return $this->_ci->JobsQueueModel->loadWhere(array('status' => self::STATUS_NEW, 'type' => $type));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* To get all the jobs specified by the given parameters
|
||||||
|
*/
|
||||||
|
public function getJobsByTypeStatus($type, $status)
|
||||||
|
{
|
||||||
|
$this->_ci->JobsQueueModel->resetQuery();
|
||||||
|
|
||||||
|
$this->_ci->JobsQueueModel->addOrder('creationtime', 'DESC');
|
||||||
|
|
||||||
|
return $this->_ci->JobsQueueModel->loadWhere(array('status' => $status, 'type' => $type));
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* To get all the jobs specified by the given parameters
|
* To get all the jobs specified by the given parameters
|
||||||
*/
|
*/
|
||||||
|
|||||||
Reference in New Issue
Block a user