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 com.yeshi.fanli.entity.integral.IntegralTaskClass;
|
import com.yeshi.fanli.entity.integral.IntegralTaskClass.UniqueKeyEnum;
|
import com.yeshi.fanli.exception.push.PushException;
|
import com.yeshi.fanli.entity.integral.IntegralTaskRecord;
|
import com.yeshi.fanli.service.inter.push.PushService;
|
import com.yeshi.fanli.service.inter.user.integral.IntegralTaskClassService;
|
import com.yeshi.fanli.service.inter.user.integral.IntegralTaskRecordService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.TimeUtil;
|
|
/**
|
* 金币任务
|
*
|
* @author Administrator
|
*
|
*/
|
@Component
|
public class IntegralTaskJob {
|
|
@Resource
|
private PushService pushService;
|
|
@Resource
|
private IntegralTaskRecordService integralTaskRecordService;
|
|
@Resource
|
private IntegralTaskClassService integralTaskClassService;
|
|
/**
|
* 推送签到提醒(每天15点半查询)
|
*/
|
@Scheduled(cron = "0 30 15 * * ? ")
|
public void pushSignInNotify() {
|
if (!Constant.IS_TASK)
|
return;
|
// 获取昨天签到过的
|
IntegralTaskClass dailySignClass = integralTaskClassService.getByUniqueKey(UniqueKeyEnum.dailySign.name());
|
if (dailySignClass == null)
|
return;
|
Long cid = dailySignClass.getId();
|
|
long timeStamp = System.currentTimeMillis();
|
Date minTime = new Date(TimeUtil.convertToTimeTemp(
|
TimeUtil.getGernalTime(timeStamp - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));
|
Date maxTime = new Date(
|
TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(timeStamp, "yyyy-MM-dd"), "yyyy-MM-dd"));
|
|
Date todayMinTime = new Date(
|
TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(timeStamp, "yyyy-MM-dd"), "yyyy-MM-dd"));
|
|
Date todayMaxTime = new Date(TimeUtil.convertToTimeTemp(
|
TimeUtil.getGernalTime(timeStamp + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));
|
|
long count = integralTaskRecordService.countByCidAndUidAndCreateTime(cid, null, minTime, maxTime);
|
int page = (int) (count % 200 == 0 ? count / 200 : count / 200 + 1);
|
for (int p = 0; p < page; p++) {
|
List<IntegralTaskRecord> list = integralTaskRecordService.listByCidAndUidAndCreateTime(cid, null, minTime,
|
maxTime, p + 1, 200);
|
if (list != null) {
|
for (IntegralTaskRecord record : list) {
|
// 查询今天是否已经签到
|
long todayCount = integralTaskRecordService.countByCidAndUidAndCreateTime(cid, record.getUid(),
|
todayMinTime, todayMaxTime);
|
if (todayCount <= 0) {// 如果未签到，需要推送信息
|
try {
|
pushService.pushUserSignInNotification(record.getUid(), "今日未签到提醒", "今日还未签到，连续签到金币翻倍哦", null,
|
null);
|
} catch (PushException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
}
|
}
|
|
}
|
