微店关键词搜索 API 实战：分销佣金筛选 + 到手价核算 + 令牌自动续期（Python 合规版）

import requests
import hmac
import hashlib
import time
import json
from requests.adapters import HTTPAdapter
from urllib3.util.retry import Retry

class WeidianSearch:
    def __init__(self, appkey, appsecret):
        self.appkey = appkey
        self.appsecret = appsecret
        self.api_gate = "https://api.weidian.com/router"
        self.token_url = "https://api.weidian.com/oauth/token"
        self.access_token = ""
        self.refresh_token = ""
        self.token_expire = 0
        # 请求重试配置
        self.session = requests.Session()
        retry_cfg = Retry(total=3, backoff_factor=0.3, status_forcelist=[429,500,502])
        self.session.mount("https://", HTTPAdapter(max_retries=retry_cfg))

    def get_sign(self, params):
        """HMAC-SHA256微店标准签名"""
        sorted_kv = sorted(params.items(), key=lambda x:x[0])
        sign_str = "&".join([f"{k}={v}" for k,v in sorted_kv])
        sign = hmac.new(self.appsecret.encode(), sign_str.encode(), hashlib.sha256).hexdigest().upper()
        return sign

    def refresh_access_token(self):
        """令牌自动续期，过期自动刷新"""
        if int(time.time()) < self.token_expire - 3600:
            return True
        req_data = {"grant_type":"refresh_token","appkey":self.appkey,"refresh_token":self.refresh_token}
        res = self.session.post(self.token_url, data=req_data, timeout=8).json()
        if res.get("code")==0:
            self.access_token = res["data"]["access_token"]
            self.refresh_token = res["data"]["refresh_token"]
            self.token_expire = int(time.time()) + int(res["data"]["expires_in"])
            return True
        return False

    def calc_score(self, sale7, comm_rate):
        """分销潜力打分：销量60%+佣金40%"""
        s_score = min(sale7/300*60,60)
        c_score = min(comm_rate*4,40)
        return round(s_score+c_score,2)

    def search_item(self, keyword, page=1, page_size=20, min_price=None,max_price=None,min_comm=0,is_group=0):
        self.refresh_access_token()
        biz_param = {"keyword":keyword,"page":page,"page_size":page_size}
        # 空参数不传入，精简报文
        if min_price:biz_param["price_min"]=min_price
        if max_price:biz_param["price_max"]=max_price
        if min_comm>0:biz_param["commission_min"]=min_comm
        if is_group==1:biz_param["is_group"]=1

        pub_params = {
            "method":"weidian.item.search","appkey":self.appkey,"access_token":self.access_token,
            "timestamp":str(int(time.time()*1000)),"version":"1.0","format":"json",
            "param_json":json.dumps(biz_param,ensure_ascii=False)
        }
        pub_params["sign"] = self.get_sign(pub_params)
        try:
            resp = self.session.post(self.api_gate,data=pub_params,timeout=10)
            ret = resp.json()
            if ret.get("code")!=0:
                return {"code":-1,"msg":ret.get("msg","接口异常")}
            data = ret["data"]
            goods_list = data.get("item_list",[])
            res_data = []
            for item in goods_list:
                comm = float(item.get("commission_rate",0))
                sale = int(item.get("sale_7d",0))
                res_data.append({
                    "item_id":item["item_id"],"title":item["title"],"ori_price":item["market_price"],
                    "sell_price":item["sell_price"],"real_price":item["coupon_price"],
                    "commission_rate":comm,"seven_sale":sale,"is_group":item.get("is_group",0),
                    "shop_name":item["shop_name"],"score":self.calc_score(sale,comm)
                })
            time.sleep(0.6)
            return {"code":200,"total":data["total"],"data":res_data}
        except Exception as e:
            return {"code":-2,"msg":str(e)}

# 调用示例
if __name__ == "__main__":
    ak = "替换你的AppKey"
    as_sec = "替换你的AppSecret"
    api = WeidianSearch(ak,as_sec)
    # 筛选：护肤、29-199元、佣金≥8%、拼团商品
    print(json.dumps(api.search_item("护肤",min_price=29,max_price=199,min_comm=8,is_group=1),ensure_ascii=False,indent=2))