From 207dc8655711cddac2653e18b51e58a88dba2084 Mon Sep 17 00:00:00 2001
From: yj <Administrator@192>
Date: 星期五, 06 三月 2020 18:14:36 +0800
Subject: [PATCH] 发圈处理
---
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java | 81 +++++++++++++++++++++++++++++++++++-----
1 files changed, 71 insertions(+), 10 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 87078e9..d9c77f6 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
@@ -159,11 +159,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);
@@ -210,6 +216,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);
}
@@ -252,11 +260,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());
@@ -328,17 +348,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);
@@ -350,8 +391,10 @@
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);
}
@@ -372,8 +415,9 @@
detail.setCouponReceiveNum(detail.getCouponTotalNum());
}
return finalList;
+ } else {
+ return getDefaultDingDongQiang();
}
- return null;
}
@Override
@@ -386,4 +430,21 @@
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);
+ }
+
}
--
Gitblit v1.8.0