jiazhizhong/OpenIsle
1
0
Fork 0
mirror of https://github.com/nagisa77/OpenIsle.git synced 2026-05-09 12:17:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

revert: 通知取消异步，并且采用事务，看看能否解决 400

Browse Source
This commit is contained in:
tim
2025-08-05 23:26:15 +08:00
parent caba1c6658
commit 4e0dda3a24
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
backend/src/main/java/com/openisle/service/NotificationService.java
View File

@@ -51,10 +51,7 @@ public class NotificationService {
pushNotificationService.sendNotification(user, buildPayload(body, url)); pushNotificationService.sendNotification(user, buildPayload(body, url));
} }
public Notification createNotification(User user, NotificationType type, Post post, Comment comment, Boolean approved) { @Transactional
return createNotification(user, type, post, comment, approved, null, null, null);
}
public Notification createNotification(User user, NotificationType type, Post post, Comment comment, Boolean approved, public Notification createNotification(User user, NotificationType type, Post post, Comment comment, Boolean approved,
User fromUser, ReactionType reactionType, String content) { User fromUser, ReactionType reactionType, String content) {
Notification n = new Notification(); Notification n = new Notification();
@@ -71,7 +68,7 @@ public class NotificationService {
} }
n = notificationRepository.save(n); n = notificationRepository.save(n);
notificationExecutor.execute(() -> { // notificationExecutor.execute(() -> {
if (type == NotificationType.COMMENT_REPLY && user.getEmail() != null && post != null && comment != null) { 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()); String url = String.format("%s/posts/%d#comment-%d", websiteUrl, post.getId(), comment.getId());
emailSender.sendEmail(user.getEmail(), "有人回复了你", url); emailSender.sendEmail(user.getEmail(), "有人回复了你", url);
@@ -95,7 +92,7 @@ public class NotificationService {
// } // }
// } // }
} }
}); // });
return n; return n;
} }