|
@@ -25,7 +25,7 @@ public class StatisticsProcessor implements Processor {
|
|
|
@Override
|
|
|
public void process(Exchange exchange) throws Exception {
|
|
|
String projectId = exchange.getIn().getBody(String.class);
|
|
|
- System.out.println("这里是Project:" + projectId);
|
|
|
+ System.out.println("这里正在统计的是Project:" + projectId);
|
|
|
DPSelectPropertyResult propertyData = (DPSelectPropertyResult) exchange.getProperty("propertyData" + exchange.getExchangeId());
|
|
|
Map<String, Map<String, String>> infoValueMap = (Map<String, Map<String, String>>) exchange.getProperty("map"); // 信息点Code --> (厂商库在该信息点的值value --> vender DPID)
|
|
|
List<Map<String, Object>> propertyList = propertyData.getContent();
|