Method CreateFileRecord

api/service/directory_manager.go:269–333

CreateFileRecord 在数据库中创建文件记录

(eid, libraryID int64, relativePath string, uploadFileID int64, basePath string, userID int64, duplicateMode DuplicateMode, isPersonalLibrary bool, originType string, originSource string, originRefID int64)

// CreateFileRecord 在数据库中创建文件记录
func (dm *DirectoryManager) CreateFileRecord(eid, libraryID int64, relativePath string, uploadFileID int64, basePath string, userID int64, duplicateMode DuplicateMode, isPersonalLibrary bool, originType string, originSource string, originRefID int64) (int64, error) {
	dm.mu.Lock()
	defer dm.mu.Unlock()

	filePath := dm.GetDirectoryPath(basePath, relativePath)

	if shouldAppendMarkdownSuffix() && filepath.Ext(filePath) != ".md" {
		filePath += ".md"
	}

	var finalPath string
	existingFile, _ := model.GetFileByPathAndLibraryNotDeleted(eid, libraryID, filePath)

	if existingFile != nil && duplicateMode == DuplicateModeReplace {
		cleanupSvc := NewCleanupService(model.DB)
		if err := cleanupSvc.CleanupFileRelatedData(eid, existingFile.ID); err != nil {
			return 0, fmt.Errorf("清理原文件相关数据失败: %v", err)
		}
		existingFile.UploadFileID = uploadFileID
		existingFile.UserID = userID
		applyFileOriginMeta(existingFile, originType, originSource, originRefID)
		if !existingFile.IsRecordingOriginType() {
			existingFile.SetPersonalUploadOrigin(uploadFileID)
		}
		existingFile.ConversionStatus = model.FileConversionStatusNormal
		existingFile.ParsingStatus = fileParsingStatusByLibrary(isPersonalLibrary)
		if err := existingFile.Update(); err != nil {
			return 0, fmt.Errorf("更新文件记录失败: %v", err)
		}
		elasticsearch.SyncFileToES(existingFile, "update")
		return existingFile.ID, nil
	}

	finalPath, err := dm.generateUniqueFileName(eid, libraryID, filePath)
	if err != nil {
		return 0, fmt.Errorf("生成唯一文件名失败: %v", err)
	}

	file := &model.File{
		Path:             finalPath,
		Type:             model.FILE_TYPE_FILE,
		LibraryID:        libraryID,
		Eid:              eid,
		UploadFileID:     uploadFileID,
		Sort:             0,
		ConversionStatus: model.FileConversionStatusNormal,
		ParsingStatus:    fileParsingStatusByLibrary(isPersonalLibrary),
		UserID:           userID,
	}
	applyFileOriginMeta(file, originType, originSource, originRefID)
	if !file.IsRecordingOriginType() {
		file.SetPersonalUploadOrigin(uploadFileID)
	}

	if err := file.Save(); err != nil {
		return 0, fmt.Errorf("保存文件记录失败: %v", err)
	}