設計判断の根拠:

• OrderをCoreとした理由: ECの本質は「注文→決済→配送」のフローであり、このフローの最適化が競争優位になる
• MarketingをCoreとした理由: クーポン・ポイント施策はLTV向上の鍵であり、独自のロジックが必要

graph TD
    CAT["Catalog"] -->|OHS/PL| ORD["Order"]
    INV["Inventory"] -->|Customer/Supplier| ORD
    ORD -->|ACL| PAY["Payment<br/>（Stripe）"]
    ORD -->|C/S| SHP["Shipping"]
    ORD -->|Partnership| MKT["Marketing"]
    REV["Review"] -->|Conformist| CAT
    NOTIFY["Notification<br/>← 全Contextからイベント受信"] -.->|Published Language| ORD
    NOTIFY -.-> CAT
    NOTIFY -.-> PAY
    NOTIFY -.-> SHP
    CUST["Customer"] -->|OHS| ALL["全サービス"]

    classDef core fill:#d4edda,stroke:#28a745,color:#333
    classDef ext fill:#fff3cd,stroke:#f0ad4e,color:#333
    classDef generic fill:#e8f4fd,stroke:#2196f3,color:#333
    class ORD,MKT core
    class PAY,CUST,NOTIFY generic
    class CAT,INV,SHP,REV ext

関係性の選択理由:

同期API（在庫確認）:

# OpenAPI 仕様
paths:
  /inventory/{productId}/availability:
    get:
      summary: 在庫確認
      parameters:
        - name: productId
          in: path
          required: true
          schema:
            type: string
      responses:
        200:
          content:
            application/json:
              schema:
                type: object
                properties:
                  productId:
                    type: string
                  available:
                    type: boolean
                  quantity:
                    type: integer
                  reservableUntil:
                    type: string
                    format: date-time

非同期イベント（在庫引当）:

// 注文確定 → 在庫引当リクエスト（イベント）
interface StockReservationRequested {
  type: 'stock.reservation.requested';
  orderId: string;
  items: Array<{
    productId: string;
    quantity: number;
  }>;
  timestamp: string;
}

// 在庫引当結果（イベント）
interface StockReservationCompleted {
  type: 'stock.reservation.completed';
  orderId: string;
  status: 'reserved' | 'insufficient';
  items: Array<{
    productId: string;
    quantity: number;
    reserved: boolean;
  }>;
  expiresAt: string;  // 引当の有効期限
  timestamp: string;
}

設計判断: 在庫確認は同期（即時応答が必要）、引当は非同期（Sagaの一部として結果整合性で処理）。

Phase 1: Schema分離（2週間）

-- 共有DBをSchema分離
CREATE SCHEMA order_schema;
CREATE SCHEMA inventory_schema;
CREATE SCHEMA catalog_schema;

-- テーブルを適切なSchemaに移動
ALTER TABLE orders SET SCHEMA order_schema;
ALTER TABLE order_items SET SCHEMA order_schema;
ALTER TABLE products SET SCHEMA catalog_schema;
ALTER TABLE stock_levels SET SCHEMA inventory_schema;

-- 互換性のためにViewを作成
CREATE VIEW public.orders AS SELECT * FROM order_schema.orders;

Phase 2: JOIN解消（4週間）

// Before: SQL JOIN
// SELECT o.*, p.name FROM orders o JOIN products p ...

// After: API Composition
class OrderDetailService {
  async getOrderDetail(orderId: string) {
    const order = await this.orderRepo.findById(orderId);
    const productIds = order.items.map(i => i.productId);
    const products = await this.catalogClient.getProducts(productIds);
    return this.compose(order, products);
  }
}

Phase 3: 物理DB分離（4週間）

データ同期戦略:

graph LR
    ODB["Order DB"] -->|CDC Debezium| K1["Kafka"] -->|注文実績| CDB["Catalog DB"]
    CDB -->|CDC| K2["Kafka"] -->|商品名キャッシュ| ODB2["Order DB"]
    IDB["Inventory DB"] -->|CDC| K3["Kafka"] -->|在庫状況表示| CDB2["Catalog DB"]

    style ODB fill:#dbeafe,stroke:#2563eb,color:#1e40af
    style ODB2 fill:#dbeafe,stroke:#2563eb,color:#1e40af
    style CDB fill:#d1fae5,stroke:#059669,color:#065f46
    style CDB2 fill:#d1fae5,stroke:#059669,color:#065f46
    style IDB fill:#fef3c7,stroke:#d97706,color:#92400e
    style K1 fill:#f3e8ff,stroke:#7c3aed,color:#5b21b6
    style K2 fill:#f3e8ff,stroke:#7c3aed,color:#5b21b6
    style K3 fill:#f3e8ff,stroke:#7c3aed,color:#5b21b6