京东商品实时监控选品实战：用 Open Claw API 快速搭建自动化工具

import requests
import hashlib
import time

# ===================== 配置信息（请替换为自己的） =====================
APP_KEY = "你的AppKey"
APP_SECRET = "你的AppSecret"
# 接口网关地址（从控制台获取）
API_URL = "https://open.claw.xxx/api"
# 目标京东商品ID
JD_ITEM_ID = "1000xxxxxxx"
# =================================================================

def create_sign(params, secret):
    """生成接口签名（标准MD5加密）"""
    # 参数按key排序
    sorted_params = sorted(params.items())
    # 拼接字符串
    param_str = ""
    for k, v in sorted_params:
        param_str += f"{k}{v}"
    # 拼接密钥并MD5加密
    sign_str = secret + param_str + secret
    md5 = hashlib.md5()
    md5.update(sign_str.encode("utf-8"))
    return md5.hexdigest().upper()

def get_jd_item_info(num_iid):
    """获取京东商品详情"""
    # 构造请求参数
    params = {
        "method": "jd.item_get",
        "appkey": APP_KEY,
        "timestamp": int(time.time()),
        "num_iid": num_iid,
        "format": "json"
    }
    # 生成签名
    params["sign"] = create_sign(params, APP_SECRET)
    # 发送请求
    try:
        response = requests.get(API_URL, params=params, timeout=10)
        if response.status_code == 200:
            return response.json()
        else:
            return {"error": f"请求失败，状态码：{response.status_code}"}
    except Exception as e:
        return {"error": f"请求异常：{str(e)}"}

def monitor_jd_item(num_iid, interval=60):
    """循环监控商品（选品核心逻辑）"""
    print(f"开始监控京东商品：{num_iid}，刷新间隔：{interval}秒")
    last_price = None
    last_stock = None
    while True:
        data = get_jd_item_info(num_iid)
        if "error" not in data:
            # 解析核心字段
            item = data.get("result", {}).get("item", {})
            title = item.get("title", "未知商品")
            price = item.get("price", "0")
            org_price = item.get("orgPrice", "0")
            stock = item.get("stock", "无库存")
            sales = item.get("sales", "0")
            
            # 价格/库存变化提醒（选品预警）
            if last_price is not None and price != last_price:
                print(f"【价格变动】{title} | 原价：{last_price} → 现价：{price}")
            if last_stock is not None and stock != last_stock:
                print(f"【库存变动】{title} | 原库存：{last_stock} → 现库存：{stock}")
            
            # 打印实时数据
            print(f"\n[{time.strftime('%Y-%m-%d %H:%M:%S')}]")
            print(f"商品名称：{title}")
            print(f"当前价格：{price}  原价：{org_price}")
            print(f"库存状态：{stock}  销量：{sales}")
            
            last_price = price
            last_stock = stock
        else:
            print(f"获取数据失败：{data['error']}")
        time.sleep(interval)

# 执行监控
if __name__ == "__main__":
    monitor_jd_item(JD_ITEM_ID, interval=60)