admin
2021-04-30 4e4af90184f5fa5b40d87e2d08d9192bfd237ef0
fanli/src/main/java/com/yeshi/fanli/util/pinduoduo/PinDuoDuoApiUtil.java
@@ -3,14 +3,10 @@
import java.io.UnsupportedEncodingException;
import java.lang.reflect.Type;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.*;
import com.yeshi.fanli.exception.pdd.PDDApiException;
import com.yeshi.fanli.vo.pdd.PDDConvertLinkResultVO;
import org.yeshi.utils.HttpUtil;
import com.google.gson.Gson;
@@ -79,7 +75,7 @@
     * @param sf
     * @return
     */
    public static PDDGoodsResult searchGoods(PDDSearchFilter sf, String customerParamters) {
    public static PDDGoodsResult searchGoods(PDDSearchFilter sf, String customerParamters) throws PDDApiException {
        Gson gson = new GsonBuilder().disableHtmlEscaping().create();
        Map<String, String> map = new HashMap<>();
        map.put("type", "pdd.ddk.goods.search");
@@ -113,6 +109,11 @@
        String result = baseRequest(map);
        System.out.println(result);
        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"));
        }
        JSONObject root = json.optJSONObject("goods_search_response");
        if (root == null) {
            return null;
@@ -136,7 +137,12 @@
        Long[] ids = new Long[goodsIds.size()];
        goodsIds.toArray(ids);
        filter.setGoodsIdList(ids);
        PDDGoodsResult result = searchGoods(filter, Constant.PDD_SEARCH_CUSTOMER_PARAMS);
        PDDGoodsResult result = null;
        try {
            result = searchGoods(filter, Constant.PDD_SEARCH_CUSTOMER_PARAMS);
        } catch (PDDApiException e) {
            e.printStackTrace();
        }
        if (result != null)
            return result.getGoodsList();
        return null;
@@ -150,7 +156,7 @@
     * @param channelType 频道类型;0, "1.9包邮", 1, "今日爆款", 2, "品牌清仓", 非必填 ,默认是1
     * @return
     */
    public static PDDGoodsResult searchByChannelType(Integer page, Integer pageSize, String channelType) {
    public static PDDGoodsResult searchByChannelType(Integer page, Integer pageSize, String channelType, Integer[] activityTags) {
        Map<String, String> map = new HashMap<>();
        map.put("type", "pdd.ddk.goods.recommend.get");
        map.put("offset", (page == null ? 0 : page) + "");
@@ -158,6 +164,9 @@
        if (channelType != null)
            map.put("channel_type", channelType);
        if (activityTags != null) {
            map.put("activity_tags", JSONArray.fromObject(Arrays.asList(activityTags)).toString());
        }
        map.put("pid", PID_FANLI);
        String result = baseRequest(map);
@@ -269,22 +278,23 @@
    /**
     * 商品转链
     *
     * @param goodsId
     * @param goodsSign
     * @param pid
     * @param customParams
     * @return
     */
    public static PDDPromotionUrl convert(Long goodsId, String pid, String customParams, boolean withAuthLink) {
    public static PDDConvertLinkResultVO convert(String goodsSign, String pid, String customParams, boolean withAuthLink) {
        Map<String, String> map = new HashMap<>();
        map.put("type", "pdd.ddk.goods.promotion.url.generate");
        map.put("p_id", pid);
        map.put("multi_group", "true");
        map.put("generate_weapp_webview", "true");
        map.put("generate_we_app", "true");
        // map.put("generate_weiboapp_webview", "true");
        JSONArray array = new JSONArray();
        array.add(goodsId);
        map.put("goods_id_list", array.toString());
        array.add(goodsSign);
        map.put("goods_sign_list", array.toString());
        if (!StringUtil.isNullOrEmpty(customParams)) {
            map.put("custom_parameters", customParams);
        }
@@ -294,6 +304,7 @@
            map.put("generate_authority_url", true + "");
        String result = baseRequest(map);
        System.out.println(result);
        JSONObject root = JSONObject.fromObject(result);
        JSONObject json = root.optJSONObject("goods_promotion_url_generate_response");
        if (json == null) {
@@ -301,7 +312,7 @@
        }
        JSONArray resultArray = json.optJSONArray("goods_promotion_url_list");
        if (resultArray != null && resultArray.size() > 0) {
            Type type = new TypeToken<PDDPromotionUrl>() {
            Type type = new TypeToken<PDDConvertLinkResultVO>() {
            }.getType();
            Gson gson = new GsonBuilder().disableHtmlEscaping().create();
            return gson.fromJson(resultArray.optJSONObject(0).toString(), type);
@@ -357,15 +368,15 @@
    /**
     * 商品转链
     *
     * @param goodsId
     * @param goodsSign
     * @param pid
     * @param customParams
     * @return
     */
    public static String getPromotionUrl(Long goodsId, String pid, String customParams) {
        PDDPromotionUrl promotion = convert(goodsId, pid, customParams, false);
    public static String getPromotionUrl(String goodsSign, String pid, String customParams) {
        PDDConvertLinkResultVO promotion = convert(goodsSign, pid, customParams, false);
        if (promotion != null) {
            return promotion.getShortUrl();
            return promotion.getShort_url();
        }
        return null;
    }
@@ -433,15 +444,35 @@
     * @param goodsId
     */
    public static PDDGoodsDetail getGoodsDetail(Long goodsId) {
        return getGoodsDetail(goodsId, null, null);
        try {
            return getGoodsDetail(goodsId, PID_FANLI, "437032");
        } catch (PDDApiException e) {
            e.printStackTrace();
        }
        return null;
    }
    public static PDDGoodsDetail getGoodsDetail(Long goodsId, String pid, String customParameters) {
    public static PDDGoodsDetail getGoodsDetail(Long goodsId, 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();
        JSONArray array = new JSONArray();
        array.add(goodsId);
        array.add(goodsSign);
        Map<String, String> map = new HashMap<>();
        map.put("type", "pdd.ddk.goods.detail");
        map.put("goods_id_list", array.toString());
        map.put("goods_sign", goodsSign);
        if (!StringUtil.isNullOrEmpty(pid)) {
            map.put("pid", pid);
        }
@@ -564,23 +595,40 @@
    }
    public static String getAuthLink(String pid, String customParameters) {
    /**
     * 生成授权链接
     *
     * @param pid
     * @param customParameters
     * @return
     */
    public static PDDConvertLinkResultVO getAuthLink(String pid, String 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("p_id_list", "[\"" + pid + "\"]");
        String result = baseRequest(map);
        System.out.println(result);
        JSONObject resultJson = JSONObject.fromObject(result);
        JSONArray array = resultJson.optJSONObject("rp_promotion_url_generate_response").optJSONArray("url_list");
        if (array != null && array.size() > 0) {
            JSONObject item = array.optJSONObject(0);
            String url = item.optString("url");
            if (StringUtil.isNullOrEmpty(url)) {
                url = item.optString("mobile_url");
            }
            return url;
            Type type = new TypeToken<List<PDDConvertLinkResultVO>>() {
            }.getType();
            List<PDDConvertLinkResultVO> list = new Gson().fromJson(array.toString(), type);
            return list.get(0);
        }
        return null;
    }
    public static void main(String[] args) {
//        PDDConvertLinkResultVO vo = getAuthLink(PID_SHARE, PinDuoDuoUtil.getCustomParams(437032l));
//
//        System.out.println(vo);
        PDDGoodsDetail goods = PinDuoDuoApiUtil.getGoodsDetail(227873724698L);
        PinDuoDuoApiUtil.convert(goods.getGoodsSign(), PID_FANLI + "","437032", false);
    }
}