Method processWithTransactionProtection

api/service/file_processor.go:190–363

processWithTransactionProtection 使用事务保护的文件处理

(task *UploadTask, saveOriginal bool)

// processWithTransactionProtection 使用事务保护的文件处理
func (fp *FileProcessor) processWithTransactionProtection(task *UploadTask, saveOriginal bool) error {
	var uploadFile *model.UploadFile
	var err error

	if GetBatchUploadManagerInstance().IsBatchCancelled(task.BatchID) {
		return errBatchUploadCancelled
	}

	// 更新批量上传进度
	fp.updateBatchProgress(task, model.UploadStatusUploading, 26)

	if GetBatchUploadManagerInstance().IsBatchCancelled(task.BatchID) {
		return errBatchUploadCancelled
	}

	// 创建上传记录（事务化处理）
	if saveOriginal {
		uploadFile, err = fp.createUploadFileRecordFromTask(task)
	} else {
		uploadFile, err = fp.createLightweightUploadRecord(task)
	}
	if err != nil {
		return fmt.Errorf("创建上传记录失败: %v", err)
	}
	task.DatabaseID = uploadFile.ID

	if GetBatchUploadManagerInstance().IsBatchCancelled(task.BatchID) {
		fp.cleanupCancelledUpload(task, uploadFile, 0)
		return errBatchUploadCancelled
	}

	// 标记为已上传并更新进度
	if err := uploadFile.MarkAsUploaded(); err != nil {
		return fmt.Errorf("标记为已上传失败: %v", err)
	}

	// 更新批量上传进度
	fp.updateBatchProgress(task, model.UploadStatusUploaded, 100)

	if GetBatchUploadManagerInstance().IsBatchCancelled(task.BatchID) {
		fp.cleanupCancelledUpload(task, uploadFile, 0)
		return errBatchUploadCancelled
	}

	// 记录处理开始
	fmt.Printf("上传记录已创建 - ID: %d, 文件: %s\n", uploadFile.ID, task.FileHeader.Filename)

	library, err := model.GetLibraryByID(task.EID, task.LibraryID)
	if err != nil {
		uploadFile.MarkAsFailed(fmt.Sprintf("获取知识库信息失败: %v", err))
		fp.updateBatchProgress(task, "failed", 0)
		return fmt.Errorf("获取知识库信息失败: %v", err)
	}

	// 创建文件记录，使用 base_path
	dirManager := NewDirectoryManager()
	fileID, err := dirManager.CreateFileRecord(task.EID, task.LibraryID, task.RelativePath, uploadFile.ID, task.BasePath, task.UserID, task.DuplicateMode, library.IsPersonalLibrary(), task.OriginType, task.OriginSource, task.OriginRefID)