Laravel 5.5：如何获取失败任务ID并关联至相关对象？

要实现将failed_jobs表中的失败任务关联到对应的MyEmail对象，我们可以通过两种方式来处理，推荐优先选择第一种（存储关联ID），因为它更高效且符合数据库设计规范。

方法一：扩展失败任务表并监听失败事件 #

1. 修正EmailJob的构造函数 #

首先确保你的EmailJob正确持有MyEmail模型实例，SerializesModels trait会自动序列化模型的ID（而非整个对象），这样队列任务的payload中会包含模型的ID信息：

class EmailJob implements ShouldQueue {
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
    private $emailModel;

    public function __construct(MyEmail $emailModel) {
        $this->emailModel = $emailModel; // 取消注释，确保赋值
    }
    // ... 其他逻辑
}

2. 给failed_jobs表添加关联字段 #

生成迁移文件来添加my_email_id字段，用于存储关联的MyEmail记录ID：

php artisan make:migration add_my_email_id_to_failed_jobs_table --table=failed_jobs

打开生成的迁移文件，修改为以下内容：

use Illuminate\Database\Migrations\Migration;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;

class AddMyEmailIdToFailedJobsTable extends Migration
{
    public function up()
    {
        Schema::table('failed_jobs', function (Blueprint $table) {
            $table->unsignedInteger('my_email_id')->nullable()->after('payload');
            // 外键关联（可选，根据你的数据库设计需求）
            $table->foreign('my_email_id')->references('id')->on('my_emails')->onDelete('set null');
        });
    }

    public function down()
    {
        Schema::table('failed_jobs', function (Blueprint $table) {
            $table->dropForeign(['my_email_id']);
            $table->dropColumn('my_email_id');
        });
    }
}

运行迁移生效：

php artisan migrate

3. 监听队列失败事件并关联记录 #

创建一个事件监听器，当任务失败时自动将MyEmail的ID写入failed_jobs表：

首先在EventServiceProvider的$listen数组中注册JobFailed事件的监听：

protected $listen = [
    \Illuminate\Queue\Events\JobFailed::class => [
        \App\Listeners\RecordFailedJobEmail::class,
    ],
];

生成监听器：

php artisan make:listener RecordFailedJobEmail

打开生成的监听器文件，修改handle方法：

namespace App\Listeners;

use Illuminate\Queue\Events\JobFailed;
use Illuminate\Support\Facades\DB;
use App\Jobs\EmailJob;
use App\Models\MyEmail;

class RecordFailedJobEmail
{
    public function handle(JobFailed $event)
    {
        // 只处理EmailJob类型的失败任务
        if ($event->job->resolveName() !== EmailJob::class) {
            return;
        }

        // 解析队列任务的原始payload
        $payload = json_decode($event->job->getRawBody(), true);
        // 反序列化Job实例（SerializesModels会自动加载MyEmail模型）
        $jobInstance = unserialize($payload['data']['command']);

        // 验证并更新关联ID
        if (isset($jobInstance->emailModel) && $jobInstance->emailModel instanceof MyEmail) {
            DB::table('failed_jobs')
                ->where('id', $event->job->getJobId())
                ->update(['my_email_id' => $jobInstance->emailModel->id]);
        }
    }
}

这样以后，所有失败的EmailJob任务都会自动关联到对应的MyEmail记录，你可以直接通过my_email_id字段查询关联。

方法二：直接从payload解析关联（无需修改表结构） #

如果你不想修改failed_jobs表结构，可以创建一个FailedJob模型，通过解析payload来动态获取关联的MyEmail对象：

namespace App\Models;

use Illuminate\Database\Eloquent\Model;
use App\Jobs\EmailJob;
use App\Models\MyEmail;

class FailedJob extends Model
{
    protected $table = 'failed_jobs';
    public $timestamps = false; // failed_jobs表默认没有timestamps字段

    public function myEmail()
    {
        // 解析payload内容
        $payload = json_decode($this->payload, true);
        if (!isset($payload['data']['command'])) {
            return null;
        }

        // 反序列化Job实例
        $jobInstance = unserialize($payload['data']['command']);
        
        // 只处理EmailJob并返回关联的MyEmail
        if ($jobInstance instanceof EmailJob && isset($jobInstance->emailModel)) {
            return $jobInstance->emailModel;
        }

        return null;
    }
}

使用示例：

// 获取某个失败任务的关联MyEmail
$failedJob = FailedJob::find(1);
$relatedEmail = $failedJob->myEmail();

这种方法无需修改表结构，但每次调用myEmail()都需要反序列化payload，频繁使用会影响性能，适合临时查询场景。

内容的提问来源于stack exchange，提问作者kingshark