Magento 2 + Exact Online: real-time synchronisatie

// Token ophalen en opslaan
$tokenData = $this->oauthClient->getAccessToken(
    'authorization_code',
    ['code' => $authCode]
);

// Token opslaan met expiratie
Cache::put('exact_access_token', $tokenData->getToken(), 590); // 590 seconden
Cache::put('exact_refresh_token', $tokenData->getRefreshToken(), 30 * 24 * 3600);

// Voorbeeld: orders ophalen
$response = Http::withToken($accessToken)
    ->get("https://start.exactonline.nl/api/v1/{$division}/salesorder/SalesOrders", [
        '$filter' => "Status eq 20", // Bevestigde orders
        '$top' => 100,
        '$select' => 'OrderID,OrderNumber,OrderDate,TotalAmountDC',
    ]);

Magento 2 (order geplaatst)
  → Event: sales_order_place_after
  → Middleware queue: order-job aanmaken
  → Worker: Exact Online API aanroepen
  → Succes: Exact order-ID opslaan in Magento
  → Fout: job opnieuw proberen met exponential backoff

// Job aanmaken bij nieuwe order
class SyncOrderToExact implements ShouldQueue
{
    use InteractsWithQueue, Queueable, SerializesModels;

    public $tries = 5;
    public $backoff = [30, 120, 300, 600, 1800]; // Seconden tussen pogingen

    public function __construct(private int $orderId) {}

    public function handle(ExactOnlineService $exactService): void
    {
        $order = Order::findOrFail($this->orderId);

        // Controleer of order al gesynchroniseerd is
        if ($order->exact_order_id) {
            return;
        }

        $exactOrderId = $exactService->createSalesOrder($order);
        $order->update(['exact_order_id' => $exactOrderId]);
    }

    public function failed(\Throwable $e): void
    {
        // Alert sturen bij definitieve mislukking
        Notification::route('mail', config('exact.alert_email'))
            ->notify(new ExactSyncFailedNotification($this->orderId, $e));
    }
}

public function createSalesOrder(Order $order): string
{
    $debtor = $this->findOrCreateDebtor($order->getCustomerEmail());

    $orderLines = [];
    foreach ($order->getAllVisibleItems() as $item) {
        $orderLines[] = [
            'Item' => $item->getSku(),
            'Description' => $item->getName(),
            'Quantity' => $item->getQtyOrdered(),
            'UnitPrice' => $item->getPrice(),
            'VATCode' => $this->resolveVatCode($item->getTaxPercent()),
        ];
    }

    $response = $this->exactClient->post('salesorder/SalesOrders', [
        'OrderedBy' => $debtor['ID'],
        'DeliverTo' => $debtor['ID'],
        'PaymentCondition' => $this->resolvePaymentCondition($order),
        'SalesOrderLines' => $orderLines,
    ]);

    return $response['d']['OrderID'];
}

// Elke 15 minuten draaien via scheduler
public function syncInventory(): void
{
    $items = $this->exactClient->get('inventory/ItemWarehouses', [
        '$filter' => "Modified gt datetime'" . now()->subMinutes(20)->toIso8601String() . "'",
        '$select' => 'Item,QuantityInStock,CurrentStock',
    ]);

    foreach ($items as $item) {
        $this->magentoInventoryService->updateStock(
            sku: $item['ItemCode'],
            qty: $item['CurrentStock']
        );
    }
}

public function findOrCreateDebtor(string $email): array
{
    // Zoek op e-mailadres in Exact
    $existing = $this->exactClient->get('crm/Accounts', [
        '$filter' => "Email eq '{$email}'",
        '$top' => 1,
    ]);

    if (!empty($existing)) {
        return $existing[0];
    }

    // Nieuw debiteur aanmaken
    return $this->exactClient->post('crm/Accounts', [
        'Email' => $email,
        'Name' => $this->getNameFromEmail($email),
        'IsSupplier' => false,
        'IsCustomer' => true,
    ]);
}

public function handle(): void
{
    try {
        $this->syncOrderToExact();
    } catch (TokenExpiredException $e) {
        $this->tokenService->refresh();
        $this->release(5); // Over 5 seconden opnieuw proberen
    } catch (ValidationException $e) {
        // Niet opnieuw proberen, alert sturen
        Log::error('Exact validation error', [
            'order_id' => $this->orderId,
            'error' => $e->getMessage(),
        ]);
        $this->fail($e);
    } catch (ConnectException $e) {
        // Tijdelijk, opnieuw proberen
        $this->release($this->attempts() * 60);
    }
}