トレーディングバックオフィスと決済システム — Front/Middle/Backを巡るデータの旅

+--------------------------------------------------------------------+
| FRONT OFFICE (FO)            「取引を作る」                          |
|  - OMS(注文管理) / EMS(執行管理) / アルゴエンジン                     |
|  - プライシング、気配提示、マーケットデータ                            |
|  - トレーダーブロッター(当日取引状況)                                 |
+---------------------------+----------------------------------------+
                            | 約定(execution)イベント
                            v
+--------------------------------------------------------------------+
| MIDDLE OFFICE (MO)           「取引を統制する」                      |
|  - トレードキャプチャ/エンリッチメント - 口座、手数料、決済情報の付与    |
|  - 限度モニタリング(ポジション/与信/VaR)、リスクレポーティング          |
|  - リアルタイムPnL、日中ポジション管理                                |
|  - コンファメーション、アファメーション(機関投資家顧客)                |
+---------------------------+----------------------------------------+
                            | 確定したトレード(confirmed trade)
                            v
+--------------------------------------------------------------------+
| BACK OFFICE (BO)             「取引を終わらせる」                     |
|  - 清算・決済指図の生成、決済機関連携(KSD/KRX清算/グローバルカストディ) |
|  - 元帳記帳、会計連携、手数料・税金の精算                              |
|  - 照合(ポジション/現金/取引)、ブレーク管理                           |
|  - コーポレートアクション、報告書、規制報告                            |
+--------------------------------------------------------------------+

 トレーダー    OMS/EMS      取引所/OTC     MO(キャプチャ/   清算機関       BO(決済)      預託/口座
   |             |             |          コンファーム)      |             |             |
   |--注文------>|--執行------>|              |              |             |             |
   |             |<--約定通知--|              |              |             |             |
   |             |--約定連携--------------->|               |             |             |
   |             |             |              |--補完/検証-->|             |             |
   |             |             |              |--確認送付--> (相手方)      |             |
   |             |             |              |              |<--清算内訳--|             |
   |             |             |              |              |--ネッティング-->|          |
   |             |             |              |              |             |--決済指図-->|
   |             |             |              |              |             |<--決済完了--|
   |             |             |              |              |             |--記帳/照合--|

実現損益(realized PnL)
  = 売却時点で確定する損益
  = (売却単価 - 保有原価単価) x 売却数量   [原価算定: 移動平均法など]

評価損益(unrealized PnL)
  = 保有中ポジションの帳簿上の損益
  = (現在の評価単価 - 保有原価単価) x 保有数量

日中PnL(intraday)
  = 前日評価基準に対する当日変動
  = 当日実現損益 + (当日評価単価 - 前日評価単価) x 保有数量 + 当日新規分の損益

# EOD評価バッチの骨格(概念例)
from decimal import Decimal

def eod_valuation(positions, closing_prices, fx_rates, base_ccy="KRW"):
    results = []
    for pos in positions:
        price = closing_prices.get(pos.instrument_id)
        if price is None:
            # 評価不能銘柄は必ず例外キューへ — ゼロで埋めてはいけない
            results.append(valuation_exception(pos, reason="NO_PRICE"))
            continue
        mv_local = Decimal(pos.quantity) * price.clean_price
        if pos.instrument_type == "BOND":
            mv_local += Decimal(pos.quantity) * price.accrued_interest
        fx = fx_rates.get((pos.currency, base_ccy), Decimal("1"))
        mv_base = mv_local * fx
        unrealized = mv_base - pos.cost_basis_base
        results.append(make_valuation(pos, mv_local, mv_base, unrealized,
                                      price_source=price.source))
    return results

ブレークのライフサイクル:
  検知(detected) --> 割当(assigned: 担当者指定)
     --> 調査(investigating: 原因コード分類)
     --> 解消(resolved: 訂正仕訳/相手方修正/価格訂正 ...)
     --> 終結(closed: 承認者確認)

  主要メトリクス: 未解消ブレーク件数 x 経過日数(aging) x 金額
  3日以上経過した高額ブレークは自動エスカレーション

確定トレード
   --> 決済指図の生成(settlement instruction)
       - 相手方の決済情報(SSI: Standing Settlement Instructions)を適用
   --> 指図送信(KSD連携 / グローバルはカストディアン経由のSWIFT)
   --> マッチング状態の追跡(相手方指図とのマッチング有無)
   --> 決済日のモニタリング(予定 vs 実際)
   --> 決済完了の確認 --> 元帳記帳の確定
   --> フェイル時: 決済フェイル対応フロー(後述)

 運用会社/証券会社BO       グローバルカストディアン      現地CSD/サブカストディアン
       |                        |                          |
       |--- MT541 (受領指図) --->|                          |
       |                        |--- 現地指図への変換 ------>|
       |                        |<-- マッチング/決済状態 ----|
       |<-- MT548 (状態通知) ----|                          |
       |<-- MT545 (決済確認) ----|     (決済完了時)          |
       |                        |                          |
       |<-- MT535 (残高報告 EOD)|                          |

イベント別仕訳の例(株式買い、単純化):
  約定日(T):    (借) 未収証券      xxx   (貸) 未払金         xxx
  決済日(T+2):  (借) 保有証券      xxx   (貸) 未収証券       xxx
               (借) 未払金        xxx   (貸) 現金(預け金)    xxx
  EOD評価:     (借/貸) 評価損益   xxx   (貸/借) 証券評価調整 xxx

決済フェイル対応runbook(要約):

1. 検知(決済日当日、可能な限り早い時刻)
   - 決済予定 vs マッチング/完了状態のモニタリングダッシュボード
   - 未マッチング指図は決済日前から警報(T+1時点の未マッチング = 危険信号)

2. 分類(原因コード)
   - 指図不一致(UNMATCHED) / 証券不足(LACK) / 資金不足(MONY)
   - 相手方事由 / 自社事由の区別 — 責任の所在がペナルティに直結

3. 即時対応
   - 指図不一致: 相手方と条件を再確認、訂正指図を送信
   - 証券不足: 貸借(借入)の可能性打診、部分決済(partial)の協議
   - 資金不足: 資金部署へエスカレーション、日中流動性の調達

4. 利害関係者への通知
   - 顧客(機関投資家) / トレーディングデスク / コンプライアンス・リスク
   - フェイルが連鎖(チェーン)を作る場合、後続決済への影響分析

5. 事後処理
   - フェイルコスト/ペナルティ精算の記録
   - 原因分析 → SSI整備、プロセス改善項目の登録
   - 反復相手方/反復原因のレポート(月次)

# ポジション照合バッチの骨格(概念例)
from collections import defaultdict
from decimal import Decimal

KEY = ("account_id", "instrument_id")  # 照合キー
TOLERANCE = Decimal("0")               # ポジションは許容誤差ゼロが原則

def reconcile(internal_rows, external_rows, as_of_date):
    internal = aggregate(internal_rows)   # key -> quantity
    external = aggregate(external_rows)
    breaks = []
    for key in internal.keys() | external.keys():
        iq = internal.get(key, Decimal("0"))
        eq = external.get(key, Decimal("0"))
        if abs(iq - eq) > TOLERANCE:
            breaks.append({
                "as_of": as_of_date,
                "key": key,
                "internal_qty": iq,
                "external_qty": eq,
                "diff": iq - eq,
                "classification": classify(key, iq, eq),  # 自動原因推定
            })
    return breaks

def classify(key, iq, eq):
    # 自動分類ヒューリスティック: 未決済取引分、CA処理の時差、
    # 貸借の未反映など
    # 分類不能はUNKNOWNのまま残し、人が調査する
    ...

+----------------+      +------------------+      +-------------------+
|    TRADE       |      | SETTLEMENT_      |      |   POSITION        |
+----------------+      | INSTRUCTION      |      +-------------------+
| trade_id PK    |--+   +------------------+      | account_id        |
| order_id FK    |  +-<-| trade_id FK      |      | instrument_id     |
| account_id     |      | si_id PK         |      | as_of_date        |
| instrument_id  |      | direction (R/D)  |      | quantity          |
| qty / price    |      | ssi_id FK        |      | cost_basis        |
| trade_date     |      | expected_date    |      | (日次スナップショット)|
| settle_date    |      | matched_status   |      +-------------------+
| status         |      | settled_at       |
| version        |      +------------------+      +-------------------+
+----------------+                                |  RECON_BREAK      |
       |                +------------------+      +-------------------+
       +------------->  | POSTING (仕訳)    |      | break_id PK       |
                        +------------------+      | recon_type        |
                        | posting_id PK    |      | as_of_date        |
                        | trade_id FK      |      | key (acct/instr)  |
                        | event_type       |      | diff_amount       |
                        | debit_account    |      | status / aging    |
                        | credit_account   |      | assigned_to       |
                        | amount / ccy     |      | resolution_code   |
                        | posted_at        |      +-------------------+
                        +------------------+