一种列车到离站信息生成方法、装置、设备以及存储介质与流程

1.本技术实施例涉及轨道交通领域，尤其涉及一种列车到离站信息生成方法、装置、设备以及存储介质。


背景技术：

2.目前，地铁作为人们一种重要的交通出行方式，给居民的生活带来了巨大的便利。随着地铁的发展，智慧车站、智慧线路等功能的逐步提出及落地实现，原有依据于离线计划与实际运行图的方式逐渐转变为实时输出的要求，对列车实时到离站数据提出了明确要求，而智慧地铁作为上层应用系统，多采用消息队列的方式接收列车位置、车速等车辆数据和信号数据。然而，在地铁线路建设的过程中，由于列车和信号系统与智慧地铁应用通常不在同一个项目中进行建设，同时由于建设单位提供的产品的多样性，导致智慧地铁应用难以获取到车辆数据和信号数据，使得智慧地铁应用在生成列车的实时到离站信息时，存在着计算难度大且计算成本高的技术问题。
3.综上所述，如何降低生成列车的实时到离站信息的计算难度，成为了目前亟需解决的技术问题。


技术实现要素：

4.本发明实施例提供了一种列车到离站信息生成方法、装置、设备以及存储介质，解决了现有技术在生成列车的实时到离站信息时，存在着计算难度大且计算成本高的技术问题。
5.第一方面，本发明实施例提供了一种列车到离站信息生成方法，包括：
6.在每个周期中，实时接收不同点位数据采集设备发送的点位数据并进行缓存，将每个所述周期内所缓存的点位数据作为每个所述周期的点位数据集合，所述点位数据由所述点位数据采集设备采集列车运行过程中的数据得到；
7.对每个所述点位数据集合中的点位数据进行排序，得到与每个所述点位数据集合相对应的目标点位数据集合；
8.对每个所述目标点位数据集合中的点位数据进行关联以及完整性校验，得到每个所述目标点位数据集合的多组点位数据组合；
9.当根据连续两个所述周期的多组点位数据组合，确定至少一辆目标列车发生移动后，确定所述目标列车是否到站或者离站；
10.若所述目标列车到站，生成所述目标列车的列车到站信息；若所述目标列车离站，生成所述目标列车的列车离站信息。
11.第二方面，本发明实施例提供了一种列车到离站信息生成装置，包括：
12.数据缓存模块，用于在每个周期中，实时接收不同点位数据采集设备发送的点位数据并进行缓存，将每个所述周期内所缓存的点位数据作为每个所述周期的点位数据集合，所述点位数据由所述点位数据采集设备采集列车运行过程中的数据得到；
13.数据排序模块，用于对每个所述点位数据集合中的点位数据进行排序，得到与每个所述点位数据集合相对应的目标点位数据集合；
14.数据校验模块，用于对每个所述目标点位数据集合中的点位数据进行关联以及完整性校验，得到每个所述目标点位数据集合的多组点位数据组合；
15.到站离站确定模块，用于当根据连续两个所述周期的多组点位数据组合，确定至少一辆目标列车发生移动后，确定所述目标列车是否到站或者离站；
16.信息生成模块，用于若所述目标列车到站，生成所述目标列车的列车到站信息；若所述目标列车离站，生成所述目标列车的列车离站信息。
17.第三方面，本发明实施例还提供了一种所述列车到离站信息生成设备，包括处理器以及存储器；
18.所述存储器用于存储计算机程序，并将所述计算机程序传输给所述处理器；
19.所述处理器用于根据所述计算机程序中的指令执行如第一方面所述的一种列车到离站信息生成方法。
20.第四方面，本发明实施例还提供了一种存储计算机可执行指令的存储介质，所述计算机可执行指令在由计算机处理器执行时用于执行如第一方面所述的一种列车到离站信息生成方法。
21.上述，本发明实施例在每个周期中实时接收不同点位数据采集设备发送的点位数据并构建点位数据集合，之后对点位数据进行排序、数据关联以及完整性校验，得到多组点位数据组合。当根据连续两个周期的多组点位数据组合，确定至少一辆目标列车发生移动时，确定目标列车是否到站或者离站；若目标列车到站，则生成目标列车的列车到站信息；若目标列车离站，则生成目标列车的列车离站信息。本发明实施例提供的列车到离站信息生成方法适用性强，满足于绝大多数地铁项目实施情况，可应用于大多数地铁线路中，能够降低生成列车的实时到离站信息的计算难度，同时能够有效降低项目变更所产生的成本，解决了现有技术在生成列车的实时到离站信息时，存在着计算难度大且计算成本高的技术问题。
附图说明
22.图1为本发明实施例提供的一种列车到离站信息生成方法的流程图。
23.图2为本发明实施例提供的一种区段的示意图。
24.图3为本发明实施例提供的另一种列车到离站信息生成方法的流程图。
25.图4为本发明实施例提供的一种列车启停的示意图。
26.图5为本发明实施例提供的一种列车到离站信息生成方法的步骤构架图。
27.图6为本发明实施例提供的一种列车到离站信息生成装置的结构示意图。
28.图7为本发明实施例提供的一种列车到离站信息生成设备的结构示意图。
具体实施方式
29.以下描述和附图充分地示出本技术的具体实施方案，以使本领域的技术人员能够实践它们。实施例仅代表可能的变化。除非明确要求，否则单独的部件和功能是可选的，并且操作的顺序可以变化。一些实施方案的部分和特征可以被包括在或替换其他实施方案的
部分和特征。本技术的实施方案的范围包括权利要求书的整个范围，以及权利要求书的所有可获得的等同物。在本文中，各实施方案可以被单独地或总地用术语“发明”来表示，这仅仅是为了方便，并且如果事实上公开了超过一个的发明，不是要自动地限制该应用的范围为任何单个发明或发明构思。本文中，诸如第一和第二等之类的关系术语仅仅用于将一个实体或者操作与另一个实体或操作区分开来，而不要求或者暗示这些实体或操作之间存在任何实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素。本文中各个实施例采用递进的方式描述，每个实施例重点说明的都是与其他实施例的不同之处，各个实施例之间相同相似部分互相参见即可。对于实施例公开的结构、产品等而言，由于其与实施例公开的部分相对应，所以描述的比较简单，相关之处参见方法部分说明即可。
30.如图1所示，图1为本发明实施例提供的一种列车到离站信息生成方法的流程图。本发明实施例提供的列车到离站信息生成方法可以由列车到离站信息生成设备执行，该列车到离站信息生成设备可以通过软件和/或硬件的方式实现，该列车到离站信息生成设备可以是两个或多个物理实体构成，也可以由一个物理实体构成。例如列车到离站信息生成设备可以是电脑、上位机、平板等设备。另外，列车到离站信息生成设备包括有多个分布式节点，不同的分布式节点用于执行本发明实施例提供的列车到离站信息生成方法中的一个步骤，或者是一个步骤中的某个特定功能，在本实施例中不进行具体限定。方法包括以下步骤：
31.步骤101、在每个周期中，实时接收不同点位数据采集设备发送的点位数据并进行缓存，将每个周期内所缓存的点位数据作为每个周期的点位数据集合，点位数据由点位数据采集设备采集列车运行过程中的数据得到。
32.本实施例中，在每个周期内，需要实时接收不同点位数据采集设备发送的点位数据，其中点位数据由点位数据采集设备采集列车运行过程中的数据得到。具体的，在智慧地铁的建设过程中，列车以及信号系统的数据往往通过综合监控系统进行采集后再上传到智慧地铁平台中，综合监控通过线路-车站-系统-设备-点位的模型进行数据采集，一个点位即为一个数据采集点。示例性的，广州5号线(线路)-员村站(车站)-车辆系统(系统)-车组1(设备)-实时速度(点位)，其中设备即为点位数据采集设备，一个点位数据采集设备能够获取多个不同点位上所采集到的点位数据，不同的点位数据包括了列车在运行过程中的各种状态数据。
33.在一个实施例中，点位数据包括车辆数据以及信号数据，车辆数据包括车组号，信号数据包括车次号、车组号、车次目的地站点以及车次当前所处区段名称，点位数据采集设备在发送点位数据时，还发送采集点位数据时的采集时间。
34.其中，区段是指轨道电路之间采用钢轨绝缘把两个轨道电路隔离成互不干扰的独立的电路单元，每个轨道电路单元成为轨道电路区段。在运行过程中，当列车经过区段时，信号系统可以识别到列车处在某个区段。如图2所示。在逻辑上，区段将轨道分割为连续的分段，运行时按顺序经过一系列区段，而当列车到达车站并停车时，列车停车的位置是一个明确的区段。另外，点位数据采集设备在发送点位数据至列车到离站信息生成设备时，还会同时上传采集到该点位数据的时间，即采集时间，其中采集时间不受列车到离站信息生成
设备的系统时间等因素的影响。
35.一个实施例中，不同点位数据采集设备在实时采集到点位数据后，可将点位数据输入至kafka中，再由kafka将点位数据传输到列车到离站信息生成设备中进行处理，使用kafka可以将点位数据采集设备与列车到离站信息生成设备之间进行解耦。其中，kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。kafka具有如下特性：(1)通过o(1)的磁盘数据结构提供消息的持久化，这种结构对于即使数以tb的消息存储也能够保持长时间的稳定性能。(2)高吞吐量：即使是非常普通的硬件kafka也可以支持每秒数百万的消息。(3)支持通过kafka服务器和消费机集群来分区消息。(4)支持hadoop并行数据加载。
36.通过kafka传递的点位数据，由于网络延迟以及源数据端等多种因素，可能导致同一时刻所采集的点位数据不能在同一时间被列车到离站信息生成设备处理。因此在本实施例中增加了一个数据延迟处理机制，即将每个周期所接收到的点位数据进行临时缓存，并根据每个点位数据生成水位线，将水位线与当前时间之间生成一个间隔，即可在一定程度上保障进入下游分布式节点的点位数据是完整的。例如，可以设置一个5秒的缓存周期，则水位线时间小于当前时间5秒，将5秒内的点位数据进行临时缓存，当当前时间向后流动1秒，水位线也向后推进1秒，则将采集时间在这1秒钟内的点位数据发送至下游的分布式节点中进行处理，无论这个数据是在5秒的缓存周期中哪个时间被列车到离站信息生成设备接收。可理解，在本实施例中周期的时间长度可根据实际需要进行设置，在本实施例中不进行具体限定。
37.步骤102、对每个点位数据集合中的点位数据进行排序，得到与每个点位数据集合相对应的目标点位数据集合。
38.在得到每个周期的点位数据集合后，为了保证后续对点位数据进行关联时的准确性，需要进一步对点位数据集合中的点位数据进行排序。示例性的，可根据采集时间对点位数据进行排序。在对每个点位数据集合中的点位数据重新排序后，即可得到与每个点位数据集合相对应的目标点位数据集合。
39.在上述实施例的基础上，步骤102中对每个点位数据集合中的点位数据进行排序，得到与每个点位数据集合相对应的目标点位数据集合，包括：
40.步骤1021、根据采集时间，对每个点位数据集合中的点位数据进行排序，得到与每个点位数据集合相对应的目标点位数据集合；其中，当采集时间相同时，根据点位数据的字段名称对点位数据进行排序。
41.在一个实施例中，在对点位数据集合中的点位数据进行排序时，首先需要根据采集时间，对每个点位数据集合中的点位数据进行排序。当采集时间相同时(毫秒数一致)，则根据点位数据的名称的权重对点位数据进行排序。示例性的，当多个点位数据的采集时间相同时，可将字段名称为车次号的点位数据排列最前，将字段名称为车次当前所处区段名称的点位数据排列在最后，以便后续在处理目标点位数据集合时，能够优先处理车次的变化再处理位置的变化。
42.在上述实施例的基础上，步骤1021、当采集时间相同时，根据点位数据的名称对点位数据进行排序，包括：
43.步骤10211、当采集时间相同时，依次根据车次号、车组号、车次目的地站点以及车
次当前所处区段名称，对点位数据进行排序。
44.在一个实施例中，在对点位数据集合中的点位数据进行排序时，若采集时间一致，则根据点位数据所对应的字段名称，对点位数据进行排序。具体的，依次根据车次号、车组号、车次目的地站点以及车次当前所处区段名称，对点位数据进行排序。在本实施例中对点位数据进行重新排序的原因在于，由于同一个采集点在不同采集时间会采集到不同车次的点位数据，例如同一个点位在不同采集时间会传输15046601和14036020两个车次号的数据，因此需要列车到离站信息生成设备优先确定出车次号变动后，在确定出与车次号相对应的列车的位置变动。
45.步骤103、对每个目标点位数据集合中的点位数据进行关联以及完整性校验，得到每个目标点位数据集合的多组点位数据组合。
46.在得到每个周期的目标点位数据集合后，列车到离站信息生成设备进一步将目标点位数据集合输出到下一个分布式节点中进行处理，下一个分布式节点在接收到目标点位数据集合后，即对目标点位数据集合中的点位数据进行关联以及完整性校验。具体的，在对点位数据进行关联时，可将属于同一个车次号的点位数据进行关联，得到一个车次的完整数据，即与每个车次相对应的点位数据组合，之后再对每个点位数据组合进行完整性校验，保证每个点位数据组合中的每个点位数据都是有相对应数值的。
47.在上述实施例的基础上，步骤103中对每个目标点位数据集合中的点位数据进行关联以及完整性校验，得到每个目标点位数据集合的多组点位数据组合，包括：
48.步骤1031、对每个目标点位数据集合中的点位数据根据数据来源进行分组，并对每组内属于同一辆列车的点位数据进行关联，得到每个目标点位数据集合中与不同列车相对应的列车点位数据组合。
49.在一个实施例中，在对目标点位数据集合中的点位数据进行关联之前，首先根据数据来源进行分组。具体的，可根据点位数据的数据来源(即点位数据所来源的点位数据采集设备)，对目标点位数据集合中的点位数据进行分组，其中根据点位数据所来源的点位数据采集设备进行分组的原因在于，一个车次完整的点位数据一般在一个点位数据采集设备内。
50.对目标点位数据集合中的点位数据进行分组后，进一步对设备点位数据组合中的点位数据进行关联，从而将同一个车次的点位数据进行关联。需要说明的是，由于分布式节点接收目标点位数据集合的数据时，并非一次性接收到所有数据，而是流式接收数据，因此分布式节点可在接收目标点位数据集合的同时，对目标点位数据集合的点位数据进行分组以及关联。例如，在接收到上游分布式节点发送的点位数据后，如果收到的是车次号、车组号以及车次目的地站点等点位数据，则将点位数据缓存起来；如果收到的是车次区段名称信息，则从缓存中读取车次号、车组号以及车次目的地站点等点位数据与车次区段名称信息进行关联，从而得到与不同列车相对应的列车点位数据组合。
51.步骤1032、对每组列车点位数据组合进行完整性校验，得到每个目标点位数据集合的多组点位数据组合。
52.在执行完步骤1031后，进一步对每组列车点位数据组合进行完整性校验，确定每组列车点位数据组合中的点位数据是否都有数值，校验完成后即可得到与每个目标点位数据集合相对应的多组点位数据组合，之后即可将多组点位数据组合输入到下游的分布式节
点中进行处理。其中需要说明的是，在将多组点位数据组合输入到下游时，每组点位数据组合中的点位数据需要整合在同一个数据流中进行传输。
53.步骤104、当根据连续两个周期的多组点位数据组合，确定至少一辆目标列车发生移动后，确定目标列车是否到站或者离站。
54.下游的分布式节点在接收到上游发送的多组点位数据组合后，当根据连续两个周期的多组点位数据组合，确定出至少一辆目标列车发生移动后，即可进一步确定出目标列车是否到达站台或者离开站台。示例性的，在连续的两个周期中，当根据第一个周期的某个点位数据组合中的车次区段名称信息确定出车次号为01的列车的位置为a区间，根据第二个周期的某个点位数据组合中的车次区段名称信息确定出车次号为01的列车的位置为b区间后，由于车次号为01的列车所占的区间发生变化，因此可以确定出车次号为01的目标列车发生移动，此时可进一步确定出目标列车是否到站或者离站。
55.在上述实施例的基础上，步骤104中当根据连续两个周期的多组点位数据组合，确定至少一辆目标列车发生移动后，确定目标列车是否到站或者离站，包括：
56.步骤1041、对于连续的第一周期以及第二周期的多组点位数据组合，对第一周期的多组点位数据组合以及第二周期的多组点位数据组合根据车组号重新进行分组，得到第一周期与每个车组号相对应的第一点位数据组合以及第二周期中与每个车组号相对应的第二点位数据组合，第一点位数据组合以及第二点位数据组合中包括与每个车组号相对应的信号数据。
57.在本实施例中，对于连续的两个周期中的第一周期以及第二周期，均需要对第一周期中的多组点位数据组合以及第二周期中的多组点位数据根据车组号重新进行分组。其中通过车组号进行重新分组的原因在于，同一个车组号可能会运行不同的车次，在某些特殊情况下，甚至同一个车组号可能连续运行两个车次，因此需要根据车组号对第一周期和第二周期中的多组点位数据组合重新进行分组，分别得到第一周期中与每个车组号相对应的第一点位数据组合以及第二周期中与每个车组号相对应的第二点位数据组合。第一点位数据组合以及第二点位数据组合中均包括车组号以及与每个车组号相对应的信号数据，即包括了{车组号、车次号、车次目的地站点、车次当前所处区段名称}，可理解，对于点位数据中的车辆数据以及信号数据，可通过车组号进行匹配。
58.步骤1042、对于每组第一点位数据组合，在第二点位数据组合中根据具有相同目标车组号的目标第二点位数据组合，确定车次当前所处区段名称发生变化后，确定与目标车组号相对应的目标列车发生移动，确定目标列车是否到站或者离站。
59.之后，对于第一周期中与每个车组号相对应的第一点位数据组合，在根据第二周期中具有相同的目标车组号的第二点位数据组合，确定出目标车组号的车次所处区段名称，与第一周期中目标车组号的车次当前所处区段名称不同时，即可确定出与目标车组号相对应的目标列车发生移动。例如，第一周期中的一组第一点位数据组合为{车组号01、车次号111、车次目的地站点s、车次当前所处区段名称a}，而在第二周期中，车组号01的第二点位数据组合为{车组号01、车次号111、车次目的地站点s、车次当前所处区段名称b}，即可确定出车组号01的目标列车移动。之后即可将第一周期中与目标车组号相对应的目标第一点位数据组合输出到下游的分布式节点中，使得下游的分布式节点进一步根据与目标第一点位数据组合确定出目标列车是否到站或者离站。需要说明的是，由于列车在一个区间内
运行时，点位数据采集设备在不同时刻会采集到与列车相对应的点位数据，因此列车到离站信息生成设备需要保证列车的位置发生变动后，才会将目标第一点位数据推动到下游进行处理。在另一个实施例中，当同一辆列车所对应的车次号发生变动时，也可以将目标第一点位数据推动到下游进行处理。
60.在上述实施例的基础上，步骤1042中确定目标列车是否到站或者离站，包括：
61.步骤10421、缓存与目标车组号相对应的目标第一点位数据组合中的车次当前所处区段名称。
62.在确定与目标车组号相对应目标列车是否到站或者离站时，首先在第一周期的第一点位数据组合中，获取与目标车组号相对应的目标第一点位数据组合，并将目标第一点位数据组合中的车次当前所处区段名称进行缓存。
63.步骤10422、根据当前所缓存的车次当前所处区段名称，以及上一次所缓存的与目标车组号相对应的车次当前所处区段名称，确定与目标列车是否到站或者离站。
64.之后，进一步根据当前所缓存的车次当前所处区段名称，以及上一次目标车组号相对应列车的位置移动时，所缓存的当前所处区段名称，确定与目标列车是否到站或者离站。具体的，根据当前所缓存的车次当前所处区段名称，以及上一次所缓存的与目标车组号相对应的车次当前所处区段名称，确定与目标列车是否到站或者离站，包括：
65.步骤104221、判断当前所缓存的车次当前所处区段名称是否为车站区段的名称。
66.步骤104222、若为车站区段的名称，确定目标列车到站，将目标第一点位数据组合的采集时间作为目标列车的到站时间。
67.在本实施例中，首先判断当前所缓存的车次当前所处区段名称是否为车站区段的名称，若是，则说明目标列车当前位于车站区段内，可以确定目标列车到站，将目标第一点位数据组合的采集时间作为目标列车的到站时间，并将到站时间和目标第一点位数据组合进行缓存。可理解，由于目标第一点位数据组合中只包括一个车组号的列车的点位数据，而同一辆列车的点位数据一般都会在同一个采集时间内采集得到。
68.步骤104223、若并非为车站区段的名称，判断上一次所缓存的与目标车组号相对应的车次当前所处区段名称，是否为车站区段的名称。
69.如果当前所缓存的车次当前所处区段名称并非为车站区段的名称，则需要获取上一次目标列车在发生移动后，所缓存的与目标车组号相对应的车次当前所处区段名称，判断上一次所缓存的车次当前所处区段名称，是否为车站区段的名称。
70.步骤104224、若为车站区段的名称，确定目标列车离站，将目标第一点位数据组合的采集时间作为目标列车的离站时间。
71.如果上一次所缓存的车次当前所处区段名称，是车站区段的名称，则说明目标列车上一次在移动后，目标列车进入了车站区段，而本次目标列车又发生了移动，则可以认为目标列车离开了车站区段，因此能够确定目标列车离站。此时，将目标第一点位数据组合的采集时间，作为目标列车的离站时间，并将离站时间和目标第一点位数据组合进行缓存。可理解，由于目标列车到站停下以及离站启动时都需要一定的时间，该时间内会经过较多的周期数，因此确认目标列车到站时所缓存的目标第一点位数据组合和确认目标列车离站时所缓存的目标第一点位数据组合并不相同。
72.步骤105、若目标列车到站，生成目标列车的列车到站信息；若目标列车离站，生成
目标列车的列车离站信息。
73.在确认目标列车到站后，即可根据到站时所缓存的并将到站时间和目标第一点位数据组合，生成目标列车的列车到站信息。示例性的，到站信息可以为：目的地站点为s，车组号为01，车次号为111的列车在xx时刻达到站点a。同理，对于目标列车的列车离站信息也可根据相同的方式进行生成，在本实施例中不再进行赘述。
74.在上述实施例的基础上，车辆数据还包括列车实时速度，第一点位数据组合还包括与每个车组号相对应的列车实时速度。
75.在本实施例中，点位数据采集设备所获取到的点位数据中，还包括有列车实时速度，在每个周期中生成与车组号相对应的第一点位数据组合时，第一点位数据组合内也包括有与每个车组号相对应列车的列车实时速度。例如第一点位数据组合为：{车组号01、车次号111、车次目的地站点s、实时速度x m/s、车次当前所处区段名称b}。
76.在一个实施例中，如图3所示，在生成与目标列车相对应的列车到站信息以及列车离站信息后，还包括以下步骤：
77.步骤106、根据目标车组号，获取目标列车在车站区段内的所有第一点位数据组合。
78.在一个实施例中，在生成目标列车在某个站点的到站信息和离站信息后，由于区段是有长度的，到站时间实际上是目标列车进入车站区段的时间，而离站时间实际上是目标列车离开车站区段的时间。但由于列车在进入车站区段后，会存在减速-停车-启动的过程，如图4所示。所以到站时间和离站时间对于目标列车真实的停车时间和启动时间来说，是不准确的，因此在本实施例中需要进一步对列车到站信息和列车离站信息进行更新。具体的，在本实施例中首先需要根据目标车组号，获取目标列车在车站区段内的所有第一点位数据组合。示例性的，可根据目标车组号以及车站区段的名称，获取目标列车在车站区段内的所有第一点位数据组合。
79.步骤107、获取所有第一点位数据组合中的列车实时速度，确定列车在车站区段内的停车时间以及启动时间，根据停车时间对列车到站信息进行更新，根据启动时间对列车离站信息进行更新。
80.之后，对于目标列车在车站区段内的所有第一点位数据组合，分别从所有的第一点位数据组合中获取列车实时速度，当列车实时速度变为0，并且再变为大于0时，则可以记录目标列车停车和再启动的一对数据，同时根据获取到相对应的第一点位数据的采集时间，能够记录目标列车在车站区段内的停车时间以及启动时间。最后再分别根据停车时间对列车到站信息进行更新，根据启动时间对列车离站信息进行更新，即可得到准确的到站信息以及离站信息。在一个实施例中，整体过程如图5所示。
81.另外，需要进一步说明的是，对于某些特定情况，例如对于列车站前折返的情况，车站与上一站之间有道岔，列车在到达车次目的地站点后，会在站台直接反向运行，并通过与上一站之间的道岔切换到上行或下行线路，此时列车的车次会改变。在这种情况下，在列车到站时缓存到站时间和目标第一点位数据组合时，可以将车组号、到站时间和车次当前所处区段名称绑定后进行缓存，从而即使车次变化时，由于车组号没有变化，在车次目的地站点依然能够关联到车组号的到站信息。具体的，通过列车当前所缓存的目标第一点位数据组合和上一次所缓存的目标第一点位数据组合中的车次号进行比对，如果是同一个车次
则是正常离开本站或站后折返方式，如果是不同车次，则可判断为站前折返的方式。此时即可根据车次号不同生成列车的到站信息和离站信息。
82.另外，当根据列车的启停时间对到站信息和离站信息进行更新时，在车站区段内可能会包括多组列车的启停时间，这种情况可能由于列车没有停到位等情况引起，在确定启停时间时，将停车时间最长的一组启停时间作为实际启停时间即可。
83.上述，本发明实施例在每个周期中实时接收不同点位数据采集设备发送的点位数据并构建点位数据集合，之后对点位数据进行排序、数据关联以及完整性校验，得到多组点位数据组合。当根据连续两个周期的多组点位数据组合，确定至少一辆目标列车发生移动时，确定目标列车是否到站或者离站；若目标列车到站，则生成目标列车的列车到站信息；若目标列车离站，则生成目标列车的列车离站信息。本发明实施例提供的列车到离站信息生成方法适用性强，满足于绝大多数地铁项目实施情况，可应用于大多数地铁线路中，能够降低生成列车的实时到离站信息的计算难度，同时能够有效降低项目变更所产生的成本，解决了现有技术在生成列车的实时到离站信息时，存在着计算难度大且计算成本高的技术问题。
84.另外，本发明实施例中还利用kafka将点位数据采集设备与列车到离站信息生成设备之间进行解耦，同时列车到离站信息生成设备在对kafka所传输的点位数据进行处理时，考虑了kafka在传输数据过程中所产生的数据匹配以及数据延迟的问题，从而可以使用kafka作为消息中间件，而不需要消息传递的严格一致。
85.如图6所示，图6为本发明实施例提供的一种列车到离站信息生成装置，包括：
86.数据缓存模块201，用于在每个周期中，实时接收不同点位数据采集设备发送的点位数据并进行缓存，将每个周期内所缓存的点位数据作为每个周期的点位数据集合，点位数据由点位数据采集设备采集列车运行过程中的数据得到；
87.数据排序模块202，用于对每个点位数据集合中的点位数据进行排序，得到与每个点位数据集合相对应的目标点位数据集合；
88.数据校验模块203，用于对每个目标点位数据集合中的点位数据进行关联以及完整性校验，得到每个目标点位数据集合的多组点位数据组合；
89.到站离站确定模块204，用于当根据连续两个周期的多组点位数据组合，确定至少一辆目标列车发生移动后，确定目标列车是否到站或者离站；
90.信息生成模块205，用于若目标列车到站，生成目标列车的列车到站信息；若目标列车离站，生成目标列车的列车离站信息。
91.在上述实施例的基础上，点位数据包括车辆数据以及信号数据，车辆数据包括车组号，信号数据包括车次号、车组号、车次目的地站点以及车次当前所处区段名称，点位数据采集设备在发送点位数据时，还发送采集点位数据时的采集时间。
92.在上述实施例的基础上，数据排序模块202具体用于根据采集时间，对每个点位数据集合中的点位数据进行排序，得到与每个点位数据集合相对应的目标点位数据集合；其中，当采集时间相同时，根据点位数据的字段名称对点位数据进行排序。
93.在上述实施例的基础上，数据排序模块202具体用于当采集时间相同时，依次根据车次号、车组号、车次目的地站点以及车次当前所处区段名称，对点位数据进行排序。
94.在上述实施例的基础上，数据校验模块203包括：
95.第一分组子单元，用于对每个目标点位数据集合中的点位数据根据数据来源进行分组，并对每组内属于同一辆列车的点位数据进行关联，得到每个目标点位数据集合中与不同列车相对应的列车点位数据组合；
96.数组校验子单元，用于对每组列车点位数据组合进行完整性校验，得到每个目标点位数据集合的多组点位数据组合。
97.在上述实施例的基础上，到站离站确定模块204包括：
98.第二分组子单元，用于对于连续的第一周期以及第二周期的多组点位数据组合，对第一周期的多组点位数据组合以及第二周期的多组点位数据组合根据车组号重新进行分组，得到第一周期与每个车组号相对应的第一点位数据组合以及第二周期中与每个车组号相对应的第二点位数据组合，第一点位数据组合以及第二点位数据组合中均包括车组号以及与每个车组号相对应的信号数据；
99.移动确定子单元，用于对于每组第一点位数据组合，在第二点位数据组合中根据具有相同目标车组号的目标第二点位数据组合，确定车次当前所处区段名称发生变化后，确定与目标车组号相对应的目标列车发生移动，确定目标列车是否到站或者离站。
100.在上述实施例的基础上，移动确定子单元具体用于缓存与目标车组号相对应的目标第一点位数据组合中的车次当前所处区段名称；根据当前所缓存的车次当前所处区段名称，以及上一次所缓存的与目标车组号相对应的车次当前所处区段名称，确定目标列车是否到站或者离站。
101.在上述实施例的基础上，移动确定子单元具体用于判断当前所缓存的车次当前所处区段名称是否为车站区段的名称；若为车站区段的名称，确定目标列车到站，将目标第一点位数据组合的采集时间作为目标列车的到站时间；若并非为车站区段的名称，判断上一次所缓存的与目标车组号相对应的车次当前所处区段名称，是否为车站区段的名称；若为车站区段的名称，确定目标列车离站，将目标第一点位数据组合的采集时间作为目标列车的离站时间。
102.在上述实施例的基础上，车辆数据还包括列车实时速度，第一点位数据组合还包括与每个车组号相对应的列车实时速度；
103.列车到离站信息生成装置还包括：
104.数据获取模块，用于根据目标车组号，获取目标列车在车站区段内的所有第一点位数据组合；
105.信息更新模块，用于获取所有第一点位数据组合中的列车实时速度，确定列车在车站区段内的停车时间以及启动时间，根据停车时间对列车到站信息进行更新，根据启动时间对列车离站信息进行更新。
106.本实施例还提供了一种列车到离站信息生成设备，如图7所示，一种列车到离站信息生成设备30，所述列车到离站信息生成设备包括处理器300以及存储器301；
107.所述存储器301用于存储计算机程序302，并将所述计算机程序302传输给所述处理器；
108.所述处理器300用于根据所述计算机程序302中的指令执行上述的一种列车到离站信息生成方法实施例中的步骤。
109.示例性的，所述计算机程序302可以被分割成一个或多个模块/单元，所述一个或
者多个模块/单元被存储在所述存储器301中，并由所述处理器300执行，以完成本技术。所述一个或多个模块/单元可以是能够完成特定功能的一系列计算机程序指令段，该指令段用于描述所述计算机程序302在所述列车到离站信息生成设备30中的执行过程。
110.所述列车到离站信息生成设备30可以是桌上型计算机、笔记本、掌上电脑及云端服务器等计算设备。所述列车到离站信息生成设备30可包括，但不仅限于，处理器300、存储器301。本领域技术人员可以理解，图7仅仅是列车到离站信息生成设备30的示例，并不构成对列车到离站信息生成设备30的限定，可以包括比图示更多或更少的部件，或者组合某些部件，或者不同的部件，例如所述列车到离站信息生成设备30还可以包括输入输出设备、网络接入设备、总线等。
111.所称处理器300可以是中央处理单元(central processing unit，cpu)，还可以是其他通用处理器、数字信号处理器(digital signal processor，dsp)、专用集成电路(application specific integrated circuit，asic)、现成可编程门阵列(field-programmable gate array，fpga)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等。通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。
112.所述存储器301可以是所述列车到离站信息生成设备30的内部存储单元，例如列车到离站信息生成设备30的硬盘或内存。所述存储器301也可以是所述列车到离站信息生成设备30的外部存储设备，例如所述列车到离站信息生成设备30上配备的插接式硬盘，智能存储卡(smart media card,smc)，安全数字(secure digital,sd)卡，闪存卡(flash card)等。进一步地，所述存储器301还可以既包括所述列车到离站信息生成设备30的内部存储单元也包括外部存储设备。所述存储器301用于存储所述计算机程序以及所述列车到离站信息生成设备30所需的其他程序和数据。所述存储器301还可以用于暂时地存储已经输出或者将要输出的数据。
113.所属领域的技术人员可以清楚地了解到，为描述的方便和简洁，上述描述的系统，装置和单元的具体工作过程，可以参考前述方法实施例中的对应过程，在此不再赘述。
114.在本技术所提供的几个实施例中，应该理解到，所揭露的系统，装置和方法，可以通过其它的方式实现。例如，以上所描述的装置实施例仅仅是示意性的，例如，所述单元的划分，仅仅为一种逻辑功能划分，实际实现时可以有另外的划分方式，例如多个单元或组件可以结合或者可以集成到另一个系统，或一些特征可以忽略，或不执行。另一点，所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口，装置或单元的间接耦合或通信连接，可以是电性，机械或其它的形式。
115.所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。
116.另外，在本发明各个实施例中的各功能单元可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现，也可以采用软件功能单元的形式实现。
117.所述集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用
时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：u盘、移动硬盘、只读存储器(rom，read-only memory)、随机存取存储器(ram，random access memory)、磁碟或者光盘等各种可以存储计算机程序的介质。
118.本发明实施例还提供一种包含计算机可执行指令的存储介质，所述计算机可执行指令在由计算机处理器执行时用于执行一种列车到离站信息生成方法，该方法包括以下步骤：
119.在每个周期中，实时接收不同点位数据采集设备发送的点位数据并进行缓存，将每个周期内所缓存的点位数据作为每个周期的点位数据集合，点位数据由点位数据采集设备采集列车运行过程中的数据得到；
120.对每个点位数据集合中的点位数据进行排序，得到与每个点位数据集合相对应的目标点位数据集合；
121.对每个目标点位数据集合中的点位数据进行关联以及完整性校验，得到每个目标点位数据集合的多组点位数据组合；
122.当根据连续两个周期的多组点位数据组合，确定至少一辆目标列车发生移动后，确定目标列车是否到站或者离站；
123.若目标列车到站，生成目标列车的列车到站信息；若目标列车离站，生成目标列车的列车离站信息。
124.注意，上述仅为本发明实施例的较佳实施例及所运用技术原理。本领域技术人员会理解，本发明实施例不限于这里所述的特定实施例，对本领域技术人员来说能够进行各种明显的变化、重新调整和替代而不会脱离本发明实施例的保护范围。因此，虽然通过以上实施例对本发明实施例进行了较为详细的说明，但是本发明实施例不仅仅限于以上实施例，在不脱离本发明实施例构思的情况下，还可以包括更多其他等效实施例，而本发明实施例的范围由所附的权利要求范围决定。

技术特征：
1.一种列车到离站信息生成方法，其特征在于，包括：在每个周期中，实时接收不同点位数据采集设备发送的点位数据并进行缓存，将每个所述周期内所缓存的点位数据作为每个所述周期的点位数据集合，所述点位数据由所述点位数据采集设备采集列车运行过程中的数据得到；对每个所述点位数据集合中的点位数据进行排序，得到与每个所述点位数据集合相对应的目标点位数据集合；对每个所述目标点位数据集合中的点位数据进行关联以及完整性校验，得到每个所述目标点位数据集合的多组点位数据组合；当根据连续两个所述周期的多组点位数据组合，确定至少一辆目标列车发生移动后，确定所述目标列车是否到站或者离站；若所述目标列车到站，生成所述目标列车的列车到站信息；若所述目标列车离站，生成所述目标列车的列车离站信息。2.根据权利要求1所述的一种列车到离站信息生成方法，其特征在于，所述点位数据包括车辆数据以及信号数据，所述车辆数据包括车组号，所述信号数据包括车次号、车组号、车次目的地站点以及车次当前所处区段名称，所述点位数据采集设备在发送所述点位数据时，还发送采集所述点位数据时的采集时间。3.根据权利要求2所述的一种列车到离站信息生成方法，其特征在于，所述对每个所述点位数据集合中的点位数据进行排序，得到与每个所述点位数据集合相对应的目标点位数据集合，包括：根据所述采集时间，对每个所述点位数据集合中的点位数据进行排序，得到与每个所述点位数据集合相对应的目标点位数据集合；其中，当所述采集时间相同时，根据所述点位数据的字段名称对所述点位数据进行排序。4.根据权利要求3所述的一种列车到离站信息生成方法，其特征在于，当所述采集时间相同时，根据所述点位数据的字段名称对所述点位数据进行排序，包括：当所述采集时间相同时，依次根据所述车次号、所述车组号、所述车次目的地站点以及所述车次当前所处区段名称，对所述点位数据进行排序。5.根据权利要求1所述的一种列车到离站信息生成方法，其特征在于，所述对每个所述目标点位数据集合中的点位数据进行关联以及完整性校验，得到每个所述目标点位数据集合的多组点位数据组合，包括：对每个所述目标点位数据集合中的点位数据根据数据来源进行分组，并对每组内属于同一辆列车的点位数据进行关联，得到每个所述目标点位数据集合中与不同列车相对应的列车点位数据组合；对每组所述列车点位数据组合进行完整性校验，得到每个所述目标点位数据集合的多组点位数据组合。6.根据权利要求2所述的一种列车到离站信息生成方法，其特征在于，所述当根据连续两个所述周期的多组点位数据组合，确定至少一辆目标列车发生移动后，确定所述目标列车是否到站或者离站，包括：对于连续的第一周期以及第二周期的多组点位数据组合，对所述第一周期的多组点位数据组合以及所述第二周期的多组点位数据组合根据所述车组号重新进行分组，得到所述
第一周期与每个所述车组号相对应的第一点位数据组合以及所述第二周期中与每个所述车组号相对应的第二点位数据组合，所述第一点位数据组合以及所述第二点位数据组合中均包括所述车组号以及与每个所述车组号相对应的信号数据；对于每组所述第一点位数据组合，在所述第二点位数据组合中根据具有相同目标车组号的目标第二点位数据组合，确定所述车次当前所处区段名称发生变化后，确定与所述目标车组号相对应的目标列车发生移动，确定所述目标列车是否到站或者离站。7.根据权利要求6所述的一种列车到离站信息生成方法，其特征在于，所述确定所述目标列车是否到站或者离站，包括：缓存与所述目标车组号相对应的目标第一点位数据组合中的车次当前所处区段名称；根据当前所缓存的车次当前所处区段名称，以及上一次所缓存的与所述目标车组号相对应的车次当前所处区段名称，确定所述目标列车是否到站或者离站。8.根据权利要求7所述的一种列车到离站信息生成方法，其特征在于，所述根据当前所缓存的车次当前所处区段名称，以及上一次所缓存的与所述目标车组号相对应的车次当前所处区段名称，确定所述目标列车是否到站或者离站，包括：判断当前所缓存的车次当前所处区段名称是否为车站区段的名称；若为所述车站区段的名称，确定所述目标列车到站，将所述目标第一点位数据组合的采集时间作为所述目标列车的到站时间；若并非为所述车站区段的名称，判断上一次所缓存的与所述目标车组号相对应的车次当前所处区段名称，是否为所述车站区段的名称；若为所述车站区段的名称，确定所述目标列车离站，将所述目标第一点位数据组合的采集时间作为所述目标列车的离站时间。9.根据权利要求8所述的一种列车到离站信息生成方法，其特征在于，所述车辆数据还包括列车实时速度，所述第一点位数据组合还包括与每个所述车组号相对应的列车实时速度；在生成与所述目标列车相对应的列车到站信息以及列车离站信息后，还包括以下步骤：根据所述目标车组号，获取所述目标列车在所述车站区段内的所有第一点位数据组合；获取所述所有第一点位数据组合中的列车实时速度，确定所述列车在所述车站区段内的停车时间以及启动时间，根据所述停车时间对所述列车到站信息进行更新，根据所述启动时间对所述列车离站信息进行更新。10.一种列车到离站信息生成装置，其特征在于，包括：数据缓存模块，用于在每个周期中，实时接收不同点位数据采集设备发送的点位数据并进行缓存，将每个所述周期内所缓存的点位数据作为每个所述周期的点位数据集合，所述点位数据由所述点位数据采集设备采集列车运行过程中的数据得到；数据排序模块，用于对每个所述点位数据集合中的点位数据进行排序，得到与每个所述点位数据集合相对应的目标点位数据集合；数据校验模块，用于对每个所述目标点位数据集合中的点位数据进行关联以及完整性校验，得到每个所述目标点位数据集合的多组点位数据组合；
到站离站确定模块，用于当根据连续两个所述周期的多组点位数据组合，确定至少一辆目标列车发生移动后，确定所述目标列车是否到站或者离站；信息生成模块，用于若所述目标列车到站，生成所述目标列车的列车到站信息；若所述目标列车离站，生成所述目标列车的列车离站信息。11.一种列车到离站信息生成设备，其特征在于，所述列车到离站信息生成设备包括处理器以及存储器；所述存储器用于存储计算机程序，并将所述计算机程序传输给所述处理器；所述处理器用于根据所述计算机程序中的指令执行如权利要求1-9中任一项所述的一种列车到离站信息生成方法。12.一种存储计算机可执行指令的存储介质，其特征在于，所述计算机可执行指令在由计算机处理器执行时用于执行如权利要求1-9中任一项所述的一种列车到离站信息生成方法。

技术总结
本发明公开了一种列车到离站信息生成方法、装置、设备以及存储介质。本发明在每个周期中实时接收不同点位数据采集设备发送的点位数据并构建点位数据集合，之后对点位数据进行排序、数据关联以及完整性校验，得到多组点位数据组合。当根据连续两个周期的多组点位数据组合，确定至少一辆目标列车发生移动时，确定目标列车是否到站或者离站；若目标列车到站，则生成目标列车的列车到站信息；若目标列车离站，则生成目标列车的列车离站信息。本发明提供的列车到离站信息生成方法适用性强，满足于绝大多数地铁项目实施情况，可应用于大多数地铁线路中，能够降低生成列车的实时到离站信息的计算难度，同时能够有效降低项目变更所产生的成本。的成本。的成本。


技术研发人员：杨浩帆
受保护的技术使用者：佳都科技集团股份有限公司 广州华佳软件有限公司 广东华之源信息工程有限公司 广州佳都城轨智慧运维服务有限公司
技术研发日：2023.01.09
技术公布日：2023/5/23