xinyin025/OpenIsle
1
0
Fork 0
mirror of https://github.com/nagisa77/OpenIsle.git synced 2026-06-26 15:44:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Cancel lottery schedule on post deletion

Browse Source
This commit is contained in:
Tim
2025-08-11 10:05:37 +08:00
parent 692fc6d1d0
commit a774c9cc97
1 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/main/java/com/openisle/service/PostService.java
+14 -1
View File
@@ -38,6 +38,9 @@ import java.time.LocalDateTime;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections; import java.util.Collections;
import java.util.HashSet; import java.util.HashSet;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.ScheduledFuture;
@Service @Service
public class PostService { public class PostService {
@@ -58,6 +61,7 @@ public class PostService {
private final ImageUploader imageUploader; private final ImageUploader imageUploader;
private final TaskScheduler taskScheduler; private final TaskScheduler taskScheduler;
private final EmailSender emailSender; private final EmailSender emailSender;
private final ConcurrentMap<Long, ScheduledFuture<?>> scheduledFinalizations = new ConcurrentHashMap<>();
@org.springframework.beans.factory.annotation.Autowired @org.springframework.beans.factory.annotation.Autowired
public PostService(PostRepository postRepository, public PostService(PostRepository postRepository,
@@ -186,8 +190,10 @@ public class PostService {
notificationService.notifyMentions(content, author, post, null); notificationService.notifyMentions(content, author, post, null);
if (post instanceof LotteryPost lp && lp.getEndTime() != null) { if (post instanceof LotteryPost lp && lp.getEndTime() != null) {
taskScheduler.schedule(() -> finalizeLottery(lp.getId()), ScheduledFuture<?> future = taskScheduler.schedule(
() -> finalizeLottery(lp.getId()),
java.util.Date.from(lp.getEndTime().atZone(ZoneId.systemDefault()).toInstant())); java.util.Date.from(lp.getEndTime().atZone(ZoneId.systemDefault()).toInstant()));
scheduledFinalizations.put(lp.getId(), future);
} }
return post; return post;
} }
@@ -202,6 +208,7 @@ public class PostService {
} }
private void finalizeLottery(Long postId) { private void finalizeLottery(Long postId) {
scheduledFinalizations.remove(postId);
lotteryPostRepository.findById(postId).ifPresent(lp -> { lotteryPostRepository.findById(postId).ifPresent(lp -> {
List<User> participants = new ArrayList<>(lp.getParticipants()); List<User> participants = new ArrayList<>(lp.getParticipants());
if (participants.isEmpty()) { if (participants.isEmpty()) {
@@ -506,6 +513,12 @@ public class PostService {
notificationRepository.deleteAll(notificationRepository.findByPost(post)); notificationRepository.deleteAll(notificationRepository.findByPost(post));
postReadService.deleteByPost(post); postReadService.deleteByPost(post);
imageUploader.removeReferences(imageUploader.extractUrls(post.getContent())); imageUploader.removeReferences(imageUploader.extractUrls(post.getContent()));
if (post instanceof LotteryPost lp) {
ScheduledFuture<?> future = scheduledFinalizations.remove(lp.getId());
if (future != null) {
future.cancel(false);
}
}
postRepository.delete(post); postRepository.delete(post);
} }