你我贷增加前筛规则

src/main/java/com/quantgroup/asset/distribution/service/funding/impl/AidFundRouteServiceImpl.java

@@ -3,6 +3,9 @@ package com.quantgroup.asset.distribution.service.funding.impl;
 import com.alibaba.fastjson.JSON;
 import com.google.common.base.Stopwatch;
 import com.quantgroup.asset.distribution.constant.AidFundStatus;
+import com.quantgroup.asset.distribution.enums.UserLoanType;
+import com.quantgroup.asset.distribution.exception.QGExceptionType;
+import com.quantgroup.asset.distribution.exception.QGPreconditions;
 import com.quantgroup.asset.distribution.model.form.AssetForm;
 import com.quantgroup.asset.distribution.model.response.GlobalResponse;
 import com.quantgroup.asset.distribution.service.funding.*;
@@ -110,6 +113,8 @@ public class AidFundRouteServiceImpl implements IAidFundRouteService {
                 }
                 //助贷资金分配规则校验
                 if(ruleService.valid(aidLoanFundConfig.getFundRuleEl(), data)){
+                    // 分配规则二次校验, md主要是ligeng的需求无法用表达式去满足, 特征值为null的居然让结果为true
+                    if (!secondValid(data, aidLoanFundConfig, asset)) { continue; }
                     // 助贷资金准入接口调用
                     boolean accessResult = false;
                     if (status == AidFundStatus.Route.PRE_PASS) {
@@ -194,4 +199,29 @@ public class AidFundRouteServiceImpl implements IAidFundRouteService {
         aidLoanFundAuditOrder.setEnable(true);
         return aidFundAuditOrderService.saveAidFundAuditOrder(aidLoanFundAuditOrder);
     }
+
+    /**
+     * 助贷分配规则二次校验
+     * 一次校验的时候已经限制了渠道号, 这里就不需要了
+     * @param data
+     * @param aidLoanFundConfig
+     * @param asset
+     * @return
+     */
+    private boolean secondValid(Map<String, Object> data, AidLoanFundConfig aidLoanFundConfig, Asset asset) {
+        if ("970".equals(aidLoanFundConfig.getFundId()) && "1052".equals(aidLoanFundConfig.getFundProductId())) {
+            // 你我贷助贷资方
+            QGPreconditions.checkArgument(asset.getUserLoanType() != null, QGExceptionType.USER_LOAN_TYPE_IS_EMPTY, asset.getUuid());
+            if (asset.getUserLoanType() == UserLoanType.FIRST_APPLY.getCode() || asset.getUserLoanType() == UserLoanType.RE_APPLY.getCode()) {
+                // 同盾分拒绝的不推
+                Integer tongdun_v2_1_bucket = Integer.parseInt(String.valueOf(data.get("model_exec_data_source#tongdun_v2_1_bucket")));
+                if (tongdun_v2_1_bucket != null && (tongdun_v2_1_bucket < 1 || tongdun_v2_1_bucket > 185)) {
+                    log.info("助贷资方导流, 用户命中二次校验规则, 不进行导流, uuid : {}, fundId : {}, fundProId : {}, tongdunScore : {}",
+                            asset.getUuid(), aidLoanFundConfig.getFundId(), aidLoanFundConfig.getFundProductId(), tongdun_v2_1_bucket);
+                    return false;
+                }
+            }
+        }
+        return true;
+    }
 }