jiazhizhong/OpenIsle
1
0
Fork 0
mirror of https://github.com/nagisa77/OpenIsle.git synced 2026-02-21 22:41:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

bugfix: 规避后台偶现失败的问题

Browse Source
This commit is contained in:
tim
2025-08-03 14:28:51 +08:00
parent ca9b2cb14d
commit 41f603e349
3 changed files with 21 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
backend/src/main/java/com/openisle/controller/ReactionController.java
View File

@@ -4,6 +4,7 @@ import com.openisle.model.Reaction;
import com.openisle.model.ReactionType;
import com.openisle.service.ReactionService;
import com.openisle.service.LevelService;
import jakarta.transaction.Transactional;
import lombok.Data;
import lombok.RequiredArgsConstructor;
import org.springframework.http.ResponseEntity;
@@ -26,6 +27,7 @@ public class ReactionController {
}
@PostMapping("/posts/{postId}/reactions")
@Transactional
public ResponseEntity<ReactionDto> reactToPost(@PathVariable Long postId,
@RequestBody ReactionRequest req,
Authentication auth) {
@@ -39,6 +41,7 @@ public class ReactionController {
}
@PostMapping("/comments/{commentId}/reactions")
@Transactional
public ResponseEntity<ReactionDto> reactToComment(@PathVariable Long commentId,
@RequestBody ReactionRequest req,
Authentication auth) {

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

@@ -78,23 +78,23 @@ public class NotificationService {
emailSender.sendEmail(user.getEmail(), "您有新的回复", pushContent + ", 点击以查看: " + url);
sendCustomPush(user, pushContent, url);
} else if (type == NotificationType.REACTION && comment != null) {
long count = reactionRepository.countReceived(comment.getAuthor().getUsername());
if (count % 5 == 0) {
String url = websiteUrl + "/messages";
sendCustomPush(comment.getAuthor(), "你有新的互动", url);
if (comment.getAuthor().getEmail() != null) {
emailSender.sendEmail(comment.getAuthor().getEmail(), "你有新的互动", "你有新的互动, 点击以查看: " + url);
}
}
// long count = reactionRepository.countReceived(comment.getAuthor().getUsername());
// if (count % 5 == 0) {
// String url = websiteUrl + "/messages";
// sendCustomPush(comment.getAuthor(), "你有新的互动", url);
// if (comment.getAuthor().getEmail() != null) {
// emailSender.sendEmail(comment.getAuthor().getEmail(), "你有新的互动", "你有新的互动, 点击以查看: " + url);
// }
// }
} else if (type == NotificationType.REACTION && post != null) {
long count = reactionRepository.countReceived(post.getAuthor().getUsername());
if (count % 5 == 0) {
String url = websiteUrl + "/messages";
sendCustomPush(post.getAuthor(), "你有新的互动", url);
if (post.getAuthor().getEmail() != null) {
emailSender.sendEmail(post.getAuthor().getEmail(), "你有新的互动", "你有新的互动, 点击以查看: " + url);
}
}
// long count = reactionRepository.countReceived(post.getAuthor().getUsername());
// if (count % 5 == 0) {
// String url = websiteUrl + "/messages";
// sendCustomPush(post.getAuthor(), "你有新的互动", url);
// if (post.getAuthor().getEmail() != null) {
// emailSender.sendEmail(post.getAuthor().getEmail(), "你有新的互动", "你有新的互动, 点击以查看: " + url);
// }
// }
}
});