From bf47d41dddf76c58a41692e492014499f9d433ae Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期五, 09 八月 2019 23:13:48 +0800
Subject: [PATCH] 服务绑定 及 代码生成器开发测试完成

---
 java110-core/src/main/java/com/java110/core/context/AbstractTransactionLog.java |   26 ++++++++++++++++++++------
 1 files changed, 20 insertions(+), 6 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
index bf1791e..53e80ba 100644
--- 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,6 +2,7 @@
 
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.java110.common.factory.ApplicationContextFactory;
 import com.java110.common.log.LoggerEngine;
 import com.java110.common.util.DateUtil;
 import org.slf4j.Logger;
@@ -20,11 +21,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 +47,7 @@
      * @return
      */
     public String getTimestamp(){
-        return DateUtil.getCurrentDate().getTime()+"";
+        return DateUtil.getNowDefault();
     }
 
 
@@ -61,6 +64,10 @@
         return responseMessage;
     }
 
+    public long getCostTime() {
+        return costTime;
+    }
+
     @Override
     public String getPort() {
         return port;
@@ -68,6 +75,10 @@
 
     /**
      * 棰勬瀯寤�
+     * 濡傛灉涓嶆槸http鏂瑰紡璇锋眰鏋勫缓鐨勫璞℃儏鍐典笅 port 涓� -1 璇峰湪鍒涘缓瀹屽璞″悗
+     * 鐢ㄨ繖涓�
+     * ServiceInfoListener serviceInfoListener =  ApplicationContextFactory.getBean("serviceInfoListener",ServiceInfoListener.class);
+     * 瀵硅薄鍒蜂竴涓� 绔彛
      * @param reqInfo
      * @param headerAll
      */
@@ -75,20 +86,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 +108,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 +134,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