java110
2020-11-16 cf7c9a25f102d0511e0cce8a3baf5388bc181268
优化代码
1个文件已修改
2个文件已添加
54 ■■■■■ 已修改文件
service-api/src/main/java/com/java110/api/smo/ISaveTransactionLogSMO.java 16 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
service-api/src/main/java/com/java110/api/smo/impl/ApiServiceSMOImpl.java 9 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
service-api/src/main/java/com/java110/api/smo/impl/SaveTransactionLogSMOImpl.java 29 ●●●●● 补丁 | 查看 | 原始文档 | 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);
    }
}