feat: 添加关闭

支持分页加载

backend/src/main/java/com/openisle/controller/NotificationController.java

@@ -24,16 +24,18 @@ public class NotificationController {
 
     @GetMapping
     public List<NotificationDto> list(@RequestParam(value = "page", defaultValue = "0") int page,
+                                      @RequestParam(value = "size", defaultValue = "30") int size,
                                       Authentication auth) {
-        return notificationService.listNotifications(auth.getName(), null, page).stream()
+        return notificationService.listNotifications(auth.getName(), null, page, size).stream()
                 .map(notificationMapper::toDto)
                 .collect(Collectors.toList());
     }
 
     @GetMapping("/unread")
     public List<NotificationDto> listUnread(@RequestParam(value = "page", defaultValue = "0") int page,
+                                            @RequestParam(value = "size", defaultValue = "30") int size,
                                             Authentication auth) {
-        return notificationService.listNotifications(auth.getName(), false, page).stream()
+        return notificationService.listNotifications(auth.getName(), false, page, size).stream()
                 .map(notificationMapper::toDto)
                 .collect(Collectors.toList());
     }

backend/src/main/java/com/openisle/controller/PostController.java

@@ -62,6 +62,16 @@ public class PostController {
         postService.deletePost(id, auth.getName());
     }
 
+    @PostMapping("/{id}/close")
+    public PostSummaryDto close(@PathVariable Long id, Authentication auth) {
+        return postMapper.toSummaryDto(postService.closePost(id, auth.getName()));
+    }
+
+    @PostMapping("/{id}/reopen")
+    public PostSummaryDto reopen(@PathVariable Long id, Authentication auth) {
+        return postMapper.toSummaryDto(postService.reopenPost(id, auth.getName()));
+    }
+
     @GetMapping("/{id}")
     public ResponseEntity<PostDetailDto> getPost(@PathVariable Long id, Authentication auth) {
         String viewer = auth != null ? auth.getName() : null;

backend/src/main/java/com/openisle/dto/PostSummaryDto.java

@@ -32,5 +32,6 @@ public class PostSummaryDto {
     private PostType type;
     private LotteryDto lottery;
     private boolean rssExcluded;
+    private boolean closed;
 }
 

backend/src/main/java/com/openisle/mapper/PostMapper.java

@@ -64,6 +64,7 @@ public class PostMapper {
         dto.setStatus(post.getStatus());
         dto.setPinnedAt(post.getPinnedAt());
         dto.setRssExcluded(post.getRssExcluded() == null || post.getRssExcluded());
+        dto.setClosed(post.isClosed());
 
         List<ReactionDto> reactions = reactionService.getReactionsForPost(post.getId())
                 .stream()

backend/src/main/java/com/openisle/model/Post.java

@@ -64,6 +64,9 @@ public class Post {
     @Column(nullable = false)
     private PostType type = PostType.NORMAL;
 
+    @Column(nullable = false)
+    private boolean closed = false;
+
     @Column
     private LocalDateTime pinnedAt;
 

backend/src/main/java/com/openisle/repository/NotificationRepository.java

@@ -5,9 +5,9 @@ import com.openisle.model.User;
 import com.openisle.model.Post;
 import com.openisle.model.Comment;
 import com.openisle.model.NotificationType;
+import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
-import org.springframework.data.jpa.repository.JpaRepository;
 
 import java.util.List;
 
@@ -15,10 +15,12 @@ import java.util.List;
 public interface NotificationRepository extends JpaRepository<Notification, Long> {
     List<Notification> findByUserOrderByCreatedAtDesc(User user);
     List<Notification> findByUserAndReadOrderByCreatedAtDesc(User user, boolean read);
-
     Page<Notification> findByUserOrderByCreatedAtDesc(User user, Pageable pageable);
     Page<Notification> findByUserAndReadOrderByCreatedAtDesc(User user, boolean read, Pageable pageable);
+    Page<Notification> findByUserAndTypeNotInOrderByCreatedAtDesc(User user, java.util.Collection<NotificationType> types, Pageable pageable);
+    Page<Notification> findByUserAndReadAndTypeNotInOrderByCreatedAtDesc(User user, boolean read, java.util.Collection<NotificationType> types, Pageable pageable);
     long countByUserAndRead(User user, boolean read);
+    long countByUserAndReadAndTypeNotIn(User user, boolean read, java.util.Collection<NotificationType> types);
     List<Notification> findByPost(Post post);
     List<Notification> findByComment(Comment comment);
 

backend/src/main/java/com/openisle/service/CommentService.java

@@ -52,6 +52,9 @@ public class CommentService {
                 .orElseThrow(() -> new com.openisle.exception.NotFoundException("User not found"));
         Post post = postRepository.findById(postId)
                 .orElseThrow(() -> new com.openisle.exception.NotFoundException("Post not found"));
+        if (post.isClosed()) {
+            throw new IllegalStateException("Post closed");
+        }
         Comment comment = new Comment();
         comment.setAuthor(author);
         comment.setPost(post);
@@ -94,6 +97,9 @@ public class CommentService {
                 .orElseThrow(() -> new com.openisle.exception.NotFoundException("User not found"));
         Comment parent = commentRepository.findById(parentId)
                 .orElseThrow(() -> new IllegalArgumentException("Comment not found"));
+        if (parent.getPost().isClosed()) {
+            throw new IllegalStateException("Post closed");
+        }
         Comment comment = new Comment();
         comment.setAuthor(author);
         comment.setPost(parent.getPost());

backend/src/main/java/com/openisle/service/NotificationService.java

@@ -23,9 +23,6 @@ import java.util.HashSet;
 import java.util.List;
 import java.util.ArrayList;
 import java.util.concurrent.Executor;
-import java.util.stream.Collectors;
-import org.springframework.data.domain.Page;
-import org.springframework.data.domain.Pageable;
 
 /** Service for creating and retrieving notifications. */
 @Service
@@ -182,22 +179,26 @@ public class NotificationService {
         userRepository.save(user);
     }
 
-    public List<Notification> listNotifications(String username, Boolean read) {
-        return listNotifications(username, read, 0);
-    }
-
-    public List<Notification> listNotifications(String username, Boolean read, int page) {
+    public List<Notification> listNotifications(String username, Boolean read, int page, int size) {
         User user = userRepository.findByUsername(username)
                 .orElseThrow(() -> new com.openisle.exception.NotFoundException("User not found"));
         Set<NotificationType> disabled = user.getDisabledNotificationTypes();
-        Page<Notification> p;
-        Pageable pageable = org.springframework.data.domain.PageRequest.of(page, 50);
+        org.springframework.data.domain.Pageable pageable = org.springframework.data.domain.PageRequest.of(page, size);
+        org.springframework.data.domain.Page<Notification> result;
         if (read == null) {
-            p = notificationRepository.findByUserOrderByCreatedAtDesc(user, pageable);
+            if (disabled.isEmpty()) {
+                result = notificationRepository.findByUserOrderByCreatedAtDesc(user, pageable);
+            } else {
+                result = notificationRepository.findByUserAndTypeNotInOrderByCreatedAtDesc(user, disabled, pageable);
+            }
         } else {
-            p = notificationRepository.findByUserAndReadOrderByCreatedAtDesc(user, read, pageable);
+            if (disabled.isEmpty()) {
+                result = notificationRepository.findByUserAndReadOrderByCreatedAtDesc(user, read, pageable);
+            } else {
+                result = notificationRepository.findByUserAndReadAndTypeNotInOrderByCreatedAtDesc(user, read, disabled, pageable);
+            }
         }
-        return p.getContent().stream().filter(n -> !disabled.contains(n.getType())).collect(Collectors.toList());
+        return result.getContent();
     }
 
     public void markRead(String username, List<Long> ids) {
@@ -216,8 +217,10 @@ public class NotificationService {
         User user = userRepository.findByUsername(username)
                 .orElseThrow(() -> new com.openisle.exception.NotFoundException("User not found"));
         Set<NotificationType> disabled = user.getDisabledNotificationTypes();
-        return notificationRepository.findByUserAndReadOrderByCreatedAtDesc(user, false).stream()
-                .filter(n -> !disabled.contains(n.getType())).count();
+        if (disabled.isEmpty()) {
+            return notificationRepository.countByUserAndRead(user, false);
+        }
+        return notificationRepository.countByUserAndReadAndTypeNotIn(user, false, disabled);
     }
 
     public void notifyMentions(String content, User fromUser, Post post, Comment comment) {

backend/src/main/java/com/openisle/service/PostService.java

@@ -512,6 +512,30 @@ public class PostService {
         return postRepository.save(post);
     }
 
+    public Post closePost(Long id, String username) {
+        Post post = postRepository.findById(id)
+                .orElseThrow(() -> new com.openisle.exception.NotFoundException("Post not found"));
+        User user = userRepository.findByUsername(username)
+                .orElseThrow(() -> new com.openisle.exception.NotFoundException("User not found"));
+        if (!user.getId().equals(post.getAuthor().getId()) && user.getRole() != Role.ADMIN) {
+            throw new IllegalArgumentException("Unauthorized");
+        }
+        post.setClosed(true);
+        return postRepository.save(post);
+    }
+
+    public Post reopenPost(Long id, String username) {
+        Post post = postRepository.findById(id)
+                .orElseThrow(() -> new com.openisle.exception.NotFoundException("Post not found"));
+        User user = userRepository.findByUsername(username)
+                .orElseThrow(() -> new com.openisle.exception.NotFoundException("User not found"));
+        if (!user.getId().equals(post.getAuthor().getId()) && user.getRole() != Role.ADMIN) {
+            throw new IllegalArgumentException("Unauthorized");
+        }
+        post.setClosed(false);
+        return postRepository.save(post);
+    }
+
     @org.springframework.transaction.annotation.Transactional
     public Post updatePost(Long id,
                            String username,

backend/src/test/java/com/openisle/controller/NotificationControllerTest.java

@@ -45,7 +45,7 @@ class NotificationControllerTest {
         p.setId(2L);
         n.setPost(p);
         n.setCreatedAt(LocalDateTime.now());
-        when(notificationService.listNotifications("alice", null, 0))
+        when(notificationService.listNotifications("alice", null, 0, 30))
                 .thenReturn(List.of(n));
 
         NotificationDto dto = new NotificationDto();
@@ -65,18 +65,19 @@ class NotificationControllerTest {
     @Test
     void listUnreadNotifications() throws Exception {
         Notification n = new Notification();
-        n.setId(3L);
+        n.setId(5L);
         n.setType(NotificationType.POST_VIEWED);
-        when(notificationService.listNotifications("alice", false, 0)).thenReturn(List.of(n));
+        when(notificationService.listNotifications("alice", false, 0, 30))
+                .thenReturn(List.of(n));
 
         NotificationDto dto = new NotificationDto();
-        dto.setId(3L);
+        dto.setId(5L);
         when(notificationMapper.toDto(n)).thenReturn(dto);
 
         mockMvc.perform(get("/api/notifications/unread")
-                        .principal(new UsernamePasswordAuthenticationToken("alice", "p")))
+                        .principal(new UsernamePasswordAuthenticationToken("alice","p")))
                 .andExpect(status().isOk())
-                .andExpect(jsonPath("$[0].id").value(3));
+                .andExpect(jsonPath("$[0].id").value(5));
     }
 
     @Test

backend/src/test/java/com/openisle/service/NotificationServiceTest.java

@@ -11,6 +11,9 @@ import org.mockito.Mockito;
 
 import java.util.List;
 import java.util.Optional;
+import java.util.HashSet;
+import org.springframework.data.domain.PageImpl;
+import org.springframework.data.domain.Pageable;
 
 import static org.junit.jupiter.api.Assertions.*;
 import static org.mockito.Mockito.*;
@@ -62,18 +65,17 @@ class NotificationServiceTest {
         User user = new User();
         user.setId(2L);
         user.setUsername("bob");
+        user.setDisabledNotificationTypes(new HashSet<>());
         when(uRepo.findByUsername("bob")).thenReturn(Optional.of(user));
 
         Notification n = new Notification();
-        org.springframework.data.domain.Page<Notification> page =
-                new org.springframework.data.domain.PageImpl<>(List.of(n));
-        when(nRepo.findByUserOrderByCreatedAtDesc(eq(user), any(org.springframework.data.domain.Pageable.class)))
-                .thenReturn(page);
+        when(nRepo.findByUserOrderByCreatedAtDesc(eq(user), any(Pageable.class)))
+                .thenReturn(new PageImpl<>(List.of(n)));
 
-        List<Notification> list = service.listNotifications("bob", null);
+        List<Notification> list = service.listNotifications("bob", null, 0, 10);
 
         assertEquals(1, list.size());
-        verify(nRepo).findByUserOrderByCreatedAtDesc(eq(user), any(org.springframework.data.domain.Pageable.class));
+        verify(nRepo).findByUserOrderByCreatedAtDesc(eq(user), any(Pageable.class));
     }
 
     @Test
@@ -90,6 +92,7 @@ class NotificationServiceTest {
         User user = new User();
         user.setId(3L);
         user.setUsername("carl");
+        user.setDisabledNotificationTypes(new HashSet<>());
         when(uRepo.findByUsername("carl")).thenReturn(Optional.of(user));
         when(nRepo.countByUserAndRead(user, false)).thenReturn(5L);
 
@@ -99,6 +102,56 @@ class NotificationServiceTest {
         verify(nRepo).countByUserAndRead(user, false);
     }
 
+    @Test
+    void listNotificationsFiltersDisabledTypes() {
+        NotificationRepository nRepo = mock(NotificationRepository.class);
+        UserRepository uRepo = mock(UserRepository.class);
+        ReactionRepository rRepo = mock(ReactionRepository.class);
+        EmailSender email = mock(EmailSender.class);
+        PushNotificationService push = mock(PushNotificationService.class);
+        Executor executor = Runnable::run;
+        NotificationService service = new NotificationService(nRepo, uRepo, email, push, rRepo, executor);
+        org.springframework.test.util.ReflectionTestUtils.setField(service, "websiteUrl", "https://ex.com");
+
+        User user = new User();
+        user.setId(4L);
+        user.setUsername("dana");
+        when(uRepo.findByUsername("dana")).thenReturn(Optional.of(user));
+
+        Notification n = new Notification();
+        when(nRepo.findByUserAndTypeNotInOrderByCreatedAtDesc(eq(user), eq(user.getDisabledNotificationTypes()), any(Pageable.class)))
+                .thenReturn(new PageImpl<>(List.of(n)));
+
+        List<Notification> list = service.listNotifications("dana", null, 0, 10);
+
+        assertEquals(1, list.size());
+        verify(nRepo).findByUserAndTypeNotInOrderByCreatedAtDesc(eq(user), eq(user.getDisabledNotificationTypes()), any(Pageable.class));
+    }
+
+    @Test
+    void countUnreadFiltersDisabledTypes() {
+        NotificationRepository nRepo = mock(NotificationRepository.class);
+        UserRepository uRepo = mock(UserRepository.class);
+        ReactionRepository rRepo = mock(ReactionRepository.class);
+        EmailSender email = mock(EmailSender.class);
+        PushNotificationService push = mock(PushNotificationService.class);
+        Executor executor = Runnable::run;
+        NotificationService service = new NotificationService(nRepo, uRepo, email, push, rRepo, executor);
+        org.springframework.test.util.ReflectionTestUtils.setField(service, "websiteUrl", "https://ex.com");
+
+        User user = new User();
+        user.setId(5L);
+        user.setUsername("erin");
+        when(uRepo.findByUsername("erin")).thenReturn(Optional.of(user));
+        when(nRepo.countByUserAndReadAndTypeNotIn(eq(user), eq(false), eq(user.getDisabledNotificationTypes())))
+                .thenReturn(2L);
+
+        long count = service.countUnread("erin");
+
+        assertEquals(2L, count);
+        verify(nRepo).countByUserAndReadAndTypeNotIn(eq(user), eq(false), eq(user.getDisabledNotificationTypes()));
+    }
+
     @Test
     void createRegisterRequestNotificationsDeletesOldOnes() {
         NotificationRepository nRepo = mock(NotificationRepository.class);

frontend_nuxt/app.vue

@@ -21,6 +21,7 @@
       </div>
     </div>
     <GlobalPopups />
+    <ConfirmDialog />
   </div>
 </template>
 
@@ -28,6 +29,7 @@
 import HeaderComponent from '~/components/HeaderComponent.vue'
 import MenuComponent from '~/components/MenuComponent.vue'
 import GlobalPopups from '~/components/GlobalPopups.vue'
+import ConfirmDialog from '~/components/ConfirmDialog.vue'
 import { useIsMobile } from '~/utils/screen'
 
 const isMobile = useIsMobile()

frontend_nuxt/assets/global.css

@@ -90,7 +90,8 @@ body {
 }
 
 .vditor-toolbar--pin {
-  top: var(--header-height) !important;
+  top: calc(var(--header-height) + 1px) !important;
+  z-index: 2000;
 }
 
 .vditor-panel {

frontend_nuxt/components/CommentEditor.vue

@@ -22,6 +22,7 @@ import {
   getEditorTheme as getEditorThemeUtil,
   getPreviewTheme as getPreviewThemeUtil,
 } from '~/utils/vditor'
+import '~/assets/global.css'
 import LoginOverlay from '~/components/LoginOverlay.vue'
 
 export default {

frontend_nuxt/components/CommentItem.vue

@@ -57,7 +57,7 @@
           v-if="showEditor"
           @submit="submitReply"
           :loading="isWaitingForReply"
-          :disabled="!loggedIn"
+          :disabled="!loggedIn || postClosed"
           :show-login-overlay="!loggedIn"
           :parent-user-name="comment.userName"
         />
@@ -76,6 +76,7 @@
               :level="level + 1"
               :default-show-replies="item.openReplies"
               :post-author-id="postAuthorId"
+              :post-closed="postClosed"
             />
           </template>
         </BaseTimeline>
@@ -122,6 +123,10 @@ const props = defineProps({
     type: [Number, String],
     required: true,
   },
+  postClosed: {
+    type: Boolean,
+    default: false,
+  },
 })
 
 const emit = defineEmits(['deleted'])
@@ -148,6 +153,7 @@ const toggleReplies = () => {
 }
 
 const toggleEditor = () => {
+  if (props.postClosed) return
   showEditor.value = !showEditor.value
   if (showEditor.value) {
     setTimeout(() => {
@@ -213,6 +219,10 @@ const deleteComment = async () => {
 }
 const submitReply = async (parentUserName, text, clear) => {
   if (!text.trim()) return
+  if (props.postClosed) {
+    toast.error('帖子已关闭')
+    return
+  }
   isWaitingForReply.value = true
   const token = getToken()
   if (!token) {

frontend_nuxt/components/ConfirmDialog.vue

@@ -0,0 +1,71 @@
+<template>
+  <BasePopup :visible="visible" @close="onCancel">
+    <div class="confirm-dialog" role="dialog" aria-modal="true">
+      <h3 class="confirm-title">{{ title }}</h3>
+      <p class="confirm-message">{{ message }}</p>
+      <div class="confirm-actions">
+        <div class="cancel-button" @click="onCancel">取消</div>
+        <div class="confirm-button" @click="onConfirm">确认</div>
+      </div>
+    </div>
+  </BasePopup>
+</template>
+
+<script setup lang="ts">
+import BasePopup from '~/components/BasePopup.vue'
+import { useConfirm } from '~/composables/useConfirm'
+
+const { visible, title, message, onConfirm, onCancel } = useConfirm()
+</script>
+
+<style scoped>
+.confirm-dialog {
+  padding: 20px;
+  text-align: center;
+}
+.confirm-title {
+  margin-top: 0;
+  font-size: 18px;
+  font-weight: 600;
+}
+.confirm-message {
+  margin: 16px 0 20px;
+  line-height: 1.6;
+  color: var(--text-secondary, #666);
+}
+.confirm-actions {
+  display: flex;
+  justify-content: center;
+  gap: 12px;
+}
+.confirm-button,
+.cancel-button {
+  min-width: 88px;
+  height: 36px;
+  padding: 0 14px;
+  border-radius: 8px;
+  cursor: pointer;
+  border: 1px solid transparent;
+}
+.confirm-button {
+  background: var(--primary-color);
+  color: #fff;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+}
+.confirm-button:hover {
+  background: var(--primary-color-hover);
+}
+.cancel-button {
+  background: transparent;
+  color: var(--primary-color);
+  border-color: currentColor;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+}
+.cancel-button:hover {
+  opacity: 0.85;
+}
+</style>

frontend_nuxt/components/PostEditor.vue

@@ -16,6 +16,7 @@ import {
   getEditorTheme as getEditorThemeUtil,
   getPreviewTheme as getPreviewThemeUtil,
 } from '~/utils/vditor'
+import '~/assets/global.css'
 
 export default {
   name: 'PostEditor',

frontend_nuxt/components/ReactionsGroup.vue

@@ -51,6 +51,10 @@ import { computed, onMounted, ref, watch } from 'vue'
 import { toast } from '~/main'
 import { authState, getToken } from '~/utils/auth'
 import { reactionEmojiMap } from '~/utils/reactions'
+import { useReactionTypes } from '~/composables/useReactionTypes'
+
+const { reactionTypes, initialize } = useReactionTypes()
+
 const config = useRuntimeConfig()
 const API_BASE_URL = config.public.apiBaseUrl
 const emit = defineEmits(['update:modelValue'])
@@ -66,30 +70,6 @@ watch(
 )
 
 const reactions = ref(props.modelValue)
-const reactionTypes = ref([])
-
-let cachedTypes = null
-const fetchTypes = async () => {
-  if (cachedTypes) return cachedTypes
-  try {
-    const token = getToken()
-    const res = await fetch(`${API_BASE_URL}/api/reaction-types`, {
-      headers: { Authorization: token ? `Bearer ${token}` : '' },
-    })
-    if (res.ok) {
-      cachedTypes = await res.json()
-    } else {
-      cachedTypes = []
-    }
-  } catch {
-    cachedTypes = []
-  }
-  return cachedTypes
-}
-
-onMounted(async () => {
-  reactionTypes.value = await fetchTypes()
-})
 
 const counts = computed(() => {
   const c = {}
@@ -200,6 +180,10 @@ const toggleReaction = async (type) => {
     toast.error('操作失败')
   }
 }
+
+onMounted(async () => {
+  await initialize()
+})
 </script>
 
 <style>
@@ -253,7 +237,7 @@ const toggleReaction = async (type) => {
 
 .make-reaction-item {
   cursor: pointer;
-  padding: 10px;
+  padding: 4px;
   opacity: 0.5;
   border-radius: 8px;
   font-size: 20px;

frontend_nuxt/composables/useConfirm.ts

@@ -0,0 +1,52 @@
+// composables/useConfirm.ts
+import { ref } from 'vue'
+
+// 全局单例（SPA 下即可；Nuxt/SSR 下见文末“SSR 提醒”）
+const visible = ref(false)
+const title = ref('')
+const message = ref('')
+
+let resolver: ((ok: boolean) => void) | null = null
+
+function reset() {
+  visible.value = false
+  title.value = ''
+  message.value = ''
+  resolver = null
+}
+
+export function useConfirm() {
+  /**
+   * 打开确认框，返回 Promise<boolean>
+   * - 确认 => resolve(true)
+   * - 取消/关闭 => resolve(false)
+   * 若并发调用，以最后一次为准（更简单直观）
+   */
+  const confirm = (t: string, m: string) => {
+    title.value = t
+    message.value = m
+    visible.value = true
+    return new Promise<boolean>((resolve) => {
+      resolver = resolve
+    })
+  }
+
+  const onConfirm = () => {
+    resolver?.(true)
+    reset()
+  }
+
+  const onCancel = () => {
+    resolver?.(false)
+    reset()
+  }
+
+  return {
+    visible,
+    title,
+    message,
+    confirm,
+    onConfirm,
+    onCancel,
+  }
+}

frontend_nuxt/composables/useReactionTypes.js

@@ -0,0 +1,52 @@
+import { ref } from 'vue'
+
+const reactionTypes = ref([])
+let isLoading = false
+let isInitialized = false
+
+export function useReactionTypes() {
+  const config = useRuntimeConfig()
+  const API_BASE_URL = config.public.apiBaseUrl
+
+  const fetchReactionTypes = async () => {
+    if (isInitialized || isLoading) {
+      reactionTypes.value = [...(window.reactionTypes || [])]
+      return reactionTypes.value
+    }
+    
+    isLoading = true
+    try {
+      const token = getToken()
+      const res = await fetch(`${API_BASE_URL}/api/reaction-types`, {
+        headers: { Authorization: token ? `Bearer ${token}` : '' },
+      })
+      if (res.ok) {
+        reactionTypes.value = await res.json()
+        window.reactionTypes = [...reactionTypes.value]
+        isInitialized = true
+      } else {
+        reactionTypes.value = []
+      }
+    } catch (error) {
+      console.error('Failed to fetch reaction types:', error)
+      reactionTypes.value = []
+    } finally {
+      isLoading = false
+    }
+    return reactionTypes.value
+  }
+
+  const initialize = async () => {
+    if (!isInitialized) {
+      await fetchReactionTypes()
+    }
+    return reactionTypes.value
+  }
+
+  return {
+    reactionTypes: readonly(reactionTypes),
+    fetchReactionTypes,
+    initialize,
+    isInitialized: readonly(isInitialized)
+  }
+}

frontend_nuxt/pages/index.vue

@@ -535,6 +535,7 @@ const sanitizeDescription = (text) => stripMarkdown(text)
 }
 
 .article-item-description {
+  max-width: 100%;
   margin-top: 10px;
   font-size: 14px;
   color: gray;

frontend_nuxt/pages/message.vue

@@ -505,14 +505,14 @@
             </div>
           </template>
         </BaseTimeline>
-        <InfiniteLoadMore :key="ioKey" :on-load="fetchNextPage" :pause="isLoadingMessage" />
+        <InfiniteLoadMore :key="selectedTab" :on-load="loadMore" :pause="isLoadingMessage" />
       </div>
     </template>
   </div>
 </template>
 
 <script setup>
-import { onActivated, ref, watch } from 'vue'
+import { ref, watch, onActivated } from 'vue'
 import BasePlaceholder from '~/components/BasePlaceholder.vue'
 import BaseTimeline from '~/components/BaseTimeline.vue'
 import NotificationContainer from '~/components/NotificationContainer.vue'
@@ -527,6 +527,7 @@ import {
   markRead,
   notifications,
   markAllRead,
+  hasMore,
   fetchNotificationPreferences,
   updateNotificationPreference,
 } from '~/utils/notification'
@@ -539,7 +540,25 @@ const selectedTab = ref(
   ['all', 'unread', 'control'].includes(route.query.tab) ? route.query.tab : 'unread',
 )
 const notificationPrefs = ref([])
-const ioKey = ref(0)
+const page = ref(0)
+const pageSize = 30
+
+const loadMore = async () => {
+  if (!hasMore.value) return true
+  page.value++
+  await fetchNotifications({
+    page: page.value,
+    size: pageSize,
+    unread: selectedTab.value === 'unread',
+    append: true,
+  })
+  return !hasMore.value
+}
+
+watch(selectedTab, async (tab) => {
+  page.value = 0
+  await fetchNotifications({ page: 0, size: pageSize, unread: tab === 'unread' })
+})
 
 const fetchPrefs = async () => {
   notificationPrefs.value = await fetchNotificationPreferences()
@@ -549,7 +568,11 @@ const togglePref = async (pref) => {
   const ok = await updateNotificationPreference(pref.type, !pref.enabled)
   if (ok) {
     pref.enabled = !pref.enabled
-    await fetchNotifications(selectedTab.value, true)
+    await fetchNotifications({
+      page: page.value,
+      size: pageSize,
+      unread: selectedTab.value === 'unread',
+    })
     await fetchUnreadCount()
   } else {
     toast.error('操作失败')
@@ -629,21 +652,11 @@ const formatType = (t) => {
   }
 }
 
-onActivated(() => {
-  fetchNotifications(selectedTab.value, true)
+onActivated(async () => {
+  page.value = 0
+  await fetchNotifications({ page: 0, size: pageSize, unread: selectedTab.value === 'unread' })
   fetchPrefs()
 })
-
-watch(selectedTab, (tab) => {
-  if (tab !== 'control') {
-    fetchNotifications(tab, true)
-  } else {
-    fetchPrefs()
-  }
-  ioKey.value++
-})
-
-const fetchNextPage = () => fetchNotifications(selectedTab.value)
 </script>
 
 <style scoped>
@@ -657,8 +670,6 @@ const fetchNextPage = () => fetchNotifications(selectedTab.value)
 .message-page {
   background-color: var(--background-color);
   overflow-x: hidden;
-  height: calc(100vh - var(--header-height));
-  overflow-y: auto;
 }
 
 .message-page-header {

frontend_nuxt/pages/posts/[id]/index.vue

@@ -15,6 +15,7 @@
         <div class="article-title-container-right">
           <div v-if="status === 'PENDING'" class="article-pending-button">审核中</div>
           <div v-if="status === 'REJECTED'" class="article-block-button">已拒绝</div>
+          <div v-if="closed" class="article-closed-button">已关闭</div>
           <div
             v-if="loggedIn && !isAuthor && !subscribed"
             class="article-subscribe-button"
@@ -167,11 +168,13 @@
         </div>
       </div>
 
+      <div class="post-close-container">该帖子已关闭，内容仅供阅读，无法进行互动</div>
+
       <ClientOnly>
         <CommentEditor
           @submit="postComment"
           :loading="isWaitingPostingComment"
-          :disabled="!loggedIn"
+          :disabled="!loggedIn || closed"
           :show-login-overlay="!loggedIn"
           :parent-user-name="author.username"
         />
@@ -196,6 +199,7 @@
               :level="0"
               :default-show-replies="item.openReplies"
               :post-author-id="author.id"
+              :post-closed="closed"
               @deleted="onCommentDeleted"
             />
           </template>
@@ -232,7 +236,16 @@
 </template>
 
 <script setup>
-import { ref, computed, onMounted, onBeforeUnmount, nextTick, watch, watchEffect } from 'vue'
+import {
+  ref,
+  computed,
+  onMounted,
+  onBeforeUnmount,
+  nextTick,
+  watch,
+  watchEffect,
+  onActivated,
+} from 'vue'
 import VueEasyLightbox from 'vue-easy-lightbox'
 import { useRoute } from 'vue-router'
 import CommentItem from '~/components/CommentItem.vue'
@@ -251,6 +264,8 @@ import { useRouter } from 'vue-router'
 import { useIsMobile } from '~/utils/screen'
 import Dropdown from '~/components/Dropdown.vue'
 import { ClientOnly } from '#components'
+import { useConfirm } from '~/composables/useConfirm'
+const { confirm } = useConfirm()
 
 const config = useRuntimeConfig()
 const API_BASE_URL = config.public.apiBaseUrl
@@ -267,6 +282,7 @@ const tags = ref([])
 const postReactions = ref([])
 const comments = ref([])
 const status = ref('PUBLISHED')
+const closed = ref(false)
 const pinnedAt = ref(null)
 const rssExcluded = ref(false)
 const isWaitingPostingComment = ref(false)
@@ -349,7 +365,12 @@ const articleMenuItems = computed(() => {
   const items = []
   if (isAuthor.value || isAdmin.value) {
     items.push({ text: '编辑文章', onClick: () => editPost() })
-    items.push({ text: '删除文章', color: 'red', onClick: () => deletePost() })
+    items.push({ text: '删除文章', color: 'red', onClick: deletePost })
+    if (closed.value) {
+      items.push({ text: '重新打开帖子', onClick: () => reopenPost() })
+    } else {
+      items.push({ text: '关闭帖子', onClick: () => closePost() })
+    }
   }
   if (isAdmin.value) {
     if (pinnedAt.value) {
@@ -485,6 +506,7 @@ watchEffect(() => {
   postReactions.value = data.reactions || []
   subscribed.value = !!data.subscribed
   status.value = data.status
+  closed.value = data.closed
   pinnedAt.value = data.pinnedAt
   rssExcluded.value = data.rssExcluded
   postTime.value = TimeManager.format(data.createdAt)
@@ -544,6 +566,10 @@ const onSliderInput = (e) => {
 
 const postComment = async (parentUserName, text, clear) => {
   if (!text.trim()) return
+  if (closed.value) {
+    toast.error('帖子已关闭')
+    return
+  }
   console.debug('Posting comment', { postId, text })
   isWaitingPostingComment.value = true
   const token = getToken()
@@ -682,24 +708,62 @@ const includeRss = async () => {
   }
 }
 
+const closePost = async () => {
+  const token = getToken()
+  if (!token) return
+  const res = await fetch(`${API_BASE_URL}/api/posts/${postId}/close`, {
+    method: 'POST',
+    headers: { Authorization: `Bearer ${token}` },
+  })
+  if (res.ok) {
+    closed.value = true
+    toast.success('已关闭')
+    await refreshPost()
+  } else {
+    toast.error('操作失败')
+  }
+}
+
+const reopenPost = async () => {
+  const token = getToken()
+  if (!token) return
+  const res = await fetch(`${API_BASE_URL}/api/posts/${postId}/reopen`, {
+    method: 'POST',
+    headers: { Authorization: `Bearer ${token}` },
+  })
+  if (res.ok) {
+    closed.value = false
+    toast.success('已重新打开')
+    await refreshPost()
+  } else {
+    toast.error('操作失败')
+  }
+}
+
 const editPost = () => {
   navigateTo(`/posts/${postId}/edit`, { replace: true })
 }
 
 const deletePost = async () => {
-  const token = getToken()
-  if (!token) {
-    toast.error('请先登录')
-    return
-  }
-  const res = await fetch(`${API_BASE_URL}/api/posts/${postId}`, {
-    method: 'DELETE',
-    headers: { Authorization: `Bearer ${token}` },
-  })
-  if (res.ok) {
-    toast.success('已删除')
-    navigateTo('/', { replace: true })
-  } else {
+  try {
+    const ok = await confirm('删除帖子', '此操作不可恢复，确认要删除吗？')
+    if (!ok) return
+    const token = getToken()
+    if (!token) {
+      toast.error('请先登录')
+      return
+    }
+    const res = await fetch(`${API_BASE_URL}/api/posts/${postId}`, {
+      method: 'DELETE',
+      headers: { Authorization: `Bearer ${token}` },
+    })
+    if (res.ok) {
+      toast.success('已删除')
+      navigateTo('/', { replace: true })
+    } else {
+      toast.error('操作失败')
+    }
+  } catch (e) {
     toast.error('操作失败')
   }
 }
@@ -812,6 +876,11 @@ const gotoProfile = () => {
   navigateTo(`/users/${author.value.id}`, { replace: true })
 }
 
+onActivated(async () => {
+  await refreshPost()
+  await fetchComments()
+})
+
 onMounted(async () => {
   await fetchComments()
   const hash = location.hash
@@ -845,6 +914,10 @@ onMounted(async () => {
   width: calc(85% - 40px);
 }
 
+.info-content-text p code {
+  padding: 2px 4px;
+}
+
 .post-page-scroller-container {
   display: flex;
   flex-direction: column;
@@ -868,6 +941,18 @@ onMounted(async () => {
   gap: 10px;
 }
 
+.post-close-container {
+  padding: 40px;
+  margin-top: 15px;
+  text-align: center;
+  font-size: 12px;
+  color: var(--text-color);
+  background-color: var(--background-color);
+  border: 1px dashed var(--normal-border-color);
+  border-radius: 10px;
+  opacity: 0.5;
+}
+
 .scroller {
   margin-top: 20px;
   margin-left: 20px;
@@ -1024,6 +1109,15 @@ onMounted(async () => {
   font-size: 14px;
 }
 
+.article-closed-button {
+  background-color: var(--background-color);
+  color: gray;
+  border: 1px solid gray;
+  padding: 5px 10px;
+  border-radius: 8px;
+  font-size: 14px;
+}
+
 .article-title {
   font-size: 30px;
   font-weight: bold;

frontend_nuxt/utils/markdown.js

@@ -1,4 +1,5 @@
-import hljs from 'highlight.js'
+import hljs from 'highlight.js/lib/common'
+
 if (typeof window !== 'undefined') {
   const theme =
     document.documentElement.dataset.theme ||

frontend_nuxt/utils/notification.js

@@ -118,44 +118,43 @@ export async function updateNotificationPreference(type, enabled) {
 function createFetchNotifications() {
   const notifications = ref([])
   const isLoadingMessage = ref(false)
-  const page = ref(0)
-  const finished = ref(false)
-  const currentTab = ref('all')
+  const hasMore = ref(true)
 
-  const fetchNotifications = async (tab = 'all', reset = false) => {
+  const fetchNotifications = async ({
+    page = 0,
+    size = 30,
+    unread = false,
+    append = false,
+  } = {}) => {
     const config = useRuntimeConfig()
     const API_BASE_URL = config.public.apiBaseUrl
     try {
       const token = getToken()
       if (!token) {
         toast.error('请先登录')
-        return true
+        return
       }
-      if (reset || tab !== currentTab.value) {
-        notifications.value = []
-        page.value = 0
-        finished.value = false
-        currentTab.value = tab
-      }
-      if (finished.value) return true
+      if (!append) notifications.value = []
       isLoadingMessage.value = true
-      let url = `${API_BASE_URL}/api/notifications`
-      if (currentTab.value === 'unread') url += '/unread'
-      url += `?page=${page.value}`
-      const res = await fetch(url, {
-        headers: {
-          Authorization: `Bearer ${token}`,
+      const res = await fetch(
+        `${API_BASE_URL}/api/notifications${unread ? '/unread' : ''}?page=${page}&size=${size}`,
+        {
+          headers: {
+            Authorization: `Bearer ${token}`,
+          },
         },
-      })
+      )
       isLoadingMessage.value = false
       if (!res.ok) {
         toast.error('获取通知失败')
-        return true
+        return
       }
       const data = await res.json()
+      const arr = []
+
       for (const n of data) {
         if (n.type === 'COMMENT_REPLY') {
-          notifications.value.push({
+          arr.push({
             ...n,
             src: n.comment.author.avatar,
             iconClick: () => {
@@ -164,7 +163,7 @@ function createFetchNotifications() {
             },
           })
         } else if (n.type === 'REACTION') {
-          notifications.value.push({
+          arr.push({
             ...n,
             emoji: reactionEmojiMap[n.reactionType],
             iconClick: () => {
@@ -175,7 +174,7 @@ function createFetchNotifications() {
             },
           })
         } else if (n.type === 'POST_VIEWED') {
-          notifications.value.push({
+          arr.push({
             ...n,
             src: n.fromUser ? n.fromUser.avatar : null,
             icon: n.fromUser ? undefined : iconMap[n.type],
@@ -186,8 +185,8 @@ function createFetchNotifications() {
               }
             },
           })
-        } else if (n.type === 'LOTTERY_WIN') {
-          notifications.value.push({
+        } else if (n.type === 'LOTTERY_WIN' || n.type === 'LOTTERY_DRAW') {
+          arr.push({
             ...n,
             icon: iconMap[n.type],
             iconClick: () => {
@@ -197,28 +196,8 @@ function createFetchNotifications() {
               }
             },
           })
-        } else if (n.type === 'LOTTERY_DRAW') {
-          notifications.value.push({
-            ...n,
-            icon: iconMap[n.type],
-            iconClick: () => {
-              if (n.post) {
-                markRead(n.id)
-                navigateTo(`/posts/${n.post.id}`)
-              }
-            },
-          })
-        } else if (n.type === 'POST_UPDATED') {
-          notifications.value.push({
-            ...n,
-            src: n.comment.author.avatar,
-            iconClick: () => {
-              markRead(n.id)
-              navigateTo(`/users/${n.comment.author.id}`, { replace: true })
-            },
-          })
-        } else if (n.type === 'USER_ACTIVITY') {
-          notifications.value.push({
+        } else if (n.type === 'POST_UPDATED' || n.type === 'USER_ACTIVITY') {
+          arr.push({
             ...n,
             src: n.comment.author.avatar,
             iconClick: () => {
@@ -227,7 +206,7 @@ function createFetchNotifications() {
             },
           })
         } else if (n.type === 'MENTION') {
-          notifications.value.push({
+          arr.push({
             ...n,
             icon: iconMap[n.type],
             iconClick: () => {
@@ -238,7 +217,7 @@ function createFetchNotifications() {
             },
           })
         } else if (n.type === 'USER_FOLLOWED' || n.type === 'USER_UNFOLLOWED') {
-          notifications.value.push({
+          arr.push({
             ...n,
             icon: iconMap[n.type],
             iconClick: () => {
@@ -248,19 +227,12 @@ function createFetchNotifications() {
               }
             },
           })
-        } else if (n.type === 'FOLLOWED_POST') {
-          notifications.value.push({
-            ...n,
-            icon: iconMap[n.type],
-            iconClick: () => {
-              if (n.post) {
-                markRead(n.id)
-                navigateTo(`/posts/${n.post.id}`, { replace: true })
-              }
-            },
-          })
-        } else if (n.type === 'POST_SUBSCRIBED' || n.type === 'POST_UNSUBSCRIBED') {
-          notifications.value.push({
+        } else if (
+          n.type === 'FOLLOWED_POST' ||
+          n.type === 'POST_SUBSCRIBED' ||
+          n.type === 'POST_UNSUBSCRIBED'
+        ) {
+          arr.push({
             ...n,
             icon: iconMap[n.type],
             iconClick: () => {
@@ -271,7 +243,7 @@ function createFetchNotifications() {
             },
           })
         } else if (n.type === 'POST_REVIEW_REQUEST') {
-          notifications.value.push({
+          arr.push({
             ...n,
             src: n.fromUser ? n.fromUser.avatar : null,
             icon: n.fromUser ? undefined : iconMap[n.type],
@@ -283,29 +255,25 @@ function createFetchNotifications() {
             },
           })
         } else if (n.type === 'REGISTER_REQUEST') {
-          notifications.value.push({
+          arr.push({
             ...n,
             icon: iconMap[n.type],
             iconClick: () => {},
           })
         } else {
-          notifications.value.push({
+          arr.push({
             ...n,
             icon: iconMap[n.type],
           })
         }
       }
-      const done = data.length < 50
-      if (!done) {
-        page.value++
-      } else {
-        finished.value = true
-      }
-      return done
+
+      if (append) notifications.value.push(...arr)
+      else notifications.value = arr
+      hasMore.value = data.length === size
     } catch (e) {
       console.error(e)
       isLoadingMessage.value = false
-      return true
     }
   }
 
@@ -355,8 +323,15 @@ function createFetchNotifications() {
     notifications,
     isLoadingMessage,
     markAllRead,
+    hasMore,
   }
 }
 
-export const { fetchNotifications, markRead, notifications, isLoadingMessage, markAllRead } =
-  createFetchNotifications()
+export const {
+  fetchNotifications,
+  markRead,
+  notifications,
+  isLoadingMessage,
+  markAllRead,
+  hasMore,
+} = createFetchNotifications()

frontend_nuxt/utils/vditor.js

@@ -2,7 +2,6 @@ import Vditor from 'vditor'
 import { getToken, authState } from './auth'
 import { searchUsers, fetchFollowings, fetchAdmins } from './user'
 import { tiebaEmoji } from './tiebaEmoji'
-import '~/assets/global.css'
 
 export function getEditorTheme() {
   return document.documentElement.dataset.theme === 'dark' ? 'dark' : 'classic'