From 28cf328a098334b51a3e9d2d56f983fb8c862211 Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期六, 23 五月 2020 09:54:38 +0800 Subject: [PATCH] 足迹、收藏订单兼容新需求 --- fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java | 36 ++++++++++-------------------------- 1 files changed, 10 insertions(+), 26 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java index 43f2f8e..3847f81 100644 --- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java +++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateDaTaoKeJob.java @@ -16,7 +16,6 @@ import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.lable.QualityFactoryService; import com.yeshi.fanli.service.inter.taobao.ShareHotGoodsService; -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.TimeUtil; @@ -34,35 +33,11 @@ private QualityFactoryService qualityFactoryService; @Resource - private DaTaoKeGoodsDetailService daTaoKeGoodsService; - - @Resource private DaTaoKeGoodsDetailV2Service daTaoKeGoodsDetailV2Service; @Resource private ShareHotGoodsService shareHotGoodsService; - @Resource - private DaTaoKeGoodsDetailService daTaoKeGoodsDetailService; - - // 1涓皬鏃舵洿鏂颁竴娆� - @Scheduled(cron = "0 0 0/1 * * ? ") - public void doSyncJob() { - if (!Constant.IS_TASK) - return; - try { - new Thread(new Runnable() { - - @Override - public void run() { - daTaoKeGoodsService.startSyncGoods(); - } - }).start(); - - } catch (Exception e) { - LogHelper.errorDetailInfo(e); - } - } // 姣忓ぉ鏃╂櫄鍚屾涓�娆� @Scheduled(cron = "0 0 6,18 * * ? ") @@ -167,11 +142,20 @@ && goods.getCouponAmount().compareTo(new BigDecimal(0)) > 0) { if (TaoBaoUtil.canAddToTLJBuyGoods(goods)) { count++; - goods = daTaoKeGoodsDetailService.filterTaoBaoGoods(goods); + goods = daTaoKeGoodsDetailV2Service.filterTaoBaoGoods(goods).getGoods(); shareHotGoodsService.addShareHotGoods(new ShareHotGoods(null, day, new Date(), goods)); } } } } + @Scheduled(cron = "0 30 7,11,18,23 * * ? ") + public void syncGoodsBeiYong() { + long latestUpdateCount = daTaoKeGoodsDetailV2Service + .countByMinUpdateTime(new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L)); + if (latestUpdateCount < 50000L) {// 鑻ユ瘡澶╂病鏈夎秴杩�5w鏁版嵁鏇存柊灏遍渶瑕侀噸鏂版洿鏂版暟鎹� + daTaoKeGoodsDetailV2Service.startSyncGoods(); + } + } + } -- Gitblit v1.8.0