262 lines
8.4 KiB
PHP
262 lines
8.4 KiB
PHP
<?php
|
|
/**
|
|
* Created by Aliyun ApsaraVideo VoD.
|
|
* User: https://www.aliyun.com/product/vod
|
|
*/
|
|
use OSS\Core\OssUtil;
|
|
|
|
class AliyunVodUtils
|
|
{
|
|
const VOD_MAX_TITLE_LENGTH = 128;
|
|
const VOD_MAX_DESCRIPTION_LENGTH = 1024;
|
|
|
|
public static function convertOssInternal($ossUrl, $ecsRegion=null, $isEnableSSL=false)
|
|
{
|
|
if (!$isEnableSSL) {
|
|
$ossUrl = str_replace("https:", "http:", $ossUrl);
|
|
}
|
|
|
|
if (!is_string($ossUrl) || !is_string($ecsRegion)) {
|
|
return $ossUrl;
|
|
}
|
|
$availableRegions = array('cn-qingdao', 'cn-beijing', 'cn-zhangjiakou', 'cn-huhehaote', 'cn-hangzhou', 'cn-shanghai', 'cn-shenzhen',
|
|
'cn-hongkong', 'ap-southeast-1', 'ap-southeast-2', 'ap-southeast-3',
|
|
'ap-northeast-1', 'us-west-1', 'us-east-1', 'eu-central-1', 'me-east-1');
|
|
|
|
if (!in_array($ecsRegion, $availableRegions)) {
|
|
return $ossUrl;
|
|
}
|
|
|
|
$ossUrl = str_replace("https:", "http:", $ossUrl);
|
|
return str_replace(sprintf("oss-%s.aliyuncs.com", $ecsRegion),
|
|
sprintf("oss-%s-internal.aliyuncs.com", $ecsRegion), $ossUrl);
|
|
}
|
|
|
|
public static function getFileName($fileUrl)
|
|
{
|
|
$fileUrl = urldecode($fileUrl);
|
|
$pos = strrpos($fileUrl, '?');
|
|
$briefPath = $fileUrl;
|
|
if ($pos !== false) {
|
|
$briefPath = substr($fileUrl, 0, $pos);
|
|
}
|
|
return array($briefPath, basename($briefPath));
|
|
}
|
|
|
|
public static function getFileExtension($fileName)
|
|
{
|
|
$pos = strrpos($fileName, '.');
|
|
if ($pos !== false) {
|
|
return substr($fileName, $pos + 1);
|
|
}
|
|
return null;
|
|
}
|
|
|
|
// 考虑分隔符为"/" 或 "\"(windows)
|
|
public static function replaceFileName($filePath, $replace) {
|
|
if (strlen($filePath) <= 0 || strlen($replace) <= 0) {
|
|
return $filePath;
|
|
}
|
|
$filePath = urldecode($filePath);
|
|
$separator = '/';
|
|
$start = strrpos($filePath, $separator);
|
|
if ($start === false) {
|
|
$separator = '\\';
|
|
$start = strrpos($filePath, '\\');
|
|
if ($start === false) {
|
|
return false;
|
|
}
|
|
}
|
|
return substr($filePath, 0, $start) . $separator. $replace;
|
|
}
|
|
|
|
public static function mkDir($filePath) {
|
|
if (strlen($filePath) <= 0) {
|
|
return true;
|
|
}
|
|
$filePath = urldecode($filePath);
|
|
$start = strrpos($filePath, '/');
|
|
if ($start === false) {
|
|
return false;
|
|
}
|
|
$fileDir = substr($filePath, 0, $start);
|
|
if (!is_dir($fileDir)) {
|
|
return mkdir($fileDir, 0777, true);
|
|
}
|
|
return true;
|
|
|
|
}
|
|
|
|
// 截取字符串，在不超过最大字节数前提下确保中文字符不被截断出现乱码
|
|
public static function subString($strVal, $maxBytes)
|
|
{
|
|
$i = mb_strlen($strVal);
|
|
while (strlen($strVal) > $maxBytes) {
|
|
$i--;
|
|
if ($i <= 0) {
|
|
return '';
|
|
}
|
|
$strVal = mb_substr($strVal, 0, $i);
|
|
}
|
|
return $strVal;
|
|
}
|
|
|
|
public static function getCurrentTimeStr() {
|
|
return date("Y-m-d H:i:s");
|
|
|
|
}
|
|
|
|
public static function startsWith($haystack, $needle){
|
|
return strncmp($haystack, $needle, strlen($needle)) === 0;
|
|
}
|
|
|
|
public static function endsWith($haystack, $needle){
|
|
return $needle === '' || substr_compare($haystack, $needle, -strlen($needle)) === 0;
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
class AliyunVodLog
|
|
{
|
|
public static $logSwitch = true;
|
|
public static function printLog($format, $args = null, $_ = null) {
|
|
if (!AliyunVodLog::$logSwitch) {
|
|
return;
|
|
}
|
|
$vargs = func_get_args();
|
|
unset($vargs[0]);
|
|
$msg = vsprintf($format, $vargs);
|
|
self::printStr($msg);
|
|
}
|
|
|
|
private static function printStr($msg) {
|
|
// printf("[%s]%s\n", AliyunVodUtils::getCurrentTimeStr(), $msg);
|
|
}
|
|
}
|
|
|
|
|
|
class AliyunVodReportUpload
|
|
{
|
|
public static $isEnableSSL = false;
|
|
|
|
const VOD_REPORT_URL = 'vod.cn-shanghai.aliyuncs.com';
|
|
const VOD_REPORT_VERSION = '1.0.2';
|
|
const VOD_REPORT_KEY ='wXr&aLIJdfI7so';
|
|
const REPORT_FILE_HASH_READ_LEN = 1048576;
|
|
|
|
public static function reportUploadProgress($clientId, $videoId, $progressInfo)
|
|
{
|
|
try {
|
|
HttpHelper::$connectTimeout = 1;
|
|
HttpHelper::$readTimeout = 2;
|
|
$authTimestamp = time();
|
|
$authInfo = md5(sprintf("%s|%s|%s", $clientId, self::VOD_REPORT_KEY, $authTimestamp));
|
|
$fields = array('Action'=>'ReportUploadProgress', 'Format'=>'JSON', 'Version'=>'2017-03-21',
|
|
'Timestamp'=>gmdate('Y-m-d\TH:i:s\Z'), 'SignatureNonce'=>md5(uniqid(mt_rand(), true)),
|
|
'VideoId'=>$videoId, 'Source'=>'PHPSDK', 'ClientId'=>$clientId,
|
|
'BusinessType'=>'UploadVideo', 'TerminalType'=>'PC', 'DeviceModel'=>'Server',
|
|
'AppVersion'=>self::VOD_REPORT_VERSION, 'AuthTimestamp'=>$authTimestamp, 'AuthInfo'=>$authInfo,
|
|
'FileName'=>$progressInfo['FileName'], 'FileHash'=>$progressInfo['FileHash'],
|
|
'FileSize'=>empty($progressInfo['FileSize']) ? 0 : $progressInfo['FileSize'],
|
|
'FileCreateTime'=>empty($progressInfo['CreateTime']) ? $authTimestamp : $progressInfo['CreateTime'],
|
|
'UploadRatio'=>empty($progressInfo['UploadRatio']) ? 0 : $progressInfo['UploadRatio'],
|
|
'UploadId'=>empty($progressInfo['UploadId']) ? 0 : $progressInfo['UploadId'],
|
|
'DonePartsCount'=>empty($progressInfo['DonePartsCount']) ? 0 : $progressInfo['DonePartsCount'],
|
|
'PartSize'=>empty($progressInfo['PartSize']) ? 0 : $progressInfo['PartSize'],
|
|
'UploadPoint'=>$progressInfo['UploadPoint'], 'UploadAddress'=>$progressInfo['UploadAddress']
|
|
);
|
|
|
|
$url = (self::$isEnableSSL ? 'https://' : 'http://') . self::VOD_REPORT_URL;
|
|
HttpHelper::curl($url,'POST', $fields);
|
|
|
|
} catch (Exception $e) {
|
|
AliyunVodLog::printLog("reportUploadProgress failed, ErrorMessage: %s\n", $e->getMessage());
|
|
}
|
|
}
|
|
|
|
public static function generateFilePartHash($clientId, $filePath, $fileSize)
|
|
{
|
|
try {
|
|
$fp = @fopen(OssUtil::encodePath($filePath),"r");
|
|
$len = $fileSize <= self::REPORT_FILE_HASH_READ_LEN ? $fileSize : self::REPORT_FILE_HASH_READ_LEN;
|
|
$str = fread($fp, $len);
|
|
fclose($fp);
|
|
} catch (Exception $e) {
|
|
$str = sprintf("%s|%s|%s", $clientId, $filePath, @filemtime($filePath));
|
|
}
|
|
return md5($str);
|
|
}
|
|
|
|
}
|
|
|
|
|
|
class AliyunVodDownloader
|
|
{
|
|
public function __construct($saveLocalDir=null)
|
|
{
|
|
if (isset($saveLocalDir)) {
|
|
$this->saveLocalDir = $saveLocalDir;
|
|
}
|
|
else {
|
|
$this->saveLocalDir = dirname(__DIR__) . '/tmp_dlfiles/';
|
|
}
|
|
}
|
|
|
|
public function downloadFile($downloadUrl, $localFileName, $fileSize=null)
|
|
{
|
|
$localPath = $this->saveLocalDir . $localFileName;
|
|
AliyunVodLog::printLog("Download %s To %s", $downloadUrl, $localPath);
|
|
|
|
if (isset($fileSize)) {
|
|
$lsize = @filesize($localPath);
|
|
if ($lsize > 0 and $lsize == $fileSize) {
|
|
return $localPath;
|
|
}
|
|
}
|
|
if (!is_dir($this->saveLocalDir)) {
|
|
@mkdir($this->saveLocalDir, 0777, true);
|
|
}
|
|
|
|
$sfp = @fopen($downloadUrl, "rb");
|
|
if ($sfp === false) {
|
|
throw new Exception("download file fail while reading ".$downloadUrl,
|
|
AliyunVodError::VOD_ERR_FILE_DOWNLOAD);
|
|
}
|
|
|
|
$dfp = @fopen(OssUtil::encodePath($localPath), "ab+");
|
|
if ($sfp === false) {
|
|
throw new Exception("download file fail while writing ".$localPath,
|
|
AliyunVodError::VOD_ERR_FILE_DOWNLOAD);
|
|
}
|
|
while (!feof($sfp)) {
|
|
$contents = fread($sfp,8 * 1024);
|
|
fwrite($dfp, $contents);
|
|
}
|
|
|
|
fclose($sfp);
|
|
fclose($dfp);
|
|
|
|
return $localPath;
|
|
}
|
|
|
|
public function getSaveLocalDir() {
|
|
return $this->saveLocalDir;
|
|
}
|
|
|
|
public function setSaveLocalDir($localDir) {
|
|
return $this->saveLocalDir = $localDir;
|
|
}
|
|
|
|
private $saveLocalDir = null;
|
|
}
|
|
|
|
class AliyunVodError
|
|
{
|
|
const VOD_ERR_FILE_READ = 10000;
|
|
const VOD_ERR_FILE_DOWNLOAD = 10001;
|
|
const VOD_ERR_M3U8_FILE_REWRITE = 10002;
|
|
const VOD_INVALID_M3U8_SLICE_FILE = 10003;
|
|
} |