Pipeline & optimize

Author: lvyahui8

spring-boot-data-aggregator-autoconfigure/src/main/java/io/github/lvyahui8/spring/autoconfigure/BeanAggregateAutoConfiguration.java

@@ -87,13 +87,13 @@ private void scanProviders(DataProviderRepository repository) {
                 Reflections reflections = new Reflections(basePackage, new MethodAnnotationsScanner());
                 Set<Method> providerMethods = reflections.getMethodsAnnotatedWith(DataProvider.class);
                 for (Method method : providerMethods) {
-                    dealProvideMethod(repository, method);
+                    dealProviderMethod(repository, method);
                 }
             }
         }
     }
 
-    private void dealProvideMethod(DataProviderRepository repository, Method method) {
+    private void dealProviderMethod(DataProviderRepository repository, Method method) {
         DataProvider beanProvider = AnnotationUtils.findAnnotation(method, DataProvider.class);
         @SuppressWarnings("ConstantConditions")
         String dataId = beanProvider.id();

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/context/AggregateContext.java

@@ -0,0 +1,15 @@
+package io.github.lvyahui8.spring.aggregate.context;
+
+import lombok.Data;
+
+/**
+ * @author lvyahui (lvyahui8@gmail.com,lvyahui8@126.com)
+ * @since 2019/7/21 22:37
+ */
+@Data
+public class AggregateContext {
+    /**
+     * 发起一次递归查询的主调线程
+     */
+    Thread rootThread;
+}

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/interceptor/AbstractAggregateQueryInterceptor.java

@@ -0,0 +1,55 @@
+package io.github.lvyahui8.spring.aggregate.interceptor;
+
+import io.github.lvyahui8.spring.aggregate.context.AggregateContext;
+import io.github.lvyahui8.spring.aggregate.model.DataProvideDefinition;
+
+/**
+ * 查询过程中各个生命周期的拦截处理
+ *
+ * @author lvyahui (lvyahui8@gmail.com,lvyahui8@126.com)
+ * @since 2019/7/21 22:28
+ */
+public interface AbstractAggregateQueryInterceptor {
+    /**
+     * 查询正常提交, Context已经创建
+     *
+     * @param aggregateContext 查询上下文
+     * @return 返回为true才继续执行
+     */
+    boolean querySubmitted(AggregateContext aggregateContext) ;
+
+    /**
+     * 每个Provider方法执行前, 将调用此方法
+     *
+     * @param aggregateContext 查询上下文
+     * @param provideDefinition 将被执行的Provider
+     * @return  返回为true才继续执行
+     */
+    boolean queryBefore(AggregateContext aggregateContext, DataProvideDefinition provideDefinition);
+
+    /**
+     * 每个Provider方法执行成功之后, 调用此方法
+     *
+     * @param aggregateContext 查询上下文
+     * @param provideDefinition 被执行的Provider
+     * @param result 查询结果
+     * @return 返回结果, 如不修改不, 请直接返回参数中的result
+     */
+    Object queryAfter(AggregateContext aggregateContext,DataProvideDefinition provideDefinition,Object result);
+
+    /**
+     * 每个Provider执行时, 如果抛出异常, 将调用此方法
+     *
+     * @param aggregateContext  查询上下文
+     * @param provideDefinition 被执行的Provider
+     * @param e Provider抛出的异常
+     */
+    void exceptionHandle(AggregateContext aggregateContext,DataProvideDefinition provideDefinition,Exception e);
+
+    /**
+     * 一次查询全部完成.
+     *
+     * @param aggregateContext 查询上下文
+     */
+    void queryFinished(AggregateContext aggregateContext);
+}