|
|
<?php
|
|
|
|
|
|
namespace ali\oss;
|
|
|
|
|
|
use OSS\OssClient;
|
|
|
use OSS\Core\OssException;
|
|
|
use think\facade\Request;
|
|
|
|
|
|
class Oss extends Base
|
|
|
{
|
|
|
|
|
|
/**
|
|
|
* 文件上传（简单上传）
|
|
|
* @param string $local_file_path 本地存储路径，填写的时候以'./'开头
|
|
|
* @param string $oss_file_dirname 存放文件的文件夹层级
|
|
|
* @param string $oss_file_name 文件名 object路径为 $file_dirname + '/' + $file_name
|
|
|
* @param boolean $is_delete_file 上传成功之后是否删除源文件(false--不删除 true--删除)，本地调试时无法删除
|
|
|
* @date 2022-06-27
|
|
|
*/
|
|
|
function uploadFile($local_file_path, $oss_file_dirname, $oss_file_name = '', $is_delete_file = true)
|
|
|
{
|
|
|
// 上传到OSS的文件没有指定文件名，自动生成
|
|
|
if (empty($oss_file_name)) {
|
|
|
// 文件名为当前微秒加密
|
|
|
$oss_file_name = md5(microtime(true));
|
|
|
|
|
|
// 获取后缀名
|
|
|
$suffix = get_suffix($local_file_path);
|
|
|
|
|
|
// 文件名
|
|
|
$oss_file_name .= '.' . $suffix;
|
|
|
}
|
|
|
|
|
|
// 上传到OSS的文件指定文件名，只需拼接项目文件夹
|
|
|
$object = $this->config['first_directory'] . '/' . $oss_file_dirname . '/' . $oss_file_name;
|
|
|
|
|
|
$options = [];
|
|
|
|
|
|
// 如果上传文件之后需要删除源文件，上传文件时设置回调
|
|
|
if ($is_delete_file) {
|
|
|
$url = [
|
|
|
// callbackUrl为回调服务器地址
|
|
|
'callbackUrl' => Request::domain() . '/index.php/base/oss/platform/Callback/uploadCallback',
|
|
|
// 发起回调时请求body的值，支持OSS系统变量、自定义变量和常量
|
|
|
'callbackBody' => 'bucket=${bucket}&object=${object}&file_path=${x:file_path}',
|
|
|
// 发起回调请求的Content-Type
|
|
|
'callbackBodyType' => 'application/x-www-form-urlencoded'
|
|
|
];
|
|
|
$url = json_encode($url);
|
|
|
|
|
|
// 设置发起回调请求的自定义参数，由Key和Value组成，Key必须以x:开始。会将这些参数和上述的系统参数一起放在POST请求的body中以方便接收回调方获取。
|
|
|
$var = [
|
|
|
'x:file_path' => $local_file_path
|
|
|
];
|
|
|
$var = json_encode($var);
|
|
|
|
|
|
$options = [
|
|
|
OssClient::OSS_CALLBACK => $url,
|
|
|
OssClient::OSS_CALLBACK_VAR => $var
|
|
|
];
|
|
|
}
|
|
|
|
|
|
try {
|
|
|
// 初始化
|
|
|
$ossClient = $this->createClient();
|
|
|
|
|
|
// 上传文件 - 简单上传
|
|
|
$result = $ossClient->uploadFile($this->config['bucket'], $object, $local_file_path, $options);
|
|
|
|
|
|
// 记录日志
|
|
|
$uid = defined('UID') ? UID : '';
|
|
|
platformLog([
|
|
|
'bucket' => $this->config['bucket'],
|
|
|
'object' => $object,
|
|
|
'local_file_path' => $local_file_path,
|
|
|
'is_delete_file' => true
|
|
|
], $result, 'ali_oss_upload_file_uid_' . $uid);
|
|
|
|
|
|
// 返回成功数据
|
|
|
return $result['info'];
|
|
|
} catch (OssException $e) {
|
|
|
// 返回报错
|
|
|
$result['Code'] = 5000;
|
|
|
$result['Message'] = $e->getMessage();
|
|
|
|
|
|
// 记录日志
|
|
|
$uid = defined('UID') ? UID : '';
|
|
|
platformLog([
|
|
|
'bucket' => $this->config['bucket'],
|
|
|
'object' => $object,
|
|
|
'local_file_path' => $local_file_path,
|
|
|
'is_delete_file' => true
|
|
|
], $result, 'ali_oss_upload_file_uid_' . $uid);
|
|
|
|
|
|
// 返回错误数据
|
|
|
return $result;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 将object下载到服务器指定的文件
|
|
|
* @param string $object object（开头没有'/'）
|
|
|
* @param string $local_file_url 本地存储路径，填写的时候以'./'开头
|
|
|
* @date 2022-12-08
|
|
|
*/
|
|
|
public function getObject($object, $local_file_url = '')
|
|
|
{
|
|
|
// 判断$object是否为带http连接的全路径
|
|
|
if (strpos($object, 'https://') !== false || strpos($object, 'http://') !== false) {
|
|
|
// 分割字符串
|
|
|
$array = explode('://', $object);
|
|
|
|
|
|
// 获取第1个/之后的字符串即为$object
|
|
|
$index = strpos($array[1], '/');
|
|
|
$object = substr($array[1], $index + 1);
|
|
|
}
|
|
|
|
|
|
// 获取文件后缀名
|
|
|
$suffix = get_suffix($object);
|
|
|
|
|
|
// 没有定义本地存储路径的时候，自动生成文件保存的本地路径
|
|
|
if (!$local_file_url) {
|
|
|
$local_file_url = './temp/' . md5(microtime(true)) . '.' . $suffix;
|
|
|
}
|
|
|
|
|
|
// 没有文件夹则先生成
|
|
|
create_directory($local_file_url);
|
|
|
|
|
|
$options = [
|
|
|
// 指定本地路径
|
|
|
OssClient::OSS_FILE_DOWNLOAD => $local_file_url
|
|
|
];
|
|
|
|
|
|
try {
|
|
|
// 初始化
|
|
|
$ossClient = $this->createClient();
|
|
|
|
|
|
// 下载文件
|
|
|
$result = $ossClient->getObject($this->config['bucket'], $object, $options);
|
|
|
|
|
|
// 记录日志
|
|
|
$uid = defined('UID') ? UID : '';
|
|
|
platformLog([
|
|
|
'bucket' => $this->config['bucket'],
|
|
|
'object' => $object,
|
|
|
'local_file_url' => $local_file_url,
|
|
|
'domain_local_file_url' => Request::domain(true) . substr($local_file_url, 1)
|
|
|
], $result, 'ali_oss_get_object_uid_' . $uid);
|
|
|
|
|
|
// 返回成功数据
|
|
|
return [
|
|
|
// 本地路径
|
|
|
'local_file_url' => $local_file_url,
|
|
|
// 带域名的本地路径
|
|
|
'domain_local_file_url' => Request::domain(true) . substr($local_file_url, 1)
|
|
|
];
|
|
|
} catch (OssException $e) {
|
|
|
// 返回报错
|
|
|
$result['Code'] = 5000;
|
|
|
$result['Message'] = $e->getMessage();
|
|
|
|
|
|
// 记录日志
|
|
|
$uid = defined('UID') ? UID : '';
|
|
|
platformLog([
|
|
|
'bucket' => $this->config['bucket'],
|
|
|
'object' => $object,
|
|
|
'local_file_url' => $local_file_url,
|
|
|
'domain_local_file_url' => Request::domain(true) . substr($local_file_url, 1)
|
|
|
], $result, 'ali_oss_get_object_uid_' . $uid);
|
|
|
|
|
|
// 返回错误数据
|
|
|
return $result;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
/**
|
|
|
* 删除oss文件
|
|
|
* @param string $object object路径，已包含项目文件夹路径
|
|
|
* @date 2022-12-08
|
|
|
*/
|
|
|
function deleteObject($object)
|
|
|
{
|
|
|
// 判断$object是否为带http连接的全路径
|
|
|
if (strpos($object, 'https://') !== false || strpos($object, 'http://') !== false) {
|
|
|
// 分割字符串
|
|
|
$array = explode('://', $object);
|
|
|
|
|
|
// 获取第1个/之后的字符串即为$object
|
|
|
$index = strpos($array[1], '/');
|
|
|
$object = substr($array[1], $index + 1);
|
|
|
}
|
|
|
|
|
|
try {
|
|
|
// 初始化
|
|
|
$ossClient = $this->createClient();
|
|
|
|
|
|
// 删除文件
|
|
|
$result = $ossClient->deleteObject($this->config['bucket'], $object);
|
|
|
|
|
|
// 记录日志
|
|
|
$uid = defined('UID') ? UID : '';
|
|
|
platformLog([
|
|
|
'bucket' => $this->config['bucket'],
|
|
|
'object' => $object
|
|
|
], $result, 'ali_oss_delete_object_uid_' . $uid);
|
|
|
|
|
|
// 返回成功数据
|
|
|
return $result['info'];
|
|
|
} catch (OssException $e) {
|
|
|
// 返回报错
|
|
|
$result['Code'] = 5000;
|
|
|
$result['Message'] = $e->getMessage();
|
|
|
|
|
|
// 记录日志
|
|
|
$uid = defined('UID') ? UID : '';
|
|
|
platformLog([
|
|
|
'bucket' => $this->config['bucket'],
|
|
|
'object' => $object
|
|
|
], $result, 'ali_oss_delete_object_uid_' . $uid);
|
|
|
|
|
|
// 返回错误数据
|
|
|
return $result;
|
|
|
}
|
|
|
}
|
|
|
}
|
