eBay Order Management API で注文を自動処理する — 受注から追跡番号登録まで

// 直近 2 時間の注文を取得
async function getRecentOrders(accessToken: string) {
  const creationDateFrom = new Date(Date.now() - 2 * 60 * 60 * 1000).toISOString()
 
  const response = await fetch(
    `https://api.ebay.com/sell/fulfillment/v1/order?filter=creationdate:[${creationDateFrom}..],orderfulfillmentstatus:{NOT_STARTED|IN_PROGRESS}`,
    {
      headers: {
        Authorization: `Bearer ${accessToken}`,
        "Content-Type": "application/json",
      },
    }
  )
 
  const data = await response.json()
  return data.orders ?? []
}

interface EbayOrder {
  orderId: string
  creationDate: string
  orderFulfillmentStatus: "NOT_STARTED" | "IN_PROGRESS" | "FULFILLED"
  lineItems: Array<{
    lineItemId: string
    sku: string
    quantity: number
    title: string
    lineItemFulfillmentStatus: string
  }>
  buyer: {
    username: string
    taxIdentifier?: { taxpayerId: string }
  }
  fulfillmentStartInstructions: Array<{
    fulfillmentInstructionsType: string
    shipToLocation: {
      contactAddress: {
        addressLine1: string
        city: string
        stateOrProvince: string
        postalCode: string
        countryCode: string
      }
      contact: {
        fullName: string
        primaryPhone: { phoneNumber: string }
      }
    }
    maxEstimatedDeliveryDate: string
  }>
}

async function registerShipment(
  accessToken: string,
  orderId: string,
  trackingNumber: string,
  lineItems: Array<{ lineItemId: string; quantity: number }>
) {
  const response = await fetch(
    `https://api.ebay.com/sell/fulfillment/v1/order/${orderId}/shipping_fulfillment`,
    {
      method: "POST",
      headers: {
        Authorization: `Bearer ${accessToken}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({
        lineItems,
        shippedDate: new Date().toISOString(),
        shippingCarrierCode: "JAPAN_POST",
        trackingNumber,
      }),
    }
  )
 
  if (!response.ok) {
    const error = await response.json()
    throw new Error(`Shipment registration failed: ${JSON.stringify(error.errors)}`)
  }
 
  return response.json()
}

async function processEbayOrders() {
  const token = await getAccessToken()
  const orders = await getRecentOrders(token)
 
  for (const order of orders) {
    // WMS への連携（詳細は省略）
    const wmsResult = await sendOrderToWms(order)
    if (wmsResult.status !== "queued") continue
 
    console.log(`Order ${order.orderId} queued in WMS`)
  }
}
 
// WMS から tracking 番号が確定したら呼ばれる
async function handleWmsShipmentComplete(
  orderId: string,
  trackingNumber: string,
  lineItems: Array<{ lineItemId: string; quantity: number }>
) {
  const token = await getAccessToken()
  await registerShipment(token, orderId, trackingNumber, lineItems)
  console.log(`Order ${orderId} marked as shipped: ${trackingNumber}`)
}

async function fetchWithRetry(url: string, options: RequestInit, maxRetries = 3) {
  for (let attempt = 0; attempt < maxRetries; attempt++) {
    const response = await fetch(url, options)
 
    if (response.status === 429 || response.status === 503) {
      const retryAfter = response.headers.get("Retry-After") ?? "5"
      await new Promise((r) => setTimeout(r, parseInt(retryAfter) * 1000))
      continue
    }
 
    return response
  }
  throw new Error(`Max retries exceeded for ${url}`)
}