From 9a78d406f8b821117c78a1bc717fe4b5813656b1 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 06 八月 2019 09:57:51 +0800
Subject: [PATCH] 首页底部推荐，详情页猜你喜欢异常保护
---
fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java | 39 +++++++++++++++++++++++++++++++++++++--
1 files changed, 37 insertions(+), 2 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 4a5f1a1..fdb8ae5 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,6 +12,7 @@
import com.google.gson.Gson;
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoGoodsBriefMapper;
+import com.yeshi.fanli.dao.taobao.TaoBaoGoodsUpdateDao;
import com.yeshi.fanli.entity.goods.CommonGoods;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.exception.goods.CommonGoodsException;
@@ -24,8 +25,9 @@
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.CMQManager;
import com.yeshi.fanli.util.StringUtil;
+import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;
import com.yeshi.fanli.util.factory.CommonGoodsFactory;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
@@ -49,6 +51,12 @@
@Resource
private TLJBuyGoodsService tljBuyGoodsService;
+
+ @Resource
+ private TaoBaoGoodsCacheUtil taoBaoGoodsCacheUtil;
+
+ @Resource
+ private TaoBaoGoodsUpdateDao taoBaoGoodsUpdateDao;
@Override
public void startUpdate() {
@@ -101,7 +109,6 @@
// 鍒嗕韩鐖嗘鏁版嵁鍒犻櫎
shareHotGoodsService.deleteByGoodsId(auctionId);
-
}
@Transactional
@@ -138,6 +145,9 @@
// 鏇存柊鑷喘绔嬪噺搴撳晢鍝�
tljBuyGoodsService.updateGoods(goods);
+
+ // 鎬昏鍟嗗搧鏇存柊
+// updateImplTBGoods(goods);
}
@Override
@@ -265,4 +275,29 @@
LogHelper.errorDetailInfo(e);
}
}
+
+ /**
+ * 鏇存柊閲嶈鐨勬窐瀹濇暟鎹�
+ *
+ * @param goods
+ */
+ public void updateImplTBGoods(TaoBaoGoodsBrief goods) {
+ if (goods == null)
+ return;
+ if (!taoBaoGoodsCacheUtil.needUpdate(goods.getAuctionId())) {
+ return;
+ }
+ goods.setUpdatetime(new Date());
+ taoBaoGoodsUpdateDao.save(goods);
+ taoBaoGoodsCacheUtil.addUpdateHistory(goods.getAuctionId());
+ }
+
+ @Override
+ public void addUpdateQueue(Long auctionId) {
+ if (taoBaoGoodsCacheUtil.canAddToUpdateQueue(auctionId)) {
+ // 娣诲姞鍒版洿鏂伴槦鍒�
+ CMQManager.getInstance().addTBImpGoodsUpdate(auctionId);
+ taoBaoGoodsCacheUtil.addAddToQueueHistory(auctionId);
+ }
+ }
}
--
Gitblit v1.8.0