admin
2019-07-11 3824cbcaec6e6c67418d5280a53e9c2fedeef6f9
fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java
@@ -18,6 +18,7 @@
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.lable.QualityFactoryService;
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService;
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailV2Service;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.taobao.DaTaoKeUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
@@ -34,6 +35,9 @@
   @Resource
   private DaTaoKeGoodsDetailService daTaoKeGoodsService;
   @Resource
   private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service;
   /**
    * 限时秒杀 数据更新
@@ -113,7 +117,62 @@
            @Override
            public void run() {
               daTaoKeGoodsService.startSyncGoods();
               daTaoKeGoodsDetailV2Service.startSyncGoods();
            }
         }).start();
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Scheduled(cron = "0 0/10 * * * ? ")
   public void doUpdateJobNew() {
      if (!Constant.IS_TASK)
         return;
      try {
         new Thread(new Runnable() {
            @Override
            public void run() {
               daTaoKeGoodsDetailV2Service.updateNewGoods();
            }
         }).start();
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   @Scheduled(cron = "0 0/10 * * * ? ")
   public void doDeleteJobNew() {
      if (!Constant.IS_TASK)
         return;
      try {
         new Thread(new Runnable() {
            @Override
            public void run() {
               daTaoKeGoodsDetailV2Service.deleteInvalid();
            }
         }).start();
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
   }
   // 每天的8点,11点,19点,23点执行一次
   @Scheduled(cron = "0 0 8,11,19,23 * * ? ")
   public void doUpdateInfoJobNew() {
      if (!Constant.IS_TASK)
         return;
      try {
         new Thread(new Runnable() {
            @Override
            public void run() {
               daTaoKeGoodsDetailV2Service.updateData();
            }
         }).start();