京东开放平台关键词搜索商品列表接口实战：类目过滤 + 参数精简 + SHA256 签名落地

import requests
import time
import hashlib
import json

class JDKeywordSearchAPI:
    """京东关键词搜索商品列表 生产级封装"""
    def __init__(self, app_key, app_secret):
        self.app_key = app_key
        self.app_secret = app_secret
        self.api_url = "https://api.jd.com/routerjson"
        self.timeout = 12
        self.qps_limit = 5

    def make_sha256_sign(self, params):
        """京东标准SHA256签名（严格按ASCII排序）"""
        sorted_items = sorted(params.items())
        sign_str = self.app_secret + "".join(f"{k}{v}" for k, v in sorted_items) + self.app_secret
        return hashlib.sha256(sign_str.encode("utf-8")).hexdigest().upper()

    def search_goods(self, keyword, page=1, page_size=20, cid=None):
        """
        关键词搜索京东商品
        :param keyword: 搜索关键词
        :param page: 页码
        :param page_size: 每页数量
        :param cid: 类目ID，用于精准过滤
        :return: 结构化商品列表
        """
        timestamp = str(int(time.time() * 1000))
        param_json = {"keyword": keyword, "pageIndex": page, "pageSize": page_size}
        if cid:
            param_json["cid"] = cid

        params = {
            "app_key": self.app_key,
            "timestamp": timestamp,
            "v": "1.0",
            "method": "jd.union.open.goods.jingfen.search",
            "param_json": json.dumps(param_json),
            "format": "json"
        }
        params["sign"] = self.make_sha256_sign(params)

        try:
            resp = requests.post(self.api_url, data=params, timeout=self.timeout)
            res = resp.json()
            if res.get("error_response"):
                return {"code":-1,"msg":res["error_response"].get("zh_desc","接口调用失败")}

            data = res.get("jd_union_open_goods_jingfen_search_response",{}).get("result",{})
            goods_list = data.get("goodsInfoList",[])
            final_list = []
            for goods in goods_list:
                final_list.append({
                    "goods_id":goods.get("goodsId"),
                    "title":goods.get("goodsName"),
                    "price":goods.get("price"),
                    "shop_name":goods.get("shopName"),
                    "main_img":goods.get("imgUrl"),
                    "commission_rate":goods.get("commissionShare"),
                    "category_name":goods.get("categoryName")
                })
            time.sleep(1/self.qps_limit)
            return {"code":200,"msg":"搜索成功","total":data.get("totalNum",0),"goods_list":final_list}
        except Exception as e:
            return {"code":500,"msg":f"请求异常：{str(e)}"}

if __name__ == "__main__":
    api = JDKeywordSearchAPI("your_app_key","your_app_secret")
    result = api.search_goods("海豹油", page=1, page_size=20, cid=1316)
    print(json.dumps(result,ensure_ascii=False,indent=2))