Integration Guide

import requests
import time

API_KEY = "sk-your-api-key"
BASE = "https://api.fulfillbot.com/api/v1/open"
HEADERS = {"Authorization": f"Bearer {API_KEY}", "Content-Type": "application/json"}

def search_products(keyword, page=1):
    """Search products on Taobao"""
    resp = requests.get(f"{BASE}/products/platform/taobao/search",
        params={"q": keyword, "page": page}, headers=HEADERS)
    resp.raise_for_status()
    return resp.json()["data"]

def add_to_cart(product_id, sku_id, quantity=1):
    """Add product to cart"""
    resp = requests.post(f"{BASE}/cart/items", headers=HEADERS,
        json={"productId": product_id, "skuId": sku_id, "quantity": quantity})
    resp.raise_for_status()
    return resp.json()["data"]

def create_order(items, remark=""):
    """Create purchase order"""
    resp = requests.post(f"{BASE}/orders", headers=HEADERS,
        json={"items": items, "remark": remark})
    resp.raise_for_status()
    return resp.json()["data"]

def wait_for_warehouse(order_id, timeout=86400, interval=300):
    """Poll until order arrives at warehouse"""
    start = time.time()
    while time.time() - start < timeout:
        resp = requests.get(f"{BASE}/orders/{order_id}/status", headers=HEADERS)
        status = resp.json()["data"]["status"]
        print(f"Order {order_id}: {status}")
        if status in ("in_warehouse", "completed"):
            return True
        if status in ("cancelled", "refunded"):
            return False
        time.sleep(interval)
    return False

def get_shippable_packages():
    """Get packages ready to ship"""
    resp = requests.get(f"{BASE}/warehouse/packages/shippable", headers=HEADERS)
    resp.raise_for_status()
    return resp.json()["data"]

def calculate_shipping(country, weight):
    """Calculate all shipping options"""
    resp = requests.post(f"{BASE}/logistics/calculate-freight-batch",
        headers=HEADERS, json={"country": country, "weight": weight})
    resp.raise_for_status()
    return resp.json()["data"]

def create_shipping_order(items, channel_id, address):
    """Create shipping order"""
    resp = requests.post(f"{BASE}/shipping/create", headers=HEADERS,
        json={"items": items, "logisticsChannelId": channel_id, **address})
    resp.raise_for_status()
    return resp.json()["data"]

# ---- Main Flow ----
if __name__ == "__main__":
    # 1. Search
    results = search_products("Nike Air Max")
    product = results["items"][0]
    print(f"Found: {product['title']} - {product['price']} CNY")

    # 2. Create order directly
    order = create_order([{
        "productId": product["id"],
        "skuId": product["skus"][0]["skuId"],
        "quantity": 1
    }])
    print(f"Order created: {order['orderNo']}")

    # 3. Wait for warehouse arrival
    if wait_for_warehouse(order["orderNo"]):
        # 4. Get shippable packages
        packages = get_shippable_packages()

        # 5. Calculate shipping
        total_weight = sum(p["weight"] for p in packages["items"])
        options = calculate_shipping("US", total_weight)
        cheapest = min(options["channels"], key=lambda c: c["totalPrice"])
        print(f"Cheapest shipping: {cheapest['name']} - {cheapest['totalPrice']} CNY")

        # 6. Create shipping order
        ship = create_shipping_order(
            items=[{"inventoryId": p["id"], "quantity": 1} for p in packages["items"]],
            channel_id=cheapest["channelId"],
            address={
                "recipientName": "John Doe",
                "recipientPhone": "+1-555-0123",
                "recipientCountry": "US",
                "recipientCity": "Los Angeles",
                "recipientAddress": "123 Main St",
                "recipientZipCode": "90001"
            }
        )
        print(f"Shipping order created: {ship['orderNo']}")