Selaa lähdekoodia

fix: 重复发邮件的问题

shc 2 vuotta sitten
vanhempi
commit
98e48f7476

+ 11 - 15
hnqz-visual/hnqz-daemon-quartz/src/main/java/com/qunzhixinxi/hnqz/daemon/quartz/task/SpringBeanTaskDemo.java

@@ -425,25 +425,21 @@ public class SpringBeanTaskDemo {
 			text.append("</table></body></html>");
 
 			log.info("table ==> {}", text);
-			Arrays.stream(re).forEach(reciver -> {
-				MimeMessage mail = sender.createMimeMessage();
-				try {
+			MimeMessage mail = sender.createMimeMessage();
+			try {
 
-					MimeMessageHelper helper = new MimeMessageHelper(mail, true);
+				MimeMessageHelper helper = new MimeMessageHelper(mail, true);
 
-					helper.setFrom("yaoyi_report@yaoyi.net");
-					helper.setTo(re);
-
-					helper.setSubject("零工平台人员认证未完成信息汇总(" + DateTimeFormatter.ofPattern("yyyy-MM-dd").format(LocalDate.now().minusDays(1L)) + ")");
-
-					helper.setText(text.toString(), true);
-					sender.send(mail);
-				} catch (MessagingException ex) {
-					log.error("邮件发送失败");
-				}
-			});
+				helper.setFrom("yaoyi_report@yaoyi.net");
+				helper.setTo(re);
 
+				helper.setSubject("零工平台人员认证未完成信息汇总(" + DateTimeFormatter.ofPattern("yyyy-MM-dd").format(LocalDate.now().minusDays(1L)) + ")");
 
+				helper.setText(text.toString(), true);
+				sender.send(mail);
+			} catch (MessagingException ex) {
+				log.error("邮件发送失败");
+			}
 		}
 
 		return HnqzQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();