Commit bd8c3818 authored by 张庆's avatar 张庆

请求参数

parent 52ebbd99
...@@ -28,6 +28,7 @@ public class CreditResultListener extends AbstractMQConsumerHandler<CreditResult ...@@ -28,6 +28,7 @@ public class CreditResultListener extends AbstractMQConsumerHandler<CreditResult
@Autowired @Autowired
private AbcHttpClient abcHttpClient; private AbcHttpClient abcHttpClient;
@Override @Override
public Class getClazz() { public Class getClazz() {
return CreditResultModel.class; return CreditResultModel.class;
...@@ -36,25 +37,26 @@ public class CreditResultListener extends AbstractMQConsumerHandler<CreditResult ...@@ -36,25 +37,26 @@ public class CreditResultListener extends AbstractMQConsumerHandler<CreditResult
@Override @Override
public void run(CreditResultModel creditResultModel) throws Exception { public void run(CreditResultModel creditResultModel) throws Exception {
CreditModel creditModel = creditComponent.getByOrderNo(creditResultModel.getOrderNo()); CreditModel creditModel = creditComponent.getByOrderNo(creditResultModel.getOrderNo());
if(ObjectUtil.isNull(creditModel) || !CreditResultStatusEnum.INIT.name().equals(creditModel.getCreditResult())){ if (ObjectUtil.isNull(creditModel) || !CreditResultStatusEnum.INIT.name().equals(creditModel.getCreditResult())) {
return; return;
} }
CreditModel update = new CreditModel(); CreditModel update = new CreditModel();
CreditDetailResponse creditDetailResponse = new CreditDetailResponse(); CreditDetailResponse creditDetailResponse = new CreditDetailResponse();
if ("YES".equalsIgnoreCase(creditResultModel.getCreditStatus())) { if ("YES" .equalsIgnoreCase(creditResultModel.getCreditStatus())) {
update.setCreditResult(CreditResultStatusEnum.PASS.getCode()); update.setCreditResult(CreditResultStatusEnum.PASS.getCode());
update.setCreditAmt(creditResultModel.getCreditAmt().toEngineeringString());
//通过 //通过
creditDetailResponse.setStatus("1"); creditDetailResponse.setStatus("1");
creditDetailResponse.setApprovalAmount(creditResultModel.getCreditAmt().toEngineeringString()); creditDetailResponse.setApprovalAmount(creditResultModel.getCreditAmt().toEngineeringString());
} }
if ("RETRIAL".equalsIgnoreCase(creditResultModel.getCreditStatus())) { if ("RETRIAL" .equalsIgnoreCase(creditResultModel.getCreditStatus())) {
update.setCreditResult(CreditResultStatusEnum.INIT.getCode()); update.setCreditResult(CreditResultStatusEnum.INIT.getCode());
} }
if ("REJECT".equalsIgnoreCase(creditResultModel.getCreditStatus())) { if ("REJECT" .equalsIgnoreCase(creditResultModel.getCreditStatus())) {
update.setCreditResult(CreditResultStatusEnum.REFUSED.getCode()); update.setCreditResult(CreditResultStatusEnum.REFUSED.getCode());
creditDetailResponse.setStatus("2"); creditDetailResponse.setStatus("2");
} }
creditComponent.updateByOrderNo(creditModel.getOrderNo(),update); creditComponent.updateByOrderNo(creditModel.getOrderNo(), update);
creditDetailResponse.setRemark(creditResultModel.getMemo()); creditDetailResponse.setRemark(creditResultModel.getMemo());
creditDetailResponse.setTransNo(IdUtil.fastSimpleUUID()); creditDetailResponse.setTransNo(IdUtil.fastSimpleUUID());
abcHttpClient.postRequest(JSON.toJSONString(creditDetailResponse), ZNPostUrlEnum.CREDIT_CALL.getCode()); abcHttpClient.postRequest(JSON.toJSONString(creditDetailResponse), ZNPostUrlEnum.CREDIT_CALL.getCode());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment