From f530c6ecdc43f50469469992472e312120559b0a Mon Sep 17 00:00:00 2001
From: qiuxiuya <ds2233039480@gmail.com>
Date: Sun, 21 Jun 2026 09:10:52 +0800
Subject: [PATCH 1/2] alias: move direct

---
 drivers/alias/meta.go |  1 +
 drivers/alias/util.go | 38 ++++++++++++++++++++++++++++++++++++++
 2 files changed, 39 insertions(+)

diff --git a/drivers/alias/meta.go b/drivers/alias/meta.go
index 72eb3c877e..33a079926e 100644
--- a/drivers/alias/meta.go
+++ b/drivers/alias/meta.go
@@ -15,6 +15,7 @@ type Addition struct {
 	DownloadPartSize     int    `json:"download_part_size" default:"0" type:"number" required:"false" help:"Need to enable proxy. Unit: KB"`
 	ProviderPassThrough  bool   `json:"provider_pass_through" type:"bool" default:"false"`
 	DetailsPassThrough   bool   `json:"details_pass_through" type:"bool" default:"false"`
+	MoveDirect           bool   `json:"move_direct" type:"bool" default:"true"`
 }
 
 var config = driver.Config{
diff --git a/drivers/alias/util.go b/drivers/alias/util.go
index 8e5eb8a843..d2e3acd56a 100644
--- a/drivers/alias/util.go
+++ b/drivers/alias/util.go
@@ -387,6 +387,40 @@ func (d *Alias) getCopyObjs(ctx context.Context, srcObj, dstDir model.Obj) (Bala
 	return srcObjs, dstObjs, nil
 }
 
+func (d *Alias) getMoveObjsDirect(ctx context.Context, tmpSrcObjs, dstObjs BalancedObjs) (BalancedObjs, BalancedObjs, error) {
+	// 按挂载点分组目标目录
+	dstByMount := make(map[string][]model.Obj)
+	for _, o := range dstObjs {
+		storage, e := fs.GetStorage(o.GetPath(), &fs.GetStoragesArgs{})
+		if e != nil {
+			continue
+		}
+		mp := storage.GetStorage().MountPath
+		dstByMount[mp] = append(dstByMount[mp], o)
+	}
+
+	srcs := make(BalancedObjs, 0, len(tmpSrcObjs))
+	dsts := make(BalancedObjs, 0)
+
+	for _, src := range tmpSrcObjs {
+		storage, e := fs.GetStorage(src.GetPath(), &fs.GetStoragesArgs{})
+		if e != nil {
+			continue
+		}
+		mp := storage.GetStorage().MountPath
+		if dstList, ok := dstByMount[mp]; ok && len(dstList) > 0 {
+			srcs = append(srcs, src)
+			dsts = append(dsts, dstList[0])
+			if len(dstList) == 1 {
+				delete(dstByMount, mp)
+			} else {
+				dstByMount[mp] = dstList[1:]
+			}
+		}
+	}
+	return srcs, dsts, nil
+}
+
 func (d *Alias) getMoveObjs(ctx context.Context, srcObj, dstDir model.Obj) (BalancedObjs, BalancedObjs, error) {
 	if d.PutConflictPolicy == DisabledWP {
 		return nil, nil, errs.PermissionDenied
@@ -399,6 +433,10 @@ func (d *Alias) getMoveObjs(ctx context.Context, srcObj, dstDir model.Obj) (Bala
 	if err != nil {
 		return nil, nil, err
 	}
+	// MoveDirect: 源后端数少于目标后端数时，只在同后端上 move，跳过其他后端
+	if d.MoveDirect && len(tmpSrcObjs) < len(dstObjs) {
+		return d.getMoveObjsDirect(ctx, tmpSrcObjs, dstObjs)
+	}
 	if len(tmpSrcObjs) < len(dstObjs) {
 		return nil, nil, ErrNotEnoughSrcObjs
 	}

From 02753953a859e6eeb5c8b7887d616e685469599c Mon Sep 17 00:00:00 2001
From: qiuxiuya <ds2233039480@gmail.com>
Date: Mon, 22 Jun 2026 14:15:46 +0800
Subject: [PATCH 2/2] alias: move direct default:"false"

---
 drivers/alias/meta.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/drivers/alias/meta.go b/drivers/alias/meta.go
index 33a079926e..f56cc8197c 100644
--- a/drivers/alias/meta.go
+++ b/drivers/alias/meta.go
@@ -15,7 +15,7 @@ type Addition struct {
 	DownloadPartSize     int    `json:"download_part_size" default:"0" type:"number" required:"false" help:"Need to enable proxy. Unit: KB"`
 	ProviderPassThrough  bool   `json:"provider_pass_through" type:"bool" default:"false"`
 	DetailsPassThrough   bool   `json:"details_pass_through" type:"bool" default:"false"`
-	MoveDirect           bool   `json:"move_direct" type:"bool" default:"true"`
+	MoveDirect           bool   `json:"move_direct" type:"bool" default:"false"`
 }
 
 var config = driver.Config{