Method SaveBatch

api/service/progress_storage.go:168–192

SaveBatch 保存批次信息

(batch *BatchUpload)

// SaveBatch 保存批次信息
func (s *ProgressStorage) SaveBatch(batch *BatchUpload) error {
	// 保存到内存缓存
	s.memoryCache.Store(fmt.Sprintf("batch:%s", batch.ID), batch)

	// 尝试保存到Redis
	if redisClient := s.ensureRedisConnection(); redisClient != nil {
		batchJSON, err := json.Marshal(batch)
		if err != nil {
			return fmt.Errorf("序列化批次信息失败: %v", err)
		}

		key := fmt.Sprintf("batch_upload:batch:%s", batch.ID)
		err = redisClient.Set(context.Background(), key, batchJSON, s.batchTimeout).Err()
		if err != nil {
			// Redis错误不应该阻止操作，只记录警告
			fmt.Printf("警告: 保存批次到Redis失败: %v\n", err)
		}

		// 更新最后更新时间
		lastUpdateKey := fmt.Sprintf("batch_upload:last_update:%s", batch.ID)
		redisClient.Set(context.Background(), lastUpdateKey, time.Now().UnixMilli(), s.batchTimeout)
	}

	return nil
}

// LoadBatch 加载批次信息
func (s *ProgressStorage) LoadBatch(batchID string) (*BatchUpload, error) {