yujian
2019-11-26 2d3afb55aed07f9780ab46aefbdc7d520cdff576
fanli/src/main/java/com/yeshi/fanli/service/impl/brand/BrandGoodsCaheServiceImpl.java
@@ -49,16 +49,19 @@
   
   
   @Override
   public int addBrandGoods(BrandInfo brandInfo) {
      int count = 0;
   public BrandInfo addBrandGoods(BrandInfo brandInfo) {
      // 淘宝
      count += addBrandGoodsTB(brandInfo);
      BrandInfo goodsTB = addBrandGoodsTB(brandInfo);
      // 京东
      count += addBrandGoodsJD(brandInfo);
      BrandInfo goodsJD = addBrandGoodsJD(brandInfo);
      // 拼多多
      count += addBrandGoodsPDD(brandInfo);
      BrandInfo goodsPDD = addBrandGoodsPDD(brandInfo);
      
      return count;
      int goodsTotal = goodsTB.getGoodsTotal() + goodsJD.getGoodsTotal() +  goodsPDD.getGoodsTotal();
      int shopTotal = goodsTB.getShopTotal() + goodsJD.getShopTotal() +  goodsPDD.getShopTotal();
      goodsTB.setGoodsTotal(goodsTotal);
      goodsTB.setShopTotal(shopTotal);
      return goodsTB;
   }
   
   
@@ -67,16 +70,19 @@
    * @param brandInfo
    * @return
    */
   private int addBrandGoodsTB(BrandInfo brandInfo) {
   private BrandInfo addBrandGoodsTB(BrandInfo brandInfo) {
      BrandInfo numInfo = new BrandInfo();
      Date date = new Date();
      String shopKey = brandInfo.getShopKey();
      if (StringUtil.isNullOrEmpty(shopKey)) {
         // 删除之前的
          brandGoodsCaheDao.removeByDate(brandInfo.getId(), 1 , date);
         // 删除店铺
          brandShopCaheService.removeByDateAndType(brandInfo.getId(), 11, date);
         return 0;
          numInfo.setShopTotal(0);
          numInfo.setGoodsTotal(0);
         return numInfo;
      }
      
      String searchKey = brandInfo.getSearchKey();
@@ -96,6 +102,7 @@
       
       // 组织商品 + 添加店铺
      int count = 0;
      int countShop = 0;
      if (searchResult != null && searchResult.getTaoBaoGoodsBriefs() != null 
            && searchResult.getTaoBaoGoodsBriefs().size() > 0) {
         boolean addShop = true;
@@ -107,6 +114,9 @@
                  && shopTitle.toLowerCase().contains(shopKey.toLowerCase())) {
               addShop = brandShopCaheService.addBrandShopTB(brandInfo, goods.getAuctionId(),
                     goods.getSellerId());
               if (!addShop)
                  countShop = 1;
            }
            
            // 添加商品
@@ -116,7 +126,7 @@
               brandGoods.setWeight((int) (Math.random() * 1000));
               brandGoods.setGoodsType(1);
               brandGoods.setGoodsTB(goods);
               brandGoods.setCreateTime(date);
               brandGoods.setCreateTime(new Date());
               brandGoodsCaheDao.insert(brandGoods);
               count ++;
            } else if (!addShop) {
@@ -128,7 +138,9 @@
      // 删除之前的
       brandGoodsCaheDao.removeByDate(brandInfo.getId(), 1 , date);
       
      return count;
       numInfo.setShopTotal(countShop);
       numInfo.setGoodsTotal(count);
      return numInfo;
   }
   
   
@@ -138,7 +150,8 @@
    * @param brandInfo
    * @return
    */
   private int addBrandGoodsJD(BrandInfo brandInfo) {
   private BrandInfo addBrandGoodsJD(BrandInfo brandInfo) {
      BrandInfo numInfo = new BrandInfo();
      Date date = new Date();
      String shopKey = brandInfo.getShopKeyJD();
      if (StringUtil.isNullOrEmpty(shopKey)) {
@@ -146,7 +159,9 @@
          brandShopCaheService.removeByDateAndType(brandInfo.getId(), 20, date);
         // 删除之前
          brandGoodsCaheDao.removeByDate(brandInfo.getId(), 2 , date);
          return 0;
          numInfo.setShopTotal(0);
          numInfo.setGoodsTotal(0);
          return numInfo;
      }
      
      String searchKey = brandInfo.getSearchKeyJD();
@@ -154,6 +169,7 @@
         searchKey = brandInfo.getName();
      
      int count = 0;
      int countShop = 0;
      JDSearchResult result = null;
      String way = configService.get("jd_api_search_key");
      
@@ -190,7 +206,7 @@
               brandGoods.setWeight((int) (Math.random() * 1000));
               brandGoods.setGoodsJD(goods);
               brandGoods.setGoodsType(2);
               brandGoods.setCreateTime(date);
               brandGoods.setCreateTime(new Date());
               brandGoodsCaheDao.insert(brandGoods);
               
               JDShopInfo shopInfo = goods.getShopInfo();
@@ -200,6 +216,7 @@
                  if (!StringUtil.isNullOrEmpty(shopName) && shopName.toLowerCase().contains(shopKey.toLowerCase())) {
                     addShop = false;
                     brandShopCaheService.addBrandShopJD(brandInfo, shopInfo);
                     countShop = 1;
                  }
               }
               
@@ -210,11 +227,12 @@
            }
         }
      }
      // 删除之前
       brandGoodsCaheDao.removeByDate(brandInfo.getId(), 2 , date);
            
        return count;
       numInfo.setShopTotal(countShop);
       numInfo.setGoodsTotal(count);
      return numInfo;
   }
   
   
@@ -223,15 +241,18 @@
    * @param brandInfo
    * @return
    */
   private int addBrandGoodsPDD(BrandInfo brandInfo) {
   private BrandInfo addBrandGoodsPDD(BrandInfo brandInfo) {
      Date date = new Date();
      BrandInfo numInfo = new BrandInfo();
      String shopKey = brandInfo.getShopKeyPDD();
      if (StringUtil.isNullOrEmpty(shopKey)) {
         // 删除之前
         brandGoodsCaheDao.removeByDate(brandInfo.getId(), 3, date);
         // 删除之前店铺
         brandShopCaheService.removeByDateAndType(brandInfo.getId(), 30, date);
         return 0;
         numInfo.setShopTotal(0);
          numInfo.setGoodsTotal(0);
          return numInfo;
      }
      
      String searchKey = brandInfo.getSearchKeyPDD();
@@ -256,7 +277,7 @@
               brandGoods.setWeight((int) (Math.random() * 1000));
               brandGoods.setGoodsType(3);
               brandGoods.setGoodsPDD(goods);
               brandGoods.setCreateTime(date);
               brandGoods.setCreateTime(new Date());
               brandGoodsCaheDao.insert(brandGoods);
               count ++;
               if (count >= 50) {
@@ -270,9 +291,11 @@
      // 删除之前店铺
      brandShopCaheService.removeByDateAndType(brandInfo.getId(), 30, date);
      // 添加店铺
      brandShopCaheService.addBrandShopPDD(brandInfo);
      int countShop = brandShopCaheService.addBrandShopPDD(brandInfo);
      
      return count;
      numInfo.setShopTotal(countShop);
       numInfo.setGoodsTotal(count);
      return numInfo;
   }