From 88b54772dbcf5ecab1e2316e4e4626ac901b8908 Mon Sep 17 00:00:00 2001
From: yujian <yujian>
Date: 星期二, 22 一月 2019 15:58:24 +0800
Subject: [PATCH] 邀请码添加返回状态
---
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java | 40 +++++++++++++++++++++++++++++++---------
1 files changed, 31 insertions(+), 9 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 035b056..51c30a4 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
@@ -12,16 +12,19 @@
import com.google.gson.Gson;
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoGoodsBriefMapper;
+import com.yeshi.fanli.entity.goods.CommonGoods;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
+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.service.inter.activity.ActivityService;
-import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;
+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;
import com.yeshi.fanli.util.StringUtil;
+import com.yeshi.fanli.util.factory.CommonGoodsFactory;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
@Service
@@ -39,7 +42,7 @@
private TaoBaoGoodsBriefMapper taoBaoGoodsBriefMapper;
@Resource
- private CollectionGoodsService collectionGoodsService;
+ private CommonGoodsService commonGoodsService;
@Override
public void startUpdate() {
@@ -58,7 +61,7 @@
}
} catch (TaobaoGoodsDownException e) {
- downTaoBaoGoods(goods.getAuctionId());
+ offlineTaoBaoGoods(goods.getAuctionId());
} catch (Exception e) {
}
@@ -80,7 +83,7 @@
@Transactional
@Override
- public void downTaoBaoGoods(Long auctionId) {
+ public void offlineTaoBaoGoods(Long auctionId) {
// 鍒犻櫎棣栭〉鎺ㄨ崘鏁版嵁
recommendSectionGoodsService.deleteRecommendSectionGoodsByTbAuctionId(auctionId);
// 鏇存柊鍔ㄦ�佹暟鎹�
@@ -91,6 +94,9 @@
// 鍒犻櫎鍟嗗搧鏈韩鏁版嵁
taoBaoGoodsBriefMapper.deleteByAuctionId(auctionId);
+
+ // 鏇存柊绠�鐗堝晢鍝佺姸鎬佷负涓嬫灦
+ commonGoodsService.offlineCommonGoods(auctionId, CommonGoods.GOODS_TYPE_TB);
}
@Transactional
@@ -103,7 +109,11 @@
throw new TaobaoGoodsUpdateException(2, "鍟嗗搧ID涓虹┖");
// 鏇存柊鏀惰棌淇℃伅
- collectionGoodsService.updateCollectionGoods(goods);
+ try {
+ commonGoodsService.updateCommonGoods(CommonGoodsFactory.create(goods));
+ } catch (CommonGoodsException e) {
+ e.printStackTrace();
+ }
List<TaoBaoGoodsBrief> goodsList = taoBaoGoodsBriefMapper.queryByAuctionId(goods.getAuctionId());
if (goodsList != null)
@@ -114,6 +124,9 @@
taoBaoGoodsBriefMapper.updateByPrimaryKeySelective(updateGoods);
}
+
+ // 鏇存柊鍔ㄦ�佸晢鍝�
+ activityService.updateRecommendActivityGoods(goods);
}
@Override
@@ -182,14 +195,23 @@
@Override
public void updateTaoBaoGoods(List<TaoBaoGoodsBrief> goodsList) throws TaobaoGoodsUpdateException {
- if (goodsList == null)
- return;
+ if (goodsList == null || goodsList.size() == 0)
+ throw new TaobaoGoodsUpdateException(1, "鍟嗗搧鍒楄〃涓虹┖");
+
List<TaoBaoGoodsBrief> updateList = new ArrayList<>();
+
for (TaoBaoGoodsBrief goods : goodsList) {
- if (goods.getId() == null || goods.getId() == 0L)
+
+ if (goods.getId() == null || goods.getId() == 0L) {
throw new TaobaoGoodsUpdateException(1, "鍟嗗搧涓婚敭ID涓虹┖");
- updateList.add(goods);
+ }
+
+ TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(goods);
+ updateGoods.setCreatetime(goods.getCreatetime());
+
+ updateList.add(updateGoods);
}
+
taoBaoGoodsBriefMapper.updateBatchSelective(updateList);
}
--
Gitblit v1.8.0