push

yd-csf-service/src/main/java/com/yd/csf/service/dto/CustomerAddRequest.java

@@ -23,6 +23,11 @@ public class CustomerAddRequest implements Serializable {
     private String fnaBizId;
     private String fnaBizId;
 
 
     /**
     /**
+     * 客户ID
+     */
+    private String customerBizId;
+
+    /**
      * 姓名-中文
      * 姓名-中文
      */
      */
     @Schema(description = "姓名-中文")
     @Schema(description = "姓名-中文")

yd-csf-service/src/main/java/com/yd/csf/service/service/CustomerService.java

@@ -34,4 +34,6 @@ public interface CustomerService extends IService<Customer> {
     Boolean updateCustomer(CustomerUpdateRequest customerUpdateRequest);
     Boolean updateCustomer(CustomerUpdateRequest customerUpdateRequest);
 
 
     void queryDependentsNum(Customer customer);
     void queryDependentsNum(Customer customer);
+
+    Customer queryOneByCustomerBizId(String customerBizId);
 }
 }

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/CustomerServiceImpl.java

@@ -104,11 +104,18 @@ public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer>
         if (ValidateUtil.isAllFieldsNull(customerAddRequest)) {
         if (ValidateUtil.isAllFieldsNull(customerAddRequest)) {
             throw new BusinessException(ErrorCode.PARAMS_ERROR.getCode(), ErrorCode.PARAMS_ERROR.getMessage());
             throw new BusinessException(ErrorCode.PARAMS_ERROR.getCode(), ErrorCode.PARAMS_ERROR.getMessage());
         }
         }
-
+        Customer customer = null;
+        if (StringUtils.isNotBlank(customerAddRequest.getCustomerBizId())) {
+            customer = customerService.queryOneByCustomerBizId(customerAddRequest.getCustomerBizId());
+        }
+        if (customer == null) {
             // 检查字段 certificate_list，根据证件类型、证件号码查询客户是否存在
             // 检查字段 certificate_list，根据证件类型、证件号码查询客户是否存在
-        Customer customer = queryByCertificate(customerAddRequest.getApiCertificateDtoList());
+            customer = queryByCertificate(customerAddRequest.getApiCertificateDtoList());
             if (customer == null) {
             if (customer == null) {
                 customer = new Customer();
                 customer = new Customer();
+                // 客户主表业务唯一id
+                customer.setCustomerBizId(RandomStringGenerator.generateBizId16(CommonEnum.UID_TYPE_CUSTOMER.getCode()));
+            }
         }
         }
 
 
         // 客户主表信息
         // 客户主表信息
@@ -128,8 +135,6 @@ public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer>
         // 校验客户主表信息
         // 校验客户主表信息
         validCustomer(customer);
         validCustomer(customer);
 
 
-        // 客户主表业务唯一id
-        customer.setCustomerBizId(RandomStringGenerator.generateBizId16(CommonEnum.UID_TYPE_CUSTOMER.getCode()));
         boolean result = customerService.saveOrUpdate(customer);
         boolean result = customerService.saveOrUpdate(customer);
         if (!result) {
         if (!result) {
             throw new BusinessException(ErrorCode.OPERATION_ERROR.getCode(), ErrorCode.OPERATION_ERROR.getMessage());
             throw new BusinessException(ErrorCode.OPERATION_ERROR.getCode(), ErrorCode.OPERATION_ERROR.getMessage());
@@ -269,6 +274,12 @@ public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer>
         }
         }
     }
     }
 
 
+    @Override
+    public Customer queryOneByCustomerBizId(String customerBizId) {
+        return this.baseMapper.selectOne(new LambdaQueryWrapper<Customer>()
+                .eq(Customer::getCustomerBizId,customerBizId).last(" limit 1 "));
+    }
+
 }
 }