fix(FileTransferTask): skip copying if destination directory does not exist

Author: cyk

internal/fs/copy_move.go

@@ -191,18 +191,24 @@ func (t *FileTransferTask) RunWithNextTaskCallback(f func(nextTask *FileTransfer
 
 		existedObjs := make(map[string]bool)
 		if t.TaskType == merge {
-			dstObjs, err := op.List(t.Ctx(), t.DstStorage, dstActualPath, model.ListArgs{})
-			if err != nil {
-				return errors.WithMessagef(err, "failed list dst [%s] objs", dstActualPath)
-			}
-			for _, obj := range dstObjs {
-				if err := t.Ctx().Err(); err != nil {
-					return err
+			// 检查目标目录是否存在
+			_, err := op.Get(t.Ctx(), t.DstStorage, dstActualPath)
+			if err == nil {
+				// 目标目录存在，列出已有文件
+				dstObjs, err := op.List(t.Ctx(), t.DstStorage, dstActualPath, model.ListArgs{})
+				if err != nil {
+					return errors.WithMessagef(err, "failed list dst [%s] objs", dstActualPath)
 				}
-				if !obj.IsDir() {
-					existedObjs[obj.GetName()] = true
+				for _, obj := range dstObjs {
+					if err := t.Ctx().Err(); err != nil {
+						return err
+					}
+					if !obj.IsDir() {
+						existedObjs[obj.GetName()] = true
+					}
 				}
 			}
+			// 如果目标目录不存在（err != nil），existedObjs保持为空map，所有文件都会被复制
 		}
 
 		for _, obj := range objs {