From cbe9871d77e3586015f26d7e7c78d254bb8ec6f6 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 19 七月 2019 17:25:55 +0800
Subject: [PATCH] 增加订单灰度测试代码
---
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java | 35 +++++++++++++++++++++++++++--------
1 files changed, 27 insertions(+), 8 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 c90925e..8211806 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
@@ -21,6 +21,8 @@
import com.yeshi.fanli.service.inter.activity.ActivityService;
import com.yeshi.fanli.service.inter.goods.CommonGoodsService;
import com.yeshi.fanli.service.inter.lable.QualityFactoryService;
+import com.yeshi.fanli.service.inter.taobao.ShareHotGoodsService;
+import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
import com.yeshi.fanli.util.BeanUtil;
import com.yeshi.fanli.util.StringUtil;
@@ -41,6 +43,12 @@
@Resource
private CommonGoodsService commonGoodsService;
+
+ @Resource
+ private ShareHotGoodsService shareHotGoodsService;
+
+ @Resource
+ private TLJBuyGoodsService tljBuyGoodsService;
@Override
public void startUpdate() {
@@ -90,6 +98,10 @@
// 鏇存柊绠�鐗堝晢鍝佺姸鎬佷负涓嬫灦
commonGoodsService.offlineCommonGoods(auctionId, CommonGoods.GOODS_TYPE_TB);
+
+ // 鍒嗕韩鐖嗘鏁版嵁鍒犻櫎
+ shareHotGoodsService.deleteByGoodsId(auctionId);
+
}
@Transactional
@@ -101,6 +113,8 @@
if (goods.getAuctionId() == null || goods.getAuctionId() == 0)
throw new TaobaoGoodsUpdateException(2, "鍟嗗搧ID涓虹┖");
+ // 璁剧疆鍟嗗搧姝ｅ父涓婄嚎
+ goods.setState(0);
// 鏇存柊鏀惰棌淇℃伅
try {
commonGoodsService.updateCommonGoods(CommonGoodsFactory.create(goods));
@@ -118,6 +132,12 @@
// 鏇存柊鍔ㄦ�佸晢鍝�
activityService.updateRecommendActivityGoods(goods);
+
+ // 鏇存柊鍒嗕韩搴撶殑鍟嗗搧
+ shareHotGoodsService.updateShareGoods(goods);
+
+ // 鏇存柊鑷喘绔嬪噺搴撳晢鍝�
+ tljBuyGoodsService.updateGoods(goods);
}
@Override
@@ -197,7 +217,7 @@
if (goods.getId() == null || goods.getId() == 0L) {
throw new TaobaoGoodsUpdateException(1, "鍟嗗搧涓婚敭ID涓虹┖");
}
-
+
// 闇�瑕佹洿鏂扮殑淇℃伅
TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(goods);
updateGoods.setCreatetime(goods.getCreatetime());
@@ -206,8 +226,7 @@
taoBaoGoodsBriefMapper.updateBatchSelective(updateList);
}
-
-
+
@Override
public List<Long> listNeedUpdateGoodsId(long start, int count, int hour) {
return taoBaoGoodsBriefMapper.listNeedUpdateGoodsId(start, count, hour);
@@ -220,27 +239,27 @@
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) {
--
Gitblit v1.8.0