README

这是一个与框架无关的定时任务调度器，可以轻松集成到您的项目中，也可以作为一个独立的命令调度器运行。最初的想法灵感来源于 Laravel Task Scheduling。

通过Composer安装

推荐的方式是通过 Composer 安装 php-cron-scheduler。有关如何下载和安装Composer的说明，请参阅入门指南。

下载/安装Composer后，运行

php composer.phar require peppeocchi/php-cron-scheduler

或将包添加到您的 composer.json

{
    "require": {
        "peppeocchi/php-cron-scheduler": "4.*"
    }
}

Scheduler V4需要php >= 7.3，对于7.3及以下且大于7.1的php版本，请使用v3分支，对于7.1及以下的php版本，请使用v2分支。

工作原理

在项目的根目录中创建一个 scheduler.php 文件，内容如下。

<?php require_once __DIR__.'/vendor/autoload.php';

use GO\Scheduler;

// Create a new scheduler
$scheduler = new Scheduler();

// ... configure the scheduled jobs (see below) ...

// Let the scheduler execute jobs which are due.
$scheduler->run();

然后向您的crontab添加一个新的条目，每分钟运行 scheduler.php。

* * * * * path/to/phpbin path/to/scheduler.php 1>> /dev/null 2>&1

就是这样！您的调度器已经启动并运行，现在您可以添加任务而无需再担心crontab了。

安排任务

默认情况下，所有任务都将尝试在后台运行。PHP脚本和原始命令默认将在后台运行，而函数总是将在前台运行。您可以通过调用 inForeground() 方法强制命令在前台运行。 需要将输出发送到电子邮件的任务将运行在前台。

安排一个PHP脚本

$scheduler->php('path/to/my/script.php');

php 方法接受4个参数

您的PHP脚本路径
要使用的PHP二进制文件
传递给脚本的自定义参数（注意：您需要在您的php.ini中启用 register_argc_argv 才能使用此功能（参考）。不用担心，它默认启用，除非您故意禁用它或您的托管商默认禁用它，您可以忽略它。）
标识符

$scheduler->php(
    'path/to/my/script.php', // The script to execute
    'path/to/my/custom/bin/php', // The PHP bin
    [
        '-c' => 'ignore',
        '--merge' => null,
    ],
    'myCustomIdentifier'
);

安排一个原始命令

$scheduler->raw('ps aux | grep httpd');

raw 方法接受3个参数

您的命令
传递给命令的自定义参数
标识符

$scheduler->raw(
    'mycommand | myOtherCommand',
    [
        '-v' => '6',
        '--silent' => null,
    ],
    'myCustomIdentifier'
);

安排一个函数

$scheduler->call(function () {
    return true;
});

call 方法接受3个参数

您的函数
传递给函数的自定义参数
标识符

$scheduler->call(
    function ($args) {
        return $args['user'];
    },
    [
        ['user' => $user],
    ],
    'myCustomIdentifier'
);

您传递到数组中的所有参数都将注入到您的函数中。例如

$scheduler->call(
    function ($firstName, $lastName) {
        return implode(' ', [$firstName, $lastName]);
    },
    [
        'John',
        'last_name' => 'Doe', // The keys are being ignored
    ],
    'myCustomIdentifier'
);

如果您想传递一个键=>值对，请将一个数组作为参数传递到参数数组中

$scheduler->call(
    function ($user, $role) {
        return implode(' ', [$user['first_name'], $user['last_name']]) . " has role: '{$role}'";
    },
    [
        [
            'first_name' => 'John',
            'last_name' => 'Doe',
        ],
        'Admin'
    ],
    'myCustomIdentifier'
);

安排执行时间

有几个方法可以帮助您设置安排的执行时间。如果您没有调用任何这些方法，任务将每分钟运行一次 (* * * * *)。

at - 此方法接受由 dragonmantank/cron-expression 支持的任何表达式
```
$scheduler->php('script.php')->at('* * * * *');
```
everyMinute - 每分钟运行一次。你可以选择传递一个 $minute 来指定作业每 $minute 分钟运行一次。
```
$scheduler->php('script.php')->everyMinute();
$scheduler->php('script.php')->everyMinute(5);
```
hourly - 每小时运行一次。你可以选择传递想要运行的 $minute，默认情况下它将在每小时的 '00' 分钟运行。
```
$scheduler->php('script.php')->hourly();
$scheduler->php('script.php')->hourly(53);
```

daily - 每天运行一次。你可以选择传递 $hour 和 $minute 以获得更细致的控制（或字符串 hour:minute）

$scheduler->php('script.php')->daily();
$scheduler->php('script.php')->daily(22, 03);
$scheduler->php('script.php')->daily('22:03');

还有针对工作日的额外辅助器（所有这些都接受可选的 hour 和 minute 参数，默认为 00:00）

星期日
星期一
星期二
星期三
星期四
星期五
星期六

$scheduler->php('script.php')->saturday();
$scheduler->php('script.php')->friday(18);
$scheduler->php('script.php')->sunday(12, 30);

还有针对月份的额外辅助器（所有这些都接受可选的 day、hour 和 minute 参数，默认为每月的 1 日 00:00）

一月
二月
三月
四月
五月
六月
七月
八月
九月
十月
十一月
十二月

$scheduler->php('script.php')->january();
$scheduler->php('script.php')->december(25);
$scheduler->php('script.php')->august(15, 20, 30);

你也可以指定一个运行作业的 date。日期可以指定为字符串或 DateTime 实例。在两种情况下，你都可以只指定日期（例如，2018-01-01）或同时指定时间（例如，2018-01-01 10:30），如果你不指定时间，它将在该日期的 00:00 运行。如果你提供一个“非标准”格式的日期，强烈建议传递一个 DateTime 实例。如果你使用 createFromFormat 没有指定时间，并且你想将其默认为 00:00，只需确保在日期格式中添加一个 !，否则时间将是当前时间。了解更多

$scheduler->php('script.php')->date('2018-01-01 12:20');
$scheduler->php('script.php')->date(new DateTime('2018-01-01'));
$scheduler->php('script.php')->date(DateTime::createFromFormat('!d/m Y', '01/01 2018'));

将输出发送到文件

你可以定义一个或多个文件，其中你想将脚本/命令/函数执行的结果发送到。

$scheduler->php('script.php')->output([
    'my_file1.log', 'my_file2.log'
]);

// The scheduler catches both stdout and function return and send
// those values to the output file
$scheduler->call(function () {
    echo "Hello";

    return " world!";
})->output('my_file.log');

将输出发送到电子邮件

你可以定义一个或多个电子邮件地址，其中你想将脚本/命令/函数执行的结果发送到。为了发送电子邮件，作业的输出首先需要发送到一个文件。实际上，文件将附加到你的电子邮件地址。为了使这正常工作，你需要安装 swiftmailer/swiftmailer

$scheduler->php('script.php')->output([
    // If you specify multiple files, both will be attached to the email
    'my_file1.log', 'my_file2.log'
])->email([
    '[email protected]' => 'My custom name',
    '[email protected]'
]);

你可以选择性地使用自定义的 Swift_Transport 来自定义 Swift_Mailer 实例。你可以配置

subject - 发送电子邮件的主题
from - 设置为发送者的电子邮件地址
body - 电子邮件正文
transport - 要使用的传输。例如，如果你想使用你的 Gmail 账户或任何其他 SMTP 账户。该值应该是一个 Swift_Transport 实例
ignore_empty_output - 如果设置为 true，则没有输出的作业不会触发任何电子邮件。

可以在创建调度器时为所有调度器命令“全局”设置配置。

$scheduler = new Scheduler([
    'email' => [
        'subject' => 'Visitors count',
        'from' => '[email protected]',
        'body' => 'This is the daily visitors count',
        'transport' => Swift_SmtpTransport::newInstance('smtp.gmail.com', 465, 'ssl')
            ->setUsername('username')
            ->setPassword('password'),
        'ignore_empty_output' => false,
    ]
]);

或者可以按作业逐个设置。

$scheduler = new Scheduler();

$scheduler->php('myscript.php')->configure([
    'email' => [
        'subject' => 'Visitors count',
    ]
]);

$scheduler->php('my_other_script.php')->configure([
    'email' => [
        'subject' => 'Page views count',
    ]
]);

安排条件执行

有时你可能希望执行计划不仅是在执行到期时，而且也取决于某些其他条件。

你可以通过方法 when 将 cron 作业的执行委托给一个真值测试。

$scheduler->php('script.php')->when(function () {
    // The job will run (if due) only when
    // this function returns true
    return true;
});

安排执行顺序

即将运行的作业将根据它们的执行进行排序：可以在后台运行的作业将首先执行。

安排重叠

为了防止在上一轮执行仍在进行时执行计划，请使用方法 onlyOne。为了避免重叠，调度器需要创建 锁文件。默认情况下，它将使用用于临时文件的目录路径。

您可以在创建新的调度器实例时全局指定自定义目录路径。

$scheduler = new Scheduler([
    'tempDir' => 'path/to/my/tmp/dir'
]);

$scheduler->php('script.php')->onlyOne();

或者您也可以按作业定义目录路径。

$scheduler = new Scheduler();

// This will use the default directory path
$scheduler->php('script.php')->onlyOne();

$scheduler->php('script.php')->onlyOne('path/to/my/tmp/dir');
$scheduler->php('other_script.php')->onlyOne('path/to/my/other/tmp/dir');

在某些情况下，您可能希望在作业重叠的情况下运行作业。例如，如果上一次执行超过5分钟前。您可以传递一个函数作为第二个参数，将注入最后执行时间。作业将不会运行，直到这个函数返回false。如果它返回true，则作业将重叠时运行。

$scheduler->php('script.php')->onlyOne(null, function ($lastExecutionTime) {
    return (time() - $lastExecutionTime) > (60 * 5);
});

作业执行前

在某些情况下，您可能希望在作业执行前运行一些代码，如果作业即将运行。例如，您可能想添加一个日志条目，ping一个URL或任何其他操作。为此，您可以像下面示例那样调用before。

// $logger here is your own implementation
$scheduler->php('script.php')->before(function () use ($logger) {
    $logger->info("script.php started at " . time());
});

作业执行后

有时您可能希望在作业运行后执行某些操作。`then`方法提供您在作业执行后执行任何操作的灵活性。作业的输出将被注入到这个函数中。例如，您可能想将条目添加到日志中，ping一个URL等... 默认情况下，作业将强制在前台运行（因为输出被注入到函数中），如果您不需要输出，您可以传递第二个参数为true以允许在后台执行（在这种情况下，`$output`将为空）。

// $logger and $messenger here are your own implementation
$scheduler->php('script.php')->then(function ($output) use ($logger, $messenger) {
    $logger->info($output);

    $messenger->ping('myurl.com', $output);
});

$scheduler->php('script.php')->then(function ($output) use ($logger) {
    $logger->info('Job executed!');
}, true);

一起使用"before"和"then"

// $logger here is your own implementation
$scheduler->php('script.php')
    ->before(function () use ($logger) {
        $logger->info("script.php started at " . time());
    })
    ->then(function ($output) use ($logger) {
        $logger->info("script.php completed at " . time(), [
            'output' => $output,
        ]);
    });

多次调度运行

在某些情况下，您可能需要在同一脚本中多次运行调度器。尽管这不是一个常见的用例，以下方法将允许您重复使用相同的调度器实例。

# some code
$scheduler->run();
# ...

// Reset the scheduler after a previous run
$scheduler->resetRun()
          ->run(); // now we can run it again

如果您在每次运行时都要重复使用相同的调度器实例，并使用不同的作业（例如，来自外部源 - 数据库、文件等），则还有一个很有用的方法，即清除当前计划中的作业。

$scheduler->clearJobs();

$jobsFromDb = $db->query(/*...*/);
foreach ($jobsFromDb as $job) {
    $scheduler->php($job->script)->at($job->schedule);
}

$scheduler->resetRun()
          ->run();

模拟调度器运行时间

在运行调度器时，您可能需要传递一个DateTime来模拟调度器运行时间。此功能的原因描述如下：此处;

// ...
$fakeRunTime = new DateTime('2017-09-13 00:00:00');
$scheduler->run($fakeRunTime);

作业失败

如果某些作业失败，您可以访问失败作业和失败原因的列表。

// get all failed jobs and select first
$failedJob = $scheduler->getFailedJobs()[0];

// exception that occurred during job
$exception = $failedJob->getException();

// job that failed
$job = $failedJob->getJob();

工作者

您可以通过启动一个工作者来模拟cron作业。让我们看看一个简单的例子

$scheduler = new Scheduler();
$scheduler->php('some/script.php');
$scheduler->work();

上面的代码启动了一个工作者，该工作者将每分钟运行您的作业。这是一个测试/调试工具，但您可以随意使用它。您可以可选地传递一个表示您希望工作者运行作业的“秒”的数组，例如通过传递`[0, 30]`，工作者将在分钟的0秒和30秒运行您的作业。

$scheduler->work([0, 10, 25, 50, 55]);

强烈建议您将工作者与调度器分开运行，尽管您可以在调度器中运行工作者。问题在于您的调度器有一个或多个同步作业，并且工作者将不得不等待您的作业完成才能继续循环。例如

$scheduler->call(function () {
    sleep(120);
});
$scheduler->work();

上面的代码将跳过多次执行，所以它不会每分钟运行一次，但可能会每2或3分钟运行一次。相反，首选的方法是将工作者与您的调度器分开。

// File scheduler.php
$scheduler = new Scheduler();
$scheduler->call(function () {
    sleep(120);
});
$scheduler->run();

// File worker.php
$scheduler = new Scheduler();
$scheduler->php('scheduler.php');
$scheduler->work();

然后在命令行中运行php worker.php。这将启动一个前台进程，您可以通过简单地退出命令来终止它。

工作者不打算收集有关您的运行的任何数据，并且如前所述，它是一个测试/调试工具。

许可证

MIT许可证（MIT）

peppeocchi / php-cron-scheduler

维护者

详细信息