109 lines
3.5 KiB
PHP
109 lines
3.5 KiB
PHP
<?php
|
||
|
||
namespace app\common\services;
|
||
|
||
use app\common\services\aliyunoss\OssClient;
|
||
use app\common\services\aliyunoss\Core\OssException;
|
||
|
||
class AliOss
|
||
{
|
||
protected $accessKeyId;
|
||
protected $accessKeySecret;
|
||
protected $endpoint;
|
||
protected $bucket;
|
||
protected $ossClient;
|
||
|
||
public function __construct($accessKeyId, $accessKeySecret, $endpoint)
|
||
{
|
||
$this->accessKeyId = $accessKeyId;
|
||
$this->accessKeySecret = $accessKeySecret;
|
||
$this->endpoint = $endpoint;
|
||
// $bucket = $bucket;
|
||
}
|
||
public function upload($object, $content, $bucket)
|
||
{
|
||
try{
|
||
$ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
|
||
|
||
$res = $ossClient->putObject($bucket, $object, $content);
|
||
if ($res['info']) {
|
||
|
||
}
|
||
$data = $ossClient->getObjectMeta($bucket, $object);
|
||
|
||
return $data;
|
||
|
||
} catch(OssException $e) {
|
||
|
||
printf($e->getMessage() . "\n");
|
||
return $e->getMessage();
|
||
}
|
||
}
|
||
|
||
public function checkBucket($bucket)
|
||
{
|
||
$ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
|
||
|
||
$res = $ossClient->listBuckets($bucket);
|
||
|
||
return $res;
|
||
}
|
||
|
||
public function getObject($object)
|
||
{
|
||
try {
|
||
$ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
|
||
$res = $ossClient->getobject($bucket, $object);
|
||
return $res;
|
||
} catch (OssException $e) {
|
||
return $e->getMessage();
|
||
}
|
||
}
|
||
|
||
public function PutBucketPublicRead()
|
||
{
|
||
try {
|
||
$ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
|
||
$res = $ossClient->putBucketAcl($bucket, 'public-read');
|
||
return $res;
|
||
} catch (OssException $e) {
|
||
return $e->getMessage();
|
||
}
|
||
}
|
||
public function PutBucketPrivate()
|
||
{
|
||
$ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
|
||
$res = $ossClient->putBucketAcl($bucket, 'private');
|
||
return $res;
|
||
}
|
||
public function upCallBack($object)
|
||
{
|
||
$ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
|
||
|
||
// 上传文件时设置回调。
|
||
// callbackUrl为回调服务器地址，如http://oss-demo.aliyuncs.com:23450或http://127.0.0.1:9090。
|
||
//callbackHost为回调请求消息头中Host的值，如oss-cn-hangzhou.aliyuncs.com。
|
||
$url =
|
||
'{
|
||
"callbackUrl": {$callbackUrl}",
|
||
"callbackHost":"{$callbackHost}",
|
||
"callbackBody":
|
||
"bucket={$bucket}&object={$object}&etag=${etag}&size=${size}&mimeType=${mimeType}&imageInfo.height=${imageInfo.height}&imageInfo.width=${imageInfo.width}&imageInfo.format=${imageInfo.format}&my_var1=${x:var1}&my_var2=${x:var2}",
|
||
"callbackBodyType":"application/x-www-form-urlencoded"
|
||
}';
|
||
|
||
// 设置发起回调请求的自定义参数，由Key和Value组成，Key必须以x:开始。
|
||
$var =
|
||
'{
|
||
"x:var1":"value1",
|
||
"x:var2":"值2"
|
||
}';
|
||
$options = array(OssClient::OSS_CALLBACK => $url,
|
||
OssClient::OSS_CALLBACK_VAR => $var
|
||
);
|
||
$result = $ossClient->putObject($bucket, $object, file_get_contents(__FILE__), $options);
|
||
print_r($result['body']);
|
||
print_r($result['info']['http_code']);
|
||
}
|
||
|
||
} |