colleague / study-project · Files

<?php
/**
 * 腾讯云直播 SDK
 * Created by PhpStorm.
 * User: zhoutao
 * Date: 2018/1/9
 * Time: 下午4:32
 */

namespace Com;

use Org\Net\Snoopy;

class LiveSDK extends Live
{
    /**
     * 直播开关状态 0: 表示禁用 1: 表示允许推流 2: 表示断流
     */
    const CHANNEL_STATUS_DISABLED = 0;
    const CHANNEL_STATUS_ALLOW = 1;
    const CHANNEL_STATUS_CUT_OFF = 2;
    const CHANNEL_STATUS_LIST = [
        self::CHANNEL_STATUS_DISABLED,
        self::CHANNEL_STATUS_ALLOW,
        self::CHANNEL_STATUS_CUT_OFF
    ];

    /**
     * 直播间管理动作 断流：forbid；恢复推流：resume
     */
    const CHANNEL_MANAGER_FORBID = 'forbid';
    const CHANNEL_MANAGER_RESUME = 'resume';

    /**
     * 直播间开启录制任务 0: 非实时 1: 实时
     */
    const TAPE_TASK_SUB_TYPE_NOT_REAL_TIME = 0;
    const TAPE_TASK_SUB_TYPE_REAL_TIME = 1;

    /**
     * 开启关闭推流
     * @param string $channelId 直播码
     * @param int $status 开关状态 0 表示禁用，1 表示允许推流，2 表示断流
     * @return bool
     */
    public function channelSetStatus($channelId, $status)
    {
        if (!in_array($status, self::CHANNEL_STATUS_LIST) || empty($channelId)) {
            return false;
        }

        return $this->requestSdk('Live_Channel_SetStatus', 'fcgi', [
            'Param.s.channel_id' => $channelId,
            'Param.n.status' => $status
        ]);
    }

    /**
     * 查询频道列表
     * @param null   $status 0：表示断流，1：表示开启，3：表示关闭 默认是不过滤
     * @param int    $page 分页页码 从 1 开始，默认为 1
     * @param int    $limit 分页大小 10~100，默认为 10
     * @param string $orderField 排序字段 可选字段：create_time，默认为create_time
     * @param null   $orderType 排序方法 0：表示正序，1：表示倒序
     * @return bool
     */
    public function channelGetChannelList($status = null, $page = 1, $limit = 10, $orderField = '', $orderType = null)
    {
        // 如果有值则对应上字段传输
        $params = [];
        $field = [
            'Param.n.status',
            'Param.n.page_no',
            'Param.n.page_size',
            'Param.s.order_field',
            'Param.n.order_type'
        ];
        foreach (func_get_args() as $key => $item) {
            if (!empty($item)) {
                $params[$field[$key]] = $item;
            }
        };


        return $this->requestSdk('Live_Channel_GetChannelList', 'fcgi', $params);
    }

    /**
     * 暂停推流并延迟恢复接口
     * @param string $channelId 直播码
     * @param int $abstimeEnd 禁播截止的时间戳  禁播截止的绝对时间，请填写UNIX 时间戳（十进制），系统最多禁播三个月。
     * @param string $action 动作  断流：forbid；恢复推流：resume
     * @return bool
     */
    public function channelManager($channelId, $abstimeEnd, $action)
    {
        return $this->requestSdk('channel_manager', 'fcgi', [
            'Param.s.channel_id' => $channelId,
            'Param.n.abstime_end' => $abstimeEnd,
            'Param.s.action' => $action
        ]);
    }

    /**
     * 创建录制任务
     * @param String $channelId 频道 ID
     * @param String $startTime 任务开始时间 标准的 date_time，需要 urlencode，如 2017-01-01%2010:10:01
     * @param String $endTime 任务结束时间 标准的 date_time，需要 urlencode，如 2017-01-01%2010:10:01。
     * @param Int $taskSubType 是否开启实时视频录制 默认 0，1 表示开启实时视频录制。
        （1）若开启实时视频录制，调用接口则同步开始录制，此时如果传入任务开始时间参数，任务开始时间参数无效。
        （2）开启实时视频录制的同时如果传入了任务结束时间，则按照任务结束时间结束录制。若没传入，则 30 分钟后自动结束录制。
        （3）实时录制任务开始时间与任务结束时间超过 30 分钟，则 30 分钟后会自动结束录制，实时视频录制建议控制台在 5 分钟以内。
     * @param String $fileFormat 录制文件格式 默认 flv；可取值 flv、hls、mp4、aac
     * @param String $recordType 录制文件类型 默认 video
        当 record_type 取值“video”时，file_format 可以取值 “flv”,"hls", "mp4"
        当 record_type 取值“audio”时，file_format 可以取值 “aac”，“flv”，“hls”，“mp4”
     * @return bool
     */
    public function liveTapeStart(
        $channelId, $startTime, $endTime,
        $taskSubType = self::TAPE_TASK_SUB_TYPE_NOT_REAL_TIME, $fileFormat = 'flv', $recordType = 'video')
    {
        return $this->requestSdk('Live_Tape_Start', 'fcgi', [
            'Param.s.channel_id' => $channelId,
            'Param.s.start_time' => $startTime,
            'Param.s.end_time' => $endTime,
            'Param.n.task_sub_type' => $taskSubType,
            'Param.s.file_format' => $fileFormat,
            'Param.s.record_type' => $recordType
        ]);
    }

    /**
     * 结束录制任务
     * @param String $channelId 频道 ID
     * @param String $taskId 任务 ID
     * @param Int $taskSubType 是否开启实时视频录制 默认 0，1 表示开启小视频录制
     * @return bool
     */
    public function liveTapeStop($channelId, $taskId, $taskSubType = self::TAPE_TASK_SUB_TYPE_NOT_REAL_TIME)
    {
        return $this->requestSdk('Live_Tape_Stop', 'fcgi', [
            'Param.s.channel_id' => $channelId,
            'Param.s.task_id' => $taskId,
            'Param.n.task_sub_type' => $taskSubType
        ]);
    }

    /**
     * 查询录制文件
     * @param String $channelId 直播码
     * @param String $startTime 查询开始时间 格式为：2016-12-10 00:00:00
     * @param String $endTime 查询结束时间 格式为：2016-12-10 00:00:00。结束时间距开始时间一天以内，且不能跨天
     * @param Int $page 分页页码 从 1 开始，默认为 1
     * @param Int $limit 分页大小 1~100，默认为 10
     * @param String $orderType 排序方式 asc 表示升序，desc 表示降序，默认 asc
     * @return bool
     */
    public function liveTapeGetFilelist(
        $channelId, $startTime = null, $endTime = null, $page = 1, $limit = 10, $orderType = 'asc')
    {
        // 如果有值则对应上字段传输
        $params = [];
        $field = [
            'Param.s.channel_id',
            'Param.s.start_time',
            'Param.s.end_time',
            'Param.n.page_no',
            'Param.n.page_size',
            'Param.s.sort_type',
        ];
        foreach (func_get_args() as $key => $item) {
            if (!empty($item)) {
                $params[$field[$key]] = $item;
            }
        };

        return $this->requestSdk('Live_Tape_GetFilelist', 'fcgi', $params);
    }

    /**
     * 获取播放统计历史信息
     * @param int $startTime 必填 查询起始时间 时间戳 15 天内的数据
     * @param int $endTIme 必填 结束时间 时间戳建议时间跨度不大于 2 小时
     * @param string $streamId 非必填 流 ID 不填就是获取总带宽
     * @param string $domain 非必填 域名 若不填，取这个 APPID 下的总数据，需要填写 cname 前的原始播放域名
     * @return mixed
     */
    public function getLivePlayStatHistory($startTime, $endTIme, $streamId = '', $domain = '')
    {
        // 如果有值则对应上字段传输
        $params = [];
        $field = [
            'Param.n.start_time',
            'Param.n.end_time',
            'Param.s.stream_id',
            'Param.s.domain'
        ];
        foreach (func_get_args() as $key => $item) {
            if (!empty($item)) {
                $params[$field[$key]] = $item;
            }
        };

        return $this->requestSdk('Get_LivePlayStatHistory', 'statcgi', $params);
    }

    /**
     * 查询指定直播流的推流和播放信息
     * @param string $streamId 直播码 如不设置 stream_id：查询所有正在直播中的流
     * @param int    $page 分页页码 从 1 开始，默认为 1
     * @param int    $pageSize 分页大小 1~300，默认为 300
     * @param string $pullDomain 拉流域名 即播放域名，如果不填则返回所有域名的播放数据
     * @return bool
     */
    public function getLiveStat($streamId, $page = 1, $pageSize = 300, $pullDomain = '')
    {
        // 如果有值则对应上字段传输
        $params = [];
        $field = [
            'Param.s.stream_id',
            'Param.n.page_no',
            'Param.n.page_size',
            'Param.s.pull_domain'
        ];
        foreach (func_get_args() as $key => $item) {
            if (!empty($item)) {
                $params[$field[$key]] = $item;
            }
        };

        return $this->requestSdk('Get_LiveStat', 'statcgi', $params);
    }

    /**
     * 同 getLiveStat 方法 只是 仅返回播放统计信息以提高查询效率
     * @param        $streamId
     * @param int    $page
     * @param int    $pageSize
     * @param string $pullDomain
     * @return bool
     */
    public function getLivePlayStat($streamId, $page = 1, $pageSize = 300, $pullDomain = '')
    {
        // 如果有值则对应上字段传输
        $params = [];
        $field = [
            'Param.s.stream_id',
            'Param.n.page_no',
            'Param.n.page_size',
            'Param.s.pull_domain'
        ];
        foreach (func_get_args() as $key => $item) {
            if (!empty($item)) {
                $params[$field[$key]] = $item;
            }
        };

        return $this->requestSdk('Get_LivePlayStat', 'statcgi', $params);
    }
}

abstract class Live
{
    /**
     * 操作类
     */
    const TYPE_OF_OPERATION = 'fcgi';

    /**
     * 统计类
     */
    const TYPE_OF_STAT = 'statcgi';

    /**
     * 基础 URL
     */
    const BASE_URL = 'http://%s.video.qcloud.com/common_access?%s';

    /**
     * API鉴权key
     * @var string
     */
    private $apiAuthKey = '';

    /**
     * 推流防盗链Key
     * @var string
     */
    private $antiTheftChain = '';

    /**
     * AppId
     * @var int
     */
    private $appId = null;

    /**
     * BizId
     * @var int
     */
    private $bizId = null;

    public function __construct()
    {
        $this->apiAuthKey = cfg('TENCENT_LIVE_API_AUTH_KEY');
        $this->antiTheftChain = cfg('TENCENT_LIVE_ANTI_THEFT_CHAIN_KEY');
        $this->appId = cfg('TENCENT_LIVE_APPID');
        $this->bizId = cfg('TENCENT_LIVE_BIZID');
    }

    /**
     * 请求腾讯云 SDK
     * @param        $interface
     * @param        $type
     * @param array  $urlParams
     * @param array  $postParams
     * @param array  $headers
     * @param string $method
     * @param null   $file
     * @return bool
     */
    protected function requestSdk(
        $interface, $type, $urlParams = [], $postParams = [], $headers = [], $method = 'GET', $file = null
    ) {
        // 防止太快过期 + 10秒
        $t = NOW_TIME + 10;
        $baseParams = [
            'appid' => $this->appId,
            'interface' => $interface,
            't' => $t,
            'sign' => md5($this->apiAuthKey . $t),
        ];
        $params = [
            self::BASE_URL,
            $type,
            http_build_query(array_merge($baseParams, $urlParams)),
        ];
        $url = call_user_func_array('sprintf', $params);

        \Think\Log::record('腾讯云直播 接口 ::: ' . $interface . ' 请求参数 ::: ' . var_export($postParams, true));
        return $this->request($url, $postParams, $headers, $method, $file);
    }

    /**
     * 请求接口数据
     * @param string       $url 请求URL
     * @param string|array $reqParams 请求数据
     * @param array        $headers 请求头部
     * @param string       $method 请求方式, 如: GET/POST/DELETE/PUT
     * @param mixed        $files 文件路径
     * @param bool         $retry 是否重试
     * @return bool
     */
    protected function request($url, $reqParams, $headers = [], $method = 'GET', $files = null, $retry = false)
    {
        $snoopy = new Snoopy();

        // 使用自定义的头字段，格式为 array(字段名 => 值, ... ...)
        $snoopy->rawheaders = $headers;
        // 非 GET 协议, 需要设置
        $method = rstrtoupper($method);
        $methods = array('GET', 'POST', 'PUT', 'DELETE');
        if (!in_array($method, $methods)) {
            $method = 'GET';
        }

        // 设置协议
        if (!empty($files)) {
            // 如果需要传文件
            $method = 'POST';
            $snoopy->set_submit_multipart();
        } else {
            $snoopy->set_submit_normal('application/json');
        }

        // 判断协议
        $snoopy->set_submit_method($method);
        switch (rstrtoupper($method)) {
            case 'POST' :
            case 'PUT' :
            case 'DELETE' :
                $result = $snoopy->submit($url, $reqParams, $files);
                break;
            default :
                $result = $snoopy->fetch($url);
                break;
        }

        // 如果读取错误
        if (!$result || 200 != $snoopy->status) {
            \Think\Log::record('请求错误::' . var_export($snoopy, true));
        }

        // 获取返回数据 (腾讯云返回的结果不是纯的 json 字符串)
        preg_match("/\{.*\}/is", $snoopy->results, $matches);
        $result = json_decode($matches[0], true);
        \Think\Log::record('返回数据:::' . var_export($matches[0], true));

        return $result;
    }

    /**
     * 获取推流地址
     * 如果不传key和过期时间，将返回不含防盗链的url
     * @param String $livecode 直播码 bizid+"_"+stream_id  如 8888_test123456
     * @param String $time 过期时间 10位数时间戳
     * @return array 0 推流地址 1 推流名称
     */
    public function getPushUrl($livecode, $time)
    {
        $txTime = strtoupper(base_convert($time, 10, 16));

        $ext_str = '?' . http_build_query(array(
                'bizid' => $this->bizId,
                // MD5( KEY + livecode + txTime )
                'txSecret' => md5($this->antiTheftChain . $livecode . $txTime),
                'txTime' => $txTime,
            ));

        return [
            'rtmp://' . $this->bizId . '.livepush.myqcloud.com/live/',
            $livecode . (isset($ext_str) ? $ext_str : '')
        ];
    }

    /**
     * 获取播放地址
     * @param String bizId 您在腾讯云分配到的bizid
     * @param String $livecode 直播码 bizid+"_"+stream_id  如 8888_test123456
     * @return String url
     */
    public function getPlayUrl($livecode)
    {
        return array(
            'rtmp://' . $this->bizId . '.liveplay.myqcloud.com/live/' . $livecode,
            'http://' . $this->bizId . '.liveplay.myqcloud.com/live/' . $livecode . '.flv',
            'http://' . $this->bizId . '.liveplay.myqcloud.com/live/' . $livecode . '.m3u8',
        );
    }

    /**
     * 获取直播码 腾讯云回调通知内容内的 stream_id 或者说 channel_id 两个是一样的 腾讯云自己的历史原因
     * @param $id
     * @return string
     */
    public function getLiveCode()
    {
        return $this->bizId . '_' . $this->getStreamId();
    }

    /**
     * 获取直播标识
     * @return string
     */
    private function getStreamId()
    {
        // 单个企业只会有一个
        return strtolower(QY_DOMAIN);
    }
}