| | |
|---|
| | | 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;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 金币任务
|
|---|
| | |
|---|
| | | @Resource
|
|---|
| | | private PushService pushService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private IntegralTaskRecordService integralTaskRecordService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private IntegralTaskClassService integralTaskClassService;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 推送签到提醒(每天15点半查询)
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron="0 30 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"));
|
|---|
| | |
|
|---|
| | | // 如果未签到，需要推送信息
|
|---|
| | | // pushService.pushUserSignInNotification(uid, title, content, null,
|
|---|
| | | // null);
|
|---|
| | | 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();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
