admin
2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe
fanli/src/main/java/com/yeshi/fanli/util/pinduoduo/PinDuoDuoApiUtil.java
@@ -5,6 +5,7 @@
import java.net.URLEncoder;
import java.util.*;
import com.google.gson.JsonObject;
import com.yeshi.fanli.exception.pdd.PDDApiException;
import com.yeshi.fanli.vo.pdd.PDDConvertLinkResultVO;
import org.yeshi.utils.HttpUtil;
@@ -52,6 +53,15 @@
        return StringUtil.Md5(CLIENT_SECRET + org + CLIENT_SECRET).toUpperCase();
    }
    private static String getFormatCustomParameters(String customParameters){
        customParameters=customParameters.replace("_","");
        JSONObject data=new JSONObject();
        data.put("uid",customParameters);
        String custom = data.toString();
        System.out.println("自定义参数:"+custom);
        return custom;
    }
    private static String baseRequest(Map<String, String> map) {
        map.put("client_id", CLIENT_ID);
        map.put("timestamp", System.currentTimeMillis() / 1000 + "");
@@ -81,7 +91,7 @@
        Gson gson = new GsonBuilder().disableHtmlEscaping().create();
        Map<String, String> map = new HashMap<>();
        map.put("type", "pdd.ddk.goods.search");
        map.put("custom_parameters", customerParamters);
        map.put("custom_parameters", getFormatCustomParameters(customerParamters));
        if (sf.getOptId() != null)
            map.put("opt_id", sf.getOptId() + "");
        if (sf.getPage() != null)
@@ -113,7 +123,7 @@
        JSONObject json = JSONObject.fromObject(result);
        if (json.optJSONObject("error_response") != null) {
            int errorCode = json.optJSONObject("error_response").optInt("sub_code");
            throw new PDDApiException(errorCode, json.optJSONObject("error_response").optString("sub_msg"));
             throw new PDDApiException(errorCode, json.optJSONObject("error_response").optString("sub_msg"));
        }
        JSONObject root = json.optJSONObject("goods_search_response");
@@ -290,6 +300,7 @@
        map.put("type", "pdd.ddk.goods.promotion.url.generate");
        map.put("p_id", pid);
        map.put("multi_group", "true");
        map.put("generate_schema_url","true");
        map.put("generate_weapp_webview", "true");
        map.put("generate_we_app", "true");
@@ -298,7 +309,7 @@
        array.add(goodsSign);
        map.put("goods_sign_list", array.toString());
        if (!StringUtil.isNullOrEmpty(customParams)) {
            map.put("custom_parameters", customParams);
            map.put("custom_parameters", getFormatCustomParameters(customParams));
        }
        //是否生成带授权的单品链接
@@ -335,9 +346,10 @@
    public static PDDConvertLinkResultVO convertActivity(String resourceType, String url, String pid, String customParams) {
        Map<String, String> map = new HashMap<>();
        map.put("type", "pdd.ddk.resource.url.gen");
        map.put("generate_schema_url","true");
        map.put("pid", pid);
        if (customParams != null) {
            map.put("custom_parameters", customParams);
            map.put("custom_parameters", getFormatCustomParameters(customParams));
        }
        map.put("resource_type", resourceType);
        if (url != null) {
@@ -381,7 +393,7 @@
        map.put("type", "pdd.ddk.cms.prom.url.generate");
        map.put("p_id_list", "[\"" + pid + "\"]");
        if (customParams != null) {
            map.put("custom_parameters", customParams);
            map.put("custom_parameters", getFormatCustomParameters(customParams));
        }
        map.put("channel_type", channelType);
        map.put("generate_mobile", true+"");
@@ -412,7 +424,7 @@
     * 微信小程序转链 @Title: convertWXMP @Description: @param goodsId @param
     * pid @param customParams @return PDDPromotionUrl 返回类型 @throws
     */
    public static String convertWXMP(Long goodsId, String pid, String customParams) {
    public static String convertWXMP(String goodsId, String pid, String customParams) {
        Map<String, String> map = new HashMap<>();
        map.put("type", "pdd.ddk.goods.promotion.url.generate");
        map.put("p_id", pid);
@@ -423,7 +435,7 @@
        array.add(goodsId);
        map.put("goods_id_list", array.toString());
        if (!StringUtil.isNullOrEmpty(customParams)) {
            map.put("custom_parameters", customParams);
            map.put("custom_parameters", getFormatCustomParameters(customParams));
        }
        String result = baseRequest(map);
@@ -488,14 +500,21 @@
        map.put("page_size", pageSize + "");
        String result = baseRequest(map);
        System.out.println(result);
        JSONObject json = JSONObject.fromObject(result);
        JSONObject root = json.optJSONObject("order_list_get_response");
        com.alibaba.fastjson.JSONObject json = com.alibaba.fastjson.JSONObject.parseObject(result);
        com.alibaba.fastjson.JSONObject root = json.getJSONObject("order_list_get_response");
        if (root != null) {
            int totalCount = root.optInt("total_count");
            JSONArray array = root.optJSONArray("order_list");
            Type type = new TypeToken<List<PDDOrder>>() {
            }.getType();
            List<PDDOrder> orderList = new Gson().fromJson(array.toString(), type);
            int totalCount = root.getInteger("total_count");
            com.alibaba.fastjson.JSONArray array = root.getJSONArray("order_list");
            Type type=new TypeToken<List<PDDOrder>>(){}.getType();
            List<PDDOrder> orderList = new Gson().fromJson( array.toJSONString(), type);
            // 处理custom_params
            for(PDDOrder order:orderList){
                String params=order.getCustomParameters();
                if(params.contains("{")) {
                    JSONObject jsonp = JSONObject.fromObject(params);
                    order.setCustomParameters(jsonp.optString("uid"));
                }
            }
            return new PDDOrderResult(totalCount, orderList);
        }
        return null;
@@ -506,10 +525,16 @@
        map.put("type", "pdd.ddk.order.detail.get");
        map.put("order_sn", orderSn);
        String result = baseRequest(map);
        JSONObject json = JSONObject.fromObject(result);
        JSONObject root = json.optJSONObject("order_detail_response");
        com.alibaba.fastjson.JSONObject json = com.alibaba.fastjson.JSONObject.parseObject(result);
        com.alibaba.fastjson.JSONObject root = json.getJSONObject("order_detail_response");
        if (root != null) {
            return new Gson().fromJson(root.toString(), PDDOrder.class);
            PDDOrder order = new Gson().fromJson(root.toString(), PDDOrder.class);
            String params=order.getCustomParameters();
            if(params.contains("{")) {
                JSONObject jsonp = JSONObject.fromObject(params);
                order.setCustomParameters(jsonp.optString("uid"));
            }
            return order;
        }
        return null;
    }
@@ -517,11 +542,11 @@
    /**
     * 获取商品详情
     *
     * @param goodsId
     * @param goodsSign
     */
    public static PDDGoodsDetail getGoodsDetail(Long goodsId) {
    public static PDDGoodsDetail getGoodsDetail(String goodsSign) {
        try {
            return getGoodsDetail(goodsId, PID_DEFAULT, "437032");
            return getGoodsDetail(goodsSign, PID_DEFAULT, "437031");
        } catch (PDDApiException e) {
            e.printStackTrace();
        }
@@ -529,19 +554,9 @@
        return null;
    }
    public static PDDGoodsDetail getGoodsDetail(Long goodsId, String pid, String customParameters) throws PDDApiException {
    public static PDDGoodsDetail getGoodsDetail(String goodsSign, String pid, String customParameters) throws PDDApiException {
        PDDSearchFilter sf = new PDDSearchFilter();
        sf.setKw(goodsId + "");
        PDDGoodsResult goodsResult = searchGoods(sf, customParameters);
        if (goodsResult == null)
            return null;
        if (goodsResult.getGoodsList() == null || goodsResult.getGoodsList().size() <= 0) {
            return null;
        }
        String goodsSign = goodsResult.getGoodsList().get(0).getGoodsSign();
//        String goodsSign = goodsResult.getGoodsList().get(0).getGoodsSign();
        JSONArray array = new JSONArray();
@@ -554,7 +569,7 @@
        }
        if (!StringUtil.isNullOrEmpty(customParameters)) {
            map.put("custom_parameters", customParameters);
            map.put("custom_parameters", getFormatCustomParameters(customParameters));
        }
        String result = baseRequest(map);
@@ -658,10 +673,13 @@
     * @return
     */
    public static boolean isAuth(String pid, String customParameters) {
//        customParameters=customParameters.replace("_","");
        System.out.println("是否授权:"+pid+"-"+customParameters);
        Map<String, String> map = new HashMap<>();
        map.put("type", "pdd.ddk.member.authority.query");
        map.put("pid", pid);
        map.put("custom_parameters", customParameters);
        map.put("custom_parameters", getFormatCustomParameters(customParameters));
        String result = baseRequest(map);
        JSONObject resultJson = JSONObject.fromObject(result);
        if (resultJson.optJSONObject("authority_query_response").optInt("bind") == 0) {
@@ -679,11 +697,14 @@
     * @return
     */
    public static PDDConvertLinkResultVO getAuthLink(String pid, String customParameters) {
//        customParameters=customParameters.replace("_","");
        System.out.println("获取授权链接:"+pid+"-"+customParameters);
        Map<String, String> map = new HashMap<>();
        map.put("type", "pdd.ddk.rp.prom.url.generate");
        map.put("channel_type", 10 + "");
        map.put("generate_we_app", true + "");
        map.put("custom_parameters", customParameters);
        map.put("custom_parameters",getFormatCustomParameters(customParameters));
        map.put("p_id_list", "[\"" + pid + "\"]");
        String result = baseRequest(map);
        System.out.println(result);
@@ -698,15 +719,25 @@
        return null;
    }
    public static void main(String[] args) {
//        PDDConvertLinkResultVO vo = getAuthLink(PID_SHARE, PinDuoDuoUtil.getCustomParams(437032l));
    public static void main(String[] args) throws Exception{
//       PDDConvertLinkResultVO vo = getAuthLink("8590899_72067894", 437031+"");
//       boolean isAuthed = isAuth(PID_DEFAULT, 437031+"");
//       System.out.println("是否授权:"+isAuthed);
//
//        System.out.println(vo);
//        PDDGoodsDetail goods = PinDuoDuoApiUtil.getGoodsDetail(227873724698L);
//       System.out.println(vo);
        PDDSearchFilter searchFilter=new PDDSearchFilter();
        searchFilter.setKw("鞋");
        searchFilter.setPage(1);
        searchFilter.setPageSize(20);
        PinDuoDuoApiUtil.searchGoods(searchFilter,Constant.PDD_SEARCH_CUSTOMER_PARAMS);
//       PDDGoodsDetail goods = PinDuoDuoApiUtil.getGoodsDetail(364476396740L);
        PDDConvertLinkResultVO vo = convertChannel("0", PID_DEFAULT, null);
    //    PDDConvertLinkResultVO vo = convertChannel("0", PID_DEFAULT, null);
        System.out.println(vo);
//        PinDuoDuoApiUtil.convert(goods.getGoodsSign(), PID_DEFAULT + "", "437032", false);
     //   System.out.println(vo);
//        PDDConvertLinkResultVO goodsc =  PinDuoDuoApiUtil.convert(goods.getGoodsSign(), PID_DEFAULT + "", "437031", false);
//        System.out.println("");
    }
}