From b3f85b60ba9e39572e686009d36b5e5d7e81e910 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 11 七月 2019 20:30:10 +0800
Subject: [PATCH] 合并远程信息
---
java110-core/src/main/java/com/java110/core/context/AbstractDataFlowContext.java | 44 ++++++++++++++++++++++++++++++++++----------
1 files changed, 34 insertions(+), 10 deletions(-)
diff --git a/java110-core/src/main/java/com/java110/core/context/AbstractDataFlowContext.java b/java110-core/src/main/java/com/java110/core/context/AbstractDataFlowContext.java
index 822799e..04c4821 100644
--- a/java110-core/src/main/java/com/java110/core/context/AbstractDataFlowContext.java
+++ b/java110-core/src/main/java/com/java110/core/context/AbstractDataFlowContext.java
@@ -2,22 +2,18 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
-import com.java110.common.factory.ApplicationContextFactory;
-import com.java110.common.log.LoggerEngine;
-import com.java110.common.util.DateUtil;
import com.java110.entity.center.Business;
import com.java110.entity.center.DataFlowLinksCost;
import com.java110.entity.center.DataFlowLog;
+import org.springframework.http.ResponseEntity;
-import java.net.InetAddress;
-import java.net.UnknownHostException;
import java.util.*;
/**
* 鏁版嵁娴佷笂涓嬫枃
* Created by wuxw on 2018/5/18.
*/
-public abstract class AbstractDataFlowContext extends AbstractTransactionLog implements DataFlowContext,Orders,TransactionLog{
+public abstract class AbstractDataFlowContext extends AbstractTransactionLog implements DataFlowContext, IOrders,TransactionLog{
private String dataFlowId;
@@ -56,7 +52,10 @@
private List<DataFlowLog> logDatas = new ArrayList<DataFlowLog>();
- protected Map<String,String> headers = new HashMap<String,String>();
+ protected Map<String,String> requestHeaders = new HashMap<String,String>();
+ protected Map<String,String> requestCurrentHeaders = new HashMap<String,String>();
+ protected Map<String,String> responseHeaders = new HashMap<String,String>();
+ protected Map<String,String> responseCurrentHeaders = new HashMap<String,String>();
//璇锋眰寮�濮嬫椂闂�
private Date startDate;
@@ -80,6 +79,7 @@
afterBuilder((DataFlowContext) dataFlowContext);
return dataFlowContext;
}
+
/**
* 棰勫鐞�
@@ -187,8 +187,20 @@
this.endDate = endDate;
}
- public Map<String, String> getHeaders() {
- return headers;
+ public Map<String, String> getRequestHeaders() {
+ return requestHeaders;
+ }
+
+ public Map<String, String> getResponseHeaders() {
+ return responseHeaders;
+ }
+
+ public Map<String, String> getRequestCurrentHeaders() {
+ return requestHeaders;
+ }
+
+ public Map<String, String> getResponseCurrentHeaders() {
+ return responseHeaders;
}
public String getReqData() {
@@ -302,6 +314,10 @@
}
+ public void setPort(String port) {
+ this.port = port;
+ }
+
public String getbId(){
return null;
}
@@ -336,7 +352,7 @@
}
- public abstract Orders getOrder();
+ public abstract IOrders getOrder();
protected AbstractDataFlowContext(Date startDate, String code){
this.setStartDate(startDate);
@@ -344,4 +360,12 @@
}
+ public void setResponseEntity(ResponseEntity responseEntity){
+
+ }
+
+ public ResponseEntity getResponseEntity(){
+ return null;
+ }
+
}
--
Gitblit v1.8.0