阿里云 OSS 教程

// lib/oss.ts
import OSS from 'ali-oss';

// OSS 客户端配置
export const ossClient = new OSS({
  region: process.env.OSS_REGION!, // 例如：'oss-rg-china-mainland'
  accessKeyId: process.env.OSS_ACCESS_KEY_ID!,
  accessKeySecret: process.env.OSS_ACCESS_KEY_SECRET!,
  bucket: process.env.OSS_BUCKET!, // 例如：'next-static-oss'
});

// 获取文件 URL
export function getOSSUrl(filename: string): string {
  return `${process.env.BASE_OSS_URL}/${filename}`;
}

// 生成唯一文件名
export function generateUniqueFilename(originalName: string): string {
  const timestamp = Date.now();
  const random = Math.random().toString(36).substring(2);
  const extension = originalName.split('.').pop();
  return `${timestamp}-${random}.${extension}`;
}

// 文件上传工具类
export class OSSManager {
  // 上传文件
  static async uploadFile(
    file: File | Buffer,
    filename: string,
    options?: {
      folder?: string;
      metadata?: Record<string, string>;
    }
  ): Promise<{ url: string; filename: string }> {
    try {
      const { folder = '', metadata = {} } = options || {};
      const fullPath = folder ? `${folder}/${filename}` : filename;

      const result = await ossClient.put(fullPath, file, {
        meta: {
          ...metadata,
          uploadTime: new Date().toISOString(),
        }
      });

      return {
        url: result.url,
        filename: fullPath
      };
    } catch (error) {
      console.error('OSS upload error:', error);
      throw new Error('文件上传失败');
    }
  }

  // 删除文件
  static async deleteFile(filename: string): Promise<boolean> {
    try {
      await ossClient.delete(filename);
      return true;
    } catch (error) {
      console.error('OSS delete error:', error);
      return false;
    }
  }

  // 批量删除文件
  static async deleteFiles(filenames: string[]): Promise<void> {
    try {
      await ossClient.deleteMulti(filenames);
    } catch (error) {
      console.error('OSS batch delete error:', error);
      throw new Error('批量删除失败');
    }
  }

  // 检查文件是否存在
  static async fileExists(filename: string): Promise<boolean> {
    try {
      await ossClient.head(filename);
      return true;
    } catch (error) {
      return false;
    }
  }

  // 获取文件信息
  static async getFileInfo(filename: string) {
    try {
      const result = await ossClient.head(filename);
      return {
        size: parseInt(result.res.headers['content-length'] || '0'),
        contentType: result.res.headers['content-type'],
        lastModified: result.res.headers['last-modified'],
        etag: result.res.headers.etag,
      };
    } catch (error) {
      throw new Error('获取文件信息失败');
    }
  }
}

// app/api/upload/route.ts
import { NextRequest, NextResponse } from 'next/server';
import { OSSManager, generateUniqueFilename } from '@/lib/oss';

export async function POST(request: NextRequest) {
  try {
    const formData = await request.formData();
    const file = formData.get('file') as File;
    const folder = formData.get('folder') as string || 'uploads';

    if (!file) {
      return NextResponse.json(
        { error: '未选择文件' },
        { status: 400 }
      );
    }

    // 检查文件类型
    const allowedTypes = ['image/jpeg', 'image/png', 'image/webp', 'application/pdf'];
    if (!allowedTypes.includes(file.type)) {
      return NextResponse.json(
        { error: '不支持的文件类型' },
        { status: 400 }
      );
    }

    // 检查文件大小 (5MB)
    const maxSize = 5 * 1024 * 1024;
    if (file.size > maxSize) {
      return NextResponse.json(
        { error: '文件大小超过限制' },
        { status: 400 }
      );
    }

    // 生成唯一文件名
    const filename = generateUniqueFilename(file.name);

    // 转换 File 为 Buffer
    const arrayBuffer = await file.arrayBuffer();
    const buffer = Buffer.from(arrayBuffer);

    // 上传到 OSS
    const result = await OSSManager.uploadFile(buffer, filename, {
      folder,
      metadata: {
        originalName: file.name,
        size: file.size.toString(),
        type: file.type,
      }
    });

    return NextResponse.json({
      success: true,
      data: {
        filename: result.filename,
        url: result.url,
        originalName: file.name,
        size: file.size,
        type: file.type,
      }
    });
  } catch (error) {
    console.error('Upload error:', error);
    return NextResponse.json(
      { error: '上传失败' },
      { status: 500 }
    );
  }
}