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