gustavonecore

/usr/local/bin/php /path/to/your/ci/root/folder/index.php jobs listen

gustavonecore

<?php

  foreach ($receivers as $receiver)
  {
    $this->model->create('jobs', [
      'name' => 'sendEmail',
      'payload' => json_encode([
        'subject' => 'My beautiful subject',
        'type' => 'html',
        'message' => 'This is an email!',

gustavonecore

CREATE TABLE `jobs` (
  `id` INT UNSIGNED NOT NULL AUTO_INCREMENT,
  `name` VARCHAR(45) NOT NULL,
  `payload` TEXT NULL COMMENT 'JSON payload',
  `response` TEXT NULL,
  `status` ENUM('running', 'queued', 'done') NOT NULL DEFAULT 'queued',
  `run_time` DOUBLE NULL,
  `created_dt` DATETIME NOT NULL,
  PRIMARY KEY (`id`));

gustavonecore

<?php

/**
 * Class to handle job execution
 */
class Jobs extends Onecore_Controller
{
	const STATUS_DONE = 'done';
	const STATUS_QUEUED = 'queued';
	const STATUS_RUNNING = 'running';