hqyt/app/Jobs/ProcessDataJob.php

<?php

namespace App\Jobs;

use App\Service\RdGenerateDeviceService;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Symfony\Component\Console\Output\OutputInterface;

class ProcessDataJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $data;
    protected $user;
    protected $type;

    // 重点 1: 设置最大尝试次数为 1，一旦失败立即进入 failed_jobs，不重试
    public $tries = 1;
    // 重点 2: 设置超时时间，防止进程死锁
    public $timeout = 360;

    public function __construct($data)
    {
        $this->data = $data;
    }

    public function handle()
    {
        $service = new RdGenerateDeviceService();
        $lockKey = $this->data['lock_key'];
        try {
            DB::transaction(function () use($service) {
                $service->doGenerate($this->data['month']);
            });
        } catch (\Exception $e) {
            // 只有这里 throw 了，任务才会进入 failed_jobs 表
            throw $e;

        } finally {
            $service->delLimitingSendRequest($lockKey);
        }
    }

    protected function echoMessage(OutputInterface $output)
    {
        //输出消息
        $output->writeln(json_encode($this->data));
    }
}