每个管道本质上是一个处理一段逻辑的类。该类应该定义一个handle方法：

namespace App\Pipes;

class SomeServiceIntegration
{
    public function handle($user, \Closure $next)
    {
        // ur codes
        
        return $next($user);
    }
}

字符串
您可以使用Pipeline类通过定义的管道发送对象：

use Illuminate\Pipeline\Pipeline;

$integrations = $user->integrations;

if ($integrations->count()) {
    // at here., you need to get the classes (pipes) for each integration
    $pipes = $integrations->map(function ($integration) {
        return $integration->serviceClass; // i assume that you store the full class path in the 'serviceClass' attribute
    })->toArray();

    return app(Pipeline::class)
        ->send($user)
        ->through($pipes)
        ->thenReturn();
}

型
如果每个服务都有自己的设置，您可能需要添加设置：

$pipes = $integrations->map(function ($integration) {
    return app($integration->serviceClass, ['settings' => $integration->settings]);
})->toArray();

型
并调整SomeServiceIntegration类以接受设置：

namespace App\Pipes;

class SomeServiceIntegration
{
    protected $settings;

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

    public function handle($user, \Closure $next)
    {
        // u can use $this->settings here easily :○

        return $next($user);
    }
}

型