video_server/app/Jobs/InitSysMessageJob.php

<?php

namespace App\Jobs;

use App\Model\VideoModel;
use App\Repositories\SysMessageRepository;
use Hyperf\AsyncQueue\Job;


class InitSysMessageJob extends Job
{
    public $params = [];

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

    public function handle()
    {
        $repo = make(SysMessageRepository::class);
        $receiveUid = $this->params['receive_uid'];
        $repo->initForUser($receiveUid);
    }
}