新增MQ

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

@@ -59,17 +59,10 @@ public class CreditSubmitCommand extends AbstractCommand {
         if (ObjectUtil.isNotNull(order)) {
             return JsonResult.success();
         }
+        CreditModel creditModel = new CreditModel();
+        creditModel.setOrderNo(request.getOrderNo());
+        creditComponent.insert(creditModel);
         windowsProducer.pullCrditDate(request);
-//        CreditModel creditModel = new CreditModel();
-//        creditModel.setOrderNo(request.getOrderNo());
-//        this.convert(request, creditModel);
-//        ClientInfoModel infoModel = this.convertCredit(request, creditModel);
-//        JsonResult result = iWakandaFeignService.clientCredit(infoModel);
-//        result.apiCheck();
-//        creditComponent.insert(creditModel);
-//        JSONObject thirdDataReq=new JSONObject();
-//        thirdDataReq.put("orderNo",request.getOrderNo());
-//        windowsProducer.pullCreditThirdData(thirdDataReq);
         return JsonResult.success();
     }
 }

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

@@ -52,19 +52,17 @@ public class CreditListener extends AbstractMQConsumerHandler<CreditSubmitReques
 
     @Override
     public void run(CreditSubmitRequest request) throws Exception {
-        CreditModel order = creditComponent.getByOrderNo(request.getOrderNo());
-        if (ObjectUtil.isNotNull(order)) {
-            return;
+        CreditModel creditModel = creditComponent.getByOrderNo(request.getOrderNo());
+        if (ObjectUtil.isNull(creditModel)) {
+            throw new RuntimeException("消息重试");
         }
-        CreditModel creditModel = new CreditModel();
         creditModel.setOrderNo(request.getOrderNo());
         this.convert(request, creditModel);
         ClientInfoModel infoModel = this.convertCredit(request, creditModel);
         JsonResult result = iWakandaFeignService.clientCredit(infoModel);
-        result.apiCheck();
-        creditComponent.insert(creditModel);
-        JSONObject thirdDataReq=new JSONObject();
-        thirdDataReq.put("orderNo",request.getOrderNo());
+        creditComponent.updateByOrderNo(request.getOrderNo(), creditModel);
+        JSONObject thirdDataReq = new JSONObject();
+        thirdDataReq.put("orderNo", request.getOrderNo());
         windowsProducer.pullCreditThirdData(thirdDataReq);
 
     }