订单bug，分享爆款自购修改

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,7 +35,9 @@


   @Resource

   private DaTaoKeGoodsDetailService daTaoKeGoodsService;

	


   @Resource

   private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service;



   /**

    * 限时秒杀 数据更新

@@ -49,20 +52,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 +88,8 @@
      }

   }



   // 20分钟更新一次

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

   // 1个小时更新一次

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

   public void doSyncJob() {

      if (!Constant.IS_TASK)

         return;

@@ -104,4 +107,78 @@
      }

   }



   // 每天早上同步一次

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

   public void doSyncJobNew() {

      if (!Constant.IS_TASK)

         return;

      try {

         new Thread(new Runnable() {



            @Override

            public void run() {

               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();



      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

   }



}