一种营销事件处理系统、方法、设备及存储介质与流程

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.图1为本发明公开的一种营销事件处理系统结构示意图；
35.图2为本发明公开的一种各事件来源消息投递示意图；
36.图3为本发明公开的一种事件接收器消息校验和保存示意图；
37.图4为本发明公开的一种事件协调器消息分发示意图；
38.图5为本发明公开的多种事件处理器示意图；
39.图6为本发明公开的一种营销事件引擎执行流程图；
40.图7为本发明公开的一种具体的营销事件引擎执行流程图；
41.图8为本发明公开的一种营销事件处理方法流程图；
42.图9为本发明公开的一种电子设备结构图。
具体实施方式
43.下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。
44.当前，一个营销活动下具有多个营销事件，营销事件具有灵活多变的特点。如果现有的营销活动系统新开一个活动模板，都要在代码层面复写大量的代码，如果修改活动模板下的营销事件，也要修改大量代码，也即营销事件的扩展性和复用率较低，不够灵活。为此，本发明提供了一种营销事件处理系统，能够解决新增营销事件时开发复杂度高的问题。
45.本发明实施例还公开了一种营销事件处理系统，参见图1所示，该系统包括：
46.消息中间件11，用于接收各事件来源的营销事件消息。
47.可以理解的是，一个营销活动下具有多个营销事件，基于事件流将营销活动拆分为关联事件，完成营销事件与营销活动的解耦。开发人员在营销活动中，开发营销事件的触发机制，往消息中间件发送营销事件消息。例如，对外服务收集用户注册、用户下单以及用户助力等源事件信息，经过统一的模型包装，判断该源信息所属的事件类型，然后发送至消息中间件。
48.需要指出的是，事件来源不局限与本地系统，外部系统也可以按照消息规范性往消息中间件投递消息。例如，参见图2所示，触发异步发奖动作、触发风控提交动作、触发发送nc(non-client非客户区)消息、下游系统回调结果以及订单系统推送的订单流等事件来源，可以往消息中间件投递消息。
49.事件接收器12，用于接收所述消息中间件传输的所述营销事件消息，并将所述营销事件消息传输至事件协调器。
50.本实施例中，所述事件接收器接收到消息中间件传输的所述营销事件消息，并将所述营销事件消息传输至事件协调器。
51.在一些具体的实施例中，所述事件接收器12，具体可以包括：
52.消息保存单元，用于将接收到的所述消息中间件传输的所述营销事件消息存储至预先构建的消息数据库中。
53.可以理解的是，事件接收器从消息中间件拉取消息，先将所述营销事件消息保存到消息数据库中完成持久化。
54.在一些具体的实施例中，所述事件接收器12，具体可以包括：
55.校验单元，用于校验所述营销事件消息的规范性得到相应的校验结果；
56.传输单元，用于基于所述校验结果将所述营销事件消息传输至事件协调器。
57.可以理解的是，所述事件接收器接收到消息中间件传输的所述营销事件消息，校验所述营销事件消息的规范性，即对营销事件的消息规范化，然后基于所述校验结果将所述营销事件消息传输至事件协调器。
58.在一些具体的实施例中，所述传输单元，具体可以包括：
59.第一处理子单元，用于当所述校验结果表明所述营销事件消息符合预设消息规范时，则将所述营销事件消息传输至所述事件协调器。
60.在一些具体的实施例中，所述传输单元，具体可以包括：
61.第二处理子单元，用于当所述校验结果表明所述营销事件消息不符合预设消息规范，则丢弃所述营销事件消息，并对所述营销事件消息进行相应的标记。
62.可以理解的是，如果所述校验结果表明所述营销事件消息合规，则将所述营销事件消息传输至事件协调器，如果所述校验结果表明所述营销事件消息不合规，则丢弃所述营销事件消息，并对所述营销事件消息进行相应的标记以禁止将所述营销事件消息传输至事件协调器，同时更新所述消息数据库。
63.例如，参见图3所示，事件接收器负责消息规范性的校验，将消息保存至数据库，并可以通过数据监控面板进行数据展示。
64.所述事件协调器13，用于根据所述营销事件消息对应的事件类型将所述营销事件消息分发至与所述营销事件消息对应的事件处理器。
65.本实施例中，所述事件协调器负责根据事件类型将营销事件消息分发给不同的事件处理器。例如，参见图4所示，所述事件协调器根据事件类型异步分发给事件处理器，无需关注处理结果，实现快速分发。
66.所述事件处理器14，用于根据所述营销事件消息的消息内容执行相应的处理操作得到相应的处理结果。
67.本实施例中，事件处理器以所述营销事件消息作为入参，根据所述营销事件消息的消息内容完成指定的业务逻辑。例如，参见图5所示，针对不同的事件来源的营销事件消息，所述事件处理器可以包括但不限于发奖事件处理器、风控事件处理器、nc消息事件处理器、回调事件处理器以及订单流事件处理器等。
68.在一些具体的实施例中，所述事件处理器14，具体可以包括：
69.结果保存单元，用于将所述处理结果保存至所述消息数据库中。
70.可以理解的是，所述事件处理器根据消息内容执行处理逻辑，将处理结果保存至消息数据库供用户侧查询或进一步参与活动，也就是说，事件处理完之后，更新数据库消息的执行结果，便于后续查询问题。
71.在一些具体的实施例中，所述事件处理器14，具体可以包括：
72.监测单元，用于在根据所述营销事件消息的消息内容执行相应的处理操作的过程中，监测是否产生新的营销事件；
73.发送单元，用于在产生所述新的营销事件时，则将所述新的营销事件发送至预设队列中。
74.可以理解的是，若处理过程中产生新事件，则将新事件发送至指定队列中。例如，若处理过程中产生到账通知、发放奖品等衍生事件，则将这些衍生事件发送至消息队列中，重新回到事件接收器与事件协调器之间的链路做通知、发奖等逻辑处理。若处理过程中出现异常错误，则由事件协调器组织重试逻辑。在达到重试上限后将消息保存至死信队列，等待人工介入处理。
75.由上可见，本发明实施例中，支持多元化的营销事件来源，对营销事件进行模板化管理，对营销事件的消息规范化，分担营销活动服务的压力并大幅降低团队协作的沟通成
本，实现新增营销事件只需新增营销事件类型和事件处理器，从而能够解决新增营销事件时开发复杂度高的问题。
76.例如，参见图6所示，营销事件处理系统，也即营销事件引擎包括消息中间件，事件接收器，事件协调器，事件处理器。各事件来源的事件，如助力事件、注册事件以及下单事件经过统一的模型包装，投递至消息中间件，事件接收器从消息中间件中拉取消息，先将所述营销事件消息保存到数据库中完成持久化，然后将所述营销事件消息传输至事件协调器，所述事件协调器负责根据事件类型将营销事件消息分发给不同的事件处理器，如助力事件处理器、注册事件处理器以及订单事件处理器，事件处理器根据所述营销事件消息的消息内容完成指定的业务逻辑，并在事件处理完成后，将处理结果保存至数据库中，若处理过程中产生到账通知、发放奖品等衍生事件，则将这些衍生事件发送至消息中间件中，重新回到事件接收器与事件协调器之间的链路做通知、发奖等逻辑处理。所述营销事件处理系统的具体执行过程，参见图7所示，触发异步发奖动作、触发风控提交动作、触发发送nc消息、下游系统回调结果以及订单系统推送的订单流等事件来源，往消息中间件投递消息，所述事件接收器接收到消息中间件传输的所述营销事件消息，先将所述营销事件消息保存到消息数据库中完成持久化，然后校验所述营销事件消息的规范性，如果所述校验结果表明所述营销事件消息合规，则将所述营销事件消息传输至事件协调器，如果所述校验结果表明所述营销事件消息不合规，则丢弃所述营销事件消息，并对所述营销事件消息进行相应的标记以禁止将所述营销事件消息传输至事件协调器，同时更新所述消息数据库。所述事件协调器负责根据事件类型将营销事件消息分发给不同的事件处理器，如发奖事件处理器、风控事件处理器、nc消息事件处理器、回调事件处理器以及订单流事件处理器等，在事件处理完之后，更新数据库消息的执行结果。
77.相应的，本发明实施例公开了一种营销事件处理方法，应用于前述公开的营销事件处理系统，参见图8所示，该方法包括：
78.步骤s11：通过所述营销事件处理系统中的消息中间件接收各事件来源的营销事件消息。
79.可以理解的是，一个营销活动下具有多个营销事件，基于事件流将营销活动拆分为关联事件，完成营销事件与营销活动的解耦。开发人员在营销活动中，开发营销事件的触发机制，往消息中间件发送营销事件消息。例如，对外服务收集用户注册、用户下单以及用户助力等源事件信息，经过统一的模型包装，判断该源信息所属的事件类型，然后发送至消息中间件，也即通过所述营销事件处理系统中的消息中间件接收各事件来源的营销事件消息。需要指出的是，事件来源不局限与本地系统，外部系统也可以按照消息规范性往消息中间件投递消息。例如，触发异步发奖动作、触发风控提交动作、触发发送nc消息、下游系统回调结果以及订单系统推送的订单流等事件来源，可以往消息中间件投递消息。
80.步骤s12：通过所述营销事件处理系统中的事件接收器接收所述消息中间件传输的所述营销事件消息，并将所述营销事件消息传输至所述营销事件处理系统中的事件协调器。
81.需要指出的是，事件接收器从消息中间件拉取消息，先将所述营销事件消息保存到消息数据库中完成持久化，然后将所述营销事件消息传输至事件协调器。
82.一种具体的实施方式中，通过所述营销事件处理系统中的事件接收器接收所述消
息中间件传输的所述营销事件消息，并校验所述营销事件消息的规范性得到相应的校验结果，并基于所述校验结果将所述营销事件消息传输至事件协调器。可以理解的是，可以理解的是，所述事件接收器接收到消息中间件传输的所述营销事件消息，校验所述营销事件消息的规范性，如果所述校验结果表明所述营销事件消息合规，则将所述营销事件消息传输至事件协调器，如果所述校验结果表明所述营销事件消息不合规，则丢弃所述营销事件消息，并对所述营销事件消息进行相应的标记以禁止将所述营销事件消息传输至事件协调器，同时更新所述消息数据库。
83.步骤s13：通过所述事件协调器根据所述营销事件消息对应的事件类型将所述营销事件消息分发至与所述营销事件消息对应的所述营销事件处理系统中的事件处理器。
84.本实施例中，通过所述事件协调器负责根据事件类型将营销事件消息分发给不同的事件处理器，也即所述事件协调器根据事件类型异步分发给事件处理器，无需关注处理结果，实现快速分发。
85.步骤s14：通过所述事件处理器根据所述营销事件消息的消息内容执行相应的处理操作得到相应的处理结果。
86.本实施例中，通过事件处理器以所述营销事件消息作为入参，根据所述营销事件消息的消息内容完成指定的业务逻辑，在事件处理完之后，将处理结果保存至消息数据库以更新数据库消息的执行结果，便于后续查询问题。
87.可见，本发明实施例中，支持多元化的营销事件来源，对营销事件进行模板化管理，对营销事件的消息规范化，分担营销活动服务的压力并大幅降低团队协作的沟通成本，实现新增营销事件只需新增营销事件类型和事件处理器，从而能够解决新增营销事件时开发复杂度高的问题。
88.进一步的，本发明实施例还提供了一种电子设备。图9是根据一示例性实施例示出的电子设备20结构图，图中的内容不能认为是对本发明的使用范围的任何限制。
89.图9为本发明实施例提供的一种电子设备20的结构示意图。该电子设备20，具体可以包括：至少一个处理器21、至少一个存储器22、电源23、通信接口24、输入输出接口25和通信总线26。其中，所述存储器22用于存储计算机程序，所述计算机程序由所述处理器21加载并执行，以实现前述任一实施例公开的营销事件处理方法中的相关步骤。另外，本实施例中的电子设备20具体可以为电子计算机。
90.本实施例中，电源23用于为电子设备20上的各硬件设备提供工作电压；通信接口24能够为电子设备20创建与外界设备之间的数据传输通道，其所遵循的通信协议是能够适用于本发明技术方案的任意通信协议，在此不对其进行具体限定；输入输出接口25，用于获取外界输入数据或向外界输出数据，其具体的接口类型可以根据具体应用需要进行选取，在此不进行具体限定。
91.另外，存储器22作为资源存储的载体，可以是只读存储器、随机存储器、磁盘或者光盘等，其上所存储的资源可以包括操作系统221、计算机程序222等，存储方式可以是短暂存储或者永久存储。
92.其中，操作系统221用于管理与控制电子设备20上的各硬件设备以及计算机程序222，其可以是windows server、netware、unix、linux等。计算机程序222除了包括能够用于完成前述任一实施例公开的由电子设备20执行的营销事件处理方法的计算机程序之外，还
可以进一步包括能够用于完成其他特定工作的计算机程序。
93.进一步的，本发明实施例还公开了一种计算机可读存储介质，所述计算机可读存储介质中存储有计算机程序，所述计算机程序被处理器加载并执行时，实现前述任一实施例公开的营销事件处理方法步骤。
94.本说明书中各个实施例采用递进的方式描述，每个实施例重点说明的都是与其它实施例的不同之处，各个实施例之间相同或相似部分互相参见即可。对于实施例公开的装置而言，由于其与实施例公开的方法相对应，所以描述的比较简单，相关之处参见方法部分说明即可。
95.最后，还需要说明的是，在本文中，诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来，而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个
……”
限定的要素，并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。
96.以上对本发明所提供的一种营销事件处理系统、方法、设备及存储介质进行了详细介绍，本文中应用了具体个例对本发明的原理及实施方式进行了阐述，以上实施例的说明只是用于帮助理解本发明的方法及其核心思想；同时，对于本领域的一般技术人员，依据本发明的思想，在具体实施方式及应用范围上均会有改变之处，综上所述，本说明书内容不应理解为对本发明的限制。

技术特征：
1.一种营销事件处理系统，其特征在于，包括：消息中间件，用于接收各事件来源的营销事件消息；事件接收器，用于接收所述消息中间件传输的所述营销事件消息，并将所述营销事件消息传输至事件协调器；所述事件协调器，用于根据所述营销事件消息对应的事件类型将所述营销事件消息分发至与所述营销事件消息对应的事件处理器；所述事件处理器，用于根据所述营销事件消息的消息内容执行相应的处理操作得到相应的处理结果。2.根据权利要求1所述的营销事件处理系统，其特征在于，所述事件接收器，还包括：校验单元，用于校验所述营销事件消息的规范性得到相应的校验结果；传输单元，用于基于所述校验结果将所述营销事件消息传输至事件协调器。3.根据权利要求2所述的营销事件处理系统，其特征在于，所述传输单元，包括：第一处理子单元，用于当所述校验结果表明所述营销事件消息符合预设消息规范时，则将所述营销事件消息传输至所述事件协调器。4.根据权利要求2所述的营销事件处理系统，其特征在于，所述传输单元，包括：第二处理子单元，用于当所述校验结果表明所述营销事件消息不符合预设消息规范，则丢弃所述营销事件消息，并对所述营销事件消息进行相应的标记。5.根据权利要求1所述的营销事件处理系统，其特征在于，所述事件接收器，还包括：消息保存单元，用于将接收到的所述消息中间件传输的所述营销事件消息存储至预先构建的消息数据库中。6.根据权利要求5所述的营销事件处理系统，其特征在于，所述事件处理器，还包括：结果保存单元，用于将所述处理结果保存至所述消息数据库中。7.根据权利要求1至6任一项所述的营销事件处理系统，其特征在于，所述事件处理器，还包括：监测单元，用于在根据所述营销事件消息的消息内容执行相应的处理操作的过程中，监测是否产生新的营销事件；发送单元，用于在产生所述新的营销事件时，则将所述新的营销事件发送至预设队列中。8.一种营销事件处理方法，其特征在于，应用于权利要求1至7任一项所述的营销事件处理系统，包括：通过所述营销事件处理系统中的消息中间件接收各事件来源的营销事件消息；通过所述营销事件处理系统中的事件接收器接收所述消息中间件传输的所述营销事件消息，并将所述营销事件消息传输至所述营销事件处理系统中的事件协调器；通过所述事件协调器根据所述营销事件消息对应的事件类型将所述营销事件消息分发至与所述营销事件消息对应的所述营销事件处理系统中的事件处理器；通过所述事件处理器根据所述营销事件消息的消息内容执行相应的处理操作得到相应的处理结果。9.一种电子设备，其特征在于，包括：存储器，用于保存计算机程序；
处理器，用于执行所述计算机程序，以实现如权利要求8所述的营销事件处理方法的步骤。10.一种计算机可读存储介质，其特征在于，用于存储计算机程序；其中，所述计算机程序被处理器执行时实现如权利要求8所述的营销事件处理方法的步骤。

技术总结
本发明公开了一种营销事件处理系统、方法、设备及存储介质，涉及计算机技术领域，包括：消息中间件，用于接收各事件来源的营销事件消息；事件接收器，用于接收消息中间件传输的营销事件消息，并将营销事件消息传输至事件协调器；事件协调器，用于根据营销事件消息对应的事件类型将营销事件消息分发至与营销事件消息对应的事件处理器；事件处理器，用于根据营销事件消息的消息内容执行相应的处理操作得到相应的处理结果。本发明支持多元化的营销事件来源，对营销事件进行模板化管理，对营销事件的消息规范化，分担营销活动服务的压力，实现新增营销事件只需新增营销事件类型和事件处理器，从而能够解决新增营销事件时开发复杂度高的问题。复杂度高的问题。复杂度高的问题。


技术研发人员：韩港庆 蔡俊良
受保护的技术使用者：上海微盟企业发展有限公司
技术研发日：2023.07.25
技术公布日：2023/10/15