邀请对应奖励红包加入版本区分

yujian

2019-06-26 020d940ae4e16f55f69cef3dd4c8dc0b9764af07

 fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java

@@ -11,11 +11,14 @@
import com.yeshi.fanli.exception.ActivityException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.activity.ActivityService;

import com.yeshi.fanli.service.inter.brand.BrandClassShopService;

import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;

import com.yeshi.fanli.service.inter.lable.LabelService;

import com.yeshi.fanli.service.inter.lable.QualityFactoryService;

import com.yeshi.fanli.service.inter.lable.QualityFlashSaleService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsActivityService;

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.Constant;



@@ -46,6 +49,12 @@


   @Resource

   private QualityFlashSaleService qualityFlashSaleService;



   @Resource

   private BrandClassShopService brandClassShopService;



   @Resource

   private TaoBaoGoodsActivityService taoBaoGoodsActivityService;



   // 动态商品更新 ，1个小时更新

   @Scheduled(cron = "0 0 */1 * * ?")

@@ -83,7 +92,7 @@
      }



      try {

         qualityFactoryService.updateWeight(10, 3);

         qualityFactoryService.updateWeight(1, 4);

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

@@ -99,17 +108,20 @@
      taoBaoGoodsUpdateService.deleteOutOfDate();

   }



   // 添加精选库中需要更新的淘宝商品ID(2个小时执行一次)

   @Scheduled(cron = "0 0 1/2 * * ? ")

   public void addNeddUpdateTaoBaoGoods() {

      if (!Constant.IS_TASK) 
   /**

    * 更新超过4个小时未更新的商品

    */

   // 1个小时更新

   @Scheduled(cron = "0 0 1/1 * * ? ")

   public void addNeedUpdateTaoBaoGoods() {

      if (!Constant.IS_TASK)

         return;

		
      List<Long> list = qualityFactoryService.queryNeedUpdate(0, 1000, 4);



      List<Long> list = taoBaoGoodsUpdateService.listNeedUpdateGoodsId(0, 2000, 4);

      if (list == null || list.size() == 0) {

         return;

      }

		


      for (Long id : list) {

         try {

            CMQManager.getInstance().addNeedUpdateTaoBaoGoodsId(id);

@@ -124,7 +136,6 @@
    */

   @Scheduled(cron = "0 15 0/6 * * ? ")

   public void removeFlashSaleGoods() {



      if (!Constant.IS_TASK) {

         return;

      }

@@ -139,8 +150,27 @@
         }



      } catch (Exception e) {

            LogHelper.errorDetailInfo(e);

         LogHelper.errorDetailInfo(e);

      }

   }



   // 更新品牌商品，每天早上6点执行一次

   @Scheduled(cron = "0 0 6 * * ? ")

   public void updateBrandGoods() {

      if (!Constant.IS_TASK)

         return;

      brandClassShopService.updateShopGoods();

   }



   /**

    * 每小时更新一次

    */

   @Scheduled(cron = "0 0 0/1 * * ?")

   public void update618() {

      if (!Constant.IS_TASK)

         return;

      LogHelper.test("更新618商品");

      taoBaoGoodsActivityService.sysncS618Goods();

   }



}