微调

integrate-system/src/main/java/com/system/dao/ThirdPartyLogMapper.java

@@ -8,6 +8,14 @@ import com.system.transfer.log.ThirdPartyLogCreateInVo;
 public interface ThirdPartyLogMapper {
 
     /**
+     * 根据唯一标识查询是否存在
+     *
+     * @param queueId 唯一标识
+     * @return 是否存在
+     */
+    Integer getThirdPartyLogByQueueId(String queueId);
+
+    /**
      * 第三方日志创建
      *
      * @param inVo 条件

integrate-system/src/main/java/com/system/dao/mapper/ThirdPartyLogMapper.xml

@@ -4,6 +4,14 @@
 
 
 
+    <select id="getThirdPartyLogByQueueId" parameterType="java.lang.String" resultType="java.lang.Integer">
+
+        SELECT COUNT(*) FROM tb_third_party_log WHERE quueu_id = #{queueId} LIMIT 1
+
+    </select>
+
+
+
     <insert id="thirdPartyLogCreate" parameterType="com.system.transfer.log.ThirdPartyLogCreateInVo" useGeneratedKeys="true" keyProperty="id">
 
         INSERT INTO tb_third_party_log (

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

@@ -6,6 +6,7 @@ import com.system.serivce.IDockingService;
 import com.system.transfer.docking.*;
 import com.system.transfer.response.RestResponse;
 import com.system.utils.JsonUtil;
+import com.system.utils.ThirdPartyLogUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -25,9 +26,15 @@ public class DockingServiceImpl implements IDockingService {
     @Autowired
     private IDockingDistributionService dockingDistributionService;
 
+    @Autowired
+    private ThirdPartyLogUtil thirdPartyLogUtil;
+
 
     @Override
     public RestResponse dockingDistributionMemberCreate(DockingDistributionMemberCreateInVo inVo) {
+        if (thirdPartyLogUtil.isExist(inVo.getQueueId()) != 0) {
+            return RestResponse.fail("操作失败! QUEUE_ID为: " + inVo.getQueueId() + "的唯一标识已存在");
+        }
         Map<String, Object> data = new HashMap<>();
         data.put("disUserId", inVo.getMemberId());
         data.put("disUserName", inVo.getMemberName());
@@ -46,6 +53,9 @@ public class DockingServiceImpl implements IDockingService {
 
     @Override
     public RestResponse dockingDistributionTransactionCreate(DockingDistributionTransactionCreateInVo inVo) {
+        if (thirdPartyLogUtil.isExist(inVo.getQueueId()) != 0) {
+            return RestResponse.fail("操作失败! QUEUE_ID为: " + inVo.getQueueId() + "的唯一标识已存在");
+        }
         Map<String, Object> data = new HashMap<>();
         data.put("disSetUserId", inVo.getMemberId());
         data.put("orderId", inVo.getOrderId());
@@ -63,6 +73,9 @@ public class DockingServiceImpl implements IDockingService {
 
     @Override
     public RestResponse dockingDistributionMemberSubordinateList(DockingDistributionMemberSubordinateListInVo inVo) {
+        if (thirdPartyLogUtil.isExist(inVo.getQueueId()) != 0) {
+            return RestResponse.fail("操作失败! QUEUE_ID为: " + inVo.getQueueId() + "的唯一标识已存在");
+        }
         String result = dockingDistributionService.dockingDistributionMemberSubordinateList(inVo.getQueueId(), inVo.getMemberId());
 
         List<Map<String, Object>> recordsList = new ArrayList<>();
@@ -84,6 +97,9 @@ public class DockingServiceImpl implements IDockingService {
 
     @Override
     public RestResponse dockingDistributionMemberBalance(DockingDistributionMemberBalanceInVo inVo) {
+        if (thirdPartyLogUtil.isExist(inVo.getQueueId()) != 0) {
+            return RestResponse.fail("操作失败! QUEUE_ID为: " + inVo.getQueueId() + "的唯一标识已存在");
+        }
         String result = dockingDistributionService.dockingDistributionMemberBalance(inVo.getQueueId(), inVo.getMemberId());
 
         Map<String, Object> map = JsonUtil.toMap(result, String.class, Object.class);
@@ -96,6 +112,9 @@ public class DockingServiceImpl implements IDockingService {
 
     @Override
     public RestResponse dockingDistributionMemberProfit(DockingDistributionMemberProfitInVo inVo) {
+        if (thirdPartyLogUtil.isExist(inVo.getQueueId()) != 0) {
+            return RestResponse.fail("操作失败! QUEUE_ID为: " + inVo.getQueueId() + "的唯一标识已存在");
+        }
         String result = dockingDistributionService.dockingDistributionMemberProfit(inVo.getQueueId(), inVo.getMemberId());
 
         Map<String, Object> map = JsonUtil.toMap(result, String.class, Object.class);

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

@@ -15,6 +15,10 @@ public class ThirdPartyLogUtil {
     private ThirdPartyLogMapper thirdPartyLogMapper;
 
 
+    public Integer isExist(String queueId) {
+        return thirdPartyLogMapper.getThirdPartyLogByQueueId(queueId);
+    }
+
     public Integer thirdPartyLogCreate(String name, String docType, String queueId, String direction, String request, String response, Integer flag) {
         ThirdPartyLogCreateInVo inVo = new ThirdPartyLogCreateInVo();
         inVo.setName(name);