Symfony 怎样把CSV文件内容转为数组

SplFileObject

setCsvControl

// 假设这是你在Symfony控制器或服务中的一个方法
use SymfonyComponentHttpFoundationFileUploadedFile;
use SplFileObject; // 这是PHP内置的类

/**
 * 将上传的CSV文件内容转换为数组。
 *
 * @param UploadedFile $csvFile 上传的CSV文件对象
 * @param bool $hasHeader CSV文件是否包含标题行
 * @param string $delimiter CSV字段分隔符，默认为逗号
 * @param string $enclosure CSV字段包围符，默认为双引号
 * @param string $escape CSV转义符，默认为反斜杠
 * @return array 转换后的数组数据
 * @throws InvalidArgumentException 如果文件无效
 * @throws RuntimeException 如果文件处理出错
 */
public function convertCsvToArray(
    UploadedFile $csvFile,
    bool $hasHeader = true,
    string $delimiter = ',',
    string $enclosure = '"',
    string $escape = '\'
): array {
    if (!$csvFile->isValid()) {
        throw new InvalidArgumentException('上传的文件无效或文件损坏。');
    }

    $filePath = $csvFile->getPathname();
    $data = [];
    $header = [];

    try {
        // 使用SplFileObject以迭代方式读取文件，避免一次性加载大文件到内存
        $file = new SplFileObject($filePath, 'r');
        // 设置SplFileObject以CSV模式读取，并跳过空行，预读一行
        $file->setFlags(SplFileObject::READ_CSV | SplFileObject::SKIP_EMPTY | SplFileObject::READ_AHEAD);
        // 设置CSV解析规则
        $file->setCsvControl($delimiter, $enclosure, $escape);

        foreach ($file as $row) {
            // 检查行是否有效，fgetcsv可能返回null或空数组
            if (!is_array($row) || empty(array_filter($row, fn($value) => $value !== null && $value !== ''))) {
                continue; // 跳过完全空或无效的行
            }

            // 处理标题行
            if ($hasHeader && empty($header)) {
                $header = array_map('trim', $row); // 移除标题两边的空白
                continue;
            }

            // 如果有标题，将当前行转换为关联数组
            if (!empty($header)) {
                // 确保数据行和标题行长度匹配，不匹配时可以根据需求截断或填充
                $processedRow = [];
                foreach ($header as $index => $colName) {
                    // 使用null合并运算符，如果数据行缺少某个列，则该列值为null
                    $processedRow[$colName] = $row[$index] ?? null;
                }
                $data[] = $processedRow;
            } else {
                // 没有标题行，直接将数组加入结果
                $data[] = $row;
            }
        }
    } catch (Exception $e) {
        // 捕获文件操作中可能出现的异常，并抛出更具体的运行时异常
        throw new RuntimeException('处理CSV文件时发生错误：' . $e->getMessage(), 0, $e);
    }

    return $data;
}

// 在控制器中调用示例：
/*
use SymfonyComponentHttpFoundationRequest;
use SymfonyComponentHttpFoundationJsonResponse;

// ...

public function uploadCsvAction(Request $request): JsonResponse
{
    // 假设你的表单文件字段名为 'csv_file'
    $uploadedFile = $request->files->get('csv_file');

    if (!$uploadedFile) {
        return new JsonResponse(['message' => '没有上传文件。'], JsonResponse::HTTP_BAD_REQUEST);
    }

    try {
        // 调用我们上面定义的转换方法
        // 假设CSV文件有标题，且使用逗号分隔
        $csvData = $this->convertCsvToArray($uploadedFile, true, ',');

        return new JsonResponse([
            'message' => 'CSV文件已成功转换。',
            'data' => $csvData
        ]);
    } catch (InvalidArgumentException $e) {
        return new JsonResponse(['error' => $e->getMessage()], JsonResponse::HTTP_BAD_REQUEST);
    } catch (RuntimeException $e) {
        return new JsonResponse(['error' => '文件处理失败：' . $e->getMessage()], JsonResponse::HTTP_INTERNAL_SERVER_ERROR);
    }
}
*/

file_get_contents

explode

SplFileObject

convertCsvToArray

// 示例：将convertCsvToArray改为生成器
// ... (方法签名不变，但返回类型改为 Generator)
public function convertCsvToGenerator(...): Generator
{
    // ... 之前的逻辑不变，但在循环中：
    // if (!empty($header)) {
    //     yield $processedRow; // 使用 yield 替代 $data[] = $processedRow;
    // } else {
    //     yield $row; // 使用 yield 替代 $data[] = $row;
    // }
}

// 在控制器中调用示例：
/*
// ...
try {
    $csvRowsGenerator = $this->convertCsvToGenerator($uploadedFile, true, ',');
    foreach ($csvRowsGenerator as $row) {
        // 这里可以逐行处理数据，比如插入数据库
        // $this->someService->saveData($row);
    }
    return new JsonResponse(['message' => 'CSV文件已成功处理。']);
} catch (...) {
    // ...
}
*/

LeagueCsv

SplFileObject