PHP表单数组与数据库值比较：实现高效的前后端协同验证

document.addEventListener('DOMContentLoaded', function() {
    const form = document.querySelector('form'); // 假设只有一个表单，或使用更具体的选择器
    form.addEventListener('submit', function(event) {
        event.preventDefault(); // 阻止表单的默认提交行为

        // 在这里执行验证逻辑
        validateForm(); 
    });
});

function validateForm() {
    const materialIds = Array.from(document.querySelectorAll('[name="material_added_id[]"]')).map(input => input.value);
    const issuedWeights = Array.from(document.querySelectorAll('[name="material_isseud_weight[]"]')).map(input => input.value);
    const unitTypes = Array.from(document.querySelectorAll('[name="unit_type[]"]')).map(input => input.value);
    // ... 其他数组字段

    // 假设所有数组长度相同
    if (materialIds.length === 0) {
        alert('请添加物料信息！');
        return;
    }

    // 在这里进行客户端的基本验证，例如非空检查
    for (let i = 0; i < issuedWeights.length; i++) {
        if (issuedWeights[i] === '' || isNaN(issuedWeights[i])) {
            alert('请输入有效的物料发放重量！');
            return; // 发现一个错误就停止
        }
    }

    // 如果基本验证通过，则进行服务器端验证
    performServerValidation(materialIds, issuedWeights, unitTypes /* ... */);
}

async function performServerValidation(materialIds, issuedWeights, unitTypes) {
    let isValid = true;
    let errorMessage = '';

    // 构建要发送到后端的数据
    const formData = new FormData();
    materialIds.forEach(id => formData.append('material_added_id[]', id));
    issuedWeights.forEach(weight => formData.append('material_isseud_weight[]', weight));
    unitTypes.forEach(type => formData.append('unit_type[]', type));
    // ... 添加其他必要的表单数据，例如 product_id, ric_name, btn_action

    formData.append('product_id', document.querySelector('[name="product_id"]').value);
    formData.append('ric', document.querySelector('[name="ric"]').value);
    formData.append('btn_action', 'validate_materials'); // 标记为验证请求

    try {
        const response = await fetch('your_validation_endpoint.php', { // 替换为你的PHP验证脚本路径
            method: 'POST',
            body: formData
        });

        const result = await response.json(); // 期望后端返回JSON

        if (!result.success) {
            isValid = false;
            errorMessage = result.message || '未知错误，请重试。';
        }

    } catch (error) {
        isValid = false;
        errorMessage = '网络请求失败，请检查您的网络连接。';
        console.error('Validation Error:', error);
    }

    if (!isValid) {
        alert(errorMessage);
        // 如果验证失败，不进行表单的实际提交
    } else {
        // 如果所有验证通过，则可以手动提交表单
        // 注意：这里是真正的表单提交，可能会再次触发表单的 'submit' 事件，
        // 如果你不想它再次触发验证，可以移除事件监听器或使用标志位。
        // 更推荐的做法是，如果验证通过，直接通过Ajax发送最终的提交数据，而不是模拟表单提交。

        // 示例：如果验证通过，可以手动提交表单
        document.querySelector('form').submit(); 

        // 或者，如果你想完全通过Ajax提交，可以在这里发送最终的提交请求
        // submitFormViaAjax(materialIds, issuedWeights, unitTypes, ...);
    }
}

<?php
// your_validation_endpoint.php

// 引入数据库连接
require_once 'db_connection.php'; // 替换为你的数据库连接文件

header('Content-Type: application/json'); // 设置响应头为JSON

$response = ['success' => true, 'message' => ''];

if (isset($_POST['btn_action']) && $_POST['btn_action'] === 'validate_materials') {
    $material_ids = $_POST['material_added_id'] ?? [];
    $material_issued_weights = $_POST['material_isseud_weight'] ?? [];

    if (empty($material_ids) || empty($material_issued_weights)) {
        $response['success'] = false;
        $response['message'] = '缺少必要的物料信息。';
        echo json_encode($response);
        exit();
    }

    $conn = null; // 假设 $conn 是你的PDO连接对象
    try {
        $conn = new PDO("mysql:host=localhost;dbname=your_db", "your_user", "your_password"); // 替换为你的数据库连接信息
        $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

        for ($i = 0; $i < count($material_ids); $i++) {
            $material_id = $material_ids[$i];
            $issued_weight = $material_issued_weights[$i];

            // 使用预处理语句防止SQL注入
            $qry = "SELECT material_weight, material_added_name FROM material_added_tb WHERE material_added_id = :material_id";
            $statement = $conn->prepare($qry);
            $statement->bindParam(':material_id', $material_id, PDO::PARAM_INT);
            $statement->execute();
            $result = $statement->fetch(PDO::FETCH_ASSOC);

            if ($result) {
                $material_weight = $result['material_weight'];
                $material_name = $result['material_added_name'];

                if ($issued_weight > $material_weight) {
                    $response['success'] = false;
                    $response['message'] = $material_name . " 库存不足，当前库存: " . $material_weight . "，尝试发放: " . $issued_weight;
                    echo json_encode($response);
                    exit(); // 发现一个不满足条件就立即终止并返回
                }
            } else {
                $response['success'] = false;
                $response['message'] = "物料ID " . $material_id . " 不存在。";
                echo json_encode($response);
                exit();
            }
        }

    } catch (PDOException $e) {
        $response['success'] = false;
        $response['message'] = '数据库操作失败：' . $e->getMessage();
        error_log("Database Error: " . $e->getMessage()); // 记录错误日志
    } finally {
        $conn = null; // 关闭连接
    }
} else {
    $response['success'] = false;
    $response['message'] = '无效的请求。';
}

echo json_encode($response);
?>