京东商品详情接口：增量同步场景下数据裁剪与缓存适配方案

import requests
import time
import json
import hashlib

class JdGoodsDetailClient:
    def __init__(self, app_key, app_secret):
        self.app_key = app_key
        self.app_secret = app_secret
        self.gateway = "https://api.jd.com/routerjson"
        self.session = requests.Session()

    def build_sign(self, params):
        filter_p = {k:v for k,v in params.items() if k != "sign"}
        sorted_items = sorted(filter_p.items())
        raw_str = self.app_secret + "".join(f"{k}{v}" for k,v in sorted_items) + self.app_secret
        return hashlib.md5(raw_str.encode("utf-8")).hexdigest().upper()

    def get_increment_detail(self, sku_id):
        timestamp = str(int(time.time()*1000))
        params = {
            "method":"jd.union.open.goods.detail.query",
            "app_key":self.app_key,
            "timestamp":timestamp,
            "v":"1.0",
            "format":"json",
            "360buy_param_json":json.dumps({"goodsId":sku_id})
        }
        params["sign"] = self.build_sign(params)
        try:
            resp = self.session.post(self.gateway, data=params, timeout=10)
            resp.raise_for_status()
            resp_data = resp.json()
        except requests.exceptions.RequestException as e:
            return {"success":False,"error":f"网络异常:{str(e)}"}

        if "error_response" in resp_data:
            return {"success":False,"error":resp_data["error_response"].get("zh_desc","业务错误")}
        resp_body = resp_data.get("jd_union_open_goods_detail_query_response",{}).get("result",{})
        item = resp_body.get("goodsInfo",{})
        if not item:
            return {"success":False,"error":"商品不存在或已下架"}

        # 拆分：动态变动字段（每次更新）、静态字段（可缓存）
        dynamic_part = {
            "sku_id":item.get("skuId"),
            "price":float(item.get("price",0)),
            "coupon_price":float(item.get("couponPrice",0)),
            "commission_rate":float(item.get("commissionRate",0))
        }
        static_part = {
            "title":item.get("goodsName",""),
            "shop_name":item.get("shopName",""),
            "is_jd_self":bool(item.get("isJdSelf")),
            "main_img":item.get("mainImage","")
        }
        return {"success":True,"dynamic":dynamic_part,"static":static_part}

if __name__ == "__main__":
    cli = JdGoodsDetailClient(app_key="your_key",app_secret="your_secret")
    res = cli.get_increment_detail(sku_id=100000000000)
    print(res)