chore: bump version to 0.0.31 [skip ci]

VERSION

@@ -1 +1 @@
-0.0.29
+0.0.31

internal/handler/routes_admin.go

@@ -55,6 +55,7 @@ func registerAdminStrmRoutes(admin *gin.RouterGroup, svc *service.Container) {
 	admin.GET("/strm/uploads", uploadQueueHandler(svc))
 	admin.POST("/strm/uploads/:id/cancel", cancelStrmUploadHandler(svc))
 	admin.POST("/strm/uploads/:id/retry", retryStrmUploadHandler(svc))
+	admin.POST("/strm/uploads/cancel-pending", cancelPendingUploadsHandler(svc))
 }
 
 func registerAdminUserRoutes(admin *gin.RouterGroup, svc *service.Container) {

internal/handler/strm.go

@@ -414,6 +414,17 @@ func cancelPendingDownloadsHandler(svc *service.Container) gin.HandlerFunc {
 	}
 }
 
+func cancelPendingUploadsHandler(svc *service.Container) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		n, err := svc.Strm.CancelPendingUploadTasks(c.Request.Context())
+		if err != nil {
+			c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+			return
+		}
+		c.JSON(http.StatusOK, gin.H{"canceled": n})
+	}
+}
+
 // ─── 公开播放端点 ──────────────────────────────────────────────────────────────
 
 // strmPlayHandler 处理 strm 文件指向的播放请求（Emby/Infuse 直接请求，无 JWT）。

internal/repository/strm_repository.go

@@ -334,13 +334,13 @@ func (r *StrmDownloadTaskRepository) RetryAllFailed(ctx context.Context) (int64,
 	return count, err
 }
 
-// CancelPending 批量取消所有排队中的任务。
+// CancelPending 批量取消所有排队中和进行中的任务。
 func (r *StrmDownloadTaskRepository) CancelPending(ctx context.Context) (int64, error) {
 	now := time.Now()
 	var count int64
 	err := withSQLiteBusyRetry(ctx, func() error {
 		res := r.db.WithContext(ctx).Model(&model.StrmDownloadTask{}).
-			Where("status = ?", model.StrmTaskPending).
+			Where("status IN ?", []string{model.StrmTaskPending, model.StrmTaskRunning}).
 			Updates(map[string]any{
 				"status":      model.StrmTaskCanceled,
 				"error":       "已批量取消",
@@ -526,6 +526,25 @@ func (r *StrmUploadTaskRepository) Delete(ctx context.Context, id string) error
 	})
 }
 
+// CancelPending 批量取消所有排队中和进行中的任务。
+func (r *StrmUploadTaskRepository) CancelPending(ctx context.Context) (int64, error) {
+	now := time.Now()
+	var count int64
+	err := withSQLiteBusyRetry(ctx, func() error {
+		res := r.db.WithContext(ctx).Model(&model.StrmUploadTask{}).
+			Where("status IN ?", []string{model.StrmTaskPending, model.StrmTaskRunning}).
+			Updates(map[string]any{
+				"status":      model.StrmTaskCanceled,
+				"error":       "已批量取消",
+				"finished_at": now,
+				"updated_at":  now,
+			})
+		count = res.RowsAffected
+		return res.Error
+	})
+	return count, err
+}
+
 // CountActive 统计某同步目录下目标仍在排队/进行的任务数（用于去重）。
 func (r *StrmUploadTaskRepository) CountActive(ctx context.Context, syncPathID, localPath string) int64 {
 	var count int64

internal/service/cloud115/cloud115_test.go

@@ -371,7 +371,62 @@ func TestThrottleCodeHandling(t *testing.T) {
 	if err == nil {
 		t.Fatal("expected throttle error")
 	}
-	if !tm.IsThrottled() {
-		t.Fatal("code 770004 should trigger throttle status")
+		if !tm.IsThrottled() {
+			t.Fatal("code 770004 should trigger throttle status")
+		}
 	}
-}
+
+	func TestRemoteFileDetailRelativePath(t *testing.T) {
+		rootCID := "3238787832374488117" // 影视库
+
+		// 场景 1：115 目录 paths 中只有祖先目录链，不包含自身
+		d1 := &RemoteFileDetail{
+			FileId:   "3251154147730910635",
+			FileName: "出包王女",
+			Paths: []struct {
+				FileId string `json:"file_id"`
+				Name   string `json:"file_name"`
+			}{
+				{FileId: "0", Name: "根目录"},
+				{FileId: "3238787832374488117", Name: "影视库"},
+				{FileId: "3238787913223892116", Name: "动漫"},
+			},
+		}
+		if got := d1.RelativePath(rootCID); got != "动漫/出包王女" {
+			t.Errorf("d1.RelativePath = %q, want %q", got, "动漫/出包王女")
+		}
+
+		// 场景 2：祖先中间目录，自身在 paths 末尾
+		d2 := &RemoteFileDetail{
+			FileId:   "3238787913223892116",
+			FileName: "动漫",
+			Paths: []struct {
+				FileId string `json:"file_id"`
+				Name   string `json:"file_name"`
+			}{
+				{FileId: "0", Name: "根目录"},
+				{FileId: "3238787832374488117", Name: "影视库"},
+				{FileId: "3238787913223892116", Name: "动漫"},
+			},
+		}
+		if got := d2.RelativePath(rootCID); got != "动漫" {
+			t.Errorf("d2.RelativePath = %q, want %q", got, "动漫")
+		}
+
+		// 场景 3：根同步目录自身
+		d3 := &RemoteFileDetail{
+			FileId:   rootCID,
+			FileName: "影视库",
+			Paths: []struct {
+				FileId string `json:"file_id"`
+				Name   string `json:"file_name"`
+			}{
+				{FileId: "0", Name: "根目录"},
+				{FileId: rootCID, Name: "影视库"},
+			},
+		}
+		if got := d3.RelativePath(rootCID); got != "" {
+			t.Errorf("d3.RelativePath = %q, want %q", got, "")
+		}
+	}
+

internal/service/cloud115/open.go

@@ -145,12 +145,15 @@ type RemoteFileDetail struct {
 
 // RelativePath 计算该目录相对于根同步目录（rootCID）的相对路径。
 func (d *RemoteFileDetail) RelativePath(rootCID string) string {
-	if d == nil || len(d.Paths) == 0 {
+	if d == nil {
 		return ""
 	}
 	if rootCID == "" {
 		rootCID = "0"
 	}
+	if d.FileId == rootCID {
+		return ""
+	}
 	rootIdx := -1
 	for i, p := range d.Paths {
 		if p.FileId == rootCID {
@@ -165,12 +168,20 @@ func (d *RemoteFileDetail) RelativePath(rootCID string) string {
 	} else if len(d.Paths) > 0 && (d.Paths[0].FileId == "0" || d.Paths[0].FileId == "") {
 		start = 1
 	}
+	hasSelf := false
 	for i := start; i < len(d.Paths); i++ {
+		if d.Paths[i].FileId == d.FileId {
+			hasSelf = true
+		}
 		name := strings.TrimSpace(d.Paths[i].Name)
 		if name != "" {
 			segments = append(segments, name)
 		}
 	}
+	// 若 115 返回的 paths 祖先链未包含当前目录自身，则将其自身目录名 FileName 补在末尾
+	if !hasSelf && strings.TrimSpace(d.FileName) != "" && d.FileId != rootCID {
+		segments = append(segments, strings.TrimSpace(d.FileName))
+	}
 	return strings.Join(segments, "/")
 }
 

internal/service/strm_queue.go

@@ -511,6 +511,11 @@ func (s *StrmService) CancelPendingDownloadTasks(ctx context.Context) (int64, er
 	return s.repo.StrmDownload.CancelPending(ctx)
 }
 
+// CancelPendingUploadTasks 批量取消所有排队上传任务，返回取消数量。
+func (s *StrmService) CancelPendingUploadTasks(ctx context.Context) (int64, error) {
+	return s.repo.StrmUpload.CancelPending(ctx)
+}
+
 func sleepContext(ctx context.Context, d time.Duration) {
 	select {
 	case <-ctx.Done():

internal/service/strm_sync.go

@@ -582,10 +582,11 @@ func (st *strmSyncState) walk115Flat(open115 *cloud115.OpenClient) error {
 							continue
 						}
 						if _, loaded := st.dirCache.Load(ancestor.FileId); !loaded {
-							subDetail := &cloud115.RemoteFileDetail{
-								FileId: ancestor.FileId,
-								Paths:  nil,
-							}
+								subDetail := &cloud115.RemoteFileDetail{
+									FileId:   ancestor.FileId,
+									FileName: ancestor.Name,
+									Paths:    nil,
+								}
 							for _, p := range detail.Paths {
 								subDetail.Paths = append(subDetail.Paths, p)
 								if p.FileId == ancestor.FileId {

test_rel.go

@@ -0,0 +1,25 @@
+package main
+import (
+	"context"
+	"fmt"
+	"github.com/ShukeBta/MMTL/internal/service"
+	"github.com/ShukeBta/MMTL/internal/service/cloud115"
+	"go.uber.org/zap"
+)
+func main() {
+	crypto := service.NewCryptoService("test-secret", zap.NewNop())
+	// Let's test with a mock RemoteFileDetail
+	d := &cloud115.RemoteFileDetail{
+		FileId: "3251154147730910635",
+		FileName: "出包王女",
+		Paths: []struct {
+			FileId string 
+			Name   string 
+		}{
+			{FileId: "0", Name: "根目录"},
+			{FileId: "3238787832374488117", Name: "影视库"},
+			{FileId: "3238787913223892116", Name: "动漫"},
+		},
+	}
+	fmt.Println("RelativePath when rootCID is 3238787832374488117:", d.RelativePath("3238787832374488117"))
+}

web/src/api/strm.ts

@@ -159,6 +159,9 @@ export const strmAPI = {
   cancelUpload: (id: string) =>
     api.post(`/admin/strm/uploads/${id}/cancel`).then((r) => r.data),
 
+  cancelPendingUploads: () =>
+    api.post<{ canceled: number }>('/admin/strm/uploads/cancel-pending').then((r) => r.data),
+
   retryUpload: (id: string) =>
     api.post(`/admin/strm/uploads/${id}/retry`).then((r) => r.data),
 }

web/src/pages/StrmQueuePage.tsx

@@ -96,7 +96,7 @@ function StrmQueuePanel({ kind }: { kind: 'download' | 'upload' }) {
     }
   }
 
-  const batchBtn = (title: string, cls: string, onClick: () => void) => (
+  const batchBtn = (title: string, icon: 'trash' | 'ban' | 'refresh', cls: string, onClick: () => void) => (
     <button
       type="button"
       disabled={batchBusy}
@@ -105,33 +105,45 @@ function StrmQueuePanel({ kind }: { kind: 'download' | 'upload' }) {
         'ml-auto inline-flex items-center gap-1 rounded-lg border px-2 py-1 text-xs font-semibold transition disabled:opacity-50 ' + cls
       }
     >
-      <Trash2 size={12} />
+      {icon === 'trash' && <Trash2 size={12} />}
+      {icon === 'ban' && <Ban size={12} />}
+      {icon === 'refresh' && <RefreshCw size={12} />}
       {title}
     </button>
   )
 
+  const cancelAllPendingAction = () => {
+    const action = isDownload
+      ? () => strmAPI.cancelPendingDownloads()
+      : () => strmAPI.cancelPendingUploads()
+    return runBatch(action, `确定取消所有排队中及进行中的${isDownload ? '下载' : '上传'}任务？`)
+  }
+
   const batchActionByFilter = () => {
+    if (filter === 'pending' || filter === 'running')
+      return batchBtn(
+        '全部取消',
+        'ban',
+        'border-amber-200 text-amber-600 hover:bg-amber-50',
+        cancelAllPendingAction,
+      )
     if (!isDownload) return null
     if (filter === 'done')
       return batchBtn(
         '清空成功记录',
+        'trash',
         'border-gray-200 text-rose-500 hover:bg-rose-50',
         () => runBatch(() => strmAPI.clearDoneDownloads(), '确定清空所有已完成下载记录？'),
       )
     if (filter === 'failed')
-      return batchBtn('批量重试', 'border-gray-200 text-brand-500 hover:bg-brand-50', () =>
+      return batchBtn('批量重试', 'refresh', 'border-gray-200 text-brand-500 hover:bg-brand-50', () =>
         runBatch(() => strmAPI.retryFailedDownloads(), '确定重新入队所有失败下载任务？'),
       )
-    if (filter === 'pending')
-      return batchBtn(
-        '批量取消',
-        'border-gray-200 text-amber-600 hover:bg-amber-50',
-        () => runBatch(() => strmAPI.cancelPendingDownloads(), '确定取消所有排队中的下载任务？'),
-      )
     return null
   }
 
   const counts = snapshot?.counts
+  const activeTaskCount = (counts?.pending ?? 0) + (counts?.running ?? 0)
   const tasks = snapshot?.tasks.filter((t) => filter === 'all' || t.status === filter) ?? []
   const isDownload = kind === 'download'
   const Icon = isDownload ? Download : Upload
@@ -152,23 +164,36 @@ function StrmQueuePanel({ kind }: { kind: 'download' | 'upload' }) {
               : 'STRM 元数据上传情况（本地 → 远端网盘，3 秒自动刷新）'}
           </p>
         </div>
-        {isDownload && (
-          <button
-            type="button"
-            disabled={batchBusy}
-            onClick={() =>
-              runBatch(() => strmAPI.clearFinishedDownloads(), '确定清空所有失败和成功的下载记录？')
-            }
-            className="inline-flex items-center gap-1.5 rounded-xl border border-rose-200 px-3 py-2 text-sm font-semibold text-rose-500 transition hover:bg-rose-50 disabled:opacity-50"
-          >
-            <Trash2 size={14} />
-            清空失败与完成记录
+        <div className="ml-auto flex items-center gap-2">
+          {activeTaskCount > 0 && (
+            <button
+              type="button"
+              disabled={batchBusy}
+              onClick={cancelAllPendingAction}
+              className="inline-flex items-center gap-1.5 rounded-xl border border-amber-300 bg-amber-500/10 px-3 py-2 text-sm font-semibold text-amber-600 transition hover:bg-amber-500/20 disabled:opacity-50"
+            >
+              <Ban size={14} />
+              全部取消 ({activeTaskCount})
+            </button>
+          )}
+          {isDownload && (
+            <button
+              type="button"
+              disabled={batchBusy}
+              onClick={() =>
+                runBatch(() => strmAPI.clearFinishedDownloads(), '确定清空所有失败和成功的下载记录？')
+              }
+              className="inline-flex items-center gap-1.5 rounded-xl border border-rose-200 px-3 py-2 text-sm font-semibold text-rose-500 transition hover:bg-rose-50 disabled:opacity-50"
+            >
+              <Trash2 size={14} />
+              清空完成与失败
+            </button>
+          )}
+          <button type="button" onClick={refresh} className="inline-flex items-center gap-1.5 rounded-xl border border-gray-200 px-3 py-2 text-sm font-semibold text-ink-100 hover:bg-gray-50">
+            <RefreshCw size={14} />
+            刷新
           </button>
-        )}
-        <button type="button" onClick={refresh} className="ml-auto inline-flex items-center gap-1.5 rounded-xl border border-gray-200 px-3 py-2 text-sm font-semibold text-ink-100 hover:bg-gray-50">
-          <RefreshCw size={14} />
-          刷新
-        </button>
+        </div>
       </header>
 
       <div className="flex flex-wrap items-center gap-2">