# 数据接口 ESB 化实施方案

> 市场风险管理系统交易数据与估值结果接口由 DSG 改为 ESB 的目标架构、接口清单、交互设计、工作量分工、分批实施路径与风险应对。

---

LLMS 索引： [llms.txt](/llms.txt)

---

本方案依据《市场风险管理系统数据接口调整方案分析》（2026 年 8 月 18 日，v1.0）的评审结论编制：市场风险管理系统的**交易数据与估值结果接口由 DSG 数据同步改为 ESB 企业服务总线**，市场数据保留 DSG / 企业知识平台。本文为实施版本，覆盖目标架构、接口改造明细、估值交互设计、工作量分工、分批实施路径与风险应对。

## 一、背景与方案概述

### 1.1 业务背景：准实时估值

市场风险管理系统建设准实时估值能力，主要基于以下诉求：

- **满足监管要求**：准实时估值是响应监管机构对市场风险管理时效性要求的重要举措；
- **及时的风险监控与预警**：风险管理部通过准实时估值及时掌握业务开展情况与限额执行情况（准实时限额依赖于准实时估值），当出现异常或超限情形时，系统通过邮件、站内信等方式自动推送预警通知；
- **为业务系统提供估值服务**：将估值结果输出至业务系统，便于其在业务流程中直接使用，项目第一阶段按**每小时**频率向外汇交易系统反馈估值结果。

### 1.2 方案概述

交易数据（5 个接口）与估值结果（2 个接口）共 7 个接口改走 ESB，市场数据（18 张表）保留现有通道，CLN 与 CDS / CRMA / CRMW 维持手工导入：

| 要素 | 内容 |
|------|------|
| 改造范围 | 交易数据 5 个接口 + 估值结果 2 个接口 |
| 主系统工作量 | 约 1.5 人月（含 5 个已建接口的返工适配） |
| 外围系统影响 | 外汇交易系统、贸金系统、票据管理系统 |
| 实施方式 | 分批实施：估值先行保提测，交易链路并行改造 |
| 整体风险 | 中，通过双轨验证与分批上线可控 |

ESB 同时承载交易数据接入与估值结果输出，实现**交易-估值链路的标准化**——服务契约、消息确认与重试补偿、全链路监控与审计；市场数据为批量同步场景，按投入产出比保留现状，优先将 ESB 资源集中于收益最高的交易与估值链路。

## 二、方案总体设计

### 2.1 目标架构

> [!NOTE]
> 图内支持缩放、语义视图、关系追踪与 PNG/SVG 导出。

<iframe src="/market-risk/arch/01-esb-target-architecture.html" title="目标架构" loading="lazy" style="width:100%;height:700px;border:1px solid #e5e7eb;border-radius:8px;"></iframe>

<a href="/market-risk/arch/01-esb-target-architecture.html" target="_blank">全屏打开 ↗</a>

交易数据（5 个接口）与估值结果（2 个接口）改走 ESB：ESB 同时承载交易数据接入与估值结果输出。市场数据保留现状：外数 8 张小时级表与外汇牌价秒级表继续走 DSG 同步，9 张 T日 表继续走企业知识平台。CLN 与 CDS / CRMA / CRMW 为手工导入 CSV，无系统接口，不受本次改造影响。

### 2.2 设计原则：数据特征与集成方式匹配

| 特征 | 适合 DSG | 适合 ESB |
|------|---------|---------|
| 可靠性 / 可追溯性 | 较弱（错误反馈难） | 强（监控、重试、审计） |
| 服务契约 | 无 | 有（标准化接口） |

三类数据与两种通道的匹配逻辑：

- **交易数据——事件驱动，适合 ESB**：交易数据随交易发生而生成，量级可控（5 个接口）。走 ESB 带来实时性（交易发生后及时进入系统，支撑准实时风险计量）、可靠性（消息确认、重试与补偿，避免数据丢失）与可追溯性（全链路监控审计，满足风险数据治理要求）；
- **估值结果——双模式输出，ESB 是唯一可行路径**：批量推送与单笔查询两种目标模式均为已确认需求，DSG 无法主动推送至外部系统，也无法提供请求-响应式查询；
- **市场数据——批量同步，保留现状投入产出比最优**：三类市场数据均为批量数据同步，不需要 ESB 的请求-响应与服务契约能力（详见 3.3 节）。

### 2.3 改造范围总览

| 数据类别 | 接口 / 表数 | 通道变化 | 说明 |
|---------|------------|---------|------|
| 交易数据 | 5 个接口 | DSG → **ESB** | 票据 1 + 福费廷 1 + 外汇 3 |
| 估值结果 | 2 个接口 | DSG → **ESB** | 批量推送 + 单笔查询 |
| 市场数据 | 18 张表 | 保留 DSG / 企业知识平台 | 外数 8 张小时级 + 外汇秒级 1 张走 DSG；9 张 T日 走企业知识平台 |
| CLN / CDS 等衍生品 | 2 个接口 | 维持手工导入 | 无系统接口，不在改造范围 |

## 三、接口改造明细

### 3.1 交易数据导入接口（共 7 个，改造 5 个）

| 序号 | 产品 | 接口数 | 对应数据源 | 说明 |
|-----|------|-------|-----------|------|
| 1 | 票据 | 1 | 票据管理系统 | 电票贴现 / 买入批次与清单等 |
| 2 | 福费廷 | 1 | 贸金系统 | FRFTBUYMASTER 福费廷包买主表 |
| 3 | 外汇交易 | 3 | 外汇交易系统 | 即期 / 远期 / 掉期等交易数据 |
| 4 | CLN | 0 | — | 信用挂钩票据，手工导入，不在改造范围 |
| 5 | CDS / CRMA / CRMW | 0 | — | 信用衍生品共用，手工导入，不在改造范围 |

不同产品的交易数据结构不同，接口需按产品分别提供，**无法合并为统一接口**——改走 ESB 后接口数与现状一致。

> [!IMPORTANT]
> 目前已完成通过 DSG 同步的交易数据读取与处理（票据、福费廷、外汇 3 个系统共 5 个接口）。改走 ESB 后，这 5 个接口的**已建成品需要重新适配改造（返工）**，已计入工作量估算，随交易改造阶段集中完成。

### 3.2 估值结果输出接口（2 个）

| 序号 | 接口 | 方向 | 说明 |
|-----|------|------|------|
| 1 | 估值结果-批量推送 | 市场风险系统 → 外汇交易系统 | 每小时主动推送估值结果 |
| 2 | 估值结果-单笔查询 | 外汇交易系统 → 市场风险系统 | 按需请求，ESB 请求-响应即时返回单笔估值 |

### 3.3 市场数据（18 张表，保留现状）

| 来源 | 表数 | 更新频率 | 当前通道 | 数据特征 | 保留理由 |
|------|------|---------|---------|---------|---------|
| 外部数据管理平台 | 8 张 | 小时级 | DSG | 引用型、准实时批量同步 | 技术上可行（低频低量），但需外数系统团队开发发送侧逻辑，边际收益低 |
| 外部数据管理平台 | 9 张 | T日 | 企业知识平台 | 引用型、日终批量 | 无需改造，零工作量 |
| 外汇交易系统 | 1 张 | 秒级 | DSG | 高频推送，PE_MKT_MKTCRTPRICE | 50tps 可承载、技术上无瓶颈，但属引用型数据，DSG 更匹配 |

保留现状并非技术约束（50tps 足够），而是**投入产出比的最优选择**：优先将 ESB 资源用于收益最高的交易数据与估值结果链路。完整表清单见 8.1 节。

## 四、估值结果交互设计

### 4.1 交互时序

> [!NOTE]
> 图内支持缩放、语义视图、关系追踪与 PNG/SVG 导出。

<iframe src="/market-risk/arch/02-valuation-interaction.html" title="估值结果交互时序" loading="lazy" style="width:100%;height:660px;border:1px solid #e5e7eb;border-radius:8px;"></iframe>

<a href="/market-risk/arch/02-valuation-interaction.html" target="_blank">全屏打开 ↗</a>

### 4.2 调用模式与通道能力对照

| 调用模式 | 交互方式 | DSG 能力 | ESB 能力 |
|---------|---------|---------|---------|
| 异步（现状） | 先推送交易数据，后查询估值结果 | 支持（批量同步） | 支持（消息队列） |
| **批量推送（目标）** | 市场风险系统每小时主动推送估值结果至外汇系统 | **不支持**（无法主动推送至外部系统） | 支持（消息队列 / 批量推送） |
| **单笔查询（目标）** | 外汇系统主动调用估值查询接口，即时返回 | **不支持**（无请求-响应能力） | 支持（请求-响应 / REST） |

当前估值交互为异步模式：外汇系统先输入交易、另行查询估值，两次独立交互。目标改为**批量推送与单笔查询双模式并存**，覆盖完整性与实时性两类诉求。两种模式是已确认的目标模式，ESB 是满足该需求的唯一可行路径。

### 4.3 ESB 可靠性机制

- **监控**：ESB 平台提供消息全链路追踪与可视化看板，可按消息 ID 实时查询投递状态；
- **重试**：失败消息自动重试达设定次数后进入死信队列（DLQ），支持补偿重发，避免数据丢失；
- **审计**：消息收发日志持久化存储，满足风险数据治理的合规审计要求。

### 4.4 大数据量兜底：文件传输 + ESB 通知

若批量推送的估值结果数据量过大（如持仓数量众多），直接通过 ESB 消息体传输可能导致消息体积超限。此时采用文件传输方案：市场风险系统将估值结果生成文件，通过**影像平台**传送至对方系统，同时通过 ESB 发送「文件已准备就绪」的轻量通知，对方系统收到通知后前往影像平台拉取文件。大数据量的实际传输由影像平台完成，ESB 仅承担通知角色。

## 五、工作量与分工

### 5.1 主系统侧（约 1.5 人月）

| 工作量维度 | 内容 |
|-----------|------|
| ① 返工 | 5 个交易接口读取逻辑重构（票据 / 福费廷 / 外汇），由 DSG 读取适配为 ESB 接收 |
| ② ESB 改造增量 | 估值接口 ESB 服务开发 + 服务契约 + 批量推送模式（2 个估值接口） |
| **小计** | **约 1.5 人月**（3 周内可完成） |

### 5.2 外围系统影响

| 外围系统 | 改造内容 |
|---------|---------|
| 外汇交易系统 | 开发交易数据 ESB 发送逻辑（3 个接口）+ 估值消费侧适配（被动读取 → 主动调用 / 接收推送） |
| 贸金系统 | 开发福费廷交易数据 ESB 发送逻辑（1 个接口） |
| 票据管理系统 | 开发票据交易数据 ESB 发送逻辑（1 个接口） |
| 外部数据管理平台 | —（保留 DSG / 企业知识平台，不改造） |

> [!NOTE]
> 使用 DSG 时，外围系统只需提供源表，DSG 负责抽取与同步，外围系统基本无开发工作量；改用 ESB 后，外围系统需主动开发数据发送逻辑。该部分工作量由各外围系统团队承担，不计入主系统估算，但需纳入联调排期协调。

## 六、实施路径

### 6.1 分批实施

> [!NOTE]
> 图内支持缩放、语义视图、关系追踪与 PNG/SVG 导出。

<iframe src="/market-risk/arch/03-rollout-plan.html" title="分批实施路径" loading="lazy" style="width:100%;height:640px;border:1px solid #e5e7eb;border-radius:8px;"></iframe>

<a href="/market-risk/arch/03-rollout-plan.html" target="_blank">全屏打开 ↗</a>

实施分三个阶段推进：

1. **估值先行（第 1–2 周）**：优先完成估值 ESB 服务开发（契约定义、批量推送 + 单笔查询）与外汇系统估值消费侧适配，估值链路 1 周内完成开发与自测，不依赖外围系统改造；
2. **交易并行改造（第 2–3 周）**：主系统 5 个接口读取逻辑返工，与票据 / 贸金 / 外汇发送侧开发并行推进；DSG 保持运行，ESB 灰度双轨验证数据一致性；
3. **联调提测与分批上线**：估值 + 交易链路统一汇入联调窗口；估值接口随版本正常上线，交易数据视联调情况上线，未就绪时延至下一版本，不阻塞整体进度。

### 6.2 工期影响与缓解

当前项目计划提测时间尚余约 3 周：

| 工期影响 | 评估 | 缓解措施 |
|---------|------|---------|
| 对提测 | 主系统改造约 1.5 人月，若立即启动可在 3 周内完成；外围系统发送侧开发需同步推进，存在跨系统排期风险 | ① 先行实施估值接口（1 周），不影响提测；② 交易接口返工与外围系统开发并行；③ 必要时交易数据部分延至下一版本 |
| 对上线 | 若提测后延 1–2 周，上线相应后延 | 通过分批实施控制：估值接口先上线，交易数据后续版本迭代 |

## 七、风险与应对

| 风险项 | 等级 | 应对措施 |
|-------|------|---------|
| ESB 性能瓶颈 | 低（交易数据中低频） | 上线前容量评估，运行期消息量监控 |
| 消息积压 / 数据延迟 | 低 | DLQ + 补偿重发机制，积压告警 |
| 双轨运行一致性 | 中 | DSG 与 ESB 并行期间建立对账核对机制，验证通过后切换 |
| 多系统协调复杂度 | 中（3 个外围系统协同） | 接口契约先行定义并冻结，联调窗口统一排期 |
| 已建成品返工 | 5 个接口返工（票据 / 福费廷 / 外汇） | 返工范围已计入工作量估算，随交易改造阶段集中完成 |

整体风险等级：**中**，通过分批实施与双轨验证可控。

## 八、附录

### 8.1 市场数据表清单（18 张，保留现状）

| 来源系统 | 表名 | 更新频率 | 当前通道 |
|---------|------|---------|---------|
| 外部数据管理平台 | BONDSIMPLEQUERY 单只债券资料查询 | T日 | 企业知识平台 |
| 外部数据管理平台 | BONDVALUATION 债券估值表 | T日 | 企业知识平台 |
| 外部数据管理平台 | CBONDCURVEMEMBERSCNBD 中债登收益率曲线成分样本 | T日 | 企业知识平台 |
| 外部数据管理平台 | CBONDISSUERRATING 中国债券发行主体信用评级 | T日 | 企业知识平台 |
| 外部数据管理平台 | CBONDRATING 中国债券信用评级 | T日 | 企业知识平台 |
| 外部数据管理平台 | CBONDRATINGDEFINITION 中国债券信用评估机构名单 | T日 | 企业知识平台 |
| 外部数据管理平台 | CGOLDSPOTEODPRICES 中国黄金现货日行情 | T日 | 企业知识平台 |
| 外部数据管理平台 | CHINABONDINDUSTRIALCLASSIFICATIONDATA 中债行业分类数据 | T日 | 企业知识平台 |
| 外部数据管理平台 | YIELDCURVE 中债收益率曲线 | 小时级 | DSG |
| 外部数据管理平台 | cbondanalysisshc 上清所债券估值 | 小时级 | DSG |
| 外部数据管理平台 | PB_DDA_IRS_CURVE 利率掉期曲线 | 小时级 | DSG |
| 外部数据管理平台 | PB_DDA_VOLATILITY 外汇期权隐含波动率表 | 小时级 | DSG |
| 外部数据管理平台 | PB_DL_CASHRATE 现金利率表 | 小时级 | DSG |
| 外部数据管理平台 | PB_DL_MARKET_PRICE 市价 | 小时级 | DSG |
| 外部数据管理平台 | PB_DL_RATING 评级表 | 小时级 | DSG |
| 外部数据管理平台 | PB_DL_SECURITY_BOND 债券证券信息表 | 小时级 | DSG |
| 外部数据管理平台 | PB_DL_BOND_DAILY 债券收盘价 | T日 | 企业知识平台 |
| 外汇交易系统 | PE_MKT_MKTCRTPRICE 市场价格表 | 秒级 | DSG |

### 8.2 未来演进：市场数据 ESB 化

外数 8 张小时级表与外汇秒级 1 张表当前保留 DSG；若未来行内统一集成架构有硬性要求，可将其迁移 ESB（需外数系统团队开发发送侧逻辑），建议先迁移小时级表、再评估秒级表；9 张 T日 表无论何时均保持企业知识平台不变。

---

本文基于《市场风险管理系统数据接口调整方案分析》的评审结论编制，工作量与风险等级为估算值，实际需结合各系统数据量、ESB 平台容量与排期进一步细化。

---

反链：

- [市场风险](/docs/market-risk/)