| service-api/src/main/java/com/java110/api/smo/ISaveTransactionLogSMO.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-api/src/main/java/com/java110/api/smo/impl/ApiServiceSMOImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| service-api/src/main/java/com/java110/api/smo/impl/SaveTransactionLogSMOImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
service-api/src/main/java/com/java110/api/smo/ISaveTransactionLogSMO.java
New file @@ -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 @@ 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.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 @@ private RestTemplate outRestTemplate; @Autowired private ITransactionLogInnerServiceSMO transactionLogInnerServiceSMOImpl; private ISaveTransactionLogSMO saveTransactionLogSMOImpl; /** @@ -181,7 +180,7 @@ } } @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 @@ 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
New file @@ -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); } }