<?php
declare(strict_types=1);
* +----------------------------------------------------------------------
* | ThinkAdmin Plugin for ThinkAdmin
* +----------------------------------------------------------------------
* | 版权所有 2014~2026 ThinkAdmin [ thinkadmin.top ]
* +----------------------------------------------------------------------
* | 官方网站: https://thinkadmin.top
* +----------------------------------------------------------------------
* | 开源协议 ( https://mit-license.org )
* | 免责声明 ( https://thinkadmin.top/disclaimer )
* | 会员特权 ( https://thinkadmin.top/vip-introduce )
* +----------------------------------------------------------------------
* | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
* | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
* +----------------------------------------------------------------------
*/
namespace think\admin\storage;
use think\admin\contract\StorageInterface;
use think\admin\contract\StorageUsageTrait;
use think\admin\Exception;
use think\admin\extend\HttpExtend;
use think\admin\Storage;
* Alist 自建存储支持
* @class AlistStorage
*/
class AlistStorage implements StorageInterface
{
use StorageUsageTrait;
* 用户账号.
* @var string
*/
protected $username;
* 用户密码
* @var string
*/
protected $password;
* 保存路径.
* @var string
*/
protected $savepath;
* 缓存前缀
* @var string
*/
protected $cachekey;
* 上传文件内容.
* @param string $name 文件名称
* @param string $file 文件内容
* @param bool $safe 安全模式
* @param ?string $attname 下载名称
* @throws Exception
*/
public function set(string $name, string $file, bool $safe = false, ?string $attname = null): array
{
$file = ['field' => 'file', 'name' => $name, 'content' => $file];
$header = ["Authorization: {$this->token()}", 'file-path:' . urlencode($this->real($name))];
$result = HttpExtend::submit("{$this->domain}/api/fs/form", [], $file, $header, 'PUT', false);
if (is_array($data = json_decode($result, true))) {
if ($data['code'] === 200 && $data['message'] === 'success') {
return $this->info($name, $safe);
}
throw new Exception($data['message'] ?? '接口请求失败！', intval($data['code'] ?? 0));
}
return [];
}
* 读取文件内容.
* @param string $name 文件名称
* @param bool $safe 安全模式
*/
public function get(string $name, bool $safe = false): string
{
return Storage::curlGet($this->url($name, $safe));
}
* 删除存储文件.
* @param string $name 文件名称
* @param bool $safe 安全模式
*/
public function del(string $name, bool $safe = false): bool
{
try {
$path = $this->real($this->delSuffix($name));
$data = ['dir' => dirname($path) ?: '/', 'names' => [basename($path)]];
$this->httpPost('/api/fs/remove', $data);
return true;
} catch (\Exception $exception) {
return false;
}
}
* 判断是否存在.
* @param string $name 文件名称
* @param bool $safe 安全模式
*/
public function has(string $name, bool $safe = false): bool
{
try {
$this->httpPost('/api/fs/get', [
'path' => $this->real($name),
]);
return true;
} catch (\Exception $exception) {
return false;
}
}
* 获取文件下载链接.
*/
public function url(string $name, bool $safe = false, ?string $attname = null): string
{
$path = rtrim($this->userPath(), '\/') . $this->real($name);
return "{$this->domain}/d{$this->delSuffix($path)}{$this->getSuffix($attname, $path)}";
}
* 获取存储路径.
* @param string $name 文件名称
* @param bool $safe 安全模式
*/
public function path(string $name, bool $safe = false): string
{
return $this->url($name, $safe);
}
* 获取文件信息.
* @param string $name 文件名称
* @param bool $safe 安全模式
* @param ?string $attname 下载名称
*/
public function info(string $name, bool $safe = false, ?string $attname = null): array
{
return $this->has($name, $safe) ? [
'key' => $name,
'url' => $this->url($name, $safe, $attname),
'file' => $this->path($name, $safe),
] : [];
}
* 获取上传地址
*/
public function upload(): string
{
return "{$this->domain}/api/fs/form";
}
* 获取存储区域
*/
public static function region(): array
{
return [];
}
* 转换为绝对路径.
*/
public function real(string $path): string
{
return "/{$this->savepath}" . trim($path, '\/');
}
* 获取用户 Token 信息.
* @throws Exception
*/
public function token(bool $force = false): string
{
try {
$skey = "{$this->cachekey}.token";
if (empty($force) && ($token = $this->app->cache->get($skey))) {
return $token;
}
$data = ['Password' => $this->password, 'Username' => $this->username];
$body = $this->httpPost('/api/auth/login', $data, false);
if (!empty($body['data']['token'])) {
$this->app->cache->set($skey, $body['data']['token'], 60);
return $body['data']['token'];
}
throw new Exception('获取用户 Token 失败！');
} catch (\Exception $exception) {
throw new Exception($exception->getMessage());
}
}
* 存储引擎初始化.
* @throws Exception
*/
protected function init()
{
$host = strtolower(sysconf('storage.alist_http_domain|raw'));
$type = strtolower(sysconf('storage.alist_http_protocol|raw'));
if (!empty($host) && $type === 'auto') {
$this->domain = "//{$host}";
} elseif (!empty($host) && in_array($type, ['http', 'https'])) {
$this->domain = "{$type}://{$host}";
} else {
throw new Exception(lang('未配置Alist域名'));
}
$this->username = sysconf('storage.alist_username|raw') ?: '';
$this->password = sysconf('storage.alist_password|raw') ?: '';
$this->savepath = trim(sysconf('storage.alist_savepath|raw') ?: '', '\/');
$this->savepath = $this->savepath ? "{$this->savepath}/" : '';
$this->cachekey = md5($this->domain . $this->username . $this->password);
}
* 创建目录.
*/
protected function mkdir(string $path): bool
{
try {
$this->httpPost('/api/fs/mkdir', [
'path' => $this->real($path),
]);
return true;
} catch (\Exception $exception) {
return false;
}
}
* 获取基础路径.
*/
private function userPath(): string
{
try {
$skey = "{$this->cachekey}.path";
if ($path = $this->app->cache->get($skey)) {
return $path;
}
$data = $this->httGet('/api/me');
if (empty($data['data']['base_path'])) {
return '/';
}
$path = trim($data['data']['base_path'], '\/');
$this->app->cache->set($skey, $path = $path ? "/{$path}/" : '/', 60);
return $path;
} catch (\Exception $exception) {
return "/{$this->savepath}";
}
}
* Get 提交数据.
* @throws Exception
*/
private function httGet(string $uri): array
{
$header = ["Authorization: {$this->token()}"];
$header[] = 'Content-Type: application/json;charset=UTF-8';
$result = HttpExtend::get($this->domain . $uri, [], ['headers' => $header]);
if (is_array($data = json_decode($result, true))) {
if ($data['code'] === 200 && $data['message'] === 'success') {
return $data;
}
throw new Exception($data['message'] ?? '接口请求失败！', intval($data['code'] ?? 0));
}
throw new Exception('接口请求失败！');
}
* POST 提交数据.
* @throws Exception
*/
private function httpPost(string $uri, array $body = [], bool $auth = true): array
{
$body = json_encode($body, JSON_UNESCAPED_UNICODE);
$header = $auth ? ["Authorization: {$this->token()}"] : [];
$header[] = 'Content-Type: application/json;charset=UTF-8';
$result = HttpExtend::post($this->domain . $uri, $body, ['headers' => $header]);
if (is_array($data = json_decode($result, true))) {
if ($data['code'] === 200 && $data['message'] === 'success') {
return $data;
}
throw new Exception($data['message'] ?? '接口请求失败！', intval($data['code'] ?? 0));
}
throw new Exception('接口请求失败！');
}
}
