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