limit 换成between and

src/main/java/cn/quantgroup/xyqb/controller/external/SyncHashController.java

@@ -50,7 +50,8 @@ public class SyncHashController {
                 .execute(() -> {
                     Long startPosition = startUserId;
                     while (isContinue) {
-                        List<User> users = userRepository.findByIdLimit(startPosition, step);
+                        Long endPosition = startPosition + step;
+                        List<User> users = userRepository.findBtIdBetween(startPosition, endPosition);
                         if (users.isEmpty()) {
                             log.info("没有数据了. 结束了");
                             return;
@@ -79,9 +80,9 @@ public class SyncHashController {
                             }
                         });
 
+                        log.info("来一波,start:{},end:{}", startPosition, endPosition);
                         startPosition = users.get(users.size() - 1).getId() + 1;
 
-                        log.info("来一波");
 
                         try {
                             Thread.sleep(250);

src/main/java/cn/quantgroup/xyqb/repository/IUserRepository.java

@@ -50,4 +50,6 @@ public interface IUserRepository extends JpaRepository<User, Long>, JpaSpecifica
     @Query(value = "select * from user where id >= ?1 limit ?2", nativeQuery = true)
     List<User> findByIdLimit(Long id, Long limit);
 
+    List<User> findBtIdBetween(Long id, Long endId);
+
 }