diff --git a/src/main/java/com/jqtx/windows/common/mq/CreditListener.java b/src/main/java/com/jqtx/windows/common/mq/CreditListener.java index 57f44b064426eae0e0015d8bbde14a0f9c344ce1..0c5ae853ff1c08cc8cc40dfd4fb8d601a71be829 100644 --- a/src/main/java/com/jqtx/windows/common/mq/CreditListener.java +++ b/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());