Laravel作业批处理表与用户模型的关系？

Question

我使用的是Laravel作业批处理功能，我有一个仪表板，可以显示批处理的进度（已处理、失败、挂起的作业…等等）。

每个用户都有自己的仪表板，我想根据登录用户显示Batch的进度，但我看不到与批处理表job_batches的用户模型有任何关系。

是否有可能以某种方式与这些表建立关系？还有其他选择吗？

谢谢

Answer 1

这是可能的，但还有很多困难需要克服。这也可能是一个关于扩展Laravel功能的通用方法的问题。

一些快速的假设是，您在创建批处理时使用某种身份验证，因此您可以执行Auth::user（）-

使用迁移为job\u batches表创建user\u id。

    Schema::table('job_batches', function (Blueprint $table) {
        $table->unsignedBigInteger('user_id')->after('name')->nullable();
        $table->foreign('user_id')->references('id')->on('users');
    });

Laravel使用批存储库在job\u Batches表中创建批，对其进行扩展并添加逻辑以将用户插入行中。我已将自定义存储库添加到App\Repositories名称空间。通常使用当前逻辑，并在执行核心Laravel逻辑后更新用户id。

<?php

namespace App\Repostories;

use Illuminate\Bus\DatabaseBatchRepository;
use Illuminate\Bus\PendingBatch;
use Illuminate\Support\Facades\Auth;

class BatchRepository extends DatabaseBatchRepository
{
    public function store(PendingBatch $batch)
    {
        $batch = parent::store($batch); // TODO: Change the autogenerated stub

        $this->connection->table($this->table)
            ->where('id', $batch->id)->update([
                'user_id' => Auth::user()->id,
            ]);

        return $batch;
    }
}

要使用新的类，需要扩展容器中的当前类。第三个参数是表名，假设您使用的是默认表。这是在提供程序中完成的。要么把它放在现有的提供程序中，要么创建一个新的提供程序，记得注册它。

use Illuminate\Bus\BatchFactory;
use Illuminate\Bus\BatchRepository;
use Illuminate\Database\Connection;
use App\Repostories\BatchRepository as CustomBatchRepository;

...

public function register()
{
    $this->app->extend(BatchRepository::class, function () {
        return new CustomBatchRepository(resolve(BatchFactory::class), resolve(Connection::class), 'job_batches');
    });
}

使用以下代码段进行测试，这将向表行添加用户id。

Bus::batch([new TestJob(), new TestJob()])->dispatch();

这种关系

BatchRepository返回不是雄辩模型的Batch。因此，我建议为关系目的创建您自己的雄辩模型，并在您想要拥有批处理功能时将其转换为批处理功能（例如。

首先，为您的批处理建立雄辩的模型。php。同时还要准备toBatch（）功能，将雄辩的模型转换为批处理类。

namespace App;

use Illuminate\Bus\BatchRepository;
use Illuminate\Database\Eloquent\Factories\HasFactory;
use Illuminate\Database\Eloquent\Model;

class Batch extends Model
{
    use HasFactory;

    protected $table = 'job_batches';

    public function toBatch()
    {
        return resolve(BatchRepository::class)->toBatch($this);
    }
}

在用户上创建关系方法。php。

public function batches()
{
    return $this->hasMany(Batch::class);
}

我用下面的代码片段测试了关系设置，它很有效。

User::first()->batches->first()->toBatch();

其次，假设有多个批处理，您将能够轻松获得具有高阶函数的批处理类。或者把它们作为一种适当的关系。

User::first()->batches->map->toBatch();

注意事项

小心导入正确的Batch和BatchRepository类。我添加了导入，以确保您包括正确的导入，以及提供程序的以下代码段，使您能够实例化我的自定义批处理存储库。

use App\Repostories\BatchRepository as CustomBatchRepository;

$this->app->bind(CustomBatchRepository::class, function () {
    return new CustomBatchRepository(resolve(BatchFactory::class), resolve(Connection::class), 'job_batches');
});

您可以自行承担风险，在为这个问题创建的粗略测试场中看到我的解决方案。用户上存在控制器和关系。不确定其他StackoverFlow项目是否有剩余。

Answer 2

只有当作业在本地执行时，我才修改此选项：

$this->connection->table($this->table)
        ->where('id', $batch->id)->update([
            'user_id' => Auth::user()->id ?? null,
        ]);