From 573c491b4a1ba60e12a5678a01c1546c0077c1ee Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 30 七月 2019 09:07:42 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- fanli/src/main/java/com/yeshi/fanli/util/dataoke/DaTaoKeApiUtil.java | 159 ++++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 144 insertions(+), 15 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/dataoke/DaTaoKeApiUtil.java b/fanli/src/main/java/com/yeshi/fanli/util/dataoke/DaTaoKeApiUtil.java index 81e4d59..12a6081 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/dataoke/DaTaoKeApiUtil.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/dataoke/DaTaoKeApiUtil.java @@ -12,6 +12,9 @@ import java.util.Set; import java.util.TreeMap; +import org.apache.commons.httpclient.HttpClient; +import org.apache.commons.httpclient.HttpException; +import org.apache.commons.httpclient.methods.GetMethod; import org.jsoup.Jsoup; import org.jsoup.nodes.Document; import org.jsoup.nodes.Element; @@ -60,11 +63,47 @@ static Gson gson = new Gson(); + private static String get(String url) { + HttpClient client = new HttpClient(); + try { + client.getHttpConnectionManager().getParams().setConnectionTimeout(5000); + client.getHttpConnectionManager().getParams().setSoTimeout(5000); + GetMethod method = new GetMethod(url); + client.executeMethod(method); + return method.getResponseBodyAsString(); + } catch (HttpException e) { + e.printStackTrace(); + } catch (IOException e) { + e.printStackTrace(); + } + return ""; + } + + private static String request(String url) { + String result = null; + + while (result == null) { + try { + result = get(url); + if ((result != null && result.startsWith("<html>")) || StringUtil.isNullOrEmpty(result)) + result = null; + } catch (Exception e) { + try { + Thread.sleep(400); + } catch (InterruptedException e1) { + } + } + } + + return result; + } + public static DaTaoKeApiResult goodsList(int page) { List<DaTaoKeDetail> list = new ArrayList<>(); String url = String.format("http://api.dataoke.com/index.php?r=Port/index&type=total&appkey=%s&v=2&page=%s", Math.random() > 0.5 ? API_KEY : API_KEY_2, page + ""); - String result = HttpUtil.get(url); + String result = request(url); + JSONObject resultJson = JSONObject.fromObject(result); System.out.println(resultJson); JSONArray array = resultJson.optJSONArray("result"); @@ -78,6 +117,14 @@ return new DaTaoKeApiResult(resultJson.optJSONObject("data").optInt("total_num"), resultJson.optJSONObject("data").optString("update_time"), list); + } + + public static DaTaoKeDetail getGoodsDetailV1(Long id) { + String url = String.format("http://api.dataoke.com/index.php?r=Port/index&type=total&appkey=%s&v=2&id=%s", + Math.random() > 0.5 ? API_KEY : API_KEY_2, id + ""); + String result = request(url); + JSONObject resultJson = JSONObject.fromObject(result); + return gson.fromJson(resultJson.optJSONArray("result").optJSONObject(0).toString(), DaTaoKeDetail.class); } /** @@ -122,7 +169,16 @@ JSONObject data = JSONObject .fromObject(els.get(i).html().replace("var brandData =", "").trim().split("};")[0] + "}"); - taoBaoShopDTO = convertTaoBaoShopDTO(data); + taoBaoShopDTO = new TaoBaoShopDTO(); + JSONObject item = data.optJSONObject("act"); + taoBaoShopDTO.setSellerId(item.optLong("seller_id")); + taoBaoShopDTO.setBrandId(item.optString("brand_id")); + taoBaoShopDTO.setBrandDes(item.optString("brand_des")); + taoBaoShopDTO.setUserType(0); + + // 鍟嗗搧淇℃伅 + taoBaoShopDTO = getDynamicShopGoods(brandId, taoBaoShopDTO); + break; } } @@ -144,7 +200,7 @@ params.put("version", "v1.0.0"); params.put("appKey", app.getAppKey()); params.put("pageSize", 200 + ""); -// params.put("sort", "1"); + // params.put("sort", "1"); if (!StringUtil.isNullOrEmpty(pageId)) { params.put("pageId", pageId); } @@ -285,16 +341,38 @@ return daTaoKeGoodsResult; } - public static DaTaoKeGoodsResult search(String key, List<Integer> cidList, int page, int pageSize, int sort) { + public static DaTaoKeDetailV2 getGoodsDetail(Long id) { + TaoKeAppInfo app = getRandomApp(); + DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult(); + Map<String, String> params = new TreeMap<>(); + params.put("version", "v1.0.0"); + params.put("appKey", app.getAppKey()); + params.put("id", id + ""); + params.put("sign", getSign(params, app.getAppSecret())); + String result = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-goods-details", params, + new HashMap<>()); + JSONObject json = JSONObject.fromObject(result); + JSONObject dataJson = json.optJSONObject("data"); + if (dataJson != null) { + return gson.fromJson(dataJson.toString(), DaTaoKeDetailV2.class); + } + return null; + } + + public static DaTaoKeGoodsResult search(String key, List<Integer> cidList, BigDecimal priceLowerLimit, + BigDecimal priceUpperLimit, int page, int pageSize, int sort) { TaoKeAppInfo app = getRandomApp(); DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult(); Map<String, String> params = new TreeMap<>(); params.put("version", "v1.0.0"); params.put("appKey", app.getAppKey()); - params.put("pageSize", 200 + ""); + params.put("pageSize", pageSize + ""); params.put("pageId", page + ""); - + if (priceLowerLimit != null) + params.put("priceLowerLimit", priceLowerLimit + ""); + if (priceUpperLimit != null) + params.put("priceUpperLimit", priceUpperLimit + ""); String cids = ""; if (cidList != null && cidList.size() > 0) for (Integer cid : cidList) { @@ -311,6 +389,7 @@ params.put("sign", getSign(params, app.getAppSecret())); String result = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-dtk-search-goods", params, new HashMap<>()); + JSONObject json = JSONObject.fromObject(result); JSONObject dataJson = json.optJSONObject("data"); if (dataJson != null) { @@ -346,21 +425,30 @@ return StringUtil.Md5(signStr).toUpperCase(); } - public static TaoBaoShopDTO convertTaoBaoShopDTO(JSONObject data) { - TaoBaoShopDTO taoBaoShopDTO = new TaoBaoShopDTO(); - JSONObject item = data.optJSONObject("act"); - taoBaoShopDTO.setSellerId(item.optLong("seller_id")); - taoBaoShopDTO.setBrandId(item.optString("brand_id")); - taoBaoShopDTO.setBrandDes(item.optString("brand_des")); - int userType = 0; + /** + * 鑾峰彇搴楅摵涓嬪墠4涓晢鍝併�佸簵閾轰粙缁� + * + * @param brandId + * @return + */ + public static TaoBaoShopDTO getDynamicShopGoods(String brandId, TaoBaoShopDTO taoBaoShopDTO) { + if (brandId == null) { + return taoBaoShopDTO; + } + int userType = 0; List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>(); - JSONArray arrayGoods = data.optJSONArray("goods"); + + String result = HttpUtil.get("http://www.dataoke.com/brandGoods?id=" + brandId + "&page=1"); + JSONObject json = JSONObject.fromObject(result); + JSONArray arrayGoods = json.optJSONArray("goods"); + for (int i = 0; i < arrayGoods.size(); i++) { if (i >= 2) { break; } JSONObject itemGoods = arrayGoods.optJSONObject(i); + TaoBaoGoodsBrief taoBaoGoods = new TaoBaoGoodsBrief(); taoBaoGoods.setAuctionId(itemGoods.optLong("goodsid")); taoBaoGoods.setBiz30day(itemGoods.optInt("xiaoliang")); @@ -385,11 +473,52 @@ userType = itemGoods.optInt("istmall"); } - taoBaoShopDTO.setListGoods(listGoods); taoBaoShopDTO.setUserType(userType); + taoBaoShopDTO.setListGoods(listGoods); return taoBaoShopDTO; } + public static int RANK_TYPE_TIME = 1;// 瀹炴椂 + public static int RANK_TYPE_DAY = 2;// 鍏ㄥぉ姒� + public static int RANK_TYPE_HOT = 3;// 鐑帹姒� + + /** + * 鍚勫ぇ姒滃崟 + * + * @param type + * @return + */ + public static DaTaoKeGoodsResult getRankingList(int type, Integer cid) { + TaoKeAppInfo app = getRandomApp(); + DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult(); + Map<String, String> params = new TreeMap<>(); + params.put("version", "v1.0.0"); + params.put("appKey", app.getAppKey()); + params.put("rankType", type + ""); + if (cid != null) + params.put("cid", cid + ""); + params.put("sign", getSign(params, app.getAppSecret())); + String result = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-ranking-list", params, new HashMap<>()); + JSONObject json = JSONObject.fromObject(result); + if (json != null) { + JSONArray array = json.optJSONArray("data"); + + List<DaTaoKeDetailV2> list = new ArrayList<>(); + for (int i = 0; i < array.size(); i++) { + JSONObject itemData = array.optJSONObject(i); + DaTaoKeDetailV2 item = gson.fromJson(itemData.toString(), DaTaoKeDetailV2.class); + item.setCouponConditions(itemData.optString("quanUsageCondition")); + item.setShopType(itemData.optInt("istmall")); + item.setOriginalPrice(new BigDecimal(itemData.optString("originPrice"))); + item.setMainPic(itemData.optString("pic")); + list.add(item); + } + daTaoKeGoodsResult.setGoodsList(list); + } + return daTaoKeGoodsResult; + + } + class DaTaoKeResult { Date updateTime; List<DaTaoKeDetail> dataList; -- Gitblit v1.8.0