導讀

京東科技業務在快速發展的同時，產生了眾多線上化資金結算的需求。傳統的線下資金結算模式有著人力成本高、耗時長、多方溝通協調成本高、結算準確率低等固有缺點，且無法滿足“風法財審”對於資金流程的管控要求，在此背景下金道結算平臺孕育而生。本文從系統建設的背景、設計細節、已支撐案例及適用業務場景多個層面進行詳細闡述。讀者可以關註文中所講的系統實踐過程，進而對結算領域系統設計能力提升，具有一定的參考價值。

一、概述

1.1 背景

業務在快速發展的同時，產生了眾多線上化資金結算的需求。傳統的線下資金結算模式有著人力成本高、耗時長、多方溝通協調成本高、結算準確率低等固有缺點，且無法滿足“風法財審”對於資金流程的管控要求。金道結算平臺應運而生，專註於內部中心化流量場外的、通過外部場或搭建撮合平臺進行獲客、轉化的場景，支撐業務方面向客戶、合作伙伴、經銷商、供應商等多利益相關方，實現快速、專業、高效、準確的線上化計費結算解決方案提供和能力支持。金道結算平臺對接各垂直業務系統，實時同步業務的交易數據，並經過標準的結算流程（數據標準化預處理，清分，計費，分攤，結算單生成、運營確認等），最終通過財務渠道或其他支付渠道完成資金結算，有效降低了各業務系統結算成本的投入，提升業務資金流轉的健康度，為業務的快速增長賦能。

1.2 痛點

業務系統在開展業務時，以當前線下處理的方式，普遍存在以下痛點：

計算難：計算規則複雜，數據量大，人工難以處理；

響應慢：現有業務變化快和新增業務速度快，人工效率較低，難以快速響應新資金結算模式；

風險高：人工計費、核對、結算數據風險高且不合規，難以溯源，操作風險高；

運營難：基礎數據不完善，線下無法多維度分析，無法精準管理業務成本，及時調整策略；

成本大：人工結算的方式，投入的時間和資源成本高。

1.3 定位

金道結算平臺深耕業務場景，打通平臺介面，支持跨平臺結算，是業財一體化的橋梁，為平臺型交易及全域營銷賦能。

圖1 平臺定位

1.4 優勢

金道平臺的建設，在解決業務痛點基礎上，平臺優勢能夠從準、快、好、省幾個層面體現：

1. 計費準確：支持大數據量計費，準確性達99.99%；

2. 結算快速：靈活支持按日或月等維度結算，縮短結算賬期，實現資金快速收付；

3. 運營精細：支持業務精細化運營，助力業務發展；

4. 成本降低：提高運營效率，節省成本。

二、系統架構介紹

2.1 名詞解釋

表1 名詞解釋

2.2 服務域設計

圖2 服務域劃分

平臺基於DDD思想，劃分清分域、清算域、結算域及報表域四個大域，每個子域又依次劃分了自己的子域。

2.3 整體架構圖

圖3 整體架構圖

說明：

1. 金道平臺從數據處理流向上，自上而下劃為分數據源、清分、清算、結算及下游，從使用群體上分為零售客戶及科技客戶。

2. 業務數據通過實時或離線兩種方式接入平臺。在清分中判別數據歸屬清分類型（通用流程或個性化流程），而進入不同的清分處理流程。清分域主要是按一定的規則對原始數據進行核對、識別、調整及打標動作，為清算做好數據標準化。

3. 當清分標準化數據後，會推送結果數據到清算域，清算按模型配置的清算規則，通過流程式控制制進入計費、分攤、累額等不同的組合處理（譬如：只計費、先計費後分攤、只分攤、先分攤後計費等），以及會補全結算戶、合同及匯率數據，數據落到清算明細表。

4. 結算模型達到結算周期條件時，會產生一個結算任務。結算任務處理時，會從清算表中按條件獲取待結算明細，然後按結算維度彙總，各自產生結算單信息。結算單自動按預定審批流程完成確認，最終推送到財務渠道（渠道當前有：科技財務、預存款賬戶、pop核算等），由財務渠道系統完成收付款。

2.4 典型問題技術設計

2.4.1 分片任務處理組件

平臺採用cds實現分庫分表存儲數據，通過DTS把數據同步到ES，併進行報表明細顯示。在整個結算流程中，存在眾多需要聚合表數據處理操作（譬如：單據預處理、清算預處理、生成結算單，條件拉取條件數據等），因為本平臺是與資金結算相關，金額必須絕對準確，所以未採用ES作為可信的聚合處理源。在前期公司調研相關產品後，未找到基於分庫分表有高效的聚合工具，所以特研發以下“分片任務處理組件”：

圖4 分片任務處理組件

此組件提供抽象的類shardingTask,預定好3個核心動作：split(如何分片）、do(分片數據如何處理）、merge(最終數據如何聚合）。

核心處理過程為：先統一抽象批量處理邏輯，把批量數據分片發送 MQ 並落庫。多節點多線程進行消費，消費完成後，對資料庫 MQ 記錄的狀態進行修改。每個分片處理完後，勻檢查該任務下的消息是否全部處理完成，如果完成後，最後執行合併邏輯，那麼此時我們想要的最終結果就出來了。

2.4.2 順序清算

背景

某些業務系統要求以業務發生的流水，按順序做計算、分攤及累額，為瞭解決這個場景，特設計以下通用的處理流程。

實現過程

第一步：數據接入在中間表中，按業務時間排序，然後打上唯一流水號（流水號自增特點）：

圖5 打標流水號

第二步：業務人員或系統自動處理單據，進行清算時，會觸發條件 ，進入以下預清算處理流程：

圖6 預清算處理流程

原理：

不需要按順序處理的單據數據，直接發送了待清算MQ主題 中，需要按順序清算單據，進入主流程。

挑戰：

1. 分片存儲情況下業務數據明細百萬級排序；

2. 順序處理如何保證處理效率；

3. 順序清算異常情況，如何斷點繼續處理。

實現核心點：

原始快照表打標順序流水號，利用分片任務組件，拉取數據後放在zset中進行排序，全部放入後，觸發順序清算流程。為應對大促銷日，可以在業務能容忍的範圍中，開放併發清算（併發數據之間不保證順序），要成功整體成功，要失敗整體失敗。

2.4.3累額重置

背景

按順序計費、分攤及累額場景，當業務人員需要回退到歷史某個時間的單據重新順序清算時，就需要從累額明細中重置到將要執行單據的位點（也就是累加的總額回退回去，併在流水中標識出哪些是無效數據）。

實現原理

圖7 累額重置實現原理

三、系統功能介紹

3.1 結算流程

圖8 結算流程

整個流程主要分為 4 個步驟：

1. 出具結算方案：每當有新業務場景接入，需由產品同學調研業務運營同學以瞭解業務場景，並出具專業的線上化結算解決方案，輔助業務系統備齊結算所需數據來源，並輔助業務數據同學加工結算數據表。

2. 結算模型配置：依據結算解決方案，在金道結算系統完成結算模型的基本信息配置以及單據處理、清算處理、結算處理、下游處理等環節的規則配置。

3. 結算任務處理：業務交易發生推送到結算平臺，然後經過清分流程處理、清算流程處理、結算單生成，如果有對賬確認流程配置，則會推送賬單由客戶進行賬單確認，發票暫由運營人員線下開具（後續會支持）。

4. 結算完成：等確認完賬單後，賬單會推送到財務進行收付款處理，財務的處理結算會通知到結算平臺。最終賬單信息可以由結算平臺提供歸檔及檢索。

3.2 主要配置

3.2.1結算模型

1. 基本信息

圖9 基本信息

2. 規則信息

圖10 規則信息

結算模型是本平臺核心配置，內容涵蓋基本信息、結算周期、單據處理、清算處理、結算處理及下游配置，運營人員可以通過引導一站式配置好整個所需功能。

3.2.2 計費模型

1. 計費規則

圖11 計費規則

對外提供計費服務，支持不同產品的計費模型和計費規則，形成計費規則引擎，實現計費規則和模型的可配置化，可支持靈活多變的計費場景。

2.分攤規則

圖12 分攤規則

本平臺支持基於預算的分攤配置能力，適合成本分攤型結算。目前我們支持分攤方式有按比例、按順序及按固定金額，支持兩級分攤，具備了大部分業務應用場景支撐能力。

四、業務支持案例

目前金道結算平臺已賦能了 微電佣金、白條息費成本、內容平臺創作者佣金、支付營銷券計收等 業務的線上化結算場景，日均處理訂單量達5000萬+，日均有效結算金額達1300萬+，有力支撐了業務快速發展。

4.1 微電業務

合作案例：為微電業務解決職場、坐席銷售金融產品而產生的資金結算問題，包括佣金、業績考核、企微加粉費和電話使用費等。

業務場景：微電業務售賣的金條、白條、基金、養老保障、小金保、股票、延保、CPA等。

圖13 微電業務

4.2 白條業務

合作案例：為白條與商城解決商城、科技、供應商、POP商家聯合營銷而產生的白條營銷費用收取問題。

業務場景：收取商城、供應商、POP商家的白條營銷費用。

圖14 白條業務

4.3 支付業務

合作案例：為支付解決外部機構採購優惠券，而產生的支付營銷費用收取問題.

業務場景：收取外部機構的支付營銷費。

圖15 支付業務

五、總結

針對目前業務場景、商業模式進行調研分析，主要有四種結算模式:分傭結算、業績考核結算、技術服務結算及商品營銷結算。

4種模式覆蓋目前所有場景，隨著接入業務場景的擴展，模式可再增加。

作者：京東科技 張學君

來源：京東雲開發者社區 轉載請註明來源