From 4eb7525c512aaafcf69b5ce1aaa2f422ee248186 Mon Sep 17 00:00:00 2001
From: HFO4 <912394456@qq.com>
Date: Fri, 26 Nov 2021 10:58:01 +0800
Subject: [PATCH] Fix: cannot transfer tasks with multiple files in slave node

---
 pkg/conf/version.go            | 2 +-
 pkg/task/slavetask/transfer.go | 5 ++---
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/pkg/conf/version.go b/pkg/conf/version.go
index aed7270..c627148 100644
--- a/pkg/conf/version.go
+++ b/pkg/conf/version.go
@@ -1,7 +1,7 @@
 package conf
 
 // BackendVersion 当前后端版本号
-var BackendVersion = "3.4.0"
+var BackendVersion = "3.4.1"
 
 // RequiredDBVersion 与当前版本匹配的数据库版本
 var RequiredDBVersion = "3.4.0"
diff --git a/pkg/task/slavetask/transfer.go b/pkg/task/slavetask/transfer.go
index c467794..698cc11 100644
--- a/pkg/task/slavetask/transfer.go
+++ b/pkg/task/slavetask/transfer.go
@@ -11,7 +11,6 @@ import (
 	"github.com/cloudreve/Cloudreve/v3/pkg/task"
 	"github.com/cloudreve/Cloudreve/v3/pkg/util"
 	"os"
-	"path/filepath"
 )
 
 // TransferTask 文件中转任务
@@ -138,8 +137,8 @@ func (job *TransferTask) Do() {
 
 // Recycle 回收临时文件
 func (job *TransferTask) Recycle() {
-	err := os.RemoveAll(filepath.Dir(job.Req.Src))
+	err := os.Remove(job.Req.Src)
 	if err != nil {
-		util.Log().Warning("无法删除中转临时目录[%s], %s", job.Req.Src, err)
+		util.Log().Warning("无法删除中转临时文件[%s], %s", job.Req.Src, err)
 	}
 }