体育直播平台开发中的积分商城系统技术架构详解

                    ┌─────────────┐
                    │    用户端     │
                    └────┬────────┘
                         │ 兑换请求
                         ▼
               ┌─────────────────────┐
               │  积分商城控制器（ThinkPHP） │
               └────┬────┬──────────┘
                    │    │
     商品模块校验 ──┘    └───► 用户积分账户系统（MySQL + Redis缓存）
                    │
                    ▼
             兑换服务调用链：
    ┌──────────┬──────────────┬─────────────┐
    │ 扣减库存 │ 扣减积分（流水） │ 创建订单记录 │（本地事务或补偿机制）
    └──────────┴──────────────┴─────────────┘
                    │
                    ▼
          消息推送（RabbitMQ）更新库存状态/订单流转
                    │
                    ▼
         ┌──────────────────────┐
         │ 订单异步处理（定时任务、状态推进） │
         └──────────────────────┘

Key: shop:item:stock:<item_id>
Type: Integer  
用途：高并发下抢兑库存扣减（`DECRBY`）

Key: user:points:<user_id>
Type: Integer
用途：快速判断积分余额，降低 DB 压力

public function exchange(Request $request)
{
    $userId = $request->user()->id;
    $itemId = $request->param('item_id');
    $num = $request->param('num', 1);

    // 校验商品合法性
    $item = ShopItem::find($itemId);
    if (!$item || $item->status !== 'online') return error('商品不可兑换');

    // 校验积分
    if (!UserPoints::hasEnough($userId, $item->point_price * $num)) {
        return error('积分不足');
    }

    // Redis 扣减库存
    $redisKey = "shop:item:stock:{$itemId}";
    if (Redis::decrBy($redisKey, $num) < 0) {
        Redis::incrBy($redisKey, $num); // 回滚
        return error('库存不足');
    }

    DB::beginTransaction();
    try {
        // 1. 扣减积分（写流水）
        PointsLog::create([
            'user_id' => $userId,
            'amount' => -$item->point_price * $num,
            'type' => 'exchange',
            'ref_id' => 0
        ]);
        UserPoints::decrement('point_balance', $item->point_price * $num);

        // 2. 创建订单
        $order = ShopOrder::create([
            'user_id' => $userId,
            'item_id' => $itemId,
            'status' => 0
        ]);

        // 3. 异步发货 or 等待人工审核
        Queue::push('OrderProcess@handle', ['order_id' => $order->id]);

        DB::commit();
        return success('兑换成功');

    } catch (\Exception $e) {
        DB::rollBack();
        Redis::incrBy($redisKey, $num); // 回滚库存
        return error('兑换失败');
    }
}

# 每分钟处理队列中的订单状态
* * * * * php think order:dispatch

public function handle()
{
    $orders = ShopOrder::where('status', 0)->limit(10)->get();
    foreach ($orders as $order) {
        // 如果是虚拟商品，自动发货
        if ($order->item->is_virtual) {
            VirtualService::deliver($order);
        } else {
            // 推送到人工发货列表
            AdminNotify::send('new_order', $order);
        }

        $order->status = 2; // 标记为已发货
        $order->save();
    }
}