optimzie exit room

java110

2023-05-23 cca504b84583f8f8289b34e794939b8590a16446

 java110-core/src/main/java/com/java110/core/context/AbstractDataFlowContext.java

old mode 100644
new mode 100755
@@ -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;
    }
}