wuxw
2019-06-02 cebc50ae8295dd24e2fd5ba0d4d236459a5190a3
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;
    }
}