阿里某BU-对账结算系统

阿里某BU对账结算系统是面向交通出行场景的全链路财务结算平台，全面支撑机票、火车票、船票、租车等多条业务线的资金对账与结算工作，覆盖交易对账、账单核销、成本核算、利润结转、差错处理全流程核心能力，是BU出行交易资金闭环、账务合规、收益核算的核心底层系统。平台承接全品类出行订单的日均大规模账务计算任务，保障海量交易数据下账务精准、结算合规、异常可追溯。
系统采用主流Spring Boot微服务架构搭建后端服务，底层基于PolarDB分布式数据库完成亿级交易数据的稳定存储，依托MaxCompute Spark构建弹性算力引擎，搭建批流一体OLAP计算体系，支撑日均百万级的对账、结转计算任务，可弹性应对大促、峰值订单流量带来的账务计算压力，保障全业务线财务结算高效、稳定、准确落地。

项目主要负责系统架构迭代、核心结算模块重构、存储与计算架构升级、查询性能优化及业务流程解耦改造，针对原有系统存储成本高、计算效率低、查询性能差、业务迭代慢、差错处理人工成本高等痛点，完成多维度技术重构与性能优化，大幅提升系统算力、稳定性与迭代效率，显著降低服务器与人力成本，核心实现及亮点如下：
1. 存储架构全面升级，大幅降低资源成本
主导系统底层存储架构迭代升级，完成从传统MySQL数据库至PolarDB分布式数据库的全量数据迁移与业务适配改造。借助PolarDB分布式弹性存储、高压缩、高可用的特性，完美支撑平台亿级账务数据稳定存储，在保障数据一致性、账务零差错的前提下，大幅缩减集群节点与存储资源开销，最终实现整体存储成本降低60%，提升海量账务数据的存储可靠性与扩展性。
2. 核心计算逻辑重构，算力性能跨越式提升
基于MaxCompute Spark大数据计算框架，全面重构对账、利润结转核心计算逻辑，替换原有低效批量计算方案，搭建弹性可扩展的批处理计算体系。优化后系统支持千万级数据量的弹性伸缩对账与结转任务，彻底解决传统计算模式耗时久、算力固定、峰值承压能力弱的问题，将原有小时级的账务计算耗时压缩至分钟级，计算性能整体提升99%，高效支撑日均百万级账务任务稳定运行。
3. 检索架构优化，提升查询效率并节约成本
针对原有OpenSearch检索组件资源开销大、查询链路冗余的问题，完成检索架构轻量化改造，将原有依赖OpenSearch的JSON检索业务，整体迁移至PolarDB原生JSON索引能力，精简中间检索链路，优化数据查询逻辑。改造后接口查询响应时间缩短20%，同时释放多余检索集群资源，每年可节约服务器资源成本25万元，实现性能与成本双向优化。
4. 核心系统重构，实现业务逻辑可配置化
主导结算系统1.0核心模块整体重构，基于Groovy脚本引擎实现结算规则、对账逻辑、核算策略的可配置化、动态化管理，摆脱传统硬编码迭代模式。业务方可通过配置快速调整结算规则，无需频繁发布代码迭代版本，将新需求开发交付周期由原来4天压缩至1天，极大提升业务迭代效率，适配多变的出行结算业务场景。
5. 流式架构解耦，差错处理自动化率大幅提升
基于Kafka Streaming流式计算技术，对原有耦合严重的差错归因流程进行全面解耦重构，搭建一套实时化、高扩展、高容错的流式差错处理体系，实现订单账务差错的实时识别、智能归因、自动修复。系统日均自动化处理10万+差错账单，将账务异常人工干预率压降⾄0.3%，大幅降低人工核对成本，提升全链路账务结算的自动化、精细化运营能力。