From 3727469752a977dde6327e2c48d761b20b565d3d Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 15 七月 2022 09:19:21 +0800
Subject: [PATCH] 商品ID字符串化

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java |   38 ++++++++++++++++++--------------------
 1 files changed, 18 insertions(+), 20 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 bab03ec..53f7b1a 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
@@ -99,7 +99,7 @@
 
     @Transactional
     @Override
-    public void deleteTaoBaoGoods(Long auctionId) {
+    public void deleteTaoBaoGoods(String auctionId) {
         // 鍒犻櫎绮鹃�夊簱鐩稿叧鐨勬暟鎹�
         qualityFactoryGoodsUpdateService.deleteByTaoBaoGoodsId(auctionId);
 
@@ -109,7 +109,7 @@
 
     @Transactional
     @Override
-    public void offlineTaoBaoGoods(Long auctionId) {
+    public void offlineTaoBaoGoods(String auctionId) {
         // 鏇存柊鍔ㄦ�佹暟鎹�
         activityGoodsUpdateService.downTaoBaoGoods(auctionId);
 
@@ -134,7 +134,7 @@
         if (goods == null)
             throw new TaobaoGoodsUpdateException(1, "鍟嗗搧涓虹┖");
 
-        if (goods.getAuctionId() == null || goods.getAuctionId() == 0)
+        if (StringUtil.isNullOrEmpty( goods.getAuctionId()))
             throw new TaobaoGoodsUpdateException(2, "鍟嗗搧ID涓虹┖");
 
         // 璁剧疆鍟嗗搧姝ｅ父涓婄嚎
@@ -146,7 +146,7 @@
             e.printStackTrace();
         }
 
-        TaoBaoGoodsBrief tb = taoBaoGoodsBriefMapper.selectByPrimaryKey(goods.getAuctionId());
+        TaoBaoGoodsBrief tb = taoBaoGoodsBriefMapper.selectOneByAuctionId(goods.getAuctionId());
         if (tb != null) {
             goods.setId(tb.getId());
             TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(goods);
@@ -174,9 +174,9 @@
 
     @Override
     public void deleteOutOfDate() {
-        List<Long> list = taoBaoGoodsBriefMapper
+        List<String> list = taoBaoGoodsBriefMapper
                 .queryCanDeleteGoods(new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24 * 2), 0, 2000);
-        for (Long auctionId : list) {
+        for (String auctionId : list) {
             deleteTaoBaoGoods(auctionId);
         }
     }
@@ -259,25 +259,25 @@
     }
 
     @Override
-    public List<Long> listNeedUpdateGoodsId(long start, int count, int hour) {
+    public List<String> listNeedUpdateGoodsId(long start, int count, int hour) {
         return taoBaoGoodsBriefMapper.listNeedUpdateGoodsId(start, count, hour);
     }
 
     @Override
-    public void updateByTaoKeGoodsDetail(Long id) {
+    public void updateByTaoKeGoodsDetail(String goodsId) {
         try {
-            TaoBaoGoodsBrief oldGoods = taoBaoGoodsBriefMapper.selectByPrimaryKey(id);
+            TaoBaoGoodsBrief oldGoods = taoBaoGoodsBriefMapper.selectOneByAuctionId(goodsId);
             if (oldGoods == null) {
                 return;
             }
 
-            TaoBaoGoodsBrief newGoods = TaoKeApiUtil.searchGoodsDetail(id);
+            TaoBaoGoodsBrief newGoods = TaoKeApiUtil.searchGoodsDetail(oldGoods.getAuctionId());
             if (newGoods == null) {
                 return;
             }
 
             // 鏇存柊绮鹃�夊晢鍝�
-            newGoods.setId(id);
+            newGoods.setId(oldGoods.getId());
             TaoBaoGoodsBrief updateGoods = getUpdateTaoBaoGoodsBrief(newGoods);
             taoBaoGoodsBriefMapper.updateByPrimaryKeySelective(updateGoods);
 
@@ -292,7 +292,7 @@
             }
 
         } catch (TaobaoGoodsDownException e) {
-            offlineTaoBaoGoods(id);
+            offlineTaoBaoGoods(goodsId);
         } catch (Exception e) {
             LogHelper.errorDetailInfo(e);
         }
@@ -310,15 +310,13 @@
             return;
         }
         goods.setUpdatetime(new Date());
-        if (goods.getId() == null)
-            goods.setId(goods.getAuctionId());
         taoBaoGoodsUpdateDao.save(goods);
         taoBaoGoodsCacheUtil.addUpdateHistory(goods.getAuctionId());
     }
 
     @Async
     @Override
-    public void addUpdateQueueAsync(Long auctionId) {
+    public void addUpdateQueueAsync(String auctionId) {
         addUpdateQueueSync(auctionId);
     }
 
@@ -327,7 +325,7 @@
      *
      * @param auctionId
      */
-    private void addUpdateQueueSync(Long auctionId) {
+    private void addUpdateQueueSync(String auctionId) {
         try {
             if (taoBaoGoodsCacheUtil.canAddToUpdateQueue(auctionId)) {
                 // 娣诲姞鍒版洿鏂伴槦鍒�
@@ -354,7 +352,7 @@
 
         // 鍟嗗搧杩囨护涓嶅厑璁稿嚭閿�
         try {
-            Map<Long, TaoBaoGoodsBrief> finalMap = new HashMap<>();
+            Map<String, TaoBaoGoodsBrief> finalMap = new HashMap<>();
             // 鍘熷鏁版嵁鍏ㄨ鐩�
             for (TaoBaoGoodsBrief goods : goodsList) {
                 finalMap.put(goods.getAuctionId(), goods);
@@ -373,7 +371,7 @@
             }
 
             // 鍐嶄粠mongodb涓彇瑕嗙洊
-            List<Long> auctionIds = new ArrayList<>();
+            List<String> auctionIds = new ArrayList<>();
             for (TaoBaoGoodsBrief goods : tempGoodsList) {
                 auctionIds.add(goods.getAuctionId());
             }
@@ -412,7 +410,7 @@
 
         // 鍟嗗搧杩囨护涓嶅厑璁稿嚭閿�
         try {
-            Map<Long, CommonGoods> finalMap = new HashMap<>();
+            Map<String, CommonGoods> finalMap = new HashMap<>();
             // 鍘熷鏁版嵁鍏ㄨ鐩�
             List<CommonGoods> tempGoodsList = new ArrayList<>();
             for (CommonGoods goods : goodsList) {
@@ -433,7 +431,7 @@
             }
 
             // 鍐嶄粠mongodb涓彇瑕嗙洊
-            List<Long> auctionIds = new ArrayList<>();
+            List<String> auctionIds = new ArrayList<>();
             for (CommonGoods goods : tempGoodsList) {
                 auctionIds.add(goods.getGoodsId());
             }

--
Gitblit v1.8.0