From 6135498971ee5a76621f9f574927bc45bd2ad36a Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期二, 07 五月 2019 00:33:42 +0800
Subject: [PATCH] 调整web服务docker文件

---
 java110-core/src/main/java/com/java110/core/context/AbstractDataFlowContext.java |  111 ++++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 105 insertions(+), 6 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 9c1ab84..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
@@ -5,6 +5,7 @@
 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.util.*;
 
@@ -12,7 +13,7 @@
  * 鏁版嵁娴佷笂涓嬫枃
  * Created by wuxw on 2018/5/18.
  */
-public abstract class AbstractDataFlowContext implements DataFlowContext,Orders{
+public abstract class AbstractDataFlowContext extends AbstractTransactionLog implements DataFlowContext, IOrders,TransactionLog{
 
     private String dataFlowId;
 
@@ -51,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;
@@ -66,7 +70,38 @@
      * @return
      * @throws Exception
      */
-    public abstract DataFlowContext builder(String reqInfo, Map<String,String> headerAll) throws Exception;
+    public  <T> T builder(String reqInfo, Map<String,String> headerAll) throws Exception{
+        //棰勫鐞�
+        preBuilder(reqInfo, headerAll);
+        //璋冪敤builder
+        T dataFlowContext = (T)doBuilder(reqInfo, headerAll);
+        //鍚庡鐞�
+        afterBuilder((DataFlowContext) dataFlowContext);
+        return dataFlowContext;
+    }
+
+
+    /**
+     * 棰勫鐞�
+     * @param reqInfo
+     * @param headerAll
+     */
+    protected void preBuilder(String reqInfo, Map<String,String> headerAll) {
+        super.preBuilder(reqInfo,headerAll);
+    }
+
+    /**
+     * 鏋勫缓瀵硅薄
+     * @param reqInfo
+     * @param headerAll
+     * @return
+     * @throws Exception
+     */
+    public abstract DataFlowContext doBuilder(String reqInfo, Map<String,String> headerAll) throws Exception;
+
+    protected void afterBuilder(DataFlowContext dataFlowContext){
+
+    }
 
     public void setTransactionId(String transactionId) {
         this.transactionId = transactionId;
@@ -152,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() {
@@ -219,6 +266,16 @@
 
     public String getUserId(){return null;};
 
+    @Override
+    public void setAppId(String appId) {
+
+    }
+
+    @Override
+    public void setUserId(String userId) {
+
+    }
+
     public String getRemark(){return null;};
 
     public String getReqSign(){return null;};
@@ -257,11 +314,45 @@
 
     }
 
+    public void setPort(String port) {
+        this.port = port;
+    }
+
     public String getbId(){
         return null;
     }
 
-    public abstract Orders getOrder();
+    public String getLogId(){
+        return getbId();
+    }
+
+
+    /**
+     * 涓氬姟缂栫爜 褰撳墠闇�瑕佸鐞嗙殑涓氬姟缂栫爜锛屽彲浠ュ啓灏嗚璇锋眰鏈嶅姟鎻愪緵鏂圭殑鏂规硶鍚�
+     * 涓昏鐢ㄤ簬 鏃ュ織绔睍绀�
+     * @return 褰撳墠鏈嶅姟缂栫爜
+     */
+    public String getServiceCode(){
+        if(this.currentBusiness != null){
+            return currentBusiness.getServiceCode();
+        }
+        return "";
+    }
+
+    /**
+     * 涓氬姟鍚嶇О 褰撳墠闇�瑕佸鐞嗙殑涓氬姟鍚嶇О锛屽彲浠ュ綋鍓嶈皟鐢ㄧ殑涓氬姟鍚嶇О 濡� 鍟嗗搧璐拱 绛�
+     * 涓昏鐢ㄤ簬 鏃ュ織绔睍绀�
+     * @return 褰撳墠鏈嶅姟鍚嶇О
+     */
+    public String getServiceName(){
+        if(this.currentBusiness != null){
+            return currentBusiness.getServiceName();
+        }
+        return "";
+    }
+
+
+    public abstract IOrders getOrder();
 
     protected AbstractDataFlowContext(Date startDate, String code){
         this.setStartDate(startDate);
@@ -269,4 +360,12 @@
     }
 
 
+    public void setResponseEntity(ResponseEntity responseEntity){
+
+    }
+
+    public ResponseEntity getResponseEntity(){
+        return null;
+    }
+
 }

--
Gitblit v1.8.0