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

admin

2019-07-11 3824cbcaec6e6c67418d5280a53e9c2fedeef6f9

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

@@ -1,5 +1,8 @@
package com.yeshi.fanli.job;



import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;



import javax.annotation.Resource;

@@ -11,11 +14,14 @@
import com.yeshi.fanli.entity.bus.lable.QualityFactory;

import com.yeshi.fanli.entity.common.AdminUser;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetail;

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;



/**

 * 更新大淘客数据

@@ -30,18 +36,39 @@
   @Resource

   private DaTaoKeGoodsDetailService daTaoKeGoodsService;



   // 两小时执行一次 对商品信息进行更新

   @Resource

   private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service;



   /**

    * 限时秒杀 数据更新

    */

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

   public void doUpdateJob() {



      if (!Constant.IS_TASK)

         return;



      List<TaoBaoGoodsBrief> listgoods = DaTaoKeUtil.getDingDongQiang();

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

      List<DaTaoKeDetail> listTaoKe = DaTaoKeUtil.getDingDongQiang();

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

         return;

      }



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

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

      }



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

      try {

         /* 操作人： 开发账号 */

         AdminUser admin = new AdminUser(2L);

@@ -52,20 +79,17 @@
         autoRule.setStartWeight(1);

         autoRule.setEndWeight(3000);

         autoRule.setGoodsSource(QualityFactory.SOURCE_TAOBAO_DATAOKE);

         qualityFactoryService.autoInsertOrUpadateStorage(listgoods, null, autoRule);

         qualityFactoryService.autoInsertOrUpadateStorage(autoRule, listgoods, null);



         // 删除之前的

         qualityFactoryService.deleteNotUpdateGoods(null, formatDate, autoRule.getGoodsSource());

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         LogHelper.errorDetailInfo(e);

      }



   }



   // 20分钟更新一次

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

   // 1个小时更新一次

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

   public void doSyncJob() {

      if (!Constant.IS_TASK)

         return;

@@ -79,11 +103,81 @@
         }).start();



      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         LogHelper.errorDetailInfo(e);

      }

   }



   // 每天早上同步一次

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

      }

   }