From dba005c31be69f4962d10dc8284f74a4b1b93681 Mon Sep 17 00:00:00 2001
From: eson <474420502@qq.com>
Date: Tue, 9 Jul 2019 01:31:26 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E6=88=90=E8=87=AA=E5=8A=A8Dubbo=20Gen?=
 =?UTF-8?q?ericService=E8=AE=BE=E7=BD=AE=E5=8F=82=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../factory/DubboGatewayFilterFactory.java    | 37 +++++++++----------
 1 file changed, 18 insertions(+), 19 deletions(-)

diff --git a/usergw-service/src/main/java/cn/ecpark/service/usergw/biz/filters/factory/DubboGatewayFilterFactory.java b/usergw-service/src/main/java/cn/ecpark/service/usergw/biz/filters/factory/DubboGatewayFilterFactory.java
index 6088378..bae7060 100644
--- a/usergw-service/src/main/java/cn/ecpark/service/usergw/biz/filters/factory/DubboGatewayFilterFactory.java
+++ b/usergw-service/src/main/java/cn/ecpark/service/usergw/biz/filters/factory/DubboGatewayFilterFactory.java
@@ -58,33 +58,32 @@ public class DubboGatewayFilterFactory extends AbstractGatewayFilterFactory<Dubb
 
             GenericServicePool gsPool = appContext.getBean(GenericServicePool.class);
             GenericService gs = gsPool.get(uri);
-
+            
             ServerHttpRequest req = exchange.getRequest();
             Flux<DataBuffer> body = req.getBody();
-            HttpMethod m = req.getMethod();
-
-
+ 
             MultiValueMap<String, String> queryParams = req.getQueryParams();
-            
-        
+     
 
-            body.map( buffer ->  {
-                byte[] bytes = new byte[buffer.readableByteCount()];
-                buffer.read(bytes);
-                DataBufferUtils.release(buffer);
-                try {
-                    String bodyString = new String(bytes, "utf-8");
-                    log.error("test body");
-                } catch (Exception e) {
-                    e.printStackTrace();
-                }
-            });
+            // body.map( buffer ->  {
+            //     byte[] bytes = new byte[buffer.readableByteCount()];
+            //     buffer.read(bytes);
+            //     DataBufferUtils.release(buffer);
+            //     try {
+            //         String bodyString = new String(bytes, "utf-8");
+            //         log.error("test body");
+            //     } catch (Exception e) {
+            //         e.printStackTrace();
+            //     }
+            //     return Flux.just(bytes);
+            // });
 
             List<String> methodString = queryParams.get("method");
+            List<String> params = queryParams.get("params");
             if(methodString.size() != 0) {
                 // special
-                Object result = gs.$invoke(methodString.get(0), new String[] { "java.lang.String" }, new Object[] { "222" });
-                // gsPool.add(rkey, gs);
+                List<String> paramTypes = mehtods.get(methodString.get(0));
+                Object result = gs.$invoke(methodString.get(0),  Arrays.copyOf(paramTypes.toArray(), paramTypes.size(), String[].class), params.toArray());
                 if (result != null) {
                     ServerHttpResponse response = exchange.getResponse();
                     return response.writeWith(Mono