diff --git a/flyfish-data/pom.xml b/flyfish-data/pom.xml
index 8efde45..288685e 100644
--- a/flyfish-data/pom.xml
+++ b/flyfish-data/pom.xml
@@ -23,6 +23,11 @@
spring-data-mongodb
+
+ org.springframework.security
+ spring-security-core
+
+
org.springframework.boot
spring-boot-starter-data-mongodb-reactive
diff --git a/flyfish-data/src/main/java/com/flyfish/framework/annotations/EnableMongoRepo.java b/flyfish-data/src/main/java/com/flyfish/framework/annotations/EnableMongoRepo.java
index ce23b87..ce3d182 100644
--- a/flyfish-data/src/main/java/com/flyfish/framework/annotations/EnableMongoRepo.java
+++ b/flyfish-data/src/main/java/com/flyfish/framework/annotations/EnableMongoRepo.java
@@ -1,6 +1,6 @@
package com.flyfish.framework.annotations;
-import com.flyfish.framework.repository.impl.DefaultRepositoryFactoryBean;
+import com.flyfish.framework.repository.factory.DefaultRepositoryFactoryBean;
import com.flyfish.framework.repository.impl.DefaultRepositoryImpl;
import org.springframework.core.annotation.AliasFor;
import org.springframework.data.mongodb.config.EnableMongoAuditing;
diff --git a/flyfish-data/src/main/java/com/flyfish/framework/annotations/EnableReactiveMongoRepo.java b/flyfish-data/src/main/java/com/flyfish/framework/annotations/EnableReactiveMongoRepo.java
new file mode 100644
index 0000000..87f9024
--- /dev/null
+++ b/flyfish-data/src/main/java/com/flyfish/framework/annotations/EnableReactiveMongoRepo.java
@@ -0,0 +1,29 @@
+package com.flyfish.framework.annotations;
+
+import com.flyfish.framework.repository.factory.DefaultReactiveRepositoryFactoryBean;
+import com.flyfish.framework.repository.impl.DefaultReactiveRepositoryImpl;
+import org.springframework.core.annotation.AliasFor;
+import org.springframework.data.mongodb.config.EnableReactiveMongoAuditing;
+import org.springframework.data.mongodb.repository.config.EnableReactiveMongoRepositories;
+
+import java.lang.annotation.*;
+
+@EnableReactiveMongoRepositories(
+ repositoryFactoryBeanClass = DefaultReactiveRepositoryFactoryBean.class,
+ repositoryBaseClass = DefaultReactiveRepositoryImpl.class
+)
+@EnableReactiveMongoAuditing
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Inherited
+public @interface EnableReactiveMongoRepo {
+
+ /**
+ * 扫描的基本路径
+ *
+ * @return 结果
+ */
+ @AliasFor(annotation = EnableReactiveMongoRepositories.class)
+ String[] basePackages() default "com.flyfish.framework";
+}
diff --git a/flyfish-data/src/main/java/com/flyfish/framework/repository/DefaultReactiveRepository.java b/flyfish-data/src/main/java/com/flyfish/framework/repository/DefaultReactiveRepository.java
index 5a66618..ed11f2d 100644
--- a/flyfish-data/src/main/java/com/flyfish/framework/repository/DefaultReactiveRepository.java
+++ b/flyfish-data/src/main/java/com/flyfish/framework/repository/DefaultReactiveRepository.java
@@ -10,6 +10,6 @@ import org.springframework.data.repository.NoRepositoryBean;
* @param 泛型
*/
@NoRepositoryBean
-public interface DefaultReactiveRepository extends ReactiveMongoRepository {
+public interface DefaultReactiveRepository extends ReactiveMongoRepository, ReactiveQueryModelExecutor {
}
diff --git a/flyfish-data/src/main/java/com/flyfish/framework/repository/QueryModelExecutor.java b/flyfish-data/src/main/java/com/flyfish/framework/repository/QueryModelExecutor.java
index 438328a..0f5b7c8 100644
--- a/flyfish-data/src/main/java/com/flyfish/framework/repository/QueryModelExecutor.java
+++ b/flyfish-data/src/main/java/com/flyfish/framework/repository/QueryModelExecutor.java
@@ -80,7 +80,7 @@ public interface QueryModelExecutor {
* @param values 集合
* @return 结果
*/
- List findAllByValues(String key, List