video_server/app/Jobs/RecordSearchJob.php

<?php

namespace App\Jobs;

use App\Repositories\UserLogRepository;
use Hyperf\AsyncQueue\Job;


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

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

    public function handle()
    {
        if (empty($this->params['event_name']) || empty($this->params['user_code']) || empty($this->params['keywords'])) {
            return true;
        }
        $repo = make(UserLogRepository::class);
        $module = $this->params['module'] ?? '';
        $repo->recordSearchLog(
            $this->params['event_name'],
            $this->params['user_code'],
            $this->params['keywords'],
            $module
        );
    }
}