设备信息添加最新内容更新时间

admin

2019-06-11 43f1fb44aa2ddfa1fd5ca6f06eec95d2c3c33846

 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,13 @@
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.util.Constant;

import com.yeshi.fanli.util.taobao.DaTaoKeUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;



/**

 * 更新大淘客数据

@@ -29,19 +34,38 @@


   @Resource

   private DaTaoKeGoodsDetailService daTaoKeGoodsService;

	


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

   /**

    * 限时秒杀 数据更新

    */

   @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,16 +76,13 @@
         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分钟更新一次

@@ -79,11 +100,26 @@
         }).start();



      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         LogHelper.errorDetailInfo(e);

      }

   }

	
	
   // 每天早上同步一次

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

      }

   }