dynamic parameter test case

Author: lvyahui8

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/annotation/DataConsumer.java

@@ -27,6 +27,11 @@
     @AliasFor("id")
     String value() default "";
 
+    /**
+     * The parameter key required by the method being consumed will be dynamically replaced
+     */
+    DynamicParameter [] dynamicParameters() default {};
+
     /**
      * Exception handling, default by global configuration
      */

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/annotation/DynamicParameter.java

@@ -0,0 +1,22 @@
+package io.github.lvyahui8.spring.annotation;
+
+import java.lang.annotation.*;
+
+/**
+ * @author lvyahui (lvyahui8@gmail.com,lvyahui8@126.com)
+ * @since 2019/11/6 23:22
+ */
+@Target({ElementType.PARAMETER})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface DynamicParameter {
+    /**
+     *  Method originally required parameter key.
+     */
+    String targetKey();
+
+    /**
+     * The new key used to replace the original parameter key
+     */
+    String replacementKey();
+}

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/annotation/InvokeParameter.java

@@ -1,5 +1,7 @@
 package io.github.lvyahui8.spring.annotation;
 
+import org.springframework.core.annotation.AliasFor;
+
 import java.lang.annotation.*;
 
 /**
@@ -15,5 +17,12 @@
     /**
      * Manually passed parameter key
      */
-    String value();
+    @AliasFor("key")
+    String value() default "";
+
+    /**
+     * same as value();
+     */
+    @AliasFor("value")
+    String key() default "";
 }

spring-boot-data-aggregator-example/src/test/java/io/github/lvyahui8/spring/example/DataBeanAggregateQueryFacadeTest.java

@@ -1,9 +1,12 @@
 package io.github.lvyahui8.spring.example;
 
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.Lists;
 import io.github.lvyahui8.spring.aggregate.facade.DataBeanAggregateQueryFacade;
 import io.github.lvyahui8.spring.aggregate.func.Function2;
 import io.github.lvyahui8.spring.aggregate.func.Function3;
 import io.github.lvyahui8.spring.annotation.DataConsumer;
+import io.github.lvyahui8.spring.annotation.DynamicParameter;
 import io.github.lvyahui8.spring.autoconfigure.BeanAggregateProperties;
 import io.github.lvyahui8.spring.example.context.ExampleAppContext;
 import io.github.lvyahui8.spring.example.context.RequestContext;
@@ -151,4 +154,28 @@ public Object apply(
             RequestContext.removeTenantId();
         }
     }
+
+    @Test
+    public void testDynamicParameter() throws Exception {
+        ImmutableMap<String, Object> params = ImmutableMap.<String, Object>builder()
+                .put("userA_Id", 1)
+                .put("userB_Id", 2)
+                .put("userC_Id", 3).build();
+        Object specialUserCollection = dataBeanAggregateQueryFacade.get(params,
+                new Function3<User,User,User,Object>() {
+                    @Override
+                    public Object apply(
+                            @DataConsumer(id = "user",
+                                    dynamicParameters = {@DynamicParameter(targetKey = "userId" ,replacementKey = "userA_Id")}) User userA,
+                            @DataConsumer(id = "user",
+                                    dynamicParameters = {@DynamicParameter(targetKey = "userId" ,replacementKey = "userB_Id")}) User userB,
+                            @DataConsumer(id = "user",
+                                    dynamicParameters = {@DynamicParameter(targetKey = "userId" ,replacementKey = "userC_Id")}) User userC) {
+                        return Lists.newArrayList(userA,userB,userC);
+                    }
+                });
+        System.out.println(specialUserCollection instanceof List);
+        System.out.println(specialUserCollection);
+    }
+
 }