微调

src/main/java/com/system/api/CommonHttpApi.java

@@ -2,6 +2,7 @@ package com.system.api;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
+import com.system.config.ThreadLocalConfig;
 import com.system.constants.MallConstants;
 import com.system.dao.InitConnectParamMapper;
 import com.system.exception.MallCommonException;
@@ -119,7 +120,14 @@ public class CommonHttpApi {
         request.putAll(where);
 
         try {
+            long start = System.currentTimeMillis();
             String response = HttpUtil.httpPost(mallAddress + "api/dataSyn/synData", JsonUtil.toString(request)).getBody();
+            long costTime = System.currentTimeMillis() - start;
+
+            Map<String, Object> map = ThreadLocalConfig.get();
+            map.put("costTime", costTime);
+            ThreadLocalConfig.set(map);
+
             productLogUtil.productSyncLogCreate(Integer.valueOf(config.get("productId")), queueId, name, config.get("docType"), config.get("direction"), JsonUtil.toString(request), response);
             return response;
         } catch (Exception e) {

src/main/java/com/system/utils/ProductLogUtil.java

@@ -155,6 +155,8 @@ public class ProductLogUtil {
         if (!CollectionUtils.isEmpty(map)) {
             int costTime = StringUtil.isNotNull(map.get("costTime")) ? Integer.parseInt(map.get("costTime").toString()) : 0;
             inVo.setCostTime(costTime);
+        } else {
+            inVo.setCostTime(0);
         }
         return inVo;
     }