Method CreateDirectoryTree

api/service/directory_manager.go:40–125

CreateDirectoryTree 在数据库中创建目录结构记录

(eid, libraryID int64, structure []FileStructureItem, basePath string, userID int64, originType string, originSource string, originRefID int64)

// CreateDirectoryTree 在数据库中创建目录结构记录
func (dm *DirectoryManager) CreateDirectoryTree(eid, libraryID int64, structure []FileStructureItem, basePath string, userID int64, originType string, originSource string, originRefID int64) error {
	dm.mu.Lock()
	defer dm.mu.Unlock()

	// 按深度排序，确保父目录先创建
	sortedStructure := make([]FileStructureItem, len(structure))
	copy(sortedStructure, structure)
	sort.Slice(sortedStructure, func(i, j int) bool {
		return sortedStructure[i].Depth < sortedStructure[j].Depth
	})

	// 创建一个映射来存储已创建的目录路径
	createdDirs := make(map[string]bool)

	// 如果有basePath，先创建basePath目录（若已存在则跳过）
	if basePath != "" {
		if !strings.HasPrefix(basePath, "/") {
			basePath = "/" + basePath
		}

		// 递归创建basePath的所有父目录
		dm.createParentDirectories(eid, libraryID, basePath, userID, createdDirs, originType, originSource, originRefID)

		// 检查基础目录是否已存在且未被删除，已存在则标记为已创建
		if existing, err := model.GetFileByPathAndLibraryNotDeleted(eid, libraryID, basePath); err == nil && existing != nil && existing.Type == model.FILE_TYPE_DIR {
			if err := dm.backfillRecordingOriginForExistingDir(existing, originType, originSource, originRefID); err != nil {
				return fmt.Errorf("回填基础目录来源信息失败: %v", err)
			}
			createdDirs[basePath] = true
		} else {
			// 检查是否已有同名但已删除的目录，如果有则直接创建新目录而不恢复已删除的目录
			// 注意：这里我们不恢复已删除的目录，而是创建一个新目录
			baseDir := &model.File{
				Path:         basePath,
				Type:         model.FILE_TYPE_DIR,
				LibraryID:    libraryID,
				Eid:          eid,
				UploadFileID: 0,
				Sort:         0,
				UserID:       userID,
			}
			applyFileOriginMeta(baseDir, originType, originSource, originRefID)

			if err := baseDir.Save(); err != nil {
				// 如果目录已存在，忽略错误
				if existingFile, getErr := model.GetFileByPathAndLibraryNotDeleted(eid, libraryID, basePath); getErr != nil || existingFile == nil || existingFile.Type != model.FILE_TYPE_DIR {
					return fmt.Errorf("保存基础目录记录失败: %v", err)
				}
				// 目录已存在且未被删除，标记为已创建
				createdDirs[basePath] = true
			} else {
				// 同步到 Elasticsearch
				elasticsearch.SyncFileToES(baseDir, "create")
				// 为目录创建者自动分配管理权限
				fps := NewFilePermissionService(eid)
				if err := fps.AddFileCreatorPermission(baseDir.ID, userID); err != nil {
					// 权限分配失败不影响目录创建，只记录错误
				}