优化 日志 床

java110-bean/src/main/java/com/java110/dto/transactionOutLog/TransactionOutLogDto.java

@@ -1,6 +1,7 @@
 package com.java110.dto.transactionOutLog;
 
 import com.java110.dto.PageDto;
+
 import java.io.Serializable;
 import java.util.Date;
 
@@ -14,15 +15,18 @@ import java.util.Date;
  **/
 public class TransactionOutLogDto extends PageDto implements Serializable {
 
+    public static final String STATE_S = "S";//成功
+    public static final String STATE_F = "F";//失败
+
     private String requestMessage;
-private String costTime;
-private String requestUrl;
-private String requestMethod;
-private String responseHeader;
-private String logId;
-private String requestHeader;
-private String state;
-private String responseMessage;
+    private String costTime;
+    private String requestUrl;
+    private String requestMethod;
+    private String responseHeader;
+    private String logId;
+    private String requestHeader;
+    private String state;
+    private String responseMessage;
 
 
     private Date createTime;
@@ -33,55 +37,72 @@ private String responseMessage;
     public String getRequestMessage() {
         return requestMessage;
     }
-public void setRequestMessage(String requestMessage) {
+
+    public void setRequestMessage(String requestMessage) {
         this.requestMessage = requestMessage;
     }
-public String getCostTime() {
+
+    public String getCostTime() {
         return costTime;
     }
-public void setCostTime(String costTime) {
+
+    public void setCostTime(String costTime) {
         this.costTime = costTime;
     }
-public String getRequestUrl() {
+
+    public String getRequestUrl() {
         return requestUrl;
     }
-public void setRequestUrl(String requestUrl) {
+
+    public void setRequestUrl(String requestUrl) {
         this.requestUrl = requestUrl;
     }
-public String getRequestMethod() {
+
+    public String getRequestMethod() {
         return requestMethod;
     }
-public void setRequestMethod(String requestMethod) {
+
+    public void setRequestMethod(String requestMethod) {
         this.requestMethod = requestMethod;
     }
-public String getResponseHeader() {
+
+    public String getResponseHeader() {
         return responseHeader;
     }
-public void setResponseHeader(String responseHeader) {
+
+    public void setResponseHeader(String responseHeader) {
         this.responseHeader = responseHeader;
     }
-public String getLogId() {
+
+    public String getLogId() {
         return logId;
     }
-public void setLogId(String logId) {
+
+    public void setLogId(String logId) {
         this.logId = logId;
     }
-public String getRequestHeader() {
+
+    public String getRequestHeader() {
         return requestHeader;
     }
-public void setRequestHeader(String requestHeader) {
+
+    public void setRequestHeader(String requestHeader) {
         this.requestHeader = requestHeader;
     }
-public String getState() {
+
+    public String getState() {
         return state;
     }
-public void setState(String state) {
+
+    public void setState(String state) {
         this.state = state;
     }
-public String getResponseMessage() {
+
+    public String getResponseMessage() {
         return responseMessage;
     }
-public void setResponseMessage(String responseMessage) {
+
+    public void setResponseMessage(String responseMessage) {
         this.responseMessage = responseMessage;
     }
 

java110-core/src/main/java/com/java110/core/client/OutRestTemplate.java

@@ -1,17 +1,29 @@
 package com.java110.core.client;
 
+import com.java110.core.context.ApiDataFlow;
+import com.java110.core.factory.GenerateCodeFactory;
 import com.java110.core.log.LoggerFactory;
+import com.java110.dto.transactionOutLog.TransactionOutLogDto;
+import com.java110.intf.common.ITransactionOutLogV1InnerServiceSMO;
+import com.java110.po.transactionLog.TransactionLogPo;
+import com.java110.po.transactionOutLog.TransactionOutLogPo;
+import com.java110.utils.constant.CommonConstant;
+import com.java110.utils.factory.ApplicationContextFactory;
+import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.ExceptionUtil;
 import org.slf4j.Logger;
 import org.springframework.http.HttpEntity;
 import org.springframework.http.HttpMethod;
+import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
+import org.springframework.web.client.HttpStatusCodeException;
 import org.springframework.web.client.RestClientException;
 
+import java.util.Date;
+
 /**
- *
  * 该类只要负责调用外部资源
  *
- *
  * @author wux
  * @create 2019-02-02 下午8:28
  * @desc 对RestTemplate类封装
@@ -38,11 +50,55 @@ public class OutRestTemplate extends RestTemplate {
     public <T> ResponseEntity<T> exchange(String url, HttpMethod method,
                                           HttpEntity<?> requestEntity, Class<T> responseType, Object... uriVariables) throws RestClientException {
 
-        logger.debug("请求信息：url:{},method:{},request:{},uriVariables:{}", url, method, requestEntity, uriVariables);
-        ResponseEntity<T> responseEntity = super.exchange(url, method, requestEntity, responseType, uriVariables);
-        logger.debug("返回信息：responseEntity:{}", responseEntity);
+        String errMsg = "";
+
+        ResponseEntity<T> responseEntity = null;
+        ResponseEntity tmpResponseEntity = null;
+        Date startTime = DateUtil.getCurrentDate();
+        try {
+            logger.debug("请求信息：url:{},method:{},request:{},uriVariables:{}", url, method, requestEntity, uriVariables);
+            responseEntity = super.exchange(url, method, requestEntity, responseType, uriVariables);
+            logger.debug("返回信息：responseEntity:{}", responseEntity);
 
+        } catch (HttpStatusCodeException e) {
+            errMsg = ExceptionUtil.getStackTrace(e);
+            throw e;
+        } finally {
+
+            if (responseEntity != null) {
+                tmpResponseEntity = new ResponseEntity(responseEntity.getBody(), responseEntity.getStatusCode());
+            } else {
+                tmpResponseEntity = new ResponseEntity(errMsg, HttpStatus.BAD_REQUEST);
+            }
+            saveLog(url, method.name(), requestEntity, tmpResponseEntity, DateUtil.getCurrentDate().getTime() - startTime.getTime());
+        }
         return responseEntity;
     }
 
+
+    private void saveLog(String url, String method, HttpEntity<?> requestEntity, ResponseEntity<String> responseEntity, long costTime) {
+
+        ITransactionOutLogV1InnerServiceSMO transactionOutLogV1InnerServiceSMO
+                = ApplicationContextFactory.getBean(ITransactionOutLogV1InnerServiceSMO.class.getName(),ITransactionOutLogV1InnerServiceSMO.class);
+
+        if(transactionOutLogV1InnerServiceSMO == null){
+            transactionOutLogV1InnerServiceSMO
+                    = ApplicationContextFactory.getBean("transactionOutLogV1InnerServiceSMOImpl",ITransactionOutLogV1InnerServiceSMO.class);
+        }
+
+        TransactionOutLogPo transactionOutLogPo = new TransactionOutLogPo();
+
+        transactionOutLogPo.setCostTime(costTime + "");
+        transactionOutLogPo.setLogId(GenerateCodeFactory.getGeneratorId("11"));
+        transactionOutLogPo.setRequestHeader(requestEntity.getHeaders() == null ? "" : requestEntity.getHeaders().toSingleValueMap().toString());
+        transactionOutLogPo.setRequestMessage(requestEntity.getBody() == null ? "" : requestEntity.getBody().toString());
+        transactionOutLogPo.setRequestMethod(method);
+        transactionOutLogPo.setRequestUrl(url);
+        transactionOutLogPo.setResponseHeader(responseEntity.getHeaders() == null ? "" : responseEntity.getHeaders().toSingleValueMap().toString());
+        transactionOutLogPo.setResponseMessage(responseEntity.getBody() == null ? "": responseEntity.getBody().toString());
+        transactionOutLogPo.setState(responseEntity.getStatusCode() == HttpStatus.OK ? TransactionOutLogDto.STATE_S:TransactionOutLogDto.STATE_F);
+
+        transactionOutLogV1InnerServiceSMO.saveTransactionOutLog(transactionOutLogPo);
+    }
+
 }