使用Quartz和Spring boot计划任务

Question

我想每天使用Spring Boot发送电子邮件，用户指定发送时间，我使用石英来安排我的工作。电子邮件的收件人有（id、emailAddress、截止日期）电子邮件将发送给截止日期=今天X...（用户指定X）。例如：用户指定X是1号，所以我们对明天有截止日期的人感兴趣。

第1天：应用程序向截止日期为今天1的人发送电子邮件。。第二天：我希望应用程序在第二天将电子邮件发送给新的收件人，但使用下面的代码，电子邮件将发送给在第1天收到它的人，这不是我所需要的。

@PostMapping("/scheduleEmailPeriodic")
    public ResponseEntity<ScheduleEmailResponse> SendScheduleEmailPeriodic(
            @Valid @RequestBody PeriodicNotification scheduleEmailRequest) throws Exception {
        ens.schedulePeriodicNotification(scheduleEmailRequest);
        LocalDate localDateTime = LocalDate.now();
        LocalTime localTime = LocalTime.parse(scheduleEmailRequest.getSendingTime());

        

        try {
            ZonedDateTime dateTime = ZonedDateTime.of(localDateTime, localTime,ZoneId.of("Africa/Casablanca"));
            if (dateTime.isBefore(ZonedDateTime.now())) {
                ScheduleEmailResponse scheduleEmailResponse = new ScheduleEmailResponse(false,
                        "dateTime must be after current time");
                return ResponseEntity.badRequest().body(scheduleEmailResponse);
            }

            JobDetail jobDetail = buildPeriodicJobDetail(scheduleEmailRequest);
            Trigger trigger = buildJobTriggerPeriodic(jobDetail, dateTime);
            scheduler.scheduleJob(jobDetail, trigger);

            ScheduleEmailResponse scheduleEmailResponse = new ScheduleEmailResponse(true, jobDetail.getKey().getName(),
                    jobDetail.getKey().getGroup(), "Email Scheduled Successfully!");
            return ResponseEntity.ok(scheduleEmailResponse);
        } catch (SchedulerException ex) {
            logger.error("Error scheduling email", ex);

            ScheduleEmailResponse scheduleEmailResponse = new ScheduleEmailResponse(false,
                    "Error scheduling email. Please try later!");
            return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(scheduleEmailResponse);
        }
    }

private JobDetail buildPeriodicJobDetail(PeriodicNotification scheduleEmailRequest) {
        JobDataMap jobDataMap = new JobDataMap();
        List<String> recipients = fileRepo.findWantedEmails(scheduleEmailRequest.getDaysNum());

        if(recipients.isEmpty()) {
            throw new RuntimeException("Aucun destinataire trouvé");
        }
        String[] to = recipients.stream().toArray(String[]::new);

        jobDataMap.put("recipients", to);
        jobDataMap.put("subject", scheduleEmailRequest.getSubject());
        jobDataMap.put("body", scheduleEmailRequest.getMessage());

        return JobBuilder.newJob(EmailJob.class).withIdentity(UUID.randomUUID().toString(), "email-jobs")
                .withDescription("Send Email Job").usingJobData(jobDataMap).storeDurably().build();
    }

    private Trigger buildJobTriggerPeriodic(JobDetail jobDetail, ZonedDateTime startAt) {
        return TriggerBuilder.newTrigger().forJob(jobDetail)
                .withIdentity(jobDetail.getKey().getName(), "email-triggers")
                .withDescription("Send Periodic Email Trigger")
                .withSchedule(SimpleScheduleBuilder
                .repeatHourlyForever(24))
                .startAt(Date.from(startAt.toInstant()))
                .build();
    }

这是电子邮件作业：

@Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        logger.info("Executing Job with key {}", context.getJobDetail().getKey());
        JobDataMap jobDataMap = context.getMergedJobDataMap();
        String subject = jobDataMap.getString("subject");
        String body = jobDataMap.getString("body");
        String[] recipients = (String[])jobDataMap.get("recipients");
        sendMail("[e-mail]", recipients, subject, body);
        
    }
    
     private void sendMail(String fromEmail, String[] toEmail, String subject, String body) {
            try {
                logger.info("Sending Email to {}", Arrays.toString(toEmail));
                MimeMessage message = mailSender.createMimeMessage();

                MimeMessageHelper messageHelper = new MimeMessageHelper(message, StandardCharsets.UTF_8.toString());
                messageHelper.setSubject(subject);
                messageHelper.setText(body, true);
                messageHelper.setFrom(fromEmail);
                messageHelper.setTo(toEmail);

                mailSender.send(message);
            } catch (MessagingException ex) {
                logger.error("Failed to send email to {}", Arrays.toString(toEmail));
            }
        }

}

我真的需要帮助，我需要每天都有新的收件人，而不是将电子邮件发送给同一个收件人。

Answer 1

您发送的电子邮件是基于日期的，但您无法跟踪为特定用户发送电子邮件的时间。因此，如果您今天将向user1发送一封电子邮件，那么user1在第二天仍然处于状态。您需要添加一个标志（或一些其他逻辑），表明已为此用户发送了电子邮件