From 7abc563e709c3a7e1f7740505c30ba58c3afb920 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 12 四月 2019 12:14:30 +0800
Subject: [PATCH] bug修改

---
 fanli/src/main/java/com/yeshi/fanli/controller/client/RecommendController.java |  316 +++++++++++++++++++++++++++-------------------------
 1 files changed, 165 insertions(+), 151 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/RecommendController.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/RecommendController.java
index 1b07d91..a92417f 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/client/RecommendController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/RecommendController.java
@@ -38,7 +38,6 @@
 import com.yeshi.fanli.entity.bus.recommend.RecommendBannerV2;
 import com.yeshi.fanli.entity.bus.recommend.RecommendSpecial;
 import com.yeshi.fanli.entity.bus.su.recommend.SuperRecommendBanner;
-import com.yeshi.fanli.entity.bus.su.recommend.SuperRecommendBannerV2;
 import com.yeshi.fanli.entity.bus.su.recommend.SuperRecommendSpecial;
 import com.yeshi.fanli.entity.bus.user.Order;
 import com.yeshi.fanli.entity.bus.user.ShamUser;
@@ -63,6 +62,7 @@
 import com.yeshi.fanli.entity.taobao.TaoKeAppInfo;
 import com.yeshi.fanli.exception.goods.CommonGoodsException;
 import com.yeshi.fanli.exception.goods.ScanHistoryException;
+import com.yeshi.fanli.exception.taobao.TaoKeApiException;
 import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
 import com.yeshi.fanli.exception.taobao.TaobaoGoodsUpdateException;
 import com.yeshi.fanli.exception.user.UserCustomSettingsException;
@@ -101,8 +101,10 @@
 import com.yeshi.fanli.util.Constant;
 import com.yeshi.fanli.util.RedisManager;
 import com.yeshi.fanli.util.StringUtil;
+import com.yeshi.fanli.util.TaoBaoConstant;
 import com.yeshi.fanli.util.ThreadUtil;
 import com.yeshi.fanli.util.TimeUtil;
+import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;
 import com.yeshi.fanli.util.factory.MonitorFactory;
 import com.yeshi.fanli.util.taobao.TaoBaoCouponUtil;
 import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
@@ -221,6 +223,9 @@
 
 	@Resource
 	private UserInfoExtraService userInfoExtraService;
+
+	@Resource
+	private TaoBaoGoodsCacheUtil taoBaoGoodsCacheUtil;
 
 	@RequestMapping(value = "getHonestList")
 	public void getHonestList(AcceptData acceptData, PrintWriter out) {
@@ -404,25 +409,28 @@
 		if (!"1".equals(version) && "android".equalsIgnoreCase(acceptData.getPlatform())) {
 			jumpDetail = jumpDetailService.getlastJumpDetailCache();
 		}
+		List<RecommendSpecial> recommendSpecialList = null;
+
 		List<SuperRecommendSpecial> superRecommendSpecialList = superRecommendSpecialService
 				.getSuperRecommendSpecialBySystemId(system.getId());
+		if (superRecommendSpecialList != null && superRecommendSpecialList.size() > 0) {
 
-		List<RecommendSpecial> recommendSpecialList = null;
-		for (SuperRecommendSpecial superRecommendSpecial : superRecommendSpecialList) {
-			if (recommendSpecialList == null) {
-				recommendSpecialList = new ArrayList<RecommendSpecial>();
+			recommendSpecialList = new ArrayList<RecommendSpecial>();
+
+			for (SuperRecommendSpecial superRecommendSpecial : superRecommendSpecialList) {
+				RecommendSpecial recommendSpecial = superRecommendSpecial.getRecommendSpecial();
+				if (jumpDetail != null) {
+					recommendSpecial.setJumpDetail(jumpDetail);
+				}
+				recommendSpecialList.add(recommendSpecial);
 			}
-			RecommendSpecial recommendSpecial = superRecommendSpecial.getRecommendSpecial();
-			if (jumpDetail != null) {
-				recommendSpecial.setJumpDetail(jumpDetail);
-			}
-			recommendSpecialList.add(recommendSpecial);
 		}
 
 		if (recommendSpecialList == null || recommendSpecialList.size() == 0) {
 			out.print(JsonUtil.loadFalseResult(1, "鏆傛棤鏁版嵁"));
 			return;
 		}
+
 		JSONObject data = new JSONObject();
 		data.put("count", recommendSpecialList.size());
 		Gson gson = new Gson();
@@ -569,8 +577,8 @@
 		// 鑾峰彇娣樺鍙傛暟
 		ClientTBPid clientTBPid = null;
 		if (simpleGoods.getMaterialLibType() != null && simpleGoods.getMaterialLibType() == 1) {
-			String pid = Constant.TAOBAO_SPECIAL_PID_DEFAULT;
-			clientTBPid = new ClientTBPid(Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET,
+			String pid = TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT;
+			clientTBPid = new ClientTBPid(TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET,
 					pid.split("_")[2], pid.split("_")[3]);
 		} else {
 			if (acceptData.getPlatform().equalsIgnoreCase("android")) {
@@ -1307,7 +1315,7 @@
 					for (TaoBaoGoodsBrief goods : result.getTaoBaoGoodsBriefs()) {
 						if (!StringUtil.isNullOrEmpty(goods.getCouponInfo()) && goods.getCouponAmount() != null
 								&& goods.getCouponAmount().compareTo(new BigDecimal("5")) >= 0
-								&& goods.getBiz30day() > 1000)
+								&& goods.getBiz30day() > 1000 && !StringUtil.isNullOrEmpty(goods.getPictUrlWhite()))
 							goodsList.add(goods);
 					}
 					try {
@@ -1368,26 +1376,8 @@
 		}
 
 		// 棣栭〉Banner
-		List<RecommendBannerV2> listBanner = null;
-
-		List<SuperRecommendBannerV2> listRecommendBanner = superRecommendBannerV2Service
-				.getSuperRecommendBannerV2sBySystem(system);
-
-		if (listRecommendBanner != null && listRecommendBanner.size() > 0) {
-
-			listBanner = new ArrayList<RecommendBannerV2>();
-
-			for (SuperRecommendBannerV2 superRecommendBanner : listRecommendBanner) {
-				RecommendBannerV2 recommendBanner = superRecommendBanner.getRecommendBanner();
-				// 娣樼壒浠锋殏鏃朵慨鏀�
-				if (system.getId() == 7) {
-					recommendBanner.getJumpDetail().setActivity(recommendBanner.getJumpDetail().getActivity()
-							.replace("com.yeshi.ec.rebate.myapplication", "com.yeshi.ec.taospecial"));
-				}
-
-				listBanner.add(recommendBanner);
-			}
-		}
+		List<RecommendBannerV2> listBanner = superRecommendBannerV2Service
+				.getSuperRecommendBannerV2sBySystem(system.getId());
 
 		JSONObject root = new JSONObject();
 		root.put("banner", listBanner);
@@ -1637,110 +1627,102 @@
 
 		LogHelper.test("鑾峰彇PID鑰楁椂锛�" + (java.lang.System.currentTimeMillis() - startTime));
 
-		final String clientPid = clientTBPid.getPid();
 		final List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();
 		// 鏄惁鍦ㄦ湇鍔$杩涜杞摼
 		boolean convertInServer = configService.isConvertTaoBaoLinkInServer();
 
-		List<String> taskList = new ArrayList<>();
-		// 鑾峰彇鍟嗗搧鍩烘湰淇℃伅
-		taskList.add("goods");
+		JSONObject ticket = new JSONObject();
+		TaoBaoGoodsBrief goods = null;
 
-		taskList.stream().parallel().forEach(task -> {
-			if (task.equalsIgnoreCase("goods")) {
-				JSONObject ticket = new JSONObject();
-				TaoBaoGoodsBrief goods = null;
-
-				if (!convertInServer) {
-
-					try {
-						goods = redisManager.getTaoBaoGoodsBrief(Long.parseLong(id));
-						if (goods.getTkRate() == null || new BigDecimal(0).compareTo(goods.getTkRate()) == 0) {
-							String appId = clientPid.split("_")[2];
-							TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(appId);
-							TaoKeAppInfo app = new TaoKeAppInfo();
-							app.setAdzoneId(clientPid.split("_")[3]);
-							app.setAppKey(config.getAppKey());
-							app.setAppSecret(config.getAppSecret());
-							app.setPid(clientPid);
-							TaoBaoGoodsBrief linkInfo = TaoKeApiUtil.specialConvertCoupon(goods.getAuctionId(), app);
-							if (linkInfo != null) {
-								goods.setAuctionUrl(linkInfo.getAuctionUrl());
-								goods.setCouponLink(linkInfo.getCouponLink());
-								goods.setTkRate(linkInfo.getTkRate());
-							}
-						}
-					} catch (TaobaoGoodsDownException e) {
-						// 鍟嗗搧涓嬫灦
-						ThreadUtil.run(new Runnable() {
-							public void run() {
-								taoBaoGoodsUpdateService.offlineTaoBaoGoods(Long.parseLong(id));
-							}
-						});
-
-					}
-
-				} else {
-					String appId = clientPid.split("_")[2];
-					TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(appId);
+		if (!convertInServer) {
+			try {
+				goods = taoBaoGoodsCacheUtil.getCommonTaoBaoGoodsInfo(Long.parseLong(id));
+				if (goods == null) {
 					TaoKeAppInfo app = new TaoKeAppInfo();
-					app.setAdzoneId(clientPid.split("_")[3]);
-					app.setAppKey(config.getAppKey());
-					app.setAppSecret(config.getAppSecret());
-					app.setPid(clientPid);
-
-					try {
-						goods = TaoKeApiUtil.searchGoodsDetail(Long.parseLong(id), app);
-						if (goods != null) {
-							ticket.put("clickUrl", goods.getAuctionUrl());
-							// 娴嬭瘯浣跨敤
-							ticket.put("couponUrl", goods.getCouponLink());
-							data.put("ticket", ticket);
-						}
-
-						if (goods.getTkRate() == null || new BigDecimal(0).compareTo(goods.getTkRate()) == 0) {
-							TaoBaoGoodsBrief linkInfo = TaoKeApiUtil.specialConvertCoupon(goods.getAuctionId(), app);
-							if (linkInfo != null) {
-								goods.setAuctionUrl(linkInfo.getAuctionUrl());
-								goods.setCouponLink(linkInfo.getCouponLink());
-								goods.setTkRate(linkInfo.getTkRate());
-							}
-						}
-
-					} catch (NumberFormatException e) {
-						e.printStackTrace();
-					} catch (TaobaoGoodsDownException e) {
+					app.setAppKey(TaoBaoConstant.TAOBAO_COMMON_APPKEY);
+					app.setAppSecret(TaoBaoConstant.TAOBAO_COMMON_APPSECRET);
+					app.setPid(TaoBaoConstant.TAOBAO_COMMON_PID);
+					app.setAdzoneId(TaoBaoConstant.TAOBAO_COMMON_PID.split("_")[3]);
+					goods = TaoKeApiUtil.searchGoodsDetail(Long.parseLong(id), app);
+					final TaoBaoGoodsBrief finalGoods = goods;
+					if (goods != null) {
 						ThreadUtil.run(new Runnable() {
+							@Override
 							public void run() {
-								taoBaoGoodsUpdateService.offlineTaoBaoGoods(Long.parseLong(id));
+								taoBaoGoodsCacheUtil.saveCommonTaoBaoGoodsInfo(finalGoods);
 							}
 						});
 					}
-
 				}
+			} catch (TaobaoGoodsDownException e) {
+				// 鍟嗗搧涓嬫灦
+				ThreadUtil.run(new Runnable() {
+					public void run() {
+						taoBaoGoodsUpdateService.offlineTaoBaoGoods(Long.parseLong(id));
+					}
+				});
 
-				if (goods != null) {
-					goodsList.add(goods);
-					final TaoBaoGoodsBrief newGoods = goods;
-					ThreadUtil.run(new Runnable() {
-						public void run() {
-							try {
-								// 鏇存柊鍟嗗搧
-								LogHelper.test("鏇存柊鍟嗗搧璇︽儏:" + newGoods.getAuctionId());
-								taoBaoGoodsUpdateService.updateTaoBaoGoods(newGoods);
-							} catch (TaobaoGoodsUpdateException e) {
-
-							}
-						}
-					});
-				}
 			}
-		});
+
+		} else {
+			final String clientPid = clientTBPid.getPid();
+			String appId = clientPid.split("_")[2];
+			TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(appId);
+			TaoKeAppInfo app = new TaoKeAppInfo();
+			app.setAdzoneId(clientPid.split("_")[3]);
+			app.setAppKey(config.getAppKey());
+			app.setAppSecret(config.getAppSecret());
+			app.setPid(clientPid);
+
+			try {
+				goods = TaoKeApiUtil.searchGoodsDetail(Long.parseLong(id), app);
+				if (goods != null) {
+					ticket.put("clickUrl", goods.getAuctionUrl());
+					// 娴嬭瘯浣跨敤
+					ticket.put("couponUrl", goods.getCouponLink());
+					data.put("ticket", ticket);
+				}
+
+				if (goods.getTkRate() == null || new BigDecimal(0).compareTo(goods.getTkRate()) == 0) {
+					TaoBaoGoodsBrief linkInfo = TaoKeApiUtil.specialConvertCoupon(goods.getAuctionId(), app);
+					if (linkInfo != null) {
+						goods.setAuctionUrl(linkInfo.getAuctionUrl());
+						goods.setCouponLink(linkInfo.getCouponLink());
+						goods.setTkRate(linkInfo.getTkRate());
+					}
+				}
+
+			} catch (NumberFormatException e) {
+				e.printStackTrace();
+			} catch (TaobaoGoodsDownException e) {
+				ThreadUtil.run(new Runnable() {
+					public void run() {
+						taoBaoGoodsUpdateService.offlineTaoBaoGoods(Long.parseLong(id));
+					}
+				});
+			}
+
+		}
+
+		if (goods != null) {
+			goodsList.add(goods);
+			final TaoBaoGoodsBrief newGoods = goods;
+			ThreadUtil.run(new Runnable() {
+				public void run() {
+					try {
+						// 鏇存柊鍟嗗搧
+						LogHelper.test("鏇存柊鍟嗗搧璇︽儏:" + newGoods.getAuctionId());
+						taoBaoGoodsUpdateService.updateTaoBaoGoods(newGoods);
+					} catch (TaobaoGoodsUpdateException e) {
+
+					}
+				}
+			});
+		}
 
 		TaoBaoGoodsBrief tb = null;
 		if (goodsList.size() > 0) {
 			tb = goodsList.get(0);
-
 		}
 
 		if (tb == null) {
@@ -1758,17 +1740,19 @@
 		for (String img : tb.getImgList()) {
 			finalImgList.add(TbImgUtil.getTBSizeImg(img, 600));
 		}
+		if (!StringUtil.isNullOrEmpty(tb.getPictUrlWhite()))
+			finalImgList.add(0, tb.getPictUrlWhite());
 
-		JSONObject goods = new JSONObject();
-		goods.put("auctionId", tb.getAuctionId());
-		goods.put("imgList", finalImgList);
-		goods.put("title", tb.getTitle());
-		goods.put("userType", tb.getUserType() == 1 ? 2 : 1);
-		goods.put("price", tb.getReservePrice().toString());
-		goods.put("zkPrice", tb.getZkPrice().toString());
+		JSONObject goodsJson = new JSONObject();
+		goodsJson.put("auctionId", tb.getAuctionId());
+		goodsJson.put("imgList", finalImgList);
+		goodsJson.put("title", tb.getTitle());
+		goodsJson.put("userType", tb.getUserType() == 1 ? 2 : 1);
+		goodsJson.put("price", tb.getReservePrice().toString());
+		goodsJson.put("zkPrice", tb.getZkPrice().toString());
 
 		// 30澶╅攢閲�
-		goods.put("saleCount", TaoBaoUtil.getSaleCount(tb.getBiz30day()));
+		goodsJson.put("saleCount", TaoBaoUtil.getSaleCount(tb.getBiz30day()));
 
 		// 鍒嗕韩璧�
 		BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(tb);
@@ -1802,7 +1786,7 @@
 		LogHelper.test(String.format("PID: uid-%s  pid-%s", uid + "", pid));
 
 		// 鏄惁鏈夊埜
-		goods.put("coupon", StringUtil.isNullOrEmpty(tb.getCouponInfo()) ? false : true);
+		goodsJson.put("coupon", StringUtil.isNullOrEmpty(tb.getCouponInfo()) ? false : true);
 
 		// 棰嗗埜浜哄垪琛�
 		List<ShamUser> listCouponUser = new ArrayList<ShamUser>();
@@ -1831,19 +1815,21 @@
 			tb.setCouponLinkTaoToken(token);
 
 			// 鏈嶅姟绔浆閾�
-			if (convertInServer && !StringUtil.isNullOrEmpty(tb.getCouponLink())) {
-				couponInfo.put("couponUrl", tb.getCouponLink());
-			} else {
-				couponInfo.put("couponUrl",
-						TaoBaoCouponUtil.getCoupleUrl(tb.getCouponActivityId() + "", pid, tb.getAuctionId() + ""));
-			}
+			// if (convertInServer &&
+			// !StringUtil.isNullOrEmpty(tb.getCouponLink())) {
+			couponInfo.put("couponUrl", tb.getCouponLink());
+			// } else {
+			// couponInfo.put("couponUrl",
+			// TaoBaoCouponUtil.getCoupleUrl(tb.getCouponActivityId() + "", pid,
+			// tb.getAuctionId() + ""));
+			// }
 
 			couponInfo.put("couponAmount", NumberUtil.subZeroAndDot(tb.getCouponAmount().toString()));
 			couponInfo.put("couponTime", "浣跨敤鏈熼檺锛�" + tb.getCouponEffectiveStartTime().replace("-", ".") + "-"
 					+ tb.getCouponEffectiveEndTime().replace("-", "."));
 			// 鍒哥殑鍙d护
 			couponInfo.put("couponToken", token);
-			goods.put("couponInfo", couponInfo);
+			goodsJson.put("couponInfo", couponInfo);
 
 			if (tb.getBiz30day() >= 1000) {
 				// 棰嗗埜浜哄垪琛�
@@ -1856,7 +1842,7 @@
 			BigDecimal proportion = manageService.getFanLiRate();
 			hongBao = TaoBaoUtil.getGoodsHongBaoInfo(tb, proportion);
 		}
-		goods.put("hongBao", hongBao);
+		goodsJson.put("hongBao", hongBao);
 
 		data.put("tbPidInfo", clientTBPid);
 
@@ -1874,7 +1860,7 @@
 			else
 				jumpUrl = tb.getAuctionUrl();
 		}
-		goods.put("jumpUrl", jumpUrl);
+		goodsJson.put("jumpUrl", jumpUrl);
 
 		TaoBaoShopInfo tbShopInfo = redisManager.getTBShopInfo(tb.getShopTitle(), tb.getSellerId(), tb.getAuctionId());
 		if (tbShopInfo != null) {
@@ -1886,7 +1872,7 @@
 			}
 		}
 		// 搴楅摵
-		goods.put("shopInfo", tbShopInfo);
+		goodsJson.put("shopInfo", tbShopInfo);
 
 		// 鍒嗕韩璺緞
 		String shareUrl = String.format("%s?id=" + tb.getAuctionId(), Constant.systemCommonConfig.getAppShareInfoUrl());
@@ -1900,7 +1886,7 @@
 		data.put("storageState", storageState);
 		data.put("shareUrl", shareUrl);
 
-		data.put("goods", goods);
+		data.put("goods", goodsJson);
 		data.put("shareUsers", listShareUser);
 		data.put("couponUsers", listCouponUser);
 		data.put("detailWebUrl", "http://apph5.yeshitv.com/apppage/goods_img.html?id=" + id);
@@ -2024,20 +2010,48 @@
 
 		List<TaoBaoGoodsBriefExtra> listExtra = new ArrayList<TaoBaoGoodsBriefExtra>();
 
-		goodsList.parallelStream().forEach(goods -> {
-			// 鑾峰彇璇︽儏
-			TaoBaoGoodsBrief taoBaoGoodsBrief = null;
-			try {
-				taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(goods.getAuctionId());
-			} catch (Exception e) {
-				e.printStackTrace();
-			}
+		TaoKeAppInfo app = new TaoKeAppInfo();
+		app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);
+		app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
+		app.setAdzoneId(TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT.split("_")[3]);
+		app.setPid(TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT);
 
-			if (taoBaoGoodsBrief != null) {
-				listExtra.add(TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), ""));
-			}
+		List<Long> ids = new ArrayList<>();
+		for (TaoBaoGoodsBrief goods : goodsList)
+			ids.add(goods.getAuctionId());
 
-		});
+		try {
+			goodsList = TaoKeApiUtil.getBatchGoodsInfo(ids);
+		} catch (TaoKeApiException e1) {
+			e1.printStackTrace();
+		} catch (TaobaoGoodsDownException e1) {
+			e1.printStackTrace();
+		}
+
+		if (goodsList != null)
+			goodsList.parallelStream().forEach(goods -> {
+
+				// 鑾峰彇璇︽儏
+				TaoBaoGoodsBrief taoBaoGoodsBrief = null;
+				try {
+					taoBaoGoodsBrief = taoBaoGoodsCacheUtil.getCommonTaoBaoGoodsInfo(goods.getAuctionId());
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+
+				if (taoBaoGoodsBrief == null) {
+					TaoBaoGoodsBrief newGoods = TaoKeApiUtil.specialConvertCoupon(goods.getAuctionId(), app);
+					goods.setCouponInfo(newGoods.getCouponInfo());
+					goods.setCouponLink(newGoods.getCouponLink());
+					goods.setTkRate(newGoods.getTkRate());
+					taoBaoGoodsBrief = goods;
+				}
+
+				if (taoBaoGoodsBrief != null) {
+					listExtra.add(TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(), ""));
+				}
+
+			});
 
 		List<TaoBaoGoodsBrief> listQuality = new ArrayList<TaoBaoGoodsBrief>();
 		// 鍒犻櫎鎺ㄨ崘

--
Gitblit v1.8.0