一种报警扩展信息回写方法、系统及存储介质与流程

本发明涉及分布式消息处理，具体涉及一种报警扩展信息回写方法、系统及存储介质。

背景技术：

1、在车载违章取证应用场景中，证据数据的处理流程通常涵盖证据下载完成后的质量判定、看板统计登记以及报警侧信息的回写等多个关键环节。目前，现有技术方案在处理上述业务时，普遍采用将状态监听、人工复核与平台字段更新等功能分散部署在独立模块中的架构模式。这种分散式的处理方式导致各业务环节之间缺乏紧密的耦合联动，难以形成以证据状态变更为单一入口的自动闭环处理机制。

2、具体而言，现有技术通常采用的方式是：通过消息队列接收证据状态通知后直接写入业务表，或者在特定界面由人工对无效证据进行复核，并手工填写车牌等信息后进行录入。虽然部分现有系统支持按照通道筛选图片的基础功能，但在整体业务流程的设计上，未能将基于通道存在性的证据质量判定与报警状态更新、专用标签绑定以及扩展列回写等操作构建在同一事务链路中进行协同处理。

3、此外，在保障数据一致性方面，现有的消费侧系统多采用分布式锁配合消费前全量对齐的机制。然而，这类机制主要面向设备上报链路设计，侧重于解决设备数据上报过程中的并发问题，难以直接适配并覆盖基于证据质量判定结果触发的多目标回写及状态联动等复杂业务需求。该局限导致现有方案在面对证据状态变化时，自动化程度低，且难以保证证据处理记录与业务对象状态之间的实时一致性。

技术实现思路

1、本发明的目的在于，提出一种报警扩展信息回写方法、系统及存储介质，能够区分无效证据与待人工证据，并保证证据处理记录与业务对象状态之间的实时一致性。

2、为了实现上述目的，第一方面，本发明提出一种报警扩展信息回写方法，包括：

3、接收证据状态变更消息，并对消息进行前置过滤，筛选出满足预设目标状态且属于预设业务类型的有效消息；

4、基于所述有效消息获取证据明细，根据所述证据明细中是否存在属于预定图像通道集合的文件，生成自动判定结果，并将包含所述自动判定结果的证据处理记录进行持久化存储；

5、当所述自动判定结果为无效时，执行无效证据联动更新操作，所述无效证据联动更新操作包括为关联的业务对象绑定专用标签以及更新报警状态；

6、执行扩展列回写操作，根据所述自动判定结果及所述证据明细中的文件信息，组装扩展字段并回写至所述业务对象的动态扩展列中。

7、基础方案的有益效果：本技术方案通过接收证据状态变更消息并进行前置过滤，基于证据明细中是否存在属于预定图像通道集合的文件生成自动判定结果，实现了证据有效性的自动化识别。当自动判定结果为无效时，系统自动执行无效证据联动更新操作并将处理记录持久化。替代了传统的人工逐条登记与审核方式，显著降低了运维成本，提高了证据处理的自动化水平。

8、本技术方案将自动判定结果与扩展列回写操作紧密结合，在执行无效证据联动更新操作的同时，根据自动判定结果及证据明细中的文件信息组装扩展字段并回写至业务对象的动态扩展列中。确保证据状态、报警标签、处理记录与平台展示信息的闭环一致性，有效避免了因人工操作疏漏导致的数据不一致问题。证据明细中的文件信息（如vai结构化数据）进行判定，确保了判定逻辑的严谨性。

9、本技术方案基于预设目标状态、预设业务类型以及预定图像通道集合进行前置过滤和自动判定，使得证据的审查规则与实际的取证设备通道及业务类型强绑定。使得方案能够灵活适配不同局点的取证规则差异；同时，结合证据明细中的文件信息进行判定，确保了判定逻辑的严谨性。

10、在执行扩展列回写操作时，本技术方案根据证据明细中的文件信息组装扩展字段，使得扩展列中回写信息的来源清晰、确定。不仅避免了数据来源混乱，确保了数据的可追溯性和可审计性，也支持了在特定场景下（如依据文件信息进行组装时）准确回写而不误写其他字段。

11、在接收证据状态变更消息时，对消息进行前置过滤，并在后续处理中将包含自动判定结果的证据处理记录进行持久化存储。从而保障同一证据的处理逻辑受控，确保数据状态的准确性，提升了系统在高并发或复杂消息场景下的稳定性和鲁棒性。

12、作为一种可实施的优选方案，对消息进行前置过滤，包括：

13、解析所述证据状态变更消息，提取状态字段和报警类型字段；

14、仅当所述状态字段的取值等于下载完成态且所述报警类型字段属于预配置的违章报警类型集合时，保留所述消息；

15、基于租户标识与证据标识的组合进行幂等性校验，若数据库中已存在对应的处理记录，则忽略所述消息。

16、作为一种可实施的优选方案，前置过滤步骤还包括：根据所述有效消息中的租户标识初始化租户上下文，以使后续接口调用具备对应的租户权限。

17、作为一种可实施的优选方案，根据所述证据明细中是否存在属于预定图像通道集合的文件，生成自动判定结果，包括：

18、从所述证据明细的文件列表中，筛选出文件类型为图像且通道号属于所述预定图像通道集合的文件，得到判定模块；

19、若所述判定模块为空，则生成表示无效的自动判定结果及表示系统自动处理的类型标识；

20、若所述判定模块非空，则生成表示待人工复核的自动判定结果及表示未自动处理的类型标识。

21、作为一种可实施的优选方案，无效证据联动更新操作，还包括：

22、在绑定所述专用标签之前，查询本地缓存或标签管理服务获取所述专用标签的标识；

23、若所述专用标签不存在，则创建所述专用标签并更新缓存；

24、若标签绑定或报警状态更新接口调用失败，记录错误日志但不撤销已持久化的所述证据处理记录。

25、作为一种可实施的优选方案，执行扩展列回写操作，包括：

26、当所述证据明细中存在属于预定图像通道集合的文件时，选取通道号数值最大的图像作为解析源，从所述图像的元数据中解析出车牌号码；

27、组装扩展字段映射对象：若解析出的车牌号码非空，写入车牌号扩展字段；当且仅当所述自动判定结果为无效时，写入处理类型扩展字段；

28、调用扩展列更新接口，将所述扩展字段映射对象回写至所述业务对象；若所述扩展字段映射对象为空，则跳过回写操作。

29、作为一种可实施的优选方案，扩展列回写操作对于自动判定结果为无效或待人工复核的证据均执行；

30、当自动判定结果为无效时，所述扩展字段映射对象包含处理类型扩展字段，或者同时包含处理类型扩展字段与车牌号扩展字段；

31、当自动判定结果为待人工复核时，所述扩展字段映射对象仅包含车牌号扩展字段，不包含处理类型扩展字段。

32、作为一种可实施的优选方案，所述方法采用批量消息监听模式，在整批消息处理结束后统一确认消费偏移量；单条消息处理异常仅记录日志并继续处理同批次剩余消息，不阻塞整批消息的确认流程；

33、若获取所述证据明细失败，则终止当前证据的处理流程，不写入所述证据处理记录且不执行后续的联动更新及扩展列回写操作；

34、所述证据处理记录作为后续报警状态更新、标签绑定及扩展列回写的唯一数据依据；所述自动判定结果的取值范围限定为无效或待人工复核；有效值由下游人工复核模块或ai分析模块独立写入。

35、第二方面，本技术提出一种报警扩展信息回写系统，应用于上述的一种报警扩展信息回写方法，包括：

36、消息过滤模块，用于接收证据状态变更消息，并对消息进行前置过滤，筛选出满足预设目标状态且属于预设业务类型的有效消息；

37、判定模块，用于基于所述有效消息获取证据明细，根据所述证据明细中是否存在属于预定图像通道集合的文件，生成自动判定结果；

38、处理记录持久化模块，用于将包含所述自动判定结果的证据处理记录进行持久化存储；

39、报警联动模块，用于当所述自动判定结果为无效时，执行无效证据联动更新操作，包括为关联的业务对象绑定专用标签以及更新报警状态；

40、标签缓存模块，用于缓存所述专用标签的标识，支持缓存未命中时的查询与创建；

41、车牌解析模块，用于当存在属于预定图像通道集合的文件时，选取通道号数值最大的图像解析车牌号码；

42、扩展列回写模块，用于根据所述自动判定结果及文件信息组装扩展字段并回写至所述业务对象的动态扩展列中。

43、第三方面，本技术提出一种计算机可读存储介质，所述存储介质上存储有计算机程序，当所述计算机程序被处理器执行时，实现上述的一种报警扩展信息回写方法。