Lazada 香港賣家 2026 物流整合完整攻略：從倉儲到跨境配送

1pip install lazop-sdk==3.0.1

1pip install pytz python-dateutil

1import lazop
2
3client = lazop.LazopClient(
4    'https://api.lazada.com/rest',
5    'YOUR_APP_KEY',
6    'YOUR_APP_SECRET'
7)
8
9# 取得 access token（首次需透過授權 URL 獲取 code）
10request = lazop.LazopRequest('/auth/token/create')
11request.add_api_param('code', 'YOUR_AUTH_CODE')
12response = client.execute(request)
13
14print(response.body)  # 包含 access_token 與 refresh_token

1{
2  "access_token": "50000601b28azYm...",
3  "refresh_token": "50001601a18bxKn...",
4  "expires_in": 604800,
5  "country_user_info": [
6    {"country": "MY", "seller_id": "123456"},
7    {"country": "SG", "seller_id": "789012"}
8  ]
9}

1def refresh_lazada_token(client, refresh_token):
2    request = lazop.LazopRequest('/auth/token/refresh')
3    request.add_api_param('refresh_token', refresh_token)
4    response = client.execute(request)
5    new_token = response.body.get('access_token')
6    # 儲存到資料庫或環境變數
7    return new_token

1import lazop
2from datetime import datetime, timedelta
3
4def fetch_pending_orders(client, access_token):
5    request = lazop.LazopRequest('/orders/get', 'GET')
6    request.add_api_param('access_token', access_token)
7    request.add_api_param('status', 'pending')
8    request.add_api_param('created_after', 
9        (datetime.utcnow() - timedelta(hours=4)).isoformat())
10    request.add_api_param('sort_by', 'created_at')
11    request.add_api_param('sort_direction', 'DESC')
12    
13    response = client.execute(request)
14    return response.body.get('data', {}).get('orders', [])
15
16def route_to_logistics(order):
17    """根據目的地國家選擇物流方案"""
18    country = order.get('shipping_address', {}).get('country')
19    
20    routing_map = {
21        'MY': {'provider': 'LGS', 'warehouse': 'HK-TST-01'},
22        'SG': {'provider': 'LGS', 'warehouse': 'HK-TST-01'},
23        'TH': {'provider': '4PX', 'warehouse': 'HK-KT-02'},
24        'PH': {'provider': 'YANWEN', 'warehouse': 'HK-KT-02'},
25        'ID': {'provider': '4PX', 'warehouse': 'SZ-BONDED-01'},
26        'VN': {'provider': 'SF_INTL', 'warehouse': 'HK-TST-01'},
27    }
28    
29    return routing_map.get(country, {'provider': 'LGS', 'warehouse': 'HK-TST-01'})

1from flask import Flask, request, jsonify
2import hmac
3import hashlib
4
5app = Flask(__name__)
6
7@app.route('/lazada/logistics-webhook', methods=['POST'])
8def handle_logistics_update():
9    payload = request.json
10    signature = request.headers.get('X-Lazada-Signature')
11    
12    # 驗證簽名
13    expected_sig = hmac.new(
14        b'YOUR_APP_SECRET',
15        request.data,
16        hashlib.sha256
17    ).hexdigest()
18    
19    if signature != expected_sig:
20        return jsonify({'error': 'Invalid signature'}), 403
21    
22    order_id = payload.get('order_id')
23    tracking_status = payload.get('tracking_status')
24    timestamp = payload.get('updated_at')
25    
26    # 寫入資料庫
27    update_order_tracking(order_id, tracking_status, timestamp)
28    
29    # 如果是異常狀態，觸發告警
30    if tracking_status in ['delivery_failed', 'returned', 'lost']:
31        send_alert_to_ops_team(order_id, tracking_status)
32    
33    return jsonify({'status': 'ok'}), 200

1import openai
2
3def standardize_address(raw_address, country_code):
4    """使用 LLM 標準化東南亞地址格式"""
5    client = openai.OpenAI(api_key='YOUR_API_KEY')
6    
7    prompt = f"""Standardize this {country_code} shipping address into 
8    structured format with: street, barangay/district, city, province, 
9    postal_code. Fix obvious typos. Return JSON only.
10    
11    Raw address: {raw_address}"""
12    
13    response = client.chat.completions.create(
14        model='gpt-4o',
15        messages=[{'role': 'user', 'content': prompt}],
16        response_format={'type': 'json_object'},
17        temperature=0.1
18    )
19    
20    return response.choices[0].message.content

1def sync_inventory_to_lazada(client, access_token, sku, warehouse_stocks):
2    """
3    將多倉庫存彙總後同步到 Lazada
4    warehouse_stocks: {'HK-TST-01': 150, 'SZ-BONDED-01': 300}
5    """
6    total_available = sum(warehouse_stocks.values())
7    
8    # 預留安全庫存 10%
9    sellable_qty = int(total_available * 0.9)
10    
11    request = lazop.LazopRequest('/product/stock/sellable/update')
12    request.add_api_param('access_token', access_token)
13    request.add_api_param('payload', json.dumps([
14        {
15            'sku_id': sku,
16            'sellable_quantity': sellable_qty,
17            'fulfillment_by': 'seller'
18        }
19    ]))
20    
21    response = client.execute(request)
22    
23    if response.body.get('code') != '0':
24        raise Exception(f"庫存同步失敗: {response.body.get('message')}")
25    
26    return sellable_qty

1import time
2import random
3
4def api_call_with_retry(func, max_retries=3, *args, **kwargs):
5    for attempt in range(max_retries):
6        try:
7            return func(*args, **kwargs)
8        except Exception as e:
9            if attempt == max_retries - 1:
10                raise
11            wait_time = (2 ** attempt) + random.uniform(0, 1)
12            print(f"重試第 {attempt + 1} 次，等待 {wait_time:.1f} 秒")
13            time.sleep(wait_time)