Przeglądaj źródła

按项目id查询所有资产

FanXiaoyu 7 lat temu
rodzic
commit
8c3f952307

+ 14 - 2
src/main/java/com/sagacloud/route/Route.java

@@ -2,6 +2,8 @@ package com.sagacloud.route;
 
 import com.github.rjeschke.txtmark.Processor;
 import com.sagacloud.route.processors.GetInsuranceNoListProcessor;
+import com.sagacloud.route.processors.GetPropByPjProcessor;
+import com.sagacloud.utils.Const;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.commons.io.IOUtils;
 
@@ -65,7 +67,17 @@ public class Route extends RouteBuilder {
                 .route()
                 .process();
 
-//        from("direct:getPropertiesByPj")
-
+        //body位JSONObject,含有projectId字段
+        from("direct:getPropertiesByPj")
+                .process(new GetPropByPjProcessor())
+                .to(Const.dataPlatform+"/property/relation_query")
+                .process(exchange -> {
+                    System.out.println(exchange.getIn().getBody(String.class));
+                });
+        rest("/test").post()
+                .consumes(MediaType.APPLICATION_JSON)
+                .produces(MediaType.APPLICATION_JSON)
+                .route()
+                .to("direct:getPropertiesByPj");
     }
 }

+ 27 - 0
src/main/java/com/sagacloud/route/processors/GetPropByPjProcessor.java

@@ -0,0 +1,27 @@
+package com.sagacloud.route.processors;
+
+import com.alibaba.fastjson.JSONObject;
+import com.sagacloud.cache.ProPasCache;
+import com.sagacloud.route.InitEnvRoute;
+import com.sagacloud.utils.Const;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+
+/**
+ * Created by Xiaoyu on 2018/7/12
+ */
+public class GetPropByPjProcessor implements Processor {
+    @Override
+    public void process(Exchange exchange) throws Exception {
+        String jsonStr = exchange.getIn().getBody(String.class);
+        JSONObject json = JSONObject.parseObject(jsonStr);
+        String projectId = json.getString(Const.HEADER_PROJECT);
+        String secret = ProPasCache.getPjSecret(projectId);
+        JSONObject queryJson = JSONObject.parseObject("{\"criteria\":{\"family\":[]}}");
+
+        exchange.getIn().setBody(queryJson.toString());
+        exchange.getIn().setHeader(Exchange.HTTP_URI, Const.dataPlatform+"/property/relation_query?method=POST");
+        exchange.getIn().setHeader(Exchange.HTTP_QUERY,Const.HEADER_PROJECT + "=" + projectId + "&"+ Const.HEADER_SECRET+ "="+ secret);
+
+    }
+}

+ 2 - 0
src/main/java/com/sagacloud/utils/Const.java

@@ -5,6 +5,8 @@ package com.sagacloud.utils;
  * 数据平台信息点
  */
 public class Const {
+    public static String dataPlatform = PropUtil.getProperty("dataPlatform.baseUrl");
+    public static String venders = PropUtil.getProperty("venders.baseUrl");
     public static final String HEADER_PROJECT = "projectId";
     public static final String HEADER_SECRET = "secret";
     public static final String MANU_ID = "DPManufacturerID";//自定义生产商id