From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 25 二月 2025 16:41:22 +0800 Subject: [PATCH] 淘宝转链接口更新 --- fanli/src/main/java/com/yeshi/fanli/util/pinduoduo/PinDuoDuoApiUtil.java | 1142 +++++++++++++++++++++++++++++++++++++------------------- 1 files changed, 743 insertions(+), 399 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/pinduoduo/PinDuoDuoApiUtil.java b/fanli/src/main/java/com/yeshi/fanli/util/pinduoduo/PinDuoDuoApiUtil.java index c15b551..2a38815 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/pinduoduo/PinDuoDuoApiUtil.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/pinduoduo/PinDuoDuoApiUtil.java @@ -1,399 +1,743 @@ -package com.yeshi.fanli.util.pinduoduo; - -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 org.yeshi.utils.HttpUtil; - -import com.google.gson.Gson; -import com.google.gson.GsonBuilder; -import com.google.gson.reflect.TypeToken; -import com.yeshi.fanli.dto.pdd.PDDGoodsDetail; -import com.yeshi.fanli.dto.pdd.PDDGoodsResult; -import com.yeshi.fanli.dto.pdd.PDDOrderResult; -import com.yeshi.fanli.dto.pdd.PDDSearchFilter; -import com.yeshi.fanli.entity.pdd.PDDOrder; -import com.yeshi.fanli.util.Constant; -import com.yeshi.fanli.util.StringUtil; -import com.yeshi.fanli.util.TimeUtil; - -import net.sf.json.JSONArray; -import net.sf.json.JSONObject; - -public class PinDuoDuoApiUtil { - public final static String PID_FANLI = "8590899_72067894"; - public final static String PID_SHARE = "8590899_72067895"; - public final static String PID_COUPON = "8590899_102657575"; - - private final static String CLIENT_ID = "9f6ee5ebd3b94c2080c4d51c2427e9fa"; - private final static String CLIENT_SECRET = "95e1f1904385664bf4b87d4b34de12f9f31c505d"; - - private static String getSign(Map<String, String> map) { - List<String> keyList = new ArrayList<>(); - Iterator<String> keys = map.keySet().iterator(); - while (keys.hasNext()) { - String key = keys.next(); - keyList.add(key); - } - Collections.sort(keyList); - String org = ""; - for (String key : keyList) { - org += key + map.get(key); - } - return StringUtil.Md5(CLIENT_SECRET + org + CLIENT_SECRET).toUpperCase(); - } - - private static String baseRequest(Map<String, String> map) { - map.put("client_id", CLIENT_ID); - map.put("timestamp", System.currentTimeMillis() / 1000 + ""); - map.put("sign", getSign(map)); - Iterator<String> keys = map.keySet().iterator(); - String url = "https://gw-api.pinduoduo.com/api/router?"; - while (keys.hasNext()) { - String key = keys.next(); - try { - url += key + "=" + URLEncoder.encode(map.get(key), "UTF-8") + "&"; - } catch (UnsupportedEncodingException e) { - e.printStackTrace(); - } - } - if (url.endsWith("&")) - url = url.substring(0, url.length() - 1); - return HttpUtil.postSimple(url); - } - - /** - * 澶氬杩涘疂鍟嗗搧鏌ヨ - * - * @param sf - * @return - */ - public static PDDGoodsResult searchGoods(PDDSearchFilter sf) { - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.ddk.goods.search"); - if (sf.getOptId() != null) - map.put("opt_id", sf.getOptId() + ""); - if (sf.getPage() != null) - map.put("page", sf.getPage() + ""); - if (sf.getPageSize() != null) - map.put("page_size", sf.getPageSize() + ""); - if (sf.getSortType() != null) - map.put("sort_type", sf.getSortType() + ""); - if (sf.getHasCoupon() != null) - map.put("with_coupon", sf.getHasCoupon() + ""); - if (sf.getIsBrand() != null) - map.put("is_brand_goods", sf.getIsBrand() + ""); - if (sf.getCatId() != null) - map.put("cat_id", sf.getCatId() + ""); - if (sf.getKw() != null) - map.put("keyword", sf.getKw()); - if (sf.getGoodsIdList() != null) - map.put("goods_id_list", "[" + StringUtil.concat(sf.getGoodsIdList(), ",") + "]"); - - map.put("pid", PID_FANLI); - String result = baseRequest(map); - JSONObject json = JSONObject.fromObject(result); - JSONObject root = json.optJSONObject("goods_search_response"); - if (root == null) { - return null; - } - - JSONArray array = root.optJSONArray("goods_list"); - if (array == null) { - return null; - } - - Type type = new TypeToken<List<PDDGoodsDetail>>() { - }.getType(); - - Gson gson = new GsonBuilder().disableHtmlEscaping().create(); - List<PDDGoodsDetail> goodsList = gson.fromJson(array.toString(), type); - int totalCount = root.optInt("total_count"); - return new PDDGoodsResult(totalCount, goodsList); - } - - /** - * 杩愯惀棰戦亾鍟嗗搧鏌ヨAPI - * - * @param page - * @param pageSize - * @param channelType - * 棰戦亾绫诲瀷锛�0, "1.9鍖呴偖", 1, "浠婃棩鐖嗘", 2, "鍝佺墝娓呬粨", 闈炲繀濉� ,榛樿鏄�1 - * @return - */ - public static PDDGoodsResult searchByChannelType(Integer page, Integer pageSize, String channelType) { - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.ddk.goods.recommend.get"); - map.put("offset", (page == null ? 0 : page) + ""); - map.put("offset", (pageSize == null ? Constant.PAGE_SIZE : pageSize) + ""); - - if (channelType != null) - map.put("channel_type", channelType); - - map.put("pid", PID_FANLI); - String result = baseRequest(map); - - JSONObject json = JSONObject.fromObject(result); - JSONObject root = json.optJSONObject("goods_basic_detail_response"); - if (root == null) { - return null; - } - JSONArray array = root.optJSONArray("list"); - if (array == null) { - return null; - } - - Type type = new TypeToken<List<PDDGoodsDetail>>() { - }.getType(); - - Gson gson = new GsonBuilder().disableHtmlEscaping().create(); - List<PDDGoodsDetail> goodsList = gson.fromJson(array.toString(), type); - int totalCount = root.optInt("total"); - return new PDDGoodsResult(totalCount, goodsList); - } - - public static void getGoodsClass() { - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.goods.cats.get"); - map.put("parent_cat_id", "0"); - String result = baseRequest(map); - - JSONObject json = JSONObject.fromObject(result); - JSONObject root = json.optJSONObject("goods_cats_get_response"); - JSONArray array = root.optJSONArray("goods_cats_list"); - } - - public static void getThemes(Integer page, Integer pageSize) { - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.ddk.theme.list.get"); - map.put("page", page + ""); - map.put("page_size", pageSize + ""); - String result = baseRequest(map); - - JSONObject json = JSONObject.fromObject(result); - JSONObject root = json.optJSONObject("theme_list_get_response"); - JSONArray array = root.optJSONArray("theme_list"); - for (int i = 0; i < array.size(); i++) { - System.out.println(array.optJSONObject(i).optString("id")); - System.out.println(array.optJSONObject(i).optString("name")); - System.out.println(array.optJSONObject(i).optString("image_url")); - System.out.println(array.optJSONObject(i).optString("goods_num")); - System.out.println("-------------------------------------------"); - } - - System.out.println(root.optLong("total")); - } - - public static void getGoodsOpt() { - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.goods.opt.get"); - map.put("parent_opt_id", "0"); - String result = baseRequest(map); - - JSONObject json = JSONObject.fromObject(result); - JSONObject root = json.optJSONObject("goods_opt_get_response"); - JSONArray array = root.optJSONArray("goods_opt_list"); - } - - /** - * 澶氬瀹㈣幏鍙栫垎娆炬帓琛屽晢鍝佹帴鍙� - * - * @param pid - * 鎺ㄥ箍浣峣d (闈炲繀濉�) - * @param page - * 浠庡灏戜綅缃紑濮嬭姹傦紱榛樿鍊� 锛� 0 (闈炲繀濉�) - * @param pageSize - * 璇锋眰鏁伴噺锛涢粯璁ゅ�� 锛�20 (闈炲繀濉�) - * @param sortType - * 1-瀹炴椂鐑攢姒滐紱2-瀹炴椂鏀剁泭姒� (闈炲繀濉�) - * @return - */ - public static PDDGoodsResult getTopList(String pid, Integer page, Integer pageSize, Integer sortType) { - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.ddk.top.goods.list.query"); - map.put("offset", (page == null ? 0 : (page - 1) * Constant.PAGE_SIZE) + ""); - map.put("limit", (pageSize == null ? Constant.PAGE_SIZE : pageSize) + ""); - - if (!StringUtil.isNullOrEmpty(pid)) - map.put("p_id", pid + ""); - - if (sortType != null) - map.put("sort_type", sortType + ""); - - String result = baseRequest(map); - JSONObject json = JSONObject.fromObject(result); - JSONObject root = json.optJSONObject("top_goods_list_get_response"); - if (root == null) { - return null; - } - JSONArray array = root.optJSONArray("list"); - if (array == null) { - return null; - } - - Type type = new TypeToken<List<PDDGoodsDetail>>() { - }.getType(); - - Gson gson = new GsonBuilder().disableHtmlEscaping().create(); - List<PDDGoodsDetail> goodsList = gson.fromJson(array.toString(), type); - // int totalCount = root.optInt("total"); - int totalCount = 400; // 榛樿璁剧疆鎴�400 - return new PDDGoodsResult(totalCount, goodsList); - } - - /** - * 鍟嗗搧杞摼 - * - * @param goodsId - * @param pid - * @param customParams - * @return - */ - public static String convert(Long 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); - map.put("multi_group", "true"); - map.put("generate_weapp_webview", "true"); - // map.put("generate_weiboapp_webview", "true"); - JSONArray array = new JSONArray(); - array.add(goodsId); - map.put("goods_id_list", array.toString()); - if (!StringUtil.isNullOrEmpty(customParams)) { - map.put("custom_parameters", customParams); - } - - String result = baseRequest(map); - JSONObject root = JSONObject.fromObject(result); - JSONObject json = root.optJSONObject("goods_promotion_url_generate_response"); - if (json == null) { - return null; - } - JSONArray resultArray = json.optJSONArray("goods_promotion_url_list"); - if (resultArray != null && resultArray.size() > 0) - return resultArray.optJSONObject(0).optString("short_url"); - return null; - } - - public static void createPid() { - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.ddk.goods.pid.generate"); - map.put("number", "2"); - JSONArray array = new JSONArray(); - array.add("杩斿埄PID"); - array.add("鍒嗕韩PID"); - map.put("p_id_name_list", array.toString()); - - String result = baseRequest(map); - System.out.println(result); - } - - /** - * 鑾峰彇璁㈠崟 - * - * @param page - * -椤电爜 - * @param pageSize-姣忛〉鏁伴噺 - * @param startTime-寮�濮嬫椂闂� - * @param endTime-缁撴潫鏃堕棿 - * 涓庡紑濮嬫椂闂翠笉寰楀ぇ浜�24灏忔椂 - * @return - */ - public static PDDOrderResult getOrdersList(int page, int pageSize, long startTime, long endTime) { - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.ddk.order.list.increment.get"); - map.put("start_update_time", startTime / 1000 + ""); - map.put("end_update_time", endTime / 1000 + ""); - map.put("page", page + ""); - map.put("page_size", pageSize + ""); - String result = baseRequest(map); - JSONObject json = JSONObject.fromObject(result); - JSONObject root = json.optJSONObject("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); - return new PDDOrderResult(totalCount, orderList); - } - return null; - } - - /** - * 鑾峰彇鍟嗗搧璇︽儏 - * - * @param goodsId - */ - public static PDDGoodsDetail getGoodsDetail(Long goodsId) { - JSONArray array = new JSONArray(); - array.add(goodsId); - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.ddk.goods.detail"); - map.put("goods_id_list", array.toString()); - String result = baseRequest(map); - JSONObject resultJson = JSONObject.fromObject(result); - JSONObject root = resultJson.optJSONObject("goods_detail_response"); - if (root == null) { - return null; - } - - JSONArray resultArray = root.optJSONArray("goods_details"); - if (resultArray == null) { - return null; - } - - Type type = new TypeToken<List<PDDGoodsDetail>>() { - }.getType(); - List<PDDGoodsDetail> goodsList = new Gson().fromJson(resultArray.toString(), type); - if (goodsList != null && goodsList.size() > 0) - return goodsList.get(0); - return null; - } - - /** - * 鑾峰彇鍟嗗搧璇︽儏 - * - * @param goodsId - */ - public static String createGenerate(Long goodsId) { - JSONArray array = new JSONArray(); - array.add(goodsId); - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.ddk.phrase.generate"); - map.put("goods_id_list", array.toString()); - map.put("p_id", PID_FANLI); - String result = baseRequest(map); - JSONObject resultJson = JSONObject.fromObject(result); - System.out.println(result); - JSONObject root = resultJson.optJSONObject("ddk_phrase_generate_response"); - if (root != null) { - array = root.optJSONArray("promotion_phrase_list"); - JSONObject phraseObject = JSONObject.fromObject(array.get(0)); - return phraseObject.optString("phrase"); - } - - return null; - } - - public static Date getSystemTime() { - try { - Map<String, String> map = new HashMap<>(); - map.put("type", "pdd.time.get"); - String result = baseRequest(map); - String time = JSONObject.fromObject(result).optJSONObject("time_get_response").optString("time"); - return new Date(TimeUtil.convertToTimeTemp(time, "yyyy-MM-dd HH:mm:ss")); - } catch (Exception e) { - } - return null; - } - -} +package com.yeshi.fanli.util.pinduoduo; + +import java.io.UnsupportedEncodingException; +import java.lang.reflect.Type; +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; + +import com.google.gson.Gson; +import com.google.gson.GsonBuilder; +import com.google.gson.reflect.TypeToken; +import com.yeshi.fanli.dto.pdd.PDDGoodsDetail; +import com.yeshi.fanli.dto.pdd.PDDGoodsResult; +import com.yeshi.fanli.dto.pdd.PDDOrderResult; +import com.yeshi.fanli.dto.pdd.PDDPromotionUrl; +import com.yeshi.fanli.dto.pdd.PDDSearchFilter; +import com.yeshi.fanli.dto.pdd.PDDShopDetail; +import com.yeshi.fanli.dto.pdd.PDDShopResult; +import com.yeshi.fanli.entity.pdd.PDDOrder; +import com.yeshi.fanli.util.Constant; +import com.yeshi.fanli.util.StringUtil; +import org.yeshi.utils.TimeUtil; + +import net.sf.json.JSONArray; +import net.sf.json.JSONObject; + +public class PinDuoDuoApiUtil { +// public final static String PID_FANLI = "8590899_72067894"; +// public final static String PID_SHARE = "8590899_72067895"; +// public final static String PID_COUPON = "8590899_102657575"; + + public final static String PID_DEFAULT = "8590899_72067894"; + + private final static String CLIENT_ID = "9f6ee5ebd3b94c2080c4d51c2427e9fa"; + private final static String CLIENT_SECRET = "95e1f1904385664bf4b87d4b34de12f9f31c505d"; + + private static String getSign(Map<String, String> map) { + List<String> keyList = new ArrayList<>(); + Iterator<String> keys = map.keySet().iterator(); + while (keys.hasNext()) { + String key = keys.next(); + keyList.add(key); + } + Collections.sort(keyList); + String org = ""; + for (String key : keyList) { + org += key + map.get(key); + } + 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 + ""); + map.put("sign", getSign(map)); + Iterator<String> keys = map.keySet().iterator(); + String url = "https://gw-api.pinduoduo.com/api/router?"; + while (keys.hasNext()) { + String key = keys.next(); + try { + url += key + "=" + URLEncoder.encode(map.get(key), "UTF-8") + "&"; + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } + } + if (url.endsWith("&")) + url = url.substring(0, url.length() - 1); + return HttpUtil.postSimple(url); + } + + /** + * 澶氬杩涘疂鍟嗗搧鏌ヨ + * + * @param sf + * @return + */ + 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"); + map.put("custom_parameters", getFormatCustomParameters(customerParamters)); + if (sf.getOptId() != null) + map.put("opt_id", sf.getOptId() + ""); + if (sf.getPage() != null) + map.put("page", sf.getPage() + ""); + if (sf.getPageSize() != null) + map.put("page_size", sf.getPageSize() + ""); + if (sf.getSortType() != null) + map.put("sort_type", sf.getSortType() + ""); + if (sf.getHasCoupon() != null) + map.put("with_coupon", sf.getHasCoupon() + ""); + if (sf.getIsBrand() != null) + map.put("is_brand_goods", sf.getIsBrand() + ""); + if (sf.getCatId() != null) + map.put("cat_id", sf.getCatId() + ""); + if (sf.getKw() != null) + map.put("keyword", sf.getKw()); + if (sf.getGoodsIdList() != null) + map.put("goods_id_list", "[" + StringUtil.concat(sf.getGoodsIdList(), ",") + "]"); + if (sf.getMerchantType() != null) + map.put("merchant_type", sf.getMerchantType() + ""); + + if (sf.getRangeList() != null && sf.getRangeList().size() > 0) { + map.put("range_list", gson.toJson(sf.getRangeList()).toString()); + } + + map.put("pid", PID_DEFAULT); + 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; + } + + JSONArray array = root.optJSONArray("goods_list"); + if (array == null) { + return null; + } + + Type type = new TypeToken<List<PDDGoodsDetail>>() { + }.getType(); + + List<PDDGoodsDetail> goodsList = gson.fromJson(array.toString(), type); + int totalCount = root.optInt("total_count"); + return new PDDGoodsResult(totalCount, goodsList); + } + + public static List<PDDGoodsDetail> listGoodsDetail(List<Long> goodsIds) { + PDDSearchFilter filter = new PDDSearchFilter(); + Long[] ids = new Long[goodsIds.size()]; + goodsIds.toArray(ids); + filter.setGoodsIdList(ids); + 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; + } + + /** + * 杩愯惀棰戦亾鍟嗗搧鏌ヨAPI + * + * @param page + * @param pageSize + * @param channelType 棰戦亾绫诲瀷锛�0, "1.9鍖呴偖", 1, "浠婃棩鐖嗘", 2, "鍝佺墝娓呬粨", 闈炲繀濉� ,榛樿鏄�1 + * @return + */ + 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) + ""); + map.put("offset", (pageSize == null ? Constant.PAGE_SIZE : pageSize) + ""); + + 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_DEFAULT); + String result = baseRequest(map); + + JSONObject json = JSONObject.fromObject(result); + JSONObject root = json.optJSONObject("goods_basic_detail_response"); + if (root == null) { + return null; + } + JSONArray array = root.optJSONArray("list"); + if (array == null) { + return null; + } + + Type type = new TypeToken<List<PDDGoodsDetail>>() { + }.getType(); + + Gson gson = new GsonBuilder().disableHtmlEscaping().create(); + List<PDDGoodsDetail> goodsList = gson.fromJson(array.toString(), type); + int totalCount = root.optInt("total"); + return new PDDGoodsResult(totalCount, goodsList); + } + + public static void getGoodsClass() { + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.goods.cats.get"); + map.put("parent_cat_id", "0"); + String result = baseRequest(map); + + JSONObject json = JSONObject.fromObject(result); + JSONObject root = json.optJSONObject("goods_cats_get_response"); + JSONArray array = root.optJSONArray("goods_cats_list"); + } + + public static void getThemes(Integer page, Integer pageSize) { + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.ddk.theme.list.get"); + map.put("page", page + ""); + map.put("page_size", pageSize + ""); + String result = baseRequest(map); + + JSONObject json = JSONObject.fromObject(result); + JSONObject root = json.optJSONObject("theme_list_get_response"); + JSONArray array = root.optJSONArray("theme_list"); + for (int i = 0; i < array.size(); i++) { + System.out.println(array.optJSONObject(i).optString("id")); + System.out.println(array.optJSONObject(i).optString("name")); + System.out.println(array.optJSONObject(i).optString("image_url")); + System.out.println(array.optJSONObject(i).optString("goods_num")); + System.out.println("-------------------------------------------"); + } + + System.out.println(root.optLong("total")); + } + + public static void getGoodsOpt() { + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.goods.opt.get"); + map.put("parent_opt_id", "0"); + String result = baseRequest(map); + + JSONObject json = JSONObject.fromObject(result); + JSONObject root = json.optJSONObject("goods_opt_get_response"); + JSONArray array = root.optJSONArray("goods_opt_list"); + } + + /** + * 澶氬瀹㈣幏鍙栫垎娆炬帓琛屽晢鍝佹帴鍙� + * + * @param pid 鎺ㄥ箍浣峣d (闈炲繀濉�) + * @param page 浠庡灏戜綅缃紑濮嬭姹傦紱榛樿鍊� 锛� 0 (闈炲繀濉�) + * @param pageSize 璇锋眰鏁伴噺锛涢粯璁ゅ�� 锛�20 (闈炲繀濉�) + * @param sortType 1-瀹炴椂鐑攢姒滐紱2-瀹炴椂鏀剁泭姒� (闈炲繀濉�) + * @return + */ + public static PDDGoodsResult getTopList(String pid, Integer page, Integer pageSize, Integer sortType) { + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.ddk.top.goods.list.query"); + map.put("offset", (page == null ? 0 : (page - 1) * Constant.PAGE_SIZE) + ""); + map.put("limit", (pageSize == null ? Constant.PAGE_SIZE : pageSize) + ""); + + if (!StringUtil.isNullOrEmpty(pid)) + map.put("p_id", pid + ""); + + if (sortType != null) + map.put("sort_type", sortType + ""); + + String result = baseRequest(map); + JSONObject json = JSONObject.fromObject(result); + JSONObject root = json.optJSONObject("top_goods_list_get_response"); + if (root == null) { + return null; + } + JSONArray array = root.optJSONArray("list"); + if (array == null) { + return null; + } + + Type type = new TypeToken<List<PDDGoodsDetail>>() { + }.getType(); + + Gson gson = new GsonBuilder().disableHtmlEscaping().create(); + List<PDDGoodsDetail> goodsList = gson.fromJson(array.toString(), type); + // int totalCount = root.optInt("total"); + int totalCount = 400; // 榛樿璁剧疆鎴�400 + return new PDDGoodsResult(totalCount, goodsList); + } + + /** + * 鍟嗗搧杞摼 + * + * @param goodsSign + * @param pid + * @param customParams + * @return + */ + 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_schema_url","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(goodsSign); + map.put("goods_sign_list", array.toString()); + if (!StringUtil.isNullOrEmpty(customParams)) { + map.put("custom_parameters", getFormatCustomParameters(customParams)); + } + + //鏄惁鐢熸垚甯︽巿鏉冪殑鍗曞搧閾炬帴 + if (withAuthLink) + 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) { + return null; + } + JSONArray resultArray = json.optJSONArray("goods_promotion_url_list"); + if (resultArray != null && resultArray.size() > 0) { + Type type = new TypeToken<PDDConvertLinkResultVO>() { + }.getType(); + Gson gson = new GsonBuilder().disableHtmlEscaping().create(); + return gson.fromJson(resultArray.optJSONObject(0).toString(), type); + } + return null; + } + + + /** + * 娲诲姩杞摼 https://open.pinduoduo.com/application/document/api?id=pdd.ddk.resource.url.gen + * + * @param resourceType + * @param url + * @param pid + * @param customParams + * @return + */ + 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", getFormatCustomParameters(customParams)); + } + map.put("resource_type", resourceType); + if (url != null) { + map.put("url", url); + } + + String result = baseRequest(map); + JSONObject root = JSONObject.fromObject(result); + JSONObject json = root.optJSONObject("resource_url_response"); + if (json == null) { + return null; + } + JSONObject urlJSON = json.optJSONObject("single_url_list"); + PDDConvertLinkResultVO vo = null; + Gson gson = new GsonBuilder().disableHtmlEscaping().create(); + if (urlJSON != null) { + + vo = gson.fromJson(urlJSON.toString(), PDDConvertLinkResultVO.class); + } + JSONObject weAppInfo = json.optJSONObject("we_app_info"); + if (weAppInfo != null && vo != null) { + PDDConvertLinkResultVO.WeAppInfoBean weAppInfoBean = gson.fromJson(weAppInfo.toString(), PDDConvertLinkResultVO.WeAppInfoBean.class); + vo.setWe_app_info(weAppInfoBean); + } + + return vo; + } + + + /** + * 棰戦亾鎺ㄥ箍锛坔ttps://open.pinduoduo.com/application/document/api?id=pdd.ddk.cms.prom.url.generate锛� + * + * @param channelType + * @param pid + * @param customParams + * @return + */ + + public static PDDConvertLinkResultVO convertChannel(String channelType, String pid, String customParams) { + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.ddk.cms.prom.url.generate"); + map.put("p_id_list", "[\"" + pid + "\"]"); + if (customParams != null) { + map.put("custom_parameters", getFormatCustomParameters(customParams)); + } + map.put("channel_type", channelType); + map.put("generate_mobile", true+""); + map.put("generate_short_url", true+""); + map.put("generate_we_app", true+""); + + + + String result = baseRequest(map); + System.out.println(result); + JSONObject root = JSONObject.fromObject(result); + JSONObject json = root.optJSONObject("cms_promotion_url_generate_response"); + if (json == null) { + return null; + } + JSONObject urlJSON = json.optJSONArray("url_list").optJSONObject(0); + PDDConvertLinkResultVO vo = null; + Gson gson = new GsonBuilder().disableHtmlEscaping().create(); + if (urlJSON != null) { + vo = gson.fromJson(urlJSON.toString(), PDDConvertLinkResultVO.class); + } + + return vo; + } + + + /** + * 寰俊灏忕▼搴忚浆閾� @Title: convertWXMP @Description: @param goodsId @param + * pid @param customParams @return PDDPromotionUrl 杩斿洖绫诲瀷 @throws + */ + 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); + map.put("multi_group", "true"); + map.put("generate_we_app", "true"); + + JSONArray array = new JSONArray(); + array.add(goodsId); + map.put("goods_id_list", array.toString()); + if (!StringUtil.isNullOrEmpty(customParams)) { + map.put("custom_parameters", getFormatCustomParameters(customParams)); + } + + String result = baseRequest(map); + JSONObject root = JSONObject.fromObject(result); + JSONObject json = root.optJSONObject("goods_promotion_url_generate_response"); + if (json == null) { + return null; + } + JSONArray resultArray = json.optJSONArray("goods_promotion_url_list"); + if (resultArray != null && resultArray.size() > 0) { + JSONObject weApp = resultArray.optJSONObject(0).optJSONObject("we_app_info"); + if (weApp != null) + return weApp.optString("page_path"); + } + return null; + } + + /** + * 鍟嗗搧杞摼 + * + * @param goodsSign + * @param pid + * @param customParams + * @return + */ + public static String getPromotionUrl(String goodsSign, String pid, String customParams) { + PDDConvertLinkResultVO promotion = convert(goodsSign, pid, customParams, false); + if (promotion != null) { + return promotion.getShort_url(); + } + return null; + } + + public static void createPid() { + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.ddk.goods.pid.generate"); + map.put("number", "2"); + JSONArray array = new JSONArray(); + array.add("杩斿埄PID"); + array.add("鍒嗕韩PID"); + map.put("p_id_name_list", array.toString()); + + String result = baseRequest(map); + System.out.println(result); + } + + /** + * 鑾峰彇璁㈠崟 + * + * @param page -椤电爜 + * @param pageSize-姣忛〉鏁伴噺 + * @param startTime-寮�濮嬫椂闂� + * @param endTime-缁撴潫鏃堕棿 涓庡紑濮嬫椂闂翠笉寰楀ぇ浜�24灏忔椂 + * @return + */ + public static PDDOrderResult getOrdersList(int page, int pageSize, long startTime, long endTime) { + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.ddk.order.list.increment.get"); + map.put("start_update_time", startTime / 1000 + ""); + map.put("end_update_time", endTime / 1000 + ""); + map.put("page", page + ""); + map.put("page_size", pageSize + ""); + String result = baseRequest(map); + System.out.println(result); + 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.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; + } + + public static PDDOrder getOrderDetail(String orderSn) { + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.ddk.order.detail.get"); + map.put("order_sn", orderSn); + String result = baseRequest(map); + com.alibaba.fastjson.JSONObject json = com.alibaba.fastjson.JSONObject.parseObject(result); + com.alibaba.fastjson.JSONObject root = json.getJSONObject("order_detail_response"); + if (root != null) { + 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; + } + + /** + * 鑾峰彇鍟嗗搧璇︽儏 + * + * @param goodsSign + */ + public static PDDGoodsDetail getGoodsDetail(String goodsSign) { + try { + return getGoodsDetail(goodsSign, PID_DEFAULT, "437031"); + } catch (PDDApiException e) { + e.printStackTrace(); + } + + return null; + } + + public static PDDGoodsDetail getGoodsDetail(String goodsSign, String pid, String customParameters) throws PDDApiException { + +// String goodsSign = goodsResult.getGoodsList().get(0).getGoodsSign(); + + + JSONArray array = new JSONArray(); + array.add(goodsSign); + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.ddk.goods.detail"); + map.put("goods_sign", goodsSign); + if (!StringUtil.isNullOrEmpty(pid)) { + map.put("pid", pid); + } + + if (!StringUtil.isNullOrEmpty(customParameters)) { + map.put("custom_parameters", getFormatCustomParameters(customParameters)); + } + + String result = baseRequest(map); + System.out.println(result); + JSONObject resultJson = JSONObject.fromObject(result); + JSONObject root = resultJson.optJSONObject("goods_detail_response"); + if (root == null) { + return null; + } + + JSONArray resultArray = root.optJSONArray("goods_details"); + if (resultArray == null) { + return null; + } + + Type type = new TypeToken<List<PDDGoodsDetail>>() { + }.getType(); + List<PDDGoodsDetail> goodsList = new Gson().fromJson(resultArray.toString(), type); + if (goodsList != null && goodsList.size() > 0) + return goodsList.get(0); + return null; + } + + /** + * 鑾峰彇鍟嗗搧璇︽儏 + * + * @param goodsId + */ + public static String createGenerate(Long goodsId) { + JSONArray array = new JSONArray(); + array.add(goodsId); + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.ddk.phrase.generate"); + map.put("goods_id_list", array.toString()); + map.put("p_id", PID_DEFAULT); + String result = baseRequest(map); + JSONObject resultJson = JSONObject.fromObject(result); + JSONObject root = resultJson.optJSONObject("ddk_phrase_generate_response"); + if (root != null) { + array = root.optJSONArray("promotion_phrase_list"); + JSONObject phraseObject = JSONObject.fromObject(array.get(0)); + return phraseObject.optString("phrase"); + } + + return null; + } + + public static Date getSystemTime() { + try { + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.time.get"); + String result = baseRequest(map); + String time = JSONObject.fromObject(result).optJSONObject("time_get_response").optString("time"); + return new Date(TimeUtil.convertToTimeTemp(time, "yyyy-MM-dd HH:mm:ss")); + } catch (Exception e) { + } + return null; + } + + /** + * @param page + * @param catId + * @return + */ + public static PDDShopResult getShopList(Integer page, Long catId) { + JSONArray arrayType = new JSONArray(); + arrayType.add(3); + + Map<String, String> map = new HashMap<>(); + map.put("type", "pdd.ddk.merchant.list.get"); + if (catId != null) + map.put("cat_id", catId + ""); + if (page != null) + map.put("page_number", page + ""); + + if (page != null) + map.put("page_number", page + ""); + + map.put("merchant_type_list", arrayType.toString()); + + String result = baseRequest(map); + JSONObject resultJson = JSONObject.fromObject(result); + JSONObject root = resultJson.optJSONObject("merchant_list_response"); + if (root != null) { + int totalCount = root.optInt("total"); + + JSONArray array = root.optJSONArray("mall_search_info_vo_list"); + Type type = new TypeToken<List<PDDShopDetail>>() { + }.getType(); + List<PDDShopDetail> listShop = new Gson().fromJson(array.toString(), type); + return new PDDShopResult(totalCount, listShop); + } + return null; + } + + /** + * 鏄惁鎺堟潈 + * + * @param pid + * @param customParameters + * @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", getFormatCustomParameters(customParameters)); + String result = baseRequest(map); + JSONObject resultJson = JSONObject.fromObject(result); + if (resultJson.optJSONObject("authority_query_response").optInt("bind") == 0) { + return false; + } else + return true; + } + + + /** + * 鐢熸垚鎺堟潈閾炬帴 + * + * @param pid + * @param customParameters + * @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",getFormatCustomParameters(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) { + 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) throws Exception{ + +// PDDConvertLinkResultVO vo = getAuthLink("8590899_72067894", 437031+""); +// boolean isAuthed = isAuth(PID_DEFAULT, 437031+""); +// System.out.println("鏄惁鎺堟潈锛�"+isAuthed); +// +// 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); + + // System.out.println(vo); +// PDDConvertLinkResultVO goodsc = PinDuoDuoApiUtil.convert(goods.getGoodsSign(), PID_DEFAULT + "", "437031", false); + +// System.out.println(""); + } +} -- Gitblit v1.8.0