新增挡板规则

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

@@ -38,24 +38,29 @@ public class CreditResultListener extends AbstractMQConsumerHandler<CreditResult
 
     @Override
     public void run(CreditResultModel creditResultModel) throws Exception {
-        CreditModel byOrderNo = creditComponent.getByOrderNo(creditResultModel.getOrderNo());
-        if(ObjectUtil.isNull(byOrderNo) || !CreditResultStatusEnum.INIT.name().equals(byOrderNo.getCreditResult())){
+        CreditModel creditModel = creditComponent.getByOrderNo(creditResultModel.getOrderNo());
+        if(ObjectUtil.isNull(creditModel) || !CreditResultStatusEnum.INIT.name().equals(creditModel.getCreditResult())){
             return;
         }
         CreditModel update =  new CreditModel();
+        CreditDetailResponse creditDetailResponse = new CreditDetailResponse();
         if ("YES".equalsIgnoreCase(creditResultModel.getCreditStatus())) {
             update.setCreditResult(CreditResultStatusEnum.PASS.getCode());
+            //通过
+            creditDetailResponse.setStatus("1");
+            creditDetailResponse.setApprovalAmount(creditResultModel.getCreditAmt().toEngineeringString());
         }
         if ("RETRIAL".equalsIgnoreCase(creditResultModel.getCreditStatus())) {
             update.setCreditResult(CreditResultStatusEnum.INIT.getCode());
         }
         if ("REJECT".equalsIgnoreCase(creditResultModel.getCreditStatus())) {
             update.setCreditResult(CreditResultStatusEnum.REFUSED.getCode());
+            creditDetailResponse.setStatus("2");
         }
-        creditComponent.updateByOrderNo(byOrderNo.getOrderNo(),update);
-        CreditDetailResponse convert = getCreditCommand.convert(byOrderNo.getOrderNo());
-        convert.setTransNo(IdUtil.fastSimpleUUID());
-        abcHttpClient.postRequest(JSON.toJSONString(convert), ZNPostUrlEnum.CREDIT_CALL.getCode());
+        creditComponent.updateByOrderNo(creditModel.getOrderNo(),update);
+        creditDetailResponse.setRemark(creditResultModel.getMemo());
+        creditDetailResponse.setTransNo(IdUtil.fastSimpleUUID());
+        abcHttpClient.postRequest(JSON.toJSONString(creditDetailResponse), ZNPostUrlEnum.CREDIT_CALL.getCode());
     }
 }