Đồng bộ Tích hợp ERP (ERP Integration Sync)

Tổng quan

HieraChain tích hợp với các hệ thống ERP doanh nghiệp (SAP, Oracle, Dynamics) thông qua cấu trúc bộ điều phối (adapter) + bộ máy ánh xạ (mapping engine). Lớp SyncScheduler thăm dò các adapter ERP theo khoảng thời gian cấu hình, dịch chuyển các sự kiện ERP gốc thành định dạng sự kiện của HieraChain thông qua EventTranslator, phát hiện các thay đổi dữ liệu có ý nghĩa và gửi chúng dưới dạng các sự kiện nghiệp vụ. Các lượt đồng bộ lỗi sẽ được thử lại theo cơ chế khoảng chờ tăng dần (exponential backoff).

Quy trình này đóng vai trò là cầu nối tiếp nhận dữ liệu (ingestion bridge) giữa các hệ thống Web2 ERP truyền thống và sổ cái HieraChain.

Biểu đồ luồng

sequenceDiagram
    autonumber
    participant ERP as 🏢 Hệ thống ERP (SAP / Oracle)
    participant EIL as 🔗 ERPIntegrationLedger
    participant ME as 🗺️ MappingEngine
    participant CD as 🔄 ChangeDetector
    participant ET as 🔀 EventTranslator
    participant SS as ⏰ SyncScheduler
    participant SC as 📦 SubChain

    Note over SS: SyncScheduler kích hoạt theo chu kỳ interval_seconds

    SS->>EIL: _execute_sync(profile_name, profile, adapter, chain)
    EIL->>ERP: adapter.get_changes_since_last_sync()
    ERP-->>EIL: [erp_event_1, erp_event_2, ...]

    loop Trên từng sự kiện ERP
        EIL->>ME: get_profile(profile_name)
        ME-->>EIL: MappingProfile { erp_system, mapping_rules, detect_changes }

        alt detect_changes=True
            EIL->>CD: detect_changes(erp_event, profile)
            CD->>CD: compare_states(previous_state, erp_event)
            CD->>CD: Chú thích { change_detected, changes: { field: { old, new, type } } }
            CD-->>EIL: Sự kiện erp_event đã được chú thích
        end

        EIL->>ET: translate(erp_event, mapping_rules)
        ET->>ET: Áp dụng ánh xạ trường (đường dẫn đơn hoặc hàm chuyển đổi)
        ET->>ET: add_blockchain_metadata()<br/>{ timestamp, event: "erp_integration", source: erp_system }
        ET-->>EIL: Từ điển blockchain_event dict

        EIL->>SC: add_event(blockchain_event)
        Note right of SC: Đi vào đường truyền Gửi Sự kiện (Event Submission)
    end

    EIL->>SS: update_last_sync(profile_name, now)
    SS->>SS: Lên lịch lần chạy tiếp theo (now + interval_seconds)

    alt Đồng bộ thất bại
        SS->>SS: schedule_retry(profile_name)<br/>Exponential backoff: min(300, 30 × 2^retry_count)
    end

Biểu đồ luồng — Cơ chế Thử lại khi Thất bại (Retry on Failure)

flowchart LR
    SYNC["_execute_sync()"] -->|Thành công| UPD["update_last_sync()\nnext = now + interval"]
    SYNC -->|Gặp ngoại lệ| RETRY["schedule_retry(profile)\nbackoff = min(300s, 30 × 2^n)"]
    RETRY --> WAIT["Đợi hết khoảng chờ backoff"]
    WAIT --> SYNC
    RETRY -->|retry_count > max| ALERT["Cảnh báo qua Risk Alerts\nLeo thang lỗi đồng bộ"]

Ví dụ Chuyển đổi Sự kiện ERP (ERP Event Translation Example)

# Sự kiện thô từ hệ thống SAP (trước khi chuyển đổi)
erp_event = {
    "MBLNR": "5000012345",       # Số chứng từ vật tư (Material document number)
    "BUDAT": "2024-04-23",       # Ngày ghi sổ (Posting date)
    "MATNR": "MAT-00789",        # Mã số vật tư (Material number)
    "MENGE": 150,                 # Số lượng (Quantity)
    "WERKS": "PLANT-01"          # Nhà máy (Plant)
}

# Sau khi qua bộ EventTranslator.translate() sử dụng profile ánh xạ của SAP
blockchain_event = {
    "entity_id": "MAT-00789",            # ánh xạ từ trường MATNR
    "event": "erp_integration",
    "timestamp": 1714000000.0,           # tự động thêm bởi add_blockchain_metadata()
    "details": {
        "document_number": "5000012345", # ánh xạ từ trường MBLNR
        "posting_date": "2024-04-23",    # ánh xạ từ trường BUDAT
        "quantity": 150,                  # ánh xạ từ trường MENGE
        "plant": "PLANT-01",             # ánh xạ từ trường WERKS
        "source": "SAP",
        "changes": {                      # tự động thêm bởi ChangeDetector nếu bật
            "quantity": {"old": 100, "new": 150, "type": "numeric_change"}
        }
    }
}

Các hệ thống ERP hỗ trợ

Các bước thực hiện chi tiết

Xử lý lỗi

Các Class & Method quan trọng

Liên quan

• Gửi Sự kiện — Các sự kiện sau khi dịch nghĩa sẽ đi vào luồng này
• Truy vết Thực thể — Các sự kiện có nguồn gốc từ ERP có thể được truy vết qua entity_id
• Cảnh báo Rủi ro — Các lỗi đồng bộ sẽ được chuyển tới đây để leo thang xử lý