设计一个网盘或文件存储服务

客户端 ── ① 申请上传（文件名、大小、内容哈希）──> 文件服务（无状态）
          │ 哈希已存在：秒传，只写元数据
          │ 不存在：在对象存储创建分片上传，签发每个分片的预签名 URL
客户端 ── ② 并发上传分片（直传，不经过文件服务）──> 对象存储
客户端 ── ③ 完成上传 ──> 文件服务：通知对象存储合并 → 校验 → 写 blob、用户文件，扣配额

下载：客户端 ──> 文件服务（鉴权）──> 返回预签名 URL 或 CDN 地址 ──> CDN ──回源──> 对象存储
元数据：MySQL（按 user_id 分片）+ Redis（目录列表缓存、上传进度）
异步：缩略图和转码、病毒和内容扫描、引用为 0 的 blob 延迟删除、过期分享清理

CREATE TABLE file_blob (                 -- 一份实际内容，多个用户文件可以共用
  id          BIGINT PRIMARY KEY,
  hash        CHAR(64) NOT NULL UNIQUE,  -- 内容的 SHA-256
  size        BIGINT NOT NULL,
  storage_key VARCHAR(255) NOT NULL,     -- 在对象存储里的 key
  ref_count   INT NOT NULL DEFAULT 0,
  status      VARCHAR(16) NOT NULL       -- ACTIVE / DELETING
);
CREATE TABLE user_file (                 -- 用户看到的文件和目录，按 user_id 分片
  id         BIGINT PRIMARY KEY,
  user_id    BIGINT NOT NULL,
  parent_id  BIGINT NOT NULL,            -- 所在目录，0 表示根目录
  name       VARCHAR(255) NOT NULL,
  is_dir     TINYINT NOT NULL,
  blob_id    BIGINT,                     -- 目录没有内容
  size       BIGINT NOT NULL DEFAULT 0,
  deleted_at DATETIME,                   -- 放进回收站的时间
  UNIQUE KEY uk_name (user_id, parent_id, name)  -- 同一目录下不重名
);
-- 另有 upload_task（上传任务和已完成的分片）、share（分享）、user_quota（已用和总配额）

export async function addFileByHash(pool, { userId, parentId, name, hash }) {
  const conn = await pool.getConnection()
  try {
    await conn.beginTransaction()
    const [[blob]] = await conn.query("SELECT id, size FROM file_blob WHERE hash = ? AND status = 'ACTIVE'", [hash])
    // 条件更新：清理任务可能刚把这个 blob 标记为删除中，这时不能再引用它
    const [r1] = blob
      ? await conn.query("UPDATE file_blob SET ref_count = ref_count + 1 WHERE id = ? AND status = 'ACTIVE'", [blob.id])
      : [{ affectedRows: 0 }]
    if (r1.affectedRows === 0) {
      await conn.rollback()
      return null // 没有可复用的内容，走正常上传
    }
    const [r2] = await conn.query('UPDATE user_quota SET used = used + ? WHERE user_id = ? AND used + ? <= total',
      [blob.size, userId, blob.size])
    if (r2.affectedRows === 0) throw new Error('空间不足')
    // 同一目录下重名由唯一索引 (user_id, parent_id, name) 拦住
    const [r3] = await conn.query('INSERT INTO user_file (user_id, parent_id, name, is_dir, blob_id, size) VALUES (?, ?, ?, 0, ?, ?)',
      [userId, parentId, name, blob.id, blob.size])
    await conn.commit()
    return r3.insertId
  } catch (err) {
    await conn.rollback()
    throw err
  } finally {
    conn.release()
  }
}
// 清理任务：UPDATE file_blob SET status = 'DELETING' WHERE id = ? AND ref_count = 0 AND status = 'ACTIVE'
// 影响 1 行才去删对象存储里的内容；和上面的加引用互斥，不会删掉刚被秒传引用的内容