트레이딩 백오피스와 결제 시스템 — Front/Middle/Back의 데이터 여정

+--------------------------------------------------------------------+
| FRONT OFFICE (FO)            "거래를 만든다"                         |
|  - OMS(주문관리) / EMS(집행관리) / 알고 엔진                          |
|  - 프라이싱, 호가, 마켓데이터                                         |
|  - 트레이더 블로터(당일 거래 현황)                                     |
+---------------------------+----------------------------------------+
                            | 체결(execution) 이벤트
                            v
+--------------------------------------------------------------------+
| MIDDLE OFFICE (MO)           "거래를 통제한다"                       |
|  - 트레이드 캡처/보강(enrichment) - 계좌, 수수료, 결제정보 부여        |
|  - 한도 모니터링(포지션/신용/VaR), 리스크 리포팅                       |
|  - 실시간 PnL, 일중 포지션 관리                                       |
|  - 컨펌(거래 확인), 어펌(기관고객 확인)                                |
+---------------------------+----------------------------------------+
                            | 확정된 트레이드(confirmed trade)
                            v
+--------------------------------------------------------------------+
| BACK OFFICE (BO)             "거래를 끝낸다"                         |
|  - 청산/결제 지시 생성, 결제기관 연계(KSD/KRX청산/글로벌 커스터디안)    |
|  - 원장 기장, 회계 연동, 수수료/세금 정산                              |
|  - 대사(포지션/현금/거래), 브레이크 관리                               |
|  - 코퍼레이트 액션, 보고서, 규제 보고                                  |
+--------------------------------------------------------------------+

 트레이더      OMS/EMS      거래소/장외     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:
            # 평가 불능 종목은 반드시 예외 큐로 — 0으로 채우면 안 된다
            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")               # 포지션은 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        |      +-------------------+
                        +------------------+