京東item_search_pro是官方推出的增強版關鍵詞搜索 API，相比基礎版item_search，其核心優勢在于「字段更全、篩選維度更多、數據精度更高」（支持品牌、價格區間、服務標簽等多維度精準篩選，返回商品規格、售后保障、店鋪評分等深度數據），適用于中高階選品分析、競品監控、精細化運營等場景。本文將從「接口特性、合規接入、多語言進階代碼、高級數據解析、實戰場景落地」五大維度，提供可直接落地的技術方案。

一、item_search_pro 核心優勢與適用場景

1. 核心優勢（對比基礎版 item_search）

2. 合規接入前提

item_search_pro屬于京東開放平臺高級接口，需滿足以下條件：

已注冊京東開放平臺開發者賬號（企業 / 個人資質認證通過）；

已創建應用并申請「商品搜索增強版」接口權限（需單獨申請，基礎版權限不包含）；

核心憑證：AppKey、AppSecret（與基礎版通用，無需重新申請）；

官方文檔參考：京東開放平臺 - item_search_pro 接口（v4.0）：https://open.jd.com/doc/api.htm?apiId=45487

二、item_search_pro 接口核心配置（參數 + 簽名）

1. 公共參數（與基礎版一致）

2. 專屬高級參數（pro 版核心亮點）

關鍵說明：

brand_id獲?。赫{用京東開放平臺「品牌列表接口」（jd.union.open.category.brand.get），根據分類 ID 查詢品牌 ID；

service_tags標簽 ID 字典：可在京東開放平臺接口文檔中下載，包含京東物流、售后保障、發票服務等所有支持的標簽 ID；

spec_ids：需先通過「商品規格接口」獲取目標商品的規格 ID，再用于篩選。

3. 簽名算法（與基礎版一致，無需修改）

按參數名 ASCII 升序排列所有請求參數（含公共參數 + 業務參數）；

拼接為「key=value&key=value」格式字符串（無 URL 編碼）；

用AppSecret作為密鑰，執行 HMAC-SHA256 加密，得到大寫簽名值（sign）；

將 sign 加入請求參數，以 GET/POST 方式提交。

三、多語言進階代碼實現（item_search_pro）

以下代碼基于京東開放平臺item_search_pro（v4.0），包含高級參數配置、批量查詢、數據入庫功能，直接替換AppKey、AppSecret即可運行。

1. Python 實現（推薦，含批量搜索 + MySQL 入庫）

python

運行

import requests
import hashlib
import hmac
import time
import pymysql
from urllib.parse import urlencode
from typing import List, Dict

class JDItemSearchPro:
    def __init__(self, app_key: str, app_secret: str, db_config: Dict = None):
        self.app_key = app_key
        self.app_secret = app_secret
        self.api_url = "https://api.jd.com/routerjson"
        # 數據庫連接（可選，用于存儲數據）
        self.db = pymysql.connect(**db_config) if db_config else None
        self.cursor = self.db.cursor() if self.db else None

    # 生成簽名（核心方法）
    def generate_sign(self, params: Dict) -> str:
        sorted_params = sorted(params.items(), key=lambda x: x[0])
        sign_str = "&".join([f"{k}={v}" for k, v in sorted_params])
        hmac_obj = hmac.new(
            self.app_secret.encode("utf-8"),
            sign_str.encode("utf-8"),
            hashlib.sha256
        )
        return hmac_obj.hexdigest().upper()

    # 單關鍵詞搜索（支持高級篩選）
    def search_single_keyword(self, keyword: str, **kwargs) -> Dict:
        """
        kwargs支持的高級參數：
        page: 頁碼，default=1
        page_size: 每頁條數，default=100
        sort_type: 排序方式，default=real_sales_desc
        brand_id: 品牌ID，default=""
        price_from: 最低價格，default=0.0
        price_to: 最高價格，default=99999.0
        service_tags: 服務標簽，default=""
        is_jd_logistics: 是否京東物流，default=1
        """
        # 公共參數
        params = {
            "app_key": self.app_key,
            "method": "jd.union.open.goods.search.pro",
            "format": "json",
            "v": "4.0",
            "timestamp": time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()),
            "keyword": keyword,
            "page": str(kwargs.get("page", 1)),
            "page_size": str(kwargs.get("page_size", 100)),
            "sort_type": kwargs.get("sort_type", "real_sales_desc"),
            "brand_id": kwargs.get("brand_id", ""),
            "price_from": str(kwargs.get("price_from", 0.0)),
            "price_to": str(kwargs.get("price_to", 99999.0)),
            "service_tags": kwargs.get("service_tags", ""),
            "is_jd_logistics": str(kwargs.get("is_jd_logistics", 1))
        }
        # 生成簽名
        params["sign"] = self.generate_sign(params)
        # 發送請求
        response = requests.get(self.api_url, params=params, timeout=15)
        if response.status_code == 200:
            return response.json()
        else:
            raise Exception(f"請求失?。籂顟B碼{response.status_code}，響應：{response.text}")

    # 多關鍵詞批量搜索
    def batch_search(self, keywords: List[str], **kwargs) -> List[Dict]:
        """批量搜索多個關鍵詞，返回合并后的數據"""
        all_goods = []
        for keyword in keywords:
            print(f"正在搜索關鍵詞：{keyword}")
            for page in range(1, kwargs.get("max_page", 3) + 1):  # 最多獲取3頁
                try:
                    result = self.search_single_keyword(
                        keyword=keyword,
                        page=page,
                        page_size=kwargs.get("page_size", 100),
                        sort_type=kwargs.get("sort_type", "real_sales_desc"),
                        brand_id=kwargs.get("brand_id", ""),
                        price_from=kwargs.get("price_from", 0.0),
                        price_to=kwargs.get("price_to", 99999.0),
                        service_tags=kwargs.get("service_tags", ""),
                        is_jd_logistics=kwargs.get("is_jd_logistics", 1)
                    )
                    # 解析數據
                    goods_list = self.parse_result(result)
                    if not goods_list:
                        break  # 無更多數據，停止分頁
                    all_goods.extend(goods_list)
                    # 存入數據庫（如果配置了DB）
                    if self.db:
                        self.save_to_db(goods_list)
                    time.sleep(1)  # 避免QPS超限
                except Exception as e:
                    print(f"關鍵詞{keyword}第{page}頁搜索失?。簕str(e)}")
                    continue
        return all_goods

    # 解析返回結果（提取pro版核心字段）
    def parse_result(self, result: Dict) -> List[Dict]:
        """提取商品核心字段，適配運營需求"""
        parsed_goods = []
        data = result.get("jd_union_open_goods_search_pro_response", {}) 
            .get("result", {}) 
            .get("data", [])
        for goods in data:
            # 解析規格信息（pro版新增）
            spec_info = goods.get("specInfo", {})
            spec_details = "; ".join([f"{k}:{v}" for k, v in spec_info.items()]) if spec_info else "無"
            
            # 解析售后保障（pro版新增）
            after_sale = goods.get("afterSaleService", {})
            after_sale_details = f"7天無理由：{'是' if after_sale.get('sevenDaysNoReasonReturn') else '否'}；" 
                                f"上門換新：{'是' if after_sale.get('onSiteReplacement') else '否'}；" 
                                f"全國聯保：{'是' if after_sale.get('nationalWarranty') else '否'}"
            
            parsed_goods.append({
                "sku_id": goods.get("skuId", ""),  # 商品唯一ID
                "goods_name": goods.get("goodsName", ""),  # 商品標題
                "brand_name": goods.get("brandName", ""),  # 品牌名稱
                "brand_id": goods.get("brandId", ""),  # 品牌ID
                "current_price": goods.get("price", 0.0),  # 現價
                "original_price": goods.get("originalPrice", 0.0),  # 原價
                "real_sales_7d": goods.get("realSales7d", 0),  # 7天實時銷量（pro新增）
                "total_sales": goods.get("salesCount", 0),  # 累計銷量
                "review_count": goods.get("reviewCount", 0),  # 評價數
                "shop_name": goods.get("shopName", ""),  # 店鋪名稱
                "shop_type": goods.get("shopType", ""),  # 店鋪類型（自營/第三方）
                "shop_score": goods.get("shopScore", 0.0),  # 店鋪評分（pro新增）
                "stock": goods.get("stock", 0),  # 庫存
                "is_jd_logistics": goods.get("isJdLogistics", 0),  # 是否京東物流
                "service_tags": goods.get("serviceTags", ""),  # 服務標簽
                "spec_details": spec_details,  # 規格詳情
                "after_sale_details": after_sale_details,  # 售后詳情
                "coupon_amount": goods.get("couponInfo", {}).get("discount", 0.0),  # 優惠券金額
                "create_time": time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())  # 數據采集時間
            })
        return parsed_goods

    # 數據存入MySQL（可選）
    def save_to_db(self, goods_list: List[Dict]):
        """創建商品數據表并插入數據"""
        # 創建表SQL
        create_table_sql = """
        CREATE TABLE IF NOT EXISTS jd_goods_pro (
            id INT AUTO_INCREMENT PRIMARY KEY,
            sku_id VARCHAR(50) UNIQUE NOT NULL,
            goods_name VARCHAR(500) NOT NULL,
            brand_name VARCHAR(100),
            brand_id VARCHAR(50),
            current_price DECIMAL(10,2),
            original_price DECIMAL(10,2),
            real_sales_7d INT,
            total_sales INT,
            review_count INT,
            shop_name VARCHAR(200),
            shop_type VARCHAR(50),
            shop_score DECIMAL(3,2),
            stock INT,
            is_jd_logistics TINYINT,
            service_tags VARCHAR(200),
            spec_details VARCHAR(500),
            after_sale_details VARCHAR(500),
            coupon_amount DECIMAL(10,2),
            create_time DATETIME
        ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
        """
        self.cursor.execute(create_table_sql)
        # 插入數據SQL
        insert_sql = """
        INSERT IGNORE INTO jd_goods_pro (
            sku_id, goods_name, brand_name, brand_id, current_price, original_price,
            real_sales_7d, total_sales, review_count, shop_name, shop_type, shop_score,
            stock, is_jd_logistics, service_tags, spec_details, after_sale_details,
            coupon_amount, create_time
        ) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
        """
        # 批量插入
        values = [
            (
                g["sku_id"], g["goods_name"], g["brand_name"], g["brand_id"], g["current_price"],
                g["original_price"], g["real_sales_7d"], g["total_sales"], g["review_count"],
                g["shop_name"], g["shop_type"], g["shop_score"], g["stock"], g["is_jd_logistics"],
                g["service_tags"], g["spec_details"], g["after_sale_details"], g["coupon_amount"],
                g["create_time"]
            ) for g in goods_list
        ]
        self.cursor.executemany(insert_sql, values)
        self.db.commit()
        print(f"成功存入{len(values)}條商品數據")

# ------------------- 實戰調用示例 -------------------
if __name__ == "__main__":
    # 配置信息（替換為實際值）
    APP_KEY = "你的京東AppKey"
    APP_SECRET = "你的京東AppSecret"
    DB_CONFIG = {
        "host": "localhost",
        "user": "root",
        "password": "你的數據庫密碼",
        "database": "jd_data",
        "charset": "utf8mb4"
    }

    # 初始化實例（如需存儲數據，傳入DB_CONFIG；無需則不傳）
    jd_pro = JDItemSearchPro(APP_KEY, APP_SECRET, DB_CONFIG)

    # 1. 單關鍵詞高級搜索（篩選京東物流、100-300元、華為品牌）
    single_result = jd_pro.search_single_keyword(
        keyword="無線藍牙耳機 主動降噪",
        brand_id="1000000779",  # 華為品牌ID（示例）
        price_from=100.0,
        price_to=300.0,
        service_tags="1,3",  # 1=京東物流，3=7天無理由
        sort_type="real_sales_desc"
    )
    parsed_single = jd_pro.parse_result(single_result)
    print(f"單關鍵詞搜索結果：{len(parsed_single)}條商品")

    # 2. 多關鍵詞批量搜索（存儲到MySQL）
    keywords = ["無線藍牙耳機 主動降噪", "機械鍵盤 青軸", "充電寶 20000mAh"]
    batch_result = jd_pro.batch_search(
        keywords=keywords,
        max_page=2,  # 每個關鍵詞獲取2頁
        page_size=100,
        price_from=50.0,
        is_jd_logistics=1
    )
    print(f"批量搜索總結果：{len(batch_result)}條商品")

    # 關閉數據庫連接
    if jd_pro.db:
        jd_pro.cursor.close()
        jd_pro.db.close()

2. Java 實現（含高級篩選 + 數據解析）

java

運行

import org.apache.commons.codec.digest.HmacUtils;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.JSONArray;
import java.util.*;
import java.net.URLEncoder;

public class JDItemSearchPro {
    private static final String APP_KEY = "你的京東AppKey";
    private static final String APP_SECRET = "你的京東AppSecret";
    private static final String API_URL = "https://api.jd.com/routerjson";

    // 生成簽名
    private static String generateSign(Map params) {
        List> entryList = new ArrayList(params.entrySet());
        entryList.sort(Map.Entry.comparingByKey());
        StringBuilder signStr = new StringBuilder();
        for (Map.Entry entry : entryList) {
            signStr.append(entry.getKey()).append("=").append(entry.getValue()).append("&");
        }
        signStr.deleteCharAt(signStr.length() - 1);
        return new HmacUtils("HmacSHA256", APP_SECRET).hmacHex(signStr.toString()).toUpperCase();
    }

    // 高級搜索方法（支持多維度篩選）
    public static JSONObject searchPro(String keyword, int page, int pageSize, String brandId,
                                       double priceFrom, double priceTo, String serviceTags, int isJdLogistics) throws Exception {
        Map params = new HashMap();
        // 公共參數
        params.put("app_key", APP_KEY);
        params.put("method", "jd.union.open.goods.search.pro");
        params.put("format", "json");
        params.put("v", "4.0");
        params.put("timestamp", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        // 業務參數（高級篩選）
        params.put("keyword", keyword);
        params.put("page", String.valueOf(page));
        params.put("page_size", String.valueOf(pageSize));
        params.put("sort_type", "real_sales_desc");
        params.put("brand_id", brandId);
        params.put("price_from", String.valueOf(priceFrom));
        params.put("price_to", String.valueOf(priceTo));
        params.put("service_tags", serviceTags);
        params.put("is_jd_logistics", String.valueOf(isJdLogistics));
        // 生成簽名
        params.put("sign", generateSign(params));

        // 構建請求URL
        StringBuilder urlBuilder = new StringBuilder(API_URL).append("?");
        for (Map.Entry entry : params.entrySet()) {
            urlBuilder.append(entry.getKey())
                    .append("=")
                    .append(URLEncoder.encode(entry.getValue(), "UTF-8"))
                    .append("&");
        }
        String url = urlBuilder.deleteCharAt(urlBuilder.length() - 1).toString();

        // 發送請求
        try (CloseableHttpClient client = HttpClients.createDefault()) {
            HttpGet request = new HttpGet(url);
            return JSONObject.parseObject(EntityUtils.toString(client.execute(request).getEntity()));
        }
    }

    // 解析Pro版核心數據
    public static List> parseProResult(JSONObject result) {
        List> parsedGoods = new ArrayList();
        JSONArray data = result.getJSONObject("jd_union_open_goods_search_pro_response")
                .getJSONObject("result")
                .getJSONArray("data");

        for (Object obj : data) {
            JSONObject goods = (JSONObject) obj;
            Map goodsMap = new HashMap();

            // 基礎字段
            goodsMap.put("skuId", goods.getString("skuId"));
            goodsMap.put("goodsName", goods.getString("goodsName"));
            goodsMap.put("brandName", goods.getString("brandName"));
            goodsMap.put("currentPrice", goods.getBigDecimal("price"));
            goodsMap.put("originalPrice", goods.getBigDecimal("originalPrice"));

            // Pro版新增字段
            goodsMap.put("realSales7d", goods.getIntValue("realSales7d"));
            goodsMap.put("shopScore", goods.getBigDecimal("shopScore"));
            goodsMap.put("specDetails", goods.getJSONObject("specInfo").toString());
            goodsMap.put("afterSaleDetails", goods.getJSONObject("afterSaleService").toString());
            goodsMap.put("isJdLogistics", goods.getIntValue("isJdLogistics"));

            parsedGoods.add(goodsMap);
        }
        return parsedGoods;
    }

    // 主函數調用
    public static void main(String[] args) throws Exception {
        // 搜索：華為無線藍牙耳機（品牌ID=1000000779），100-300元，京東物流
        JSONObject result = searchPro(
                "無線藍牙耳機 主動降噪",
                1, 100,
                "1000000779",
                100.0, 300.0,
                "1,3", 1
        );

        // 解析數據
        List> goodsList = parseProResult(result);
        System.out.println("搜索結果數量：" + goodsList.size());
        for (Map goods : goodsList) {
            System.out.println("商品ID：" + goods.get("skuId"));
            System.out.println("商品名稱：" + goods.get("goodsName"));
            System.out.println("7天實時銷量：" + goods.get("realSales7d"));
            System.out.println("店鋪評分：" + goods.get("shopScore"));
            System.out.println("---------------------");
        }
    }
}

3. PHP 實現（簡潔版，含高級參數）

php

運行

appSecret));
    }

    // 高級搜索
    public function searchPro($keyword, $page = 1, $pageSize = 100, $brandId = '', $priceFrom = 0, $priceTo = 99999, $serviceTags = '', $isJdLogistics = 1) {
        $params = [
            'app_key' => $this->appKey,
            'method' => 'jd.union.open.goods.search.pro',
            'format' => 'json',
            'v' => '4.0',
            'timestamp' => date('Y-m-d H:i:s'),
            'keyword' => $keyword,
            'page' => (string)$page,
            'page_size' => (string)$pageSize,
            'sort_type' => 'real_sales_desc',
            'brand_id' => $brandId,
            'price_from' => (string)$priceFrom,
            'price_to' => (string)$priceTo,
            'service_tags' => $serviceTags,
            'is_jd_logistics' => (string)$isJdLogistics
        ];
        $params['sign'] = $this->generateSign($params);

        // 發送請求
        $url = $this->apiUrl . '?' . http_build_query($params);
        $response = file_get_contents($url);
        return json_decode($response, true);
    }

    // 解析數據
    public function parseResult($result) {
        $goodsList = $result['jd_union_open_goods_search_pro_response']['result']['data'] ?? [];
        $parsed = [];
        foreach ($goodsList as $goods) {
            $parsed[] = [
                'sku_id' => $goods['skuId'],
                'goods_name' => $goods['goodsName'],
                'brand_name' => $goods['brandName'],
                'current_price' => $goods['price'],
                'real_sales_7d' => $goods['realSales7d'],
                'shop_score' => $goods['shopScore'],
                'spec_details' => json_encode($goods['specInfo']),
                'after_sale' => json_encode($goods['afterSaleService'])
            ];
        }
        return $parsed;
    }
}

// 調用示例
$jdPro = new JDItemSearchPro();
$result = $jdPro->searchPro(
    '無線藍牙耳機 主動降噪',
    1, 100,
    '1000000779',  // 華為品牌ID
    100, 300,
    '1,3', 1
);
$parsedData = $jdPro->parseResult($result);
print_r("搜索結果：" . count($parsedData) . "條n");
print_r($parsedData[0]);
?>

四、item_search_pro 核心數據解析與運營落地

1. Pro 版新增核心字段（運營關鍵）

2. 高階運營場景落地（基于 Pro 版數據）

（1）精細化選品（精準鎖定高潛力商品）

篩選邏輯：京東物流（is_jd_logistics=1）+ 7 天實時銷量 > 500（realSales7d>500）+ 店鋪評分 > 4.8（shopScore>4.8）+ 有上門換新服務（afterSaleService.onSiteReplacement=true）+ 價格區間 100-300 元。Python 代碼示例：

python

運行

# 篩選高潛力商品
high_potential = [
    g for g in parsed_single
    if g["real_sales_7d"] > 500
    and g["shop_score"] > 4.8
    and "上門換新：是" in g["after_sale_details"]
    and 100 <= g["current_price"] <= 300
]
print(f"高潛力商品數量：{len(high_potential)}")
for goods in high_potential:
    print(f"商品：{goods['goods_name']}，7天銷量：{goods['real_sales_7d']}，店鋪評分：{goods['shop_score']}")

（2）競品服務對標分析

核心需求：分析競品的售后保障、服務標簽，優化自身店鋪服務配置。數據提取邏輯：提取同類競品的service_tags和after_sale_details，統計高頻服務標簽和售后政策。代碼示例：

python

運行

# 統計競品高頻服務標簽
service_tags_count = {}
for goods in batch_result:
    tags = goods["service_tags"].split(",")
    for tag in tags:
        if tag:
            service_tags_count[tag] = service_tags_count.get(tag, 0) + 1

# 統計售后政策分布
after_sale_count = {"7天無理由": 0, "上門換新": 0, "全國聯保": 0}
for goods in batch_result:
    if "7天無理由：是" in goods["after_sale_details"]:
        after_sale_count["7天無理由"] += 1
    if "上門換新：是" in goods["after_sale_details"]:
        after_sale_count["上門換新"] += 1
    if "全國聯保：是" in goods["after_sale_details"]:
        after_sale_count["全國聯保"] += 1

print("競品服務標簽分布：", service_tags_count)
print("競品售后政策分布：", after_sale_count)

（3）動態定價策略優化

核心邏輯：基于同類商品的價格區間、優惠券金額、規格配置，制定差異化定價。

提取同類商品價格區間：min_price = min([g["current_price"] for g in batch_result])，max_price = max([g["current_price"] for g in batch_result])；

熱門規格溢價分析：若 “8GB+256GB” 規格的商品價格比 “6GB+128GB” 高 30% 以上，可適當降低溢價，提升競爭力。

五、常見問題與解決方案（Pro 版專屬）

六、合規與風險提示

接口使用限制：item_search_pro的 QPS 限制高于基礎版，但仍需遵守平臺規定，禁止高頻惡意調用（否則會導致 AppKey 封禁）；

數據使用范圍：僅用于自身運營分析，不得轉售、泄露商品數據或店鋪信息，遵守《京東開放平臺服務協議》；

權限有效期：高級接口權限需定期審核，確保資質合規，避免權限到期導致服務中斷。

審核編輯 黃宇