使用PHP解析固定宽度数据文件（.out）并导出为CSV或SQL格式

I299207075410 07  OCCLUSAL-HP                        LIQ17%                          LMedicis              B000001000000000001EA 8428010080529100   1072363   200301010000000167500000000167500000000001675002001010100000000000000000000000001218000000000000000000000000000000000000000000000000020021231262436018510(W/BRUSH APPLICATOR)     TPLIQ     
 299207085060R01  LUZU                               CRE1%                           SBausch               C000006000000000001EA 8404080054930829 1 1309011   20180105000000590530000000098421700000000902967000000000000000000000000000000000000000000000000000000000000000000000000000000                                     TPCRE     

<?php

// 原始固定宽度数据文件路径
$dataFile = 'data.out';

// 检查文件是否存在
if (!file_exists($dataFile)) {
    die("错误：数据文件 '{$dataFile}' 不存在。\n");
}

// 读取所有行到数组中
$rawLines = file($dataFile, FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);

// 定义字段及其固定长度
// 这里的字段名和长度是示例，请根据你的实际数据结构进行精确修改。
// 例如：'字段名' => 长度
$fields = [
    'id'        => 1,   // 第一个字段，长度1
    'id2'       => 12,  // 第二个字段，长度12
    'code'      => 5,   // 第三个字段，长度5
    'category'  => 35,  // ...
    'code2'     => 32,
    'category2' => 22,
    'code3'     => 22,
    'code5'     => 17,
    'code6'     => 2,
    'code7'     => 10,
    'code8'     => 186,
    'code9'     => 10
];

// 构建 unpack 格式字符串
// 'A' 表示 ASCII 字符串，后面跟着长度和字段名
$unpackFormats = [];
foreach ($fields as $name => $length) {
    $unpackFormats[] = 'A' . $length . $name;
}
$unpackString = implode('/', $unpackFormats); // 使用 '/' 分隔每个格式单元

echo "Unpack 格式字符串: " . $unpackString . "\n\n";

// 用于存储解析后的数据
$parsedData = [];

// 逐行解析数据
foreach ($rawLines as $lineNumber => $line) {
    // 确保行不为空且长度足够进行解析
    if (empty(trim($line)) || strlen($line) < array_sum($fields)) {
        echo "警告：第 " . ($lineNumber + 1) . " 行数据可能不完整或为空，跳过。\n";
        continue;
    }

    // 使用 unpack 函数解析当前行
    $parsedRow = unpack($unpackString, $line);

    // 清除每个字段值两端的空白字符，但对于固定宽度数据，有时保留是必要的，
    // 这里根据需求决定是否 trim()。如果空白字符有意义，则不应 trim。
    // 示例中，我们假设空白字符有时是数据的一部分，所以不进行全局 trim。
    // 如果需要，可以在这里对特定字段进行清理，例如：
    // foreach ($parsedRow as $key => $value) {
    //     $parsedRow[$key] = trim($value);
    // }

    $parsedData[] = $parsedRow;
}

// 打印解析后的数据结构（调试用）
echo "解析后的数据结构示例：\n";
var_dump(array_slice($parsedData, 0, 2)); // 只显示前两条记录

// ... 后续导出代码
?>

<?php
// ... (接上面的PHP解析代码) ...

// CSV 导出文件路径
$csvFile = "data.csv";
$delimiter = "|"; // 自定义分隔符

// 打开文件用于写入
$exportHandle = fopen($csvFile, "w");

if ($exportHandle === false) {
    die("错误：无法打开 CSV 文件 '{$csvFile}' 进行写入。\n");
}

// 写入 CSV 头部（字段名）
// 获取第一个解析行（如果存在）的键作为头部
if (!empty($parsedData)) {
    fputcsv($exportHandle, array_keys($parsedData[0]), $delimiter);
}

// 逐行写入数据到 CSV 文件
foreach ($parsedData as $row) {
    fputcsv($exportHandle, $row, $delimiter);
}

// 关闭文件句柄
fclose($exportHandle);

echo "\n数据已成功导出到 '{$csvFile}' 文件，使用分隔符 '{$delimiter}'。\n";

?>

<?php
// ... (接上面的PHP解析代码) ...

// 假设目标表名为 'my_table'
$tableName = 'my_table';
$sqlFile = 'data.sql';

// 打开 SQL 文件用于写入
$sqlExportHandle = fopen($sqlFile, "w");

if ($sqlExportHandle === false) {
    die("错误：无法打开 SQL 文件 '{$sqlFile}' 进行写入。\n");
}

// 获取字段名列表，用于构建 SQL INSERT 语句的列部分
$columnNames = array_keys($fields); // 使用 $fields 的键作为列名
$columnsSql = implode(', ', $columnNames);

foreach ($parsedData as $row) {
    $values = [];
    foreach ($row as $key => $value) {
        // 根据实际需求进行数据类型转换和转义
        // 这里简单地将所有值视为字符串并进行转义
        // 实际应用中，你需要根据 $key 判断字段类型
        $values[] = "'" . mysqli_real_escape_string(null, $value) . "'"; // 假设使用 mysqli 风格转义
    }
    $valuesSql = implode(', ', $values);

    $insertSql = "INSERT INTO {$tableName} ({$columnsSql}) VALUES ({$valuesSql});\n";
    fwrite($sqlExportHandle, $insertSql);
}

fclose($sqlExportHandle);

echo "\n数据已成功导出为 SQL INSERT 语句到 '{$sqlFile}' 文件。\n";

// 注意：mysqli_real_escape_string 需要一个数据库连接对象。
// 在实际应用中，你需要先建立一个数据库连接，并传入连接对象。
// 例如：$conn = new mysqli("localhost", "user", "password", "database");
// 并在循环中传入 $conn。如果只是生成文件，可以暂时用一个占位符，
// 但最终导入时需要确保数据已正确转义。
// 或者使用 addslashes() 进行简单转义，但不如数据库连接提供的函数安全。
?>