Інтеграція блокчейну з корпоративними системами

Інтеграція блокчейну з корпоративними системами

Корпоративні системи — ERP, CRM, WMS, SCM — проектувалися під централізовану модель даних. Блокчейн пропонує протилежне: дані розподілені, стан верифікується математично, транзакції необоротні. Точка напруження виникає саме тут: ERP хоче зміненні записи з транзакційними откатами, а блокчейн говорить "записане не стирається".

Перед проектуванням інтеграції потрібно відповісти: що саме повинно жити в блокчейні, а що — в корпоративній системі? Зберігати всі дані ERP у блокчейні — неправильно технічно та економічно. Правильна відповідь: в блокчейні — тільки те, що вимагає верифікації кількома сторонами або незмінюваного audit trail. Документи про право власності, результати аудиту поставщиків, сертифікати походження — так. Поточні складські остатки — ні.

Паттерни інтеграції

1. Blockchain як audit log

Найпоширеніший паттерн. ERP залишається системою запису, блокчейн — іммутабельний audit log для критичних подій.

ERP подія → Event Hook → Blockchain Writer Service → Smart Contract
                                                          ↓
                                               Hash(event_data) + метадані

Зберігаємо не самі дані, а їх хеш:

contract AuditLog {
    struct AuditRecord {
        bytes32 dataHash;
        string systemId;    // "SAP-PROD-001"
        string eventType;   // "INVOICE_APPROVED"
        uint256 timestamp;
        address submitter;
    }
    
    mapping(bytes32 => AuditRecord) public records;
    
    event RecordAnchored(
        bytes32 indexed recordId,
        bytes32 dataHash,
        string eventType,
        uint256 timestamp
    );
    
    function anchor(
        bytes32 recordId,
        bytes32 dataHash,
        string calldata systemId,
        string calldata eventType
    ) external onlyAuthorized {
        require(records[recordId].timestamp == 0, "Record exists");
        records[recordId] = AuditRecord({
            dataHash: dataHash,
            systemId: systemId,
            eventType: eventType,
            timestamp: block.timestamp,
            submitter: msg.sender
        });
        emit RecordAnchored(recordId, dataHash, eventType, block.timestamp);
    }
    
    function verify(bytes32 recordId, bytes32 dataHash) external view returns (bool) {
        return records[recordId].dataHash == dataHash;
    }
}

Верифікація: беремо запис із ERP, хешуємо, порівнюємо з on-chain хешем. Якщо збігається — запис не змінювався з моменту анкоринга.

2. Токенізація активів: корпоративний реєстр

Реєстр активів (обладнання, транспортні засоби, нерухомість) у блокчейні. ERP/EAM синхронізується з on-chain станом.

ERP Asset Record  ←→  Blockchain Token (ERC-721 або ERC-1155)
     [змінювальна]         [іммутабельна історія]

Ключове рішення: хто може минтити/бернити токени? Зазвичай — авторизовані корпоративні аккаунти через multisig або timelock. Смарт-контракт з ролевим доступом (AccessControl):

bytes32 public constant ASSET_MANAGER_ROLE = keccak256("ASSET_MANAGER_ROLE");
bytes32 public constant AUDITOR_ROLE = keccak256("AUDITOR_ROLE");

function mintAsset(
    address to,
    uint256 tokenId,
    string calldata externalId, // ID в ERP системі
    bytes calldata metadata
) external onlyRole(ASSET_MANAGER_ROLE) {
    // ...
}

3. Smart contract-triggered workflows

Подія в блокчейні триггерить процес в корпоративній системі. Наприклад: смарт-контракт підтверджує отримання товару → автоматично створюється invoice в ERP.

Smart Contract Event
       ↓
Event Listener Service
       ↓
Message Queue (Kafka/RabbitMQ)
       ↓
ERP Integration Adapter
       ↓
ERP API (REST/SOAP/EDI)

Middleware: ключовий компонент інтеграції

Пряме взаємодія ERP ↔ блокчейн — майже завжди погана ідея. SAP, Oracle, 1C не мають нативних блокчейн коннекторів (або вони примітивні). Потрібен middleware шар:

class BlockchainIntegrationMiddleware {
  private eventQueue: KafkaProducer;
  private erpAdapter: ERPAdapter;
  private blockchainService: BlockchainService;

  // ERP → Blockchain: анкоринг события
  async anchorERPEvent(event: ERPEvent): Promise<AnchorResult> {
    // 1. Нормалізація даних
    const normalized = this.normalizeEvent(event);
    
    // 2. Хеш для анкоринга
    const dataHash = ethers.keccak256(
      ethers.toUtf8Bytes(JSON.stringify(normalized))
    );
    
    // 3. Запис у блокчейн
    const tx = await this.blockchainService.anchor(
      event.id,
      dataHash,
      event.systemId,
      event.type
    );
    
    // 4. Зберігаємо результат у ERP (tx hash, block number)
    await this.erpAdapter.updateAnchorInfo(event.id, {
      txHash: tx.hash,
      blockNumber: tx.blockNumber,
      network: 'ethereum-mainnet',
      anchoredAt: new Date(),
    });
    
    return { txHash: tx.hash, dataHash };
  }

  // Blockchain → ERP: обробка on-chain события
  async processBlockchainEvent(event: BlockchainEvent): Promise<void> {
    // Idempotency: не обробляємо повторно
    if (await this.isAlreadyProcessed(event.transactionHash)) return;
    
    await this.eventQueue.send({
      topic: `erp-integration.${event.type}`,
      messages: [{ 
        key: event.transactionHash,
        value: JSON.stringify(event) 
      }],
    });
    
    await this.markAsProcessed(event.transactionHash);
  }
}

SAP інтеграція: практичні деталі

SAP надає кілька точок інтеграції:

BAPI/RFC — бізнес-функції, які викликаються через RFC протокол. Бібліотека node-rfc для Node.js.

SAP Integration Suite (BTP) — хмарна інтеграційна платформа з візуальним конструктором flows. Підтримує REST/SOAP/OData адаптери.

IDocs — асинхронний обмін документами. Класичний паттерн для EDI інтеграцій.

SAP Event Mesh — Kafka-сумісний message broker від SAP.

// Приклад через SAP RFC (BAPI)
import { Client } from 'node-rfc';

const client = new Client({
  ashost: process.env.SAP_HOST!,
  sysnr: '00',
  client: '100',
  user: process.env.SAP_USER!,
  passwd: process.env.SAP_PASSWORD!,
  lang: 'EN',
});

await client.open();

// Отримуємо дані замовлення для анкоринга
const result = await client.call('BAPI_SALESORDER_GETLIST', {
  CUSTOMER_NUMBER: customerId,
  MATERIAL: materialId,
});

// Формуємо дані для анкоринга в блокчейні
const orderData = result.SALES_ORDERS.map(order => ({
  id: order.VBELN,
  date: order.ERDAT,
  amount: order.NETWR,
  currency: order.WAERK,
}));

Управління транзакційністю та помилками

Головна проблема: блокчейн-транзакція може бути підтверджена в середину бізнес-процесу, після якої ERP операція упала. Або навпаки.

Паттерн Saga для розподілених транзакцій:

class AssetRegistrationSaga {
  async execute(assetData: AssetData): Promise<void> {
    const sagaId = uuid();
    
    // Крок 1: Записуємо в ERP (оборотне)
    const erpAssetId = await this.erpAdapter.createAsset(assetData);
    await this.saveSagaState(sagaId, 'ERP_CREATED', { erpAssetId });
    
    try {
      // Крок 2: Мінтимо токен в блокчейні (необоротне після finality)
      const tokenId = await this.blockchainService.mintAsset(
        erpAssetId, assetData
      );
      await this.saveSagaState(sagaId, 'TOKEN_MINTED', { tokenId });
      
      // Крок 3: Оновлюємо ERP з blockchain reference
      await this.erpAdapter.updateAssetBlockchainRef(erpAssetId, tokenId);
      await this.saveSagaState(sagaId, 'COMPLETED');
      
    } catch (blockchainError) {
      // Компенсуюча транзакція: откатуємо ERP
      await this.erpAdapter.deleteAsset(erpAssetId);
      await this.saveSagaState(sagaId, 'COMPENSATED');
      throw blockchainError;
    }
  }
}

Ідентифікація та PKI

Корпоративні користувачі не повинні управляти приватними ключами вручну. Рішення:

• HSM (Hardware Security Module) — Azure Dedicated HSM, AWS CloudHSM. Ключи генеруються та зберігаються в аппаратному модулі, операції підписання виконуються всередину HSM.
• Key Management Service — AWS KMS, Azure Key Vault. Програмний аналог HSM з управлінням через IAM.
• Enterprise Wallet — Fireblocks, Copper — enterprise-grade кастодія з MPC (Multi-Party Computation), workflow approvals, audit logs.

Для корпоративної інтеграції Fireblocks — золотий стандарт: API для програмного створення транзакцій, policy engine для автоматичного одобрення/відклонення, інтеграція з Active Directory.

Типові етапи проекту

Суммарно: 3–6 місяців, залежно від складності ERP ландшафту. Проекти з кількома корпоративними системами (SAP + Oracle + legacy WMS) — ближче до 6 місяців.