PHP项目如何实现库存调拨？

wen java案例 2026-07-21 5

PHP项目如何实现库存调拨？从架构设计到代码实战全解析

📖 目录导读

库存调拨的业务场景与核心难点
数据库设计：如何存储调拨数据？
调拨逻辑实现：PHP后端核心代码
并发与事务处理：保证库存准确性的关键
前端交互与API接口设计
常见错误与排查方案
实战问答环节

库存调拨的业务场景与核心难点

业务场景

在多仓库或多门店管理系统中,库存调拨是指将商品从A仓库转移到B仓库，常见场景包括：

PHP项目如何实现库存调拨？

电商平台：将滞销仓库存调至热销仓
零售连锁：门店间相互补货
供应链管理：总仓向分仓调拨

核心难点

数据一致性：调拨过程涉及两个仓库的库存增减，必须保证原子性
并发冲突：同一商品同时被多个调拨单使用，易出现超调
状态变更：调拨单有“审批-出库-在途-入库”多个状态
物料编码差异：不同仓库可能使用不同SKU编码

数据库设计：如何存储调拨数据？

核心表结构

-- 调拨单主表
CREATE TABLE transfer_order (
    id INT AUTO_INCREMENT PRIMARY KEY,
    order_no VARCHAR(50) UNIQUE COMMENT '调拨单号',
    from_warehouse_id INT COMMENT '调出仓库ID',
    to_warehouse_id INT COMMENT '调入仓库ID',
    status TINYINT DEFAULT 0 COMMENT '0待审批 1出库中 2在途 3已完成 4已取消',
    total_quantity INT DEFAULT 0,
    created_at DATETIME,
    updated_at DATETIME
);
-- 调拨明细表
CREATE TABLE transfer_order_item (
    id INT AUTO_INCREMENT PRIMARY KEY,
    order_id INT NOT NULL,
    product_id INT NOT NULL,
    quantity INT NOT NULL COMMENT '调拨数量',
    unit_price DECIMAL(10,2) DEFAULT 0,
    FOREIGN KEY (order_id) REFERENCES transfer_order(id)
);
-- 库存表（示例）
CREATE TABLE inventory (
    id INT AUTO_INCREMENT PRIMARY KEY,
    warehouse_id INT NOT NULL,
    product_id INT NOT NULL,
    quantity INT DEFAULT 0,
    version INT DEFAULT 0 COMMENT '乐观锁版本号'
);

设计要点

版本号字段：使用乐观锁防止并发修改
在途库存：建议增加中间态字段，如 in_transit_quantity，避免真实库存被提前占用
索引优化：对 warehouse_id + product_id 建立唯一索引

调拨逻辑实现：PHP后端核心代码

创建调拨单（包含事务）

use think\facade\Db;
class TransferService 
{
    public function createTransfer($fromWarehouseId, $toWarehouseId, $items)
    {
        Db::startTrans();
        try {
            // 1. 生成单号
            $orderNo = 'TR' . date('Ymd') . rand(1000, 9999);
            // 2. 创建调拨单主表
            $orderId = Db::table('transfer_order')->insertGetId([
                'order_no' => $orderNo,
                'from_warehouse_id' => $fromWarehouseId,
                'to_warehouse_id' => $toWarehouseId,
                'status' => 0,
                'total_quantity' => array_sum(array_column($items, 'quantity')),
                'created_at' => date('Y-m-d H:i:s')
            ]);
            // 3. 插入明细并校验库存
            foreach ($items as $item) {
                // 使用乐观锁预占库存（不真正扣减）
                $affected = Db::table('inventory')
                    ->where([
                        'warehouse_id' => $fromWarehouseId,
                        'product_id' => $item['product_id'],
                        'quantity' => ['>=', $item['quantity']]
                    ])
                    ->update([
                        'quantity' => Db::raw('quantity - ' . $item['quantity']),
                        'in_transit_quantity' => Db::raw('in_transit_quantity + ' . $item['quantity']),
                        'version' => Db::raw('version + 1')
                    ]);
                if (!$affected) {
                    throw new \Exception("商品ID {$item['product_id']} 库存不足或版本冲突");
                }
                Db::table('transfer_order_item')->insert([
                    'order_id' => $orderId,
                    'product_id' => $item['product_id'],
                    'quantity' => $item['quantity']
                ]);
            }
            Db::commit();
            return ['code' => 200, 'order_no' => $orderNo];
        } catch (\Exception $e) {
            Db::rollback();
            return ['code' => 500, 'msg' => $e->getMessage()];
        }
    }
}

确认调拨入库（出仓后入库）

public function confirmReceive($orderId)
{
    Db::startTrans();
    try {
        $order = Db::table('transfer_order')->lock(true)->find($orderId);
        // 状态校验
        if ($order['status'] != 1) { // 1表示已出库
            throw new \Exception('当前状态不允许入库确认');
        }
        $items = Db::table('transfer_order_item')
            ->where('order_id', $orderId)
            ->select();
        foreach ($items as $item) {
            // 从在途库存转真实库存
            Db::table('inventory')
                ->where([
                    'warehouse_id' => $order['to_warehouse_id'],
                    'product_id' => $item['product_id']
                ])
                ->update([
                    'quantity' => Db::raw('quantity + ' . $item['quantity']),
                    'in_transit_quantity' => Db::raw('in_transit_quantity - ' . $item['quantity'])
                ]);
        }
        Db::table('transfer_order')
            ->where('id', $orderId)
            ->update([
                'status' => 2,  // 已入库
                'updated_at' => date('Y-m-d H:i:s')
            ]);
        Db::commit();
        return ['code' => 200];
    } catch (\Exception $e) {
        Db::rollback();
        return ['code' => 500, 'msg' => $e->getMessage()];
    }
}

并发与事务处理：保证库存准确性的关键

事务隔离级别

建议使用 REPEATABLE READ，配合行锁避免幻读：

Db::query('SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ');

乐观锁 vs 悲观锁

类型	适用场景	实现方式
悲观锁	高并发写、冲突频繁	`SELECT ... FOR UPDATE`
乐观锁	读多写少、冲突概率低	版本号字段更新时校验

在高并发场景下的优化建议

使用Redis分布式锁防止同一商品同时调拨：

$lockKey = 'transfer_lock_'.$productId;
$lock = Redis::setnx($lockKey, 1);
if (!$lock) {
    return ['code' => 429, 'msg' => '操作繁忙，请稍后重试'];
}
Redis::expire($lockKey, 10);

消息队列削峰：将调拨请求写入队列，后台异步处理

前端交互与API接口设计

RESTful API 示例

接口	方法	说明
`/api/transfer/create`	POST	创建调拨单
`/api/transfer/list`	GET	查询调拨单列表
`/api/transfer/confirm-out`	POST	确认出库
`/api/transfer/confirm-in`	POST	确认入库

前端调用示例（Vue + Axios）

// 创建调拨单
async function createTransfer(items) {
  const res = await axios.post('/api/transfer/create', {
    from_warehouse_id: 1,
    to_warehouse_id: 2,
    items: items
  });
  if (res.data.code === 200) {
    console.log('调拨单已创建:', res.data.order_no);
  } else {
    console.error('创建失败:', res.data.msg);
  }
}

常见错误与排查方案

❌ 错误1：库存扣减异常导致负数

原因：高并发下未加锁，两个请求同时读到的库存相同。解决：使用UPDATE ... WHERE quantity >= ? 原子条件。

❌ 错误2：调拨单状态混乱

原因：未使用状态机校验，直接从“待审批”跳转到“已入库”。解决：建立状态转换矩阵，如 0→1→2，禁止跳转。

❌ 错误3：回滚后库存未恢复

原因：调拨失败时未清理在途库存。解决：在 catch 中增加库存回滚逻辑。

实战问答环节

Q1: 调拨过程中，如果调出仓库的库存不足怎么办？

A: 建议采用预占库存模式：创建调拨单时就扣减真实库存并标记为“在途”，入库时再转回真实库存，如果库存不足，直接返回错误提示，不生成调拨单。

Q2: 如何处理调拨单的撤销？

状态为“待审批”时可直接删除
状态为“出库中”时，需先回滚库存（将在途库存转回可用库存）
状态为“已入库”时，需做反调拨（生成逆向调拨单）

Q3: 我的项目使用ThinkPHP，如何实现自动生成调拨单号？

A: 可以在Model的beforeInsert事件中实现：

protected static function onBeforeInsert($model)
{
    $model->order_no = 'TR' . date('Ymd') . str_pad(rand(0, 9999), 4, '0', STR_PAD_LEFT);
}

Q4: 调拨单流程中是否需要审批环节？

A: 视业务复杂度而定，建议采用可配置审批流，如：

调拨数量 < 100件 → 自动审批
调拨数量 ≥ 100件 → 需上级审批

实现PHP库存调拨的核心在于事务一致性与并发控制，本文从数据库设计、后端代码、前端接口到常见问题提供了完整方案，实际项目中建议结合业务复杂度，引入消息队列和分布式锁优化，如果你正在开发多仓库系统，建议先画出状态机图，再编写代码，可大幅降低后期维护成本。

本文参考资料：PHP官方文档、ThinkPHP事务处理文档、MySQL InnoDB锁机制。