diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageDataInitServiceImpl.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageDataInitServiceImpl.java
index 096335ec..ca93d2d0 100644
--- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageDataInitServiceImpl.java
+++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageDataInitServiceImpl.java
@@ -63,7 +63,8 @@ public class PendingMessageDataInitServiceImpl implements PendingMessageDataInit
                 .eq(MessageRecord::getType, MsgTypeEnum.PENDING_MESSAGE)
                 .eq(MessageRecord::getIsDelete, YesNoEnum.NO.getCode())
                 .ge(MessageRecord::getCreateAt, DateFormatUtil.toDate(queryFrom))
-                .between(MessageRecord::getId, minRecordId, scrollId)
+                .lt(MessageRecord::getId, scrollId)
+                .gt(MessageRecord::getId, minRecordId)
                 .orderByDesc(MessageRecord::getId)
                 .last("LIMIT 1000")
                 .list();
@@ -76,11 +77,13 @@ public class PendingMessageDataInitServiceImpl implements PendingMessageDataInit
             }
             scrollId = records.stream().min(Comparator.comparing(MessageRecord::getId))
                     .map(MessageRecord::getId).orElse(0L);
+            log.info("[cold_blade] scrollId:[{}]", scrollId);
             records = messageRecordDao.lambdaQuery()
                     .eq(MessageRecord::getType, MsgTypeEnum.PENDING_MESSAGE)
                     .eq(MessageRecord::getIsDelete, YesNoEnum.NO.getCode())
                     .ge(MessageRecord::getCreateAt, DateFormatUtil.toDate(queryFrom))
-                    .between(MessageRecord::getId, minRecordId, scrollId)
+                    .lt(MessageRecord::getId, scrollId)
+                    .gt(MessageRecord::getId, minRecordId)
                     .orderByDesc(MessageRecord::getId)
                     .last("LIMIT 1000")
                     .list();