Home / Diagrams / 08 event flow diagrams.html

PakLog Event Flow Diagrams

Complete Event-Driven Architecture

Order Fulfillment Flow - End to End

sequenceDiagram
    participant EC as E-Commerce
    participant OM as Order Management
    participant I as Inventory
    participant C as Cartonization
    participant WO as Warehouse Ops
    participant WP as Wave Planning
    participant TE as Task Execution
    participant PE as Pick Execution
    participant PS as Pack & Ship
    participant ST as Shipment Transport

    EC->>OM: Order Request
    OM->>OM: Validate Order
    OM->>I: Check Availability
    I-->>OM: Stock Available
    OM->>I: Allocate Inventory

    OM->>+OM: Publish OrderCreated
    Note over OM: Domain Event

    OM->>C: Request Cartonization
    C->>C: Calculate 3D Packing
    C-->>OM: PackingSolution

    OM->>+OM: Publish OrderAllocated

    OM->>WO: Release Order
    WO->>+WO: Publish OrderReleasedToWarehouse

    WO->>WP: Add to Wave Queue
    WP->>WP: Optimize Wave
    WP->>+WP: Publish WavePlanned

    WP->>TE: Create Tasks
    TE->>+TE: Publish TaskCreated

    TE->>PE: Assign Pick Task
    PE->>PE: Calculate TSP Path
    PE->>+PE: Publish PickStarted

    PE->>PE: Execute Picks
    PE->>+PE: Publish PickCompleted

    PE->>PS: Transfer to Pack
    PS->>PS: Pack Items
    PS->>+PS: Publish PackageSealed

    PS->>ST: Create Shipment
    ST->>ST: Generate Label
    ST->>+ST: Publish ShipmentCreated

    ST-->>OM: Update Status
    OM->>+OM: Publish OrderShipped

Returns Processing Flow

sequenceDiagram
    participant CUST as Customer
    participant RM as Returns Mgmt
    participant OM as Order Mgmt
    participant I as Inventory
    participant QC as Quality Compliance
    participant FS as Financial Settlement

    CUST->>RM: Request Return
    RM->>OM: Validate Order
    OM-->>RM: Order Details

    RM->>RM: Check Return Window
    RM->>RM: Fraud Detection
    RM->>+RM: Publish ReturnCreated

    alt Approved
        RM->>+RM: Publish ReturnApproved
        RM->>CUST: Send RMA Label

        CUST->>RM: Ship Return
        RM->>+RM: Publish ReturnReceived

        RM->>QC: Inspect Items
        QC->>QC: Quality Check
        QC->>+QC: Publish InspectionCompleted

        QC-->>RM: Inspection Result

        alt Good Condition
            RM->>I: Return to Stock
            I->>+I: Publish InventoryReceived
            RM->>FS: Process Refund
            FS->>+FS: Publish RefundProcessed
        else Damaged
            RM->>RM: Disposition Decision
            RM->>+RM: Publish DispositionDecided
        end
    else Denied
        RM->>+RM: Publish ReturnDenied
        RM->>CUST: Notify Denial
    end

Robotics Fleet Coordination Flow

sequenceDiagram
    participant TE as Task Execution
    participant RF as Robotics Fleet
    participant WES as WES Orchestration
    participant PT as Physical Tracking
    participant LM as Location Master

    TE->>RF: Request Robot
    RF->>RF: Select Best Robot
    RF->>RF: Calculate A* Path
    RF->>+RF: Publish RobotAssigned

    RF->>RF: Check Collisions
    RF->>LM: Get Zone Capacity
    LM-->>RF: Zone Status

    RF->>+RF: Publish PathCalculated

    RF->>PT: Update Position
    PT->>+PT: Publish AssetMoved

    loop Mission Execution
        RF->>RF: Execute Step
        RF->>PT: Update Location
        PT->>+PT: Publish LocationUpdated

        alt Battery Low
            RF->>+RF: Publish BatteryLow
            RF->>RF: Queue Charging
        end
    end

    RF->>+RF: Publish MissionCompleted
    RF->>TE: Task Complete

Predictive Analytics Integration Flow

sequenceDiagram
    participant PA as Predictive Analytics
    participant WP as Wave Planning
    participant WL as Workload Planning
    participant I as Inventory
    participant YM as Yard Management

    Note over PA: Scheduled Job
    PA->>PA: Collect Historical Data
    PA->>PA: Train ML Model
    PA->>PA: Generate Forecasts

    PA->>+PA: Publish DemandForecast
    WP-->>PA: Subscribe
    WL-->>PA: Subscribe

    PA->>+PA: Publish InventoryForecast
    I-->>PA: Subscribe

    PA->>+PA: Publish LaborForecast
    WL-->>PA: Subscribe

    PA->>+PA: Publish VolumeForeca
    YM-->>PA: Subscribe

    alt Anomaly Detected
        PA->>+PA: Publish AnomalyDetected
        Note over PA: Alert stakeholders
    end

Cross-Docking Flow

sequenceDiagram
    participant YM as Yard Management
    participant CD as Cross-Docking
    participant WO as Warehouse Ops
    participant ST as Shipment Transport
    participant I as Inventory

    YM->>+YM: Publish TrailerArrived
    CD-->>YM: Subscribe

    CD->>CD: Check Cross-Dock Eligible

    alt Direct Transfer
        CD->>+CD: Publish CrossDockPlanned
        CD->>WO: Skip Put-Away
        CD->>ST: Direct to Outbound
        ST->>+ST: Publish DirectShipmentCreated
    else Consolidation Required
        CD->>CD: Plan Consolidation
        CD->>+CD: Publish ConsolidationPlanned
        CD->>WO: Stage Items

        loop Wait for All Items
            CD->>CD: Track Arrivals
        end

        CD->>+CD: Publish ConsolidationCompleted
        CD->>ST: Ship Consolidated
    end

WES Orchestration Saga Flow

sequenceDiagram
    participant WES as WES Orchestration
    participant OM as Order Management
    participant I as Inventory
    participant WP as Wave Planning
    participant TE as Task Execution
    participant PS as Pack & Ship

    Note over WES: Complex Order Workflow
    WES->>WES: Start Saga
    WES->>+WES: Publish WorkflowStarted

    WES->>OM: Step 1: Validate Order
    OM-->>WES: Success
    WES->>+WES: Publish StepCompleted

    WES->>I: Step 2: Allocate Inventory
    I-->>WES: Success
    WES->>+WES: Publish StepCompleted

    WES->>WP: Step 3: Plan Wave
    WP-->>WES: Success
    WES->>+WES: Publish StepCompleted

    WES->>TE: Step 4: Execute Tasks

    alt Task Failed
        TE-->>WES: Failure
        WES->>+WES: Publish CompensationStarted

        Note over WES: Reverse Order
        WES->>WP: Compensate: Cancel Wave
        WES->>I: Compensate: Deallocate
        WES->>OM: Compensate: Cancel Order

        WES->>+WES: Publish WorkflowFailed
    else Success
        TE-->>WES: Success
        WES->>PS: Step 5: Ship
        PS-->>WES: Success

        WES->>+WES: Publish WorkflowCompleted
    end

Event Catalog

Core Domain Events

Order Management Events

Inventory Events

Wave Planning Events

Task Execution Events

Pick Execution Events

Pack & Ship Events

Robotics Fleet Events

Returns Management Events

Quality Compliance Events

Predictive Analytics Events

Event Publishing Patterns

Event Structure (CloudEvents)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

{
  "specversion": "1.0",
  "type": "com.paklog.order.OrderCreated",
  "source": "order-management-service",
  "subject": "order/12345",
  "id": "event-uuid",
  "time": "2024-01-15T10:30:00Z",
  "datacontenttype": "application/json",
  "data": {
    "orderId": "12345",
    "customerId": "CUST-789",
    "orderLines": [...],
    "priority": "HIGH"
  }
}

Event Topics

Kafka Topic Structure

Event Ordering Guarantees

Idempotency

Event Sourcing Services

Dead Letter Queue (DLQ) Handling