92 lines
3.3 KiB
PHP
Executable File
92 lines
3.3 KiB
PHP
Executable File
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | likeshop100%开源免费商用商城系统
|
||
// +----------------------------------------------------------------------
|
||
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
|
||
// | 开源版本可自由商用，可去除界面版权logo
|
||
// | 商业版本务必购买商业授权，以免引起法律纠纷
|
||
// | 禁止对系统程序代码以任何目的，任何形式的再发布
|
||
// | gitee下载：https://gitee.com/likeshop_gitee
|
||
// | github下载：https://github.com/likeshop-github
|
||
// | 访问官网：https://www.likeshop.cn
|
||
// | 访问社区：https://home.likeshop.cn
|
||
// | 访问手册：http://doc.likeshop.cn
|
||
// | 微信公众号：likeshop技术社区
|
||
// | likeshop团队 版权所有 拥有最终解释权
|
||
// +----------------------------------------------------------------------
|
||
// | author: likeshopTeam
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace app\common\command;
|
||
|
||
use app\common\enum\CrontabEnum;
|
||
use think\console\Command;
|
||
use think\console\Input;
|
||
use think\console\Output;
|
||
use Cron\CronExpression;
|
||
use think\facade\Console;
|
||
|
||
/**
|
||
* 定时任务
|
||
* Class Crontab
|
||
* @package app\command
|
||
*/
|
||
class Crontab extends Command
|
||
{
|
||
protected function configure()
|
||
{
|
||
$this->setName('crontab')
|
||
->setDescription('定时任务');
|
||
}
|
||
|
||
protected function execute(Input $input, Output $output)
|
||
{
|
||
$lists = \app\common\model\Crontab::where('status', CrontabEnum::START)->select()->toArray();
|
||
if(empty($lists)) {
|
||
return false;
|
||
}
|
||
foreach($lists as $item) {
|
||
$nextTime = (new CronExpression($item['expression']))
|
||
->getNextRunDate($item['last_time'])
|
||
->getTimestamp();
|
||
if($nextTime > time()) {
|
||
// 未到时间，不执行
|
||
continue;
|
||
}
|
||
// 开始执行
|
||
self::start($item);
|
||
}
|
||
}
|
||
|
||
public static function start($item)
|
||
{
|
||
// 开始执行
|
||
$startTime = microtime(true);
|
||
$error = '';
|
||
$status = CrontabEnum::START;
|
||
try {
|
||
$params = explode(' ', $item['params']);
|
||
if (is_array($params) && !empty($item['params'])) {
|
||
Console::call($item['command'], $params);
|
||
} else {
|
||
Console::call($item['command']);
|
||
}
|
||
// 清除错误信息
|
||
// \app\common\model\Crontab::where('id', $item['id'])->update(['error' => '']);
|
||
} catch(\Exception $e) {
|
||
// 记录错误信息
|
||
// \app\common\model\Crontab::where('id', $item['id'])->update(['error' => $e->getMessage(), 'status' => CrontabEnum::ERROR]);
|
||
$error = $e->getMessage();
|
||
$status = CrontabEnum::ERROR;
|
||
} finally {
|
||
$endTime = microtime(true);
|
||
// 本次执行时间
|
||
$useTime = round(($endTime - $startTime), 2);
|
||
// 最大执行时间
|
||
$maxTime = max($useTime, $item['max_time']);
|
||
// 更新最后执行时间
|
||
\app\common\model\Crontab::where('id', $item['id'])
|
||
->update(['last_time' => time(), 'time' => $useTime, 'max_time' => $maxTime,'error' => $error, 'status' => $status]);
|
||
}
|
||
}
|
||
} |