From 3fc84b5d4b36ce9ab5cea84ee1b54942c8e04ef9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 08 八月 2019 16:55:52 +0800
Subject: [PATCH] 拼多多短链修改

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java |   40 +++++++++++++++++++++++++++-------------
 1 files changed, 27 insertions(+), 13 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java
index 38cc76b..517cac5 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java
@@ -22,6 +22,7 @@
 import com.yeshi.fanli.exception.taobao.TaoKeApiException;
 import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
 import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsService;
+import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
 import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService;
 import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailV2Service;
 import com.yeshi.fanli.util.StringUtil;
@@ -47,6 +48,9 @@
 	@Resource
 	private EhCacheCacheManager ehCacheCacheManager;
 
+	@Resource
+	private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;
+
 	@Override
 	public void addTLJBuyGoods(TLJBuyGoods goods, TaoKeAppInfo taoKeAppInfo) {
 		if (goods == null || StringUtil.isNullOrEmpty(goods.getDay()) || goods.getGoods() == null)
@@ -62,7 +66,17 @@
 	@Cacheable(value = "commonContentCache", key = "'tljBuy-listByDay'+#day")
 	@Override
 	public List<TLJBuyGoods> listByDay(String day) {
-		return listByDay(day, 10);
+		List<TLJBuyGoods> list = listByDay(day, 10);
+		// if (list.size() <= 10)
+		// return list;
+		// else {
+		// List<TLJBuyGoods> newList = new ArrayList<>();
+		// for (int i = 0; i < 10; i++) {
+		// newList.add(list.get(i));
+		// }
+		// return newList;
+		// }
+		return list;
 	}
 
 	@Override
@@ -70,19 +84,8 @@
 		List<TLJBuyGoods> list = tljBuyGoodsDao.listByDayOrderByUpdateTime(day, 1, count);
 		List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();
 		if (list != null) {
-			for (TLJBuyGoods shg : list) {
-				// 璁$畻鎺ㄥ箍绾㈠寘
-				BigDecimal spreadMoney = TaoBaoUtil.getGoodsHongBaoMoney(shg.getGoods(),
-						TaoBaoConstant.OWN_BUY_WITHOUT_FANLI_RATE);
-				BigDecimal finalPrice = TaoBaoUtil.getAfterUseCouplePrice(shg.getGoods());
-
-				// 鎺ㄥ箍绾㈠寘 涓嶈兘灏忎簬1,浠锋牸涓嶈兘澶т簬30
-				if (spreadMoney.compareTo(new BigDecimal(1.0)) < 0 || finalPrice.compareTo(new BigDecimal(30)) >= 0) {
-					continue;
-				}
-
+			for (TLJBuyGoods shg : list)
 				goodsList.add(shg.getGoods());
-			}
 		}
 		// 杩囨护涓嬬嚎鍟嗗搧
 		goodsList = taoBaoGoodsBriefService.filterOffLineGoods(goodsList);
@@ -98,6 +101,15 @@
 				list.remove(j);
 				j--;
 			}
+		}
+
+		// 鍔犲叆鏇存柊闃熷垪
+		//
+		try {
+			for (TLJBuyGoods tljGoods : list)
+				if (tljGoods != null && tljGoods.getGoods() != null && tljGoods.getGoods().getAuctionId() != null)
+					taoBaoGoodsUpdateService.addUpdateQueueAsync(tljGoods.getGoods().getAuctionId());
+		} catch (Exception e) {
 		}
 		return list;
 	}
@@ -192,6 +204,8 @@
 				TLJBuyGoods.getGoods().setCouponTotalCount(goods.getCouponTotalCount());
 				TLJBuyGoods.getGoods().setBiz30day(goods.getBiz30day());
 				TLJBuyGoods.getGoods().setTkRate(goods.getTkRate());
+				TLJBuyGoods.getGoods().setId(goods.getId());
+				TLJBuyGoods.getGoods().setAuctionId(goods.getAuctionId());
 				tljBuyGoodsDao.save(TLJBuyGoods);
 			}
 	}

--
Gitblit v1.8.0