新增MQ

src/main/java/com/jqtx/windows/command/LoanSubmitCommand.java

@@ -50,30 +50,35 @@ public class LoanSubmitCommand extends AbstractCommand {
         if (Objects.isNull(creditModel)) {
             throw new BizException(ExceptionCodeEnum.BIZ_CREDIT_NOT_FOUND_ERROR);
         }
-        //查询loan表是否存在
-        LoanModel loanComponentByLoanNo = loanComponent.getByLoanNo(loanSubmitResponse.getLoanNo());
-        Assert.isFalse(loanComponentByLoanNo != null, "重新借款单");
-        //防止重复提交
-        LoanModel loanComponentByOrderNoInit = loanComponent.getByOrderNoInit(loanSubmitResponse.getOrderNo());
-        Assert.isFalse(loanComponentByOrderNoInit != null, "提现风控未出结果,请勿重复操作");
-        // 保存windows_loan表
-        LoanModel loanModel = new LoanModel();
-        loanModel.setOrderNo(loanSubmitResponse.getOrderNo());
-        loanModel.setLoanNo(loanSubmitResponse.getLoanNo());
-        loanModel.setLoanStatus(LoanStatusEnum.AUDITED.name());
-        loanModel.setGmtCreated(LocalDateTime.now());
-        loanModel.setGmtModified(LocalDateTime.now());
-        Boolean insert = loanComponent.insert(loanModel);
-        JSONObject thirdDataReq = new JSONObject();
-        thirdDataReq.put("orderNo", loanSubmitResponse.getOrderNo());
-        windowsProducer.pullCreditThirdData(thirdDataReq);
-        if (!insert) {
-            throw new BizException(ExceptionCodeEnum.SYSTEM_SQL_INSERT_ERROR);
+        try {
+            //查询loan表是否存在
+            LoanModel loanComponentByLoanNo = loanComponent.getByLoanNo(loanSubmitResponse.getLoanNo());
+            Assert.isFalse(loanComponentByLoanNo != null, "重新借款单");
+            //防止重复提交
+            LoanModel loanComponentByOrderNoInit = loanComponent.getByOrderNoInit(loanSubmitResponse.getOrderNo());
+            Assert.isFalse(loanComponentByOrderNoInit != null, "提现风控未出结果,请勿重复操作");
+            // 保存windows_loan表
+            LoanModel loanModel = new LoanModel();
+            loanModel.setOrderNo(loanSubmitResponse.getOrderNo());
+            loanModel.setLoanNo(loanSubmitResponse.getLoanNo());
+            loanModel.setLoanStatus(LoanStatusEnum.AUDITED.name());
+            loanModel.setGmtCreated(LocalDateTime.now());
+            loanModel.setGmtModified(LocalDateTime.now());
+            Boolean insert = loanComponent.insert(loanModel);
+            JSONObject thirdDataReq = new JSONObject();
+            thirdDataReq.put("orderNo", loanSubmitResponse.getOrderNo());
+            windowsProducer.pullCreditThirdData(thirdDataReq);
+            if (!insert) {
+                throw new BizException(ExceptionCodeEnum.SYSTEM_SQL_INSERT_ERROR);
+            }
+            // 提现授信
+            LoanCreditSubmitModel model = new LoanCreditSubmitModel();
+            model.setOrderNo(loanSubmitResponse.getOrderNo());
+            JsonResult<Boolean> booleanJsonResult = wakandaFeignService.loanCredit(model);
+            JsonResult.success(booleanJsonResult.isSuccess());
+        } catch (BizException e) {
+            log.error("LoanSubmitCommand借款编号：{}  报错：{}", loanSubmitResponse.getLoanNo(), e.getMessage(), e);
         }
-        // 提现授信
-        LoanCreditSubmitModel model = new LoanCreditSubmitModel();
-        model.setOrderNo(loanSubmitResponse.getOrderNo());
-        JsonResult<Boolean> booleanJsonResult = wakandaFeignService.loanCredit(model);
-        return JsonResult.success(booleanJsonResult.isSuccess());
+        return JsonResult.success();
     }
 }