修改提交

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

@@ -7,6 +7,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.jqtx.windows.common.exception.BizException;
 import com.jqtx.windows.common.factory.AbstractCommand;
 import com.jqtx.windows.common.factory.RuntimeContextHolder;
+import com.jqtx.windows.common.mq.MqProducer;
 import com.jqtx.windows.component.CreditComponent;
 import com.jqtx.windows.component.LoanComponent;
 import com.jqtx.windows.component.enums.CreditResultStatusEnum;
@@ -43,6 +44,9 @@ public class LoanSubmitCommand extends AbstractCommand {
     @Autowired
     private AbcHttpClient abcHttpClient;
 
+    @Autowired
+    private MqProducer mqProducer;
+
     @Override
     public JsonResult execute() {
         String request = RuntimeContextHolder.currentRuntimeContext().getRequestBody();
@@ -66,14 +70,8 @@ public class LoanSubmitCommand extends AbstractCommand {
         if (!insert) {
             throw new BizException(ExceptionCodeEnum.SYSTEM_SQL_INSERT_ERROR);
         }
+        mqProducer.pullCreditThirdData(loanSubmitResponse.getOrderNo());
 
-        JSONObject thirdCredit = new JSONObject();
-        thirdCredit.put("reqNo", loanSubmitResponse.getOrderNo());
-        thirdCredit.put("type", "01");
-        abcHttpClient.postRequest(thirdCredit.toJSONString(), ZNPostUrlEnum.CREDIT_APPLY.getCode());
-        CreditModel creditModel1=new CreditModel();
-        creditModel1.setCreditThirdStatus("INIT");
-        creditComponent.updateByOrderNo(loanSubmitResponse.getOrderNo(),creditModel1);
         // 提现授信
         LoanCreditSubmitModel model = new LoanCreditSubmitModel();
         model.setOrderNo(loanSubmitResponse.getOrderNo());

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

@@ -3,12 +3,15 @@ package com.jqtx.windows.common.mq;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.jqtx.infrastructure.mq.starter.annotation.MQConsumerComponent;
 import com.jqtx.infrastructure.oss.starter.config.OssUtils;
 import com.jqtx.windows.common.mq.model.CreditResultModel;
+import com.jqtx.windows.component.CreditComponent;
 import com.jqtx.windows.component.LoanComponent;
 import com.jqtx.windows.component.enums.CreditResultStatusEnum;
 import com.jqtx.windows.component.enums.ZNPostUrlEnum;
+import com.jqtx.windows.component.model.CreditModel;
 import com.jqtx.windows.component.model.LoanModel;
 import com.jqtx.windows.utils.AbcHttpClient;
 import com.jqtx.windows.web.response.WithdrawDetailResponse;
@@ -21,7 +24,7 @@ import java.time.LocalDateTime;
  * 提现审核结果
  */
 @Slf4j
-@MQConsumerComponent(tags = "creditDataApply", topic = "$mq.creditTopic")
+@MQConsumerComponent(tags = "creditThirdData", topic = "$mq.creditTopic")
 public class CreditThirdDataListener extends AbstractMQConsumerHandler<String> {
 
     @Autowired
@@ -30,6 +33,8 @@ public class CreditThirdDataListener extends AbstractMQConsumerHandler<String> {
     private AbcHttpClient abcHttpClient;
     @Autowired
     private OssUtils ossUtils ;
+    @Autowired
+    private CreditComponent creditComponent;
 
     @Override
     public Class getClazz() {
@@ -37,8 +42,14 @@ public class CreditThirdDataListener extends AbstractMQConsumerHandler<String> {
     }
 
     @Override
-    public void run(String creditResultModel) throws Exception {
-
+    public void run(String orderNo) throws Exception {
+        JSONObject thirdCredit = new JSONObject();
+        thirdCredit.put("reqNo", orderNo);
+        thirdCredit.put("type", "01");
+        abcHttpClient.postRequest(thirdCredit.toJSONString(), ZNPostUrlEnum.CREDIT_APPLY.getCode());
+        CreditModel creditModel1=new CreditModel();
+        creditModel1.setCreditThirdStatus("INIT");
+        creditComponent.updateByOrderNo(orderNo,creditModel1);
     }
 }
 

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

@@ -21,6 +21,8 @@ public class MqProducer {
 
     private String creditTopic;
 
+
+
     @Autowired
     private MQProducer mqProducer;
 
@@ -28,6 +30,10 @@ public class MqProducer {
         publishData(null, json, creditTopic, "firstCredit");
     }
 
+    public void pullCreditThirdData(String json) {
+        publishData(null, json, creditTopic, "creditThirdData");
+    }
+
 
     private void publishData(String id, String body, String topic, String tag) {
         try {