预售秒杀活动产品系统

万达电影与开放世界动作游戏《鸣潮》开启“共鸣之旅”联名活动，推出角色立牌、徽章套装、主题海报等限定衍生品，覆盖全国700余家影城。活动上线首日，部分热门商品在30秒内售罄，系统瞬时并发请求量超过日常峰值的50倍。这只是冰山一角——万达电影全年计划落地数十场IP联名活动，覆盖动漫、游戏、影视等多个领域。
这揭示了影院衍生品零售的一个结构性需求：影城不再是单一的观影场所，正转型为IP衍生品的线下体验与零售节点。然而，每场联名活动的选品、定价、库存结构、参与影城范围、限购规则各不相同，不可能为每场活动单独开发一套系统。运营团队需要的是一套可复用的秒杀活动工具——能够快速配置活动规则、灵活对接不同供应商系统、自动完成库存同步与订单流转，实现“一次搭建、多场复用”。
更深层的挑战在于，影院衍生品是实物商品，链路比虚拟票务长得多。一端要对接上游供应商或内部进销存系统（如百盛），实现库存的精准同步；另一端要承接下游的物流配送和门店自取履约，保证实物交付体验。这要求系统在活动层面抽象出通用的商品模型、库存模型和订单模型，同时在接入层面提供标准化的外部系统对接接口，让每一场新活动都能像搭积木一样快速组装上线。

1、活动配置与管理
系统提供完整的活动生命周期管理能力。运营人员可在后台创建新活动，填写活动名称、预热时间、秒杀开始与结束时间、限购规则（如每人每商品限购1件）、适用影城范围等基础信息。活动状态支持草稿、待预热、预热中、进行中、已结束五阶段流转，每个阶段切换可手动或定时触发。活动支持复制功能，创建新活动时可从历史活动中复用配置模板，大幅降低配置工作量。
2、商品与库存管理
商品管理模块支持从供应商系统或内部进销存系统批量导入商品数据，包括商品名称、规格、图片、所属分类、关联影城等。系统抽象出“商品SKU—影城库存”的二级库存模型，同一款衍生品在不同影城可配置独立库存数量，互不影响。库存同步支持定时全量同步与手动触发同步两种模式，每次同步记录日志便于追溯。同步时系统自动校验数据完整性，发现异常即时告警。
3、下单与履约
用户端提供标准化的秒杀体验：活动倒计时、库存实时展示、一键抢购、限时支付。下单瞬间系统通过分布式锁与原子化库存扣减保障不超卖。支付环节支持物流配送与门店自取两种履约方式，用户可自由切换。订单生成后，系统自动将订单同步至供应商系统或内部系统完成下单。若同步失败，系统启动重试机制；多次重试仍失败则自动退款并回滚库存，保证数据一致。
4、监控与异常处理
后台提供活动大盘监控，实时展示订单量、支付成功率、库存消耗率、同步失败量等核心指标。异常订单列表支持按失败原因筛选，运营人员可对同步失败的订单进行手动重试或批量退款操作。系统还提供活动结束后的一键对账功能，自动比对本地订单与供应商系统订单，生成差异报告。

项目实现
系统采用分层微服务架构。接入层通过CDN缓存静态资源、WAF防护恶意流量、Nginx反向代理；网关层API网关负责鉴权、限流与路由；服务层拆分活动、商品、库存、订单、用户五个微服务；基础设施层以Redis为核心缓存，RocketMQ解耦异步任务，Nacos、XXL-Job、ELK等组件支撑服务治理与监控。

我主要负责商品域与库存域的核心链路，涵盖数据接入、高并发读写与库存扣减的完整闭环。
1、商品对接与展示：百盛是衍生品基础数据的唯一源头。我设计了标准化同步适配层，通过XXL-Job每5分钟全量拉取商品信息，经清洗转换后写入MySQL，同步日志完整记录，异常自动告警，同时支持手动触发补偿。数据入库后同步至Redis缓存，以Hash结构存储，列表与详情接口直读Redis不穿透数据库。图片等静态资源推送至CDN，设置Cache-Control: max-age=600，回源周期10分钟，版本号控制强制刷新。商品数据覆盖70个节点，列表接口压测QPS达每秒20万左右。
2、库存同步与扣减：库存从百盛采购单同步至Redis，以“活动ID+影城ID+商品ID”为粒度，每家影城仅同步一次不可修改。秒杀请求采用分布式锁加Lua脚本原子化方案：先获取商品粒度锁，再通过Lua脚本校验并预扣库存，杜绝超卖。扣减成功后发送事务消息至RocketMQ，消费端再次加锁完成数据库扣减与订单生成，幂等性设计保证可靠处理。库存覆盖50个节点，扣减链路压测QPS达每秒6至8万，满足高并发秒杀性能要求。