package com.yeshi.fanli.job;
|
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
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.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.TaoBaoGoodsUpdateService;
|
import com.yeshi.fanli.util.CMQManager;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
|
/**
|
* 淘宝商品更细
|
*
|
* @author Administrator
|
*
|
*/
|
|
@Component
|
public class UpdateTaoBaoGoodsJob {
|
|
@Resource
|
private TaoBaoGoodsBriefService taoBaoGoodsBriefService;
|
|
@Resource
|
private RecommendSectionGoodsService recommendSectionGoodsService;
|
|
@Resource
|
private ActivityService activityService;
|
|
@Resource
|
private QualityFactoryService qualityFactoryService;
|
|
@Resource
|
private LabelService labelService;
|
|
@Resource
|
private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;
|
|
@Resource
|
private QualityFlashSaleService qualityFlashSaleService;
|
|
|
@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 * * ?")
|
public void updateActivityGoodsJob() {
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
Long count = activityService.getRecommendActivityCount(RecommendActivity.TYPE_SHARE_GOODS);
|
int pageSize = 50;
|
int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
|
// 最多更新50页数据
|
if (totalPage > 50)
|
totalPage = 50;
|
for (int i = 1; i <= totalPage; i++) {
|
List<RecommendActivity> list = activityService.getRecommendActivityList(RecommendActivity.TYPE_SHARE_GOODS,
|
i, pageSize);
|
if (list != null)
|
for (RecommendActivity activity : list) {
|
try {
|
activityService.upgradeShareGoodsRecommendActivity(activity.getId());
|
} catch (ActivityException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
}
|
|
// 调整超过3个小时未更新 的商品权重值设为10
|
@Scheduled(cron = "0 0 0/3 * * ?")
|
public void updateQualityFactoryWeightJob() {
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
LogHelper.test("---执行--updateQualityFactoryWeightJob--");
|
|
qualityFactoryService.updateWeight(10, 3);
|
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
|
}
|
|
// 删除过期商品资源(30分钟)
|
@Scheduled(cron = "0 0/30 * * * ? ")
|
public void deleteOutOfDateTaoBaoGoods() {
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
taoBaoGoodsUpdateService.deleteOutOfDate();
|
}
|
|
// 添加精选库中需要更新的淘宝商品ID(2个小时执行一次)
|
@Scheduled(cron = "0 0 1/2 * * ? ")
|
public void addNeddUpdateTaoBaoGoods() {
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
LogHelper.test("---addNeddUpdateTaoBaoGoods----execute ");
|
|
List<Long> list = qualityFactoryService.queryNeedUpdate(0, 3000, 4);
|
if (list != null) {
|
for (Long id : list) {
|
try {
|
CMQManager.getInstance().addNeedUpdateTaoBaoGoodsId(id);
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
}
|
}
|
|
|
/**
|
* 定时清理超过6个小时未更新的限时抢购商品
|
*/
|
@Scheduled(cron = "0 15 0/6 * * ? ")
|
public void removeFlashSaleGoods() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
while (true) {
|
List<Long> list = qualityFlashSaleService.queryNeedRemove(0, 100, 6);
|
|
if (list == null || list.size() == 0) {
|
break;
|
}
|
|
qualityFlashSaleService.deleteBatchByPrimaryKey(list);
|
}
|
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
}
|
