jiazhizhong/OpenIsle
1
0
Fork 0
mirror of https://github.com/nagisa77/OpenIsle.git synced 2026-06-09 19:47:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source 
This reverts commit 4e0dda3a24.
This commit is contained in:
tim
2025-08-05 23:54:40 +08:00
parent e491a00c57
commit 26ed082f93
1 changed files with 6 additions and 3 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,7 +51,10 @@ public class NotificationService {
pushNotificationService.sendNotification(user, buildPayload(body, url)); pushNotificationService.sendNotification(user, buildPayload(body, url));
} }
@Transactional public Notification createNotification(User user, NotificationType type, Post post, Comment comment, Boolean approved) {
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();
@@ -68,7 +71,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);
@@ -92,7 +95,7 @@ public class NotificationService {
// } // }
// } // }
} }
// }); });
return n; return n;
} }