PHP 재고 관리 시스템의 재고 이전 검토 기능을 위한 코드 생성

<?php

function createTransferOrder($orderNumber, $transferDate, $transferType, $transferQuantity) {
    // 将调拨单数据插入到数据库中
    $sql = "INSERT INTO transfer_orders (order_number, transfer_date, transfer_type, transfer_quantity, status) VALUES ('$orderNumber', '$transferDate', '$transferType', '$transferQuantity', 'pending')";
    $result = mysqli_query($connection, $sql);
    
    if ($result) {
        echo "调拨单创建成功！";
    } else {
        echo "创建调拨单时发生错误：" . mysqli_error($connection);
    }
}

?>

<?php

function approveTransferOrder($orderId) {
    // 更新调拨单的状态为approved
    $sql = "UPDATE transfer_orders SET status='approved' WHERE id='$orderId'";
    $result = mysqli_query($connection, $sql);
    
    if ($result) {
        echo "调拨单审核通过！";
    } else {
        echo "审核调拨单时发生错误：" . mysqli_error($connection);
    }
}

function rejectTransferOrder($orderId) {
    // 更新调拨单的状态为rejected
    $sql = "UPDATE transfer_orders SET status='rejected' WHERE id='$orderId'";
    $result = mysqli_query($connection, $sql);
    
    if ($result) {
        echo "调拨单审核拒绝！";
    } else {
        echo "审核调拨单时发生错误：" . mysqli_error($connection);
    }
}

?>

<?php

function executeTransfer($orderId) {
    // 根据调拨单查询调拨信息
    $sql = "SELECT transfer_quantity, transfer_type FROM transfer_orders WHERE id='$orderId'";
    $result = mysqli_query($connection, $sql);
    $row = mysqli_fetch_assoc($result);
    $transferQuantity = $row['transfer_quantity'];
    $transferType = $row['transfer_type'];
    
    // 更新出库仓库和入库仓库的库存数量
    $sql = "UPDATE warehouses SET quantity = quantity - $transferQuantity WHERE type='$transferType' AND location='$warehouseOut'";
    $result1 = mysqli_query($connection, $sql);
    
    if ($result1) {
        $sql = "UPDATE warehouses SET quantity = quantity + $transferQuantity WHERE type='$transferType' AND location='$warehouseIn'";
        $result2 = mysqli_query($connection, $sql);
        
        if ($result2) {
            echo "调拨操作执行成功！";
        } else {
            echo "执行调拨操作时发生错误：" . mysqli_error($connection);
        }
    } else {
        echo "执行调拨操作时发生错误：" . mysqli_error($connection);
    }
}

?>