diff --git a/internal/domains/api/services/processors/dwbg/dwbg8b4d_processor.go b/internal/domains/api/services/processors/dwbg/dwbg8b4d_processor.go index e68d878..72f4b3c 100644 --- a/internal/domains/api/services/processors/dwbg/dwbg8b4d_processor.go +++ b/internal/domains/api/services/processors/dwbg/dwbg8b4d_processor.go @@ -1524,7 +1524,7 @@ func buildElementVerificationDetail(apiData map[string]interface{}, log *zap.Log } detail["belongRisks"] = belongRisks - // 公安重点人员核验产品(highRiskFlag 和 keyPersonCheckList) + // 公安重点人员核验产品(highRiskFlag 由 keyPersonCheckList 五项是否命中决定) flxgdea9Data := getMapValue(apiData, "FLXGDEA9") keyPersonCheckList := make(map[string]interface{}) keyPersonCheckList["num"] = "1" @@ -1538,7 +1538,6 @@ func buildElementVerificationDetail(apiData map[string]interface{}, log *zap.Log if flxgdea9Map, ok := flxgdea9Data.(map[string]interface{}); ok { level, ok := flxgdea9Map["level"].(string) if !ok { - // 尝试从其他可能的字段获取 if levelVal, exists := flxgdea9Map["level"]; exists { if levelStr, ok := levelVal.(string); ok { level = levelStr @@ -1548,19 +1547,14 @@ func buildElementVerificationDetail(apiData map[string]interface{}, log *zap.Log } } + // 仅根据 level 解析并填充 keyPersonCheckList 五项 if level != "" && level != "0" { - // 有风险,设置highRiskFlag为1(高风险) - detail["highRiskFlag"] = 1 - - // 解析level字段,填充keyPersonCheckList levelParts := strings.Split(level, ",") for _, part := range levelParts { part = strings.TrimSpace(part) if part == "" || part == "0" { continue } - - // 根据level代码判断风险类型 if strings.HasPrefix(part, "A") { keyPersonCheckList["fontFlag"] = 1 } @@ -1577,14 +1571,27 @@ func buildElementVerificationDetail(apiData map[string]interface{}, log *zap.Log keyPersonCheckList["sheJiaoTongFlag"] = 1 } } - } else { - // 无风险,设置highRiskFlag为2(低风险) - detail["highRiskFlag"] = 2 } + } } detail["keyPersonCheckList"] = keyPersonCheckList + // 仅根据 keyPersonCheckList 五项判定 highRiskFlag(不看是否有数据): + // 五项均未命中 → 0 无风险;仅 sheJiaoTongFlag 命中 → 2 低风险;其他任一项命中 → 1 高风险 + otherHit := keyPersonFlagEq1(keyPersonCheckList, "fontFlag") || + keyPersonFlagEq1(keyPersonCheckList, "jingJiFontFlag") || + keyPersonFlagEq1(keyPersonCheckList, "fangAiFlag") || + keyPersonFlagEq1(keyPersonCheckList, "zhongDianFlag") + sheJiaoHit := keyPersonFlagEq1(keyPersonCheckList, "sheJiaoTongFlag") + if otherHit { + detail["highRiskFlag"] = 1 // 高风险 + } else if sheJiaoHit { + detail["highRiskFlag"] = 2 // 低风险:仅涉交通命中 + } else { + detail["highRiskFlag"] = 0 // 无风险:五项均未命中 + } + // 设置默认值 if _, exists := detail["sjsysFlag"]; !exists { detail["sjsysFlag"] = 0 @@ -3945,6 +3952,22 @@ func getMapValue(data map[string]interface{}, key string) interface{} { return nil } +// keyPersonFlagEq1 判断 keyPersonCheckList 中某标识是否为 1(支持 int/float64) +func keyPersonFlagEq1(m map[string]interface{}, key string) bool { + v, ok := m[key] + if !ok { + return false + } + switch vv := v.(type) { + case int: + return vv == 1 + case float64: + return vv == 1 + default: + return false + } +} + func maskName(name string) string { if name == "" { return "" diff --git a/internal/domains/api/services/processors/dwbg/谛听报告_风险标识判断标准.md b/internal/domains/api/services/processors/dwbg/谛听报告_风险标识判断标准.md new file mode 100644 index 0000000..6af88ba --- /dev/null +++ b/internal/domains/api/services/processors/dwbg/谛听报告_风险标识判断标准.md @@ -0,0 +1,219 @@ +# 谛听多维报告(DWBG8B4D)风险标识判断标准 + +本文档汇总 `dwbg8b4d_processor.go` 中所有风险标识(*Flag / riskFlag)的判定规则与数据来源,便于查阅和评审。 + +--- + +## 一、elementVerificationDetail(要素核验产品)内风险标识 + +### 1. sjsysFlag(手机三要素简版风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 未查得 | 无 YYSYH6D2 数据或无法解析 | +| 1 | 高风险 | YYSYH6D2.result ≠ "0"(身份证+手机号+姓名 不一致) | +| 2 | 低风险 | YYSYH6D2.result == "0"(三要素一致) | + +**数据源**:YYSYH6D2(手机三要素简版) + +--- + +### 2. sfzeysFlag(身份证二要素风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 未查得 | 无 IVYZ9K7F 数据或 status/desc/result 无法解析 | +| 1 | 高风险 | 核验结果不为「一致」 | +| 2 | 低风险 | 核验结果为「一致」 | + +**数据源**:IVYZ9K7F(身份证二要素)。status 来自 data.status、desc 或 result(0=一致,非0=不一致)。 + +--- + +### 3. onlineRiskFlag(手机在网时长风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 未查得 | 无 YYSY8B1C 数据或 inTime 为空 | +| 1 | 高风险 | inTime == "0" 或 "3"(在网时长极短) | +| 2 | 低风险 | inTime 为其他非空值 | + +**数据源**:YYSY8B1C(手机在网时长) + +--- + +### 4. phoneVailRiskFlag(手机信息验证风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 未查得 | 无 YYSYE7V5 数据或 status 无法解析 | +| 1 | 高风险 | status == 1(不在网) | +| 2 | 低风险 | status == 0(在网/实号) | + +**数据源**:YYSYE7V5(手机在网状态等) + +--- + +### 5. belongRiskFlag(身份证号与手机号归属地风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 未查得 | 无 YYSY9E4A 或 YYSYH6D2,或户籍/归属地任一方为空 | +| 1 | 高风险 | 户籍所在地与号码归属地**不一致**(经智能比较) | +| 2 | 低风险 | 户籍所在地与号码归属地**一致** | + +**数据源**:YYSY9E4A(号码归属地)、YYSYH6D2(address 作户籍)。使用 `compareLocation` 做省/市归一化后比较。 + +--- + +### 6. highRiskFlag(公安重点人员核验风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 无风险 | keyPersonCheckList 五项(fontFlag、jingJiFontFlag、fangAiFlag、zhongDianFlag、sheJiaoTongFlag)**均为 0** | +| 1 | 高风险 | **任一项** fontFlag / jingJiFontFlag / fangAiFlag / zhongDianFlag 为 1(涉刑/经侦/妨害/重点/涉交通以外) | +| 2 | 低风险 | **仅** sheJiaoTongFlag 为 1(仅涉交通命中),其余为 0 | + +**数据源**:FLXGDEA9 的 level 解析后填充 keyPersonCheckList(A→fontFlag, B→jingJiFontFlag, C→fangAiFlag, D→zhongDianFlag, E→sheJiaoTongFlag)。**不看是否有数据**,仅根据五项当前值判定。 + +--- + +## 二、overdueRiskProduct(逾期风险产品)内风险标识 + +### 7. lyjlhyFlag(履约/借贷逾期类风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 未查得 | 无 JRZQ5E9F 数据(默认) | +| 1 | 高风险 | 当前存在未结清逾期 **或** 近 7/14/30 天有逾期(hasUnsettledOverdue=="逾期" 或 overdueLast7Days/14Days/30Days 任一为「逾期」) | +| 2 | 低风险 | 有 JRZQ5E9F 数据且无上述逾期情况 | + +**数据源**:JRZQ5E9F(借选指数评估),字段:xyp_cpl0044、xyp_cpl0029、xyp_cpl0030、xyp_cpl0031 等。 + +--- + +### 8. dkzhktjFlag(贷款综合情况风险标识) + +与 **lyjlhyFlag** 使用同一套逻辑,同时赋值:有逾期或近期逾期则为 1,否则为 2。 + +**数据源**:JRZQ5E9F。 + +--- + +### 9. tsmdyzFlag(特殊名单验证风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 未查得 | 无 JRZQ8A2D 数据(默认) | +| 1 | 高风险 | specialListVerification 列表**非空**(身份证或手机号任一侧命中:法院失信人/被执行人、银行/非银中风险/一般风险/高风险等任一) | +| 2 | 低风险 | 有 JRZQ8A2D 数据且 specialListVerification 为空 | + +**数据源**:JRZQ8A2D(特殊名单验证 B)。命中规则:id/cell 下对应字段值为 "0" 表示命中(如 court_bad、court_executed、bank_lost 等)。 + +--- + +## 三、multCourtInfo(司法风险核验产品)内风险标识 + +### 10. legalCasesFlag(涉案公告案件风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 无 | 无 FLXG7E8F 或 lawsuitStat 下无民事/刑事/行政/保全/破产案件 | +| 1 | 高风险 | legalCases 列表**非空**(民事、刑事、行政、保全、破产任一类 cases 非空) | + +**数据源**:FLXG7E8F(个人司法涉诉查询)→ judicial_data.lawsuitStat → civil/criminal/administrative/preservation/bankrupt.cases。 + +--- + +### 11. executionCasesFlag(执行案件风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 无 | 无 FLXG7E8F 或 implement.cases 为空 | +| 1 | 高风险 | executionCases 列表**非空** | + +**数据源**:FLXG7E8F → judicial_data.lawsuitStat.implement.cases。 + +--- + +### 12. disinCasesFlag(失信案件风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 无 | 无 FLXG7E8F 或 breachCaseList 为空 | +| 1 | 高风险 | disinCases 列表**非空** | + +**数据源**:FLXG7E8F → judicial_data.breachCaseList。 + +--- + +### 13. limitCasesFlag(限高案件风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 无 | 无 FLXG7E8F 或 consumptionRestrictionList 为空 | +| 1 | 高风险 | limitCases 列表**非空** | + +**数据源**:FLXG7E8F → judicial_data.consumptionRestrictionList。 + +--- + +## 四、loanEvaluationVerificationDetail(借贷评估产品)内风险标识 + +### 14. riskFlag(借贷评估风险标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 未查得 | 无 JRZQ6F2A 或 risk_screen_v2.variables[0].variableValue 无法解析 | +| 1 | 高风险 | checkLoanRisk 为 true:**任一时间段**(d7/d15/m1/m3)下,银行或非银申请次数 **≥ 10**(als_{period}_id_bank_allnum / als_{period}_id_nbank_allnum) | +| 2 | 低风险 | 有数据且 checkLoanRisk 为 false | + +**数据源**:JRZQ6F2A(借贷意向验证 A)→ risk_screen_v2.variables[0].variableValue。 + +--- + +## 五、leasingRiskAssessment(租赁风险评估产品)内风险标识 + +### 15. riskFlag(租赁风险评估标识) + +| 取值 | 含义 | 判断条件 | +|------|--------|----------| +| 0 | 无风险 | 近 12 月(m12)**总次数为 0**(身份证维度 alc_m12_id_allnum 与手机号维度 alc_m12_cell_allnum 取**较大值**后为 0) | +| 1 | 高风险 | 近 12 月总次数 **> 10** | +| 2 | 低风险 | 近 12 月总次数 **1~10**(含 10) | + +**数据源**:JRZQ1D09(3C 租赁申请意向)。**仅用近 12 月(Last12 / m12)**,totalCount = max(idCount, cellCount)。 + +--- + +## 六、riskWarning(规则风险提示)内各项命中规则摘要 + +以下为「命中即置 1」的规则,未命中或未查得均为 0。不改变上述各产品内 *Flag 的取值含义。 + +| 类别 | 字段示例 | 命中条件(简要) | +|----------------|----------|------------------| +| 要素核查 | idCardTwoElementMismatch | IVYZ9K7F 二要素结果非「一致」 | +| | phoneThreeElementMismatch | YYSYH6D2.result ≠ "0" | +| 运营商/在网 | shortPhoneDuration | YYSY8B1C.inTime == "0" | +| | shortPhoneDurationSlight | YYSY8B1C.inTime == "3" | +| | noPhoneDuration | YYSYE7V5.status==1 且 desc 含「风险」 | +| 归属地 | idCardPhoneProvinceMismatch | 户籍与号码归属地智能比较不一致 | +| 公安重点人员 | hasCriminalRecord / isEconomyFront / isDisrupSocial / isKeyPerson / isTrafficRelated | FLXGDEA9.level 解析后 A/B/C/D/E 前缀 | +| 涉赌涉诈 | isAntiFraudInfo | FLXG8B4D 中 moneyLaundering/deceiver/gamblerPlayer/gamblerBanker 任一项非空且非"0" | +| 逾期/名单 | hitHighRiskBankLastTwoYears / hitHighRiskNonBankLastTwoYears / hitCurrentOverdue | JRZQ8A2D.id 下 bank_lost/nbank_lost/bank_overdue/nbank_overdue 等字段值为 "0"(命中) | +| 司法 | hitCivilCase / hitCriminalRisk / hitExecutionCase / hitAdministrativeCase / hitPreservationReview / hitBankruptcyAndLiquidation | FLXG7E8F 对应案件类型 **cases 数组非空**(不依 count) | +| 借贷意向 | frequentApplicationRecent | 近 d7/d15/m1 银行或非银申请次数 **≥ 10**(JRZQ6F2A) | +| | frequentBankApplications / moreFrequentBankApplications | 近 m6+m12 银行申请总次数 **≥ 20** / **≥ 15** | +| | frequentNonBankApplications / moreFrequentNonBankApplications | 近 m6+m12 非银申请总次数 **≥ 20** / **≥ 15** | +| 租赁申请 | veryFrequentRentalApplications / frequentRentalApplications | JRZQ1D09 近 m3+m6+m12(每期取 id/cell 较大值再累加)总次数 **≥ 20** / **≥ 15** | +| 偿债压力 | highDebtPressure | JRZQ5E9F 当前逾期金额或当前逾期机构数非空且非 "0"/"1" | + +--- + +## 七、风险取值约定(通用) + +- **0**:未查得 / 无风险 / 无命中(依字段语义) +- **1**:高风险 / 命中 +- **2**:低风险(仅部分 *Flag 使用,如 sjsysFlag、sfzeysFlag、onlineRiskFlag、phoneVailRiskFlag、belongRiskFlag、highRiskFlag、lyjlhyFlag、dkzhktjFlag、tsmdyzFlag、loanEvaluation riskFlag、leasingRiskAssessment riskFlag) + +文档版本:根据当前 `dwbg8b4d_processor.go` 逻辑整理,若有代码变更请同步更新本文档。 diff --git a/internal/infrastructure/external/zhicha/zhicha_test.go b/internal/infrastructure/external/zhicha/zhicha_test.go index 3ca5e50..651dd19 100644 --- a/internal/infrastructure/external/zhicha/zhicha_test.go +++ b/internal/infrastructure/external/zhicha/zhicha_test.go @@ -91,9 +91,9 @@ func TestDecryptWithInvalidData(t *testing.T) { "", // 空数据 "invalid_base64", // 无效的Base64 "dGVzdA==", // 有效的Base64但不是AES加密数据 - "ZmJIKRQz6j+IboulkSfq0g==", - "qBijvRmmm3bbLEdaCMw2XvHc8SDq3oGh6lD6BwELyhU=", - "ITtZBkPMZQ88UTHWJuWjSA==", + "i96w+SDjwENjuvsokMFbLw==", + "oaihmICgEcszWMk0gXoB12E/ygF4g78x0/sC3/KHnBk=", + "5bx+WvXvdNRVVOp9UuNFHg==", } for _, data := range invalidData {