129 lines
2.4 KiB
PHP
129 lines
2.4 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Scheduling;
|
|
|
|
use App\Models\Instance\Cron;
|
|
use Carbon\Carbon;
|
|
|
|
class CronEvent
|
|
{
|
|
/**
|
|
* The cron model.
|
|
*
|
|
* @var Cron
|
|
*/
|
|
private $cron;
|
|
|
|
/**
|
|
* Frequency to run the command in minutes.
|
|
*
|
|
* @var int
|
|
*/
|
|
private $minutes = 1;
|
|
|
|
/**
|
|
* Frequency to run the command in days.
|
|
*
|
|
* @var int
|
|
*/
|
|
private $days = 0;
|
|
|
|
public function __construct(Cron $cron)
|
|
{
|
|
$this->cron = $cron;
|
|
}
|
|
|
|
/**
|
|
* Get the command.
|
|
*/
|
|
public static function command(string $command): self
|
|
{
|
|
/** @var \App\Models\Instance\Cron $cron */
|
|
$cron = Cron::firstOrCreate(['command' => $command]);
|
|
|
|
return new self($cron);
|
|
}
|
|
|
|
/**
|
|
* Get current Cron.
|
|
*
|
|
* @return Cron
|
|
*/
|
|
public function cron()
|
|
{
|
|
return $this->cron;
|
|
}
|
|
|
|
/**
|
|
* Run the command once per hour.
|
|
*/
|
|
public function hourly(): self
|
|
{
|
|
$this->minutes = 60;
|
|
$this->days = 0;
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Run the command once per day.
|
|
*/
|
|
public function daily(): self
|
|
{
|
|
$this->minutes = 0;
|
|
$this->days = 1;
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Run the command once a week.
|
|
*/
|
|
public function weekly(): self
|
|
{
|
|
$this->minutes = 0;
|
|
$this->days = 7;
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Run the command every $minutes.
|
|
*/
|
|
public function minutes(int $minutes): self
|
|
{
|
|
$this->minutes = $minutes;
|
|
$this->days = 0;
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Test if the command is due to run.
|
|
*/
|
|
public function isDue(): bool
|
|
{
|
|
$now = now();
|
|
|
|
if ($this->cron->last_run_at !== null) {
|
|
$t = $this->cron->last_run_at;
|
|
|
|
if ($this->minutes !== 0) {
|
|
$nextRun = Carbon::create($t->year, $t->month, $t->day, $t->hour, (int) floor($t->minute / $this->minutes) * $this->minutes, 0)
|
|
->addMinutes($this->minutes);
|
|
} elseif ($this->days !== 0) {
|
|
$nextRun = Carbon::create($t->year, $t->month, (int) floor($t->day / $this->days) * $this->days, 0, 0, 0)
|
|
->addDays($this->days);
|
|
}
|
|
|
|
if (! isset($nextRun) || $nextRun > $now) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
$this->cron->update(['last_run_at' => $now]);
|
|
|
|
return true;
|
|
}
|
|
}
|