From f4a0f2acc63d7785eab108419a4e16f5f688cb95 Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期六, 18 一月 2020 12:06:27 +0800 Subject: [PATCH] 用户注册信息 --- fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java | 49 ++++++++++++++++++++++++++++--------------------- 1 files changed, 28 insertions(+), 21 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java index 1baa55d..3f4252f 100644 --- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java +++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateTaoBaoGoodsJob.java @@ -1,5 +1,6 @@ package com.yeshi.fanli.job; +import java.util.Date; import java.util.List; import javax.annotation.Resource; @@ -8,21 +9,22 @@ import org.springframework.stereotype.Component; import com.yeshi.fanli.entity.bus.activity.RecommendActivity; -import com.yeshi.fanli.entity.taobao.ShareHotGoods; import com.yeshi.fanli.exception.ActivityException; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.activity.ActivityService; +import com.yeshi.fanli.service.inter.brand.BrandClassShopGoodsService; import com.yeshi.fanli.service.inter.brand.BrandClassShopService; import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService; import com.yeshi.fanli.service.inter.lable.LabelService; import com.yeshi.fanli.service.inter.lable.QualityFactoryService; import com.yeshi.fanli.service.inter.lable.QualityFlashSaleService; import com.yeshi.fanli.service.inter.taobao.ShareHotGoodsService; +import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsService; import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsActivityService; import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService; import com.yeshi.fanli.util.CMQManager; import com.yeshi.fanli.util.Constant; -import com.yeshi.fanli.util.TimeUtil; +import com.yeshi.fanli.util.cache.HttpGoodsCacheManager; /** * 娣樺疂鍟嗗搧鏇寸粏 @@ -60,6 +62,15 @@ @Resource private ShareHotGoodsService shareHotGoodsService; + + @Resource + private TLJBuyGoodsService tljBuyGoodsService; + + @Resource + private BrandClassShopGoodsService brandClassShopGoodsService; + + @Resource + private HttpGoodsCacheManager httpGoodsCacheManager; // 鍔ㄦ�佸晢鍝佹洿鏂� 锛�1涓皬鏃舵洿鏂� @Scheduled(cron = "0 0 */1 * * ?") @@ -159,33 +170,29 @@ } } - // 鏇存柊鍝佺墝鍟嗗搧锛屾瘡澶╂棭涓�6鐐规墽琛屼竴娆� + // 鏇存柊澧炲姞鍝佺墝鍟嗗搧锛屾瘡澶╂棭涓�6鐐规墽琛屼竴娆� @Scheduled(cron = "0 0 6 * * ? ") - public void updateBrandGoods() { + public void updateAddBrandGoods() { if (!Constant.IS_TASK) return; brandClassShopService.updateShopGoods(); } - /** - * 姣忓ぉ鍑屾櫒杩�5鍒嗛挓楠岃瘉 - */ - @Scheduled(cron = "0 5 0 * * ?") - public void update618() { + // 鏇存柊鍘熸湁绮惧搧搴撶殑鍝佺墝鍟嗗搧锛屾瘡澶╁噷鏅�3鐐规墽琛屼竴娆� + @Scheduled(cron = "0 0 3 * * ? ") + public void updateBrandGoods() { if (!Constant.IS_TASK) return; - LogHelper.test("楠岃瘉鐖嗘鍟嗗搧搴撳晢鍝�"); - String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd"); - List<ShareHotGoods> list = shareHotGoodsService.listByDay(day, 15); - int count = 0; - for (int i = 0; i < list.size(); i++) { - if (count >= 10) - break; - boolean success = shareHotGoodsService.verifyCanCreateTLJ(list.get(i).getGoods().getAuctionId()); - if (success) { - count++; - } - } + brandClassShopGoodsService.startUpdateGoods(); } + // 姣忓ぉ鍑屾櫒4鐐规ā鎷熻姹� + @Scheduled(cron = "0 0 4 * * ? ") + public void simulateRequest() { + httpGoodsCacheManager.requestHomeRecommend(); + httpGoodsCacheManager.requestClassGoods(); + httpGoodsCacheManager.requestBrandGoods(); + httpGoodsCacheManager.requestDynamic(); + httpGoodsCacheManager.requestCommonTemplate(); + } } -- Gitblit v1.8.0