本发明实施例涉及计算机技术领域，尤其涉及一种预警管理方法和装置。
背景技术：
在工地出现劳务工人长时间疲劳工作和违规事件后，工地的上级组织可能无法获知工地上发生的违规事件，从而造成由于监管不力导致事态严重的后果。
现有技术中未出现针对工地场景创建的跨系统需求下的综合预报警，因此，如何对多个工地中发生的预警事件进行综合预警统一管理是当前亟待解决的技术问题。
技术实现要素：
本发明实施例提供了一种预警管理方法和装置，能够实时监控下层系统中出现的预警事件，使得集团管理层对下属系统进行统一的预警管理。
第一方面，本发明实施例提供了一种预警管理方法，包括：
接收大数据平台发送的预警规则列表；
若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件；
根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。
第二方面，本发明实施例还提供了一种预警管理方法，包括：
获取预警信息，所述预警信息包括预警事件和预警等级；
将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息；
获取所述预警信息的未被处理时长；
根据所述预警等级和所述未处理时长确定事态等级。
第三方面，本发明实施例还提供了一种预警管理装置，包括：
接收模块，用于接收大数据平台发送的预警规则列表；
确定模块，用于若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件；
管理模块，用于根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。
第四方面，本发明实施例还提供了一种预警管理装置，包括：
第一获取模块，用于获取预警信息，所述预警信息包括预警事件和预警等级；
记录模块，用于将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息；
第二获取模块，用于获取所述预警信息的未被处理时长；
确定模块，用于根据所述预警等级和所述未处理时长确定事态等级。
本发明实施例提供了一种预警管理方法和装置，首先接收大数据平台发送的预警规则列表，然后若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件，最后根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。利用上述技术方案，能够实时监控下层系统中出现的预警事件，使得集团管理层对下属系统进行统一的预警管理。
附图说明
图1为本发明实施例一所提供的一种预警管理方法的流程示意图；
图2为本发明实施例二所提供的一种预警管理方法的流程示意图；
图3为本发明实施例三所提供的一种预警管理方法中的组织架构关联示例流程图；
图4为本发明实施例三所提供的一种预警管理方法中的预警规则下发示例流程图；
图5为本发明实施例三所提供的一种预警管理方法中的预警管理示例流程图；
图6为本发明实施例四所提供的一种预警管理装置的结构示意图；
图7为本发明实施例五所提供的一种预警管理装置的结构示意图；
图8为本发明实施例六所提供的一种区域数据平台服务器的结构示意图；
图9为本发明实施例七所提供的一种大数据平台服务器的结构示意图。
具体实施方式
下面将参照附图更详细地描述本发明的实施例。虽然附图中显示了本发明的某些实施例，然而应当理解的是，本发明可以通过各种形式来实现，而且不应该被解释为限于这里阐述的实施例，相反提供这些实施例是为了更加透彻和完整地理解本发明。应当理解的是，本发明的附图及实施例仅用于示例性作用，并非用于限制本发明的保护范围。
应当理解，本发明的方法实施方式中记载的各个步骤可以按照不同的顺序执行，和/或并行执行。此外，方法实施方式可以包括附加的步骤和/或省略执行示出的步骤。本发明的范围在此方面不受限制。
本文使用的术语“包括”及其变形是开放性包括，即“包括但不限于”。术语“基于”是“至少部分地基于”。术语“一个实施例”表示“至少一个实施例”；术语“另一实施例”表示“至少一个另外的实施例”；术语“一些实施例”表示“至少一些实施例”。其他术语的相关定义将在下文描述中给出。
需要注意，本发明中提及的“第一”、“第二”等概念仅用于对不同的装置、模块或单元进行区分，并非用于限定这些装置、模块或单元所执行的功能的顺序或者相互依存关系。
需要注意，本发明中提及的“一个”、“多个”的修饰是示意性而非限制性的，本领域技术人员应当理解，除非在上下文另有明确指出，否则应该理解为“一个或多个”。
本发明实施方式中的多个装置之间所交互的消息或者信息的名称仅用于说明性的目的，而并不是用于对这些消息或信息的范围进行限制。
实施例一
图1为本发明实施例一所提供的一种预警管理方法的流程示意图，该方法可适用于集团管理层对下属区域进行预警管理的情况，该方法可以由预警管理装置来执行，其中该装置可由软件和/或硬件实现，并一般集成在区域数据平台服务器上，在本实施例中区域数据平台服务器可以为区域数据平台中的一个或多个服务器。
如图1所示，本发明实施例一提供的一种预警管理方法，包括如下步骤：
s110、接收大数据平台发送的预警规则列表。
其中，大数据平台可以理解为对应集团管理层的数据平台，区域数据平台可以为下属区域的数据平台。示例性的，每个区域工地都有对应一个区域数据平台，区域工地的管理层对应的是大数据平台，通过大数据平台和各个区域平台的数据交互，集团管理层可以跨平台的对各个区域工地进行预警管理。
其中，预警规则列表可以为在大数据平台的预警规则库中选取至少一条预警规则组成的列表。
其中，预警规则库是根据调研结果、每条预报警触发算法规则、初始化每条规则所属等级、使用层级、预警类型、名称以及规则算法等数据生成的。所有组织架构共享预警规则库，大数据平台的组织架构可以从预警规则库选取预警规则添加到自身组织架构的预警规则列表中，区域数据平台的组织架构获取预警规则的方式可以为由集团级别账号从大数据平台的预警规则库中选取预警规则形成预警规则列表后下发至区域数据平台。需要说明的是，初始加入预警规则列表中的预警规则对应的预警触发阈值为空。
可以理解的是，用户可以在预警规则库的列表页面执行下列操作：
1、编辑：集团账号可以对列表页中规则的名称、研判通知以及预警等级等字段进行编辑，规则的文案、阈值或条件不能编辑。
2、添加/移除：将列表页中的规则添加到预警规则列表中或是从预警规则列表中将规则删除。
3、下发：集团账号可以登录大数据平台将预警规则库中的某一条预警规则批量下发至区域数据平台的本地规则列表中，下发成功后，每条预警规则的阈值和条件为空，是否启用状态默认为禁用，未设置阈值之前预警规则无法启用。
进一步的，在所述接收大数据平台发送的预警规则列表之后，还包括：判断所述预警规则列表与所述区域数据平台是否匹配；若否，则对所述预警规则列表不做处理。
在本实施例中，区域数据平台还需要判断接收到的预警规则列表是否属于本区域组织架构对应的规则列表。需要说明的是，大数据平台的预警规则库中的预警规则是根据不同区域的组织架构进行设置的，区域数据平台只需要获取本平台的组织架构对应的预警规则列表即可。
在本实施例中，若所述预警规则列表属于本区域组织架构对应的规则列表，则可以将区域数据平台内的本地规则列表根据预警规则列表进行更新。
进一步的，在所述接收大数据平台发送的预警规则列表之前，还包括：获取所述大数据平台对应的第一组织架构和所述区域数据平台对应的第二组织架构；所述第一组织结构和所述第二组织架构均包含多个节点；遍历所述第一组织结构和所述第二组织架构中的各节点，将处于同一等级的第一组织架构的节点和第二组织架构的节点建立关联。
在本实施例中，第一组织架构可以理解为大数据平台中的组织架构，第二组织架构可以理解为区域数据平台中的组织架构。每个组织架构可以包括多个节点，每个节点代表一个层级，示例性的，一级节点可以代表员工层级，二级节点可以代表组长层级，三级节点可以代表经理层级。
具体的，区域数据平台可以从大数据平台拉取第一组织架构和第二组织架构，遍历第一组织架构和第二组织架构，将两个组织架构中相同的节点建立关联。示例性的，将第一组织架构中的员工等级节点与第二组织架构中的员工等级节点建立关联。将相同等级的节点建立关联，可以使得不同平台间的相同节点间进行数据传输。
s120、若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件。
在本实施例中，区域数据平台可以对该区域发生的事件进行监侧，若监测到发生的事件未满足预警规则，则可以确定发生预警事件。预警事件可以理解为违反预警规则的事件。
可选的，在确定预警事件后，还可以确定所述预警事件触发的预警规则属于本区域组织架构中哪个节点。不同节点的预警规则的触发阈值不同，示例性的，预警事件为某工人一天连续10小时工作，组长层级节点对应的触发阈值可以为大于9小时，员工层级节点对应的触发阈值可以为大于8小时，即若某个工人一天连续工作时间超过8小时，则可以确定所述预警事件触发了组长层级节点和员工层级节点对应的预警规则中的触发阈值。
s130、根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。
在本实施例中，确定预警事件后，可以组装预警触发基础数据并将该预警事件标记为未记录预警事件。预警信息可以为表征预警事件产生的信息，预警信息可以包括预警事件。
其中，大数据平台对预警信息进行管理的内容此处不做具体说明，在实施例二中进行说明。
本发明实施例一提供的一种预警管理方法，首先接收大数据平台发送的预警规则列表；然后若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件；最终根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。利用上述方法，能够实时监控下层系统中出现的预警事件，使得集团管理层对下属区域进行统一的预警管理。
实施例二
图2为本发明实施例二所提供的一种预警管理方法的流程示意图，该方法可适用于集团管理层对下属区域进行预警管理的情况，该方法可以由预警管理装置来执行，其中该装置可由软件和/或硬件实现，并一般集成在大数据平台服务器上，在本实施例中大数据平台服务器可以为大数据平台中的一个或多个服务器。
如图2所示，本发明实施例二提供的一种预警管理方法，包括如下步骤：
s210、获取预警信息，所述预警信息包括预警事件和预警等级。
在本实施例中，预警信息可以为表征预警事件发生的信息，根据预警信息可以获取预警事件以及该预警事件对应的预警等级。
其中，预警等级可以理解为预警事件对应的预警等级，每个预警规则对应的预警等级是预先设置的，根据预警事件触发的预警规则可以确定该预警事件对应的预警等级。预警等级可以包括一级预警、二级预警、三级预警以及四级预警，其中，一级预警可以表征该预警事件为特别严重事件，二级预警可以表征该预警事件为严重事件，三级预警可以表征该预警事件为较严重事件，四级预警可以表征该预警事件为一般事件。
进一步的，所述获取预警信息，包括：接收区域数据平台发送的预警信息；或者，基于所述目标预警规则列表对区域数据平台中的事件进行监测，若区域数据平台中的事件未满足所述预警规则列表中的规则，则生成预警信息。
其中，大数据平台获取预警信息的方式可以包括：区域数据平台监测到预警事件产生后，将预警信息发送至大数据平台后大数据平台获取到的；大数据平台的服务器端监测到预警规则被触发后生成的预警信息。
进一步的，在所述获取预警信息之前，还包括：从预警规则库中拉取设定数量的预警规则，形成初始预警规则列表；对所述初始规则列表进行配置，获得目标预警规则列表。
其中，形成初始预警规则列表后可以对初始预警规则列表中的预警规则进行配置，配置可以包括对预警规则进行编辑、设置预警规则的状态以及将预警规则删除等操作。
初始预警规则列表中的预警规则状态默认设置为禁用，且预警规则的触发阈值默认设置为空，必须完成触发阈值的配置才能启用该预警规则。每个组织架构节点的触发阈值可以设置为不同值且仅针对该组织节点生效，即可以理解为组织架构节点与预警规则可以为多对多的关系。
可以理解的是，在预警规则列表页面可以执行以下操作：
1、配置：执行预警规则下发或添加操作的组织架构账号可配置预警规则的触发条件，触发条件或触发阈值都为必填项，配置成功并且启用后预警规则将生效。
2、查看：集团账号下发的预警规则，下属组织架构节点只能查看，不可配置和启用禁用，只有集团账号可以配置和启用禁用；下发或添加预警规则的组织架构节点才可以对该预警规则进行配置，其他组织架构无法对该预警规则进行配置，仅可以对预警规则进行查看。
在得到目标预警规则列表后还可以将目标预警规则列表发送至区域数据平台，以使得区域数据平台与大数据平台的预警规则同步。
在本实施例中，获取预警信息后可以将预警消息推送至kafka预警触发队列并在监听到预警信息后将预警事件记录到事件触发基础表中，再通过消息推送将预警信息推送至kafka预警事件产生队列。
s220、将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息。
在本实施例中，将预警信息进行记录包括从kafka预警事件产生队列监听到预警信息后将预警事件记录到预警事件列表中。
可以理解为每个组织架构节点的预警规则列表中有预警规则触发时，生成一个预警事件，并按照配置好的推送机制以消息的形式推送至对应的预警消息列表中。
进一步的，将预警信息进行记录后可以在大数据平台的显示页面显示预警事件列表，预警事件列表中可以包括预警事件的处理状态，大数据平台集团管理层组织架构人员在大数据平台系统可以查看到该预警事件，若将预警事件进行处理后可以将处理状态修改为已处理。大数据平台获取到修改状态指令后，可以知晓该预警事件已处理。
需要具体说明的是，在预警事件列表页面可以执行以下操作：
1、处理：处理状态为未处理的事件，可以输入处理描述、上传处理文件以及处理照片，提交成功后处理状态变为已处理。属于某个节点的预警事件产生后，只能由该节点对该预警事件的状态进行处理，其他节点只能查看。
1.1保存：处理描述、处理文件、处理照片为非必填项，点击“保存”按钮后可以保存处理描述、处理文件以及处理照片，不改变预警事件的处理状态。
1.2提交：提交初次处理或修改提交保存后的处理信息，并将预警事件的处理状态修改为已处理。
2、查看：当前组织架构的上级节点可以查看处理状态为已处理的预警事件，以及当前组织架构的下级节点包括的预警事件的详情。
s230、获取所述预警信息的未被处理时长。
在本实施例中，预警信息的未被处理时长可以根据预警事件的处理状态确定，将记录预警事件的时间作为开始时间，将该事件的状态修改为处理后的时间作为结束时间，开始时间与结束时间之间的时长即为该预警事件的未处理时长。
s240、根据所述预警等级和所述未处理时长确定事态等级。
在本实施例中，每个预警等级下都包括四个不同的事态等级，事态等级包括最严重等级、严重等级、较严重等级以及一般等级。在事态等级列表页可以配置事态等级规则，将最严重等级显示为红色、将严重等级显示为橙色、将较严重等级显示为黄色，将一般等级显示为蓝色。
需要说明的是，同一预警等级的四个事态的升级时长都是以预警时间为基准计算的，示例性的，获取预警事件对应的预警等级后开始计时，可以将事态等级从蓝色升级为黄色的第一升级时长设置为1小时，将事态等级从黄色升级为橙色的第二升级时长设置为2小时，其中，1小时和2小时是从确定预警等级后开始计算的，2小时并不是在升级为黄色事态等级后重新计算的。
进一步的，所述根据所述预警等级和所述未处理时长确定事态等级，包括：获取当前事态等级；根据所述预警等级和所述当前事态等级确定对应的升级时长；若所述未处理时长超过所述升级时长，则将所述当前事态等级进行升级。
其中，每个事态等级都对应一个升级时长，升级时长需要满足：事态等级升级为红色的升级时长大于升级为橙色的升级时长大于升级为黄色的升级时长。
任何预警等级的预警事件触发时，该预警事件的事态等级默认为蓝色，之后根据未处理时长是否超过升级时长确定该预警事件的事态等级是否升级。具体的，事态等级为蓝色时，该预警事件的未处理时长超过第一升级时长后，可以将该预警事件的事态等级升级为黄色；将事态等级升级为黄色后继续获取未处理时长，若为处理时长超过第二升级时长后，可以继续将该预警事件的事态等级升级为橙色，以此类推，直至事态等级升级为红色。
需要说明的是，事态等级列表页面中的所有事态等级升级时间输入框为必填项。可以理解的是，蓝色事态等级对应的升级时间为0，则表示该预警事件触发后对应的事态等级默认为黄色。
进一步的，在所述根据所述预警等级和所述未处理时长确定事态等级之后，还包括：确定所述预警事件在所述区域数据平台的组织架构中所处的节点；将所述事态等级发送至所述节点及所述节点的高级节点。
其中，不同区域数据平台都对应一个组织架构，一个组织架构中可以包括多个节点，在区域数据平台从大数据平台拉取预警规则列表之前需要将大数据平台对应的组织架构中的各节点与区域数据平台对应的组织架构中的各节点建立关联。建立关联后可以通过大数据平台向区域数据平台的各节点下发属于该节点的预警规则，当监测到事件发生后可以确定该事件是否违反该节点所包括的预警规则，若违反则可以将该事件确定为本节点对应的预警事件，并将预警事件对应的事态等级推送至本节点的本节点的上级节点。
可选的，当预警事件的事态等级升级时可以按照对应的推送机制以消息的形式推送至对应的预警消息列表中，每个节点对应的预警事件列表都可以展示该节点以及该节点的下级节点的预警事件。
在推送规则列表页面可以配置推送规则，可以对四种事态推送进行复选配置，所有节点对应的蓝色事态推送，本节点勾选且置灰不可编辑；推送规则配置时，四种事态推送的复选项只展示本级节点和上一节点的名称。
本发明实施例二提供的一种预警管理方法，首先获取预警信息，所述预警信息包括预警事件和预警等级；然后将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息；之后获取所述预警信息的未被处理时长；最后根据所述预警等级和所述未处理时长确定事态等级。利用该方法，能够实时监控下层系统中出现的预警事件，使得集团管理层对下属区域进行统一的预警管理。
实施例三
图3为本发明实施例三所提供的一种预警管理方法中的组织架构关联示例流程图，大数据平台可以与多个区域数据平台进行组织架构关联，图3以大数据平台与a区域数据平台以及b区域数据平台进行组织架构关联为例进行说明。
如图3所示，大数据平台分布与a区域数据平台和b区域数据平台进行组织架构关联的过程相同，下面以a区域数据平台与大数据平台进行组织架构关联为例进行说明。具体的，a区域数据平台将本区域的组织架构进行初始化；从大数据平台查询大数据组织架构列表即获取大数据平台对应的第一组织架构；拉取本地组织架构列表即获取区域数据平台对应的第二组织架构；遍历本地组织架构判断是否为同一组织架构节点，若是，则将本地节点与大数据节点关联，若否，则继续循环下一节点即遍历所述第一组织结构和所述第二组织架构中的各节点，将处于同一等级的第一组织架构的节点和第二组织架构的节点建立关联。
由图3可知，每一条预警规则都需要与一个组织架构中的节点进行关联，同一条预警规则可以与多个节点进行关联且同一条预警规则关联不同节点时设置的触发阈值不同，可以理解预警规则和各节点属于多对多关系。在跨平台情况下，区域数据平台存在独立的组织架构，因此需要大数据平台暴露组织架构同步接口为多平台组织架构节点建立关联。
图4为本发明实施例三所提供的一种预警管理方法中的预警规则下发示例流程图，以大数据平台将预警规则列表下发至a区域数据平台为例进行说明。
预警规则库在大数据平台内，区域数据平台无法配置预警规则，所有预警规则的配置都在大数据平台进行并下发至区域数据平台，区域数据平台可以有多个，每个区域数据平台都有一个组织架构，各区域数据平台只需记录本平台组织架构对应的预警规则即可。
如图4所示，大数据平台可以通过添加或集团下发的方式从预警规则库中选取预警规则添加至规则列表即预警规则列表中，编辑规则列表信息，将规则列表变更消息推送至a区域数据平台中的kafka消息队列，a区域数据平台进行规则下发消息监听，监听到规则列表变更消息后拉取组织架构信息即a区域数据平台的组织架构信息，确定规则列表中的预警规则是否属于本区域组织架构的预警规则，若是，则更新本地规则列表即判断所述预警规则列表与所述区域数据平台是否匹配，若是，则将区域数据平台内的本地规则列表根据预警规则列表进行更新。
图5为本发明实施例三所提供的一种预警管理方法中的预警管理示例流程图。预警事件的产生存在多端触发情况，包括区域数据平台触发以及大数据平台服务器端触发，区域数据平台服务器通常处理本区域平台实时监测到的预警事件，大数据平台服务器端通常用于触发统计类的预警事件。无论是哪个平台的服务器端触发的预警事件，都需要同一记录在大数据平台并进行预警事件的记录、处理以及消息推送等，区域数据平台无法对预警事件进行处理也无需对预警事件进行记录。
如图5所示，大数据平台从a区域数据平台获取预警信息的过程为a区域数据平台监测到预警产生后通过规则查询可以确定预警对应的组织架构规则，判断是否启用且达到触发阈值即预警规则是否启用并确定预警事件是否达到触发阈值，若是，则组装预警触发基础数据并将预警事件标记为未记录，将预警消息进行消息推送至大数据平台的kafka预警触发队列并进行消息监听，当监听到预警触发消息即预警信息后将预警事件记录到事件触发基础表，通过消息推送将预警信息推送到kafka预警事件产生队列。
大数据平台从大数据服务器端获取预警信息的过程为大数据服务器端监测到触发预警规则的预警事件后，组装预警触发基础数据并将预警事件标记为未记录，存入hive事件触发基础表，通过sqoop导出预警事件数据至mysql，通过消息推送将预警信息推送至kafka预警事件产生队列。
大数据平台进行预警产生消息监听，拉取为记录的预警事件至未记录事件列表并记录预警事件，将预警事件消息推送，开启处理超时事态升级任务，超时触发后可以将事态等级升级即若所述未处理时长超过所述升级时长，则将所述当前事态等级进行升级，判断预警事件的事态等级是否是最高级，若是，则结束升级，若否，则将事态等级继续升到下一级。
实施例四
图6为本发明实施例四所提供的一种预警管理装置的结构示意图，该装置可适用于集团管理层对下属区域进行预警管理的情况，其中该装置可由软件和/或硬件实现，并一般集成在区域数据平台的服务器上。
如图6所示，该装置包括：接收模块610、确定模块620以及管理模块630。
接收模块610，用于接收大数据平台发送的预警规则列表；
确定模块620，用于若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件；
管理模块630，用于根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。
在本实施例中，该装置首先通过接收模块610接收大数据平台发送的预警规则列表；然后通过确定模块620用于若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件；最后通过管理模块630根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。
本实施例提供了一种预警管理装置，能够实时监控下层系统中出现的预警事件，使得集团管理层对下属区域进行统一的预警管理。
进一步的，在所述接收大数据平台发送的预警规则列表之后，还包括：判断所述预警规则列表与所述区域数据平台是否匹配；若否，则对所述预警规则列表不做处理。
进一步的，在所述接收大数据平台发送的预警规则列表之前，还包括：获取所述大数据平台对应的第一组织架构和所述区域数据平台对应的第二组织架构；所述第一组织结构和所述第二组织架构均包含多个节点；遍历所述第一组织结构和所述第二组织架构中的各节点，将处于同一等级的第一组织架构的节点和第二组织架构的节点建立关联。
上述预警管理装置可执行本发明实施例一所提供的预警管理方法，具备执行方法相应的功能模块和有益效果。
实施例五
图7为本发明实施例五所提供的一种预警管理装置的结构示意图，该装置可适用于集团管理层对下属区域进行预警管理的情况，其中该装置可由软件和/或硬件实现，并一般集成在大数据平台的服务器上。
如图7所示，该装置包括：第一获取模块710、记录模块720、第二获取模块730以及确定模块740。
第一获取模块710，用于获取预警信息，所述预警信息包括预警事件和预警等级；
记录模块720，用于将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息；
第二获取模块730，用于获取所述预警信息的未被处理时长；
确定模块740，用于根据所述预警等级和所述未处理时长确定事态等级。
在本实施例中，该装置首先通过第一获取模块710获取预警信息，所述预警信息包括预警事件和预警等级；然后通过记录模块720将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息；之后通过第二获取模块730获取所述预警信息的未被处理时长；最后通过确定模块740根据所述预警等级和所述未处理时长确定事态等级。
本实施例提供了一种预警管理装置，能够实时监控下层系统中出现的预警事件，使得集团管理层对下属区域进行统一的预警管理。
基于上述技术方案，在所述获取预警信息之前，还包括：从预警规则库中拉取设定数量的预警规则，形成初始预警规则列表；对所述初始规则列表进行配置，获得目标预警规则列表。
进一步的，第一获取模块710，具体用于接收区域数据平台发送的预警信息；或者，基于所述目标预警规则列表对区域数据平台中的事件进行监测，若区域数据平台中的事件未满足所述预警规则列表中的规则，则生成预警信息。
进一步的，确定模块740具体用于获取当前事态等级；根据所述预警等级和所述当前事态等级确定对应的升级时长；若所述未处理时长超过所述升级时长，则将所述当前事态等级进行升级。
进一步的，在根据预警等级和未处理时长确定事态等级之后，还包括：确定预警事件在所述区域数据平台的组织架构中所处的节点；将事态等级发送至所述节点及节点的高级节点。
上述预警管理装置可执行本发明实施例二所提供的预警管理方法，具备执行方法相应的功能模块和有益效果。
实施例六
图8为本发明实施例六所提供的一种区域数据平台服务器的结构示意图。如图8所示，本发明实施例六提供的区域数据平台服务器包括：一个或多个处理器81和存储装置82；该区域数据平台服务器中的处理器81可以是一个或多个，图8中以一个处理器81为例；存储装置82用于存储一个或多个程序；所述一个或多个程序被所述一个或多个处理器81执行，使得所述一个或多个处理器81实现如本发明实施例一中任一项所述的预警管理方法。
所述区域数据平台服务器还可以包括：输入装置83和输出装置84。
区域数据平台服务器中的处理器81、存储装置82、输入装置83和输出装置84可以通过总线或其他方式连接，图8中以通过总线连接为例。
该区域数据平台服务器中的存储装置82作为一种计算机可读存储介质，可用于存储一个或多个程序，所述程序可以是软件程序、计算机可执行程序以及模块，如本发明实施例一所提供的预警管理方法对应的程序指令/模块(例如，附图6所示的预警管理装置中的模块，包括：接收模块610、确定模块620以及管理模块630)。处理器81通过运行存储在存储装置82中的软件程序、指令以及模块，从而执行区域数据平台服务器的各种功能应用以及数据处理，即实现上述方法实施例中的预警管理方法。
存储装置82可包括存储程序区和存储数据区，其中，存储程序区可存储操作系统、至少一个功能所需的应用程序；存储数据区可存储根据区域数据平台服务器的使用所创建的数据等。此外，存储装置82可以包括高速随机存取存储器，还可以包括非易失性存储器，例如至少一个磁盘存储器件、闪存器件、或其他非易失性固态存储器件。在一些实例中，存储装置82可进一步包括相对于处理器81远程设置的存储器，这些远程存储器可以通过网络连接至设备。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。
输入装置83可用于接收输入的数字或字符信息，以及产生与区域数据平台服务器的用户设置以及功能控制有关的键信号输入。输出装置84可包括显示屏等显示设备。
并且，当上述区域数据平台服务器所包括一个或者多个程序被所述一个或者多个处理器81执行时，程序进行如下操作：
接收大数据平台发送的预警规则列表；
若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件；
根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。
实施例七
图9为本发明实施例七所提供的一种大数据平台服务器的结构示意图。如图9所示，本发明实施例七提供的大数据平台服务器包括：一个或多个处理器91和存储装置92；该大数据平台服务器中的处理器91可以是一个或多个，图9中以一个处理器91为例；存储装置92用于存储一个或多个程序；所述一个或多个程序被所述一个或多个处理器91执行，使得所述一个或多个处理器91实现如本发明实施例二中任一项所述的预警管理方法。
所述大数据平台服务器还可以包括：输入装置93和输出装置94。
大数据平台服务器中的处理器91、存储装置92、输入装置93和输出装置94可以通过总线或其他方式连接，图9中以通过总线连接为例。
该大数据平台服务器中的存储装置92作为一种计算机可读存储介质，可用于存储一个或多个程序，所述程序可以是软件程序、计算机可执行程序以及模块，如本发明实施例二所提供的预警管理方法对应的程序指令/模块(例如，附图7所示的预警管理装置中的模块，包括：第一获取模块710、记录模块720、第二获取模块730以及确定模块740)。处理器81通过运行存储在存储装置82中的软件程序、指令以及模块，从而执行区域数据平台服务器的各种功能应用以及数据处理，即实现上述方法实施例二中的预警管理方法。
存储装置92可包括存储程序区和存储数据区，其中，存储程序区可存储操作系统、至少一个功能所需的应用程序；存储数据区可存储根据区域数据平台服务器的使用所创建的数据等。此外，存储装置92可以包括高速随机存取存储器，还可以包括非易失性存储器，例如至少一个磁盘存储器件、闪存器件、或其他非易失性固态存储器件。在一些实例中，存储装置92可进一步包括相对于处理器91远程设置的存储器，这些远程存储器可以通过网络连接至设备。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。
输入装置93可用于接收输入的数字或字符信息，以及产生与大数据平台服务器的用户设置以及功能控制有关的键信号输入。输出装置94可包括显示屏等显示设备。
并且，当上述大数据平台服务器所包括一个或者多个程序被所述一个或者多个处理器91执行时，程序进行如下操作：
获取预警信息，所述预警信息包括预警事件和预警等级；
将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息；
获取所述预警信息的未被处理时长；
根据所述预警等级和所述未处理时长确定事态等级。
实施例八
本发明实施例八提供了一种计算机可读存储介质，其上存储有计算机程序，该程序被处理器执行时用于执行预警管理方法。
如应用于区域数据服务器的方法，该方法包括：
接收大数据平台发送的预警规则列表；
若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件；
根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。
如应用于大数据平台服务器的方法，该方法包括：
获取预警信息，所述预警信息包括预警事件和预警等级；
将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息；
获取所述预警信息的未被处理时长；
根据所述预警等级和所述未处理时长确定事态等级。
可选的，该程序被处理器执行时还可以用于执行本发明任意实施例所提供的预警管理方法。
本发明实施例的计算机存储介质，可以采用一个或多个计算机可读的介质的任意组合。计算机可读介质可以是计算机可读信号介质或者计算机可读存储介质。计算机可读存储介质例如可以是，但不限于，电、磁、光、电磁、红外线、或半导体的系统、装置或器件，或者任意以上的组合。计算机可读存储介质的更具体的例子(非穷举的列表)包括：具有一个或多个导线的电连接、便携式计算机磁盘、硬盘、随机存取存储器(randomaccessmemory，ram)、只读存储器(readonlymemory，rom)、可擦式可编程只读存储器(erasableprogrammablereadonlymemory，eprom)、闪存、光纤、便携式cd-rom、光存储器件、磁存储器件、或者上述的任意合适的组合。计算机可读存储介质可以是任何包含或存储程序的有形介质，该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。
计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号，其中承载了计算机可读的程序代码。这种传播的数据信号可以采用多种形式，包括但不限于：电磁信号、光信号或上述的任意合适的组合。计算机可读的信号介质还可以是计算机可读存储介质以外的任何计算机可读介质，该计算机可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。
计算机可读介质上包含的程序代码可以用任何适当的介质传输，包括但不限于：无线、电线、光缆、无线电频率(radiofrequency，rf)等等，或者上述的任意合适的组合。
可以以一种或多种程序设计语言或其组合来编写用于执行本发明操作的计算机程序代码，所述程序设计语言包括面向对象的程序设计语言，诸如java、smalltalk、c ，还包括常规的过程式程序设计语言，诸如“c”语言或类似的程序设计语言。程序代码可以完全地在用户计算机上执行、部分地在用户计算机上执行、作为一个独立的软件包执行、部分在用户计算机上部分在远程计算机上执行、或者完全在远程计算机或服务器上执行。在涉及远程计算机的情形中，远程计算机可以通过任意种类的网络，包括局域网(lan)或广域网(wan)，连接到用户计算机，或者，可以连接到外部计算机(例如利用因特网服务提供商来通过因特网连接)。
注意，上述仅为本发明的较佳实施例及所运用技术原理。本领域技术人员会理解，本发明不限于这里所述的特定实施例，对本领域技术人员来说能够进行各种明显的变化、重新调整和替代而不会脱离本发明的保护范围。因此，虽然通过以上实施例对本发明进行了较为详细的说明，但是本发明不仅仅限于以上实施例，在不脱离本发明构思的情况下，还可以包括更多其他等效实施例，而本发明的范围由所附的权利要求范围决定。
1.一种预警管理方法，其特征在于，包括：
接收大数据平台发送的预警规则列表；
若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件；
根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。
2.根据权利要求1所述的方法，其特征在于，在所述接收大数据平台发送的预警规则列表之后，还包括：
判断所述预警规则列表与所述区域数据平台是否匹配；
若否，则对所述预警规则列表不做处理。
3.根据权利要求1所述的方法，其特征在于，在所述接收大数据平台发送的预警规则列表之前，还包括：
获取所述大数据平台对应的第一组织架构和所述区域数据平台对应的第二组织架构；所述第一组织结构和所述第二组织架构均包含多个节点；
遍历所述第一组织结构和所述第二组织架构中的各节点，将处于同一等级的第一组织架构的节点和第二组织架构的节点建立关联。
4.一种预警管理方法，其特征在于，包括：
获取预警信息，所述预警信息包括预警事件和预警等级；
将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息；
获取所述预警信息的未被处理时长；
根据所述预警等级和所述未处理时长确定事态等级。
5.根据权利要求4所述的方法，其特征在于，在所述获取预警信息之前，还包括：
从预警规则库中拉取设定数量的预警规则，形成初始预警规则列表；
对所述初始规则列表进行配置，获得目标预警规则列表。
6.根据权利要求5所述的方法，其特征在于，所述获取预警信息，包括：
接收区域数据平台发送的预警信息；或者，
基于所述目标预警规则列表对区域数据平台中的事件进行监测，若区域数据平台中的事件未满足所述预警规则列表中的规则，则生成预警信息。
7.根据权利要求4所述的方法，其特征在于，所述根据所述预警等级和所述未处理时长确定事态等级，包括：
获取当前事态等级；
根据所述预警等级和所述当前事态等级确定对应的升级时长；
若所述未处理时长超过所述升级时长，则将所述当前事态等级进行升级。
8.根据权利要求4所述的方法，其特征在于，在所述根据所述预警等级和所述未处理时长确定事态等级之后，还包括：
确定所述预警事件在所述区域数据平台的组织架构中所处的节点；
将所述事态等级发送至所述节点及所述节点的高级节点。
9.一种预警管理装置，其特征在于，包括：
接收模块，用于接收大数据平台发送的预警规则列表；
确定模块，用于若区域数据平台中的事件未满足所述预警规则列表中的预警规则，则将所述事件确定为预警事件；
管理模块，用于根据所述预警事件生成预警信息，并将所述预警信息发送至所述大数据平台，使得所述大数据平台对所述预警信息进行管理。
10.一种预警管理装置，其特征在于，包括：
第一获取模块，用于获取预警信息，所述预警信息包括预警事件和预警等级；
记录模块，用于将所述预警信息进行记录并进行消息推送，以提示用户处理所述预警信息；
第二获取模块，用于获取所述预警信息的未被处理时长；
确定模块，用于根据所述预警等级和所述未处理时长确定事态等级。
技术总结