test case

Author: lvyahui8

spring-boot-data-aggregate-autoconfigure/src/main/java/org/feego/spring/annotation/DataBeanConsumer.java

@@ -3,12 +3,15 @@
 import java.lang.annotation.*;
 
 /**
+ * 数据依赖项
+ *
  * @author lvyahui ([email protected],[email protected])
  * @since 2019/6/1 0:05
  */
-@Target({ElementType.METHOD})
+@Target({ElementType.PARAMETER})
 @Retention(RetentionPolicy.RUNTIME)
 @Documented
 public @interface DataBeanConsumer {
-
+    String id();
+    String namespace();
 }

spring-boot-data-aggregate-autoconfigure/src/main/java/org/feego/spring/annotation/DataBeanProvider.java

@@ -3,12 +3,16 @@
 import java.lang.annotation.*;
 
 /**
+ * 数据提供者
+ *
  * @author lvyahui ([email protected],[email protected])
  * @since 2019/6/1 0:05
  */
 @Target({ElementType.METHOD})
 @Retention(RetentionPolicy.RUNTIME)
 @Documented
 public @interface DataBeanProvider {
-
+    String id();
+    String namespace();
+    long timeout() default 1000;
 }

spring-boot-data-aggregate-autoconfigure/src/main/java/org/feego/spring/annotation/InvokeParameter.java

@@ -0,0 +1,11 @@
+package org.feego.spring.annotation;
+
+/**
+ * 数据聚合时需要的输入参数
+ *
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/2 16:32
+ */
+public @interface InvokeParameter {
+    String value();
+}

spring-boot-data-aggregate-example/src/main/java/org/feego/spring/example/ExampleApplication.java

@@ -1,9 +1,11 @@
 package org.feego.spring.example;
 
 import org.feego.spring.aggregate.facade.DataBeanAggregateQueryFacade;
+import org.feego.spring.example.model.User;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.util.Assert;
 
 /**
  * @author lvyahui ([email protected],[email protected])
@@ -15,7 +17,8 @@ public class ExampleApplication {
     public static void main(String[] args) {
         ConfigurableApplicationContext context = SpringApplication.run(ExampleApplication.class);
         DataBeanAggregateQueryFacade queryFacade = context.getBean(DataBeanAggregateQueryFacade.class);
-        String loginUserName = queryFacade.get("login.user", String.class);
-        System.out.println(loginUserName);
+        User user = queryFacade.get("login.user", User.class);
+        Assert.notNull(user,"user not null");
+        Assert.notNull(user.getPosts(),"user posts not null");
     }
 }

spring-boot-data-aggregate-example/src/main/java/org/feego/spring/example/aggregate/UserAggregate.java

@@ -0,0 +1,27 @@
+package org.feego.spring.example.aggregate;
+
+import org.feego.spring.annotation.DataBeanConsumer;
+import org.feego.spring.annotation.DataBeanProvider;
+import org.feego.spring.example.model.Post;
+import org.feego.spring.example.model.User;
+import org.feego.spring.example.service.UserService;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/2 16:42
+ */
+@Component
+public class UserAggregate {
+    private UserService userService;
+
+    @DataBeanProvider(id="userWithPosts",namespace = "feego.example")
+    public User userWithPosts(
+            @DataBeanConsumer(id = "user",namespace = "feego.example") User user,
+            @DataBeanConsumer(id = "posts",namespace = "feego.example") List<Post> posts) {
+        user.setPosts(posts);
+        return user;
+    }
+}

spring-boot-data-aggregate-example/src/main/java/org/feego/spring/example/model/Post.java

@@ -0,0 +1,13 @@
+package org.feego.spring.example.model;
+
+import lombok.Data;
+
+/**
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/2 16:44
+ */
+@Data
+public class Post {
+    private String title;
+    private String content;
+}

spring-boot-data-aggregate-example/src/main/java/org/feego/spring/example/model/User.java

@@ -0,0 +1,17 @@
+package org.feego.spring.example.model;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/2 16:38
+ */
+@Data
+public class User {
+    private Long id;
+    private String username;
+    private String email;
+    List<Post> posts ;
+}

spring-boot-data-aggregate-example/src/main/java/org/feego/spring/example/service/PostService.java

@@ -0,0 +1,13 @@
+package org.feego.spring.example.service;
+
+import org.feego.spring.example.model.Post;
+
+import java.util.List;
+
+/**
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/2 16:53
+ */
+public interface PostService {
+    List<Post> getPosts(Long userId);
+}

spring-boot-data-aggregate-example/src/main/java/org/feego/spring/example/service/UserService.java

@@ -0,0 +1,11 @@
+package org.feego.spring.example.service;
+
+import org.feego.spring.example.model.User;
+
+/**
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/2 16:36
+ */
+public interface UserService {
+    User get(Long id);
+}

spring-boot-data-aggregate-example/src/main/java/org/feego/spring/example/service/impl/PostServiceImpl.java

@@ -0,0 +1,26 @@
+package org.feego.spring.example.service.impl;
+
+import org.feego.spring.annotation.DataBeanProvider;
+import org.feego.spring.annotation.InvokeParameter;
+import org.feego.spring.example.model.Post;
+import org.feego.spring.example.service.PostService;
+import org.springframework.stereotype.Service;
+
+import java.util.Collections;
+import java.util.List;
+
+/**
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/2 16:54
+ */
+@Service
+public class PostServiceImpl implements PostService {
+    @DataBeanProvider(id = "posts",namespace = "feego.example")
+    @Override
+    public List<Post> getPosts(@InvokeParameter("userId") Long userId) {
+        Post post = new Post();
+        post.setTitle("spring data aggregate example");
+        post.setContent("No active profile set, falling back to default profiles");
+        return Collections.singletonList(post);
+    }
+}