问题[laravel](coding)

在我的 Laravel 项目中，我有 5 到 6 个不同的队列。每个队列都会按照严格的顺序触发下一个队列，形成如下的处理链：

工作 1 → 工作 2 → 工作 3 → 工作 4 → 工作 5

该流程始终由以 Job1 开头的外部请求触发。每个作业执行一个文件操作（创建/修改文件），这些文件存储在执行该作业的服务器本地。

当我尝试通过添加更多服务器来处理队列来实现水平扩展时，问题就出现了。由于 Laravel 队列是分布式的，因此无法保证 Job2 会由处理 Job1 的同一台服务器处理——这会中断流程，因为 Job2 需要访问 Job1 创建的本地文件。

我的需求：我想确保一旦 Job1 在特定服务器上启动，整个作业链（Job2 到 Job5）就会在同一服务器上继续运行 — — 即使在多服务器设置中也是如此。

我尝试过的方法：将“机器 ID”附加到作业有效负载 - 但这并不能保证该作业将被同一台机器接收。

在线搜索“粘性作业”或“将作业固定到同一个工作者/服务器” - 但找不到干净或官方的解决方案。

我的问题是：有人处理过类似的需求吗？在 Laravel 中，运行分布式队列系统时，有没有一种行之有效的方法可以将作业链固定到同一台服务器上？

我是 Laravel 新手。我正在尝试使用 HasTo 关系。我的数据库中有两张表。一张是产品表，另一张是类别表。我使用表单添加产品。表单中有一个选择选项部分。在此部分中，我从类别表中为产品选择一个类别。问题是，当我选择一个类别时，我想获取该类别的 ID 并将其添加到产品表中的 categoryId 列。然后，当我发布产品时，我想访问产品表中的 categoryId 部分并获取类别表中匹配的类别，但我无法成功。这是我的表单：

<form action="{{ route('product.store') }}" method="post" enctype="multipart/form-data">
  @csrf
    <div class="form-group mb-3">
      <label>Name</label>
      <input
        name="productName"
        type="text"
        class="form-control" />
    </div>
    <div class="form-group mb-3">
      <label>Description</label>
      <textarea name="productDescription" class="form-control" rows="3"></textarea>
    </div>
    <div class="form-group mb-3">
      <label>Price</label>
      <input name="productPrice" type="number" class="form-control" />
    </div>
    <div class="form-group mb-3">
      <label>Category</label>
      <input name="categoryId" type="number" class="form-control" />
      <select class="custom-select tm-select-accounts form-control" name="categoryId">
        <option>Choose a Category</option>
        @foreach($getCategory as $category)
          <option value="{{ $category->id }}">{{ $category->categoryName}}</option>
        @endforeach 
      </select>
    </div>
  </div>
  <div class="col-12">
    <button type="submit" class="btn btn-primary btn-block text-uppercase">Add Product</button>
  </div>
</form>

这是我发布产品时的表格：前3个td标签正常工作。我无法获取与categoryId匹配的categoryName，因此我直接发布了该ID。

<tbody>
  @foreach ($product as $item)
    <tr>
      <th scope="row">
        <input type="checkbox" />
      </th>
      <td class="tm-product-name">{{ $item->productName }}</td>
      <td>{{ $item->productPrice }}</td>
      <td>{{ $item->productDescription }}</td>
      <td>{{ $item->categoryId }}</td>
      <td>
        <a href="{{ route('product.edit', $item->id) }}">
          <i class="fas fa-3x fa-edit"></i>
        </a>
      </td>
      <td class="text-right">
        <form method="post" action="{{ route('product.destroy', $item->id) }}">
          @method('delete')
          @csrf
          <button type="submit" class="btn btn-danger btn-sm show_confirm" id="deletebutton">Delete Product</button>
        </form>
      </td>
    </tr>
  @endforeach
</tbody>

产品控制器：

public function index()
{
    $product = Page::all();

    return view('admin.pages.products', compact('product'));
}

/**
 * Show the form for creating a new resource.
 */
public function create()
{
    $data['getCategory'] = Category::get();

    return view('admin.pages.add_product', $data);
}

/**
 * Store a newly created resource in storage.
 */
public function store(Request $request)
{
    $request->validate([
        'productName' => ['required','string','max:255'],
        'productDescription' => ['required','string'],
        'productPrice' => ['nullable','numeric'],
        'categoryId' => ['required'],
    ]);

    $product = new Page();
    $product->productName = $request->productName;
    $product->productDescription = $request->productDescription;
    $product->productPrice = $request->productPrice;
    $product->categoryId = $request->categoryId;
    $product->save();

    return redirect()->route('admin')->with('success', 'Ürün başarıyla eklendi');
}

页面模型：

class Page extends Model
{
    protected $table = 'products';
    
    protected $fillable = [
        'productName', 
        'productDescription', 
        'productPrice',
        'productImage',
        'categoryId'
    ];

    
    public function products()
    {
        return $this->belongsTo(Category::class);
    }
}

类别型号：

class Category extends Model
{
    protected $table = 'category';
    
    protected $fillable = [
        'categoryName',
    ];

    public function productCategories()
    {
        return $this->hasMany(Page::class);
    }
}

我已经设法链接数据库中的两个表，但无法使用产品表中的类别 ID 获取类别表中的类别名称。

即使我为用户分配了单个角色，只允许他们查看一个资源，为什么他们拥有与超级管理员相同的权限？（除了管理角色）就好像我创建的每个用户都继承了角色。我已经从 Tinker 中检查过它们，它正确地指示了他们的角色和权限。但是，他们仍然拥有比分配的权限多得多的权限。

在查询生成器中连接多个表非常简单：

DB::table('projects')
->select('tasks.*')
->join('tasks', 'tasks.project_id', 'projects.id')

但现在客户要求我避免join使用：

SELECT tasks.*
FROM projects, tasks
WHERE tasks.project_id = projects.id

如何做？

使用 Builder 的方法from是个坏主意：

• from仅接受一个字符串（一个表名），而不是数组
• from杀死table并from写过

PS 请不要浪费时间描述 Eloquent 的工作原理 - 我只需要知道如何使用 Laravel Query Builder 来实现。当然，如果可以使用 LQB 来实现的话

问题

我正在构建一个应用程序，该应用程序具有 Next.js 前端和 Laravel 后端，并使用 Sanctum 进行 SPA 身份验证。当我从 Next.js 应用程序登录时，我可以看到浏览器中设置的身份验证 cookie，但后续获取用户信息的请求返回“未经身份验证”错误。注意：Postman 中的一切都正常运行。

环境

• 前端：Next.js
• 后端：带有 Sanctum 的 Laravel
• 身份验证：Laravel Sanctum SPA 身份验证
• 在 Postman 中测试时一切正常

我尝试过的方法

登录过程运行正常，我可以确认登录后浏览器中设置了 cookie。但是，当我尝试获取经过身份验证的用户信息时，出现“未授权”错误。我在 Postman 中尝试对“/api/v1/user”发出 GET 请求，成功了。

代码

我的登录功能：

const baseUrl = process.env.NEXT_PUBLIC_BASE_URL;

async function fetchCsrfCookie() {
    await fetch(`${process.env.NEXT_PUBLIC_BASE_URL}/sanctum/csrf-cookie`, {
        method: 'GET',
        credentials: 'include',
    });
}

export const fetchSignIn = async (username: string, password: string) => {
    //   1) Init Sanctum
    await fetchCsrfCookie();

    // 2) Login
    const res = await fetch(`${baseUrl}/api/v1/login`, {
        method: 'POST',
        credentials: 'include',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({ username, password, remember: true }),
    });
    if (!res.ok) {
        throw new Error('Login failed');
    }
    return res.json();
};

获取用户功能：

export const fetchAuthUser = async () => {
    try {
        const res = await fetch(`${process.env.NEXT_PUBLIC_BASE_URL}/api/v1/user`, {
            method: 'GET',
            credentials: 'include',
            headers: {
                'Content-Type': 'application/json',
            },
        });

        if (!res.ok) {
            const errorData: any = await res.json();
            console.error('Error data:', errorData);
            throw new Error(errorData.message || res.statusText);
        }

        return res.json();
    } catch (error) {
        console.error(`Failed to fetch resource:`, error);
        throw error;
    }
};

我是 laravel 的新手，我 Undefined variable $columnCounts在查看时遇到了一个错误。

我有一个 index() 方法，它调用同一个 NumberController 的另外两个方法 columnCount() 和 rowCount() 来进行少量数字计数。

这是 index() 方法：

    public function index()
{
    //

    $column1count = $this->countColumn(1);
    $column2count = $this->countColumn(2);
    $column3count = $this->countColumn(3);

    $row1count = $this->countRow(1);
    $row2count = $this->countRow(2);
    $row3count = $this->countRow(3);

    $columnCounts = [['column' => 1, 'count' => $column1count], ['column' => 2, 'count' => $column2count], ['column' => 3, 'count' => $column3count]];
    $rowCounts = [['row' => 1, 'count' => $row1count], ['row' => 2, 'count' => $row2count], ['row' => 3, 'count' => $row3count]];
    $numbers =  Number::all();
    return view('index', ['numbers' => $numbers, 'columnCounts' => $columnCounts, 'rowCounts' => $rowCounts]);
}

这是 columnCount() 方法：

    public function countColumn($column)
{
    $lastNumber = Number::all()->sortByDesc('created_at')->first();
    $lastColumn = Number::all()->where('colonna', '=', $column)->sortByDesc('created_at')->first();
    $count = $lastNumber->id - $lastColumn->id;
    return $count;
}

这是 rowCount() 方法：

    public function countRow($row)
{
    $lastNumber = Number::all()->sortByDesc('created_at')->first();
    $lastRow = Number::all()->where('riga', '=', $row)->sortByDesc('created_at')->first();
    $count = $lastNumber->id - $lastRow->id;
    return $count;
}

如果我转到索引路线，一切顺利，它会显示列数和行数以及序列中的所有数字。

我在索引视图中有一个表单，用于在数据库中存储一个新号码。该表单具有索引操作，并在将号码存储到数据库后，我会执行以下操作：

return $this->index();

这是我的 store() 方法：

    public function store(StoreNumberRequest $request)
{
    $validated = $request->validated();


    if ($validated) {

        $lastNumber = $request->input('lastNumber');
        $column1 = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12];
        $column2 = [13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24];
        $column3 = [25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36];
        $row1 = [1, 4, 7, 10, 13, 16, 19, 22, 25, 28, 31, 34];
        $row2 = [2, 5, 8, 11, 14, 17, 20, 23, 26, 29, 32, 35];
        $row3 = [3, 6, 9, 12, 15, 18, 21, 24, 27, 30, 33, 36];


        if (in_array($lastNumber, $column1) && in_array($lastNumber, $row1)) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 1,
                'riga' => 1,
            ];
            Number::create($number);
            $numbers =  Number::all();
            return view('index', ['numbers' => $numbers]);
        } elseif (in_array($lastNumber, $column1) && in_array($lastNumber, $row2)) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 1,
                'riga' => 2,
                'created_at' => now(),
                'updated_at' => now(),
            ];
            Number::create($number);
            $numbers =  Number::all();
            return view('index', ['numbers' => $numbers]);
        } elseif (in_array($lastNumber, $column1) && in_array($lastNumber, $row3)) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 1,
                'riga' => 3,
                'created_at' => now(),
                'updated_at' => now(),
            ];
            Number::create($number);
            $numbers =  Number::all();
            return view('index', ['numbers' => $numbers]);
        } elseif (in_array($lastNumber, $column2) && in_array($lastNumber, $row1)) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 2,
                'riga' => 1,
                'created_at' => now(),
                'updated_at' => now(),
            ];
            Number::create($number);
            $numbers =  Number::all();
            return view('index', ['numbers' => $numbers]);
        } elseif (in_array($lastNumber, $column2) && in_array($lastNumber, $row2)) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 2,
                'riga' => 2,
                'created_at' => now(),
                'updated_at' => now(),
            ];
            Number::create($number);
            $numbers =  Number::all();
            return view('index', ['numbers' => $numbers]);
        } elseif (in_array($lastNumber, $column2) && in_array($lastNumber, $row3)) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 2,
                'riga' => 3,
                'created_at' => now(),
                'updated_at' => now(),
            ];
            Number::create($number);
            $numbers =  Number::all();
            return view('index', ['numbers' => $numbers]);
        } elseif (in_array($lastNumber, $column3) && in_array($lastNumber, $row1)) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 3,
                'riga' => 1,
                'created_at' => now(),
                'updated_at' => now(),
            ];
            Number::create($number);
            $numbers =  Number::all();
            return view('index', ['numbers' => $numbers]);
        } elseif (in_array($lastNumber, $column3) && in_array($lastNumber, $row2)) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 3,
                'riga' => 2,
                'created_at' => now(),
                'updated_at' => now(),
            ];
            Number::create($number);
            $numbers =  Number::all();
            return view('index', ['numbers' => $numbers]);
        } elseif (in_array($lastNumber, $column3) && in_array($lastNumber, $row3)) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 3,
                'riga' => 3,
                'created_at' => now(),
                'updated_at' => now(),
            ];
            Number::create($number);
            $numbers =  Number::all();
            return view('index', ['numbers' => $numbers]);
        } elseif ($lastNumber === 0) {
            $number = [
                'number' => $request->input('lastNumber'),
                'colonna' => 0,
                'riga' => 0,
                'created_at' => now(),
                'updated_at' => now(),
            ];
            Number::create($number);

            return $this->index();
        }
    }
}

这是 index.blade.view ：

        <div class="row text-center">
        @foreach ($columnCounts as $column)
            <div class="col border border-2 border-dark p-5 mb-5">

                <p>Column {{ $column['column'] }} Count</p>
                <p>{{ $column['count'] }}</p>
            </div>
        @endforeach
        @foreach ($rowCounts as $row)
            <div class="col border border-2 border-dark p-5 mb-5">
                <p>Row {{ $row['row'] }} Count</p>
                <p>{{ $row['count'] }}</p>
            </div>
        @endforeach

    </div>

但是提交表单后，当我返回 $this->index(); 时，我收到“未定义变量 $columnCounts”的信息。

我在视图中也有一个删除按钮。该按钮调用 destroy() 方法来删​​除序列中插入的最后一个数字。

这是 destroy() 方法：

    public function destroy()
{

    DB::table("numbers")->orderBy("created_at", "DESC")->take(1)->delete();

    return $this->index();
}

在 destroy() 方法中我返回 $this->index(); 就像在 store() 方法中一样。

当我使用 destroy() 删除一个数字时，应用程序会返回索引并正常运行，但使用 store() 时会出现该错误。

有人可以向我解释我做错了什么，以及是否有更好的方法将 $variables 发送到视图而不会出现此问题？

我的表格（和 Laravel 模型关系）： projects -> tasks -> commands

计算任务数量：

$body = Project->withCount('tasks')->get();

美好的。

然后我想计算所有任务的命令数。 SQL 等效代码为：

select 
    count(commands.*)
from projects
inner join tasks on tasks.project_id = projects.id
inner join commands on commands.task_id = tasks.id

如何通过 Eloquent 获取？由于某些原因，查询生成器不可接受。

不幸的是，witchCount它不够灵活with，我不能使用withCount('tasks.commands')

我可以在 Livewire 组件上创建 Filamentphp 表单，以将其显示在公共页面上。但是它没有使用 Filament 样式。这是我的 Livewire 组件

<?php

namespace App\Livewire;
use Filament\Forms\Components\Wizard;
use Filament\Forms\Components\Select;
use Filament\Forms\Components\TextInput;
use Filament\Forms\Concerns\InteractsWithForms;
use Filament\Forms\Contracts\HasForms;
use Filament\Forms\Form;
use Livewire\Component;

class Submission extends Component implements HasForms
{
    use InteractsWithForms;
    public ?array $data = [];

    public function mount()
    {
        $this->form->fill();
    }

    public function form(Form $form): Form
    {
        return $form
            ->schema([
                Wizard::make([
                    Wizard\Step::make('Wizard Step 1')
                        ->schema([
                            Select::make('type')
                                ->label('Do you want:')
                                ->options([
                                    'a' => 'A',
                                    'b' => 'B',
                                    'not_sure' => 'Not Sure',
                                ]),
                        ]),

                    Wizard\Step::make('Wizard Step 2')
                        ->schema([
                            TextInput::make('names'),
                        ]),

                ])
            ]);
    }
    public function render()
    {
        return view('livewire.submission');
    }
}

这是我的组件视图

<div class="flex justify-center items-center min-h-screen">
    <form wire:submit.prevent="submit" class="w-full max-w-md bg-white p-6 rounded shadow">
        <div>
            {{ $this->form }}
        </div>
    </form>
</div>

这是我的页面浏览量

<x-app-layout>
    @livewire('submission')
</x-app-layout>

这是我的布局

<!DOCTYPE html>
<html lang="{{ str_replace('_', '-', app()->getLocale()) }}">
<head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width, initial-scale=1">

    <title>{{ config('app.name', 'Laravel') }}</title>

    <!-- Filament Styles -->
    @vite(['resources/css/app.css', 'resources/js/app.js'])
    @livewireStyles
    @filamentStyles
</head>
<body class="antialiased bg-gray-100">
    <div class="min-h-screen">
        <!-- Replace this -->
        {{ $slot }}
        <!-- End replacement -->
    </div>

    @livewireScripts
    @filamentScripts
</body>
</html>

以下是我的结果：

您可以看到按钮是白色的，下拉菜单有一些时髦的样式。有没有办法应用与 fibre 内部相同的主题，同时仍让页面公开而没有所有菜单？就像登录或注册页面一样。

我在 Laravel 中使用参数化查询：

$objectsSQL = <<<'EOS'
SELECT
    o.id AS oid,
    o.name AS name,
    o.fields AS fields
FROM projects p
JOIN tasks AS t ON t.project_id = p.id
LEFT JOIN commands AS c ON c.task_id = t.id
LEFT JOIN objects AS o ON o.id = c.object_id
WHERE p.id = :pid
GROUP BY o.id, o.name
ORDER BY o.name
EOS;

然后我在循环中使用它$objects = DB::select($objectsSQL, ['pid' => $row->pid]);

现在我想避免使用原始 SQL 并用查询生成器替换它：

$objects = DB::table('projects', 'p')
    ->select(
        'o.id AS oid',
        'o.name AS name',
        'o.fields AS fields'
    )
    ->join('tasks as t', 't.project_id', '=', 'p.id')
    ->leftJoin('commands as c', 'c.task_id', '=', 't.id')
    ->leftJoin('objects as o', 'o.id', '=', 'c.object_id')

    **what to do here to use `:pid`? (WHERE p.id = :pid)**

    ->gropupBy(['o.id', 'o.name'])
    ->orderBy('o.name')

然后如何绑定:pid？

我们正在寻找一个代码片段，用于测试 Laravel 邮件 SMTP，同时打印出 SMTP 对话框。SMTP 对话框通常包含消息 ID，因此如果邮件未到达，可以在相关服务器上进行跟踪。

在以前的 Laravel 版本中我们使用

$to = '[email protected]';

Mail::getSwiftMailer()->registerPlugin(   new Swift_Plugins_LoggerPlugin( new Swift_Plugins_Loggers_EchoLogger(false) ));

Mail::raw('Testmail', function ($message) use ($to) {  $message->to($to)->subject('Testmail'); });

这导致

 BadMethodCallException  Method Illuminate\Mail\Mailer::getSwiftMailer does not exist.

如何将其移植到使用 Symfony 邮件程序的 Laravel 11？

尝试使用 ChatGPT 进行了一些尝试，但目前还没有成功。