admin
2020-05-06 24a8d17e007545f7426c48352109aa1a9c6587ee
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java
@@ -21,8 +21,8 @@
import com.yeshi.fanli.dao.goods.taobao.dataoke.DaTaoKeGoodsDetailV2Dao;
import com.yeshi.fanli.dto.dataoke.DaTaoKeGoodsResult;
import com.yeshi.fanli.dto.dataoke.DingDongQiangDTO;
import com.yeshi.fanli.dto.taobao.DaTaoKeFilterResult;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetail;
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailV2Service;
@@ -160,11 +160,17 @@
      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<>();
      for (DaTaoKeDetailV2 goods : dtList)
         map.put(goods.getGoodsId(), goods);
      if (dtList != null)
         for (DaTaoKeDetailV2 goods : dtList)
            map.put(goods.getGoodsId(), goods);
      for (TaoBaoGoodsBrief goods : goodsList) {
         DaTaoKeDetailV2 detail = map.get(goods.getAuctionId());
         goods = DaTaoKeUtil.filterTaoBaoGoods(goods, detail);
@@ -172,20 +178,6 @@
      return goodsList;
   }
   @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;
   }
   @Override
   public List<DaTaoKeDetailV2> listByIds(List<Long> idsList) {
@@ -211,6 +203,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);
   }
@@ -253,11 +247,23 @@
   public List<DaTaoKeDetailV2> listPreTLJBuyGoods(int page) {
      if (page == 1) {
         List<DaTaoKeDetailV2> listPreGoodsList = new ArrayList<>();
         // 热销榜
         DaTaoKeGoodsResult result = DaTaoKeApiUtil.getRankingList(DaTaoKeApiUtil.RANK_TYPE_HOT, null);
         if (result != null && result.getGoodsList() != null)
            listPreGoodsList.addAll(result.getGoodsList());
         // 复购榜
         result = DaTaoKeApiUtil.getRankingList(DaTaoKeApiUtil.RANK_TYPE_REBUY, null);
         if (result != null && result.getGoodsList() != null)
            listPreGoodsList.addAll(result.getGoodsList());
         // 综合搜索
         try {
            result = DaTaoKeApiUtil.search("", null, null, null, 1, 200, DaTaoKeApiUtil.SORT_DEFAULT);
            if (result == null)
               throw new Exception();
         } catch (Exception e) {// 异常重复一次
            result = DaTaoKeApiUtil.search("", null, null, null, 1, 200, DaTaoKeApiUtil.SORT_DEFAULT);
         }
         if (result != null && result.getGoodsList() != null)
            listPreGoodsList.addAll(result.getGoodsList());
@@ -329,17 +335,38 @@
   @Async
   private void updateGoods(Long id) {
      DaTaoKeDetailV2 v2 = DaTaoKeApiUtil.getGoodsDetail(id);
      // TODO暂时关闭服务
      DaTaoKeDetailV2 v2 = null;// DaTaoKeApiUtil.getGoodsDetail(id);
      if (v2 != null)
         daTaoKeGoodsDetailV2Dao.save(v2);
   }
   private List<DaTaoKeDetailV2> getDefaultDingDongQiang() {
      // 按更新时间加
      DaTaoKeGoodsResult result = DaTaoKeApiUtil.getRankingList(DaTaoKeApiUtil.RANK_TYPE_TIME, null);
      if (result != null && result.getGoodsList().size() > 0) {
         List<DaTaoKeDetailV2> finalList = new ArrayList<>();
         Collections.shuffle(result.getGoodsList());
         finalList.addAll(result.getGoodsList().subList(0,
               result.getGoodsList().size() > 8 ? 8 : result.getGoodsList().size()));
         for (DaTaoKeDetailV2 detail : finalList) {
            detail.setCouponReceiveNum(detail.getCouponTotalNum() - (int) (200 + Math.random() * 1000));
            if (detail.getCouponTotalNum() - detail.getCouponReceiveNum() <= 0)
               detail.setCouponReceiveNum(detail.getCouponTotalNum());
         }
         return finalList;
      }
      return null;
   }
   @Cacheable(value = "daTaoKeGoodsCache", key = "'getDingDongQiangData-'+#time")
   @Override
   public List<DaTaoKeDetailV2> getDingDongQiangData(String time) {
      List<DingDongQiangDTO> list = getDingDongQiangData();
      if (list == null)
         return null;
      if (list == null || list.size() == 0) {
         return getDefaultDingDongQiang();
      }
      Map<String, DingDongQiangDTO> map = new HashMap<>();
      for (DingDongQiangDTO dto : list)
         map.put(dto.getTime(), dto);
@@ -351,9 +378,22 @@
            idList.add(td.getId());
         List<DaTaoKeDetailV2> finalList = listByIds(idList);
         if (finalList.size() != idList.size()) {
            for (Long id : idList)
               updateGoods(id);
            for (Long id : idList) {
               // updateGoods(id);
               // TODO 不能异步调用
            }
            finalList = listByIds(idList);
         }
         // 如果商品数小于4,需要再加商品
         if (finalList == null || finalList.size() <= 3) {
            // 按更新时间加
            List<DaTaoKeDetailV2> latestList = daTaoKeGoodsDetailV2Dao.listPreShareHotGoods(0, 50, "updateTime",
                  new BigDecimal("0.5"));
            if (latestList != null && latestList.size() > 0) {
               Collections.shuffle(latestList);
               finalList.addAll(latestList.subList(0, latestList.size() > 8 ? 8 : latestList.size()));
            }
         }
         for (DaTaoKeDetailV2 detail : finalList) {
@@ -362,8 +402,59 @@
               detail.setCouponReceiveNum(detail.getCouponTotalNum());
         }
         return finalList;
      } else {
         return getDefaultDingDongQiang();
      }
      return null;
   }
   @Override
   public List<String> getDingDongQiangTime() {
      List<DingDongQiangDTO> list = getDingDongQiangData();
      List<String> dateList = new ArrayList<>();
      for (DingDongQiangDTO dto : list) {
         dateList.add(dto.getTime());
      }
      return dateList;
   }
   @Override
   public List<DaTaoKeDetailV2> listByMaxPrice(Integer cid, BigDecimal maxPrice, String sortName, int page,
         int count) {
      return daTaoKeGoodsDetailV2Dao.listByMaxPrice(cid, maxPrice, sortName, (page - 1) * count, count);
   }
   @Override
   public int countByMaxPrice(Integer cid, BigDecimal maxPrice) {
      return (int) daTaoKeGoodsDetailV2Dao.countByMaxPrice(cid, maxPrice);
   }
   @Override
   public List<DaTaoKeDetailV2> listBySellerId(long start, int count, Long sellerId) {
      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 DaTaoKeFilterResult filterTaoBaoGoods(TaoBaoGoodsBrief goods) {
      List<Long> goodsIdList = new ArrayList<>();
      goodsIdList.add(goods.getAuctionId());
      List<DaTaoKeDetailV2> daTaoKeList = listByGoodsIds(goodsIdList);
      if (daTaoKeList == null || daTaoKeList.size() == 0)
         return new DaTaoKeFilterResult(goods, DaTaoKeFilterResult.FILTER_TYPE_NONE);
      // 重新设置标题与券价格
      return DaTaoKeUtil.filterTaoBaoGoods(goods, daTaoKeList.get(0), true);
   }
}