package com.yeshi.fanli.job;
|
|
import java.util.ArrayList;
|
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.user.ThreeSale;
|
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
|
import com.yeshi.fanli.service.inter.msg.UserInviteMsgNotificationService;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.util.Constant;
|
|
@Component
|
public class UpdateThreeSaleJob {
|
|
@Resource
|
private ThreeSaleSerivce ThreeSaleSerivce;
|
@Resource
|
private UserInviteMsgNotificationService userInviteMsgNotificationService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
// 每天00点20执行 过期邀请筛选
|
@Scheduled(cron = "0 20 0 * * ? ")
|
public void updateReward() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
List<Long> list = new ArrayList<Long>();
|
|
// 发出邀请未成功 超过60天
|
List<Long> listFailed = ThreeSaleSerivce.queryLongTimeFailed(60);
|
if (listFailed != null && listFailed.size() > 0) {
|
list.addAll(listFailed);
|
}
|
|
// 更新邀请过期： 60天未被邀请成功、60天未登陆系统
|
if (list.size() > 0) {
|
ThreeSaleSerivce.updateExpire(list);
|
for (Long id : listFailed) {
|
// 通知
|
ThreeSale ts = ThreeSaleSerivce.selectByPrimaryKey(id);
|
if (ts != null)
|
userInviteMsgNotificationService.inviteFail(ts.getBoss().getId(), ts);
|
}
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
}
|
