Magento 2 + Picqer: warehouse management koppeling

Klant plaatst order in Magento 2
  ↓
Order-event triggert middleware
  ↓
Middleware stuurt order naar Picqer API
  ↓
Picqer maakt picklist aan
  ↓
Magazijnmedewerker pikt en verpakt
  ↓
Picqer markeert order als verzonden (met track & trace)
  ↓
Middleware werkt Magento-order bij: status + tracking
  ↓
Klant ontvangt automatische bevestigingsmail met tracking

Picqer: voorraadmutatie (ontvangst of pick)
  ↓
Middleware: voorraadupdate naar Magento
  ↓
Magento: actuele voorraad op productpagina

// Picqer API client initialiseren
$client = new Client([
    'base_uri' => 'https://jouw-account.picqer.com/api/v1/',
    'auth' => [config('picqer.api_key'), ''],
    'headers' => [
        'Content-Type' => 'application/json',
        'User-Agent' => 'MagentoIntegration/1.0',
    ],
]);

// Alle producten ophalen (paginering)
$products = [];
$offset = 0;

do {
    $response = $client->get('products', [
        'query' => ['offset' => $offset, 'limit' => 100],
    ]);
    $page = json_decode($response->getBody(), true);
    $products = array_merge($products, $page);
    $offset += 100;
} while (count($page) === 100);

// Magento observer: order geplaatst
class OrderPlacedObserver implements ObserverInterface
{
    public function __construct(
        private readonly PicqerSyncQueue $queue
    ) {}

    public function execute(Observer $observer): void
    {
        $order = $observer->getEvent()->getOrder();

        // Alleen syncen als order betaald of geconfirmeerd
        if (!in_array($order->getStatus(), ['processing', 'pending_payment'])) {
            return;
        }

        $this->queue->dispatch(new SyncOrderToPicqer($order->getId()));
    }
}

public function createPickingOrder(Order $order): array
{
    $orderLines = [];

    foreach ($order->getAllVisibleItems() as $item) {
        $orderLines[] = [
            'productcode' => $item->getSku(),
            'amount' => (int) $item->getQtyOrdered(),
            'name' => $item->getName(),
            'price' => $item->getRowTotalInclTax() / $item->getQtyOrdered(),
        ];
    }

    return $this->picqerClient->post('orders', [
        'idorder' => $order->getIncrementId(), // Magento ordernummer als referentie
        'deliveryname' => $order->getShippingAddress()->getName(),
        'deliveryaddress' => $order->getShippingAddress()->getStreetLine(1),
        'deliverycity' => $order->getShippingAddress()->getCity(),
        'deliveryzip' => $order->getShippingAddress()->getPostcode(),
        'deliverycountry' => $order->getShippingAddress()->getCountryId(),
        'products' => $orderLines,
        'reference' => $order->getIncrementId(),
    ]);
}

// Controleer of order al bestaat in Picqer
$existingOrders = $this->picqerClient->get('orders', [
    'query' => ['idorder' => $order->getIncrementId()],
]);

if (!empty($existingOrders)) {
    // Al gesynchroniseerd, sla het Picqer ID op als dat nog niet is gedaan
    $order->setData('picqer_order_id', $existingOrders[0]['idorder']);
    return;
}

public function processPicqerShipment(array $picqerOrder): void
{
    // Vind de Magento order via het referentienummer
    $magentoOrder = $this->orderRepository->get(
        $this->orderFactory->create()->loadByIncrementId($picqerOrder['reference'])->getId()
    );

    // Maak shipment aan in Magento
    $shipment = $this->shipmentFactory->create($magentoOrder);

    foreach ($magentoOrder->getAllItems() as $orderItem) {
        $shipmentItem = $this->shipmentItemFactory->create();
        $shipmentItem->setOrderItem($orderItem)->setQty($orderItem->getQtyToShip());
        $shipment->addItem($shipmentItem);
    }

    // Track & trace toevoegen
    if (!empty($picqerOrder['shipments'][0]['barcode'])) {
        $track = $this->trackFactory->create();
        $track->setCarrierCode($this->resolveCarrierCode($picqerOrder['shipments'][0]['shipper']))
              ->setTitle($picqerOrder['shipments'][0]['shipper'])
              ->setTrackNumber($picqerOrder['shipments'][0]['barcode']);
        $shipment->addTrack($track);
    }

    $this->shipmentRepository->save($shipment);

    // Stuur automatisch verzendbevestiging naar klant
    $this->shipmentSender->send($shipment);
}

public function syncInventoryFromPicqer(): void
{
    // Producten ophalen die zijn gewijzigd in de afgelopen 35 minuten
    // (5 minuten overlap voor veiligheid)
    $since = now()->subMinutes(35)->toIso8601String();

    $products = $this->picqerClient->get('products', [
        'query' => ['updated_since' => $since],
    ]);

    foreach ($products as $product) {
        try {
            $this->updateMagentoStock(
                sku: $product['productcode'],
                qty: $product['stock'],
                isInStock: $product['stock'] > 0
            );
        } catch (NoSuchEntityException $e) {
            // Product bestaat niet in Magento, loggen en doorgaan
            Log::warning("Picqer product niet gevonden in Magento: {$product['productcode']}");
        }
    }
}

private function updateMagentoStock(string $sku, int $qty, bool $isInStock): void
{
    $stockItem = $this->stockRegistry->getStockItemBySku($sku);
    $stockItem->setQty($qty);
    $stockItem->setIsInStock($isInStock);
    $this->stockRegistry->updateStockItemBySku($sku, $stockItem);
}

// Dagelijkse check: ongesynchroniseerde orders
$unsyncedOrders = Order::where('status', 'processing')
    ->whereNull('picqer_order_id')
    ->where('created_at', '<', now()->subHours(2))
    ->count();

if ($unsyncedOrders > 0) {
    Notification::route('mail', config('picqer.alert_email'))
        ->notify(new UnsyncedOrdersAlert($unsyncedOrders));
}