video_server/app/Jobs/SendTgMegJob.php

<?php

namespace App\Jobs;

use App\Events\Task\LastSignInEvent;
use App\Model\TaskAwarkLogModel;
use App\Repositories\ConfigRepoistory;
use App\Repositories\Service\CommonService;
use App\Repositories\Service\UserSingInService;
use App\Repositories\TaskAwarkLogRepository;
use GuzzleHttp\Client;
use Hyperf\AsyncQueue\Job;
use Hyperf\Guzzle\ClientFactory;

class SendTgMegJob extends Job
{
    public $params;
    public $name;
    public $message;

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

    public function handle()
    {
        $configRepo = make(ConfigRepoistory::class);
        $tgMsgServer = $configRepo->get('tg_msg_server', 'sys', '');
        $tgApiToken = $configRepo->get('tg_api_token', 'sys', '');
        if ($tgMsgServer && $tgApiToken) {
            $content = json_encode($this->params,JSON_UNESCAPED_UNICODE);
            make(CommonService::class)->httpPostJson(
                $tgMsgServer . 'api/tg/send/message',
                [
                    'name' => $this->name,
                    'message' => $this->message,
                    'content'=>$content,
                    'title' => '雏姬'
                ],
            ['AUTH-TOKEN' => $tgApiToken]);
        }

    }
}