From ed390c70bfbafb399fe20e8b89efc02ca5be008d Mon Sep 17 00:00:00 2001 From: yujian <yujian@123.com> Date: 星期二, 30 七月 2019 15:32:40 +0800 Subject: [PATCH] config --- fanli/src/main/java/com/yeshi/fanli/util/jd/JDApiUtil.java | 466 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 452 insertions(+), 14 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/jd/JDApiUtil.java b/fanli/src/main/java/com/yeshi/fanli/util/jd/JDApiUtil.java index b0f70d9..2740e21 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/jd/JDApiUtil.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/jd/JDApiUtil.java @@ -13,15 +13,21 @@ import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.methods.PostMethod; +import org.yeshi.utils.HttpUtil; import com.google.gson.Gson; import com.google.gson.reflect.TypeToken; import com.yeshi.fanli.dto.jd.JDCategoryInfo; import com.yeshi.fanli.dto.jd.JDCommissionInfo; +import com.yeshi.fanli.dto.jd.JDCouponInfo; +import com.yeshi.fanli.dto.jd.JDFilter; import com.yeshi.fanli.dto.jd.JDOrderResult; +import com.yeshi.fanli.dto.jd.JDPingouInfo; +import com.yeshi.fanli.dto.jd.JDSearchResult; import com.yeshi.fanli.dto.jd.JDShopInfo; import com.yeshi.fanli.entity.jd.JDGoods; import com.yeshi.fanli.entity.jd.JDOrder; +import com.yeshi.fanli.tag.PageEntity; import com.yeshi.fanli.util.MoneyBigDecimalUtil; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.TimeUtil; @@ -37,6 +43,7 @@ public static Long POSITION_FANLI = 1834339426L; public static Long POSITION_SHARE = 1834289924L; + public static Long POSITION_COUPON = 1859510742L; // 璁㈠崟鏌ヨ绫诲瀷 public static int ORDER_TYPE_CREATETIME = 1;// 涓嬪崟鏃堕棿 @@ -62,6 +69,31 @@ client.executeMethod(pm); String result = pm.getResponseBodyAsString(); return new String(result.getBytes("ISO-8859-1"), "UTF-8"); + } catch (Exception e) { + e.printStackTrace(); + } + return null; + } + + private static String post2(String url, Map<String, String> params) { + String baseUrl = url; + List<String> paramsList = new ArrayList<>(); + if (params != null) + for (Iterator<String> its = params.keySet().iterator(); its.hasNext();) { + String key = its.next(); + try { + paramsList.add(key + "=" + URLEncoder.encode(params.get(key), "UTF-8")); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } + } + baseUrl += "?" + StringUtil.concat(paramsList, "&"); + HttpClient client = new HttpClient(); + PostMethod pm = new PostMethod(baseUrl); + try { + client.executeMethod(pm); + String result = pm.getResponseBodyAsString(); + return result; } catch (Exception e) { e.printStackTrace(); } @@ -99,30 +131,339 @@ return result; } + + private static String baseRequest2(String method, String accessToken, JSONObject params) { + Map<String, String> baseMap = new HashMap<String, String>(); + baseMap.put("param_json", params.toString()); + baseMap.put("app_key", APP_KEY); + baseMap.put("method", method); + if (accessToken != null) + baseMap.put("access_token", accessToken); + baseMap.put("timestamp", TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss")); + baseMap.put("format", "json"); + baseMap.put("v", "1.0"); + baseMap.put("sign_method", "md5"); + baseMap.put("sign", getSign(baseMap)); + String result = post2(SERVER_URL, baseMap); + return result; + } + /** * 杞摼 * * @return */ - public static String convertLink(String materialId, String couponUrl, String pid) { + public static String convertLink(String materialId, String couponUrl, String positionId, String ext1) { JSONObject json = new JSONObject(); json.put("materialId", materialId); json.put("siteId", APP_ID); - if (couponUrl != null) + json.put("positionId", positionId); + + if (!StringUtil.isNullOrEmpty(couponUrl)) json.put("couponUrl", couponUrl); - // json.put("ext1", "437032_12"); - json.put("pid", pid); + + if (!StringUtil.isNullOrEmpty(ext1)) + json.put("ext1", ext1); JSONObject root = new JSONObject(); root.put("promotionCodeReq", json); - String result = baseRequest("jd.union.open.promotion.common.get", null, json); + String result = baseRequest("jd.union.open.promotion.common.get", null, root); JSONObject resultJson = JSONObject.fromObject(result); result = resultJson.optJSONObject("jd_union_open_promotion_common_get_response").optString("result"); resultJson = JSONObject.fromObject(result); return resultJson.optJSONObject("data").optString("clickURL"); } + + /** + * 杞摼鎺�-鐭繛鎺� + * @param materialId + * @param couponUrl + * @param positionId + * @param ext1 + * @return + */ + public static String convertShortLink(String materialId, String couponUrl, String positionId, String ext1) { + String url = convertLink(materialId, couponUrl, positionId, ext1); + if (!StringUtil.isNullOrEmpty(url)) { + url = HttpUtil.getShortLink(url); + } + return url; + } + + + public static JDGoods queryGoodsDetail(Long skuId) { + List<Long> skuIdList = new ArrayList<>(); + skuIdList.add(skuId); + JDFilter filter = new JDFilter(); + filter.setPageIndex(1); + filter.setPageSize(20); + filter.setListId(skuIdList); + JDSearchResult searchResult = queryByKey(filter); + if (searchResult != null) { + List<JDGoods> list = searchResult.getGoodsList(); + if (list != null && list.size() > 0) + return list.get(0); + } + return null; + } + + /** + * 鍏抽敭璇嶅晢鍝佹煡璇㈡帴鍙c�愮敵璇枫�� + * @param skuIdList + * @return + */ + public static JDSearchResult queryByKey(JDFilter filter) { + JDSearchResult searchResult = new JDSearchResult(); + + List<JDGoods> list = new ArrayList<>(); + JSONObject json = new JSONObject(); + json.put("pageIndex", filter.getPageIndex()); + json.put("pageSize", filter.getPageSize()); + if (filter.getCid1() != null) + json.put("cid1", filter.getCid1()); + + if (filter.getCid2() != null) + json.put("cid2", filter.getCid2()); + + if (filter.getCid3() != null) + json.put("cid3", filter.getCid3()); + + if (filter.getKeyword() != null) + json.put("keyword", filter.getKeyword()); + + if (filter.getPricefrom() != null) + json.put("pricefrom", filter.getPricefrom()); + + if (filter.getPriceto() != null) + json.put("priceto", filter.getPriceto()); + + if (filter.getCommissionShareStart() != null) + json.put("commissionShareStart", filter.getCommissionShareStart()); + + if (filter.getCommissionShareEnd() != null) + json.put("commissionShareEnd", filter.getCommissionShareEnd()); + + if (filter.getSortName() != null) + json.put("sortName", filter.getSortName()); + + if (filter.getSort() != null) + json.put("sort", filter.getSort()); + + if (filter.getIsCoupon() != null) + json.put("isCoupon", filter.getIsCoupon()); + + if (filter.getListId() != null) + json.put("skuIds", "[" + StringUtil.concat(filter.getListId(), ",") + "]"); + + if (filter.getIsPG() != null) + json.put("isPG", filter.getIsPG()); + + if (filter.getPingouPriceStart() != null) + json.put("pingouPriceStart", filter.getPingouPriceStart()); + + if (filter.getPingouPriceEnd() != null) + json.put("pingouPriceEnd", filter.getPingouPriceEnd()); + + if (filter.getIsHot() != null) + json.put("isHot", filter.getIsHot()); + + if (filter.getBrandCode() != null) + json.put("brandCode", filter.getBrandCode()); + + if (filter.getShopId() != null) + json.put("shopId", filter.getShopId()); + + if (filter.getOwner() != null) + json.put("owner", filter.getOwner()); + + System.out.println(json.toString()); + + JSONObject jsonDTO = new JSONObject(); + jsonDTO.put("goodsReqDTO", json); + + + String result = baseRequest2("jd.union.open.goods.query", null, jsonDTO); + System.out.println(result); + JSONObject resultJson = JSONObject.fromObject(result); + resultJson = resultJson.optJSONObject("jd_union_open_goods_query_response"); + if (resultJson.optInt("code") == 0) { + result = resultJson.optString("result"); + resultJson = JSONObject.fromObject(result); + String message = resultJson.optString("message"); + if ("SUCCESS".equalsIgnoreCase(message)) { + JSONArray array = resultJson.optJSONArray("data"); + if (array != null) { + for (int i = 0; i < array.size(); i++) { + JDGoods goods = parseJDGoods(array.optJSONObject(i)); + if (goods != null) + list.add(goods); + } + } + } + + long totalCount = resultJson.optLong("totalCount"); + PageEntity pageEntity = new PageEntity(); + pageEntity.setTotalCount(totalCount); + + searchResult.setPageEntity(pageEntity); + } + searchResult.setGoodsList(list); + return searchResult; + } + + + + + private static JDGoods parseJDGoods(JSONObject json) { + JDGoods goods = new JDGoods(); + + // 浣i噾淇℃伅 + Object commission = json.get("commissionInfo"); + JSONObject commissionJson = JSONObject.fromObject(commission); + BigDecimal commissionShare = new BigDecimal(commissionJson.optString("commissionShare")); + if (commissionShare.compareTo(new BigDecimal(0)) > 0) { + JDCommissionInfo commissionInfo = new JDCommissionInfo(); + commissionInfo.setCommission(new BigDecimal(commissionJson.optString("commission"))); + commissionInfo.setCommissionShare(commissionShare); + goods.setCommissionInfo(commissionInfo); + } else { + return null; + } + + goods.setComments(json.optLong("comments")); + goods.setBrandCode(json.optString("brandCode")); + goods.setBrandName(json.optString("brandName")); + goods.setGoodCommentsShare(new BigDecimal(json.optString("goodCommentsShare"))); + goods.setInOrderCount30Days(json.optLong("inOrderCount30Days")); + goods.setOwner(json.optString("owner")); + goods.setMaterialUrl(json.optString("materialUrl")); + goods.setSkuId(json.optLong("skuId")); + goods.setSkuName(json.optString("skuName")); + goods.setIsHot(json.optInt("isHot")); + + + // 浠锋牸淇℃伅 + Object priceInfo = json.get("priceInfo"); + JSONObject priceInfoJson = JSONObject.fromObject(priceInfo); + goods.setPrice(new BigDecimal(priceInfoJson.optString("price"))); + + // 搴楅摵淇℃伅 + Object shopInfo = json.get("shopInfo"); + JSONObject shopInfoJson = JSONObject.fromObject(shopInfo); + JDShopInfo jdshopInfo = new JDShopInfo(); + jdshopInfo.setShopId(shopInfoJson.optInt("shopId")); + jdshopInfo.setShopName(shopInfoJson.optString("shopName")); + goods.setShopInfo(jdshopInfo); + + + // 鍒嗙被淇℃伅 + Object category = json.get("categoryInfo"); + JSONObject categoryJson = JSONObject.fromObject(category); + JDCategoryInfo categoryInfo = new JDCategoryInfo(); + categoryInfo.setCid1(categoryJson.optLong("cid1")); + categoryInfo.setCid1Name(categoryJson.optString("cid1Name")); + categoryInfo.setCid2(categoryJson.optLong("cid2")); + categoryInfo.setCid2Name(categoryJson.optString("cid2Name")); + categoryInfo.setCid3(categoryJson.optLong("cid3")); + categoryInfo.setCid3Name(categoryJson.optString("cid3Name")); + goods.setCategoryInfo(categoryInfo); + + + // 鍥剧墖淇℃伅 + List<String> imageList = new ArrayList<String>(); + Object images = json.get("imageInfo"); + JSONObject imagesJson = JSONObject.fromObject(images); + JSONArray imagesArray = imagesJson.optJSONArray("imageList"); + for (int i = 0; i < imagesArray.size(); i++) { + imageList.add(imagesArray.optJSONObject(i).optString("url")); + } + goods.setImageList(imageList); + + if (imageList.size() > 0) { + goods.setPicUrl(imageList.get(0)); + } + + BigDecimal price = new BigDecimal(priceInfoJson.optString("price")); + // 鎷艰喘淇℃伅 + Object pinGouInfo = json.get("pinGouInfo"); + if (pinGouInfo != null) { + JSONObject pinGouInfoJson = JSONObject.fromObject(pinGouInfo); + if (!pinGouInfoJson.isEmpty()) { + JDPingouInfo jdPinGouInfo = new JDPingouInfo(); + price = new BigDecimal(pinGouInfoJson.optString("pingouPrice")); + jdPinGouInfo.setPingouPrice(price); + jdPinGouInfo.setPingouTmCount(pinGouInfoJson.optLong("pingouTmCount")); + jdPinGouInfo.setPingouUrl(pinGouInfoJson.optString("pingouUrl")); + jdPinGouInfo.setTotalCount(pinGouInfoJson.optLong("totalCount")); + jdPinGouInfo.setPingouEndTime(pinGouInfoJson.optLong("pingouEndTime")); + jdPinGouInfo.setPingouStartTime(pinGouInfoJson.optLong("pingouStartTime")); + goods.setPinGouInfo(jdPinGouInfo); + } + } + + + + // 鍒镐俊鎭� + Object coupon = json.get("couponInfo"); + if (coupon != null) { + JSONObject couponJson = JSONObject.fromObject(coupon); + JSONArray couponArray = couponJson.optJSONArray("couponList"); + if (couponArray != null) { + BigDecimal discount_temp = null; + JDCouponInfo couponInfo = null; + for (int i = 0; i < couponArray.size(); i++) { + boolean add = false; + JSONObject jdcoupon = couponArray.optJSONObject(i); + + BigDecimal quota = new BigDecimal(jdcoupon.optString("quota")); + BigDecimal sub = MoneyBigDecimalUtil.sub(price, quota); + if (sub.compareTo(new BigDecimal(0)) < 0) { + continue; // 鍟嗗搧浠锋牸灏忎簬浼樻儬鍒镐环鏍奸檺鍒� + } + + // 鍒搁潰棰� + BigDecimal discount = new BigDecimal(jdcoupon.optString("discount")); + if (discount_temp == null) { + add = true; + discount_temp = discount; + } else if (discount_temp.compareTo(discount) > 0) { // 鍒搁潰棰濆ぇ + add = true; + } + + if (add) { + if (couponInfo == null) { + couponInfo = new JDCouponInfo(); + } + + couponInfo.setBindType(jdcoupon.optInt("bindType")); + couponInfo.setDiscount(new BigDecimal(jdcoupon.optString("discount"))); + couponInfo.setQuota(new BigDecimal(jdcoupon.optString("quota"))); + couponInfo.setPlatformType(jdcoupon.optInt("platformType")); + couponInfo.setGetEndTime(jdcoupon.optLong("getEndTime")); + couponInfo.setGetStartTime(jdcoupon.optLong("getStartTime")); + couponInfo.setUseEndTime(jdcoupon.optLong("useEndTime")); + couponInfo.setUseStartTime(jdcoupon.optLong("useStartTime")); + couponInfo.setLink(jdcoupon.optString("link")); + } + } + + goods.setCouponInfo(couponInfo); + } + } + + + + return goods; + } + + + /** + * 鑾峰彇鎺ㄥ箍鍟嗗搧淇℃伅鎺ュ彛 + * @param skuIdList + * @return + */ public static List<JDGoods> getGoodsDetail(List<Long> skuIdList) { List<JDGoods> list = new ArrayList<>(); JSONObject json = new JSONObject(); @@ -133,7 +474,6 @@ if (resultJson.optInt("code") == 0) { result = resultJson.optString("result"); resultJson = JSONObject.fromObject(result); - System.out.println(resultJson); JSONArray array = resultJson.optJSONArray("data"); if (array != null) for (int i = 0; i < array.size(); i++) { @@ -147,7 +487,21 @@ private static JDGoods parseSimpleJDGoods(JSONObject json) { JDGoods goods = new JDGoods(); + goods.setPrice(StringUtil.isNullOrEmpty(json.optString("wlUnitPrice")) + ? new BigDecimal(json.optString("unitPrice")) : new BigDecimal(json.optString("wlUnitPrice"))); + + BigDecimal commisionRatioWl = new BigDecimal(json.optString("commisionRatioWl")); + if (commisionRatioWl.compareTo(new BigDecimal(0)) > 0) { + JDCommissionInfo commissionInfo = new JDCommissionInfo(); + commissionInfo.setCommissionShare(new BigDecimal(json.optString("commisionRatioWl"))); + commissionInfo.setCommission(MoneyBigDecimalUtil + .div(goods.getPrice().multiply(commissionInfo.getCommissionShare()), new BigDecimal(100))); + goods.setCommissionInfo(commissionInfo); + } else { + return null; + } + JDCategoryInfo categoryInfo = new JDCategoryInfo(); categoryInfo.setCid1(json.optLong("cid1")); categoryInfo.setCid1Name(json.optString("cid1Name")); @@ -158,19 +512,17 @@ goods.setCategoryInfo(categoryInfo); goods.setComments(null); - goods.setPrice(StringUtil.isNullOrEmpty(json.optString("wlUnitPrice")) - ? new BigDecimal(json.optString("unitPrice")) : new BigDecimal(json.optString("wlUnitPrice"))); - JDCommissionInfo commissionInfo = new JDCommissionInfo(); - commissionInfo.setCommissionShare(new BigDecimal(json.optString("commisionRatioWl"))); - commissionInfo.setCommission(MoneyBigDecimalUtil - .div(goods.getPrice().multiply(commissionInfo.getCommissionShare()), new BigDecimal(100))); - - goods.setCommissionInfo(commissionInfo); + String isFreeShipping = json.optString("isFreeShipping"); + if (!StringUtil.isNullOrEmpty(isFreeShipping)) { + goods.setIsFreeShipping(Integer.parseInt(isFreeShipping)); + } + goods.setCouponInfo(null); goods.setGoodCommentsShare(null); List<String> imageList = new ArrayList<>(); imageList.add(json.optString("imgUrl")); + goods.setPicUrl(json.optString("imgUrl")); goods.setImageList(imageList); goods.setInOrderCount30Days(0L); goods.setIsHot(null); @@ -188,6 +540,92 @@ return goods; } + + + public static JDSearchResult getJingFenGoods(int pageIndex, int eliteId) { + JDSearchResult searchResult = new JDSearchResult(); + List<JDGoods> list = new ArrayList<>(); + JSONObject json = new JSONObject(); + json.put("pageIndex", pageIndex); + json.put("pageSize", 20); + json.put("sortName", "inOrderCount30DaysSku"); + json.put("sort", "desc"); + json.put("eliteId", eliteId); + + JSONObject jsonDTO = new JSONObject(); + jsonDTO.put("goodsReq", json); + + + String result = baseRequest2("jd.union.open.goods.jingfen.query", null, jsonDTO); + System.out.println(result); + JSONObject resultJson = JSONObject.fromObject(result); + resultJson = resultJson.optJSONObject("jd_union_open_goods_jingfen_query_response"); + if (resultJson.optInt("code") == 0) { + result = resultJson.optString("result"); + resultJson = JSONObject.fromObject(result); + String message = resultJson.optString("message"); + if ("SUCCESS".equalsIgnoreCase(message)) { + JSONArray array = resultJson.optJSONArray("data"); + if (array != null) { + for (int i = 0; i < array.size(); i++) { + JDGoods goods = parseJDGoods(array.optJSONObject(i)); + if (goods != null) + list.add(goods); + } + } + } + + long totalCount = resultJson.optLong("totalCount"); + PageEntity pageEntity = new PageEntity(); + pageEntity.setTotalCount(totalCount); + + searchResult.setPageEntity(pageEntity); + } + searchResult.setGoodsList(list); + return searchResult; + } + + + public static JDSearchResult getGoodsClass() { + JDSearchResult searchResult = new JDSearchResult(); + List<JDGoods> list = new ArrayList<>(); + JSONObject json = new JSONObject(); + json.put("parentId", 0); + json.put("grade", 0); + + JSONObject jsonDTO = new JSONObject(); + jsonDTO.put("req", json); + + + String result = baseRequest2("jd.union.open.category.goods.get", null, jsonDTO); + System.out.println(result); + JSONObject resultJson = JSONObject.fromObject(result); + resultJson = resultJson.optJSONObject("jd_union_open_goods_jingfen_query_response"); + if (resultJson.optInt("code") == 0) { + result = resultJson.optString("result"); + resultJson = JSONObject.fromObject(result); + String message = resultJson.optString("message"); + if ("SUCCESS".equalsIgnoreCase(message)) { + JSONArray array = resultJson.optJSONArray("data"); + if (array != null) { + for (int i = 0; i < array.size(); i++) { + JDGoods goods = parseJDGoods(array.optJSONObject(i)); + if (goods != null) + list.add(goods); + } + } + } + + long totalCount = resultJson.optLong("totalCount"); + PageEntity pageEntity = new PageEntity(); + pageEntity.setTotalCount(totalCount); + + searchResult.setPageEntity(pageEntity); + } + searchResult.setGoodsList(list); + return searchResult; + } + public static JDGoods getGoodsDetail(Long skuId) { List<Long> skuIdList = new ArrayList<>(); -- Gitblit v1.8.0