yujian
2019-08-01 ba94d20eea2cc91a57f4ffed9f09ee0eb6352bfc
fanli/src/main/java/com/yeshi/fanli/util/jd/JDApiUtil.java
@@ -6,6 +6,7 @@
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;
@@ -41,40 +42,17 @@
   public static String SECRET_KEY = "fb49bc6ecac5458ba5394fc2969d7c56";
   private static String SERVER_URL = "https://router.jd.com/api";
   public static Long POSITION_FANLI = 1834339426L;
   public static Long POSITION_SHARE = 1834289924L;
   public static Long POSITION_COUPON = 1859510742L;
   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;// 下单时间
   public static int ORDER_TYPE_FINISHTIME = 2;// 完成时间
   public static int ORDER_TYPE_UPDATETIME = 3;// 更新时间
   private static String post(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 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<>();
@@ -115,23 +93,6 @@
      return StringUtil.Md5(SECRET_KEY + str + SECRET_KEY).toUpperCase();
   }
   private static String baseRequest(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 = post(SERVER_URL, baseMap);
      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());
@@ -147,7 +108,7 @@
      String result = post2(SERVER_URL, baseMap);
      return result;
   }
   /**
    * 转链
    * 
@@ -158,25 +119,31 @@
      json.put("materialId", materialId);
      json.put("siteId", APP_ID);
      json.put("positionId", positionId);
      if (!StringUtil.isNullOrEmpty(couponUrl))
         json.put("couponUrl", couponUrl);
      if (!StringUtil.isNullOrEmpty(ext1))
          json.put("ext1", ext1);
         json.put("ext1", ext1);
      JSONObject root = new JSONObject();
      root.put("promotionCodeReq", json);
      String result = baseRequest("jd.union.open.promotion.common.get", null, root);
      String result = baseRequest2("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");
      if (result == null) {
         return null;
      }
      resultJson = JSONObject.fromObject(result);
      return resultJson.optJSONObject("data").optString("clickURL");
   }
   /**
    * 转链接-短连接
    *
    * @param materialId
    * @param couponUrl
    * @param positionId
@@ -190,8 +157,7 @@
      }
      return url;
   }
   public static JDGoods queryGoodsDetail(Long skuId) {
      List<Long> skuIdList = new ArrayList<>();
      skuIdList.add(skuId);
@@ -207,15 +173,16 @@
      }
      return null;
   }
   /**
    * 关键词商品查询接口【申请】
    *
    * @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());
@@ -274,16 +241,15 @@
      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);
@@ -302,23 +268,20 @@
               }
            }
         }
         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();
      // 佣金信息
      Object commission = json.get("commissionInfo");
      JSONObject commissionJson = JSONObject.fromObject(commission);
@@ -331,7 +294,7 @@
      } else {
         return null;
      }
      goods.setComments(json.optLong("comments"));
      goods.setBrandCode(json.optString("brandCode"));
      goods.setBrandName(json.optString("brandName"));
@@ -342,13 +305,12 @@
      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);
@@ -356,8 +318,7 @@
      jdshopInfo.setShopId(shopInfoJson.optInt("shopId"));
      jdshopInfo.setShopName(shopInfoJson.optString("shopName"));
      goods.setShopInfo(jdshopInfo);
      // 分类信息
      Object category = json.get("categoryInfo");
      JSONObject categoryJson = JSONObject.fromObject(category);
@@ -369,8 +330,7 @@
      categoryInfo.setCid3(categoryJson.optLong("cid3"));
      categoryInfo.setCid3Name(categoryJson.optString("cid3Name"));
      goods.setCategoryInfo(categoryInfo);
      // 图片信息
      List<String> imageList = new ArrayList<String>();
      Object images = json.get("imageInfo");
@@ -380,11 +340,11 @@
         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");
@@ -402,9 +362,7 @@
            goods.setPinGouInfo(jdPinGouInfo);
         }
      }
      // 券信息
      Object coupon = json.get("couponInfo");
      if (coupon != null) {
@@ -416,13 +374,13 @@
            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) {
@@ -431,12 +389,12 @@
               } 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")));
@@ -448,19 +406,17 @@
                  couponInfo.setLink(jdcoupon.optString("link"));
               }
            }
            goods.setCouponInfo(couponInfo);
         }
      }
      return goods;
   }
   /**
    * 获取推广商品信息接口
    *
    * @param skuIdList
    * @return
    */
@@ -468,7 +424,7 @@
      List<JDGoods> list = new ArrayList<>();
      JSONObject json = new JSONObject();
      json.put("skuIds", StringUtil.concat(skuIdList, ","));
      String result = baseRequest("jd.union.open.goods.promotiongoodsinfo.query", null, json);
      String result = baseRequest2("jd.union.open.goods.promotiongoodsinfo.query", null, json);
      JSONObject resultJson = JSONObject.fromObject(result);
      resultJson = resultJson.optJSONObject("jd_union_open_goods_promotiongoodsinfo_query_response");
      if (resultJson.optInt("code") == 0) {
@@ -490,7 +446,6 @@
      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();
@@ -501,7 +456,7 @@
      } else {
         return null;
      }
      JDCategoryInfo categoryInfo = new JDCategoryInfo();
      categoryInfo.setCid1(json.optLong("cid1"));
      categoryInfo.setCid1Name(json.optString("cid1Name"));
@@ -517,7 +472,7 @@
      if (!StringUtil.isNullOrEmpty(isFreeShipping)) {
         goods.setIsFreeShipping(Integer.parseInt(isFreeShipping));
      }
      goods.setCouponInfo(null);
      goods.setGoodCommentsShare(null);
      List<String> imageList = new ArrayList<>();
@@ -540,8 +495,7 @@
      return goods;
   }
   public static JDSearchResult getJingFenGoods(int pageIndex, int eliteId) {
      JDSearchResult searchResult = new JDSearchResult();
      List<JDGoods> list = new ArrayList<>();
@@ -551,11 +505,10 @@
      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);
@@ -574,29 +527,27 @@
               }
            }
         }
         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);
@@ -615,17 +566,16 @@
               }
            }
         }
         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<>();
@@ -636,21 +586,32 @@
      return null;
   }
   public static JDOrderResult getOrder(int page, int pageSize, String time, int type) {
   /**
    * 获取订单列表
    *
    * @param page
    * @param pageSize
    * @param time
    * @param type
    *            时间类型 1-下单时间 2-完成时间 3-更新时间
    * @return
    */
   public static JDOrderResult getOrderList(int page, int pageSize, Date time, int type) {
      JSONObject json = new JSONObject();
      JSONObject orderReq = new JSONObject();
      orderReq.put("pageNo", page);
      orderReq.put("pageSize", pageSize);
      orderReq.put("type", type);
      orderReq.put("time", time);
      orderReq.put("time", TimeUtil.getGernalTime(time.getTime(), "yyyyMMddHH"));
      json.put("orderReq", orderReq);
      String result = baseRequest("jd.union.open.order.query", null, json);
      String result = baseRequest2("jd.union.open.order.query", null, json);
      JSONObject root = JSONObject.fromObject(result).optJSONObject("jd_union_open_order_query_response");
      if (root.optInt("code") == 0) {
         boolean hasMore = root.optBoolean("hasMore");
         root = JSONObject.fromObject(root.optString("result"));
         if (root.optInt("code") == 200) {
         if (root.optInt("code") == 200&&root.optJSONArray("data")!=null) {
            String date = root.optJSONArray("data").toString();
            Type typeToken = new TypeToken<List<JDOrder>>() {
            }.getType();