电商架构实战：高频营销活动系统中的“数据留存”与“业务解耦”设计

// 用户抽奖获奖结算逻辑片段
class LotteryService {
    public function recordUserReward(int $userId, int $activityId, int $goodsId) {
        // 1. 获取当前活动快照
        $activity = ActivityModel::find($activityId);
        
        // 2. 写入用户获奖流水（冗余活动快照信息）
        $rewardLog = new UserRewardLog();
        $rewardLog->user_id = $userId;
        $rewardLog->activity_id = $activityId;
        $rewardLog->activity_name_snapshot = $activity->name; // 快照名称
        $rewardLog->gameplay_type = $activity->type;
        $rewardLog->goods_id = $goodsId;
        $rewardLog->created_at = time();
        
        $rewardLog->save();
        
        // 3. 后续处理：将商品推入用户虚拟仓库...
    }
}

// 定义统一的玩法输出接口
interface GameplayStrategy {
    public function executePlay(int $userId, array $params): RewardResult;
}

// 玩法 A：概率盲盒
class ProbabilityBoxStrategy implements GameplayStrategy {
    public function executePlay(int $userId, array $params): RewardResult {
        // 执行概率随机算法...
        return new RewardResult($goodsId, $goodsType);
    }
}

// 玩法 B：一番赏（固定库存扣减）
class IchibanKujiStrategy implements GameplayStrategy {
    public function executePlay(int $userId, array $params): RewardResult {
        // 执行基于 Redis 队列的库存扣减与抽选...
        return new RewardResult($goodsId, $goodsType);
    }
}

// 后端返回的用户历史记录 API 结构设计
{
  "code": 200,
  "data": {
    "list": [
      {
        "record_id": "100293",
        "gameplay_name": "中秋限定福袋", // 即使活动下线，名称依然保留
        "cost_assets": "200金币",
        "reward_details": [
          {"goods_name": "隐藏款手办", "image": "url..."}
        ],
        "status_text": "已存入仓库",
        "created_at": "2023-09-29 10:00:00"
      }
    ]
  }
}

CREATE TABLE `user_warehouse_items` (
  `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
  `user_id` BIGINT UNSIGNED NOT NULL COMMENT '用户ID',
  `source_activity_id` INT NOT NULL COMMENT '来源活动ID（溯源用）',
  `goods_id` INT NOT NULL COMMENT '实物商品SKU_ID',
  `status` TINYINT NOT NULL DEFAULT 0 COMMENT '状态: 0=待处理, 1=已提货发货, 2=已折算兑换',
  `order_no` VARCHAR(64) DEFAULT NULL COMMENT '关联的最终发货订单号',
  `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  INDEX `idx_user_status` (`user_id`, `status`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='用户虚拟资产仓库';