楽天 RMS Web API で注文管理を自動化する — 受注確認から出荷完了まで全フロー実装

// 認証ヘッダの生成
function buildAuthHeader(serviceSecret: string, licenseKey: string): string {
  const credentials = Buffer.from(`${serviceSecret}:${licenseKey}`).toString("base64")
  return `ESA ${credentials}`
}
 
// API リクエストの基本構造
async function callRmsApi(endpoint: string, params: Record<string, unknown>) {
  const response = await fetch(`https://api.rms.rakuten.co.jp/es/${endpoint}`, {
    method: "POST",
    headers: {
      Authorization: buildAuthHeader(SERVICE_SECRET, LICENSE_KEY),
      "Content-Type": "application/json; charset=utf-8",
    },
    body: JSON.stringify(params),
  })
  return response.json()
}

async function getUnconfirmedOrders() {
  const result = await callRmsApi("order/1.0/searchOrder", {
    orderProgressList: [100], // 100: 注文確認待ち
    PaginationRequestModel: {
      requestRecordsAmount: 100,
      requestPage: 1,
    },
  })
 
  return result.orderNumberList ?? []
}

async function getOrderDetails(orderNumberList: string[]) {
  const result = await callRmsApi("order/1.0/getOrder", {
    orderNumberList,
  })
  return result.orderModelList ?? []
}

async function confirmOrders(orderNumberList: string[]) {
  return callRmsApi("order/1.0/confirmOrder", {
    orderNumberList,
  })
}

async function registerShippingInfo(
  orderNumber: string,
  shippingModel: {
    deliveryCompany: string // 配送会社コード
    shippingNumber: string  // 追跡番号
  }
) {
  return callRmsApi("order/1.0/updateOrderShipping", {
    orderNumber,
    orderSenderModel: {
      shippingCarrierId: shippingModel.deliveryCompany,
      shippingNumber: shippingModel.shippingNumber,
    },
  })
}

async function markAsShipped(orderNumberList: string[]) {
  return callRmsApi("order/1.0/updateOrderProgress", {
    orderProgressList: [
      {
        orderProgress: 700, // 700: 発送済み
        orderNumberList,
      },
    ],
  })
}

async function processNewOrders() {
  // 1. 未確認注文の取得
  const orderNumbers = await getUnconfirmedOrders()
  if (orderNumbers.length === 0) return
 
  // 2. 受注確認
  await confirmOrders(orderNumbers)
 
  // 3. 注文詳細取得 → WMS へ連携
  const orders = await getOrderDetails(orderNumbers)
  for (const order of orders) {
    await sendToWms(order)
  }
}
 
// WMS から追跡番号を受け取った後
async function handleShipment(orderNumber: string, trackingNumber: string) {
  // 4. 伝票番号登録
  await registerShippingInfo(orderNumber, {
    deliveryCompany: "2", // ヤマト運輸
    shippingNumber: trackingNumber,
  })
 
  // 5. 出荷完了通知
  await markAsShipped([orderNumber])
}