新增MQ

src/main/java/com/jqtx/windows/common/mq/CreditListener.java

@@ -13,15 +13,18 @@ import com.jqtx.infrastructure.mq.starter.annotation.MQConsumerComponent;
 import com.jqtx.infrastructure.oss.starter.config.OssUtils;
 import com.jqtx.infrastructure.oss.starter.properties.OssProperties;
 import com.jqtx.infrastructure.util.LoanMobileAESUtil;
+import com.jqtx.windows.common.exception.BizException;
 import com.jqtx.windows.component.CreditComponent;
 import com.jqtx.windows.component.enums.ZNEduEnum;
 import com.jqtx.windows.component.enums.ZNInComeEnum;
 import com.jqtx.windows.component.enums.ZNMarryEnum;
 import com.jqtx.windows.component.enums.ZNRelationEnum;
 import com.jqtx.windows.component.model.CreditModel;
+import com.jqtx.windows.infrastructure.enums.ExceptionCodeEnum;
 import com.jqtx.windows.infrastructure.feign.IClientFeignService;
 import com.jqtx.windows.infrastructure.feign.IWakandaFeignService;
 import com.jqtx.windows.infrastructure.feign.enums.ProductNameEnum;
+import com.jqtx.windows.infrastructure.feign.model.client.ClientFeignModel;
 import com.jqtx.windows.infrastructure.feign.model.wakanda.*;
 import com.jqtx.windows.web.request.CreditSubmitRequest;
 import com.jqtx.windows.web.response.JsonResult;
@@ -164,12 +167,12 @@ public class CreditListener extends AbstractMQConsumerHandler<CreditSubmitReques
         infoModel.setIdentifyInfo(idModel);
         infoModel.setBasicInfo(basicModel);
         infoModel.setContinuedLoan(false);
-//        ClientFeignModel clientFeignModel = new ClientFeignModel(infoModel.getBasicInfo().getIdCard(), infoModel.getBasicInfo().getName());
-//        JsonResult<String> clientResult = iClientFeignService.getClientNo(clientFeignModel);
-//        if (!clientResult.isSuccess()) {
-//            throw new BizException(ExceptionCodeEnum.SYSTEM_REMOTE_ERROR);
-//        }
-        String clientId = IdUtil.simpleUUID().toString();
+        ClientFeignModel clientFeignModel = new ClientFeignModel(infoModel.getBasicInfo().getIdCard(), infoModel.getBasicInfo().getName());
+        JsonResult<String> clientResult = iClientFeignService.getClientNo(clientFeignModel);
+        if (!clientResult.isSuccess()) {
+            throw new BizException(ExceptionCodeEnum.SYSTEM_REMOTE_ERROR);
+        }
+        String clientId = clientResult.getResult();
         infoModel.setClientNo(clientId);
         infoModel.setOrderNo(request.getOrderNo());