diff --git a/src/Command/DaemonCommand.php b/src/Command/DaemonCommand.php index c09921e..c7be627 100644 --- a/src/Command/DaemonCommand.php +++ b/src/Command/DaemonCommand.php @@ -49,8 +49,7 @@ class DaemonCommand extends Command if(!empty($jobsToRun)) { foreach($jobsToRun as $job) { $jobRepo->setJobRunning($job, true); - $pid = -1; - //$pid = pcntl_fork(); + $pid = pcntl_fork(); if($pid == -1) { $jobRepo->RunJob($job); $jobRepo->setJobRunning($job, false); diff --git a/src/Repository/Job.php b/src/Repository/Job.php index 9b8bf7e..998a074 100644 --- a/src/Repository/Job.php +++ b/src/Repository/Job.php @@ -105,9 +105,9 @@ class Job } while ($nextrun < time()); - $addRunSql = 'UPDATE job SET nextrun = :nextrun WHERE id = :id'; + $addRunSql = 'UPDATE job SET nextrun = :nextrun, timestamp = :timestamp WHERE id = :id'; $addRunStmt = $this->dbcon->prepare($addRunSql); - $addRunStmt->executeQuery([':id' => $job['id'], ':nextrun' => $nextrun]); + $addRunStmt->executeQuery([':id' => $job['id'], ':nextrun' => $nextrun, ':timestamp' => time()]); } public function addJob(array $values) { diff --git a/storage/database.sql b/storage/database.sql index 58c70f5..52dd5bc 100644 --- a/storage/database.sql +++ b/storage/database.sql @@ -22,5 +22,6 @@ CREATE TABLE run ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, job_id INTEGER NOT NULL, exitcode TEXT NOT NULL, - output TEXT NOT NULL + output TEXT NOT NULL, + timestamp INTEGER NOT NULL ); \ No newline at end of file