短剧线上交易系统产品研发架构方案

短剧线上交易系统 – 产品研发架构方案

一、 总体架构设计原则

1. 高内聚低耦合：按业务边界拆分微服务，独立部署与演进。
2. 安全合规优先：全流程满足《网络安全法》、广电总局内容审核要求及金融级数据安全标准。
3. 自动化与可观测：交易、分账全自动化，并构建完善监控、链路追踪、日志体系。
4. 扩展性：支持未来多语言、多币种、多国家合规的国际化阶段演进。

二、 业务架构与微服务划分

基于DDD（领域驱动设计），将系统划分为以下核心微服务：

三、 技术栈与基础设施选型

四、 关键业务流程架构设计

1. 版权上架-审核-存证流程

2. 智能匹配与交易撮合

• 离线部分：定时任务（每2小时）运行Spark/Flink任务，基于用户历史行为更新标签权重和推荐模型。
• 在线部分：
  1. 采购方设置需求标签（题材、时长、价格区间等）→ 请求存入采购方画像到ES。
  2. 推荐服务根据画像，使用ES查询 + 向量相似度（如BERT生成的剧集向量）召回Top-N作品。
  3. 版权方可主动查询采购方历史订单（从交易服务获取），系统推荐相似内容作品。
• 交易发起：采购方选择作品→交易服务创建协议→双方在线编辑关键条款→调用电子签章→协议生效→支付。

3. 支付分账与资金安全架构

• 资金托管：所有交易资金进入第三方支付机构的监管账户（如微信支付商家分账、连连支付资金管家），平台无法触碰。
• 智能分账引擎：
  • 版权方在作品上架时预设分账规则（如：版权方70%、编剧20%、平台10%）。
  • 支付成功后，支付分账服务同步记录订单，异步发送ORDER_PAID消息至RocketMQ。
  • 分账消费者消费消息，调用支付机构的分账API（如微信分账接口），传入分账接收方及金额。
  • 支付机构执行资金划转（T+3到账），回调通知系统更新分账状态。
• 分布式事务保障：使用Seata AT模式确保“订单支付成功”与“分账记录创建”的强一致；使用RocketMQ事务消息确保分账请求至少发送一次。

五、 数据模型关键设计（MySQL核心表）

• user (id, role_type, real_name, cert_no, sm4_encrypted_phone, status)
• copyright_cert (id, work_id, chain_tx_hash, cert_no, cert_time, blockchain_status)
• work (id, title, file_url, tags, price_type, price_value,备案号, status, 分账规则JSON)
• transaction_order (id, work_id, buyer_id, seller_id, total_amount, status, protocol_url, sign_time)
• split_rule (id, work_id, receiver_type, receiver_id, ratio, amount)
• split_record (id, order_id, split_rule_id, amount, channel_split_id, status, settle_time)

六、 合规与风控落地要点

• 内容合规：在内容审核服务中硬编码“未备案/无许可证不可上架”逻辑；每日定时任务扫描已上架作品，再次调用广电备案系统确认状态未变。
• 交易安全：
  • 所有支付调用走HTTPS + 双向证书（与支付机构约定）。
  • 敏感字段（身份证、手机号）在MySQL中使用SM4算法存储，应用层加解密。
  • 关键操作（修改分账规则、提现）需短信/邮件二次验证。
• 反作弊：反作弊服务通过设备指纹+行为埋点（鼠标轨迹、点击频率），结合规则引擎识别批量注册、黄牛刷单，自动加入黑名单或触发人工审核。

七、 部署与运维架构

• 环境：K8s集群（生产2个可用区，每个区3个节点），使用Ingress-Nginx暴露API网关。
• 数据高可用：
  • MySQL主从复制+定期全量备份到OSS。
  • Redis Cluster 三主三从。
  • ES集群至少3节点。
• 弹性伸缩：根据CPU/Memory指标或RocketMQ消息堆积量，HPA自动扩容支付分账服务、推荐服务实例数。
• 灾备：跨区域（如杭州+上海）备份核心数据库，RTO < 1小时，RPO < 15分钟。

八、 迭代阶段对应的架构演进计划

九、 研发关键成功指标的技术映射

以上架构方案可直接作为研发团队进行系统设计、技术选型、任务拆解的基线。