优化代码

java110

2021-05-19 98b5ba40c0894fb2dbfaa1097c317ef302f54d89

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

old mode 100644
new mode 100755
@@ -2,15 +2,12 @@

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.java110.common.log.LoggerEngine;
import com.java110.common.util.DateUtil;
import com.java110.utils.util.DateUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.net.InetAddress;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;

/**
 * 交互日志抽象类
@@ -20,11 +17,13 @@

    private final static Logger logger = LoggerFactory.getLogger(AbstractTransactionLog.class);

    private String port;
    protected String port;

    private String logStatus;

    private String requestMessage;

    private long costTime;

    private String responseMessage;

@@ -44,7 +43,7 @@
     * @return
     */
    public String getTimestamp(){
        return DateUtil.getCurrentDate().getTime()+"";
        return DateUtil.getNowDefault();
    }


@@ -61,6 +60,10 @@
        return responseMessage;
    }

    public long getCostTime() {
        return costTime;
    }

    @Override
    public String getPort() {
        return port;
@@ -68,6 +71,10 @@

    /**
     * 预构建
     * 如果不是http方式请求构建的对象情况下 port 为 -1 请在创建完对象后
     * 用这个
     * ServiceInfoListener serviceInfoListener =  ApplicationContextFactory.getBean("serviceInfoListener",ServiceInfoListener.class);
     * 对象刷一下 端口
     * @param reqInfo
     * @param headerAll
     */
@@ -75,20 +82,21 @@

        if(headerAll != null && headerAll.containsKey("port")){
            this.port = headerAll.get("port");
        }else{
            this.port = "-1";
        }

    }

    /**
     * 重新构建 TransactionLog 对象 主要用于服务调用方
     * @return
     */
    public TransactionLog reBuilder(String requestMessage,String responseMessage,String logStatus){
    public TransactionLog reBuilder(String requestMessage,String responseMessage,String logStatus,long costTime){

        this.logStatus = logStatus;
        this.requestMessage = requestMessage;
        this.responseMessage = responseMessage;

        this.costTime = costTime;
        return this;
    }

@@ -96,13 +104,14 @@
     * 重新构建 TransactionLog 对象 主要用于服务提供方
     * @return
     */
    public TransactionLog reBuilder(String appId,String userId,String requestMessage,String responseMessage,String logStatus){
    public TransactionLog reBuilder(String appId,String userId,String requestMessage,String responseMessage,String logStatus,long costTime){

        this.logStatus = logStatus;
        this.requestMessage = requestMessage;
        this.responseMessage = responseMessage;
        this.setAppId(appId);
        this.setUserId(userId);
        this.costTime = costTime;
        return this;
    }

@@ -121,6 +130,7 @@
        logMessage.put("serviceName",getServiceName());
        logMessage.put("timestamp",getTimestamp());
        logMessage.put("logStatus",getLogStatus());
        logMessage.put("costTime",costTime);
        logMessage.put("requestMessage",getRequestMessage());
        logMessage.put("responseMessage",getResponseMessage());
        return logMessage.toJSONString(logMessage,SerializerFeature.WriteNullStringAsEmpty);