Method GetFileProgress

api/service/progress_storage.go:261–294

GetFileProgress 获取文件进度

(batchID, fileID string)

// GetFileProgress 获取文件进度
func (s *ProgressStorage) GetFileProgress(batchID, fileID string) (*FileUpload, error) {
	key := fmt.Sprintf("file:%s:%s", batchID, fileID)

	// 先查内存缓存
	if value, ok := s.memoryCache.Load(key); ok {
		return value.(*FileUpload), nil
	}

	// 尝试从Redis获取
	if redisClient := s.ensureRedisConnection(); redisClient != nil {
		redisKey := fmt.Sprintf("batch_upload:file:%s:%s", batchID, fileID)
		progressJSON, err := redisClient.Get(context.Background(), redisKey).Result()
		if err != nil {
			if err == redis.Nil {
				return nil, fmt.Errorf("文件进度不存在")
			}
			return nil, fmt.Errorf("从Redis获取文件进度失败: %v", err)
		}

		var fileUpload FileUpload
		err = json.Unmarshal([]byte(progressJSON), &fileUpload)
		if err != nil {
			return nil, fmt.Errorf("反序列化文件进度失败: %v", err)
		}

		// 回填内存缓存
		s.memoryCache.Store(key, &fileUpload)

		return &fileUpload, nil
	}

	// Redis不可用时，只能从内存缓存查找
	return nil, fmt.Errorf("文件进度不存在")
}

// GetBatchProgress 获取批次进度
func (s *ProgressStorage) GetBatchProgress(batchID string, params *ProgressQueryParams) (*BatchProgressResponse, error) {