fix异常被吞没的问题

Author: lvyahui8

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/service/impl/DataBeanAggregateQueryServiceImpl.java

@@ -128,7 +128,7 @@ private  <T> T innerGet(DataProvideDefinition provider, Map<String, Object> invo
             return resultType.cast(interceptorChain.applyQueryAfter(context,provider,result));
         } catch (Exception e) {
             interceptorChain.applyExceptionHandle(context,provider,e);
-            return null;
+            throw e;
         }
     }
 
@@ -169,7 +169,7 @@ public Object execute() throws Exception {
             for (Map.Entry<String,Future<?>> item : futureMap.entrySet()) {
                 Future<?> future = item.getValue();
                 Object value = null;
-                DataConsumeDefinition consumeDefinition = consumeDefinitionMap.get(item.getKey());
+                DataConsumeDefinition consumeDefinition = consumeDefinitionMap.get(item.getKey().substring(0,item.getKey().indexOf('_')));
                 try {
                     value = future.get();
                 } catch (ExecutionException e) {

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

@@ -178,4 +178,21 @@ public Object apply(
         System.out.println(specialUserCollection);
     }
 
+    @Test
+    public void testParameterTypeException() throws Exception {
+        try{
+            dataBeanAggregateQueryFacade.get(Collections.singletonMap("userId", "1"),
+                    new Function2<User, List<Post>, User>() {
+                        @Override
+                        public User apply(@DataConsumer("user") User user,
+                                          @DataConsumer("posts") List<Post> posts) {
+                            return user;
+                        }
+                    });
+            throw new IllegalStateException("must throw IllegalArgumentException");
+        } catch (Exception e) {
+            log.error("eMsg:",e);
+            Assert.isTrue(e instanceof IllegalArgumentException,"e must be typeof IllegalArgumentException");
+        }
+    }
 }