Baiduのトランザクションプラットフォームは、グループのモバイルエコシステム戦略の基盤として機能し、ビジネスを強化し、POS取引や決済・清算シナリオのための効率的なトランザクションエコシステムを提供しています。現在、Baiduエコシステム内の複数の製品ライン（Baidu Store、ミニプログラム、Baidu Maps & Taxi、Baiduの文心易言プラットフォームなど）をサポートしています。この記事では、Baiduトランザクションプラットフォームのトランザクションチェーンシステムにおけるデータ整合性のための照合システムについて主に紹介し、特に準リアルタイムの照合とオフラインのビッグデータ照合に焦点を当てます。

取引システムのコアコンポーネントには、レジ、取引注文、取引マーケティング、取引履行、データセンター、決済センター、キャッシュプール、データ元帳などがあります。

• キャッシャー: WeChat Pay、Alipay、UnionPay (法人および個人)、Du Xiaoman Pay、Baidu QuickPass、Huifu Payment、JD Pay をサポートし、キャッシャー支払伝票とキャッシャー払い戻し伝票を生成する、集約された支払い機能を提供します。
• 取引注文：ユーザー、加盟店、商品、在庫、アフターサービスといった主要なビジネスプロセスを繋ぎ、取引プロセス全体を推進する中核を担うのがこれらの注文です。注文システムは、注文プロセス管理、在庫・マーケティング管理、価格設定エンジン、フルフィルメントサブプロセス、アフターサービス、返金情報管理といった一連の機能を備え、取引注文と返金注文を生成するエントリーポイントとして機能します。
• トランザクション マーケティング:プロモーション活動や特定のトランザクション条件を通じてマーケティング注文を生成することで顧客を引き付け、売上増加を促進することを目的として、マーケティング予算、マーケティング在庫、マーケティング キャンペーンを管理する機能を提供します。
• 取引履行：販売者が署名した商品の拘束関係に基づいて、引き換えられた商品が提供する対応するサービスを履行またはキャンセルし、履行注文とキャンセル注文を生成します。
• データ センター:取引注文、返金注文、履行済み注文、キャンセルされた履行済み注文を収集し、決済センターが依存する決済契約および販売者や仕入先情報などの主要データを補足し、バウチャー注文を生成します。
• 決済センター：決済契約に基づき、該当する加盟店サプライヤーへの注文の支払いを決済します。決済請求書を発行し、最終的に加盟店のキャッシュプールに入金されます。
• 資金プール：加盟店に資金残高、資金フロー記録、および決済処理機能を提供します。また、取引記録、資金プール残高、および支払伝票を加盟店に提供します。
• データ会計センター：取引プラットフォームの統合データアウトレット。注文、決済請求書、キャッシュプールフローを網羅します。加盟店はこのシステムを通じて収入、その他の支払い、経費を直接照会し、日次、月次、年次の財務調整情報を受け取ることができます。

全体の概要は次の図に示されています。

• 百新銀行：取引ミドルプラットフォームにおいて、取引のアクイジション、クリアリング、決済を一括処理し、「ワンストップクリアリング」を実現します。「ワンストップクリアリング取引」「ワンストップクリアリング償却」「ワンストップクリアリング収入」「ワンストップクリアリング支払」の指示書を提供します。

• 集約された支払いチャネル: WeChat Pay、Alipay、UnionPay (法人および個人)、中国銀行デジタル通貨支払い、Du Xiaoman Payment、Baidu QuickPass、Huifu Payment、JD Pay など、請求書の支払いオプションを提供します。

  
  

取引プラットフォームにおける決済サービスの多様化に伴い、取引注文量は急速かつ活発に増加し、取引決済サービスの複雑性も継続的に高まっています。まとめると、以下の特徴が挙げられます。

このような取引においては、取引データの正確性と適時性を確保すると同時に、フルフィルメント、決済、資金請求、そして加盟店への支払いの適時性と一貫性も保証する必要があります。これは、当社の照合システムにとって大きな課題となっています。以下の図は、取引システムの運用中に発生する問題の一部を簡単に示しています。

「データの不整合」には、次のようにさまざまな原因があります。

一貫性の問題に関しては、業界ではすでに非常に成熟したソリューションが存在します。Baiduで「一貫性の問題」を検索すると、この問題に関する数多くの説明、定義、アプローチ、解決策が見つかります。

4.1.1 システムの概要

「ニアリアルタイム」は、データの問題を迅速に検出・解決できる自動照合システムを提供することを目指しています。システム間のデータ同期の問題をリアルタイムで追跡・処理するための専用プラットフォームが開発されています。設計コンセプトは下図に示されています。

1. DTS プラットフォームを介してトランザクション チェーン システム内のデータベースの binlog ファイルを監視することにより、binlog メッセージが BP に送信されます。

2. BP データを消費し、上流システムと下流システムからデータセットを収集し、上流システムと下流システム間のデータ構造を抽象化し、上流システムからのプッシュと下流システムからの受信をメタデータのペアとして保存します。

3. システムは監視設定情報に基づいて、ペアになっていない調整要素情報を定期的に監視し、修復インターフェイスを自動的に呼び出して、異常な調整要素情報に対して早期警告を発します。

4. 調整結果は、セルフサービスの Sugar レポート プラットフォームを活用して視覚的に分析レポートを生成することで視覚化されます。

「T+1」とは、取引日から翌営業日までの期間を指します。つまり、「T+1」照合とは、T日までのデータ照合がT+1日に完了することを意味します。照合システムは、取引チェーンシステム内の内部照合と、取引ミドルプラットフォームと外部システム間の照合に分かれており、主にデータ準備、データ検証、データ照合、データ報告などのモジュールで構成されています。

• データ準備: 名前が示すように、調整システムが依存するすべてのデータを取得することが含まれます。

• データ検証：データの比較が行われ、両者間で一致しないデータは不一致とみなされます。

• データ調整: 不一致の 2 回目の調整を完了し、会計期間間の差異を排除し、最終的な不一致の自動修復と早期警告を実現します。

• データ レポート: 調整結果のデータ分析と統計を完了し、データ レポートの視覚的な表示インターフェイスを提供します。

  
  

4.2.2 取引チェーンシステム内の内部調整

• データ準備

ETLデータ同期ツールを使用して、T日のトランザクションデータをT+1日にオフラインAFSファイルシステムに同期し、AFSファイルとHiveメタテーブルのバインディングを完了します。Pingoプラットフォームを使用して、データ同期タスクをスケジュールし、定期的に実行します。

• 問題の発見

• データ検証

• エラー処理

下流システムは、データ検査およびデータ修復インターフェースを提供します。データ検証が完了すると、エラー処理が開始され、データ修復インターフェースが呼び出され、その後、データ検査インターフェースが再度呼び出され、最終的にデータ修復が完了します。エラー処理は3回繰り返すように設定されています。3回処理しても修復されないデータは、自動的に早期警告システムに入り、メールとSMSでチームと個人に警告を送信し、最終的には手動で解決されます。

4.2.3 トランザクションプラットフォームと外部システム間の調整

• データ準備

• 問題の発見

• データ検証

• エラー処理

Baiduの取引プラットフォームは、注文処理、支払い、フルフィルメント、決済といった取引機能を統合しています。ビジネスパートナーの参加が増えるにつれ、トラフィックオーナー主導の販売、ライブストリーミング販売、ホスト主導の販売、複数当事者による収益分配取引など、取引シナリオはますます多様化しています。これらの多様なシナリオは複雑な決済プロセスをもたらし、タイムリーかつ正確な決済を保証するためには、安定した信頼性の高い取引データストリームが必要です。Baiduの取引プラットフォームの照合システムは継続的に改善・アップグレードされており、ビジネスパートナーに安定した信頼性の高い取引照合バックエンドを提供するとともに、取引データストリームの安定性を最優先に考え、継続的なビジネス発展を支援しています。