代码加锁

ibznotify-core/src/main/java/cn/ibizlab/core/extensions/service/NotifyCoreService.java

@@ -671,7 +671,7 @@ public class NotifyCoreService {
      * @return
      */
     @Scheduled(fixedRate = 300000)
-    public void getBacklogPageContent() {
+    public synchronized void getBacklogPageContent() {
         MsgBodySearchContext context = new MsgBodySearchContext();
         context.setSize(Integer.MAX_VALUE);
 
@@ -691,6 +691,7 @@ public class NotifyCoreService {
         if (!msgMap.containsKey(toUserId)) {
             return Page.empty();
         } else {
+
             com.baomidou.mybatisplus.extension.plugins.pagination.Page<MsgBody> pages = new com.baomidou.mybatisplus.extension.plugins.pagination.Page<>();
             int current = context.getPages().getCurrent() < 0 ? 0 : (int) context.getPages().getCurrent();
             int size = context.getPages().getCurrent() < 0 ? 0 : (int) context.getPages().getSize();