01
Jul

php乐视云直播接口类

<?php

// +----------------------------------------------------------------------
// | Wemy Server - 博域科技威迈系统乐视云模块
// +----------------------------------------------------------------------
// | Copyright (c) 2016 http://www.wemy.com.cn, All rights reserved.
// +----------------------------------------------------------------------
// | Author: Andy <www.wangyang.me>
// +----------------------------------------------------------------------

class Lecloud
{

	const ON_DEMAND_APIURL = 'http://api.letvcloud.com/open.php';		//点播接口
	const ON_DEMAND_VER = '2.0';										//点播协议版本
	const LIVE_APIURL = 'http://api.open.letvcloud.com/live/execute';	//直播接口
	const LIVE_VER = '3.1';												//直播协议版本

	public function __construct($options)
	{
		$this->userid = isset($options['userid'])?$options['userid']:'';	//用户ID
		$this->uuid = isset($options['uuid'])?$options['uuid']:'';			//UUID
		$this->pkey = isset($options['pkey'])?$options['pkey']:'';			//私钥
	}

	/**
	 * 拼接数组成为字符串
	 * @param  array   $param   参数数组
	 * @param  boolean $urlencode URL处理
	 * @return string             参数字符串
	 */
	protected function _formatBizQueryParaMap($param, $urlencode = false){
		$buff = "";
		ksort($param);
		foreach ($param as $k => $v){
			if($urlencode){
				$v = urlencode($v);
			}
			$buff .= $k . $v;
		}
		return $buff;
	}

	/**
	 * 整理GET方式URL参数
	 * @param  array   $param   参数数组
	 * @param  boolean $urlencode URL处理
	 * @return string             参数字符串
	 */
	protected function _formatGetPara($param){
		$buff = "";
		ksort($param);
		foreach ($param as $k => $v){
			$buff .= $k . "=" . $v . "&";
		}
        //去掉末位&
        $buff = "?" . substr($buff,0,strlen($buff)-1);
		return $buff;
	}

	/**
	 * 获取签名
	 * @param  array  $param 参数
	 * @return string        签名
	 */
	protected function _getSign($param){
		//一、把除sign外的所有参数(包括另外的公共参数)按key升序排序
		ksort($param);
		//二、把key和它对应的value拼接成一个字符串。按步骤1中顺序,把所有键值对字符串拼接成一个字符串。对于uri类的参数,请使用url编码前的字符串。
		$String = $this->_formatBizQueryParaMap($param);
		//三、把分配给的pkey拼接在第2步骤得到的字符串后面
		$String = $String . $this->pkey;
		//四、计算第3步骤字符串的md5值,使用md5值的16进制字符串作为sign的值。
		$String = md5($String);
		return $String;
	}

	/**
	 * 发送POST请求
	 * @param  string $url  请求地址
	 * @param  array  $data 请求参数
	 * @return  			请求结果
	 */
	private function _curlPost($url,$data){
		$ch = curl_init();
		$header = "Accept-Charset: utf-8";
		curl_setopt($ch, CURLOPT_URL, $url);
		curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
		curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
		curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
		curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
		curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
		curl_setopt($ch, CURLOPT_AUTOREFERER, 1);
		curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
		$tmpInfo = curl_exec($ch);
		curl_close($ch);
		return $tmpInfo;
	}

	/**
	 * 发送GET请求
	 * @param  string $url  请求地址
	 * @return  			请求结果
	 */
	private function _curlGet($url){
		$oCurl = curl_init();
		if(stripos($url,"https://")!==FALSE){
			curl_setopt($oCurl, CURLOPT_SSL_VERIFYPEER, FALSE);
			curl_setopt($oCurl, CURLOPT_SSL_VERIFYHOST, FALSE);
			curl_setopt($oCurl, CURLOPT_SSLVERSION, 1); //CURL_SSLVERSION_TLSv1
		}
		curl_setopt($oCurl, CURLOPT_URL, $url);
		curl_setopt($oCurl, CURLOPT_RETURNTRANSFER, 1 );
		$sContent = curl_exec($oCurl);
		$aStatus = curl_getinfo($oCurl);
		curl_close($oCurl);
		if(intval($aStatus["http_code"])==200){
			return $sContent;
		}else{
			return false;
		}
	}


	/**
	 * 发送点播API请求
	 * @param  array  $param  参数
	 * @param  string $method 请求方法
	 * @return          	  返回结果
	 */
	protected function _sendOnDemandApi($param, $method = "get"){
		$param['ver'] = self::ON_DEMAND_VER;
		$param['user_unique'] = $this->uuid;
		$param['timestamp'] = time() * 1000;		//当前Unix时间戳
		$param['format'] = 'json';					//返回参数格式:支持json和xml两种方式
		$param['sign'] = $this->_getSign($param);
		if($method === 'get'){
			$url = $this->_formatGetPara($param);
			$json = $this->_curlGet(self::ON_DEMAND_APIURL . $url);
		} else {
			$json = $this->_curlPost(self::ON_DEMAND_APIURL, $param);
		}
		$res = json_decode($json,true);
		if($res['code'] == 0){
			return isset($res['data']) ? $res['data'] : true;
		}
		return false;
	}

	/**
	 * 发送直播API请求
	 * @param  array  $param  参数
	 * @param  string $method 请求方法
	 * @return                返回结果
	 */
	protected function _sendLiveApi($param, $method = "get"){
		$param['ver'] = self::LIVE_VER;
		$param['userid'] = $this->userid;
		$param['timestamp'] = time()*1000;			//当前Unix时间戳
		$param['sign'] = $this->_getSign($param);
		if($method === 'get'){
			$url = $this->_formatGetPara($param);
			$json = $this->_curlGet(self::LIVE_APIURL . $url);
		} else {
			$json = $this->_curlPost(self::LIVE_APIURL, $param);
		}
		return json_decode($json,true);
	}


	/*
	* 点播api
	* $api_name string 点播接口名
	* $param array 点播参数
	*/
	public function dianbo($api_name,$param=''){
		$param['api'] = $api_name;
		return $this->_sendOnDemandApi($param);//请求接口
	}

	/**
	 * 直播活动信息查询
	 * @param  string  $activityId     直播活动ID
	 * @param  string  $activityName   直播活动名称
	 * @param  string  $activityStatus 直播活动状态。0:未开始 1:已开始 3:已结束
	 * @param  integer $offSet         从第几条数据开始查询,默认0
	 * @param  integer $fetchSize      一次返回多少条数据,默认为10,最多不能超过100条
	 * @return                   	   直播活动信息
	 */
	public function getLiveInfo($activityId = "", $activityName = "", $activityStatus = "", $offSet = 0, $fetchSize = 10){
		$param['method'] = "lecloud.cloudlive.vrs.activity.vrsinfo.search";
		$param['activityId'] = $activityId;
		$param['activityName'] = $activityName;
		$param['activityStatus'] = $activityStatus;
		$param['offSet'] = $offSet;
		$param['fetchSize'] = $fetchSize;
		return $this->_sendLiveApi($param);
	}

	/**
	 * 获取直播活动推流Token
	 * @param  string  $activityId     直播活动ID
	 * @return string                  token
	 */
	public function getPushToken($activityId){
		if(empty($activityId)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.activity.getPushToken";
		$param['activityId'] = $activityId;
		return $this->_sendLiveApi($param);
	}

	/**
	 * 获取直播活动推流地址
	 * @param  string  $activityId     直播活动ID
	 * @return array
	 */
	public function getPushUrl($activityId){
		if(empty($activityId)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.activity.getPushUrl";
		$param['activityId'] = $activityId;
		return $this->_sendLiveApi($param);
	}

	/**
	 * 修改直播活动媒资信息
	 * @param  string  $activityId     直播活动ID
	 * @param  array   $param          活动信息
	 * @return NULL
	 *
	 * 
	 *   例:
	 *   -------------------------------------------------------
     *   $data['activityName'] = "直播活动名称(200个字符以内)";
     *   $data['startTime'] = "开始时间 格式yyyyMMddHHmmss";
     *   $data['endTime'] = "结束时间 格式yyyyMMddHHmmss";
     *   $data['coverImgUrl'] = "直播中-活动封面地址";
     *   $data['description'] = "直播中-活动描述(255个字符以内)";
     *   $data['activityCategory'] = "活动分类参见《活动编码》,无二级编码时直接填写一级编码";
     *   $data['extensions'] = "扩展字段,活动分类修改时,需要修改分类的扩展字段,也可在活动分类不变的情况下单独修改扩展字段,按如下方式传参数";
     *   $lecloud->modifyLive($activityId, $data);
     *
     * 
	 */
	public function modifyLive($activityId, $param = array()){
		if(empty($activityId)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.vrs.activity.vrsinfo.modify";
		$param['activityId'] = $activityId;
		return $this->_sendLiveApi($param, "post");
	}

	/**
	 * 用于第三方播放器获取直播活动的流信息
	 * @param  string  $activityId     直播活动ID
	 * @return array
	 */
	public function getStreamForThird($activityId){
		if(empty($activityId)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.vrs.activity.streaminfo.search";
		$param['activityId'] = $activityId;
		return $this->_sendLiveApi($param);
	}

	/**
	 * 直播活动结束
	 * @param  string  $activityId     直播活动ID
	 * @return NULL
	 */
	public function stopLive($activityId){
		if(empty($activityId)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.activity.stop";
		$param['activityId'] = $activityId;
		return $this->_sendLiveApi($param, "post");
	}

	/**
	 * 直播活动机位状态查询
	 * @param  string  $activityId     直播活动ID
	 * @return array
	 */
	public function getActivityMachineState($activityId){
		if(empty($activityId)){
			return false;
		}
		$param['method']= "letv.cloudlive.activity.getActivityMachineState";
		$param['activityId'] = $activityId;
		return $this->_sendLiveApi($param);
	}

	/**
	 * 直播活动封面上传
	 * @param  string  $activityId     直播活动ID
	 * @param  File    $file           图片文件,支持格式jpg、png、gif
	 * @return string                  图片地址
	 */
	public function modifyCoverImg($activityId, $file){
		if(empty($activityId) OR empty($file)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.activity.modifyCoverImg";
		$param['activityId'] = $activityId;
		$param['file'] = $file;
		return $this->_sendLiveApi($param, "post");
	}

	/**
	 * 直播活动创建
	 * @param  string  $activityName     直播活动名称(200个字符以内)
	 * @param  string  $startTime        开始时间 格式yyyyMMddHHmmss
	 * @param  string  $endTime          结束时间 格式yyyyMMddHHmmss
	 * @param  string  $coverImgUrl      活动封面地址,如果为空,则系统会默认一张图片
	 * @param  string  $description      活动描述(1024个字符以内)
	 * @param  integer $liveNum          机位数量,范围为:1,2,3,4. 默认为1
	 * @param  string  $codeRateTypes    流的码率类型,逗号分隔。由大到小排列。取值范围:10 流畅;13 标清;16 高清;19 超清;22 720P;25 1080P;99 原画
	 * @param  integer $needRecord       是否支持全程录制 0:否 1:是。默认为0
	 * @param  integer $needTimeShift    是否支持时移 0:否 1:是。默认为0
	 * @param  integer $needFullView     是否全景观看 0:否 1:是。默认为0
	 * @param  string  $activityCategory 活动分类,参见《活动编码》。默认为999-其他
	 * @param  integer $playMode         播放模式,0:实时直播。1:流畅直播
	 * @return string                    activityId
	 */
	public function createLive($activityName, $startTime, $endTime, $coverImgUrl = '', $description = '', $liveNum = 1, $codeRateTypes = '99', $needRecord = 0, $needTimeShift = 0, $needFullView = 0, $activityCategory = '999', $playMode = 0){
		if(empty($activityName) OR empty($startTime) OR empty($endTime)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.activity.create";
		$param['activityName'] = $activityName;
		$param['startTime'] = $startTime;
		$param['endTime'] = $endTime;
		$param['coverImgUrl'] = $coverImgUrl;
		$param['description'] = $description;
		$param['liveNum'] = $liveNum;
		$param['codeRateTypes'] = $codeRateTypes;
		$param['needRecord'] = $needRecord;
		$param['needTimeShift'] = $needTimeShift;
		$param['needFullView'] = $needFullView;
		$param['activityCategory'] = $activityCategory;
		$param['playMode'] = $playMode;
		return $this->_sendLiveApi($param, "post");
	}

	/**
	 * 直播活动播放页地址获取
	 * @param  string  $activityId     直播活动ID
	 * @return string 				   直播播放页地址
	 */
	public function getLiveUrl($activityId){
		if(empty($activityId)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.activity.playerpage.getUrl";
		$param['activityId'] = $activityId;
		$playPageUrl = $this->_sendLiveApi($param);
		return $playPageUrl;
	}

	/**
	 * 直播活动安全信息设置
	 * @param string  $activityId     			 直播活动ID
	 * @param integer $neededPushAuth            是否启用推流鉴权 0:否 1:是
	 * @param integer $pushUrlValidTime          推流地址有效时长,单位s,启用推流鉴权时有效
	 * @param string  $liveKey                   直播安全码,计算推流地址时用到的安全码,如果为空的话,则使用客户的安全码
	 * @param integer $needIpWhiteList           是否启用IP推流白名单 0:否 1:是。
	 * @param string  $pushIpWhiteList           推流IP白名单,启用IP推流白名单时有效。多个IP时,用英文半角逗号分隔,IP最多可以配置10个,值总长度最大为512
	 * @param integer $needPlayerDomainWhiteList 是否启用域名白名单,默认为0,否
	 * @param string  $playerDomainWhiteList     域名白名单,多个时逗号分隔。最大长度为512,最多为10个
	 * @return NULL
	 */
	public function setLiveSafe($activityId, $neededPushAuth = 1, $pushUrlValidTime = 60, $liveKey = '', $needIpWhiteList = 0, $pushIpWhiteList = '', $needPlayerDomainWhiteList = 0, $playerDomainWhiteList = ''){
		if(empty($activityId) OR empty($file)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.activity.sercurity.config";
		$param['activityId'] = $activityId;
		$param['neededPushAuth'] = $neededPushAuth;
		$param['pushUrlValidTime'] = $pushUrlValidTime;
		$param['liveKey'] = $liveKey;
		$param['needIpWhiteList'] = $needIpWhiteList;
		$param['pushIpWhiteList'] = $pushIpWhiteList;
		$param['needPlayerDomainWhiteList'] = $needPlayerDomainWhiteList;
		$param['playerDomainWhiteList'] = $playerDomainWhiteList;
		return $this->_sendLiveApi($param, "post");
	}

	/**
	 * 直播创建打点录制任务 - 原画码率作为输入码率,直播上的码率作为输出码率,执行转码获取打点录制任务
	 * @param  string $liveId    直播ID,直播id查询参考getStreamForThird()
	 * @param  string $startTime 开始时间 格式yyyyMMddHHmmss
	 * @param  string $endTime   结束时间 格式yyyyMMddHHmmss
	 * @return string            taskId -任务ID
	 */
	public function createLiveRecTask($liveId, $startTime, $endTime){
		if(empty($activityId) OR empty($file)){
			return false;
		}
		$param['method']= "lecloud.cloudlive.rec.createRecTask";
		$param['liveId'] = $liveId;
		$param['startTime'] = $startTime;
		$param['endTime'] = $endTime;
		return $this->_sendLiveApi($param, "post");
	}

	/**
	 * 直播打点录制结果查询
	 * @param  array   $param          直播id等信息
	 * @return array
	 *
	 * 
	 *   例:
	 *   -------------------------------------------------------
     *   $data['liveId'] = "直播ID";
     *   $data['taskId'] = "任务ID";
     *   $data['offset'] = 开始行数;
     *   $data['size'] = 每页记录数;
     *   $data['startTime'] = "开始时间 格式yyyyMMdd";
     *   $data['endTime'] = "结束时间 格式yyyyMMdd";
     *   $lecloud->getLiveRecTask($data);
     *
     * 
	 */
	public function getLiveRecTask($param){
		$param['method']= "lecloud.cloudlive.rec.searchResult";
		return $this->_sendLiveApi($param);
	}

}

下载地址:附件:Lecloud.class.php

阿里云“99套餐”,新老同享,低价长效,助力开发者普惠上云!

About Me

Nothing is impossible!

Friends
倩倩的网站儿子的网站丽丽
助力快速上云,让学生、开发者、企业用云无忧。!
CATEGORIES
Tags
ChatGPT四舍五入GOBeatles想像冰雪奇缘北京编程SSL证书认知障碍Docker春天行政区域名列表域名体系nginxopen_basedir思维指令编程语言程序URL网站上线域名FTP云服务器搜索引擎JSCSS网页超链接聚合内容列表元素网页构成网站的构成网站的分类网站单标签HTML第一个网页简单网页博域科技2018香山春游AJAX字体
Copyright©2022 王阳 版权所有  京ICP备14005672号-6