你我贷联系人为空不推送流量以及撞库你我贷不返回结果按拒绝处理

src/main/java/com/quantgroup/asset/distribution/service/niwodai/impl/NiwodaiAssetServiceImpl.java

@@ -160,12 +160,28 @@ public class NiwodaiAssetServiceImpl implements INiwodaiAssetService {
         loanInfo.setPurpose(NiwodaiCostant.Purpose.CONSUMPTION.name());
         vo.setLoanInfo(loanInfo);
         NiwodaiCostant.Contacts contacts = new NiwodaiCostant.Contacts();
-        contacts.setNameA((String) infoMap.get("firstName"));
-        contacts.setPhoneA((String) infoMap.get("firstMobile"));
-        contacts.setRelationshipA(conversRelationship((String)infoMap.get("firstRelation")).name());
-        contacts.setNameB((String) infoMap.get("secondName"));
-        contacts.setPhoneB((String) infoMap.get("secondMobile"));
-        contacts.setRelationshipB(conversRelationship((String)infoMap.get("secondRelation")).name());
+        String firstName = (String) infoMap.get("firstName");
+        String firstMobile = (String) infoMap.get("firstMobile");
+        String firstRelation =  (String)infoMap.get("firstRelation");
+        if (StringUtils.isAnyEmpty(firstName, firstMobile, firstRelation)) {
+            log.info("你我贷进件审核接口用户联系人1为空, 按拒绝处理, uuid : {}, bizNo : {}, firstName : {}, firstMobile : {}, firstRelation : {}",
+                    assetForm.getUuid(), assetForm.getBizNo(), firstName, firstMobile, firstRelation);
+            return NiwodaiIncomingResponseVO.createRejectVo();
+        }
+        contacts.setNameA(firstName);
+        contacts.setPhoneA(firstMobile);
+        contacts.setRelationshipA(conversRelationship(firstRelation).name());
+        String secondName = (String) infoMap.get("secondName");
+        String secondMobile = (String) infoMap.get("secondMobile");
+        String secondRelation =  (String)infoMap.get("secondRelation");
+        if (StringUtils.isAnyEmpty(secondName, secondMobile, secondRelation)) {
+            log.info("你我贷进件审核接口用户联系人2为空, 按拒绝处理, uuid : {}, bizNo : {}, secondName : {}, secondMobile : {}, secondRelation : {}",
+                    assetForm.getUuid(), assetForm.getBizNo(), secondName, secondMobile, secondRelation);
+            return NiwodaiIncomingResponseVO.createRejectVo();
+        }
+        contacts.setNameB(secondName);
+        contacts.setPhoneB(secondMobile);
+        contacts.setRelationshipB(conversRelationship(secondRelation).name());
         vo.setContacts(contacts);
         NiwodaiCostant.CompnayInfo compnayInfo = new NiwodaiCostant.CompnayInfo();
         compnayInfo.setName(random(NiwodaiCostant.COMPANY_NAMES));
@@ -493,13 +509,20 @@ public class NiwodaiAssetServiceImpl implements INiwodaiAssetService {
     }
 
     public static void main(String[] args) {
-        Map<String, Object> data=  new HashMap<>();
-        Integer age = (Integer)data.get("user_age");
-        System.out.println(age);
-        if (age == null || age.intValue() < 22 || age.intValue() > 50) {
-            System.out.println("不要");
-        } else {
-            System.out.println("要");
+        Map<String, Object> map = new HashMap<>();
+        System.out.println((String) map.get("firstName"));
+
+        String str = (String) map.get("riffs");
+
+        switch (str) {
+            case "asdf" :
+                System.out.println(1);
+                break;
+            default:
+                System.out.println(2);
+                break;
         }
+
+
     }
 }

src/main/java/com/quantgroup/asset/distribution/service/niwodai/impl/NiwodaiServiceImpl.java

@@ -61,6 +61,12 @@ public class NiwodaiServiceImpl implements INiwodaiService {
             if (vo != null && vo.getPass() != null) {
                 return JSON.parseObject(result, NiwodaiDataImportCheckResponseVO.class);
             }
+        } else {
+            // 先临时这么处理, 最后一个抛异常也先不删除了, 你我贷需要修复这个问题
+            log.info("你我贷准入接口返回结果出现错误, 按拒绝处理, uuid : {}, response : {}", uuid, result);
+            alarmService.dingtalkAlarm("Warn", "你我贷准入返回结果出现错误", "uuid : " + uuid
+                    + " , 错误信息 : 3012->你我贷准入接口返回结果异常, response : " + result);
+            return NiwodaiDataImportCheckResponseVO.createPassFalse();
         }
         throw new QGException(QGExceptionType.NIWODAI_PRE_AUDIT_RESULAT_ERROR, result);
     }
@@ -80,6 +86,7 @@ public class NiwodaiServiceImpl implements INiwodaiService {
                 return vo;
             }
         } else {
+            // 下面抛异常的先不删了, 你我贷会修复这个问题
             log.info("你我贷进件审核接口返回结果出现错误, 按拒绝处理, uuid : {}, bizNo : {}, result : {}", uuid, requestVO.getOrderId(), result);
             alarmService.dingtalkAlarm("Warn", "你我贷进件返回结果出现错误", "bizNo : " + requestVO.getOrderId()
                     + " , uuid : " + uuid + " , 错误信息 : 3013->你我贷进件返回结果异常, response : " + result);