<?php
// config/minio.php
return [
    // MinIO服务地址（含端口，本地默认9000）
    'endpoint' => env('MINIO_ENDPOINT', 'http://192.168.20.147:9000'),
    // 是否使用路径风格（MinIO推荐开启，自托管场景必备）
    'use_path_style_endpoint' => true,
    // 认证信息（MinIO控制台创建的Access Key和Secret Key）
    'credentials' => [
        'key' => env('MINIO_ACCESS_KEY', '5QEARuEh9VzSusd9qCAO'),
        'secret' => env('MINIO_SECRET_KEY', 'TO6TdWpTpkldCyvaov69XBf6EcOvuQGoVyDkXYOW'),
    ],
    // 区域（MinIO可随意填写，非必填但不能为空，示例：us-east-1）
    'region' => env('MINIO_REGION', 'us-east-1'),
    // 是否启用SSL（本地测试默认false，生产环境根据配置调整）
    'ssl.certificate_authority' => env('MINIO_SSL', false),
    // 默认存储桶（需提前在MinIO控制台创建）
    'bucket' => env('MINIO_BUCKET', 'articleinnerimg'),
];

// 读取MinIO配置
$config = config('minio');

// 初始化S3客户端（MinIO兼容S3协议）
$s3Client = new S3Client([
    'endpoint' => $config['endpoint'],
    'use_path_style_endpoint' => $config['use_path_style_endpoint'],
    'credentials' => $config['credentials'],
    'region' => $config['region'],
]);

// 构建文件索引（Key）：含目录结构+唯一文件名
$filename = "DemoFile/20251118/" . uniqid() . "_" . $originalName;

// 上传文件到MinIO
$result = $s3Client->putObject([
    'Bucket' => $config['bucket'], // 存储桶名称
    'Key' => $filename, // 文件索引（含目录结构，模拟文件夹）
    'Body' => fopen($imgFile->getPathname(), 'r'), // 文件流
    'ContentType' => $imgFile->getMime(), // 文件MIME类型
]);

// 构建可访问URL（MinIO地址+存储桶+文件索引）
$fileUrl = $config['endpoint'] . '/' . $config['bucket'] . '/' . $filename;

<?php
namespace app\controller;

use think\facade\Request;
use think\facade\Config;
use Aws\S3\S3Client;
use Aws\Exception\AwsException;

class DemoController
{
    /**
     * 显示上传页面
     */
    public function upload()
    {
        return view("demo/upload");
    }

    /**
     * 处理图片上传（支持目录分级存储）
     * @param string $prefix 一级目录前缀（默认：DemoFile）
     * @return \think\response\Json
     */
    public function img(string $prefix = "DemoFile")
    {
        // 1. 获取上传文件
        $imgFile = Request::file("image");
        if (!$imgFile) {
            return json(['code' => 1, 'msg' => '请选择文件']);
        }
        if (!$imgFile->isValid()) {
            return json(['code' => 1, 'msg' => '文件无效：' . $imgFile->getError()]);
        }

        try {
            // 2. 读取MinIO配置
            $config = Config::get('minio');

            // 3. 初始化S3客户端
            $s3Client = new S3Client([
                'endpoint' => $config['endpoint'],
                'use_path_style_endpoint' => $config['use_path_style_endpoint'],
                'credentials' => $config['credentials'],
                'region' => $config['region'],
            ]);

            // 4. 构建文件路径（分级存储：前缀/日期/唯一文件名）
            $originalName = basename($imgFile->getOriginalName()); // 原始文件名（去除路径）
            $dateDir = date('Ymd'); // 按日期创建二级目录
            $dirPath = "{$prefix}/{$dateDir}/"; // 完整目录路径
            $filename = $dirPath . uniqid() . '_' . $originalName; // 最终文件索引（Key）

            // 5. 上传文件到MinIO
            $s3Client->putObject([
                'Bucket' => $config['bucket'],
                'Key' => $filename,
                'Body' => fopen($imgFile->getPathname(), 'r'),
                'ContentType' => $imgFile->getMime(),
            ]);

            // 6. 构建可访问URL
            $fileUrl = $config['endpoint'] . '/' . $config['bucket'] . '/' . $filename;

            // 7. 返回结果
            return json([
                'code' => 0,
                'msg' => '上传成功',
                'data' => [
                    'url' => $fileUrl,
                    'filename' => $filename // 存储文件索引（用于后续删除/下载）
                ]
            ]);

        } catch (AwsException $e) {
            // 捕获AWS SDK异常
            return json(['code' => 1, 'msg' => '上传失败：' . $e->getMessage()]);
        } catch (\Exception $e) {
            // 捕获其他异常
            return json(['code' => 1, 'msg' => '系统异常：' . $e->getMessage()]);
        }
    }
}

/**
 * 删除MinIO中的图片
 * @param string $key 文件索引（含目录结构，如：DemoFile/20251118/691c71a48050d_xxx.png）
 * @return \think\response\Json
 */
public function deleteImg(string $key)
{
    // 校验Key是否为空
    if (empty($key)) {
        return json(['code' => 1, 'msg' => '请传入要删除的文件Key']);
    }

    try {
        $config = Config::get('minio');
        $s3Client = new S3Client([
            'endpoint' => $config['endpoint'],
            'use_path_style_endpoint' => $config['use_path_style_endpoint'],
            'credentials' => $config['credentials'],
            'region' => $config['region'],
        ]);

        // 执行删除操作
        $result = $s3Client->deleteObject([
            'Bucket' => $config['bucket'],
            'Key' => $key // 必须传递完整的文件索引（含目录）
        ]);

        // 校验删除结果（204表示删除成功）
        if ($result->get('@metadata')['statusCode'] === 204) {
            return json(['code' => 0, 'msg' => '图片删除成功']);
        } else {
            return json(['code' => 1, 'msg' => '图片删除失败，状态异常']);
        }

    } catch (AwsException $e) {
        return json(['code' => 1, 'msg' => '删除失败：' . $e->getMessage()]);
    }
}

/**
 * 下载MinIO中的图片
 * @param string $key 文件索引（含目录结构）
 * @param string|null $downloadName 自定义下载文件名（默认使用原始文件名）
 * @return \think\response\Json|\think\response\Response
 */
public function downloadImg(string $key, ?string $downloadName = null)
{
    // 校验Key是否为空
    if (empty($key)) {
        return json(['code' => 1, 'msg' => '请传入要下载的文件Key']);
    }

    try {
        $config = Config::get('minio');
        $s3Client = new S3Client([
            'endpoint' => $config['endpoint'],
            'use_path_style_endpoint' => $config['use_path_style_endpoint'],
            'credentials' => $config['credentials'],
            'region' => $config['region'],
        ]);

        // 获取文件对象
        $result = $s3Client->getObject([
            'Bucket' => $config['bucket'],
            'Key' => $key
        ]);

        // 处理下载文件名（默认使用Key中的原始文件名）
        if (empty($downloadName)) {
            $downloadName = basename($key);
        }

        // 获取文件MIME类型（用于响应头）
        $mimeType = $result->get('ContentType') ?? 'application/octet-stream';
        // 获取文件内容
        $fileContent = (string)$result->get('Body');

        // 构建响应（触发浏览器下载）
        $response = response($fileContent)
            ->header('Content-Type', $mimeType)
            ->header('Content-Disposition', 'attachment; filename="' . rawurlencode($downloadName) . '"')
            ->header('Content-Length', strlen($fileContent));

        return $response;

    } catch (AwsException $e) {
        return json(['code' => 1, 'msg' => '下载失败：' . $e->getMessage()]);
    }
}