From c007868c62c7da5c9ce1bf0e77d9e5f8619826e4 Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期三, 12 六月 2019 12:24:09 +0800
Subject: [PATCH] 查询默认有效调整
---
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java | 75 ++++++++++++++++++++++++++-----------
1 files changed, 53 insertions(+), 22 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java
index 599c960..c90925e 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java
@@ -17,9 +17,9 @@
import com.yeshi.fanli.exception.goods.CommonGoodsException;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsUpdateException;
+import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.activity.ActivityService;
import com.yeshi.fanli.service.inter.goods.CommonGoodsService;
-import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService;
import com.yeshi.fanli.service.inter.lable.QualityFactoryService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
import com.yeshi.fanli.util.BeanUtil;
@@ -29,8 +29,6 @@
@Service
public class TaoBaoGoodsUpdateServiceImpl implements TaoBaoGoodsUpdateService {
- @Resource
- private RecommendSectionGoodsService recommendSectionGoodsService;
@Resource
private ActivityService activityService;
@@ -71,11 +69,8 @@
@Transactional
@Override
public void deleteTaoBaoGoods(Long auctionId) {
- // 鍒犻櫎棣栭〉鎺ㄨ崘鏁版嵁
- recommendSectionGoodsService.deleteRecommendSectionGoodsByTbAuctionId(auctionId);
-
// 鍒犻櫎绮鹃�夊簱鐩稿叧鐨勬暟鎹�
- qualityFactoryService.deleteByTbAuctionId(auctionId);
+ qualityFactoryService.deleteByTaoBaoGoodsId(auctionId);
// 鍒犻櫎鍟嗗搧鏈韩鏁版嵁
taoBaoGoodsBriefMapper.deleteByAuctionId(auctionId);
@@ -84,13 +79,11 @@
@Transactional
@Override
public void offlineTaoBaoGoods(Long auctionId) {
- // 鍒犻櫎棣栭〉鎺ㄨ崘鏁版嵁
- recommendSectionGoodsService.deleteRecommendSectionGoodsByTbAuctionId(auctionId);
// 鏇存柊鍔ㄦ�佹暟鎹�
activityService.downTaoBaoGoods(auctionId);
// 鍒犻櫎绮鹃�夊簱鐩稿叧鐨勬暟鎹�
- qualityFactoryService.deleteByTbAuctionId(auctionId);
+ qualityFactoryService.deleteByTaoBaoGoodsId(auctionId);
// 鍒犻櫎鍟嗗搧鏈韩鏁版嵁
taoBaoGoodsBriefMapper.deleteByAuctionId(auctionId);
@@ -115,15 +108,13 @@
e.printStackTrace();
}
- List<TaoBaoGoodsBrief> goodsList = taoBaoGoodsBriefMapper.queryByAuctionId(goods.getAuctionId());
- if (goodsList != null)
- for (TaoBaoGoodsBrief tb : goodsList) {
- goods.setId(tb.getId());
- TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(goods);
- System.out.println("鏇寸粏淇℃伅:" + new Gson().toJson(updateGoods));
- taoBaoGoodsBriefMapper.updateByPrimaryKeySelective(updateGoods);
-
- }
+ TaoBaoGoodsBrief tb = taoBaoGoodsBriefMapper.selectByPrimaryKey(goods.getAuctionId());
+ if (tb != null) {
+ goods.setId(tb.getId());
+ TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(goods);
+ System.out.println("鏇寸粏淇℃伅:" + new Gson().toJson(updateGoods));
+ taoBaoGoodsBriefMapper.updateByPrimaryKeySelective(updateGoods);
+ }
// 鏇存柊鍔ㄦ�佸晢鍝�
activityService.updateRecommendActivityGoods(goods);
@@ -190,6 +181,7 @@
updateGoods.setRootCategoryName(goods.getRootCategoryName());
updateGoods.setLeafCatId(goods.getLeafCatId());
updateGoods.setLeafName(goods.getLeafName());
+ updateGoods.setMaterialLibType(goods.getMaterialLibType());
return updateGoods;
}
@@ -202,18 +194,57 @@
List<TaoBaoGoodsBrief> updateList = new ArrayList<>();
for (TaoBaoGoodsBrief goods : goodsList) {
-
if (goods.getId() == null || goods.getId() == 0L) {
throw new TaobaoGoodsUpdateException(1, "鍟嗗搧涓婚敭ID涓虹┖");
}
-
+
+ // 闇�瑕佹洿鏂扮殑淇℃伅
TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(goods);
updateGoods.setCreatetime(goods.getCreatetime());
-
updateList.add(updateGoods);
}
taoBaoGoodsBriefMapper.updateBatchSelective(updateList);
}
+
+
+ @Override
+ public List<Long> listNeedUpdateGoodsId(long start, int count, int hour) {
+ return taoBaoGoodsBriefMapper.listNeedUpdateGoodsId(start, count, hour);
+ }
+ @Override
+ public void updateByTaoKeGoodsDetail(Long id) {
+ try {
+ TaoBaoGoodsBrief oldGoods = taoBaoGoodsBriefMapper.selectByPrimaryKey(id);
+ if (oldGoods == null) {
+ return;
+ }
+
+ TaoBaoGoodsBrief newGoods = TaoKeApiUtil.searchGoodsDetail(id);
+ if (newGoods == null) {
+ return;
+ }
+
+ // 鏇存柊绮鹃�夊晢鍝�
+ newGoods.setId(id);
+ TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(newGoods);
+ taoBaoGoodsBriefMapper.updateByPrimaryKeySelective(updateGoods);
+
+ // 鏇存柊鍔ㄦ�佸晢鍝�
+ activityService.updateRecommendActivityGoods(newGoods);
+
+ // 鏇存柊鏀惰棌淇℃伅
+ try {
+ commonGoodsService.updateCommonGoods(CommonGoodsFactory.create(newGoods));
+ } catch (CommonGoodsException e) {
+ e.printStackTrace();
+ }
+
+ } catch (TaobaoGoodsDownException e) {
+ offlineTaoBaoGoods(id);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+ }
}
--
Gitblit v1.8.0