From 353ac53e5e8093e36c69fbaa7b26160bb2d97f9d Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期三, 15 四月 2020 16:09:24 +0800 Subject: [PATCH] 消息订阅 --- fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java | 50 +++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 39 insertions(+), 11 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java index 0ebe200..38a3a07 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java @@ -28,6 +28,7 @@ import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.TimeUtil; +import com.yeshi.fanli.util.VersionUtil; import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil; import com.yeshi.fanli.util.taobao.DaTaoKeUtil; import com.yeshi.fanli.util.taobao.TaoBaoUtil; @@ -159,8 +160,13 @@ for (TaoBaoGoodsBrief goods : goodsList) goodsIdList.add(goods.getAuctionId()); - List<DaTaoKeDetailV2> dtList = listByGoodsIds(goodsIdList); + List<DaTaoKeDetailV2> dtList = null; + try { + dtList = listByGoodsIds(goodsIdList); + } catch (Exception e) { + + } Map<Long, DaTaoKeDetailV2> map = new HashMap<>(); if (dtList != null) for (DaTaoKeDetailV2 goods : dtList) @@ -174,17 +180,8 @@ @Override public TaoBaoGoodsBrief filterTaoBaoGoods(TaoBaoGoodsBrief goods) { - List<Long> goodsIdList = new ArrayList<>(); - goodsIdList.add(goods.getAuctionId()); - List<DaTaoKeDetailV2> daTaoKeList = listByGoodsIds(goodsIdList); - if (daTaoKeList == null || daTaoKeList.size() == 0) - return goods; - - // 閲嶆柊璁剧疆鏍囬涓庡埜浠锋牸 - goods = DaTaoKeUtil.filterTaoBaoGoods(goods, daTaoKeList.get(0)); - - return goods; + return filterTaoBaoGoods(goods, null, null); } @Override @@ -211,6 +208,8 @@ @Override public List<DaTaoKeDetailV2> getGoodsNotInList(Long cid, List<Long> listId, int count) { + if (cid != null && cid == 0L) + cid = null; return daTaoKeGoodsDetailV2Dao.getGoodsNotInList(cid, listId, count); } @@ -440,4 +439,33 @@ return daTaoKeGoodsDetailV2Dao.listBySellerId((int) start, count, sellerId); } + @Override + public DaTaoKeDetailV2 selectByAuctionId(Long auctionId) { + return daTaoKeGoodsDetailV2Dao.selectByAuctionId(auctionId); + } + + @Cacheable(value = "daTaoKeGoodsCache", key = "'selectByAuctionId-'+#auctionId") + @Override + public DaTaoKeDetailV2 selectByAuctionIdCache(Long auctionId) { + return selectByAuctionId(auctionId); + } + + @Override + public TaoBaoGoodsBrief filterTaoBaoGoods(TaoBaoGoodsBrief goods, String platform, String version) { + List<Long> goodsIdList = new ArrayList<>(); + goodsIdList.add(goods.getAuctionId()); + + List<DaTaoKeDetailV2> daTaoKeList = listByGoodsIds(goodsIdList); + if (daTaoKeList == null || daTaoKeList.size() == 0) + return goods; + + if (platform != null && version != null && VersionUtil.greaterThan_2_1(platform, version)) { + // 閲嶆柊璁剧疆鏍囬涓庡埜浠锋牸 + goods = DaTaoKeUtil.filterTaoBaoGoods(goods, daTaoKeList.get(0), true); + } else + goods = DaTaoKeUtil.filterTaoBaoGoods(goods, daTaoKeList.get(0), false); + + return goods; + } + } -- Gitblit v1.8.0