你我贷进件返回结果未null时按拒绝处理

src/main/java/com/quantgroup/asset/distribution/exception/QGExceptionType.java

@@ -61,8 +61,8 @@ public enum QGExceptionType {
     USER_ID_NO_EMPTY(3009, "用户身份证为空"),
     USER_NAME_EMPTY(3010, "用户姓名为空"),
     GET_NIWODAI_TOKEN_ERROR(3011, "获取你我贷token异常"),
-    NIWODAI_PRE_AUDIT_RESULAT_ERROR(3012, "你我贷准入接口返回结果异常, resposne : %s"),
-    NIWODAI_INCOMING_RESULT_ERROR(3013, "你我贷进件返回结果异常, resposne : % s"),
+    NIWODAI_PRE_AUDIT_RESULAT_ERROR(3012, "你我贷准入接口返回结果异常, response : %s"),
+    NIWODAI_INCOMING_RESULT_ERROR(3013, "你我贷进件返回结果异常, response : %s"),
     NIWODAI_INCOMING_AUDIT_RESULT_ERROR(3014, "你我贷进件审核返回结果异常, response : %s"),
     OCR_DATA_MISS(3015,"OCR信息数据缺失，请核查"),
     UNKNOW_AID_FUND_ID(3016, "未知的助贷资方, fundId : %s");

src/main/java/com/quantgroup/asset/distribution/service/distribute/impl/AssetDistributeServiceImpl.java

@@ -148,7 +148,7 @@ public class AssetDistributeServiceImpl implements IAssetDistributeService{
                     String hitFinanceProduct = hitFundIfUseFundModule(assetForm, data, ExecuteType.ONLINE);
                     // 资方模块结果处理
                     financeProductService.checkFundResult(assetForm, hitFinanceProduct);
-                    if(StringUtils.isNotEmpty(hitFinanceProduct)) {
+                    if(StringUtils.isNotEmpty(assetForm.getFinanceProducts())) {
                         notifyService.notifyFundServer(assetForm, data);
                         return StatusConstants.WAIT;
                     }

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

@@ -6,6 +6,7 @@ import com.google.common.collect.Maps;
 import com.quantgroup.asset.distribution.constant.RedisKeyConstants;
 import com.quantgroup.asset.distribution.exception.QGException;
 import com.quantgroup.asset.distribution.exception.QGExceptionType;
+import com.quantgroup.asset.distribution.service.alarm.IAlarmService;
 import com.quantgroup.asset.distribution.service.httpclient.IHttpService;
 import com.quantgroup.asset.distribution.service.niwodai.INiwodaiService;
 import com.quantgroup.asset.distribution.service.niwodai.vo.*;
@@ -39,6 +40,8 @@ public class NiwodaiServiceImpl implements INiwodaiService {
     @Value("${niwodai.client.secret}")
     private String clientSecret;
 
+    @Autowired
+    private IAlarmService alarmService;
     @Autowired
     IRedisService<String> iRedisService;
     @Autowired
@@ -76,6 +79,11 @@ public class NiwodaiServiceImpl implements INiwodaiService {
             if (vo != null && vo.getCode() != null) {
                 return vo;
             }
+        } else {
+            log.info("你我贷进件审核接口返回结果出现错误, 按拒绝处理, uuid : {}, bizNo : {}, result : {}", uuid, requestVO.getOrderId(), result);
+            alarmService.dingtalkAlarm("Warn", "你我贷进件返回结果出现错误", "bizNo : " + requestVO.getOrderId()
+                    + " , uuid : " + uuid + " , 错误信息 : 3013->你我贷进件返回结果异常, response : " + result);
+            return NiwodaiIncomingResponseVO.createRejectVo();
         }
         throw new QGException(QGExceptionType.NIWODAI_INCOMING_RESULT_ERROR, result);
     }

src/main/java/com/quantgroup/asset/distribution/service/niwodai/vo/NiwodaiIncomingResponseVO.java

@@ -9,11 +9,17 @@ public class NiwodaiIncomingResponseVO implements Serializable {
 
     private static final long serialVersionUID = 1L;
     /**
-     * 300004:进件处理中; 300005:进件拒绝  必填
+     * 300008-进件申请拒绝,300007-进件申请通过  必填
      */
     private Integer code;
     /**
      * 描述信息 非必填
      */
     private String message;
+
+    public static NiwodaiIncomingResponseVO createRejectVo() {
+        NiwodaiIncomingResponseVO vo = new NiwodaiIncomingResponseVO();
+        vo.setCode(300008);
+        return vo;
+    }
 }