| | |
|---|
| | | import org.springframework.stereotype.Component;
|
|---|
| | |
|
|---|
| | | import com.yeshi.fanli.entity.bus.activity.RecommendActivity;
|
|---|
| | | import com.yeshi.fanli.entity.bus.recommend.RecommendSectionGoods;
|
|---|
| | | import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
|---|
| | | import com.yeshi.fanli.exception.ActivityException;
|
|---|
| | | import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
|
|---|
| | | import com.yeshi.fanli.log.LogHelper;
|
|---|
| | | import com.yeshi.fanli.service.inter.activity.ActivityService;
|
|---|
| | | import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService;
|
|---|
| | | import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefRecordService;
|
|---|
| | | 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.taobao.TaoBaoGoodsUpdateService;
|
|---|
| | | import com.yeshi.fanli.util.CMQManager;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 淘宝商品更细
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private TaoBaoGoodsBriefService taoBaoGoodsBriefService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private RecommendSectionGoodsService recommendSectionGoodsService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private ActivityService activityService;
|
|---|
| | |
|---|
| | | @Resource
|
|---|
| | | private QualityFlashSaleService qualityFlashSaleService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private TaoBaoGoodsBriefRecordService taoBaoGoodsBriefRecordService;
|
|---|
| | | |
|---|
| | | |
|---|
| | |
|
|---|
| | | @Scheduled(cron = "0 0 0 * * ?")
|
|---|
| | | public void doJob() {
|
|---|
| | | if (!Constant.IS_TASK)
|
|---|
| | | return;
|
|---|
| | | taoBaoGoodsBriefService.getUpdateTaoBao();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 两小时执行一次 对推荐商品信息进行更新
|
|---|
| | | @Scheduled(cron = "0 0 */2 * * ?")
|
|---|
| | | public void doUpdateJob() {
|
|---|
| | | if (!Constant.IS_TASK)
|
|---|
| | | return;
|
|---|
| | | List<RecommendSectionGoods> list = taoBaoGoodsBriefService.listRecommendSectionGoods();
|
|---|
| | | for (RecommendSectionGoods recommendSectionGoods : list) {
|
|---|
| | | try {
|
|---|
| | | TaoBaoGoodsBrief goods = TaoKeApiUtil
|
|---|
| | | .searchGoodsDetail(recommendSectionGoods.getTaoBaoGoodsBrief().getAuctionId());
|
|---|
| | | taoBaoGoodsUpdateService.updateTaoBaoGoods(goods);
|
|---|
| | | } catch (TaobaoGoodsDownException e1) {
|
|---|
| | | taoBaoGoodsUpdateService. offlineTaoBaoGoods(recommendSectionGoods.getTaoBaoGoodsBrief().getAuctionId());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | try {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | } catch (Exception e1) {
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 动态商品更新 ，1个小时更新
|
|---|
| | | @Scheduled(cron = "0 0 */1 * * ?")
|
|---|
| | |
|---|
| | |
|
|---|
| | | qualityFlashSaleService.deleteBatchByPrimaryKey(list);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | } catch (Exception e) {
|
|---|
| | | try {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | } catch (Exception e1) {
|
|---|
| | | e1.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | |
|---|
| | | /**
|
|---|
| | | * 清理淘宝商品缓存记录表
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "0 0 0 * * ? ")
|
|---|
| | | public void cleanTaoBaoGoodsBriefRecord() {
|
|---|
| | | |
|---|
| | | if (!Constant.IS_TASK) {
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | try {
|
|---|
| | | |
|---|
| | | taoBaoGoodsBriefRecordService.deleteAllData();
|
|---|
| | |
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | try {
|
|---|
