上传任务暂停功能修复 - 开发笔记

// pauseTransfer 方法
final uploadJob = _uploadJobs[id];
if (uploadJob != null) {
  uploadJob.cancelToken.cancel('手动暂停');  // ① 先取消 token
  _updateTransferStatus(id, TransferStatus.paused, null);  // ② 再更新状态
  return;
}

// _doPathModeUpload 方法
if (job.cancelToken.isCancelled) {  // ③ 检测到取消
  // 此时状态可能还是 running（② 尚未执行）
  _handleUploadCancelled(job);  // ④ 将状态设为 cancelled
  return;
}

// doUploadByPath 方法
// ... 上传完成后
if progress != nil {
  progress.Phase = "done"
  progress.Progress = 100
  progress.FileID = fileID  // 只在完成时设置
  progress.Metadata = &metadata
}

void pauseTransfer(String id) {
  // ...
  final uploadJob = _uploadJobs[id];
  if (uploadJob != null) {
    _updateTransferStatus(id, TransferStatus.paused, null);  // ① 先更新状态
    uploadJob.cancelToken.cancel('手动暂停');                 // ② 再取消 token
    return;
  }
  // ...
}

// _doPathModeUpload 方法中的多个检查点
if (job.cancelToken.isCancelled) {
  final idx = _transfers.indexWhere((t) => t.id == job.id);
  if (idx >= 0 && _transfers[idx].status == TransferStatus.paused) {
    // 暂停：通知后端取消上传任务，但保留前端任务记录
    await api.cancelUpload(taskId);
    _runningUploads--;
    notifyListeners();
    return;  // 不调用 _handleUploadCancelled
  }
  // 真正取消
  await api.cancelUpload(taskId);
  _handleUploadCancelled(job);
  return;
}

void _handleUploadCancelled(_UploadJob job) {
  final idx = _transfers.indexWhere((t) => t.id == job.id);
  if (idx >= 0) {
    final currentStatus = _transfers[idx].status;
    // 双重保险：如果已经是 paused 状态，不要覆盖
    if (currentStatus == TransferStatus.paused) {
      _runningUploads--;
      notifyListeners();
      return;
    }
    _transfers[idx] = _transfers[idx].copyWith(
      status: TransferStatus.cancelled,
      error: '已取消',
    );
  }
  // ...
}

func (s *Server) doUploadByPath(...) {
  // ...
  // 断点续传：如果指定了 resumeFileID，则继续上传；否则新建文件
  fileID := resumeFileID
  if fileID == "" {
    fileID = newFileID()
  }
  // 立即设置 fileID，让前端能在上传过程中获取（用于断点续传）
  if progress != nil {
    progress.FileID = fileID
  }
  // ... 继续上传流程
}

// 保存进度，同时保存 fileId 用于断点续传
db.updateTransfer(
  id: job.id,
  progress: progress.progress,
  size: fileSize,
  fileId: progress.fileId,  // 关键：保存 fileId
);

Future<void> _loadS3Config() async {
  // ... 加载配置
  await _loadTransfersFromDb();  // 添加
}
 
Future<void> refreshS3Configs() async {
  // ... 刷新配置
  await _loadTransfersFromDb();  // 添加
}

void cancelTransfer(String id) {
  // 检查是否是暂停状态
  final idx = _transfers.indexWhere((t) => t.id == id);
  if (idx >= 0 && _transfers[idx].status == TransferStatus.paused) {
    _updateTransferStatus(id, TransferStatus.cancelled, '已取消');
    _uploadJobs.remove(id);
    _downloadJobs.remove(id);
    _importJobs.remove(id);
    return;
  }
  // ... 其他逻辑
}

enum TransferStatus {
  queued,     // 排队中
  running,    // 运行中
  finishing,  // 收尾中
  paused,     // 已暂停
  success,    // 成功
  failed,     // 失败
  cancelled,  // 已取消
}

class _UploadJob {
  final String id;
  final String filePath;
  final String fileName;
  final String remotePath;
  final CancelToken cancelToken;
  // 断点续传字段
  final String? resumeFileId;  // 续传时使用的文件 ID
  final int startChunk;        // 续传起始分块
}