From 98b1a0affd69bbe63223c21fdd2c404e8bedfccb Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 20 五月 2020 17:25:08 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/div' into 2.1.2

---
 fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java |  191 ++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 146 insertions(+), 45 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 3fda554..5455308 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,10 +7,12 @@
 import java.util.List;
 import java.util.Map;
 
+import org.yeshi.utils.JsonUtil;
 import org.yeshi.utils.taobao.TbImgUtil;
 
 import com.yeshi.fanli.dto.taobao.TaoBaoShopInfoDTO;
 import com.yeshi.fanli.dto.taobao.TaoLiJinDTO;
+import com.yeshi.fanli.dto.taobao.api.TaoKeOfficialActivityConvertResultDTO;
 import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinReport;
 import com.yeshi.fanli.entity.taobao.SearchFilter;
 import com.yeshi.fanli.entity.taobao.SearchShopFilter;
@@ -169,6 +171,8 @@
 		goods.setPictUrl(item.optString("pict_url"));
 		goods.setShopTitle(item.optString("nick"));
 		goods.setSellerId(item.optLong("seller_id"));
+		goods.setRootCategoryName(item.optString("cat_name"));
+		goods.setLeafName(item.optString("cat_leaf_name"));
 
 		String optString = item.optString("shop_dsr");
 		if (!StringUtil.isNullOrEmpty(optString)) {
@@ -318,29 +322,37 @@
 				}
 			}
 
-		// 鍐嶄粠娣樺疂鑱旂洘缃戦〉鎼滅储
-		filter.setKey(goods.getAuctionUrl());
-		TaoBaoSearchResult searchResult = TaoBaoUtil.searchFromAlimamaWeb(filter, null);
-		if (searchResult != null && searchResult.getTaoBaoGoodsBriefs() != null
-				&& searchResult.getTaoBaoGoodsBriefs().size() > 0) {
-			for (TaoBaoGoodsBrief g : searchResult.getTaoBaoGoodsBriefs()) {
-				if (g.getAuctionId().longValue() == goods.getAuctionId()) {
-					g.setImgList(goods.getImgList());
-					goods = g;
-					if ("鏃�".equalsIgnoreCase(goods.getCouponInfo()))
-						goods.setCouponInfo(null);
-					return goods;
+		// 浠庤浆閾炬悳绱�
+		TaoBaoGoodsBrief newGoods = specialConvertCoupon(goods.getAuctionId(),
+				new TaoKeAppInfo(TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET,
+						TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT));
+
+		if (newGoods != null) {
+			goods.setTkRate(newGoods.getTkRate());
+			if (!StringUtil.isNullOrEmpty(newGoods.getCouponInfo())) {
+				List<BigDecimal> couponInfo = TaoBaoCouponUtil.getCouponInfo(newGoods.getCouponInfo());
+				if (couponInfo != null && couponInfo.size() > 1) {
+					goods.setCouponStartFee(couponInfo.get(0));
+					goods.setCouponAmount(couponInfo.get(1));
+					goods.setCouponEffectiveStartTime(newGoods.getCouponEffectiveStartTime());
+					goods.setCouponEffectiveEndTime(newGoods.getCouponEffectiveEndTime());
+					goods.setCouponLeftCount(newGoods.getCouponLeftCount());
+					goods.setCouponTotalCount(newGoods.getCouponTotalCount());
+					goods.setCouponInfo(newGoods.getCouponInfo());
 				}
 			}
+
+			return goods;
+
+		} else {
+			goods.setCouponAmount(new BigDecimal("0"));
+			goods.setTkMktStatus("1");
+			goods.setTkRate(new BigDecimal("0"));
+			goods.setReservePrice(new BigDecimal(0));
+			goods.setTkCommFee(new BigDecimal(0));
+			return goods;
 		}
 
-		TaoKeLogHelper.error(null, "娌℃湁鎼滅储鍒拌鎯�:" + id);
-		goods.setCouponAmount(new BigDecimal("0"));
-		goods.setTkMktStatus("1");
-		goods.setTkRate(new BigDecimal("0"));
-		goods.setReservePrice(new BigDecimal(0));
-		goods.setTkCommFee(new BigDecimal(0));
-		return goods;
 	}
 
 	/**
@@ -387,29 +399,36 @@
 				}
 			}
 
-		// 鍐嶄粠娣樺疂鑱旂洘缃戦〉鎼滅储
-		filter.setKey(goods.getAuctionUrl());
-		TaoBaoSearchResult searchResult = TaoBaoUtil.searchFromAlimamaWeb(filter, null);
-		if (searchResult != null && searchResult.getTaoBaoGoodsBriefs() != null
-				&& searchResult.getTaoBaoGoodsBriefs().size() > 0) {
-			for (TaoBaoGoodsBrief g : searchResult.getTaoBaoGoodsBriefs()) {
-				if (g.getAuctionId().longValue() == goods.getAuctionId()) {
-					g.setImgList(goods.getImgList());
-					goods = g;
-					if ("鏃�".equalsIgnoreCase(goods.getCouponInfo()))
-						goods.setCouponInfo(null);
-					return goods;
+		// 浠庤浆閾炬悳绱�
+		TaoBaoGoodsBrief newGoods = specialConvertCoupon(goods.getAuctionId(),
+				new TaoKeAppInfo(TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET,
+						TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT));
+
+		if (newGoods != null) {
+			goods.setTkRate(newGoods.getTkRate());
+			if (!StringUtil.isNullOrEmpty(newGoods.getCouponInfo())) {
+				List<BigDecimal> couponInfo = TaoBaoCouponUtil.getCouponInfo(newGoods.getCouponInfo());
+				if (couponInfo != null && couponInfo.size() > 1) {
+					goods.setCouponStartFee(couponInfo.get(0));
+					goods.setCouponAmount(couponInfo.get(1));
+					goods.setCouponEffectiveStartTime(newGoods.getCouponEffectiveStartTime());
+					goods.setCouponEffectiveEndTime(newGoods.getCouponEffectiveEndTime());
+					goods.setCouponLeftCount(newGoods.getCouponLeftCount());
+					goods.setCouponTotalCount(newGoods.getCouponTotalCount());
+					goods.setCouponInfo(newGoods.getCouponInfo());
 				}
 			}
-		}
 
-		TaoKeLogHelper.error(null, "娌℃湁鎼滅储鍒拌鎯�:" + id);
-		goods.setCouponAmount(new BigDecimal("0"));
-		goods.setTkMktStatus("1");
-		goods.setTkRate(new BigDecimal("0"));
-		goods.setReservePrice(new BigDecimal(0));
-		goods.setTkCommFee(new BigDecimal(0));
-		return goods;
+			return goods;
+
+		} else {
+			goods.setCouponAmount(new BigDecimal("0"));
+			goods.setTkMktStatus("1");
+			goods.setTkRate(new BigDecimal("0"));
+			goods.setReservePrice(new BigDecimal(0));
+			goods.setTkCommFee(new BigDecimal(0));
+			return goods;
+		}
 	}
 
 	/**
@@ -1624,6 +1643,7 @@
 		map.put("adzone_id", sts[3]);
 		try {
 			String result = TaoKeBaseUtil.baseRequestForThreeTimes(map, app);
+			System.out.println(result);
 			JSONObject json = JSONObject.fromObject(result);
 			JSONObject resultJSON = json.optJSONObject("tbk_coupon_convert_response").optJSONObject("result")
 					.optJSONObject("results");
@@ -1634,6 +1654,17 @@
 			if (!StringUtil.isNullOrEmpty(resultJSON.optString("coupon_info"))) {
 				goods.setCouponLink(couponLink);
 				goods.setCouponInfo(resultJSON.optString("coupon_info"));
+				if (!StringUtil.isNullOrEmpty(resultJSON.optString("coupon_total_count"))) {
+					goods.setCouponTotalCount(Integer.parseInt(resultJSON.optString("coupon_total_count")));
+				}
+
+				if (!StringUtil.isNullOrEmpty(resultJSON.optString("coupon_remain_count"))) {
+					goods.setCouponLeftCount(Integer.parseInt(resultJSON.optString("coupon_remain_count")));
+				}
+
+				goods.setCouponEffectiveStartTime(resultJSON.optString("coupon_start_time"));
+				goods.setCouponEffectiveEndTime(resultJSON.optString("coupon_end_time"));
+
 			}
 			String tkRate = resultJSON.optString("max_commission_rate");
 			if (!StringUtil.isNullOrEmpty(tkRate)) {
@@ -2047,11 +2078,12 @@
 	 *            -娓犻亾ID
 	 * @return
 	 */
-	public static String officialActivityConvert(String adZoneId, String promotionSceneId, String relationId) {
+	public static TaoKeOfficialActivityConvertResultDTO officialActivityConvert(String adZoneId,
+			String promotionSceneId, String relationId) {
 		Map<String, String> map = new HashMap<>();
-		map.put("method", "taobao.tbk.activitylink.get");
+		map.put("method", "taobao.tbk.activity.info.get");
 		map.put("adzone_id", adZoneId);
-		map.put("promotion_scene_id", promotionSceneId);
+		map.put("activity_material_id", promotionSceneId);
 		if (relationId != null)
 			map.put("relation_id", relationId);
 		TaoKeAppInfo app = new TaoKeAppInfo();
@@ -2059,11 +2091,13 @@
 		app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
 		try {
 			String result = TaoKeBaseUtil.baseRequestForThreeTimes(map, app);
+			System.out.println(result);
 			JSONObject json = JSONObject.fromObject(result);
 			if (json != null) {
-				json = json.optJSONObject("tbk_activitylink_get_response");
-				if (json.optInt("result_code") == 200) {
-					return json.optString("data");
+				json = json.optJSONObject("tbk_activity_info_get_response");
+				if (json.optJSONObject("data") != null) {
+					return JsonUtil.getSimpleGson().fromJson(json.optJSONObject("data").toString(),
+							TaoKeOfficialActivityConvertResultDTO.class);
 				}
 			}
 		} catch (Exception e) {
@@ -2104,6 +2138,73 @@
 
 		return goodsList;
 	}
+
+	public static List<TaoBaoGoodsBrief> getCouponListByItemId(Long auctionId) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.itemid.coupon.get");
+		map.put("platform", auctionId + "");
+		map.put("num_iids", auctionId + "");
+		map.put("pid", TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT);
+
+		List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();
+		JSONObject resultJSON = null;
+		try {
+			resultJSON = TaoKeBaseUtil.baseRequest(map, new TaoKeAppInfo(TaoBaoConstant.TAOBAO_AUTH_APPKEY,
+					TaoBaoConstant.TAOBAO_AUTH_APPSECRET, TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT));
+
+			JSONObject response = resultJSON.optJSONObject("tbk_dg_optimus_material_response");
+			if (response != null && response.optJSONObject("result_list") != null) {
+				JSONArray array = response.optJSONObject("result_list").optJSONArray("map_data");
+				if (array != null) {
+
+					for (int i = 0; i < array.size(); i++) {
+						JSONObject item = array.optJSONObject(i);
+						TaoBaoGoodsBrief goods = parseWuLiaoItemFromMaterialId(item);
+						if (goods != null)
+							goodsList.add(goods);
+					}
+				}
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+
+		return goodsList;
+	}
+
+	/**
+	 * 娣樺疂瀹�-鎺ㄥ箍鑰�-瀹樻柟娲诲姩淇℃伅鑾峰彇
+	 * @Title: getActivityInfo
+	 * @Description: 
+	 * @param activityMaterialId
+	 * @param pid
+	 * @param relationId
+	 * @return 
+	 * String 杩斿洖绫诲瀷
+	 * @throws
+	 */
+	public static String getActivityInfo(String activityMaterialId, String pid, String relationId) {
+		Map<String, String> map = new HashMap<>();
+		map.put("method", "taobao.tbk.activity.info.get");
+		map.put("activity_material_id", activityMaterialId);
+		map.put("adzone_id", pid.split("_")[3] + "");
+		map.put("relation_id", relationId);
+
+		JSONObject resultJSON = null;
+		try {
+			resultJSON = TaoKeBaseUtil.baseRequest(map,
+					new TaoKeAppInfo(TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET, pid));
+			JSONObject response = resultJSON.optJSONObject("tbk_activity_info_get_response");
+			if (response != null && response.optJSONObject("data") != null) {
+				return response.optJSONObject("data").optString("click_url");
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+
+		return null;
+	}
+
 }
 
 class QuanInfo {

--
Gitblit v1.8.0