一种基于多源数据融合的金融车辆风险预警方法及系统与流程

本发明涉及车联网与汽车金融风控，具体涉及一种面向融资/租赁车辆的风险预警方法及系统，尤其涉及一种融合实时流式告警与周期性规则计算、并按车辆健康状态进行自适应风险分级的多源数据风险预警方法。

背景技术：

1、在汽车金融（消费贷款、融资租赁）业务中，金融机构对贷款车辆进行全程监管，需及时识别"车辆闲置、跨境或边境异常活动、阶段性运营异常、常跑区域偏移、终端离线失控"等多类风险事件，以便在借款人违约前采取催收、锁车等处置措施。车辆风险数据来源高度异构，主要包括：车载终端实时上报的卫星定位、车速、在线状态；大数据平台计算的里程或活跃度统计；电子围栏进出与停留事件；以及设备防拆卸告警等。

2、传统金融/融资租赁车辆风险预警多采用两类技术路线：一是基于定时任务的周期性扫描车辆状态并与固定阈值比对；二是基于消息队列（如kafka）的实时事件订阅。两类路线通常各自独立部署，预警结果分散存储，难以形成统一的车辆风险视图。同时，现有预警手段普遍存在以下技术缺陷：

3、第一，上述割裂直接导致风险视图的分散。由于周期计算与实时事件告警各自独立部署、结果分散存储，运营方需跨多个系统逐一查询才能掌握一台车辆的完整风险状态，效率低下，且难以对一台车辆的风险进行整体研判——风险信息无法在同一视图中被统一查看与研判。

4、第二，视图的分散进一步造成预警结果重复、时效性差。由于缺乏统一的风险记录与查重基础，周期性扫描对处于静止状态的车辆会反复触发同一预警，产生大量重复告警，淹没真正的新风险；而车辆状态一旦发生变化（如重新行驶），又因缺乏跨周期的去重机制而漏报，降噪与时效难以兼顾。

5、第三，分散且重复的预警进一步使风险分级判定粗糙、误报漏报并存。由于分级所依赖的告警分散且掺有大量重复噪声，现有技术只能对全部车辆采用统一的风险判定标准，无法考虑车辆自身健康状态的差异——对于本身存在异常（如设备故障）的车辆与健康车辆，采用同一离线时长阈值判级，导致误报、漏报并存，风险判定粒度粗糙。

6、第四，分散的架构更导致风险类型覆盖与业务联动不足。由于缺乏统一的组织与联动基础，现有预警对边境/口岸风险、电子围栏、车辆白名单等业务要素缺乏系统性联动，口岸配置、围栏创建、车辆白名单同步多依赖人工维护，配置滞后且大批量同步易超时，影响实时边界类风险的识别及时性。

7、由上述可知，预警分散、重复、分级粗糙、联动不足等缺陷同源同根——其根因均在于现有技术缺乏一个统一、可信、可据以处置的风险数据底座：既无法将周期与实时两类预警收敛至同一视图，也无法在该视图上对告警去重提纯、进而基于可信告警进行差异化分级。现有技术从未提出“在统一视图下对海量受监管车辆生成可信、可分级处置的风险预警”这一技术问题，更未给出相应解决手段，导致运营方始终无法依据预警视图做出准确、及时的处置决策。因此，本领域亟需一种能够在统一视图下生成可信、可分级处置的风险预警的技术。

技术实现思路

1、本发明的目的是为了解决现有技术中存在的缺点，而提出的一种基于多源数据融合的金融车辆风险预警方法及系统。

2、为实现上述目的，本发明采用了如下技术方案：

3、一种基于多源数据融合的金融车辆风险预警方法，包括以下步骤：

4、s1，构建双层融合体系：构建周期性规则计算层与实时流式预警层，使所述周期性规则计算层产生的周期预警与所述实时流式预警层产生的实时预警统一收敛写入同一风险预警记录表，形成统一风险视图。

5、s2，周期层滑动窗口指标计算与循环再预警去重：所述周期性规则计算层按预设周期对受监管车辆执行风险指标计算，计算行驶里程增量与最大连续离线时长；在判定触发预警前，以终端标识、模型标识、条件类型的联合键查询最近预警记录，若查询到的最近预警记录所记载的累计里程与当前末次里程相等，则判定车辆状态未发生变化并跳过本轮预警；若里程发生变化，则生成新预警。

6、s3，实时层多风险类型消费与统一落库：所述实时流式预警层按风险类型分别订阅独立消息主题，多主题并行消费处理后统一落入所述风险预警记录表。

7、s4，自适应风险分级：获取终端异常事件对应的车辆健康状态与离线时长，当车辆健康状态为异常时采用紧凑阈值阶梯、为正常时采用宽松阈值阶梯，按对应的离线时长阈值将离线风险划分为低、中、高、高危等级，并随异常事件一并持久化至所述风险预警记录表。

8、进一步地，所述周期性规则计算层执行风险指标计算前，以固定键向缓存申请分布式锁，锁租约设为预设时长，申请失败者直接退出，保证同一时刻仅一个节点执行扫描；任务结束释放锁；并批量查询全部受监管车辆集合，提取监管方标识，按监管方分组加载类型为活跃度的预警模型配置，跳过已停用的模型。

9、更进一步地，所述周期性规则计算层加载预警模型配置后，读取模型的推送频率字段并按推送频率执行日历门控：推送频率为及时或每天时每次执行，为每周时仅当当日为周一时执行，为每月时仅当当日为每月一号时执行；门控未通过的模型本轮跳过。

10、更进一步地，每条预警模型的触发条件以数组形式持久化，条件包含条件类型、阈值与监控天数；条件类型包括离开围栏、行驶里程少于、连续离线达到、以及里程少且连续离线的复合条件；计算行驶里程增量时，按条件监控天数确定滑动窗口起点，查询该终端在窗口内的卫星定位末次位置数据序列，对序列按时间排序后取首末两条的累计里程之差作为行驶里程增量；计算最大连续离线时长时，将数据序列倒序遍历逐段累计离线段时长并取最大值换算为小时；阈值比对时，行驶里程增量小于阈值或最大连续离线时长大于等于阈值则触发，复合条件需各子条件同时满足，模型含多个条件时监控时间窗口取各条件监控天数的最大值。

11、更进一步地，以终端标识、模型标识、条件类型的联合键查询最近预警记录进行循环再预警去重时，若最近预警记录记载的累计里程与当前末次里程完全相等则判定车辆状态未发生变化、本轮跳过不生成新预警，若里程发生变化则在满足触发条件时生成新预警，从而既抑制车辆静止时的重复预警，又能在车辆有新的行驶后重新评估并再次预警。

12、更进一步地，所述实时流式预警层按风险类型订阅独立消息主题包括：车辆闲置风险主题，消费大数据平台计算的车辆里程告警，校验渠道与业务开通状态后按配置的闲置月数与闲置里程生成预警；边境活动风险主题，消费电子围栏停留告警，仅处理区域停留超时且报警开始的事件，以告警携带的围栏标识反查口岸配置，命中后按口岸名、半径、停留时长生成预警；阶段运营异常主题，按配置的连续月数与里程阈值生成预警；常跑区域异常主题，消费大数据平台计算的异常城市数组生成预警；各主题配置独立的消费组与容器工厂互不阻塞，每类消费者批量插入风险预警记录表并按短信开关批量发送预警短信。

13、更进一步地，所述方法还包括口岸与围栏联动配置与白名单自动同步：维护口岸的经纬度、监控半径、停留时长阈值与邻国信息；口岸保存时若坐标、半径、停留时长齐备则调用电子围栏服务创建圆形围栏并设置围栏规则，围栏标识回写口岸配置，配置变化时同步更新围栏与规则，配置不完整或删除时停用或删除围栏告警；围栏创建后异步查询全部已开通业务的车辆，按可配置批次大小分批调用围栏白名单接口同步，避免大批量单次调用超时。

14、更进一步地，获取终端异常事件对应的车辆健康状态与离线时长后，当车辆健康状态为异常时，采用紧凑阈值阶梯；当车辆健康状态为正常时，采用宽松阈值阶梯；使同一离线时长指标在不同车辆健康状态下得到差异化的风险判定。

15、本发明还提供一种基于多源数据融合的金融车辆风险预警系统，包括周期性规则计算层、实时流式预警层、口岸与围栏联动模块、自适应风险分级模块及统一风险记录表；其中，所述周期性规则计算层与所述实时流式预警层分别与所述统一风险记录表连接并共同写入风险预警记录，所述口岸与围栏联动模块与所述实时流式预警层连接并为实时层的口岸风险提供围栏与白名单支撑，所述自适应风险分级模块与所述统一风险记录表连接并将离线风险等级写入所述统一风险记录表。

16、需要进一步指出的是，上述统一风险记录表、循环再预警去重与自适应风险分级并非相互独立的可选手段，而是共同构成本发明完整技术方案、相互依存的三个结构性环节，三者之间存在紧密的技术关联：其一，若无统一风险记录表这一共同数据底座，周期性预警与实时预警各自分散存储，则循环再预警去重将因缺乏跨周期、跨类型的统一查重基础而无法实施，自适应分级亦将因缺乏收敛后的可靠告警集合而缺乏依据；其二，若仅建立统一风险记录表而缺失循环再预警去重，则表内将充斥车辆静止状态反复触发的重复告警，噪声淹没真正的新风险，在此基础上进行的任何风险分级都会因输入数据失真而失去意义；其三，若仅实现统一落库与去重而缺失基于车辆健康状态的自适应分级，则即使获得了可信、去重后的告警，也无法针对处于异常状态的车辆（如设备故障、信号异常）与健康车辆采用差异化的判定标准，误报漏报依然并存，预警的可处置性无从落地。由此，统一风险记录表提供可信且收敛的风险数据底座，循环再预警去重在该底座上抑制重复并保留新风险，自适应分级别基于去重后的可信告警按车辆健康状态精准定级——三者构成“统一底座→告警提纯→精准分级”的递进且闭环的技术链条，任一环节缺失都会导致预警视图无法支撑准确、及时的处置决策，故上述特征必须配套实施、不可分割，此为现有技术中周期与实时预警割裂、各自分散存储的方案所无法实现的技术效果。

17、与现有技术相比，本发明的有益效果为：

18、生成可信、可分级处置的统一风险视图。本发明将周期性规则计算层与实时流式预警层统一收敛至同一风险预警记录表，在该统一表上以终端标识、模型标识、条件类型的联合键结合里程变化实现循环再预警去重，并以去重后的可信告警为基础、按车辆健康状态进行自适应分级。三者构成“统一视图→告警提纯→精准分级”的递进数据链，下游分级质量依赖上游告警提纯，共同解决了现有技术无法在统一视图下生成可信、可分级处置的风险预警这一技术问题，取得了任一单一技术手段均无法实现的、作为整体协同的意想不到技术效果。

19、实现周期与实时双层融合、统一视图。将周期性规则计算与实时流式预警统一收敛至同一风险预警记录表，运营方在一处即可查看全量风险，消除了跨系统查询的低效，为车辆整体风险研判提供统一底座。

20、按车辆健康状态自适应分级、显著降低误报漏报。本发明对离线时长按车辆健康状态采用差异化的双阈值阶梯：车辆处于异常状态（如设备故障、信号异常）时其离线往往意味着更大风险（可能为人为拆卸或失控），采用紧凑阈值尽早升级风险；健康车辆偶尔的短时离线（如进入信号盲区）风险较低，采用宽松阈值避免误报。由此，同一离线时长指标在不同车辆健康状态下得到更贴合实际的风险判定——即便仅采用该自适应分级手段本身，亦能针对现有技术“统一标准判级导致误报漏报并存”的缺陷，独立实现降低误报与漏报的技术效果。