06｜整合與交易時序

sequenceDiagram
    autonumber
    actor C as 呼叫方
    participant O as Ordering
    participant DB as PostgreSQL
    participant K as Debezium／Kafka
    participant I as Inventory
    participant W as WMS
    C->>O: HTTP POST /orders（JSON）
    alt 欄位或唯一／參照約束失敗
        O-->>C: 400／409 application/problem+json
    else 驗證通過
        O->>DB: BEGIN；orders、order_lines、event_outbox；COMMIT
        O-->>C: 200 OrderStatusResponse（PENDING）
        DB-->>K: logical WAL → ordering.order-events
        K->>I: OrderPlacedIntegrationEvent
        I->>DB: BEGIN；Inbox claim + 註冊 operation／moves
        I->>DB: 查供給與前序需求，嘗試整單配貨
        alt 供給不足或前序需求優先
            I->>DB: 保持 CONFIRMED，不部分預留；COMMIT
            Note over C,I: 補貨 availability event 或 reconciliation 再嘗試
        else 全需求可供應
            I->>DB: 同交易原子預留 + ASSIGNED + Outbox；COMMIT
            DB-->>K: promising.allocation-events
            K->>O: OrderAllocationCommittedIntegrationEvent → ALLOCATED
            K->>W: 同事件 → 建立 Shipment
            W->>DB: 波次、揀貨、包裝、交運狀態 + Outbox
            DB-->>K: promising.fulfillment-handoffs
            K->>I: ShipmentHandedOverIntegrationEvent
            I->>DB: 完成扣庫 DONE + 兩份 Outbox publication
            DB-->>K: OutboundMovementsCompletedIntegrationEvent
            K->>O: markFulfilled → FULFILLED
        end
    end
    opt HTTP 回應逾時或連線中斷
        C->>O: GET /orders?ownerId=...&limit=100 核對原單
        Note over C,O: 此 API 只有最近清單，找不到不能證明未建立；需日誌／DB 查單號
    end

載入圖表…

sequenceDiagram
    actor C as 呼叫方
    participant F as Fulfillment
    participant DB as PostgreSQL
    participant K as Kafka／Outbox
    participant W as WMS
    participant O as Ordering
    participant I as Inventory
    C->>F: POST /orders/{orderId}/cancellation-requests
    F->>DB: INSERT cancellation_processes ON CONFLICT DO NOTHING
    alt requestId 與原內容相同
        F-->>C: 200 ALREADY_REQUESTED
    else 同鍵異內容或同單已有 active process
        F-->>C: 409 CONFLICT（application/json）
    else 新請求
        F->>DB: WAITING_WMS + Outbox，COMMIT
        F-->>C: 202 ACCEPTED + effectiveRequestId
        K->>W: WmsCancellationRequestedIntegrationEvent
        alt 已交運或多張 Shipment
            W->>K: WmsCancellationRequestResolvedIntegrationEvent
            K->>F: REJECTED／MULTIPLE_SHIPMENTS
            F->>DB: SELECT FOR UPDATE；REJECTED／CONFLICT
        else 可取消或 NO_SHIPMENT
            W->>K: 倉內取消完成結果（必要時先等待 CANCELLING）
            K->>F: SHIPMENT_CANCELLED／NO_SHIPMENT
            F->>DB: SELECT FOR UPDATE；WAITING_ORDERING + Outbox
            K->>O: OrderingCancellationRequestedIntegrationEvent
            O->>K: OrderingCancellationRequestResolvedIntegrationEvent
            K->>F: SUCCEEDED → COMPLETED；REJECTED → CONFLICT
            O->>K: 成功時 OrderCancelledIntegrationEvent
            K->>I: 取消 operation／moves，釋放預留
        end
    end
    opt 超時或只收到 ACCEPTED
        C->>F: GET /orders/{orderId}/cancellation-requests/{requestId}
        F-->>C: process state（Events only）；找不到時 404 空 body
    end

載入圖表…

flowchart LR
    M[一筆 Kafka delivery] --> L[本地首次 + 2 次 optimistic retry]
    L -->|可重試且未成功| B[Kafka 4 次 redelivery]
    B --> L
    L -->|成功| Commit[Inbox 與業務提交]
    B -->|額度耗盡| DLT[保留 identity 送 DLT]
    L -->|永久錯誤| DLT

載入圖表…