私有化B2B订货系统实战：核心模块设计与代码实现-程序员充电站

在当今企业数字化转型过程中，订货系统的私有化部署成为许多中大型企业的首选方案。与公有云SaaS服务相比，私有化部署在数据安全、系统定制、性能控制等方面更具优势。本文将围绕B2B订货系统的核心模块，结合实际代码示例，探讨如何从技术层面实现一个高效、稳定、可扩展的私有化订货系统。

一、系统架构设计概览

一个典型的私有化B2B订货系统可采用微服务架构，模块化设计，主要包括：

订单服务
商品服务
库存服务
客户服务
支付服务
权限服务

后端可采用Spring Cloud + MySQL + Redis技术栈，前端可使用Vue.js + Element UI，支持PC与移动端自适应。

二、订单管理模块实现

订单是系统的核心业务流，其状态机设计尤为重要。通常包括：待审核、已确认、出库中、已发货、已完成、已取消、退货中、已退货等状态。

订单创建代码示例

@Service
public class OrderService {

@Autowired
private OrderRepository orderRepository;
@Autowired
private InventoryService inventoryService;

/**
* 创建订单（包含库存预占）
*/
@Transactional
public Order createOrder(OrderCreateRequest request) {
// 1. 验证客户与商品信息
Customer customer = validateCustomer(request.getCustomerId());
List<OrderItem> items = validateItems(request.getItems());

// 2. 预占库存
for (OrderItem item : items) {
inventoryService.preDeductStock(item.getSkuId(),
item.getWarehouseId(),
item.getQuantity());
}

// 3. 生成订单号
String orderNo = generateOrderNo();

// 4. 创建订单实体
Order order = new Order();
order.setOrderNo(orderNo);
order.setCustomerId(customer.getId());
order.setItems(items);
order.setTotalAmount(calculateTotal(items));
order.setStatus(OrderStatus.PENDING);
order.setCreatedTime(LocalDateTime.now());

// 5. 保存订单
orderRepository.save(order);

// 6. 发送订单创建事件（用于触发审核流程）
eventPublisher.publishEvent(new OrderCreatedEvent(order));

return order;
}

private String generateOrderNo() {
// 生成规则：年月日 + 随机数 + 序列号
return "ORD" + LocalDate.now().format(DateTimeFormatter.BASIC_ISO_DATE)
+ RandomStringUtils.randomNumeric(4);
}
}

三、多仓库库存同步与预警机制

库存管理是B2B系统的难点，尤其是多仓库场景下的实时同步与预警。

库存同步与预警代码示例

class InventoryService:
def __init__(self, db, redis_client):
self.db = db
self.redis = redis_client
self.low_stock_threshold = 10 # 低库存阈值

def sync_stock_across_warehouses(self, sku_id, warehouse_from, warehouse_to, quantity):
"""
多仓库库存调拨同步
"""
with self.db.transaction():
# 1. 减少源仓库库存
self.db.execute(
"UPDATE inventory SET stock = stock - %s WHERE sku_id = %s AND warehouse_id = %s",
(quantity, sku_id, warehouse_from)
)

# 2. 增加目标仓库库存
self.db.execute(
"UPDATE inventory SET stock = stock + %s WHERE sku_id = %s AND warehouse_id = %s",
(quantity, sku_id, warehouse_to)
)

# 3. 更新Redis缓存
cache_key_from = f"stock:{sku_id}:{warehouse_from}"
cache_key_to = f"stock:{sku_id}:{warehouse_to}"
self.redis.decrby(cache_key_from, quantity)
self.redis.incrby(cache_key_to, quantity)

# 4. 检查库存预警
self.check_stock_alert(sku_id, warehouse_from)
self.check_stock_alert(sku_id, warehouse_to)

def check_stock_alert(self, sku_id, warehouse_id):
"""
库存预警检查
"""
stock = self.get_current_stock(sku_id, warehouse_id)
if stock <= self.low_stock_threshold:
# 触发预警：发送邮件/短信/系统通知
self.send_alert({
"type": "LOW_STOCK",
"sku_id": sku_id,
"warehouse_id": warehouse_id,
"current_stock": stock,
"threshold": self.low_stock_threshold,
"timestamp": datetime.now()
})

def get_current_stock(self, sku_id, warehouse_id):
"""
获取实时库存（优先从缓存读取）
"""
cache_key = f"stock:{sku_id}:{warehouse_id}"
cached = self.redis.get(cache_key)
if cached is not None:
return int(cached)

# 缓存未命中，从数据库查询
row = self.db.fetch_one(
"SELECT stock FROM inventory WHERE sku_id = %s AND warehouse_id = %s",
(sku_id, warehouse_id)
)
stock = row['stock'] if row else 0
self.redis.setex(cache_key, 300, stock) # 缓存5分钟
return stock