消防车作战报告生成方法及装置与流程

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.图1是本发明实施例提供的消防车作战报告生成方法的流程示意图；
41.图2是本发明实施例提供的数据流模型的结构示意图；
42.图3是本发明实施例提供的数据传输模型的结构示意图之一；
43.图4是本发明实施例提供的数据传输模型的结构示意图之二；
44.图5是本发明实施例提供的基于作战数据生成待测消防车的作战报告的流程示意图之一；
45.图6是本发明实施例提供的基于作战数据生成待测消防车的作战报告的流程示意图之二；
46.图7是本发明实施例提供的基于作战数据生成待测消防车的作战报告的流程示意图之三；
47.图8是本发明实施例提供的消防车作战报告生成装置的结构示意图；
48.图9是本发明实施例提供的电子设备的结构示意图。
具体实施方式
49.为使本发明的目的、技术方案和优点更加清楚，下面将结合本发明中的附图，对本发明中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。
50.下面结合图1至图7描述本发明的消防车作战报告生成方法。本发明消防车作战报告生成方法由云端服务器等电子设备或其中的硬件和/或软件执行。如图1所示，本发明消防车作战报告生成方法至少包括：
51.s101、基于预设的数据流模型接收以及解析待测消防车传输的实时数据流，并将所述实时数据流的解析结果存储为所述待测消防车的运行数据；其中，所述数据流模型用于将所述实时数据流中的数据写入至预设的消息队列，并对所述消息队列中的数据进行解析处理；所述消息队列的数量为一个或多个。
52.s102、基于所述运行数据获取预设参数的参数值，并基于所述预设参数的参数值确定所述待测消防车的作战时间段。
53.s103、获得所述运行数据中所述作战时间段对应的数据，作为所述待测消防车的作战数据，并基于所述作战数据生成所述待测消防车的作战报告。
54.本实施例中，待测消防车为待生成作战报告的消防车。待测消防车传输的实时数据流，可以包括待测消防车的车辆信息以及待测消防车上安装的传感装置实时采集的传感数据，另外，还可以包括待测消防车实时产生的整车数据等。
55.可以基于预设的数据流传输模型来接收以及解析待测消防车传输的实时数据流，数据流模型用于接收待测消防车传输的实时数据流，并将实时数据流中的数据写入到预设的消息队列，以通过消息队列对接收到的实时数据流中的数据进行存储，并对消息队列中的数据进行解析处理，从而能够实现对实时数据流的有效接收以及解析，为待测消防车的作战报告的生成提供了大量、全面的数据。
56.其中，消息队列的数量可以为一个或多个，可以根据数据解析任务的数量来创建消息队列，消息队列与数据解析任务一一对应，便于数据的传输和解析处理。
57.可以将实时数据流中解析后的数据作为待测消防车的运行数据存储至预设的数据存储装置，如，clickhouse(click stream,data warehouse，点击流数据仓)等实时数仓，以实现对大量实时数据的高性能存储，其中，可以对实时数据流中解析后的数据进行分类处理、事件添加等之后，存入实时数仓。另外，还可以基于事件添加的结果对实时数仓中存储的数据进行进一步处理，并存入数据表，以便于数据的调用。
58.在生成作战报告的过程中，可以从存储的运行数据中获取预设参数的参数值，并基于预设参数的参数值确定待测消防车的作战时间段。预设参数可以包括定位信息、水路系统的出水状态和预设工作装置的工作参数中的一种或多种。例如，预设参数为定位信息时，可以基于定位信息对应的位置与预设位置的比较结果，确定待测消防车的作战时间段，预设位置可以为待测消防车的常驻地；预设参数为水路系统的出水状态时，可以基于出水状态的状态值与预设状态值的比较结果，确定待测消防车的作战时间段；预设参数为预设工作装置的工作参数时，可以基于工作参数的参数值与预设值的比较结果，确定待测消防车的作战时间段，预设工作装置可以为臂架系统和/或支腿系统。作为一种可选的实施方
式，可以基于定位信息、水路系统的出水状态和预设工作装置的工作参数中的两种或三种确定待测消防车的作战时间段。
59.确定待测消防车的作战时间段后，可以从存储的运行数据中获取作战时间段对应的数据，并作为待测消防车的作战数据，以及基于作战数据生成待测消防车的作战报告。由于作战数据是基于待测消防车传输的实时数据流获取得到的，且包括了待测消防车整个作战时间段的数据，数据类型多，数据量大，且较为全面，从而基于待测消防车的作战数据能够保证生成的作战报告的有效性，进而根据生成的作战报告能够对消防车的作战性能进行有效改进。
60.本实施例通过预设的数据流模型接收待测消防车传输的实时数据流，并将实时数据流中的数据写入至预设的消息队列，对消息队列中的数据进行解析处理后存储为待测消防车的运行数据，基于运行数据获取预设参数的参数值，并基于预设参数的参数值确定待测消防车的作战时间段，以及获得运行数据中作战时间段对应的作战数据，获得的作战数据的数据类型多、数据量大，较为全面，由此，在基于作战数据生成待测消防车的作战报告的过程中，保证了作战报告的有效性，进而根据生成的作战报告能够对消防车的作战性能进行有效改进。
61.在示例性实施例中，如图2所示，所述数据流模型包括数据传输模型201和数据解析模型202；
62.所述数据解析模型202包括一个或多个数据解析子模型203，所述数据解析子模型203与所述消息队列一一对应；所述数据解析子模型203用于发送数据需求信息至所述数据传输模型201，还用于对相应的所述消息队列中的数据进行解析处理；其中，图2中以多个数据解析子模型203进行示例；
63.所述数据传输模型201用于将所述实时数据流中的数据转换为消息，并写入相应的所述消息队列，基于各所述数据解析子模型203发送的数据需求信息，将各所述消息队列中的消息传输至相应的所述数据解析子模型203。
64.本实施例中，预设的数据流模型可以包括数据传输模型201和数据解析模型202。数据解析模型202可以包括一个或多个数据解析子模型203，数据解析子模型203与消息队列一一对应，不同的数据解析子模型203可以用于执行不同的解析任务，例如，不同的数据解析子模型203可以对实时数据流中不同数据类别的数据进行解析处理。可以基于数据解析子模型203来设置消息队列、各消息队列对应的标识信息以及消息队列与数据解析子模型203之间的对应关系。
65.数据传输模型201在接收实时数据流的过程中，可以将实时数据流中的每一条数据均转换为消息，并写入到相应的消息队列。消息可以包括消息头和消息体，对于实时数据流中的任一条数据，在转换为消息时，消息头可以包括该数据对应的消息队列的标识信息，消息体可以包括该数据的数据内容。例如，数据传输模型201可以基于该数据的数据类别确定该数据对应的消息队列，并基于该数据对应的消息队列的标识信息生成消息头，以及基于该数据的数据值生成消息体，从而将该数据转换为消息，并将其写入至该数据对应的消息队列，以通过消息队列对实时数据流中的数据进行暂存，实现了对实时数据流的实时接收。
66.各数据解析子模型203可以根据自身的数据处理能力发送数据需求信息至数据传
输模型201，数据传输模型201可以根据各数据解析子模型203发送的数据需求信息，将每一个消息队列中的消息传输至相应的数据解析子模型203，例如，可以根据各数据解析子模型203发送的数据需求信息，确定各数据解析子模型203所需要的数据量，对于任一数据解析子模型203，可以根据该数据解析子模型203需要的数据量，从相应的消息队列中获取相应数据量的数据并转发至该数据解析子模型203，从而能够按照各数据解析子模型203的数据处理能力对各消息队列中的数据进行转发，实现了对实时数据流的传输以及解析。
67.各数据解析子模型203可以对接收到的消息队列中的数据进行解析，以实现对实时数据流的解析处理，进一步保证了生成的作战报告的可靠性。
68.在示例性实施例中，如图3所示，所述数据传输模型201包括依次连接的消息生成单元301、数据中转单元302和数据输出单元303，所述数据输出单元303包括一个或多个数据输出子单元304，所述数据输出子单元304与所述数据解析子模型203一一对应连接；其中，图3中以多个数据输出子单元304进行示例；
69.所述消息生成单元301用于确定所述实时数据流中的目标数据的数据类别，以及根据所述目标数据的数据类别将所述目标数据转换为消息后传输至所述数据中转单元302；
70.所述数据中转单元302用于基于各所述数据解析子模型203发送的数据需求信息，将接收到的消息写入相应的所述消息队列，以及将各所述消息队列中的消息投递至相应的所述数据输出子单元304；
71.所述数据输出子单元304用于将接收到的消息转发至相应的所述数据解析子模型203。
72.本实施例中，数据传输模型201包括依次连接的消息生成单元301、数据中转单元302和数据输出单元303。
73.目标数据为当前时刻进行消息转换的数据。消息生成单元301用于确定实时数据流中目标数据的数据类别，并根据目标数据的数据类别将目标数据转换为消息后传输至数据中转单元302。例如，消息生成单元301可以根据目标数据中预设位的数值，确定目标数据的数据类别，可以理解的是，对于实时数据流中的任一数据，其预设位的数值用于表征该数据的数据类别。消息生成单元301可以基于目标数据的数据类别，确定目标数据对应的消息队列，并基于该消息队列对应的标识信息生成消息头，以及，基于目标数据的数据位的数值生成消息体，从而通过消息头和消息体构成目标数据对应的消息。
74.数据中转单元302可以根据各数据解析子模型203发送的需求信息，确定各数据解析子模型203所需要的数据量，并根据各数据解析子模型203所需要的数据量，将接收到的消息写入相应的消息队列，以及，根据各数据解析子模型203所需要的数据量，将各消息队列中的消息投递至相应的数据输出子单元304，例如，可以根据所需要的数据量来分配各消息队列对应的数据传输线程，该消息队列对应的数据解析子模型203所需要的数据量越大，为该消息队列分配的数据传输线程越多，以使得数据需求量大的数据解析子模型203对应的消息队列能够快速消息入队以及快速消息输出，从而能够在保证数据中转单元302的资源得到充分利用的同时，有效满足各数据解析子模型203的数据解析需求，且提高了数据传输效率。
75.在示例性实施例中，所述数据中转单元302包括数据通信单元和数据转发单元；
76.所述数据通信单元用于基于各所述数据解析子模型203发送的数据需求信息，为每一个所述消息队列分配第一数据传输线程，并通过所述第一数据传输线程将接收到的消息写入相应的所述消息队列；
77.所述数据转发单元用于基于各所述数据解析子模型203发送的数据需求信息，为每一个所述消息队列分配第二数据传输线程，并通过所述第二数据传输线程将各所述消息队列中的消息投递至相应的所述数据输出子单元304。
78.本实施例中，数据通信单元与消息生成单元301连接，数据通信单元可以基于各数据解析子模型203发送的数据需求信息，确定各数据解析子模型203所需要的数据量，并根据各数据解析子模型203所需要的数据量为每一个消息队列分配第一数据传输线程，以通过各第一数据传输线程将接收到的消息写入到相应的消息队列。例如，数据通信单元可以基于各解析子模型所需要的数据量，采用负载均衡的方法为每一个消息队列分配第一数据传输线程，从而能够根据各数据解析子模型203的数据需求信息控制各消息入队，使得数据需求量大的数据解析子模型203对应的消息队列能够快速消息入队，便于快速转发消息至各数据解析子模型203，以满足各数据解析子模型203的数据解析需求，且提高了数据传输效率。
79.另外，数据通信单元在将接收到的消息写入相应的消息队列之前，还可以对接收到的消息进行有效性检测，例如，可以对接收到的消息进行消息结构的检测(如，对消息头和/或消息体的长度是否满足要求)、消息内容的检测(例如，消息名称是否满足要求)，等等。若检测结果为有效，则将该消息写入相应的消息队列，若检测结果为无效，则剔除该消息，从而能够有效提高转发至数据解析模型202的数据的有效性。
80.数据转发单元一端与数据通信单元连接，另一端与数据输出单元303连接。数据转发单元可以基于各数据解析子模型203发送的数据需求信息，确定各数据解析子模型203所需要的数据量，并根据各数据解析子模型203所需要的数据量为每一个消息队列分配第二数据传输线程，通过各第二数据传输线程将每一个消息队列中的消息投递至相应的数据输出子单元304，以通过各数据输出子单元304向相应的数据解析子模型203转发消息。例如，数据转发单元可以基于各解析子模型所需要的数据量，采用负载均衡的方法为每一个消息队列分配第二数据传输线程，从而能够有效满足各数据解析子模型203的数据解析需求，且提高了数据传输效率。
81.另外，数据转发单元还可以维护各消息队列与相应的数据输出子单元304的连接信息，以保证各消息队列中消息的有效转发。
82.在示例性实施例中，所述数据通信单元用于基于各所述数据解析子模型203发送的数据需求信息，采用负载均衡的方法为每一个所述消息队列分配所述第一数据传输线程；
83.和/或，
84.所述数据转发单元用于基于各所述数据解析子模型203发送的数据需求信息，采用负载均衡的方法为每一个所述消息队列分配所述第二数据传输线程。
85.本实施例中，数据通信单元采用负载均衡的方法为每一个消息队列分配第一数据传输线程的过程中，可以基于各数据解析子模型203所需要的数据量，确定各消息队列对应的第一数据传输线程的数量占比，并根据数据通信单元中第一数据传输线程的最大可分配
数量以及各消息队列对应的第一数据传输线程的数量占比，确定各消息队列对应的第一数据传输线程的数量，从而能够在保证数据通信单元的资源得到充分利用的同时，有效满足各数据解析子模型203的数据解析需求，且提高了数据传输效率。
86.数据转发单元采用负载均衡的方法为每一个消息队列分配第二数据传输线程的过程中，可以基于各数据解析子模型203所需要的数据量，确定各消息队列对应的第二数据传输线程的数量占比，并根据数据转发单元中第二数据传输线程的最大可分配数量以及各消息队列对应的第二数据传输线程的数量占比，确定各消息队列对应的第二数据传输线程的数量，从而能够在保证数据转发单元的资源得到充分利用的同时，有效满足各数据解析子模型203的数据解析需求，且提高了数据传输效率。
87.在示例性实施例中，如图4所示，所述数据传输模型201还包括数据预处理单元401；
88.所述数据预处理单元401用于对所述实时数据流中的数据进行数据预处理后传输至所述消息生成单元301。
89.本实施例中，数据传输模型201还包括数据预处理单元401，数据预处理单元401的输入端用于接收待测消防车传输的实时数据流，数据预处理单元401的输出端与消息生成单元301连接，通过数据预处理单元401对实时数据流中的数据进行数据预处理后传输至消息生成单元301，以生成消息。
90.数据预处理的方法可以包括：为实时数据流中的数据添加到达时刻、对实时数据流中的数据进行信元长度的校验、对实时数据流中的数据进行crc(cyclic redundancy check，循环冗余校核)，等等，从而能够有效保证数据传输模型201转发至数据解析模型202的消息的有效性。
91.作为一种可选的实施方式，待测消防车传输的实时数据流可以通过预设的数据处理中心等数据处理设备进行数据处理后传输至数据预处理单元401，例如，可以通过数据处理设备对实时数据流中的数据进行报文解密、数据过滤等，以保证传输至数据流模型的数据的有效性。
92.其中，本实施例数据流模型的吞吐量可达到10兆比特每秒，解析速度可达到10万条数据每秒。
93.在示例性实施例中，所述作战报告包括所述待测消防车的预设工作装置的姿态分布数据；如图5所示，所述基于所述作战数据生成所述待测消防车的作战报告，包括：
94.s501、基于所述作战数据中所述预设工作装置对应的第一传感数据，获得所述预设工作装置的工作数据；
95.s502、对所述工作数据进行分组处理，得到数据队列，并将所述数据队列输入至预设姿态分类模型，得到所述预设工作装置的姿态分类结果；
96.s503、基于所述姿态分类结果，确定所述预设工作装置的姿态分布数据。
97.本实施例中，待测消防车的预设工作装置可以包括臂架系统和/或支腿系统，臂架系统可以包括多节臂架，例如，可以包括6节臂架，支腿系统可以包括多个支腿，例如，可以包括4个支腿。臂架系统的姿态分布数据可以包括臂架系统的不同姿态的占比。
98.在基于作战数据生成待测消防车的作战报告的过程中，可以获取作战数据中预设工作装置对应的第一传感数据，并根据第一传感数据获得预设工作装置的工作数据。
99.其中，预设工作装置为臂架系统时，第一传感数据可以包括臂架系统中各节臂架的角度检测值。在根据臂架系统对应的第一传感数据获得臂架系统的工作数据时，可以直接将臂架系统对应的第一传感数据作为臂架系统的工作数据，也可以基于臂架系统对应的第一传感数据以及臂架系统中各节臂架的长度，确定每一节臂架的预设端的位置信息，并将每一节臂架的预设端的位置信息作为臂架系统的工作数据。例如，可以将臂架系统中的转台作为原点构建二维坐标系，并根据每一节臂架的角度和长度，确定各节臂架的预设端在该二维坐标系中的坐标，以得到每一节臂架的预设端的位置信息。预设端可以为臂架末端，即，远离转台的一端。
100.预设工作装置为支腿系统时，第一传感数据可以包括支腿系统中各支腿的角度检测值或伸出长度检测值。在根据支腿系统对应的第一传感数据获得支腿系统的工作数据时，可以直接将支腿系统对应的第一传感数据作为支腿系统的工作数据。
101.对预设工作装置的工作数据进行分组处理的过程中，可以采用预设滑窗将工作数据划分为多个数据组，预设滑窗的滑动步长即为预设滑窗的长度；还可以基于预设时间间隔(如，2秒)对工作数据进行采样处理，并基于各采样时刻的先后顺序，将预设数量(如，60条)的工作数据作为一个数据组，各数据组形成数据队列，并将数据队列传输至预设姿态分类模型，以实现将大量的工作数据输入至预设姿态分类模型。
102.预设姿态分类模型可以为非监督聚类模型，如，k-means聚类模型，通过预设姿态分类模型，可以得到k(k为大于1的正整数)个聚类中心，以及每一条工作数据对应的聚类中心，其中，每一个聚类中心代表预设工作装置的一类姿态。可以基于姿态分类结果，生成预设工作装置的姿态分布数据，从而能够快速准确地确定预设工作装置的姿态分布数据。
103.在示例性实施例中，所述基于所述姿态分类结果，确定所述预设工作装置的姿态分布数据，包括：
104.获取所述姿态分类结果中的每一类姿态对应的所述工作数据的数量；
105.基于每一类姿态对应的所述工作数据的数量，确定所述预设工作装置的姿态分布数据。
106.本实施例中，姿态分类结果可以包括多个类别的姿态，以及每一条工作数据对应的姿态的类别，从而可以确定每一类姿态对应的工作数据的数量。
107.在基于每一类姿态对应的工作数据的数量，确定预设工作装置的姿态分布数据的过程中，可以基于每一类姿态对应的工作数据的数量，以及各类姿态对应的工作数据的总数量，确定各类姿态对应的工作数据的占比，对于各类姿态中的任一类姿态，可以将该类姿态对应的工作数据的占比作为该类姿态的占比，并基于各类姿态的占比确定预设工作装置的姿态分布数据。例如，预设工作装置的姿态分布数据可以包括每一类姿态的占比，还可以仅包括各类姿态中预设姿态(例如，占比为前三的姿态)的占比，从而能够快速准确地确定预设工作装置的姿态分布数据。
108.在实际应用中，姿态分布数据中的每一类姿态，可以通过图形的形式来表示。例如，对于姿态分布数据中的任一类姿态，可以基于该类姿态对应的聚类中心，绘制预设工作装置的姿态图，并在姿态图中标注该类姿态的占比，从而能够直观地对预设工作装置的姿态分布数据进行展示。
109.在示例性实施例中，所述作战报告包括所述待测消防车的水路系统的工况分布数
据；如图6所示，所述基于所述作战数据生成所述待测消防车的作战报告，包括：
110.s601、获取所述作战数据中所述水路系统的出水状态对应的第二传感数据；
111.s602、基于所述第二传感数据，生成所述水路系统的工况分布数据。
112.本实施例中，待测消防车的水路系统的工况分布数据可以包括水路系统中不同供水状态的占比，其中，供水状态可以为供水流量。
113.在基于作战数据生成待测消防车的作战报告的过程中，可以获取作战数据中水路系统的供水状态对应的第二传感数据，并基于第二传感数据生成水路系统的工况分布数据。例如，可以基于各第二传感数据与多个预设流量范围的比较结果，确定各第二传感数据所处的预设流量范围，以得到各预设流量范围对应的第二传感数据的数量，可以将每一个预设流量范围作为水路系统的一个供水状态，从而能够得到水路系统的各供水状态对应的第二传感数据的数量。可以基于每一个供水状态对应的第二传感数据的数量，以及各供水状态对应的第二传感数据的总数量，确定各供水状态对应的第二传感数据的占比，对于各供水状态中的任一供水状态，可以将该供水状态对应的第二传感数据的占比作为该供水状态的占比，并基于各供水状态的占比确定水路系统的工况分布数据。例如，可以直接将各供水状态的占比作为水路系统的工况分布数据，从而能够快速准确地确定水路系统的工况分布数据。
114.在实际应用中，工况分布数据可以通过图表(如，柱状图)的形式进行展示，也可以通过表格的形式进行展示，从而能够直观地对水路系统的工况分布数据进行展示。
115.可以理解的是，作战报告还可以包括待测消防车的水路系统的最大供水流量、平均供水流量和用水量等数据。其中，可以基于第二传感数据获得最大供水流量、平均供水流量和用水量。
116.在示例性实施例中，所述作战报告包括所述待测消防车的设备状态数据；如图7所示，所述基于所述作战数据生成所述待测消防车的作战报告，包括：
117.s701、获取所述作战数据中一个或多个预设工作参数对应的第三传感数据；
118.s702、基于所述第三传感数据，确定所述待测消防车的设备状态数据。
119.本实施例中，待测消防车的设备状态数据可以包括待测消防车的预设工作参数对应的参数值。预设工作参数的数量为一个或多个，例如，预设工作参数可以包括臂架的工作高度、臂架的工作幅度、液压系统的主系统压力、分动箱油温、液压油温、臂架末端温度、发动机转速、水泵转速和水泵出口压力中的一个或多个。预设工作参数对应的参数值可以包括预设工作参数的最大值、预设工作参数的平均值和预设工作参数的值域中的一种或多种。
120.在基于作战数据生成待测消防车的作战报告的过程中，可以获取作战数据中各预设工作参数对应的第三传感数据，并基于第三传感数据确定各预设工作参数对应的参数值，并作为待测消防车的设备状态数据。在实际应用中，待测消防车的设备状态数据可以通过表格的形式进行展示，从而能够直观地对待测消防车的设备状态数据进行展示。
121.在示例性实施例中，所述作战报告包括所述待测消防车的作战地信息；所述基于所述作战数据生成所述待测消防车的作战报告，包括：
122.获取所述作战数据中的定位信息，以及，基于所述定位信息确定所述作战地信息。
123.在示例性实施例中，所述作战报告包括所述待测消防车的车辆信息；还包括：
124.获取所述运行数据中的预设装备参数的参数值，并基于所述预设装备参数的参数值生成所述车辆信息。
125.本实施例中，预设装备参数可以包括装备类型、装备编号、装备型号、服务工程师、联系方式、底盘类型、交机时间、上次保养时间、常驻地等。
126.下面对本发明提供的消防车作战报告生成装置进行描述，下文描述的消防车作战报告生成装置与上文描述的消防车作战报告生成方法可相互对应参照。如图8所示，本发明消防车作战报告生成装置至少包括：
127.第一处理模块801，用于基于预设的数据流模型接收以及解析待测消防车传输的实时数据流，并将所述实时数据流的解析结果存储为所述待测消防车的运行数据；其中，所述数据流模型用于将所述实时数据流中的数据写入至预设的消息队列，并对所述消息队列中的数据进行解析处理；所述消息队列的数量为一个或多个；
128.第二处理模块802，用于基于所述运行数据获取预设参数的参数值，并基于所述预设参数的参数值确定所述待测消防车的作战时间段；
129.第三处理模块803，用于获得所述运行数据中所述作战时间段对应的数据，作为所述待测消防车的作战数据，并基于所述作战数据生成所述待测消防车的作战报告。
130.在示例性实施例中，所述数据流模型包括数据传输模型和数据解析模型；
131.所述数据解析模型包括一个或多个数据解析子模型，所述数据解析子模型与所述消息队列一一对应；所述数据解析子模型用于发送数据需求信息至所述数据传输模型，还用于对相应的所述消息队列中的数据进行解析处理；
132.所述数据传输模型用于将所述实时数据流中的数据转换为消息，并写入相应的所述消息队列，基于各所述数据解析子模型发送的数据需求信息，将各所述消息队列中的消息传输至相应的所述数据解析子模型。
133.在示例性实施例中，所述数据传输模型包括依次连接的消息生成单元、数据中转单元和数据输出单元，所述数据输出单元包括一个或多个数据输出子单元，所述数据输出子单元与所述数据解析子模型一一对应连接；
134.所述消息生成单元用于确定所述实时数据流中的目标数据的数据类别，以及根据所述目标数据的数据类别将所述目标数据转换为消息后传输至所述数据中转单元；
135.所述数据中转单元用于基于各所述数据解析子模型发送的数据需求信息，将接收到的消息写入相应的所述消息队列，以及将各所述消息队列中的消息投递至相应的所述数据输出子单元；
136.所述数据输出子单元用于将接收到的消息转发至相应的所述数据解析子模型。
137.在示例性实施例中，所述数据中转单元包括数据通信单元和数据转发单元；
138.所述数据通信单元用于基于各所述数据解析子模型发送的数据需求信息，为每一个所述消息队列分配第一数据传输线程，并通过所述第一数据传输线程将接收到的消息写入相应的所述消息队列；
139.所述数据转发单元用于基于各所述数据解析子模型发送的数据需求信息，为每一个所述消息队列分配第二数据传输线程，并通过所述第二数据传输线程将各所述消息队列中的消息投递至相应的所述数据输出子单元。
140.在示例性实施例中，所述数据通信单元用于基于各所述数据解析子模型发送的数
据需求信息，采用负载均衡的方法为每一个所述消息队列分配所述第一数据传输线程；
141.和/或，
142.所述数据转发单元用于基于各所述数据解析子模型发送的数据需求信息，采用负载均衡的方法为每一个所述消息队列分配所述第二数据传输线程。
143.在示例性实施例中，所述数据传输模型还包括数据预处理单元；
144.所述数据预处理单元用于对所述实时数据流中的数据进行数据预处理后传输至所述消息生成单元。
145.在示例性实施例中，所述作战报告包括所述待测消防车的预设工作装置的姿态分布数据；所述第三处理模块803具体用于：
146.基于所述作战数据中所述预设工作装置对应的第一传感数据，获得所述预设工作装置的工作数据；
147.对所述工作数据进行分组处理，得到数据队列，并将所述数据队列输入至预设姿态分类模型，得到所述预设工作装置的姿态分类结果；
148.基于所述姿态分类结果，确定所述预设工作装置的姿态分布数据。
149.在示例性实施例中，所述第三处理模块803具体用于：
150.获取所述姿态分类结果中的每一类姿态对应的所述工作数据的数量；
151.基于每一类姿态对应的所述工作数据的数量，确定所述预设工作装置的姿态分布数据。
152.在示例性实施例中，所述作战报告包括所述待测消防车的水路系统的工况分布数据；所述第三处理模块803具体用于：获取所述作战数据中所述水路系统的供水状态对应的第二传感数据，并基于所述第二传感数据，生成所述水路系统的工况分布数据；
153.和/或，
154.所述作战报告包括所述待测消防车的设备状态数据；所述第三处理模块803具体用于：获取所述作战数据中一个或多个预设工作参数对应的第三传感数据，并基于所述第三传感数据，确定所述待测消防车的设备状态数据。
155.图9示例了一种电子设备的实体结构示意图，如图9所示，该电子设备可以包括：处理器(processor)901、通信接口(communications interface)902、存储器(memory)903和通信总线904，其中，处理器901，通信接口902，存储器903通过通信总线904完成相互间的通信。处理器901可以调用存储器903中的逻辑指令，以执行消防车作战报告生成方法，该方法包括：基于预设的数据流模型接收以及解析待测消防车传输的实时数据流，并将所述实时数据流的解析结果存储为所述待测消防车的运行数据；其中，所述数据流模型用于将所述实时数据流中的数据写入至预设的消息队列，并对所述消息队列中的数据进行解析处理；所述消息队列的数量为一个或多个；
156.基于所述运行数据获取预设参数的参数值，并基于所述预设参数的参数值确定所述待测消防车的作战时间段；
157.获得所述运行数据中所述作战时间段对应的数据，作为所述待测消防车的作战数据，并基于所述作战数据生成所述待测消防车的作战报告。
158.此外，上述的存储器903中的逻辑指令可以通过软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本
发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：u盘、移动硬盘、只读存储器(rom，read-only memory)、随机存取存储器(ram，random access memory)、磁碟或者光盘等各种可以存储程序代码的介质。
159.另一方面，本发明还提供一种计算机程序产品，所述计算机程序产品包括存储在非暂态计算机可读存储介质上的计算机程序，所述计算机程序包括程序指令，当所述程序指令被计算机执行时，计算机能够执行上述各方法所提供的消防车作战报告生成方法，该方法包括：基于预设的数据流模型接收以及解析待测消防车传输的实时数据流，并将所述实时数据流的解析结果存储为所述待测消防车的运行数据；其中，所述数据流模型用于将所述实时数据流中的数据写入至预设的消息队列，并对所述消息队列中的数据进行解析处理；所述消息队列的数量为一个或多个；
160.基于所述运行数据获取预设参数的参数值，并基于所述预设参数的参数值确定所述待测消防车的作战时间段；
161.获得所述运行数据中所述作战时间段对应的数据，作为所述待测消防车的作战数据，并基于所述作战数据生成所述待测消防车的作战报告。
162.又一方面，本发明还提供一种非暂态计算机可读存储介质，其上存储有计算机程序，该计算机程序被处理器执行时实现以执行上述各提供的消防车作战报告生成方法，该方法包括：基于预设的数据流模型接收以及解析待测消防车传输的实时数据流，并将所述实时数据流的解析结果存储为所述待测消防车的运行数据；其中，所述数据流模型用于将所述实时数据流中的数据写入至预设的消息队列，并对所述消息队列中的数据进行解析处理；所述消息队列的数量为一个或多个；
163.基于所述运行数据获取预设参数的参数值，并基于所述预设参数的参数值确定所述待测消防车的作战时间段；
164.获得所述运行数据中所述作战时间段对应的数据，作为所述待测消防车的作战数据，并基于所述作战数据生成所述待测消防车的作战报告。
165.以上所描述的装置实施例仅仅是示意性的，其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下，即可以理解并实施。
166.通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到各实施方式可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件。基于这样的理解，上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品可以存储在计算机可读存储介质中，如rom/ram、磁碟、光盘等，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行各个实施例或者实施例的某些部分所述的方法。
167.最后应说明的是：以上实施例仅用以说明本发明的技术方案，而非对其限制；尽管
参照前述实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。

技术特征：
1.一种消防车作战报告生成方法，其特征在于，包括：基于预设的数据流模型接收以及解析待测消防车传输的实时数据流，并将所述实时数据流的解析结果存储为所述待测消防车的运行数据；其中，所述数据流模型用于将所述实时数据流中的数据写入至预设的消息队列，并对所述消息队列中的数据进行解析处理；所述消息队列的数量为一个或多个；基于所述运行数据获取预设参数的参数值，并基于所述预设参数的参数值确定所述待测消防车的作战时间段；获得所述运行数据中所述作战时间段对应的数据，作为所述待测消防车的作战数据，并基于所述作战数据生成所述待测消防车的作战报告。2.根据权利要求1所述的消防车作战报告生成方法，其特征在于，所述数据流模型包括数据传输模型和数据解析模型；所述数据解析模型包括一个或多个数据解析子模型，所述数据解析子模型与所述消息队列一一对应；所述数据解析子模型用于发送数据需求信息至所述数据传输模型，还用于对相应的所述消息队列中的数据进行解析处理；所述数据传输模型用于将所述实时数据流中的数据转换为消息，并写入相应的所述消息队列，基于各所述数据解析子模型发送的数据需求信息，将各所述消息队列中的消息传输至相应的所述数据解析子模型。3.根据权利要求2所述的消防车作战报告生成方法，其特征在于，所述数据传输模型包括依次连接的消息生成单元、数据中转单元和数据输出单元，所述数据输出单元包括一个或多个数据输出子单元，所述数据输出子单元与所述数据解析子模型一一对应连接；所述消息生成单元用于确定所述实时数据流中的目标数据的数据类别，以及根据所述目标数据的数据类别将所述目标数据转换为消息后传输至所述数据中转单元；所述数据中转单元用于基于各所述数据解析子模型发送的数据需求信息，将接收到的消息写入相应的所述消息队列，以及将各所述消息队列中的消息投递至相应的所述数据输出子单元；所述数据输出子单元用于将接收到的消息转发至相应的所述数据解析子模型。4.根据权利要求3所述的消防车作战报告生成方法，其特征在于，所述数据中转单元包括数据通信单元和数据转发单元；所述数据通信单元用于基于各所述数据解析子模型发送的数据需求信息，为每一个所述消息队列分配第一数据传输线程，并通过所述第一数据传输线程将接收到的消息写入相应的所述消息队列；所述数据转发单元用于基于各所述数据解析子模型发送的数据需求信息，为每一个所述消息队列分配第二数据传输线程，并通过所述第二数据传输线程将各所述消息队列中的消息投递至相应的所述数据输出子单元。5.根据权利要求4所述的消防车作战报告生成方法，其特征在于，所述数据通信单元用于基于各所述数据解析子模型发送的数据需求信息，采用负载均衡的方法为每一个所述消息队列分配所述第一数据传输线程；和/或，所述数据转发单元用于基于各所述数据解析子模型发送的数据需求信息，采用负载均
衡的方法为每一个所述消息队列分配所述第二数据传输线程。6.根据权利要求3所述的消防车作战报告生成方法，其特征在于，所述数据传输模型还包括数据预处理单元；所述数据预处理单元用于对所述实时数据流中的数据进行数据预处理后传输至所述消息生成单元。7.根据权利要求1至6任一项所述的消防车作战报告生成方法，其特征在于，所述作战报告包括所述待测消防车的预设工作装置的姿态分布数据；所述基于所述作战数据生成所述待测消防车的作战报告，包括：基于所述作战数据中所述预设工作装置对应的第一传感数据，获得所述预设工作装置的工作数据；对所述工作数据进行分组处理，得到数据队列，并将所述数据队列输入至预设姿态分类模型，得到所述预设工作装置的姿态分类结果；基于所述姿态分类结果，确定所述预设工作装置的姿态分布数据。8.根据权利要求7所述的消防车作战报告生成方法，其特征在于，所述基于所述姿态分类结果，确定所述预设工作装置的姿态分布数据，包括：获取所述姿态分类结果中的每一类姿态对应的所述工作数据的数量；基于每一类姿态对应的所述工作数据的数量，确定所述预设工作装置的姿态分布数据。9.根据权利要求1至6任一项所述的消防车作战报告生成方法，其特征在于，所述作战报告包括所述待测消防车的水路系统的工况分布数据；所述基于所述作战数据生成所述待测消防车的作战报告，包括：获取所述作战数据中所述水路系统的供水状态对应的第二传感数据，并基于所述第二传感数据，生成所述水路系统的工况分布数据；和/或，所述作战报告包括所述待测消防车的设备状态数据；所述基于所述作战数据生成所述待测消防车的作战报告，包括：获取所述作战数据中一个或多个预设工作参数对应的第三传感数据，并基于所述第三传感数据，确定所述待测消防车的设备状态数据。10.一种消防车作战报告生成装置，其特征在于，包括：第一处理模块，用于基于预设的数据流模型接收以及解析待测消防车传输的实时数据流，并将所述实时数据流的解析结果存储为所述待测消防车的运行数据；其中，所述数据流模型用于将所述实时数据流中的数据写入至预设的消息队列，并对所述消息队列中的数据进行解析处理；所述消息队列的数量为一个或多个；第二处理模块，用于基于所述运行数据获取预设参数的参数值，并基于所述预设参数的参数值确定所述待测消防车的作战时间段；第三处理模块，用于获得所述运行数据中所述作战时间段对应的数据，作为所述待测消防车的作战数据，并基于所述作战数据生成所述待测消防车的作战报告。

技术总结
本发明涉及数据处理领域，提供一种消防车作战报告生成方法及装置，该方法包括：基于预设的数据流模型接收以及解析待测消防车传输的实时数据流，并将实时数据流的解析结果存储为待测消防车的运行数据；其中，数据流模型用于将实时数据流中的数据写入至预设的消息队列，并对消息队列中的数据进行解析处理；基于运行数据获取预设参数的参数值，并基于预设参数的参数值确定待测消防车的作战时间段；获得运行数据中作战时间段对应的作战数据，并基于作战数据生成待测消防车的作战报告。本发明获得的作战数据的数据类型多、数据量大，较为全面，从而保证了生成的作战报告的有效性，进而根据生成的作战报告能够对消防车的作战性能进行有效改进。进行有效改进。进行有效改进。


技术研发人员：游书豪 饶源 夏家林
受保护的技术使用者：三一汽车制造有限公司
技术研发日：2023.07.26
技术公布日：2023/10/6