video_server/app/Jobs/SendMessageToUserJob.php

<?php

namespace App\Jobs;

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

class SendMessageToUserJob extends Job
{
    protected $params = [];

    public function __construct($params = [])
    {
        $this->params = $params;
    }

    public function handle()
    {
        $messageRepo = make(MessageRepository::class);
        $fromType = data_get($this->params, 'from_type', '');
        $receiveUid = data_get($this->params, 'receive_uid', '');
        $subject = data_get($this->params, 'subject', '');
        $content = data_get($this->params, 'content', '');
        if ($fromType == 'sys') {
            $messageRepo->sendTextFromSys($receiveUid, $content, $subject);
        } elseif ($fromType == 'user') {
            $fromUid = data_get($this->params, 'from_uid', '');
            $messageRepo->sendTextFromUser($receiveUid, $fromUid, $content, $subject);
        }
    }

}