优化代码

service-api/src/main/java/com/java110/api/smo/ISaveTransactionLogSMO.java

@@ -0,0 +1,16 @@
+package com.java110.api.smo;
+
+import com.java110.po.transactionLog.TransactionLogPo;
+
+/**
+ * @ClassName ISaveTransactionLog
+ * @Description TODO
+ * @Author wuxw
+ * @Date 2020/11/16 0:42
+ * @Version 1.0
+ * add by wuxw 2020/11/16
+ **/
+public interface ISaveTransactionLogSMO {
+
+    public void saveLog(TransactionLogPo transactionLogPo);
+}

service-api/src/main/java/com/java110/api/smo/impl/ApiServiceSMOImpl.java

@@ -3,6 +3,7 @@ package com.java110.api.smo.impl;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.java110.api.smo.IApiServiceSMO;
+import com.java110.api.smo.ISaveTransactionLogSMO;
 import com.java110.core.client.RestTemplate;
 import com.java110.core.context.ApiDataFlow;
 import com.java110.core.context.DataFlow;
@@ -13,10 +14,8 @@ import com.java110.core.factory.GenerateCodeFactory;
 import com.java110.entity.center.AppRoute;
 import com.java110.entity.center.AppService;
 import com.java110.entity.center.DataFlowLinksCost;
-import com.java110.intf.common.ITransactionLogInnerServiceSMO;
 import com.java110.po.transactionLog.TransactionLogPo;
 import com.java110.utils.cache.AppRouteCache;
-import com.java110.utils.cache.CommonCache;
 import com.java110.utils.cache.MappingCache;
 import com.java110.utils.constant.CommonConstant;
 import com.java110.utils.constant.KafkaConstant;
@@ -64,7 +63,7 @@ public class ApiServiceSMOImpl extends LoggerEngine implements IApiServiceSMO {
     private RestTemplate outRestTemplate;
 
     @Autowired
-    private ITransactionLogInnerServiceSMO transactionLogInnerServiceSMOImpl;
+    private ISaveTransactionLogSMO saveTransactionLogSMOImpl;
 
 
     /**
@@ -181,7 +180,7 @@ public class ApiServiceSMOImpl extends LoggerEngine implements IApiServiceSMO {
         }
     }
 
-    @Async
+
     private void doSaveLog(ApiDataFlow dataFlow, Date startDate, Date endDate, String serviceCode, String reqJson, ResponseEntity<String> responseEntity) {
 
         TransactionLogPo transactionLogPo = new TransactionLogPo();
@@ -198,7 +197,7 @@ public class ApiServiceSMOImpl extends LoggerEngine implements IApiServiceSMO {
         transactionLogPo.setResponseHeader(responseEntity.getHeaders().toSingleValueMap().toString());
         transactionLogPo.setRequestMessage(reqJson);
         transactionLogPo.setResponseMessage(responseEntity.getBody());
-        transactionLogInnerServiceSMOImpl.saveTransactionLog(transactionLogPo);
+        saveTransactionLogSMOImpl.saveLog(transactionLogPo);
     }
 
 

service-api/src/main/java/com/java110/api/smo/impl/SaveTransactionLogSMOImpl.java

@@ -0,0 +1,29 @@
+package com.java110.api.smo.impl;
+
+import com.java110.api.smo.ISaveTransactionLogSMO;
+import com.java110.intf.common.ITransactionLogInnerServiceSMO;
+import com.java110.po.transactionLog.TransactionLogPo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+
+/**
+ * @ClassName SaveTransactionLogSMOImpl
+ * @Description TODO
+ * @Author wuxw
+ * @Date 2020/11/16 0:43
+ * @Version 1.0
+ * add by wuxw 2020/11/16
+ **/
+@Service
+public class SaveTransactionLogSMOImpl implements ISaveTransactionLogSMO {
+
+    @Autowired
+    private ITransactionLogInnerServiceSMO transactionLogInnerServiceSMOImpl;
+
+    @Override
+    @Async
+    public void saveLog(TransactionLogPo transactionLogPo) {
+        transactionLogInnerServiceSMOImpl.saveTransactionLog(transactionLogPo);
+    }
+}