Selaa lähdekoodia

新增根据项目id获取

Jxing 6 vuotta sitten
vanhempi
commit
b18646d9fa

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

@@ -184,7 +184,7 @@ public class Route extends ExceptionHandlerBaseRoute {
                 //.parallelProcessing()
                 .process(exchange -> {
                     String projectId = exchange.getIn().getBody(String.class);
-                    System.out.println("现在处理项目:" + projectId);
+                    System.out.println("统计:" + projectId);
                     JSONObject json = new JSONObject();
                     json.put("projectId", projectId);
                     exchange.setProperty("projectId" + exchange.getExchangeId(), projectId);
@@ -192,7 +192,6 @@ public class Route extends ExceptionHandlerBaseRoute {
                 })
                 .to("direct:getPropertiesByPj")
                 .process(exchange -> {
-                    System.out.println("进入D");
                     String jsonStr = exchange.getIn().getBody(String.class);
 
                     DPSelectPropertyResult dpResult = JSONObject.parseObject(jsonStr, DPSelectPropertyResult.class);

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

@@ -23,6 +23,5 @@ public class GetPropByPjProcessor implements Processor {
 //        exchange.getIn().setBody("{\"criteria\":{\"family\":[]}}");
         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);
-        System.out.println("进入C");
     }
 }