<?php
|
|
|
require_once 'autoload.php';
|
require_once 'Config.php';
|
|
use OSS\OssClient;
|
use OSS\Core\OssException;
|
|
|
class ossUpload {
|
|
const endpoint = Config::OSS_ENDPOINT;// img.douxu.com 图片服务器别名路径
|
const accessKeyId = Config::OSS_ACCESS_ID; //阿里OSS ACCESS
|
const accessKeySecret = Config::OSS_ACCESS_KEY;//阿里OSS ACCESSkey
|
const bucket = Config::OSS_TEST_BUCKET; //BUCKET 名称 即目录 或者 盘符
|
const userdomain = Config::OSS_USERDOMAIN; //图片配置域名（远程OSS 地址 image.douxu.com）
|
|
private $ossClient;
|
private $maxsize;
|
private $pic_type;
|
private $is_picself;
|
private $is_picthumb;
|
|
|
function __construct($paras = array()){
|
|
$this->maxsize = $paras['maxsize']; // 上传大小
|
$this->pic_type = $paras['pic_type']; // 图片类型
|
$this->is_picself = $paras['is_picself']; // 安全验证
|
$this->is_picthumb = $paras['is_picthumb']; // 强制压缩
|
//实例化 ossClient true为开启CNAME。CNAME是指将自定义域名绑定到存储空间上。
|
$this->ossClient = new OssClient(self::accessKeyId, self::accessKeySecret, self::endpoint, false);
|
}
|
/**
|
* 上传本地图片至 OSS
|
* $file 本地文件路径
|
* $dir OSS 目录名称
|
* $type 后缀名
|
* $thumb array crop 将图最长边限制在 100 像素，短边按比例处理
|
*/
|
public function uploadImg($file,$dir='img',$thumb=array()){
|
|
//根据本地文件路径获取后缀名
|
$imgType=end(@explode('.',$file['name']));
|
//判断后缀名是否合法
|
if(!$file['tmp_name']){
|
|
$returnMsg['msg'] = '未找到相关图片';
|
|
}elseif(!in_array(strtolower($imgType),$this->pic_type)){
|
|
$returnMsg['msg'] = '上传文件类型不符';
|
|
}elseif($file['size'] > $this->maxsize * 1024){//判断大小是否超限
|
|
$returnMsg['msg'] = '上传图片太大';
|
|
}else{
|
if($dir){
|
$dir.='/'.date('Ymd').'/';
|
}
|
|
//重置文件名称 时间戳+随机数
|
$newImgName =time().rand(1000,9999).'.'.$imgType;
|
|
$object = $dir.$newImgName;//OSS 新文件名称 可带目录 如 user com 。。
|
|
$filePath = $file['tmp_name'];//本地上传文件路径
|
|
try {
|
$this->ossClient->uploadFile(self::bucket, $object, $filePath);
|
//是否需要缩略 按传入长度取最长边长度，短边等比例压缩。
|
if(!empty($thumb['crop'])){
|
// 图片缩放
|
$newImgName =time().rand(1000,9999).'.'.$imgType;
|
|
$Newobject = $dir.$newImgName;//OSS 新文件名称
|
// 缩放图片格式。等比例缩放，最长边未$fbl
|
$style = "image/resize,l_". $thumb['crop'];
|
// 将处理后的图片转存到当前Bucket。
|
$process = $style. '|sys/saveas' . ',o_'.$this->base64url_encode($Newobject) . ',b_'.$this->base64url_encode(self::bucket);
|
|
$this->ossClient->processObject(self::bucket, $object, $process);
|
|
$this->delObject($object);
|
|
$object = $Newobject;
|
}
|
if (strpos($dir, 'logo') !== false){
|
$returnMsg['picurl'] = $object;
|
}else{
|
$returnMsg['picurl'] = './'.$object;
|
}
|
return $returnMsg;
|
|
} catch (OssException $e) {
|
//错误信息输出
|
$returnMsg['msg'] = $e->getMessage();
|
}
|
}
|
return $returnMsg;
|
}
|
|
|
/**
|
* 上传本地文件至 OSS
|
* $file 本地文件路径
|
* $dir OSS 目录名称
|
*/
|
public function uploadDoc($file,$dir='doc'){
|
|
//允许上传文件后缀
|
$upTypes=array('doc','docx','rar','zip','txt','xls');
|
|
//根据本地文件路径获取后缀名
|
$docType=end(@explode('.',$file['name']));
|
//判断后缀名是否合法
|
if(!$file['tmp_name']){
|
|
$returnMsg['error'] = '未找到相关文件';
|
|
}elseif(!in_array(strtolower($docType),$upTypes)){
|
|
$returnMsg['error'] = '仅允许上传 doc,docx,xls,rar,zip,txt格式文件';
|
|
}elseif($file['size']>10*1024*1024){//判断大小是否超限 限定10M
|
|
$returnMsg['error'] = '上传文件大小不能超过10M';
|
|
}else{
|
if($dir){
|
$dir.='/'.date('Ymd').'/';
|
}
|
//重置文件名称 时间戳+随机数
|
$newDocName =time().rand(1000,9999).'.'.$docType;
|
|
$object = $dir.$newDocName;//OSS 新文件名称 可带目录
|
|
|
$filePath = $file['tmp_name'];//本地上传文件路径
|
$options = array();//暂不需要，为空即可
|
|
try {
|
$this->ossClient->uploadFile(self::bucket, $object, $filePath, $options);
|
$returnMsg['docurl'] = '/'.$object;
|
|
} catch (OssException $e) {
|
//错误信息输出
|
$returnMsg['msg'] = $e->getMessage();
|
|
}
|
return $returnMsg;
|
}
|
|
}
|
/*删除文件
|
*$fileUrl:OSS 文件存储地址 如 img/xxxx.jpg
|
*$fileUrl： array 可传入数组形式 多文件删除
|
|
*/
|
public function delObject($fileUrl)
|
{
|
//批量删除多文件
|
if(is_array($fileUrl)){
|
$object=array();
|
foreach($fileUrl as $value){
|
//判断是否存储的缩略图格式 即带@ 符号
|
if(strstr($value,'@')){
|
$fileUrls = explode('@',$value);
|
$object[] = $fileUrls[0];
|
}else{
|
$object[] = $value;
|
}
|
}
|
if($object&&is_array($object)){
|
foreach($object as $k=>$v){
|
$v=str_replace('//','',$v);
|
if(substr($v,0,1)=='/'){
|
$v=substr($v,1);
|
}
|
$object[$k]=$v;
|
}
|
}
|
try{
|
$this->ossClient->deleteObjects(self::bucket, $object);
|
|
return true;
|
|
} catch(OssException $e) {
|
|
//return $returnMsg['error'] = $e->getMessage();//失败具体原因 仅供调试需要
|
return false;
|
|
}
|
}else{
|
|
//判断是否存储的缩略图格式 即带@ 符号
|
if(strstr($fileUrl,'@')){
|
$fileUrls = explode('@',$fileUrl);
|
$object = $fileUrls[0];
|
}else{
|
$object = $fileUrl;
|
}
|
$object=str_replace('//','',$object);
|
if(substr($object,0,1)=='/'){
|
$object=substr($object,1);
|
}
|
try{
|
$this->ossClient->deleteObject(self::bucket, $object);
|
|
return true;
|
|
} catch(OssException $e) {
|
|
//return $returnMsg['error'] = $e->getMessage();//失败具体原因 仅供调试需要
|
return false;
|
|
}
|
}
|
}
|
/*OSS 同项目内文件复制
|
* $from_object:源文件
|
* $to_object ：复制后新文件
|
*/
|
function copyObject($from_object, $to_object)
|
{
|
$to_object=str_replace('//','',$to_object);
|
if(substr($to_object,0,1)=='/'){
|
$to_object=substr($to_object,1);
|
}
|
$options = array();
|
try{
|
$this->ossClient->copyObject(self::bucket, $from_object, self::bucket, $to_object, $options);
|
|
|
//return $returnMsg['error'] = 'ok';
|
return true;
|
} catch(OssException $e) {
|
|
//return $returnMsg['error'] = $e->getMessage();
|
return false;
|
}
|
}
|
//图片裁剪 缩放 水印 等
|
function cutPic($img,$dir,$x,$y,$width,$height,$scale=1){
|
|
$object = $dir.'/'.date('Ymd').'/'.end(explode('/',$img));
|
|
//图片裁剪
|
if($dir){
|
$dir.='/'.date('Ymd').'/';
|
}
|
$imgType=end(@explode('.',$object));
|
//重置文件名称 时间戳+随机数
|
$newImgName =time().rand(1000,9999).'.'.$imgType;
|
|
$file = $dir.$newImgName;//OSS 新文件名称 可带目录
|
|
try {
|
// 自定义裁剪
|
$style = 'image/crop,w_'.$width.',h_'.$height.',x_'.$x.',y_'.$y;
|
// 将处理后的图片转存到当前Bucket。
|
$process = $style. '|sys/saveas' . ',o_'.$this->base64url_encode($file) . ',b_'.$this->base64url_encode(self::bucket);
|
|
$this->ossClient->processObject(self::bucket, $object, $process);
|
|
$returnMsg['picurl'] = './'.$file;
|
|
$this->delObject($object);
|
return $returnMsg;
|
} catch (OssException $e) {
|
|
//错误信息输出
|
$returnMsg['error'] = $e->getMessage();
|
|
return $returnMsg;
|
}
|
}
|
/**
|
* base64图片上传
|
* @param string $data base64
|
* @param string $dir 上传位置
|
* @return string
|
*/
|
function imageBase($data, $dir = 'img'){
|
|
preg_match('/^(data:\s*image\/(\w+);base64,)/', $data, $result);
|
|
$uimage = str_replace($result[1], '', str_replace('#','+',$data));
|
// 获取图片格式
|
if(in_array(strtolower($result[2]),$this->pic_type)){
|
$imgType = $result[2];
|
}else{
|
$imgType = 'jpg';
|
}
|
$new_file = time().rand(1000,9999).'.' . $imgType;
|
|
try {
|
$objdir = $dir.'/'.date('Ymd').'/';
|
$object = $objdir.$new_file;
|
// 使用字符串上传，将base64写到图片里
|
$this->ossClient->putObject(self::bucket, $object, base64_decode($uimage));
|
|
if (strpos($dir, 'logo') !== false){
|
$returnMsg['picurl'] = $object;
|
}else{
|
$returnMsg['picurl'] = './'.$object;
|
}
|
|
} catch (OssException $e) {
|
//错误信息输出
|
$returnMsg['msg'] = $e->getMessage();
|
}
|
|
return $returnMsg;
|
}
|
/**
|
* 上传本地图片至 OSS,用户编辑器内图片上传
|
* $file 本地文件路径
|
*/
|
public function uploadLocalImg($file)
|
{
|
if (strpos($file, 'data/upload') !== false){
|
|
$object = strstr($file, 'data/upload');
|
|
try {
|
|
$this->ossClient->uploadFile(self::bucket, $object, $file);
|
|
$returnMsg['picurl'] = './'.$object;
|
|
} catch (OssException $e) {
|
//错误信息输出
|
$returnMsg['msg'] = $e->getMessage();
|
|
}
|
return $returnMsg;
|
}
|
}
|
public function uploadVoice($file,$dir='voice'){
|
|
|
$fileType=end(@explode('.',$file['name']));
|
if(!$file['tmp_name']){
|
|
$returnMsg['msg'] = '录音文件不存在，请重试';
|
|
}else{
|
if($dir){
|
$dir.='/'.date('Ymd').'/';
|
}
|
$newVoiceName =time().rand(1000,9999).'.'.$fileType;
|
|
$object = $dir.$newVoiceName;
|
|
|
$filePath = $file['tmp_name'];
|
$options = array();
|
|
try {
|
$this->ossClient->uploadFile(self::bucket, $object, $filePath, $options);
|
$returnMsg['voiceurl'] = '/'.$object;
|
|
} catch (OssException $e) {
|
$returnMsg['msg'] = $e->getMessage();
|
|
}
|
return $returnMsg;
|
}
|
}
|
private function base64url_encode($data)
|
{
|
return rtrim(strtr(base64_encode($data), '+/', '-_'), '=');
|
}
|
}
|
?>
|
