From 2073596fdd72c0c0d08da8e3bbdb9e53f91fbe23 Mon Sep 17 00:00:00 2001 From: Odboy Date: Fri, 1 Aug 2025 21:06:38 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E7=A7=BB=E5=8A=A8=E6=96=87=E4=BB=B6?= =?UTF-8?q?=E5=AE=8C=E6=88=90=E5=90=8E=E6=B8=85=E7=A9=BA=20scan=5Flog=20?= =?UTF-8?q?=E7=BB=AD=E4=BC=A0=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/service/scan.go | 5 +++++ internal/store/store.go | 9 +++++++++ 2 files changed, 14 insertions(+) diff --git a/internal/service/scan.go b/internal/service/scan.go index 6618dcd..bf074c6 100644 --- a/internal/service/scan.go +++ b/internal/service/scan.go @@ -360,6 +360,11 @@ func (s *ScanService) runMove(ctx context.Context) { return } + // 移动完成后清空续传记录 + if err := s.store.ClearScanLog(); err != nil { + fmt.Printf("=== 清空续传记录失败: %v\n", err) + } + fmt.Println("=== 文件移动完成") s.finish(ScanDone, fmt.Sprintf("文件移动完成,共移动 %d 个文件", len(jobs))) } diff --git a/internal/store/store.go b/internal/store/store.go index 862a85e..09018ba 100644 --- a/internal/store/store.go +++ b/internal/store/store.go @@ -189,6 +189,15 @@ func (s *Store) SaveScanLogs(entries []ScanLog) error { return sess.Commit() } +// ClearScanLog 清空全部续传记录。移动完成后调用。 +func (s *Store) ClearScanLog() error { + if s == nil || s.engine == nil { + return nil + } + _, err := s.engine.Delete(new(ScanLog)) + return err +} + // ============================ 媒体记录的新增/更新 ============================ // SaveMedia 保存/更新一条媒体记录:按 MD5 找,有就更新,没有就新增。