系统分层架构

无状态能力服务 × 工作流编排 × 多产品复用

产品层 Product Layer
电商RBF
SaaS RBF
内容创作RBF
传统企业RBF
供应链RBF
工作流编排
工作流编排层 Temporal / Camunda Workflow Engine
电商RBF工作流
GMV监控 · 平台授权
SaaS RBF工作流
MRR监控 · 订阅分析
动态还款工作流
收入变化触发还款
调用原子化能力
能力服务层 无状态微服务 · 水平扩展
KYC验证
收入核验
风控引擎
尽调服务
反欺诈
还款追踪
融资额度
通知服务
事件驱动
事件总线 Apache Kafka · 高吞吐量 · 持久化
RevenueUpdated还款已计算RiskScoreChanged异常已检测LoanCapApproachingCollectionTriggered
数据持久化
基础设施层
PostgreSQL
Redis缓存
ClickHouse
Elasticsearch
S3存储

四大设计原则

能力原子化
每个业务能力封装为独立微服务
高度复用，独立部署和扩展
无状态设计
服务间通过事件和参数传递状态
水平扩容、故障隔离、幂等保证
工作流编排
Temporal引擎管理复杂业务流程
长期运行任务、状态恢复、补偿逻辑
事件驱动
Kafka事件总线实现异步解耦
实时响应、状态同步、审计追溯

能力服务调用

点击任意服务卡片，模拟真实API调用并查看响应结果

KYC验证服务
P99 <3s · 99.9%可用
POST /api/kyc/verify
活体检测 · OCR识别 · 制裁名单 · PEP筛查 · 工商验证
收入核验服务
P99 <5s · 99.95%可用
POST /api/revenue/verify
多平台聚合 · 趋势分析 · 季节性识别 · 稳定性评分
风控评分引擎
P99 <500ms · 99.99%可用
POST /api/risk/score
RBF专用评分 · 多维特征 · 可解释性输出 · 推荐条款
还款追踪服务
P99 <200ms · 99.99%可用
POST /api/repayment/calculate
动态计算 · 节假日豁免 · 最低还款保护 · 倍数封顶
反欺诈检测服务
P99 <400ms · 99.97%可用
POST /api/antifraud/check
设备指纹 · 行为分析 · 关联图谱 · 黑名单核查 · 团伙风险
尽职调查服务
P99 <30s · 99.5%可用
POST /api/duediligence/assess
工商核查 · 财务健康 · 合规审查 · 舆情分析 · 行业评估
通知推送服务
P99 <150ms · 99.8%可用
POST /api/notification/send
短信 · 邮件 · 微信 · App推送 · 多渠道并发投递
融资额度决策
P99 <300ms · 99.98%可用
POST /api/credit/decide
综合评分 · 额度测算 · 条款定价 · 拒绝归因 · 申诉判断

工作流编排设计器

拖拽能力节点 · 自定义产品流程 · 一键运行验证

触发器
能力服务
逻辑控制
输出动作
从左侧拖拽节点到此处
或点击右上角加载预设模板
节点属性
点击画布中的节点
查看和配置属性
节点: 0 连线: 0 提示: 从左侧拖拽节点 · 点击节点配置参数 · 拖动输出端口连线

事件驱动架构

Kafka事件总线 · 实时事件流模拟

事件流转架构图 · 点击「启动事件流」可逐步演示下方完整流程
收入服务
数据采集
收入数据已更新
还款服务
动态计算
还款金额已计算
自动扣款
资金划转
融资上限即将触达
融资管理
结清检查
收入异常已检测
风险监控
预警处置
吞吐量: 12,450 msg/s 积压: 234
收入数据已更新 还款金额已计算 收入异常已检测 融资上限即将触达
Kafka消费者 · 收入事件主题 0 条事件
点击「启动事件流演示」开始播放完整事件序列

异常检测规则

收入突降检测
单日下降 >30% HIGH
单日下降 >50% CRITICAL
推荐动作：立即联系客户 · 审查平台数据 · 冻结新增授信
持续低收入检测
近7天均值 < 历史30天50% MEDIUM
持续14天低迷 HIGH
推荐动作：安排业务审查 · 提供还款重组方案

收入分成计算器

营业额 → 净收入 → RBF分成方案 → 各投资方分润

月营业额（GMV）

¥10万¥500万
RBF 分润公式
投资方分润 = 营业额 × 分成比例 × 调整系数
经营者留存 = 营业额 − Σ各方分润
回报上限 = 本金 × 回报倍数（达上限自动结清）

当期调整项

投资方 / RBF方案

RBF分润规则

投资方分润 = 月营业额 × 分成比例 × 调整系数
分润直接基于营业额，不扣除任何成本
回报上限 = 融资本金 × 回报倍数，达上限自动结清
经营者留存 = 营业额 − Σ(各投资方本期分润)
设置参数后点击「立即计算分润」
支持多投资方 · RBF回报上限 · 实时分润预览

SLA监控面板

实时服务健康状态 · 响应时间 · 可用性指标

HEALTHY
系统总体状态
8/8
服务在线
1个降级
12,450
Kafka吞吐/s
1,847
活跃工作流
服务SLA详情
服务名称 P99响应 SLA目标 实际可用性 错误率 状态 响应趋势
数据库连接
读操作延迟2.3ms
写操作延迟4.1ms
连接池使用率34%
活跃连接17/50
Kafka集群
吞吐量12,450 msg/s
消费积压234 msgs
分区数48
副本同步率100%
Temporal引擎
活跃工作流1,847
待处理活动342
调度延迟12ms
失败工作流3

服务契约设计原则

原则 技术要求 实施方法 验证标准
幂等性相同requestId多次调用返回一致结果Redis去重 + DB唯一约束自动化幂等测试
无副作用查询操作不改变系统状态GET只读，计算结果缓存接口语义检查
上下文完整性调用方传入完整上下文参数校验 + 必填字段检查Schema验证
标准错误处理统一错误码体系HTTP状态码 + 业务错误码错误码覆盖测试
版本兼容向后兼容，支持灰度接口版本号 + 特性开关版本兼容性测试