video_server/app/Jobs/SendTgWithdrawMegJob.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 SendTgWithdrawMegJob extends Job
{
    public $platform;
    public $uid;
    public $name;
    public $type;
    public $amount;
    public $date;

    /**
     * @param $platform
     * @param $uid
     * @param $user
     * @param $type
     * @param $amount
     * @param $date
     */
    public function __construct($platform, $uid, $user, $type, $amount, $date)
    {
        // 这里最好是普通数据，不要使用携带 IO 的对象，比如 PDO 对象
        $this->platform = $platform;
        $this->uid = $uid;
        $this->user = $user;
        $this->type = $type;
        $this->amount = $amount;
        $this->date = $date;
    }

    public function handle()
    {
        $configRepo = make(ConfigRepoistory::class);
        $tgMsgServer = $configRepo->get('tg_msg_server', 'sys', '');
        $tgApiToken = $configRepo->get('tg_api_token', 'sys', '');
        if ($tgMsgServer && $tgApiToken) {
            $type = '未知';
            if ($this->type == 1) {
                $type = 'USDT';
            } elseif ($this->type == 2) {
                $type = '银行卡';
            } elseif ($this->type == 3) {
                $type = '支付宝';
            }
            make(CommonService::class)->httpPostJson(
                $tgMsgServer . 'api/tg/send/user/withdraw/message',
                [
                    'platform' => $this->platform,
                    'uid' => $this->uid,
                    'user' => $this->user,
                    'type_name' => $type,
                    'amount' => $this->amount,
                    'date' => $this->date,
                ],
                ['AUTH-TOKEN' => $tgApiToken]);
        }

    }
}