Update and repair the local scanning strategy for audio types in the media library

Author: Super-Badmen-Viper

.gitignore

@@ -1,3 +1,6 @@
 .idea
 .VSCodeCounter
 Ninesong/tmp
+NineSong/test.exe
+NineSong/test_build.exe
+NineSong/.all_in_ai/core/controller_spec.md

NineSong/api/controller/controller_file_entity/scene_audio_db_api_controller/file_entity_controller.go

@@ -28,41 +28,53 @@ func (ctrl *FileController) ScanDirectory(c *gin.Context) {
 	}
 
 	if err := c.ShouldBind(&req); err != nil {
+		// 增加日志输出，记录无效请求的详细信息
+		log.Printf("[扫描请求] 无效请求参数: %v", err)
+		log.Printf("[扫描请求] 请求原始数据: %+v", c.Request.Form)
 		controller.ErrorResponse(c, http.StatusBadRequest, "INVALID_REQUEST", "无效的请求格式: "+err.Error())
 		return
 	}
 
+	// 增加日志输出，记录有效的请求参数
+	log.Printf("[扫描请求] 开始扫描 - FolderPath: '%s', FolderType: %d, ScanModel: %d",
+		req.FolderPath, req.FolderType, req.ScanModel)
+
 	if req.FolderPath != "" {
 		if _, err := os.Stat(req.FolderPath); err != nil {
 			if os.IsNotExist(err) {
+				log.Printf("[扫描请求] 指定的目录不存在: %s", req.FolderPath)
 				controller.ErrorResponse(c, http.StatusBadRequest, "DIRECTORY_NOT_FOUND",
 					fmt.Sprintf("指定的目录不存在: %s", req.FolderPath))
 				return
 			}
+			log.Printf("[扫描请求] 无法访问目录 %s: %v", req.FolderPath, err)
 			controller.ErrorResponse(c, http.StatusInternalServerError, "DIRECTORY_ACCESS_ERROR",
 				fmt.Sprintf("无法访问目录: %s (%v)", req.FolderPath, err))
 			return
 		}
 
 		fileInfo, err := os.Stat(req.FolderPath)
 		if err != nil {
+			log.Printf("[扫描请求] 无法获取目录信息 %s: %v", req.FolderPath, err)
 			controller.ErrorResponse(c, http.StatusInternalServerError, "DIRECTORY_STAT_ERROR",
 				fmt.Sprintf("无法获取目录信息: %s (%v)", req.FolderPath, err))
 			return
 		}
 		if !fileInfo.IsDir() {
+			log.Printf("[扫描请求] 路径不是目录: %s", req.FolderPath)
 			controller.ErrorResponse(c, http.StatusBadRequest, "NOT_A_DIRECTORY",
 				fmt.Sprintf("路径不是目录: %s", req.FolderPath))
 			return
 		}
 	}
 
-	if req.ScanModel == 0 || req.ScanModel == 3 {
-		if len(req.FolderPath) == 0 {
-			controller.ErrorResponse(c, http.StatusBadRequest, "INVALID_REQUEST", "扫描模式为新建或删除时，必须提供目录路径")
-			return
-		}
-	}
+	// 移除与修复逻辑相矛盾的验证 - 现在所有扫描模式都支持空FolderPath（默认扫描所有媒体库）
+	// if req.ScanModel == 0 || req.ScanModel == 3 {
+	// 	if len(req.FolderPath) == 0 {
+	// 		controller.ErrorResponse(c, http.StatusBadRequest, "INVALID_REQUEST", "扫描模式为新建或删除时，必须提供目录路径")
+	// 		return
+	// 	}
+	// }
 
 	var dirPaths []string
 	if req.FolderPath != "" {

NineSong/repository/repository_file_entity/scene_audio/scene_audio_db_repository/repository_db_media_file.go

@@ -697,36 +697,41 @@ func (r *mediaFileRepository) GetByFolder(ctx context.Context, folderPath string
 func (r *mediaFileRepository) GetFilesWithMissingMetadata(ctx context.Context, folderPath string, folderType int) ([]*scene_audio_db_models.MediaFileMetadata, error) {
 	coll := r.db.Collection(r.collection)
 
-	// 1. 获取数据库中所有文件的最新更新时间
+	// 1. 获取特定媒体库文件夹下文件的最新更新时间
 	var latestUpdatedAt time.Time
-	// 按updated_at降序排序，获取第一条记录
+	// 按updated_at降序排序，获取该文件夹下的第一条记录
 	findOpts := options.Find().SetSort(bson.D{{"updated_at", -1}}).SetProjection(bson.D{{"updated_at", 1}}).SetLimit(1)
+
+	// 构建过滤条件，只查询指定文件夹下的文件
+	filter := bson.M{
+		"path": bson.M{
+			"$regex":   fmt.Sprintf("^%s", regexp.QuoteMeta(filepath.ToSlash(filepath.Clean(folderPath)))),
+			"$options": "i",
+		},
+	}
+
 	var latestRecord struct {
 		UpdatedAt time.Time `bson:"updated_at"`
 	}
-	cursor, err := coll.Find(ctx, bson.M{}, findOpts)
+	cursor, err := coll.Find(ctx, filter, findOpts)
 	if err != nil {
-		if errors.Is(err, driver.ErrNoDocuments) {
-			// 数据库中没有记录，返回空列表
-			return []*scene_audio_db_models.MediaFileMetadata{}, nil
-		} else {
-			return nil, fmt.Errorf("查询最新更新时间失败: %w", err)
+		return nil, fmt.Errorf("查询最新更新时间失败: %w", err)
+	}
+
+	// 遍历游标获取第一条记录
+	if cursor.Next(ctx) {
+		if err := cursor.Decode(&latestRecord); err != nil {
+			cursor.Close(ctx)
+			return nil, fmt.Errorf("解码最新更新时间失败: %w", err)
 		}
+		latestUpdatedAt = latestRecord.UpdatedAt
 	} else {
-		// 遍历游标获取第一条记录
-		if cursor.Next(ctx) {
-			if err := cursor.Decode(&latestRecord); err != nil {
-				return nil, fmt.Errorf("解码最新更新时间失败: %w", err)
-			}
-			latestUpdatedAt = latestRecord.UpdatedAt
-		} else {
-			// 数据库中没有记录，返回空列表
-			return []*scene_audio_db_models.MediaFileMetadata{}, nil
-		}
-		cursor.Close(ctx)
+		// 该文件夹下没有记录，设置为时间零值，这样所有文件都会被视为新文件
+		latestUpdatedAt = time.Time{}
 	}
+	cursor.Close(ctx)
 
-	log.Printf("DEBUG - 数据库最新更新时间: %v", latestUpdatedAt)
+	log.Printf("DEBUG - 文件夹 %s 最新更新时间: %v", folderPath, latestUpdatedAt)
 
 	// 2. 遍历文件夹，收集所有符合类型的文件及其修改时间
 	fileModTimeMap := make(map[string]time.Time)
@@ -787,12 +792,12 @@ func (r *mediaFileRepository) GetFilesWithMissingMetadata(ctx context.Context, f
 	}
 
 	// 查询数据库中这些文件的更新时间
-	filter := bson.M{
+	fileFilter := bson.M{
 		"path": bson.M{"$in": filePaths},
 	}
-	findOpts = options.Find().SetProjection(bson.M{"path": 1, "updated_at": 1})
+	findOpts2 := options.Find().SetProjection(bson.M{"path": 1, "updated_at": 1})
 
-	cursor, err = coll.Find(ctx, filter, findOpts)
+	cursor, err = coll.Find(ctx, fileFilter, findOpts2)
 	if err != nil {
 		return nil, fmt.Errorf("查询文件更新时间失败: %w", err)
 	}

NineSong/usecase/usecase_file_entity/file_entity_usecase_basic_file.go

@@ -440,8 +440,8 @@ func (uc *FileUsecase) ProcessDirectory(
 				libraryFolders = append(libraryFolders, folder)
 			}
 		}
-		if libraryFolders == nil && ScanModel == 2 {
-			// 默认扫描所有媒体库目录，当传入路径为空且ScanModel为2时
+		if (libraryFolders == nil || len(libraryFolders) == 0) && (ScanModel == 0 || ScanModel == 2) {
+			// 默认扫描所有媒体库目录，当传入路径为空且ScanModel为0或2时
 			library, err := uc.folderRepo.GetAllByType(ctx, 1)
 			if err != nil {
 				log.Printf("文件夹查询失败: %v", err)