微调

integrate-system/src/main/java/com/system/serivce/impl/DockingDistributionServiceImpl.java

@@ -36,7 +36,7 @@ public class DockingDistributionServiceImpl implements IDockingDistributionServi
             data.put("secret", secret);
             String result = HttpClientUtil.sendPost("http://192.168.0.34:8080/api/v1/memberAdd", JsonUtil.toString(data));
 
-            thirdPartyLogUtil.thirdPartyLogCreate("分销会员创建", "0001", queueId, "平台->分销", JsonUtil.toString(data), result, 1);
+            thirdPartyLogUtil.thirdPartyLogCreate("分销会员创建", "0001", queueId, "平台->分销", JsonUtil.toString(data), result);
             return result;
         } catch (IOException e) {
             e.printStackTrace();
@@ -50,7 +50,7 @@ public class DockingDistributionServiceImpl implements IDockingDistributionServi
             data.put("secret", secret);
             String result = HttpClientUtil.sendPost("http://192.168.0.34:8080/api/v1/trade", JsonUtil.toString(data));
 
-            thirdPartyLogUtil.thirdPartyLogCreate("分销交易创建", "0001", queueId, "平台->分销", JsonUtil.toString(data), result, 1);
+            thirdPartyLogUtil.thirdPartyLogCreate("分销交易创建", "0001", queueId, "平台->分销", JsonUtil.toString(data), result);
             return result;
         } catch (IOException e) {
             e.printStackTrace();
@@ -87,7 +87,7 @@ public class DockingDistributionServiceImpl implements IDockingDistributionServi
             data.put("memberId", memberId);
             String result = HttpClientUtil.sendPost("http://192.168.0.34:8080/api/v1/subordinate", JsonUtil.toString(data));
 
-            thirdPartyLogUtil.thirdPartyLogCreate("分销会员下级查询", "0001", queueId, "平台->分销", JsonUtil.toString(data), result, 1);
+            thirdPartyLogUtil.thirdPartyLogCreate("分销会员下级查询", "0001", queueId, "平台->分销", JsonUtil.toString(data), result);
             return result;
         } catch (IOException e) {
             e.printStackTrace();
@@ -103,7 +103,7 @@ public class DockingDistributionServiceImpl implements IDockingDistributionServi
             data.put("memberId", memberId);
             String result = HttpClientUtil.sendPost("http://192.168.0.34:8080/api/v1/member/balance", JsonUtil.toString(data));
 
-            thirdPartyLogUtil.thirdPartyLogCreate("分销会员余额查询", "0001", queueId, "平台->分销", JsonUtil.toString(data), result, 1);
+            thirdPartyLogUtil.thirdPartyLogCreate("分销会员余额查询", "0001", queueId, "平台->分销", JsonUtil.toString(data), result);
             return result;
         } catch (IOException e) {
             e.printStackTrace();
@@ -121,7 +121,7 @@ public class DockingDistributionServiceImpl implements IDockingDistributionServi
             data.put("limit", 14);
             String result = HttpClientUtil.sendPost("http://192.168.0.34:8080/api/v1/member/profit", JsonUtil.toString(data));
 
-            thirdPartyLogUtil.thirdPartyLogCreate("分销会员收益查询", "0001", queueId, "平台->分销", JsonUtil.toString(data), result, 1);
+            thirdPartyLogUtil.thirdPartyLogCreate("分销会员收益查询", "0001", queueId, "平台->分销", JsonUtil.toString(data), result);
             return result;
         } catch (IOException e) {
             e.printStackTrace();

integrate-system/src/main/java/com/system/serivce/impl/DockingServiceImpl.java

@@ -45,7 +45,7 @@ public class DockingServiceImpl implements IDockingService {
         String result = dockingDistributionService.dockingDistributionMemberCreate(inVo.getQueueId(), data);
         Map<String, Object> map = JsonUtil.toMap(result, String.class, Object.class);
         if (CollectionUtils.isEmpty(map) || !Constants.SUCCESS_CODE.equals(String.valueOf(map.get(Constants.SUCCESS_NAME)))) {
-            return RestResponse.fail("新增会员失败");
+            return RestResponse.fail("新增会员失败!" + map.get("errorMessage"));
         }
 
         return RestResponse.success();
@@ -65,7 +65,7 @@ public class DockingServiceImpl implements IDockingService {
         String result = dockingDistributionService.dockingDistributionTransactionCreate(inVo.getQueueId(), data);
         Map<String, Object> map = JsonUtil.toMap(result, String.class, Object.class);
         if (CollectionUtils.isEmpty(map) || !Constants.SUCCESS_CODE.equals(String.valueOf(map.get(Constants.SUCCESS_NAME)))) {
-            return RestResponse.fail("新增交易失败");
+            return RestResponse.fail("新增交易失败! " + map.get("errorMessage"));
         }
 
         return RestResponse.success();

integrate-system/src/main/java/com/system/utils/ThirdPartyLogUtil.java

 package com.system.utils;
 
+import com.system.constants.Constants;
 import com.system.dao.ThirdPartyLogMapper;
 import com.system.transfer.log.ThirdPartyLogCreateInVo;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
+
+import java.util.Map;
 
 /**
  * @author Inori
@@ -19,7 +23,7 @@ public class ThirdPartyLogUtil {
         return thirdPartyLogMapper.getThirdPartyLogByQueueId(queueId);
     }
 
-    public Integer thirdPartyLogCreate(String name, String docType, String queueId, String direction, String request, String response, Integer flag) {
+    public void thirdPartyLogCreate(String name, String docType, String queueId, String direction, String request, String response) {
         ThirdPartyLogCreateInVo inVo = new ThirdPartyLogCreateInVo();
         inVo.setName(name);
         inVo.setCode(docType);
@@ -27,10 +31,15 @@ public class ThirdPartyLogUtil {
         inVo.setDirection(direction);
         inVo.setRequest(request);
         inVo.setResponse(response);
-        inVo.setFlag(flag);
+
+        Map<String, Object> map = JsonUtil.toMap(response, String.class, Object.class);
+        if (!CollectionUtils.isEmpty(map) && Constants.SUCCESS_CODE.equals(String.valueOf(map.get(Constants.SUCCESS_NAME)))) {
+            inVo.setFlag(1);
+        } else {
+            inVo.setFlag(0);
+        }
 
         thirdPartyLogMapper.thirdPartyLogCreate(inVo);
-        return inVo.getId();
     }