基于区块链与多云协同的货运事件调度方法及系统与流程

本发明涉及数据处理技术，尤其涉及一种基于区块链与多云协同的货运事件调度方法及系统。

背景技术：

1、随着智慧物流、网络货运和区域协同运输体系的快速发展，货运平台逐步从单中心部署模式演进为双云容灾和跨区域多云部署模式，为满足跨区域接入、异地容灾、业务连续性和高可用要求，越来越多的货运平台采用多云协同架构，将不同区域业务部署在不同云节点之上，并通过主备机制实现容灾切换。

2、现有技术中，在多云货运平台的实际运行过程中，由于不同云节点之间存在网络时延差异、同步策略差异和局部故障风险，同一运单在不同云节点中的履约状态容易出现不一致现象，例如，某一云节点已经确认发车，而另一云节点仍停留在装货状态，可能导致在主云节点故障后，备云节点可能仅能恢复到某个滞后的履约状态，无法准确判断目标运单在故障发生前已实际完成到何种履约阶段，这类问题会影响后续的调度控制、签收确认、异常判断和结算处理，降低平台的可靠性。

3、因此，如何在多云货运平台进行容灾切换时，实现运单履约状态的精准恢复，成为亟需解决的问题。

技术实现思路

1、本发明提供一种基于区块链与多云协同的货运事件调度方法及系统，可以在多云货运平台进行容灾切换时，实现运单履约状态的精准恢复。

2、本发明的第一方面，提供一种基于区块链与多云协同的货运事件调度方法，包括：

3、将接收到的来自多云节点及多源终端的货运关键事件转换为标准事件对象并写入缓存队列，对所述缓存队列中的标准事件对象进行去重恢复处理，生成目标运单对应的有效恢复事件链；

4、基于所述有效恢复事件链识别所述目标运单的关键履约状态，将所述关键履约状态的摘要信息写入区块链网络，生成对应目标运单的链上可信锚点；

5、当触发运单可信状态判定时，基于所述链上可信锚点生成补充事件链，根据链上可信锚点与所述补充事件链对各多云节点的运单履约状态进行一致性校验，确定目标运单的可信履约状态；

6、根据所述可信履约状态控制所述目标运单进入下一履约阶段或触发异常处理流程。

7、可选地，在第一方面的一种可能实现方式中，所述将接收到的来自多云节点及多源终端的货运关键事件转换为标准事件对象并写入缓存队列，对所述缓存队列中的标准事件对象进行去重恢复处理，生成目标运单对应的有效恢复事件链，包括：

8、提取各货运关键事件中的运单标识、事件类型、事件时间及事件内容摘要，并基于预设的数据结构对提取后的数据进行重组得到标准事件对象，并基于所述运单标识将所述标准事件对象写入对应的缓存队列；

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、对所述目标运单添加异常状态标记，并暂停所述目标运单的自动调度操作；

35、获取所述当前编号与所述可信编号的编号差值，当所述编号差值小于预设阈值时，对各多云节点间的运单状态进行同步操作；

36、当所述差值大于或等于所述预设阈值时，触发人工复核流程；

37、当所述目标运单处于签收阶段或结算阶段时，禁止所述目标运单进入签收确认流程或结算发起流程。

38、本发明的第二方面，提供一种基于区块链与多云协同的货运事件调度系统，包括：

39、转换模块，用于将接收到的来自多云节点及多源终端的货运关键事件转换为标准事件对象并写入缓存队列，对所述缓存队列中的标准事件对象进行去重恢复处理，生成目标运单对应的有效恢复事件链；

40、生成模块，用于基于所述有效恢复事件链识别所述目标运单的关键履约状态，将所述关键履约状态的摘要信息写入区块链网络，生成对应目标运单的链上可信锚点；

41、校验模块，用于当触发运单可信状态判定时，基于所述链上可信锚点生成补充事件链，根据链上可信锚点与所述补充事件链对各多云节点的运单履约状态进行一致性校验，确定目标运单的可信履约状态；

42、控制模块，用于根据所述可信履约状态控制所述目标运单进入下一履约阶段或触发异常处理流程。

43、本发明的有益效果如下：

44、1、本发明可以通过将关键履约状态的摘要信息写入区块链形成链上锚点，在容灾切换时以链上锚点为恢复起点，从缓存队列中提取增量事件生成补充事件链并进行一致性校验，使备云节点能够根据不可修改的链上锚点和经过去重恢复的补充事件链，准确的确定运单的当前履约状态，从而可以保证调度控制的准确性。

45、2、本发明通过对接单、装货、发车、轨迹、签收和结算等关键事件进行统一标准化处理，并结合缓存暂存、重复过滤、断点续传和顺序恢复机制，能够在双云容灾和跨区域多云场景下有效降低同一运单在不同云节点中的状态不一致的问题，提高货运履约状态的一致性。

46、3、本发明通过将可信履约状态与当前处理节点本地记录的当前履约阶段在预设状态流转次序中对应的次序编号进行比较，当可信编号大于当前编号时判定状态向前推进并执行下一履约阶段的自动调度操作，当可信编号小于当前编号时判定状态回退并触发异常处理流程，使得多云货运平台能够根据可信履约状态对目标运单进行差异化的调度控制，可以提高履约调度控制的准确性和货运业务的安全性。