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

feat: 修改邮件格式

Browse Source
This commit is contained in:
Tim
2025-07-30 12:14:11 +08:00
parent 748f7f9709
commit 995cfdf87e
1 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/main/java/com/openisle/service/NotificationService.java
View File

@@ -27,14 +27,16 @@ public class NotificationService {
private String websiteUrl; private String websiteUrl;
private String buildPayload(String body, String url) { private String buildPayload(String body, String url) {
try { // try {
return new ObjectMapper().writeValueAsString(Map.of( // return new ObjectMapper().writeValueAsString(Map.of(
"body", body, // "body", body,
"url", url // "url", url
)); // ));
} catch (Exception e) { // } catch (Exception e) {
return body; // return body;
} // }
return body;
} }
public void sendCustomPush(User user, String body, String url) { public void sendCustomPush(User user, String body, String url) {
@@ -60,15 +62,16 @@ public class NotificationService {
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(), "【OpenIsle】有人回复了你", url); String pushContent = comment.getAuthor() + "回复了你: \"" + comment.getContent() + "\"";
sendCustomPush(user, "有人回复了你", url); emailSender.sendEmail(user.getEmail(), "【OpenIsle】您有新的回复", pushContent + ", 点击以查看: " + url);
sendCustomPush(user, pushContent, url);
} else if (type == NotificationType.REACTION && comment != null) { } else if (type == NotificationType.REACTION && comment != null) {
long count = reactionRepository.countReceived(comment.getAuthor().getUsername()); long count = reactionRepository.countReceived(comment.getAuthor().getUsername());
if (count % 5 == 0) { if (count % 5 == 0) {
String url = websiteUrl + "/messages"; String url = websiteUrl + "/messages";
sendCustomPush(comment.getAuthor(), "你有新的互动", url); sendCustomPush(comment.getAuthor(), "你有新的互动", url);
if (comment.getAuthor().getEmail() != null) { if (comment.getAuthor().getEmail() != null) {
emailSender.sendEmail(comment.getAuthor().getEmail(), "【OpenIsle】你有新的互动", url); emailSender.sendEmail(comment.getAuthor().getEmail(), "【OpenIsle】你有新的互动", "你有新的互动, 点击以查看: " + url);
} }
} }
} else if (type == NotificationType.REACTION && post != null) { } else if (type == NotificationType.REACTION && post != null) {
@@ -77,7 +80,7 @@ public class NotificationService {
String url = websiteUrl + "/messages"; String url = websiteUrl + "/messages";
sendCustomPush(post.getAuthor(), "你有新的互动", url); sendCustomPush(post.getAuthor(), "你有新的互动", url);
if (post.getAuthor().getEmail() != null) { if (post.getAuthor().getEmail() != null) {
emailSender.sendEmail(post.getAuthor().getEmail(), "【OpenIsle】你有新的互动", url); emailSender.sendEmail(post.getAuthor().getEmail(), "【OpenIsle】你有新的互动", "你有新的互动, 点击以查看: " + url);
} }
} }
} }