hc_live/application/common/service/SettingService.php

<?php
/**
 * Author: luzheng.liu
 * Time: 2020/12/6 17:25
 */

namespace app\common\service;


use app\index\exception\ApiException;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;
use think\Exception;

class SettingService {

    const TOKEN = 'Bearer a1aw1av25bk1usqjv7r84mw9knpv3sma';

    const BASE_URL = 'http://api.webcasting.bizconfstreaming.com/';

    public function verifyChannelName(int $channelId,string $channelName) {
        $client = new Client();
        $res =$client->request('GET', self::BASE_URL.'v1/activities/'.$channelId, [
            'headers' => [
                'Authorization' => self::TOKEN
            ]
        ]);
        $info = json_decode((string)$res->getBody(),true);
        if ($channelName !== $info['name']) {
            throw new ApiException("频道名称不一致,频道{$channelId}名称为 ".$info['name']);
        }
    }

    public function setAuthUrl(int $channelId, string $redirectUrl) {
//        $client = new Client();
//        $res =$client->request('Post', self::BASE_URL.'v1/activities/'.$channelId.'/setAuth', [
//            'headers' => [
//                'Authorization' => self::TOKEN
//            ],
//            'json' => [
//                'method' => 'CUSTOM_VERIFY',
//                'redirect_url' => $redirectUrl
//            ]
//        ]);
        $curl = curl_init();
        $data = [
            'method'       => 'CUSTOM_VERIFY',
            'redirect_url' => $redirectUrl
        ];
        $data = json_encode($data);
        curl_setopt_array($curl, array(
            CURLOPT_URL => self::BASE_URL.'v1/activities/'.$channelId.'/setAuth',
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_ENCODING => '',
            CURLOPT_MAXREDIRS => 10,
            CURLOPT_TIMEOUT => 0,
            CURLOPT_FOLLOWLOCATION => true,
            CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
            CURLOPT_CUSTOMREQUEST => 'POST',
            CURLOPT_POSTFIELDS => $data,
            CURLOPT_HTTPHEADER => array(
                'Authorization: '.self::TOKEN,
                'Content-Type: application/json'
            ),
        ));

        $response = curl_exec($curl);

        curl_close($curl);

        $info = json_decode((string)$response,true);
        if ($info['status'] !== 'y') {
            throw new ApiException("设置自定义授权url失败--".(string)$response);
        }
    }

    public function getAuthCode(int $channelId) {
        $client = new Client();
        $res =$client->request('Post', self::BASE_URL.'v1/activities/'.$channelId.'/getAuthKey', [
            'headers' => [
                'Authorization' => self::TOKEN
            ]
        ]);
        $info = json_decode((string)$res->getBody(),true);
        if (empty($info)){
            throw new ApiException($info['message']);
        }
        return $info['authkey'];
    }
}