库存管理

引言 在跨境电商业务中，库存成本核算是一个看似简单实则复杂的问题。同一个SKU，不同批次的采购价格可能差异很大——汇率波动、供应商调价、运费变化都会影响入库成本。当这个SKU出库时，应该按什么成本计算？ 这个问题直接影响： 毛利计算：成本算错，毛利就错 库存估值：影响资产负债表 定价决策：成本不准，定价就没有依据 税务合规：成本核算方法需要符合会计准则 本文将深入讲解库存成本核算的核心方法，重点介绍移动加权平均法的算法实现、特殊场景处理和月结流程设计。 一、成本核算方法对比 1.1 三种主流方法 方法 原理 优点 缺点 适用场景 先进先出法(FIFO) 先入库的先出库 符合实物流转，成本反映真实 计算复杂，需追踪批次 有保质期的商品 移动加权平均法 每次入库重新计算平均成本 成本平滑，计算相对简单 无法追溯具体批次成本 标准化商品 个别计价法 每个商品单独计价 成本最准确 管理成本高 高价值、可识别商品 1.2 跨境电商的选择 对于年营收5-7亿的跨境电商，移动加权平均法是最佳选择： 选择理由： SKU数量大：通常有数万SKU，FIFO管理成本太高 标准化商品：大部分是标准化产品，无需追溯批次 价格波动频繁：汇率、运费变化大，平均法能平滑波动 财务软件兼容：金蝶、用友等主流财务软件都支持 不适用场景： 有保质期的商品（食品、化妆品）→ 建议FIFO 高价值单品（珠宝、艺术品）→ 建议个别计价 有序列号管理需求的商品 → 建议个别计价 二、移动加权平均算法详解 2.1 核心公式 新单位成本 = (原库存金额 + 本次入库金额) / (原库存数量 + 本次入库数量) 示例： 原库存：100件，单位成本10元，库存金额1000元 本次入库：50件，单位成本12元，入库金额600元 新单位成本 = (1000 + 600) / (100 + 50) = 10.67元 2.2 数据模型设计 -- 库存成本主表 CREATE TABLE inventory_cost ( id BIGINT PRIMARY KEY AUTO_INCREMENT, sku_code VARCHAR(50) NOT NULL COMMENT 'SKU编码', warehouse_code VARCHAR(50) NOT NULL COMMENT '仓库编码', quantity DECIMAL(18,4) NOT NULL DEFAULT 0 COMMENT '当前库存数量', unit_cost DECIMAL(18,6) NOT NULL DEFAULT 0 COMMENT '单位成本(6位小数)', total_cost DECIMAL(18,4) NOT NULL DEFAULT 0 COMMENT '库存总成本', last_in_cost DECIMAL(18,6) COMMENT '最近入库成本', last_in_time DATETIME COMMENT '最近入库时间', version INT NOT NULL DEFAULT 0 COMMENT '乐观锁版本号', created_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, UNIQUE KEY uk_sku_warehouse (sku_code, warehouse_code) ) COMMENT '库存成本主表'; -- 成本变动流水表 CREATE TABLE inventory_cost_log ( id BIGINT PRIMARY KEY AUTO_INCREMENT, sku_code VARCHAR(50) NOT NULL COMMENT 'SKU编码', warehouse_code VARCHAR(50) NOT NULL COMMENT '仓库编码', biz_type VARCHAR(30) NOT NULL COMMENT '业务类型:PURCHASE_IN/SALE_OUT/RETURN_IN/TRANSFER/ADJUST', biz_no VARCHAR(50) NOT NULL COMMENT '业务单号', direction TINYINT NOT NULL COMMENT '方向:1入库,-1出库', quantity DECIMAL(18,4) NOT NULL COMMENT '变动数量', unit_cost DECIMAL(18,6) NOT NULL COMMENT '本次单位成本', amount DECIMAL(18,4) NOT NULL COMMENT '本次金额', before_quantity DECIMAL(18,4) NOT NULL COMMENT '变动前数量', before_unit_cost DECIMAL(18,6) NOT NULL COMMENT '变动前单位成本', before_total_cost DECIMAL(18,4) NOT NULL COMMENT '变动前总成本', after_quantity DECIMAL(18,4) NOT NULL COMMENT '变动后数量', after_unit_cost DECIMAL(18,6) NOT NULL COMMENT '变动后单位成本', after_total_cost DECIMAL(18,4) NOT NULL COMMENT '变动后总成本', created_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, INDEX idx_sku_warehouse (sku_code, warehouse_code), INDEX idx_biz_no (biz_no), INDEX idx_created_time (created_time) ) COMMENT '成本变动流水表'; 2.3 核心算法实现 /** * 库存成本服务 * 实现移动加权平均法 */ @Service @Slf4j public class InventoryCostService { @Autowired private InventoryCostMapper costMapper; @Autowired private InventoryCostLogMapper logMapper; /** * 入库成本计算 * 核心公式：新单位成本 = (原库存金额 + 本次入库金额) / (原库存数量 + 本次入库数量) */ @Transactional(rollbackFor = Exception.class) public void processInbound(CostChangeRequest request) { String skuCode = request.getSkuCode(); String warehouseCode = request.getWarehouseCode(); BigDecimal inQuantity = request.getQuantity(); BigDecimal inUnitCost = request.getUnitCost(); // 1. 获取当前库存成本（加锁） InventoryCost cost = costMapper.selectForUpdate(skuCode, warehouseCode); // 2. 记录变动前状态 CostSnapshot before = createSnapshot(cost); // 3. 计算新成本 BigDecimal beforeQuantity = cost != null ? cost.getQuantity() : BigDecimal.ZERO; BigDecimal beforeTotalCost = cost != null ? cost.getTotalCost() : BigDecimal.ZERO; BigDecimal inAmount = inQuantity.multiply(inUnitCost); BigDecimal afterQuantity = beforeQuantity.add(inQuantity); BigDecimal afterTotalCost = beforeTotalCost.add(inAmount); // 移动加权平均计算 BigDecimal afterUnitCost; if (afterQuantity.compareTo(BigDecimal.ZERO) > 0) { afterUnitCost = afterTotalCost.divide(afterQuantity, 6, RoundingMode.HALF_UP); } else { afterUnitCost = inUnitCost; // 库存为0时，使用入库成本 } // 4. 更新库存成本 if (cost == null) { cost = new InventoryCost(); cost.setSkuCode(skuCode); cost.setWarehouseCode(warehouseCode); cost.setQuantity(afterQuantity); cost.setUnitCost(afterUnitCost); cost.setTotalCost(afterTotalCost); cost.setLastInCost(inUnitCost); cost.setLastInTime(new Date()); costMapper.insert(cost); } else { cost.setQuantity(afterQuantity); cost.setUnitCost(afterUnitCost); cost.setTotalCost(afterTotalCost); cost.setLastInCost(inUnitCost); cost.setLastInTime(new Date()); int rows = costMapper.updateWithVersion(cost); if (rows == 0) { throw new ConcurrentModificationException("库存成本更新冲突，请重试"); } } // 5. 记录成本流水 CostSnapshot after = createSnapshot(cost); saveCostLog(request, before, after, 1); log.info("入库成本计算完成: sku={}, warehouse={}, 入库数量={}, 入库成本={}, " + "新单位成本={}, 新库存数量={}", skuCode, warehouseCode, inQuantity, inUnitCost, afterUnitCost, afterQuantity); } /** * 出库成本计算 * 出库时按当前单位成本计算 */ @Transactional(rollbackFor = Exception.class) public BigDecimal processOutbound(CostChangeRequest request) { String skuCode = request.getSkuCode(); String warehouseCode = request.getWarehouseCode(); BigDecimal outQuantity = request.getQuantity(); // 1. 获取当前库存成本（加锁） InventoryCost cost = costMapper.selectForUpdate(skuCode, warehouseCode); if (cost == null || cost.getQuantity().compareTo(outQuantity) < 0) { throw new BusinessException("库存不足，无法出库"); } // 2. 记录变动前状态 CostSnapshot before = createSnapshot(cost); // 3. 计算出库金额（使用当前单位成本） BigDecimal outUnitCost = cost.getUnitCost(); BigDecimal outAmount = outQuantity.multiply(outUnitCost); // 4. 更新库存 BigDecimal afterQuantity = cost.getQuantity().subtract(outQuantity); BigDecimal afterTotalCost = cost.getTotalCost().subtract(outAmount); // 单位成本保持不变（出库不改变单位成本） cost.setQuantity(afterQuantity); cost.setTotalCost(afterTotalCost); int rows = costMapper.updateWithVersion(cost); if (rows == 0) { throw new ConcurrentModificationException("库存成本更新冲突，请重试"); } // 5. 记录成本流水 CostSnapshot after = createSnapshot(cost); request.setUnitCost(outUnitCost); // 设置出库成本 saveCostLog(request, before, after, -1); log.info("出库成本计算完成: sku={}, warehouse={}, 出库数量={}, 出库成本={}, " + "出库金额={}", skuCode, warehouseCode, outQuantity, outUnitCost, outAmount); return outAmount; // 返回出库金额，用于计算销售成本 } /** * 创建成本快照 */ private CostSnapshot createSnapshot(InventoryCost cost) { CostSnapshot snapshot = new CostSnapshot(); if (cost != null) { snapshot.setQuantity(cost.getQuantity()); snapshot.setUnitCost(cost.getUnitCost()); snapshot.setTotalCost(cost.getTotalCost()); } else { snapshot.setQuantity(BigDecimal.ZERO); snapshot.setUnitCost(BigDecimal.ZERO); snapshot.setTotalCost(BigDecimal.ZERO); } return snapshot; } /** * 保存成本流水 */ private void saveCostLog(CostChangeRequest request, CostSnapshot before, CostSnapshot after, int direction) { InventoryCostLog log = new InventoryCostLog(); log.setSkuCode(request.getSkuCode()); log.setWarehouseCode(request.getWarehouseCode()); log.setBizType(request.getBizType()); log.setBizNo(request.getBizNo()); log.setDirection(direction); log.setQuantity(request.getQuantity()); log.setUnitCost(request.getUnitCost()); log.setAmount(request.getQuantity().multiply(request.getUnitCost())); log.setBeforeQuantity(before.getQuantity()); log.setBeforeUnitCost(before.getUnitCost()); log.setBeforeTotalCost(before.getTotalCost()); log.setAfterQuantity(after.getQuantity()); log.setAfterUnitCost(after.getUnitCost()); log.setAfterTotalCost(after.getTotalCost()); logMapper.insert(log); } } 2.4 并发控制 库存成本计算必须保证并发安全，否则会导致成本计算错误。 ...

引言：跨境电商ERP的特殊性 传统ERP（如SAP、Oracle）是为制造业设计的，而跨境电商有其特殊性： 维度 传统ERP 跨境电商ERP 销售渠道 单一/少量 多渠道（Amazon、eBay等） 币种 单一 多币种 仓库 集中 分布式（国内+海外） 订单量 少量大单 大量小单 库存管理 批次管理 SKU+批次+效期 因此，跨境电商需要一套适合自己的ERP设计。 一、ERP在系统矩阵中的定位 1.1 系统边界 ┌─────────────────────────────────────────────────────┐ │ OMS │ │ 订单管理（销售端） │ └─────────────────────┬───────────────────────────────┘ │ 销售数据 ▼ ┌─────────────────────────────────────────────────────┐ │ ERP │ │ ┌─────────┐ ┌─────────┐ ┌─────────┐ │ │ │ 财务模块 │ │ 采购模块 │ │ 库存模块 │ │ │ └─────────┘ └─────────┘ └─────────┘ │ └─────────────────────┬───────────────────────────────┘ │ 采购/入库指令 ▼ ┌─────────────────────────────────────────────────────┐ │ WMS │ │ 仓储执行（实物管理） │ └─────────────────────────────────────────────────────┘ 1.2 职责划分 功能 OMS ERP WMS 销售订单 ✓ 可售库存 ✓ 财务核算 ✓ 采购管理 ✓ 账面库存 ✓ 实物库存 ✓ 库位管理 ✓ 二、财务模块设计 2.1 跨境电商财务特点 多币种挑战： ...

引言 库存准确性是WMS的生命线。本文深入讲解库存管理的核心业务，包括库存查询、盘点、调拨和预警机制。 1. 库存的三个维度 1.1 可用库存、锁定库存、在途库存 总库存 = 可用库存 + 锁定库存 + 在途库存 示例： 总库存: 1000件 可用库存: 800件（可以销售） 锁定库存: 150件（已分配订单，未出库） 在途库存: 50件（调拨中，未到达） 1.2 库存扣减逻辑（防止超卖） -- 悲观锁方案 BEGIN; SELECT available_qty FROM inventory WHERE sku_code = 'iPhone-15Pro' FOR UPDATE; -- 扣减库存（原子操作） UPDATE inventory SET available_qty = available_qty - 1, locked_qty = locked_qty + 1 WHERE sku_code = 'iPhone-15Pro' AND available_qty >= 1; -- 防止超卖 COMMIT; 2. 库存查询与统计 2.1 多维度查询 1. 按SKU查询 SELECT * FROM inventory WHERE sku_code = 'iPhone-15Pro'; 2. 按库位查询 SELECT * FROM inventory WHERE location_code = 'A01-02-03'; 3. 按批次查询 SELECT * FROM inventory WHERE batch_no = '20251120'; 4. 库龄分析 ...

引言 想象这样一个场景：用户在购物车中看到商品显示"有货"，提交订单时却提示"库存不足"。或者更糟糕的情况：订单已支付，仓库却发现没有库存可发货。这些问题的根源都指向一个核心能力：库存预占。 库存预占是OMS系统的生命线。它要解决的核心问题是：在下单到发货的整个周期内，如何保证已承诺给用户的商品库存不被其他订单抢走？本文将从第一性原理出发，系统性地探讨库存预占与释放机制的设计与实现。 库存预占的本质 什么是库存预占？ 库存预占（Inventory Reservation）是指在订单创建时，为订单中的商品临时锁定库存，防止被其他订单占用。 库存状态转换： 可用库存 → 预占库存 → 已出库 ↓ 释放回可用（订单取消） 为什么需要库存预占？ 场景1：下单到支付的时间窗口 用户操作流程： 1. 加入购物车（不预占） 2. 提交订单（预占库存）← 关键点 3. 支付（15分钟内） 4. 发货 问题：如果不预占，步骤2到步骤3之间，库存可能被其他用户购买 场景2：支付到发货的时间窗口 订单处理流程： 1. 用户支付成功 2. 订单进入待发货队列 3. 仓库拣货打包（可能需要几小时） 4. 发货 问题：如果不预占，步骤1到步骤4之间，库存可能被超卖 场景3：高并发秒杀 秒杀场景： - 库存：100件 - 请求：10000个并发请求 - 目标：保证只有前100个请求成功，且不超卖 核心挑战：如何在毫秒级时间内准确预占库存？ 库存预占的核心目标 防止超卖：已售数量 ≤ 实际库存 保证时效：预占操作要快（毫秒级） 支持释放：订单取消/超时后自动释放 高并发：支持万级QPS的库存预占 数据一致性：分布式环境下保证强一致性 库存预占流程设计 标准预占流程 class InventoryReservationService: """库存预占服务""" def reserve(self, order): """ 预占库存的标准流程 1. 校验库存可用性 2. 锁定库存 3. 扣减可用库存 4. 增加预占库存 5. 记录预占日志 """ try: # 1. 校验库存 self._validate_inventory(order) # 2. 获取分布式锁 lock = self._acquire_lock(order.items) # 3. 执行预占 reservations = [] for item in order.items: reservation = self._reserve_single_item( sku_id=item.sku_id, warehouse_id=item.warehouse_id, quantity=item.quantity, order_id=order.order_id ) reservations.append(reservation) # 4. 释放锁 self._release_lock(lock) return ReservationResult( success=True, reservations=reservations ) except InsufficientStockException as e: return ReservationResult( success=False, error=str(e) ) def _reserve_single_item(self, sku_id, warehouse_id, quantity, order_id): """预占单个SKU的库存""" # 原子操作：扣减可用库存，增加预占库存 with self.db.transaction(): # 1. 查询当前库存（加行锁） inventory = self.db.query( """ SELECT available, reserved FROM inventory WHERE sku_id = %s AND warehouse_id = %s FOR UPDATE """, (sku_id, warehouse_id) ) # 2. 检查库存充足性 if inventory.available < quantity: raise InsufficientStockException( f"SKU {sku_id} 库存不足" ) # 3. 更新库存 self.db.execute( """ UPDATE inventory SET available = available - %s, reserved = reserved + %s WHERE sku_id = %s AND warehouse_id = %s """, (quantity, quantity, sku_id, warehouse_id) ) # 4. 记录预占记录 reservation = InventoryReservation( reservation_id=generate_id(), order_id=order_id, sku_id=sku_id, warehouse_id=warehouse_id, quantity=quantity, status='RESERVED', expire_at=datetime.now() + timedelta(minutes=30) ) self.db.insert('inventory_reservations', reservation) return reservation 数据库设计 -- 库存表 CREATE TABLE inventory ( id BIGINT PRIMARY KEY AUTO_INCREMENT, sku_id VARCHAR(64) NOT NULL, warehouse_id VARCHAR(64) NOT NULL, available INT NOT NULL DEFAULT 0, -- 可用库存 reserved INT NOT NULL DEFAULT 0, -- 预占库存 sold INT NOT NULL DEFAULT 0, -- 已售库存 total INT NOT NULL DEFAULT 0, -- 总库存 version INT NOT NULL DEFAULT 0, -- 乐观锁版本号 created_at DATETIME NOT NULL, updated_at DATETIME NOT NULL, UNIQUE KEY uk_sku_warehouse (sku_id, warehouse_id), INDEX idx_sku (sku_id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- 库存预占记录表 CREATE TABLE inventory_reservations ( id BIGINT PRIMARY KEY AUTO_INCREMENT, reservation_id VARCHAR(64) NOT NULL UNIQUE, order_id VARCHAR(64) NOT NULL, sku_id VARCHAR(64) NOT NULL, warehouse_id VARCHAR(64) NOT NULL, quantity INT NOT NULL, status VARCHAR(32) NOT NULL, -- RESERVED, CONSUMED, RELEASED expire_at DATETIME NOT NULL, -- 预占过期时间 created_at DATETIME NOT NULL, released_at DATETIME, INDEX idx_order (order_id), INDEX idx_expire (expire_at, status) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- 库存变更日志表 CREATE TABLE inventory_change_logs ( id BIGINT PRIMARY KEY AUTO_INCREMENT, log_id VARCHAR(64) NOT NULL UNIQUE, sku_id VARCHAR(64) NOT NULL, warehouse_id VARCHAR(64) NOT NULL, change_type VARCHAR(32) NOT NULL, -- RESERVE, RELEASE, CONSUME quantity INT NOT NULL, before_available INT NOT NULL, after_available INT NOT NULL, order_id VARCHAR(64), created_at DATETIME NOT NULL, INDEX idx_sku (sku_id), INDEX idx_order (order_id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; 库存预占失败处理 失败场景分类 class ReservationFailureHandler: """预占失败处理器""" def handle_failure(self, order, failure_reason): """处理预占失败""" if isinstance(failure_reason, InsufficientStockException): return self._handle_insufficient_stock(order) elif isinstance(failure_reason, DistributedLockException): return self._handle_lock_timeout(order) elif isinstance(failure_reason, DatabaseException): return self._handle_db_error(order) else: return self._handle_unknown_error(order) def _handle_insufficient_stock(self, order): """处理库存不足""" # 1. 尝试部分预占 partial_result = self._try_partial_reservation(order) if partial_result.has_available_items(): return self._create_partial_order( order, partial_result.available_items ) # 2. 尝试跨仓调拨 transfer_result = self._try_warehouse_transfer(order) if transfer_result.success: return self._retry_reservation(order) # 3. 推荐替代商品 alternatives = self._find_alternatives(order) return ReservationResult( success=False, error="库存不足", alternatives=alternatives ) def _handle_lock_timeout(self, order): """处理锁超时""" # 重试策略：指数退避 for retry in range(3): time.sleep(0.1 * (2 ** retry)) # 100ms, 200ms, 400ms try: return self.reservation_service.reserve(order) except DistributedLockException: continue # 降级策略：异步处理 return self._async_reservation(order) 部分预占策略 class PartialReservationStrategy: """部分预占策略""" def try_partial_reservation(self, order): """尝试部分预占""" available_items = [] unavailable_items = [] for item in order.items: try: # 尝试预占单个商品 reservation = self.reservation_service.reserve_single_item( item ) available_items.append(item) except InsufficientStockException: unavailable_items.append(item) return PartialReservationResult( available_items=available_items, unavailable_items=unavailable_items, fulfillment_rate=len(available_items) / len(order.items) ) def should_accept_partial(self, result, order): """判断是否接受部分预占""" # 策略1：订单金额超过阈值，接受部分预占 if order.total_amount > 500 and result.fulfillment_rate > 0.8: return True # 策略2：重要商品都有货，接受部分预占 critical_items = [i for i in order.items if i.is_critical] if all(i in result.available_items for i in critical_items): return True # 策略3：用户设置允许部分发货 if order.allow_partial_shipment: return True return False 库存释放触发条件 自动释放场景 class InventoryReleaseService: """库存释放服务""" def __init__(self): # 定义释放规则 self.release_rules = [ # 规则1：订单取消 ReleaseRule( name="order_cancelled", condition=lambda order: order.status == 'CANCELLED', action=self._release_all ), # 规则2：支付超时 ReleaseRule( name="payment_timeout", condition=lambda order: ( order.status == 'PENDING_PAYMENT' and datetime.now() > order.payment_deadline ), action=self._release_all ), # 规则3：部分退货 ReleaseRule( name="partial_refund", condition=lambda order: order.has_partial_refund(), action=self._release_partial ), # 规则4：预占过期 ReleaseRule( name="reservation_expired", condition=lambda reservation: ( datetime.now() > reservation.expire_at ), action=self._release_expired ) ] def release_for_order(self, order): """为订单释放库存""" # 1. 查询订单的所有预占记录 reservations = self.reservation_repo.find_by_order(order.order_id) # 2. 执行释放 released_count = 0 for reservation in reservations: if reservation.status != 'RESERVED': continue try: self._release_reservation(reservation) released_count += 1 except Exception as e: self.logger.error( f"释放预占失败: {reservation.reservation_id}", exc_info=e ) return ReleaseResult( success=True, released_count=released_count ) def _release_reservation(self, reservation): """释放单个预占""" with self.db.transaction(): # 1. 更新库存（原子操作） affected_rows = self.db.execute( """ UPDATE inventory SET available = available + %s, reserved = reserved - %s WHERE sku_id = %s AND warehouse_id = %s AND reserved >= %s """, ( reservation.quantity, reservation.quantity, reservation.sku_id, reservation.warehouse_id, reservation.quantity ) ) if affected_rows == 0: raise InventoryMismatchException( f"预占库存不足: {reservation.reservation_id}" ) # 2. 更新预占记录状态 self.db.execute( """ UPDATE inventory_reservations SET status = 'RELEASED', released_at = NOW() WHERE reservation_id = %s """, (reservation.reservation_id,) ) # 3. 记录变更日志 self._log_inventory_change( sku_id=reservation.sku_id, warehouse_id=reservation.warehouse_id, change_type='RELEASE', quantity=reservation.quantity, order_id=reservation.order_id ) 定时释放任务 class ScheduledReleaseJob: """定时释放任务""" def run(self): """ 每分钟执行一次，释放过期预占 批量处理策略： 1. 查询过期预占（分批查询） 2. 批量释放库存 3. 批量更新预占状态 """ batch_size = 1000 offset = 0 while True: # 1. 查询过期预占 expired_reservations = self.reservation_repo.find_expired( limit=batch_size, offset=offset ) if not expired_reservations: break # 2. 按仓库和SKU分组 grouped = defaultdict(list) for res in expired_reservations: key = (res.sku_id, res.warehouse_id) grouped[key].append(res) # 3. 批量释放 for (sku_id, warehouse_id), reservations in grouped.items(): total_quantity = sum(r.quantity for r in reservations) # 批量更新库存 self.db.execute( """ UPDATE inventory SET available = available + %s, reserved = reserved - %s WHERE sku_id = %s AND warehouse_id = %s """, (total_quantity, total_quantity, sku_id, warehouse_id) ) # 批量更新预占状态 reservation_ids = [r.reservation_id for r in reservations] self.db.execute( """ UPDATE inventory_reservations SET status = 'RELEASED', released_at = NOW() WHERE reservation_id IN %s """, (tuple(reservation_ids),) ) offset += batch_size # 限流保护 time.sleep(0.1) 库存预占的并发控制 数据库层面的并发控制 方案1：悲观锁（SELECT FOR UPDATE） ...

引言 库存管理是供应链管理的核心环节，直接影响企业的运营成本和服务水平。据统计，库存成本通常占企业总成本的30-40%，优化库存管理可以降低成本20-30%。 本文将系统化介绍库存管理的核心概念、经典模型和实战方法，为后续深入学习打下基础。 1. 库存管理概述 1.1 什么是库存管理 定义：在保证供应的前提下，最小化库存成本。 核心目标： 降低库存成本 提高服务水平 平衡供需关系 1.2 库存的三大成本 持有成本： 仓储费：租金、水电、人工 资金占用：库存价值 × 资金成本率 损耗：过期、破损、盗窃 订货成本： 订单处理费 运输费 验收费 缺货成本： 销售损失 客户流失 紧急采购加价 示例计算： 年需求量: 10000件 单价: 100元 持有成本率: 20%/年 订货成本: 500元/次 持有成本 = 平均库存 × 单价 × 持有成本率 = 500 × 100 × 20% = 10000元/年 订货成本 = 订货次数 × 订货成本 = 20 × 500 = 10000元/年 总成本 = 10000 + 10000 = 20000元/年 2. 库存分类管理 2.1 ABC分类法 原理：帕累托法则(80/20法则) ...

引言 在上一篇《WMS系统全景图》中，我们从宏观层面理解了WMS的定义、核心功能和业务流程。本文将深入微观层面，系统性地学习WMS领域的核心概念、数据模型设计、库位编码规则和库存状态流转。掌握这些基础术语和数据结构,是设计和实施WMS系统的基石。 1. 核心概念 1.1 仓库层级结构 现代仓库采用层级化管理，从宏观到微观分为多个层级： Warehouse（仓库） └─ Zone（库区） └─ Aisle（巷道/排） └─ Shelf（货架/列） └─ Bin（库位/层） 详细说明： 1. Warehouse（仓库） 定义：独立的物理仓储建筑 示例： 京东北京亚洲一号仓库 亚马逊上海FBA仓库 菜鸟广州智能仓库 属性： 仓库编码：WH001、WH002 仓库名称：北京仓、上海仓 仓库地址：北京市通州区XX路XX号 仓库类型：常温仓、冷链仓、保税仓 2. Zone（库区） 定义：仓库内的功能分区 分类： 按功能分：收货区、质检区、存储区、拣货区、打包区、发货区 按温度分：常温区、冷藏区（0-4℃）、冷冻区（-18℃以下） 按商品属性分：高价值区、普通区、退货区、不良品区 示例： A区：电子产品存储区 B区：日用品存储区 C区：食品冷藏区 D区：退货隔离区 3. Aisle（巷道/排） 定义：库区内的货架排列行 编码：A01、A02、A03…（A区第1排、第2排、第3排） 设计原则： 巷道宽度：叉车通行需2.5-3米 人工拣货巷道：1.2-1.5米 单向 vs 双向：根据仓库布局 4. Shelf（货架/列） 定义：巷道内的货架列 编码：A01-02（A区第1排第2列） 货架类型： 重型货架：存储托盘货物 中型货架：存储箱装货物 轻型货架：存储小件商品 自动化货架：配合穿梭车、堆垛机 5. Bin（库位/层） 定义：货架上的最小存储单元 编码：A01-02-03（A区第1排第2列第3层） 属性： 库位尺寸：长×宽×高（米） 承重能力：最大载重（公斤） 库位状态：可用、占用、锁定、维护 温湿度要求：常温、冷藏、冷冻 实际案例：亚马逊FBA仓库 仓库: SHG1（上海仓库1号） 库区: A区（电子产品）、B区（日用品）、C区（图书） 库位示例: A-05-12-03 └─ A: A区（电子产品） └─ 05: 第5排 └─ 12: 第12列 └─ 03: 第3层 1.2 SKU、批次、序列号 1. SKU（Stock Keeping Unit，库存单位） ...