From 69bee82b81626b82b7f39f0e459e4f56b1699b51 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 13 三月 2019 12:02:16 +0800
Subject: [PATCH] 正式数据库修改

---
 fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java |  308 +++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 296 insertions(+), 12 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java b/fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java
index 7faf1ba..7833b6a 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java
@@ -7,6 +7,8 @@
 import java.util.List;
 import java.util.Map;
 
+import org.yeshi.utils.taobao.TbImgUtil;
+
 import com.taobao.api.ApiException;
 import com.yeshi.fanli.entity.taobao.RelateGoods;
 import com.yeshi.fanli.entity.taobao.SearchFilter;
@@ -19,12 +21,12 @@
 import com.yeshi.fanli.entity.taobao.TaoKeAppInfo;
 import com.yeshi.fanli.exception.taobao.TaoKeApiException;
 import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
+import com.yeshi.fanli.log.LogHelper;
 import com.yeshi.fanli.log.TaoKeLogHelper;
 import com.yeshi.fanli.tag.PageEntity;
 import com.yeshi.fanli.util.MoneyBigDecimalUtil;
 import com.yeshi.fanli.util.StringUtil;
 import com.yeshi.fanli.util.TimeUtil;
-import org.yeshi.utils.taobao.TbImgUtil;
 
 import net.sf.json.JSONArray;
 import net.sf.json.JSONObject;
@@ -157,6 +159,7 @@
 		map.put("method", "taobao.tbk.item.info.get");
 		map.put("num_iids", id + "");
 		String resultStr = TaoKeBaseUtil.baseRequestForThreeTimes(map, true);
+		// System.out.println(resultStr);
 		JSONObject data = JSONObject.fromObject(resultStr);
 		// 鍟嗗搧涓嬫灦
 		if (data.optJSONObject("error_response") != null && data.optJSONObject("error_response").optInt("code") == 15
@@ -192,6 +195,7 @@
 			goods.setProvcity(item.optString("provcity"));
 			goods.setPictUrl(item.optString("pict_url"));
 			goods.setShopTitle(item.optString("nick"));
+			goods.setSellerId(item.optLong("seller_id"));
 
 			String optString = item.optString("shop_dsr");
 			if (!StringUtil.isNullOrEmpty(optString)) {
@@ -218,9 +222,38 @@
 			if (item.optBoolean("free_shipment"))
 				goods.setFreeShipment(1);
 
+			if (!StringUtil.isNullOrEmpty(item.optString("material_lib_type")))
+				goods.setMaterialLibType(item.optInt("material_lib_type"));
+
 			return goods;
 		}
 		return null;
+	}
+
+	public String convertSpecialGoodsLink(Long auctionId, TaoKeAppInfo app) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.coupon.convert");
+		map.put("item_id", auctionId + "");
+		String resultStr = TaoKeBaseUtil.baseRequestForThreeTimes(map, app);
+		return resultStr;
+	}
+
+	public static List<TaoBaoGoodsBrief> getBatchGoodsInfo(List<Long> listId)
+			throws TaoKeApiException, TaobaoGoodsDownException {
+		if (listId == null || listId.size() == 0) {
+			throw new TaobaoGoodsDownException(1, "娣樺疂鍟嗗搧ID涓嶈兘涓虹┖");
+		}
+
+		if (listId.size() > 40) {
+			throw new TaobaoGoodsDownException(1, "娣樺疂鍟嗗搧ID涓嶈兘瓒呰繃40涓�");
+		}
+
+		StringBuffer ids = new StringBuffer();
+		for (Long id : listId) {
+			ids.append(id + ",");
+		}
+
+		return getBatchGoodsInfos(ids.substring(0, ids.length() - 1));
 	}
 
 	/**
@@ -302,6 +335,9 @@
 
 				if (item.optBoolean("free_shipment"))
 					goods.setFreeShipment(1);
+
+				if ("1".equalsIgnoreCase(item.optString("material_lib_type")))
+					;
 
 				goodsList.add(goods);
 			}
@@ -627,6 +663,12 @@
 		if (filter.getEndTkRate() > 0)
 			map.put("end_tk_rate", filter.getEndTkRate() + "");
 
+		if (filter.getStartKaTkRate() > 0)
+			map.put("start_ka_tk_rate", filter.getStartKaTkRate() + "");
+
+		if (filter.getEndKaTkRate() > 0)
+			map.put("end_ka_tk_rate", filter.getEndKaTkRate() + "");
+
 		if (filter.isTmall())
 			map.put("is_tmall", filter.isTmall() + "");
 
@@ -729,7 +771,7 @@
 
 		// 璁剧疆鍙戣揣鍦板潃
 		TaoBaoSearchNav nav = new TaoBaoSearchNav();
-		nav.setName("鍙戣揣鍦�");
+		nav.setName("鍙戣揣鍦伴�夋嫨");
 		nav.setFlag("address");
 		nav.setId(11110);
 		nav.setType("fahuodi");
@@ -860,10 +902,16 @@
 	private static TaoBaoGoodsBrief parseWuLiaoItem(JSONObject item) {
 		TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
 		goods.setPictUrl(item.optString("pict_url"));
+
+		if (!StringUtil.isNullOrEmpty(item.optString("white_image"))) {
+			goods.setPictUrlWhite(item.optString("white_image"));
+		}
+
 		goods.setAuctionId(item.optLong("num_iid"));
 		goods.setAuctionUrl("https:" + item.optString("url"));
 		goods.setBiz30day(item.optInt("volume"));
 		goods.setCouponInfo(item.optString("coupon_info"));
+
 		if (goods.getCouponInfo() != null)
 			goods.setCouponInfo(goods.getCouponInfo().replace(".00", ""));
 
@@ -953,6 +1001,11 @@
 	 * @return
 	 */
 	public static String getTKToken(String logo, String text, String url) {
+		if (text == null)
+			return null;
+		if (text.length() < 5)
+			text = "濂借揣锛�" + text;
+
 		Map<String, String> map = new HashMap<>();
 		map.put("method", "taobao.tbk.tpwd.create");
 		map.put("url", url);
@@ -1033,16 +1086,17 @@
 				return list;
 			JSONArray array = data.optJSONObject("tbk_item_recommend_get_response").optJSONObject("results")
 					.optJSONArray("n_tbk_item");
-			for (int i = 0; i < array.size(); i++) {
-				JSONObject item = array.optJSONObject(i);
-				TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
-				goods.setAuctionId(item.optLong("num_iid"));
-				goods.setTitle(item.optString("title"));
-				goods.setZkPrice(new BigDecimal(item.optString("zk_final_price")));
-				goods.setAuctionUrl(item.optString("item_url"));
-				goods.setPictUrl(item.optString("pict_url"));
-				list.add(goods);
-			}
+			if (array != null)
+				for (int i = 0; i < array.size(); i++) {
+					JSONObject item = array.optJSONObject(i);
+					TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
+					goods.setAuctionId(item.optLong("num_iid"));
+					goods.setTitle(item.optString("title"));
+					goods.setZkPrice(new BigDecimal(item.optString("zk_final_price")));
+					goods.setAuctionUrl(item.optString("item_url"));
+					goods.setPictUrl(item.optString("pict_url"));
+					list.add(goods);
+				}
 		}
 		return list;
 	}
@@ -1403,6 +1457,236 @@
 		return result;
 	}
 
+	/**
+	 * 浠庢窐瀹濋摼鎺ヤ腑瑙f瀽鍟嗗搧ID锛堥珮绾ф帴鍙o級
+	 * 
+	 * @param link
+	 * @return
+	 */
+	public static String parseAuctionIdFromLink(String link) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.item.click.extract");
+		map.put("click_url", link + "");
+		JSONObject resultJSON = null;
+		try {
+			resultJSON = TaoKeBaseUtil.baseRequest(map, true);
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+		}
+		if (resultJSON == null)
+			return null;
+
+		return null;
+
+	}
+
+	public static String getAccessToken(String code, String appKey, String appSecret) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.top.auth.token.create");
+		map.put("code", code);
+		TaoKeAppInfo app = new TaoKeAppInfo();
+		app.setAppKey(appKey);
+		app.setAppSecret(appSecret);
+		try {
+			JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
+			if (json != null)
+				return json.toString();
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+		}
+
+		return null;
+	}
+
+	/**
+	 * 娓犻亾閭�璇风爜
+	 * 
+	 * @param relationId
+	 * @return
+	 */
+	public static String getInviteCode(Long relationId, String accessToken, String appKey, String appSecret) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.sc.invitecode.get");
+		map.put("session", accessToken);
+		map.put("code_type", "1");
+		map.put("relation_app", "common");
+		JSONObject resultJSON = null;
+		try {
+			TaoKeAppInfo app = new TaoKeAppInfo();
+			app.setAppKey(appKey);
+			app.setAppSecret(appSecret);
+			resultJSON = TaoKeBaseUtil.baseRequest(map, app);
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+		}
+		if (resultJSON == null)
+			return null;
+
+		return null;
+	}
+
+	/**
+	 * 鑾峰彇娓犻亾閭�璇风爜
+	 * 
+	 * @param accessToken
+	 * @param appKey
+	 * @param appSecret
+	 * @return
+	 */
+	public static String getRootRelationInviteCode(String accessToken, String appKey, String appSecret) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.sc.invitecode.get");
+		map.put("session", accessToken);
+		map.put("code_type", "1");
+		map.put("relation_app", "common");
+		JSONObject resultJSON = null;
+		try {
+			TaoKeAppInfo app = new TaoKeAppInfo();
+			app.setAppKey(appKey);
+			app.setAppSecret(appSecret);
+			resultJSON = TaoKeBaseUtil.baseRequest(map, app);
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+		}
+		if (resultJSON == null)
+			return null;
+
+		return null;
+	}
+
+	public static String getRootSpecialInviteCode(String accessToken, String appKey, String appSecret) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.sc.invitecode.get");
+		map.put("session", accessToken);
+		map.put("code_type", "3");
+		map.put("relation_app", "common");
+		JSONObject resultJSON = null;
+		try {
+			TaoKeAppInfo app = new TaoKeAppInfo();
+			app.setAppKey(appKey);
+			app.setAppSecret(appSecret);
+			resultJSON = TaoKeBaseUtil.baseRequest(map, app);
+			return resultJSON.optJSONObject("tbk_sc_invitecode_get_response").optJSONObject("data")
+					.optString("inviter_code");
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+		}
+		if (resultJSON == null)
+			return null;
+
+		return null;
+	}
+
+	public static String getRelationId(String accessToken, String appKey, String appSecret) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.sc.publisher.info.save");
+		map.put("session", accessToken);
+		map.put("inviter_code", "A2QnGL");
+		map.put("info_type", "1");
+		map.put("online_scene", "1");
+		JSONObject resultJSON = null;
+		try {
+			TaoKeAppInfo app = new TaoKeAppInfo();
+			app.setAppKey(appKey);
+			app.setAppSecret(appSecret);
+			resultJSON = TaoKeBaseUtil.baseRequest(map, app);
+			return resultJSON.optJSONObject("tbk_sc_publisher_info_save_response").optJSONObject("data")
+					.optString("relation_id");
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+			LogHelper.error("娓犻亾ID鐢宠鍑洪敊:" + resultJSON);
+		}
+
+		return null;
+	}
+
+	public static String getSpecialId(String accessToken, String appKey, String appSecret) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.sc.publisher.info.save");
+		map.put("session", accessToken);
+		map.put("inviter_code", "AA5ISJ");
+		map.put("info_type", "1");
+		map.put("online_scene", "1");
+		JSONObject resultJSON = null;
+		try {
+			TaoKeAppInfo app = new TaoKeAppInfo();
+			app.setAppKey(appKey);
+			app.setAppSecret(appSecret);
+			resultJSON = TaoKeBaseUtil.baseRequest(map, app);
+			return resultJSON.optJSONObject("tbk_sc_publisher_info_save_response").optJSONObject("data")
+					.optString("special_id");
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+			LogHelper.error("浼氬憳杩愯惀ID鐢宠鍑洪敊:" + resultJSON);
+		}
+
+		return null;
+	}
+
+	public static void specialConvertItem(Long auctionId, TaoKeAppInfo app) {
+		String pid = app.getPid();
+		String[] sts = pid.split("_");
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.item.convert");
+		map.put("num_iids", auctionId + "");
+		map.put("fields", "num_iid,click_url");
+		map.put("adzone_id", sts[3]);
+		map.put("platform", "2");
+		try {
+			JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
+			System.out.println(json.toString());
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+		}
+	}
+
+	public static TaoBaoGoodsBrief specialConvertCoupon(Long auctionId, TaoKeAppInfo app) {
+		String pid = app.getPid();
+		String[] sts = pid.split("_");
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.coupon.convert");
+		map.put("item_id", auctionId + "");
+		map.put("adzone_id", sts[3]);
+		try {
+			JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
+			JSONObject resultJSON = json.optJSONObject("tbk_coupon_convert_response").optJSONObject("result")
+					.optJSONObject("results");
+			String couponLink = resultJSON.optString("coupon_click_url");
+			String itemLink = resultJSON.optString("item_url");
+			TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
+			goods.setAuctionUrl(itemLink);
+			if (!StringUtil.isNullOrEmpty(resultJSON.optString("coupon_info")))
+				goods.setCouponLink(couponLink);
+			return goods;
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+		}
+
+		return null;
+	}
+
+	public static void juHuaSuan() {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.ju.items.search");
+		map.put("current_page", 1 + "");
+		map.put("page_size", 100+"");
+		map.put("pid", "mm_124933865_43788020_381938426");
+		
+		TaoKeAppInfo app = new TaoKeAppInfo();
+		app.setAppKey("24838852");
+		app.setAppSecret("bc8265e2bf8d8115329d652f9d3d4cd8");
+		
+		try {
+			JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
+			System.out.println(json);
+		} catch (TaoKeApiException e) {
+			e.printStackTrace();
+		}
+
+	}
+
+	// AA5ISJ
+
 	private static TaoBaoGoodsBrief parseWuLiaoItemFromMaterialId(JSONObject item) {
 		TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
 		// 璁剧疆鎴�320*320鐨勫浘鐗囧昂瀵�

--
Gitblit v1.8.0