package com.yeshi.fanli.job;
|
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.yeshi.utils.DateUtil;
|
|
import com.yeshi.fanli.entity.bus.activity.RecommendActivity;
|
import com.yeshi.fanli.entity.bus.activity.RecommendActivityInviteInfo;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.activity.ActivityService;
|
import com.yeshi.fanli.service.inter.dynamic.DynamicInfoService;
|
import com.yeshi.fanli.util.Constant;
|
|
@Component
|
public class DynamicInfoJob {
|
|
@Resource
|
private DynamicInfoService dynamicInfoService;
|
|
@Resource
|
private ActivityService activityService;
|
|
|
/**
|
* 每10分钟 晚上00:00~06:00不下发任何一个商品
|
*/
|
@Scheduled(cron = "0 0/10 6-23 * * ?")
|
public void insetDynamicInfo() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
dynamicInfoService.insertTimeHotSale();
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
|
|
try {
|
dynamicInfoService.insertTimeRecommend();
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
|
/**
|
* 早上6,7,15,16,21,22,23点更新1次
|
*/
|
@Scheduled(cron = "0 0 6,7,15,16,21,22,23 * * ? ")
|
public void insetShopInfo1() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
dynamicInfoService.insertShopInfo();
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* 早上8:00~10:00每半个小时更新
|
*/
|
@Scheduled(cron = "0 0/30 8,9,10 * * ?")
|
public void insetShopInfo2() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
dynamicInfoService.insertShopInfo();
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
|
/**
|
* 早上11:00~14:00每半个小时更新
|
*/
|
@Scheduled(cron = "0 0/30 11,12,13,14 * * ?")
|
public void insetShopInfo3() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
dynamicInfoService.insertShopInfo();
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
|
/**
|
* 下午17:00~20:00每半个小时更新
|
*/
|
@Scheduled(cron = "0 0/30 17,18,19,20 * * ? ")
|
public void insetShopInfo4() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
dynamicInfoService.insertShopInfo();
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
|
/**
|
* 每天零点删除3天之前数据
|
*/
|
@Scheduled(cron = "0 0 1,10 * * ?")
|
public void remove() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
LogHelper.test("DynamicInfoJob-remove-开始执行态");
|
dynamicInfoService.removeByDate(DateUtil.reduceDay(2, new Date()));
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
|
/**
|
* 后台编辑动态： 每3分钟检索
|
*/
|
@Scheduled(cron = "0 0/3 * * * ?")
|
public void activityNeedPublish() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
List<RecommendActivity> list = activityService.getNeedPublish();
|
if (list == null || list.size() == 0) {
|
return;
|
}
|
|
|
for (RecommendActivity activity : list) {
|
Integer type = activity.getType();
|
if (RecommendActivity.TYPE_SHARE_GOODS == type) {
|
// 商品动态
|
dynamicInfoService.insertActivityRecommend(activity);
|
|
activity.setState(1);
|
activityService.updateByPrimaryKeySelective(activity);
|
|
} else if (RecommendActivity.TYPE_INVITE == type) {
|
// 邀请素材
|
RecommendActivityInviteInfo inviteInfo = activityService.getRecommendActivityInviteInfoByActivityId(activity.getId());
|
activity.setInviteInfo(inviteInfo);
|
|
dynamicInfoService.insertInviteActivity(activity);
|
|
activity.setState(1);
|
activityService.updateByPrimaryKeySelective(activity);
|
}
|
}
|
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
|
/**
|
* 每天6点天更新邀请素材
|
*/
|
@Scheduled(cron = "0 0 6 * * ?")
|
public void insertTimeInvite() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
dynamicInfoService.insertTimeInvite();
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
|
}
|
