video_server/app/Jobs/SearchHotelLogJob.php

<?php

declare(strict_types=1);

namespace App\Jobs;

use App\Model\Mongo\SearchHotelLogModel;
use Hyperf\AsyncQueue\Job;

class SearchHotelLogJob extends Job
{
    public $userId;
    public $fid;
    public $project;

    public function __construct(string $userId, string $fid, array $project)
    {
        // 这里最好是普通数据，不要使用携带 IO 的对象，比如 PDO 对象
        $this->userId = $userId;
        $this->fid = $fid;
        $this->project = $project;
    }

    public function handle()
    {
        make(SearchHotelLogModel::class)->create($this->userId, $this->fid, $this->project);
    }
}