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

yujian

2019-06-26 020d940ae4e16f55f69cef3dd4c8dc0b9764af07

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

@@ -34,7 +34,6 @@


   @Resource

   private DaTaoKeGoodsDetailService daTaoKeGoodsService;

	


   /**

    * 限时秒杀 数据更新

@@ -49,20 +48,20 @@
      if (listTaoKe == null || listTaoKe.size() == 0) {

         return;

      }

		


      List<Long> listDaoKeId = new ArrayList<Long>();

      for (DaTaoKeDetail daTaoKeDetail: listTaoKe) {

      for (DaTaoKeDetail daTaoKeDetail : listTaoKe) {

         listDaoKeId.add(daTaoKeDetail.getId());

      }

		


      List<DaTaoKeDetail> listDetail = daTaoKeGoodsService.listByIds(listDaoKeId);

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

         return;

      }

		


      List<TaoBaoGoodsBrief> listgoods = new ArrayList<TaoBaoGoodsBrief>();

      for (DaTaoKeDetail daTaoKeDetail: listDetail) {

         listgoods.add( TaoBaoUtil.convert(daTaoKeDetail));

      for (DaTaoKeDetail daTaoKeDetail : listDetail) {

         listgoods.add(TaoBaoUtil.convert(daTaoKeDetail));

      }



      String formatDate = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date());

@@ -85,8 +84,8 @@
      }

   }



   // 20分钟更新一次

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

   // 1个小时更新一次

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

   public void doSyncJob() {

      if (!Constant.IS_TASK)

         return;

@@ -104,4 +103,23 @@
      }

   }



   // 每天早上同步一次

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

   public void doSyncJobNew() {

      if (!Constant.IS_TASK)

         return;

      try {

         new Thread(new Runnable() {



            @Override

            public void run() {

               daTaoKeGoodsService.startSyncGoods();

            }

         }).start();



      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

   }



}