直播带货系统搭建全流程拆解：私域直播如何实现稳定变现

用户端（小程序/H5/App）
        ↓
API网关（统一入口）
        ↓
业务服务层
 ├── 用户服务（User Service）
 ├── 商品服务（Product Service）
 ├── 订单服务（Order Service）
 ├── 直播服务（Live Service）
 ├── 营销服务（Marketing Service）
        ↓
基础设施
 ├── Redis（缓存/秒杀）
 ├── MySQL（数据存储）
 ├── MQ（消息队列）
 ├── CDN/RTC（直播流）

@PostMapping("/live/bindProduct")
public Result bindProduct(@RequestBody BindDTO dto){
    LiveRoom room = liveService.getRoom(dto.getRoomId());
    Product product = productService.getById(dto.getProductId());

    if(product.getStock() <= 0){
        return Result.fail("库存不足");
    }

    liveService.bindProduct(room.getId(), product.getId());
    return Result.ok();
}

// 秒杀/抢购下单逻辑
public String createOrder(Long userId, Long productId){
    String key = "stock:" + productId;

    Long stock = redisTemplate.decrement(key);
    if(stock < 0){
        return "已售罄";
    }

    // 异步入队
    mqProducer.send("order_queue", new OrderMsg(userId, productId));

    return "下单成功（处理中）";
}

@RabbitListener(queues = "order_queue")
public void handleOrder(OrderMsg msg){
    orderService.create(msg.getUserId(), msg.getProductId());
}

public void tagUser(Long userId, String tag){
    String key = "user:tag:" + userId;
    redisTemplate.opsForSet().add(key, tag);
}

public void calculateCommission(Order order){
    Long inviterId = userService.getInviter(order.getUserId());

    if(inviterId != null){
        BigDecimal commission = order.getAmount().multiply(new BigDecimal("0.1"));
        accountService.addBalance(inviterId, commission);
    }
}