定时任务案例1：每周生成提醒

package nd.sdp.idea.modules.schedule;

import nd.sdp.idea.modules.idea.entity.Idea;
import nd.sdp.idea.modules.idea.service.IdeaService;
import nd.sdp.idea.modules.reminder.entity.CyclePendingIdeaReminder;
import nd.sdp.idea.modules.reminder.service.CPIReminderService;
import org.joda.time.DateTime;
import org.joda.time.format.ISODateTimeFormat;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

/**
 * 周期性待处理提醒任务
 *
 * @author yanguanyu(290536)
 * @since 0.1 created on 2016/10/20.
 */
@Component
public class CyclePendingReminderTask {

    private static final Logger logger = LoggerFactory.getLogger(CyclePendingReminderTask.class);

    @Resource
    private IdeaService ideaService;
    @Resource
    private CPIReminderService cpiReminderService;

    private static final String DATE_FORMAT = "dd/MM/yyyy";

    //每周一0点0分0秒触发，处理上上周
    @Scheduled(cron = "0 0 0 ? * MON ")
    public void weeklyRemind() {
        logger.info("CyclePendingReminderTask.weeklyRemind");
        logger.info("周期性待处理提醒任务开始");
        String now = DateTime.now().toString(DATE_FORMAT);
        //往前推2周，上上周周一
        String from = DateTime.parse(now, ISODateTimeFormat.dateElementParser())
                .minusWeeks(2).toString(DATE_FORMAT);
        //上上周周日
        String to = DateTime.parse(from, ISODateTimeFormat.dateElementParser())
                .plusWeeks(1).minusDays(1).toString(DATE_FORMAT);
        //上上周周一0点时间戳
        long fromTime = DateTime.parse(from, ISODateTimeFormat.dateElementParser()).getMillis();
        //上周周一0点时间戳
        long toTime = DateTime.parse(to, ISODateTimeFormat.dateElementParser()).plus(1).getMillis();
        List<String> userIdList = ideaService.getUserIdList();
        for (String userId : userIdList) {
            List<Idea> ideaList = ideaService.findIdeasByCreateAt(userId, fromTime, toTime);
            //有创建想法才会有提醒
            if (ideaList.size() > 0) {
                CyclePendingIdeaReminder reminder = new CyclePendingIdeaReminder();
                reminder.setUserId(userId);
                reminder.setFrom(from);
                reminder.setTo(to);
                reminder.setFinished(false);
                cpiReminderService.save(reminder);
            }
        }
        logger.info("周期性待处理提醒任务完成");
    }

    public static void main(String[] args) {
        Date date = DateTime.parse("2016-10-17", ISODateTimeFormat.dateElementParser()).minusWeeks(2).toDate();
        System.out.println(date);
        date = DateTime.parse("2016-10-03", ISODateTimeFormat.dateElementParser()).plusWeeks(1).minusDays(1).toDate();
        System.out.println(date);
        System.out.println(DateTime.now().toString(DATE_FORMAT));
    }
}