From 98b5ba40c0894fb2dbfaa1097c317ef302f54d89 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期三, 19 五月 2021 00:21:51 +0800
Subject: [PATCH] 优化代码

---
 java110-core/src/main/java/com/java110/core/context/AbstractTransactionLog.java |   28 +++++++++++++++++++---------
 1 files changed, 19 insertions(+), 9 deletions(-)

diff --git a/java110-core/src/main/java/com/java110/core/context/AbstractTransactionLog.java b/java110-core/src/main/java/com/java110/core/context/AbstractTransactionLog.java
old mode 100644
new mode 100755
index 2db1119..f61c174
--- a/java110-core/src/main/java/com/java110/core/context/AbstractTransactionLog.java
+++ b/java110-core/src/main/java/com/java110/core/context/AbstractTransactionLog.java
@@ -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;
 
@@ -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);

--
Gitblit v1.8.0