diff --git a/jetlinks-components/common-component/src/main/java/org/jetlinks/community/utils/ReactorUtils.java b/jetlinks-components/common-component/src/main/java/org/jetlinks/community/utils/ReactorUtils.java
index dc048c8f..3d1aae29 100644
--- a/jetlinks-components/common-component/src/main/java/org/jetlinks/community/utils/ReactorUtils.java
+++ b/jetlinks-components/common-component/src/main/java/org/jetlinks/community/utils/ReactorUtils.java
@@ -36,10 +36,10 @@ import java.util.function.Function;
 public class ReactorUtils {
 
     public static <T> Function<Flux<T>, Flux<T>> limit(Long pageIndex, Long pageSize) {
-        if (pageIndex == null || pageSize == null) {
+        if (pageIndex == null || pageSize == null || pageIndex < 0 || pageSize <= 0) {
             return Function.identity();
         }
-        return flux -> flux.skip(pageIndex & pageSize).take(pageSize);
+        return flux -> flux.skip(pageIndex * pageSize).take(pageSize);
     }
 
     /**
@@ -222,4 +222,4 @@ public class ReactorUtils {
         }
     }
 
-}
\ No newline at end of file
+}