SendNotifyMessageJob.java 文件源码

@Scheduled(fixedDelay = 60 * 1000)
public void execute() {
    Date date = DateUtils.parse(DateUtils.format(new Date(), DateUtils.PATTERN_SIMPLE_DATE),
            DateUtils.PATTERN_SIMPLE_DATE);
    if (date.compareTo(this.date) > 0) {
        this.date = date;
        cache.clear();
    }

    String accessToken = getAccessToken();
    scheduleRepository.findByDate(date).forEach(s -> {
        if (cache.contains(new Long(s.getScheduleId().intValue()))) {
            return;
        }
        if (isNeedSendMessageNow(s)) {
            doSend(accessToken, s);
            cache.add(new Long(s.getScheduleId().intValue()));
        }
    });
}