🔄 批量与日终体系概览
批量与日终处理是银行核心系统运行的"幕后引擎"。每日日切后，批处理系统在有限的时间窗口内完成积数累计、利息计提、账务核对、报表生成等关键任务，确保次日营业数据准确可用。本章节系统梳理批量分类体系、日切机制、批处理窗口及任务依赖链，并聚焦批量调度与日终流程的测试要点。
📐 批量处理分类体系
银行批量作业按处理周期和业务特征可分为以下四大类别：
📅 日终批处理
每日日切后执行：积数累计、利息计提、费用扣收、总账更新、日计表生成。是所有批量作业的基础，必须在次日营业前完成。
📆 周期批处理
按固定周期触发：季度结息（3/6/9/12月20日）、月度费用批量、周度报表。处理量级大，对窗口要求高。
📋 事件驱动批处理
由特定事件触发：利率调整生效、税率变更、产品到期批量处理、参数版本切换。执行时机不固定但影响范围广。
📊 年度批处理
年度决算特有：年终损益结转、利润分配、科目结转、年度报表生成。涉及全科目，需多部门协同确认。
🕐 日切机制
1. 日切原理
日切（Day Cutover）是银行核心系统从当前营业日切换到下一营业日的关键操作。日切时系统记录当前日期的最终状态，开启新日期的账务处理。日切策略直接影响7×24小时连续运营能力。
| 日切模式 | 原理 | 优点 | 缺点 | 适用银行 |
|---|---|---|---|---|
| 停业日切 | 日切期间暂停所有联机交易，待批处理完成后再恢复 | 实现简单，数据一致性强 | 有服务中断窗口（通常1-4小时） | 传统城商行、农信社 |
| 双会计日 | 日切期间同时维护T日和T+1日两套会计日期，联机交易不停 | 7×24小时连续服务 | 实现复杂，需处理跨日交易 | 大中型商业银行 |
| 热日切 | 无需停止联机交易，系统平滑切换会计日期，批处理与联机并行 | 零停机、高可用 | 技术要求高，并发控制复杂 | 全国性股份制银行 |
| 多批次日切 | 将日终处理分成多个批次（如18:00/22:00/02:00），分步骤完成日切 | 灵活、窗口分散 | 协调难度大，依赖链长 | 超大型银行 |
2. 日切关键时点
| 时点 | 操作 | 测试关注点 |
|---|---|---|
| T日 18:00-20:00 | 日切准备：备份数据快照、停止大额支付来账 | 快照完整性、支付来账挂账处理 |
| T日 22:00 | 日切执行：切换会计日期、启动作业调度 | 在途交易归属、日期切换原子性 |
| T日 22:00-02:00 | 核心批处理：积数累计、利息计提、费用扣收 | 批处理耗时、并行分片效率 |
| T日 02:00-04:00 | 账务核对：总分核对、试算平衡、跨行对账 | 核对结果准确性、差异处理 |
| T日 04:00-05:30 | 报表生成与数据分发 | 报表数据准确性、分发时效 |
| T日 06:00 | 日切完成：恢复联机交易、新日期开始营业 | 日初余额衔接、交易可用性 |
⏱️ 批处理窗口管理
1. 窗口定义
批处理窗口（Batch Window）是从日切开始到次日营业前、批处理系统可用的时间区间。典型窗口为 22:00至次日06:00（8小时），实际可用时间还需考虑异常处理缓冲和报表分发时间。
2. 窗口容量规划
| 规划维度 | 内容 | 规划方法 |
|---|---|---|
| 作业量评估 | 统计各作业当前执行耗时，按业务增长率推算未来耗时 | 历史数据回归 + 线性外推 |
| 并行度规划 | 确定可并行执行的作业组合，计算并行后的窗口时间 | DAG关键路径分析 |
| 缓冲时间 | 为异常重跑、人工介入预留时间（通常为总窗口的20-30%） | 故障模式影响分析（FMEA） |
| 峰值场景 | 季度末、年末等业务高峰日的窗口承载能力 | 峰值日压测 + 容量模型 |
| 弹性扩展 | 临时增加计算资源以缩短窗口时间的能力 | 云资源弹性、数据库读写分离 |
🔗 任务依赖链
1. 典型依赖拓扑
银行批处理作业遵循严格的依赖关系，构成有向无环图（DAG）：
| 依赖层级 | 作业环节 | 前置依赖 | 产出 |
|---|---|---|---|
| L1 | 交易补账 | 日切完成 | 全量交易日终状态 |
| L2 | 积数累计 | L1 交易补账 | 账户当日积数（∑日终余额） |
| L3 | 利息计提 | L2 积数累计 | 应付利息/应收利息分录 |
| L4 | 费用处理 | L2 积数累计 | 费用扣收流水、会计分录 |
| L5 | 总账更新 | L3 利息计提 + L4 费用处理 | 科目余额更新 |
| L6 | 总分核对 | L5 总账更新 | 核对结果、差异报告 |
| L7 | 报表生成 | L6 总分核对（通过） | 日计表、损益表、监管报表 |
2. 依赖管理策略
- 串行依赖：不可并行的作业（如 L1 → L2 → L3），通过调度引擎确保顺序执行
- 并行分片：同层级作业按分行/账号段分片并行（如 L2 积数累计按10个分片并行）
- 条件分支：L3/L4 并行但需等 L2 完成，L5 需等 L3 和 L4 均完成（AND汇聚）
- 失败传播：上游作业失败时，下游作业自动等待或跳过——需定义每种失败模式下的处理策略
- 断点续跑：依赖链中某作业失败后修复，从失败点恢复，不重复处理已完成作业
🎯 核心测试关注维度
⏱️ 窗口时效
日终批处理全流程必须在8小时窗口内完成，含异常处理和报表分发时间
🔄 数据一致性
日切前后余额衔接、总分核对一致、试算平衡、跨系统数据同步准确性
🔗 依赖正确性
DAG拓扑正确、循环依赖检测、条件触发逻辑、上下游数据传递准确性
🛡️ 异常处理
作业失败回滚、断点续跑、超时降级、资源竞争、部分成功的数据一致性
📊 并发吞吐量
并行分片效率、数据库锁竞争、大规模数据吞吐、CPU/IO资源利用率
📋 监管合规
报表数据准确性、报送时效、审计轨迹完整性、参数变更审批留痕
📊 典型批量作业量参考
| 批量作业 | 处理对象量级 | 执行频率 | 典型耗时 | 关键性能指标 |
|---|---|---|---|---|
| 积数累计 | 亿级活期账户 | 每日 | 30-60分钟 | ≥100万账户/分钟 |
| 利息计提 | 千万级定期/贷款 | 每日 | 20-40分钟 | ≥50万笔/分钟 |
| 季度结息 | 亿级活期账户 | 每季末 | 2-4小时 | ≥50万账户/分钟 |
| 总分核对 | 全科目、全账户 | 每日 | 20-40分钟 | ≤30分钟全量 |
| 日计表生成 | 百张报表 | 每日 | 10-20分钟 | ≤15分钟 |
| 年终决算 | 全年数据 | 每年12月31日 | 6-12小时 | ≤12小时 |