Thiết kế Database Ledger kế toán đôi cho ví điện tử và ngân hàng

Thiết kế Database Ledger kế toán đôi cho ví điện tử và ngân hàng | Shanverse

Codeplain text

1BEGIN2  claim idempotency key3  insert journal as draft4  insert every posting5  verify at least two postings6  verify debit_sum = credit_sum per currency7  validate account currency and status8  lock affected balance rows in deterministic order9  update balance projection10  mark journal posted11  insert outbox event12COMMIT

Codesql

1CREATE TYPE account_type AS ENUM (2  'asset', 'liability', 'equity', 'revenue', 'expense'3);45CREATE TYPE normal_side AS ENUM ('debit', 'credit');67CREATE TABLE ledgers (8  ledger_id UUID PRIMARY KEY,9  code TEXT NOT NULL UNIQUE,10  name TEXT NOT NULL,11  base_currency CHAR(3),12  created_at TIMESTAMPTZ NOT NULL DEFAULT now()13);1415CREATE TABLE ledger_accounts (16  account_id UUID PRIMARY KEY,17  ledger_id UUID NOT NULL REFERENCES ledgers(ledger_id),18  code TEXT NOT NULL,19  name TEXT NOT NULL,20  account_type account_type NOT NULL,21  normal_side normal_side NOT NULL,22  currency CHAR(3) NOT NULL,23  owner_type TEXT,24  owner_id UUID,25  parent_account_id UUID REFERENCES ledger_accounts(account_id),26  allow_negative BOOLEAN NOT NULL DEFAULT false,27  status TEXT NOT NULL CHECK (status IN ('active', 'frozen', 'closed')),28  created_at TIMESTAMPTZ NOT NULL DEFAULT now(),29  UNIQUE (ledger_id, code),30  UNIQUE (ledger_id, owner_type, owner_id, currency)31);

Codesql

1CREATE TYPE journal_status AS ENUM (2  'draft', 'posted', 'reversed'3);45CREATE TABLE journal_transactions (6  journal_id UUID PRIMARY KEY,7  ledger_id UUID NOT NULL REFERENCES ledgers(ledger_id),8  idempotency_key TEXT NOT NULL,9  business_type TEXT NOT NULL,10  reference_type TEXT,11  reference_id TEXT,12  status journal_status NOT NULL DEFAULT 'draft',13  effective_at TIMESTAMPTZ NOT NULL,14  posted_at TIMESTAMPTZ,15  reversal_of UUID REFERENCES journal_transactions(journal_id),16  correlation_id UUID,17  metadata JSONB NOT NULL DEFAULT '{}'::jsonb,18  created_by TEXT NOT NULL,19  created_at TIMESTAMPTZ NOT NULL DEFAULT now(),20  UNIQUE (ledger_id, idempotency_key),21  UNIQUE (reversal_of)22);

Codesql

1CREATE TYPE posting_side AS ENUM ('debit', 'credit');23CREATE TABLE postings (4  posting_id UUID PRIMARY KEY,5  journal_id UUID NOT NULL REFERENCES journal_transactions(journal_id),6  account_id UUID NOT NULL REFERENCES ledger_accounts(account_id),7  side posting_side NOT NULL,8  amount_minor BIGINT NOT NULL CHECK (amount_minor > 0),9  currency CHAR(3) NOT NULL,10  sequence_no SMALLINT NOT NULL,11  description TEXT,12  created_at TIMESTAMPTZ NOT NULL DEFAULT now(),13  UNIQUE (journal_id, sequence_no)14);1516CREATE INDEX postings_account_time_idx17  ON postings (account_id, created_at, posting_id);

Codesql

1SELECT2  currency,3  SUM(CASE WHEN side = 'debit' THEN amount_minor ELSE 0 END) AS debit_total,4  SUM(CASE WHEN side = 'credit' THEN amount_minor ELSE 0 END) AS credit_total5FROM postings6WHERE journal_id = $17GROUP BY currency8HAVING9  SUM(CASE WHEN side = 'debit' THEN amount_minor ELSE 0 END)10  <>11  SUM(CASE WHEN side = 'credit' THEN amount_minor ELSE 0 END);

Codesql

1SELECT COALESCE(SUM(2  CASE3    WHEN side = normal_side THEN amount_minor4    ELSE -amount_minor5  END6), 0) AS balance_minor7FROM postings p8JOIN ledger_accounts a USING (account_id)9JOIN journal_transactions j USING (journal_id)10WHERE p.account_id = $111  AND j.status IN ('posted', 'reversed');

Codesql

1CREATE TABLE account_balances (2  account_id UUID PRIMARY KEY REFERENCES ledger_accounts(account_id),3  posted_balance_minor BIGINT NOT NULL DEFAULT 0,4  available_balance_minor BIGINT NOT NULL DEFAULT 0,5  version BIGINT NOT NULL DEFAULT 0,6  last_posting_id UUID,7  updated_at TIMESTAMPTZ NOT NULL DEFAULT now()8);

Codesql

1CREATE TABLE balance_holds (2  hold_id UUID PRIMARY KEY,3  account_id UUID NOT NULL REFERENCES ledger_accounts(account_id),4  idempotency_key TEXT NOT NULL,5  amount_minor BIGINT NOT NULL CHECK (amount_minor > 0),6  currency CHAR(3) NOT NULL,7  status TEXT NOT NULL CHECK (8    status IN ('active', 'captured', 'released', 'expired')9  ),10  expires_at TIMESTAMPTZ,11  created_at TIMESTAMPTZ NOT NULL DEFAULT now(),12  UNIQUE (account_id, idempotency_key)13);

Thiết kế Database Ledger kế toán đôi cho ví điện tử và ngân hàng

Debit và Credit không đồng nghĩa cộng và trừ

Ví dụ nghiệp vụ từ góc nhìn nhà cung cấp ví

Khách nạp 100.000đ vào ví

Bình luận

User A chuyển 30.000đ cho User B

User B rút 20.000đ về ngân hàng

Các invariant không được phá vỡ

Schema PostgreSQL đề xuất

1. Ledger và Chart of Accounts

2. Journal transaction

3. Postings

CHECK constraint không thể tự cân bằng nhiều row

Kiểm tra cân bằng theo từng currency

Multi-currency và FX

Balance: tính trực tiếp hay lưu projection?

Posted balance, available balance và holds

Ngăn overspending dưới tải đồng thời

Reversal: sửa sai mà không sửa lịch sử

Idempotency và duplicate delivery

Immutability thực tế

Partition và indexing

Reconciliation

Bảo mật và audit

Kiểm thử bắt buộc

Checklist production

Kết luận

Tích hợp VietQR và QR động: Xử lý Webhook/IPN để tự động xác nhận đơn hàng

Hướng dẫn cài đặt PostgreSQL trên Ubuntu

Xử lý bão giao dịch: Queue, Rate Limiting và Circuit Breaker cho hệ thống thanh toán

Debit và Credit không đồng nghĩa cộng và trừ

Ví dụ nghiệp vụ từ góc nhìn nhà cung cấp ví

Khách nạp 100.000đ vào ví

Bình luận

User A chuyển 30.000đ cho User B

User B rút 20.000đ về ngân hàng

Các invariant không được phá vỡ

Schema PostgreSQL đề xuất

1. Ledger và Chart of Accounts

2. Journal transaction

3. Postings

CHECK constraint không thể tự cân bằng nhiều row

Kiểm tra cân bằng theo từng currency

Multi-currency và FX

Balance: tính trực tiếp hay lưu projection?

Posted balance, available balance và holds

Ngăn overspending dưới tải đồng thời

Reversal: sửa sai mà không sửa lịch sử

Idempotency và duplicate delivery

Immutability thực tế

Partition và indexing

Reconciliation

Bảo mật và audit

Kiểm thử bắt buộc

Checklist production

Kết luận

Bài viết liên quan

Tích hợp VietQR và QR động: Xử lý Webhook/IPN để tự động xác nhận đơn hàng

Hướng dẫn cài đặt PostgreSQL trên Ubuntu

Xử lý bão giao dịch: Queue, Rate Limiting và Circuit Breaker cho hệ thống thanh toán