PHP中CSV文件上传与数据转换：从URL字符串中精准提取关键词

<form enctype='multipart/form-data' action='' method='post'>
    <label>上传 CSV 文件</label><br>
    <input size='50' type='file' name='filename'>
    <br>
    <input type='submit' name='submit' value='上传文件'>
</form>

<?php

if (isset($_POST['submit'])) {
    // 检查文件是否成功上传
    if (isset($_FILES['filename']) && $_FILES['filename']['error'] === UPLOAD_ERR_OK) {
        $file = fopen($_FILES['filename']['tmp_name'], "r"); // 以只读模式打开临时文件

        $all_rows = array(); // 用于存储所有行的数组
        $header = fgetcsv($file); // 读取CSV文件的第一行作为表头

        // 循环读取CSV文件的每一行，直到文件末尾
        while (($row = fgetcsv($file)) !== FALSE) {
            // 确保行数据与表头数量匹配，避免array_combine报错
            if (count($header) === count($row)) {
                $all_rows[] = array_combine($header, $row); // 将表头与行数据组合成关联数组
            } else {
                // 处理行数据与表头不匹配的情况，例如记录日志或跳过
                error_log("CSV行数据与表头不匹配，已跳过。行内容: " . implode(",", $row));
            }
        }
        fclose($file); // 关闭文件句柄

        // 此时 $all_rows 包含了解析后的CSV数据，每行是一个关联数组
        // print_r($all_rows); // 调试用，查看初始数组结构

        // 后续我们将在此处添加数据转换逻辑
    } else {
        echo "文件上传失败或未选择文件。错误码: " . $_FILES['filename']['error'];
    }
}

?>

// 假设 $all_rows 已经通过上述代码填充
foreach ($all_rows as $key => $value) {
    // 1. 使用 strstr 查找 'keywords=' 第一次出现的位置，并返回从该位置开始到字符串末尾的部分
    // 例如：从 "&keywords=Computational%20Biologist&origin=host" 开始
    $queryString = strstr($all_rows[$key]['query'], 'keywords=');

    if ($queryString !== false) { // 确保找到了 'keywords='
        // 2. 使用 str_replace 移除 'keywords=' 前缀
        // 例如：变为 "Computational%20Biologist&origin=host"
        $queryString = str_replace('keywords=', '', $queryString);

        // 3. 使用 strpos 查找 '&' 符号在 $queryString 中第一次出现的位置
        // 然后使用 substr 截取从开始到 '&' 符号之间的部分
        // 例如：变为 "Computational%20Biologist"
        $ampersandPos = strpos($queryString, "&");
        if ($ampersandPos !== false) {
            $queryString = substr($queryString, 0, $ampersandPos);
        }
        // 如果没有找到 '&'，说明 'keywords' 是最后一个参数，无需截取

        // 4. 使用 urldecode 解码 URL 编码的字符串（如 %20 会变为空格）
        // 例如：变为 "Computational Biologist"
        $all_rows[$key]['query'] = urldecode($queryString);
    } else {
        // 如果没有找到 'keywords='，可以根据需求设置默认值或保持原样
        $all_rows[$key]['query'] = '关键词未找到'; // 或者 $all_rows[$key]['query'] = '';
    }
}

<?php

// 确保错误报告开启，便于调试
ini_set('display_errors', 1);
ini_set('display_startup_errors', 1);
error_reporting(E_ALL);

// HTML 表单部分
echo "<form enctype='multipart/form-data' action='' method='post'>";
echo "<label>上传 CSV 文件</label><br>";
echo "<input size='50' type='file' name='filename'>";
echo "</br>";
echo "<input type='submit' name='submit' value='上传文件'>";
echo "</form>";

if (isset($_POST['submit'])) {
    // 检查文件是否成功上传
    if (isset($_FILES['filename']) && $_FILES['filename']['error'] === UPLOAD_ERR_OK) {
        $file = fopen($_FILES['filename']['tmp_name'], "r");

        $all_rows = array();
        $header = fgetcsv($file); // 读取表头

        if ($header === FALSE) {
            echo "无法读取CSV文件头，文件可能为空或格式错误。";
            fclose($file);
            exit();
        }

        while (($row = fgetcsv($file)) !== FALSE) {
            // 确保行数据与表头数量匹配
            if (count($header) === count($row)) {
                $all_rows[] = array_combine($header, $row);
            } else {
                error_log("CSV行数据与表头不匹配，已跳过。行内容: " . implode(",", $row));
            }
        }
        fclose($file);

        // 遍历并转换 'query' 字段
        foreach ($all_rows as $key => $value) {
            // 确保 'query' 键存在且是字符串
            if (isset($all_rows[$key]['query']) && is_string($all_rows[$key]['query'])) {
                $queryString = strstr($all_rows[$key]['query'], 'keywords=');

                if ($queryString !== false) {
                    $queryString = str_replace('keywords=', '', $queryString);
                    $ampersandPos = strpos($queryString, "&");
                    if ($ampersandPos !== false) {
                        $queryString = substr($queryString, 0, $ampersandPos);
                    }
                    $all_rows[$key]['query'] = urldecode($queryString);
                } else {
                    $all_rows[$key]['query'] = '关键词未找到'; // 或根据业务逻辑设置其他默认值
                }
            } else {
                // 如果 'query' 键不存在或不是字符串，可以设置默认值或跳过
                $all_rows[$key]['query'] = '无效查询数据';
            }
        }

        echo "<h3>处理后的数据：</h3>";
        echo "<pre>";
        print_r($all_rows);
        echo "</pre>";

    } else {
        echo "文件上传失败或未选择文件。错误码: " . $_FILES['filename']['error'];
        // 详细错误信息
        switch ($_FILES['filename']['error']) {
            case UPLOAD_ERR_INI_SIZE:
                echo "上传文件大小超过了 php.ini 中 upload_max_filesize 选项限制的值。";
                break;
            case UPLOAD_ERR_FORM_SIZE:
                echo "上传文件大小超过了 HTML 表单中 MAX_FILE_SIZE 选项指定的值。";
                break;
            case UPLOAD_ERR_PARTIAL:
                echo "文件只有部分被上传。";
                break;
            case UPLOAD_ERR_NO_FILE:
                echo "没有文件被上传。";
                break;
            case UPLOAD_ERR_NO_TMP_DIR:
                echo "找不到临时文件夹。";
                break;
            case UPLOAD_ERR_CANT_WRITE:
                echo "文件写入失败。";
                break;
            case UPLOAD_ERR_EXTENSION:
                echo "PHP扩展停止了文件上传。";
                break;
            default:
                echo "未知上传错误。";
                break;
        }
    }
}

?>