From ca4662481a96825dffab34118fbfb6b18a92923e Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期五, 03 七月 2020 19:23:50 +0800
Subject: [PATCH] 优化 事务
---
java110-core/src/main/java/com/java110/core/context/AbstractDataFlowContext.java | 104 +++++++++++++++++++++++++++++++++++-----------------
1 files changed, 70 insertions(+), 34 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 386afba..8ec9b4f 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,23 +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;
@@ -35,6 +30,8 @@
private String responseTime;
private JSONArray resBusiness;
+
+ private JSONArray serviceBusiness;
private String code;
@@ -57,10 +54,10 @@
private List<DataFlowLog> logDatas = new ArrayList<DataFlowLog>();
- 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>();
+ 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;
@@ -70,16 +67,17 @@
/**
* 鏋勫缓 瀵硅薄淇℃伅
+ *
* @param reqInfo
* @param headerAll
* @return
* @throws Exception
*/
- public <T> T 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);
+ T dataFlowContext = (T) doBuilder(reqInfo, headerAll);
//鍚庡鐞�
afterBuilder((DataFlowContext) dataFlowContext);
return dataFlowContext;
@@ -88,23 +86,25 @@
/**
* 棰勫鐞�
+ *
* @param reqInfo
* @param headerAll
*/
- protected void preBuilder(String reqInfo, Map<String,String> headerAll) {
- super.preBuilder(reqInfo,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;
+ public abstract DataFlowContext doBuilder(String reqInfo, Map<String, String> headerAll) throws Exception;
- protected void afterBuilder(DataFlowContext dataFlowContext){
+ protected void afterBuilder(DataFlowContext dataFlowContext) {
}
@@ -230,7 +230,7 @@
}
- public List<DataFlowLog> getLogDatas(){
+ public List<DataFlowLog> getLogDatas() {
return logDatas;
}
@@ -252,24 +252,32 @@
/**
* 娣诲姞鍚勪釜鐜妭鐨勬棩蹇�
+ *
* @param dataFlowLog
*/
- public void addLogDatas(DataFlowLog dataFlowLog){
+ public void addLogDatas(DataFlowLog dataFlowLog) {
this.logDatas.add(dataFlowLog);
}
/**
* 娣诲姞鍚勪釜鐜妭鐨勮�楁椂
+ *
* @param dataFlowLinksCost
*/
- public void addLinksCostDates(DataFlowLinksCost dataFlowLinksCost){
+ public void addLinksCostDates(DataFlowLinksCost dataFlowLinksCost) {
this.linksCostDates.add(dataFlowLinksCost);
}
- public String getAppId(){return null;}
+ public String getAppId() {
+ return null;
+ }
- public String getUserId(){return null;};
+ public String getUserId() {
+ return null;
+ }
+
+ ;
@Override
public void setAppId(String appId) {
@@ -281,11 +289,23 @@
}
- public String getRemark(){return null;};
+ public String getRemark() {
+ return null;
+ }
- public String getReqSign(){return null;};
+ ;
- public JSONArray getAttrs(){return null;};
+ public String getReqSign() {
+ return null;
+ }
+
+ ;
+
+ public JSONArray getAttrs() {
+ return null;
+ }
+
+ ;
public String getBusinessType() {
return businessType;
@@ -323,11 +343,11 @@
this.port = port;
}
- public String getbId(){
+ public String getbId() {
return null;
}
- public String getLogId(){
+ public String getLogId() {
return getbId();
}
@@ -335,10 +355,11 @@
/**
* 涓氬姟缂栫爜 褰撳墠闇�瑕佸鐞嗙殑涓氬姟缂栫爜锛屽彲浠ュ啓灏嗚璇锋眰鏈嶅姟鎻愪緵鏂圭殑鏂规硶鍚�
* 涓昏鐢ㄤ簬 鏃ュ織绔睍绀�
+ *
* @return 褰撳墠鏈嶅姟缂栫爜
*/
- public String getServiceCode(){
- if(this.currentBusiness != null){
+ public String getServiceCode() {
+ if (this.currentBusiness != null) {
return currentBusiness.getServiceCode();
}
return "";
@@ -347,30 +368,45 @@
/**
* 涓氬姟鍚嶇О 褰撳墠闇�瑕佸鐞嗙殑涓氬姟鍚嶇О锛屽彲浠ュ綋鍓嶈皟鐢ㄧ殑涓氬姟鍚嶇О 濡� 鍟嗗搧璐拱 绛�
* 涓昏鐢ㄤ簬 鏃ュ織绔睍绀�
+ *
* @return 褰撳墠鏈嶅姟鍚嶇О
*/
- public String getServiceName(){
- if(this.currentBusiness != null){
+ public String getServiceName() {
+ if (this.currentBusiness != null) {
return currentBusiness.getServiceName();
}
return "";
}
- public abstract Orders getOrder();
+ public abstract IOrders getOrder();
- protected AbstractDataFlowContext(Date startDate, String code){
+ protected AbstractDataFlowContext(Date startDate, String code) {
this.setStartDate(startDate);
this.setCode(code);
}
- public void setResponseEntity(ResponseEntity responseEntity){
+ public void setResponseEntity(ResponseEntity responseEntity) {
}
- public ResponseEntity getResponseEntity(){
+ public ResponseEntity getResponseEntity() {
return null;
}
+ public JSONArray getServiceBusiness() {
+ return serviceBusiness;
+ }
+
+ public void addServiceBusiness(JSONObject serviceBusiness) {
+ if (this.serviceBusiness == null) {
+ this.serviceBusiness = new JSONArray();
+ }
+ this.serviceBusiness.add(serviceBusiness);
+ }
+
+ public void setServiceBusiness(JSONArray serviceBusinesses) {
+ this.serviceBusiness = serviceBusinesses;
+ }
}
--
Gitblit v1.8.0