feat(media): 清空刮削、删除已失效

Author: PIKACHUIM

internal/db/media.go

@@ -235,6 +235,55 @@ func ClearMediaItemsByScanPath(scanPathID uint) error {
 	return db.Unscoped().Where("scan_path_id = ?", scanPathID).Delete(&model.MediaItem{}).Error
 }
 
+// ClearMediaScrapedData 清空指定类型的所有刮削数据（保留扫描出的文件记录本身）
+// 仅清空刮削结果相关字段，不删除条目，便于重新刮削。
+// mediaType 为空时表示对所有类型生效。
+func ClearMediaScrapedData(mediaType model.MediaType) (int64, error) {
+	tx := db.Unscoped().Model(&model.MediaItem{})
+	if mediaType != "" {
+		tx = tx.Where("media_type = ?", mediaType)
+	}
+	updates := map[string]interface{}{
+		"scraped_name": "",
+		"description":  "",
+		"cover":        "",
+		"release_date": "",
+		"rating":       0,
+		"genre":        "",
+		"authors":      "",
+		"plot":         "",
+		"reviews":      "",
+		"external_id":  "",
+		"album_artist": "",
+		"publisher":    "",
+		"isbn":         "",
+		"scraped_at":   nil,
+	}
+	result := tx.Updates(updates)
+	return result.RowsAffected, result.Error
+}
+
+// ListAllValidMediaItemsForCheck 列出指定类型下所有未删除的媒体条目（仅取必要字段，用于失效检查）
+// mediaType 为空时返回所有类型条目。
+func ListAllValidMediaItemsForCheck(mediaType model.MediaType) ([]model.MediaItem, error) {
+	var items []model.MediaItem
+	tx := db.Model(&model.MediaItem{}).
+		Select("id, media_type, scan_path_id, file_name, folder_path, is_folder")
+	if mediaType != "" {
+		tx = tx.Where("media_type = ?", mediaType)
+	}
+	err := tx.Find(&items).Error
+	return items, err
+}
+
+// DeleteMediaItemsByIDs 按ID列表硬删除媒体条目
+func DeleteMediaItemsByIDs(ids []uint) error {
+	if len(ids) == 0 {
+		return nil
+	}
+	return db.Unscoped().Where("id IN ?", ids).Delete(&model.MediaItem{}).Error
+}
+
 // ListAlbums 列出所有专辑（音乐专用）
 func ListAlbums(q MediaItemQuery) ([]AlbumInfo, int64, error) {
 	type albumRow struct {

server/handles/media.go

@@ -8,8 +8,11 @@ import (
 	"sync"
 	"time"
 
+	stdpath "path"
+
 	"github.com/OpenListTeam/OpenList/v4/internal/conf"
 	"github.com/OpenListTeam/OpenList/v4/internal/db"
+	"github.com/OpenListTeam/OpenList/v4/internal/fs"
 	"github.com/OpenListTeam/OpenList/v4/internal/media"
 	"github.com/OpenListTeam/OpenList/v4/internal/media/scraper"
 	"github.com/OpenListTeam/OpenList/v4/internal/model"
@@ -306,6 +309,75 @@ func ClearMediaDB(c *gin.Context) {
 	common.SuccessResp(c)
 }
 
+// ClearMediaScrape 清空刮削数据（保留扫描记录，但清空所有刮削结果字段）
+// 参数：media_type 可选，留空表示所有类型；item_id 暂不支持（统一为类型/全部）
+func ClearMediaScrape(c *gin.Context) {
+	mediaType := model.MediaType(c.Query("media_type"))
+	affected, err := db.ClearMediaScrapedData(mediaType)
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+		return
+	}
+	// 同步清掉对应媒体配置中的最近刮削时间
+	if mediaType != "" {
+		if cfg, e := db.GetMediaConfig(mediaType); e == nil && cfg != nil {
+			cfg.LastScrapeAt = nil
+			_ = db.SaveMediaConfig(cfg)
+		}
+	} else {
+		if cfgs, e := db.GetAllMediaConfigs(); e == nil {
+			for i := range cfgs {
+				cfgs[i].LastScrapeAt = nil
+				_ = db.SaveMediaConfig(&cfgs[i])
+			}
+		}
+	}
+	common.SuccessResp(c, gin.H{"affected": affected})
+}
+
+// DeleteInvalidMedia 删除已失效的媒体条目（即对应文件 / 文件夹在存储中已不存在）
+// 参数：media_type 可选，留空表示扫描所有类型
+// 返回：检测总数、被删除条目数
+func DeleteInvalidMedia(c *gin.Context) {
+	mediaType := model.MediaType(c.Query("media_type"))
+
+	items, err := db.ListAllValidMediaItemsForCheck(mediaType)
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+		return
+	}
+
+	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Minute)
+	defer cancel()
+
+	var invalidIDs []uint
+	for i := range items {
+		it := &items[i]
+		// 拼接文件 / 文件夹的完整 VFS 路径
+		// - 文件夹模式 (is_folder=true): folder_path 即文件夹自身（扫描根 + 文件夹名 视情况而定）；这里直接使用 folder_path/file_name
+		// - 普通文件: folder_path 是所在目录，file_name 是文件名
+		fullPath := stdpath.Join(it.FolderPath, it.FileName)
+		if fullPath == "" || fullPath == "/" {
+			continue
+		}
+		if _, gerr := fs.Get(ctx, fullPath, &fs.GetArgs{NoLog: true}); gerr != nil {
+			invalidIDs = append(invalidIDs, it.ID)
+		}
+	}
+
+	if len(invalidIDs) > 0 {
+		if err := db.DeleteMediaItemsByIDs(invalidIDs); err != nil {
+			common.ErrorResp(c, err, 500)
+			return
+		}
+	}
+	log.Infof("删除已失效媒体条目：检测 %d 条，删除 %d 条 (media_type=%q)", len(items), len(invalidIDs), mediaType)
+	common.SuccessResp(c, gin.H{
+		"checked": len(items),
+		"deleted": len(invalidIDs),
+	})
+}
+
 // ==================== 扫描与刮削 ====================
 
 // ScanMediaReq 扫描请求

server/router.go

@@ -197,6 +197,8 @@ func admin(g *gin.RouterGroup) {
 	mediaAdmin.GET("/scan/progress", handles.GetMediaScanProgress)
 	mediaAdmin.POST("/scrape/start", handles.StartMediaScrape)
 	mediaAdmin.POST("/clear", handles.ClearMediaDB)
+	mediaAdmin.POST("/clear_scrape", handles.ClearMediaScrape)
+	mediaAdmin.POST("/delete_invalid", handles.DeleteInvalidMedia)
 	// 扫描路径管理
 	mediaAdmin.GET("/scan_paths", handles.ListMediaScanPaths)
 	mediaAdmin.POST("/scan_paths/create", handles.CreateMediaScanPath)