diff --git a/backend/src/main/java/com/openisle/service/NotificationService.java b/backend/src/main/java/com/openisle/service/NotificationService.java index 9fbc595f2..86335151b 100644 --- a/backend/src/main/java/com/openisle/service/NotificationService.java +++ b/backend/src/main/java/com/openisle/service/NotificationService.java @@ -72,7 +72,7 @@ public class NotificationService { } n = notificationRepository.save(n); - Runnable asyncTask = () -> { +// Runnable asyncTask = () -> { if (type == NotificationType.COMMENT_REPLY && user.getEmail() != null && post != null && comment != null) { String url = String.format("%s/posts/%d#comment-%d", websiteUrl, post.getId(), comment.getId()); emailSender.sendEmail(user.getEmail(), "有人回复了你", url); @@ -96,18 +96,18 @@ public class NotificationService { // } // } } - }; +// }; - if (TransactionSynchronizationManager.isSynchronizationActive()) { - TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { - @Override - public void afterCommit() { - notificationExecutor.execute(asyncTask); - } - }); - } else { - notificationExecutor.execute(asyncTask); - } +// if (TransactionSynchronizationManager.isSynchronizationActive()) { +// TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { +// @Override +// public void afterCommit() { +// notificationExecutor.execute(asyncTask); +// } +// }); +// } else { +// notificationExecutor.execute(asyncTask); +// } return n; }