Merge branch 'master' of http://git.hchbox.com/yuyou/client into master

src/main/java/com/yuyou/openapi/openapi/dao/ZhangmenMessageRepository.java

@@ -22,4 +22,9 @@ public interface ZhangmenMessageRepository extends JpaRepository<ZhangmenMessage
      * fixme 因为避免多环境下recId会产生重复的问题,这里先进行写这个接口,后续和上游确认通过 app_id 和 rec_id 进行组合查询,进行去重
      */
      List<ZhangmenMessageDO> findByRecIdAndAppId(Long recId, String appId);
+
+    /**
+     * 根据pnum来进行查询
+     */
+    List<ZhangmenMessageDO> findByPnum(String pnum);
 }

src/main/java/com/yuyou/openapi/openapi/service/impl/ABClientServiceImpl.java

@@ -1,5 +1,6 @@
 package com.yuyou.openapi.openapi.service.impl;
 
+import cn.hutool.core.util.StrUtil;
 import com.yuyou.openapi.openapi.dao.*;
 import com.yuyou.openapi.openapi.model.convert.*;
 import com.yuyou.openapi.openapi.model.dataobject.*;
@@ -129,6 +130,14 @@ public class ABClientServiceImpl implements ABClientService {
             log.error("========== [recId is null,please check this data , error msg is {} ] ==========", dto.toString());
             return Boolean.FALSE;
         }
+        // 增加先进行校验客户是否已经存在
+        String pnum = zhangmenMessageDO.getPnum();
+        List<ZhangmenMessageDO> zmDOList = zhangmenMessageRepository.findByPnum(pnum);
+        if (!CollectionUtils.isEmpty(zmDOList)){
+            log.error("========== [pnum already exist, red_id is {}] ==========", recId);
+            return Boolean.FALSE;
+        }
+
         // 增加前先进行校验在数据库中是否存在
         List<ZhangmenMessageDO> zhangmenMessageDOList = zhangmenMessageRepository.findByRecId(recId);
         if (CollectionUtils.isEmpty(zhangmenMessageDOList)){