自定义命令

<?php
namespace App\Console\Commands;

use Illuminate\Support\Facades\Redis;
use App\Services\SpreadsheetService;
use Illuminate\Console\Command;

class CreateTask extends Command
{

    private $spreadsheet;

    private $limit = 200000;

    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'create:task {key?} {filename?} {worksheet?}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Create a scrapy queue task';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
        $this->spreadsheet = new SpreadsheetService($this->limit);
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        $key = $this->argument('key') ?: 'queue:task';
        $worksheet = $this->argument('worksheet') ?: '';
        $filename = storage_path($this->argument('filename') ?: 'task.xlsx');
        if (! file_exists($filename)) {
            return $this->error('file not found: ' . $filename);
        }

        $total = 0;
        $array = [];
        $extension = strtolower(pathinfo($filename, PATHINFO_EXTENSION));
        switch ($extension) {
            case 'xlsx':
            case 'xls':
                $data = $this->spreadsheet->reader($filename, $worksheet, false);
                foreach ($data as $list) {
                }
                break;
            default:
                return $this->error('格式不支持');
        }
        return $this->info('finish!');
    }
}

任务调度

添加调度器

* * * * * cd /path-to-your-project && php artisan schedule:run >> /dev/null 2>&1

这个 Cron 会每分钟执行一次 Laravel 的命令行调度器。当 schedule:run 命令被执行的时候，Laravel 会根据你的调度执行预定的程序。

定义调度

// schedule
$schedule->call(function () {
    DB::table('recent_users')->delete();
})->daily();

// 除了使用闭包来定义任务调度外，你也可以使用 invokable objects。
// Invokable objects 指的是 PHP 中含有 __invoke 方法的类。
$schedule->call(new DeleteRecentUsers)->daily();

// Artisan 命令调度（推荐）
$schedule->command('emails:send Taylor --force')->daily();

// 队列任务调度
$schedule->job(new Heartbeat)->everyFiveMinutes();

// Shell 调度
$schedule->exec('node /home/forge/script.js')->daily();

调度频率设置

小技巧

1. 避免任务重复

$schedule->command('emails:send')->withoutOverlapping();

2. 任务只运行在一台服务器上

// 你的应用默认缓存驱动必须是 memcached 或 redis 才能使用这个特性。除此之外，所有服务器必须使用同一台中央缓存服务器来通信。
$schedule->command('report:generate')->fridays()->at('17:00')->onOneServer();

3. 后台任务

// 针对有长时间运行的命令
$schedule->command('analytics:report')->daily()->runInBackground();