一种基于流程引擎的电信订单处理方法及系统与流程

1.本发明属于互联网通讯技术领域，尤其是涉及一种基于流程引擎的电信订单处理方法及系统。


背景技术：

2.对于长流程的商品订单，如号卡订单、白卡订单、合约机订单等，一般采用系统模块之间的人工串联，或者状态机模式来实现从接单、号卡开户、物流配送、用户签收、用户激活的完整流程。此方式依赖人工对业务的熟悉，按照功能菜单顺序逐项进行，或采用功能菜单的牵引方式来串联流程。
3.目前，电信行业内，采用了基于流程引擎(jbpm)的订单流转技术，实现长流程订单在电信内部不同团队、不同岗位间的流转，通过流程引擎的代办任务指引岗位人员进行任务处理。
4.但是，在电信上云(将oracle数据库转为teledb数据库)过程中，流程引擎的代办查询订单量超过了500万，导致代办订单处查询性能极差，无法满足正常的业务使用要求。


技术实现要素：

5.针对上述问题，本发明提出了一种基于流程引擎的电信订单处理方法及系统，提升电信长流程订单的流程驱动能力，使业务处理简单、高效、自动化，在大流量订单的场景下，解决流程引擎处理的性能问题。
6.为实现上述目的，本发明公开了一种基于流程引擎的电信订单处理方法，包括：
7.接收各渠道发送来的订单创建请求及各环节请求，将订单完整信息写入关系数据库，对应各环节请求进行所述订单完整信息的更新，并发起流程开始或流程流转请求；
8.流程引擎基于流程开始或流程流转请求向关系数据库查询流程规则信息，根据所述流程规则信息匹配订单流向；
9.根据订单流向，向所述内存数据库写入当前订单的流转记录信息；
10.当进行代办订单查询时，向所述内存数据库发起查询。
11.作为本发明的进一步改进，接收各渠道发送来的订单的创建请求时，包括：
12.生成订单id，将订单完整信息写入关系数据库模块，并向流程引擎模块发起流程开始请求；
13.接收订单的各环节请求时，包括：
14.对应在所述关系数据库更新订单状态、物流状态、物流信息，并向流程引擎模块发起流程流转请求。
15.作为本发明的进一步改进，订单的各环节请求包括：
16.订单支付请求、订单开户请求、订单打包请求，订单发货请求、订单签收请求和号卡激活请求。
17.作为本发明的进一步改进，对应在所述关系数据库更新订单状态、物流状态、物流
信息，包括：
18.接受到订单支付请求、订单开户请求、订单打包请求及号卡激活请求时，更新订单状态；
19.接受到订单发货请求时，更新订单物流信息；
20.接受到订单签收请求时，更新订单物流状态和物流信息。
21.作为本发明的进一步改进，所述内存数据库对到达最后环节的所述流转记录信息，生成该订单的历史流转记录信息，并迁移至所述关系数据库。
22.本发明还提供了一种基于流程引擎的电信订单处理系统，包括：订单流转模块、流程引擎模块、内存数据库模块和关系数据库模块；
23.所述订单流转模块，用于：
24.接收各渠道发送来的订单创建请求及各环节请求，将订单完整信息写入关系数据库模块，对应各环节请求进行所述订单完整信息的更新，并发起流程开始请求或流程流转请求；
25.所述流程引擎模块，用于：
26.根据所述流程开始请求或流程流转请求向所述关系数据库模块查询流程规则信息，根据所述流程规则信息匹配订单流向；
27.根据订单流向，向所述内存数据库模块写入当前订单的流转记录信息；
28.所述内存数据库模块，用于：
29.记录各订单的流转记录信息；
30.所述关系数据库模块，用于：
31.存储供所述流程引擎模块查询的所述流程规则信息；
32.保存并更新订单完整信息；
33.保存订单的历史流转记录信息。
34.作为本发明的进一步改进，接收各渠道发送来的订单的创建请求时，包括：
35.生成订单id，将订单完整信息写入关系数据库模块，并向流程引擎模块发起流程开始请求；
36.接收订单的各环节请求时，包括：
37.对应在所述关系数据库更新订单状态、物流状态、物流信息，并向流程引擎模块发起流程流转请求。
38.作为本发明的进一步改进，订单的各环节请求包括：
39.订单支付请求、订单开户请求、订单打包请求，订单发货请求、订单签收请求和号卡激活请求。
40.作为本发明的进一步改进，对应在所述关系数据库更新订单状态、物流状态、物流信息，包括：
41.接受到订单支付请求、订单开户请求、订单打包请求及号卡激活请求时，更新订单状态；
42.接受到订单发货请求时，更新订单物流信息；
43.接受到订单签收请求时，更新订单物流状态和物流信息。
44.作为本发明的进一步改进，所述内存数据库对到达最后环节的所述流转记录信
息，生成该订单的历史流转记录信息，并迁移至所述关系数据库。
45.与现有技术相比，本发明的有益效果为：
46.现有订单处理系统中，订单引擎模块将待处理数据存储在mysql数据库中，在订单量超过500w时写入和读取的性能严重下降，本发明相较于现有订单处理原系统，采用内存数据库替代mysql存储流程记录信息，可支持1000w级别订单时引擎处理的高性能支持，写性能是现有订单处理系统的3倍，读性能是现有订单处理系统的6倍；本发明通过流程引擎管理订单的整个流程，提升了电信长流程订单的流程驱动能力，使业务处理简单、高效、自动化；在大流量订单的场景下，解决流程引擎处理的性能问题。
47.本发明通过基于流程引擎的电信订单处理系统建设，在现有主机资源未增加的条件下，tps(事务处理系统)处理性能提升2倍，满足了用户对系统性能指标要求，并且系统更加稳定和高可用，具备分布式扩展能力。
附图说明
48.图1为本发明一种实施例公开的基于流程引擎的电信订单处理方法流程图；
49.图2为本发明一种实施例公开的基于流程引擎的电信订单处理系统各模块及模块间关系示意图。
具体实施方式
50.为使本发明实施例的目的、技术方案和优点更加清楚，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明的一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动的前提下所获得的所有其他实施例，都属于本发明保护的范围。
51.下面结合附图对本发明做进一步的详细描述：
52.如图1所示，本发明公开的一种基于流程引擎的电信订单处理方法，包括：
53.s1、接收各渠道发送来的订单创建请求及各环节请求，将订单完整信息写入关系数据库，对应各环节请求进行订单完整信息的更新，并发起流程开始或流程流转请求；
54.其中，
55.接收各渠道发送来的订单的创建请求时，包括：
56.生成订单id，将订单完整信息写入关系数据库模块，并向流程引擎模块发起流程开始请求；
57.接收订单的各环节请求时，包括：
58.对应在关系数据库更新订单状态、物流状态、物流信息，并向流程引擎模块发起流程流转请求。
59.进一步的，
60.订单的各环节请求包括：
61.订单支付请求、订单开户请求、订单打包请求，订单发货请求、订单签收请求和号卡激活请求。
62.对应在关系数据库更新订单状态、物流状态、物流信息，包括：
63.接受到订单支付请求、订单开户请求、订单打包请求及号卡激活请求时，更新订单
状态；
64.接受到订单发货请求时，更新订单物流信息；
65.接受到订单签收请求时，更新订单物流状态和物流信息。
66.s2、流程引擎基于流程开始或流程流转请求向关系数据库查询流程规则信息，根据流程规则信息匹配订单流向；
67.s3、根据订单流向，向内存数据库写入当前订单的流转记录信息；
68.其中，
69.内存数据库对到达最后环节的流转记录信息，生成该订单的历史流转记录信息，并迁移至关系数据库。
70.s4、当进行代办订单查询时，向内存数据库发起查询。
71.如图2所示，本发明还提供了一种基于流程引擎的电信订单处理系统，包括：订单流转模块、流程引擎模块、内存数据库模块和关系数据库模块；
72.(1)订单流转模块，用于：
73.接收各渠道发送来的订单创建请求及各环节请求，将订单完整信息写入关系数据库模块，对应各环节请求进行订单完整信息的更新，并发起流程开始请求或流程流转请求；
74.其中，
75.接收各渠道发送来的订单的创建请求时，包括：
76.生成订单id，将订单完整信息写入关系数据库模块，并向流程引擎模块发起流程开始请求；
77.接收订单的各环节请求时，包括：
78.对应在关系数据库更新订单状态、物流状态、物流信息，并向流程引擎模块发起流程流转请求。
79.进一步的，
80.订单的各环节请求包括：
81.订单支付请求、订单开户请求、订单打包请求，订单发货请求、订单签收请求和号卡激活请求。
82.对应在关系数据库更新订单状态、物流状态、物流信息，包括：
83.接受到订单支付请求、订单开户请求、订单打包请求及号卡激活请求时，更新订单状态；
84.接受到订单发货请求时，更新订单物流信息；
85.接受到订单签收请求时，更新订单物流状态和物流信息。
86.(2)流程引擎模块，用于：
87.根据流程开始请求或流程流转请求向关系数据库模块查询流程规则信息，根据流程规则信息匹配订单流向；
88.根据订单流向，向内存数据库模块写入当前订单的流转记录信息。
89.(3)内存数据库模块，用于：
90.记录各订单的流转记录信息；
91.内存数据库对到达最后环节的流转记录信息，生成该订单的历史流转记录信息，并迁移至关系数据库。
92.(4)关系数据库模块，用于：
93.存储供流程引擎模块查询的流程规则信息；
94.保存并更新订单完整信息；
95.保存订单的历史流转记录信息。
96.实施例：
97.如图2所示，电信订单处理系统，由4部分组成：订单流转模块，流程引擎模块，内存数据库模块，关系数据库模块；对各个渠道提供统一的订单服务，包含：订单创建、订单流转、代办订单、订单查询；具体订单处理过程包括：
98.1、订单流转模块接收到订单创建请求后，生成订单id，将订单完整信息写入到关系数据库模块(mysql)，并向流程引擎模块发起流程开始请求；
99.2、订单流转模块接收到订单支付请求后，更新订单状态，并向流程引擎模块发起流程流转请求；
100.3、订单流转模块接收到订单开户请求后，更新订单状态，并向流程引擎模块发起流程流转请求；
101.4、订单流转模块接收到订单打包请求后，更新订单状态，并向流程引擎模块发起流程流转请求；
102.5、订单流转模块接收到订单发货请求后，更新订单物流信息，并向流程引擎模块发起流程流转请求；
103.6、订单流转模块接收到订单签收请求后，更新订单物流状态和物流信息(具体为：物流跟踪信息)，并向流程引擎模块发起流程流转请求；
104.7、订单流转模块接收到号卡激活请求后，更新订单状态，并向流程引擎模块发起流程流转请求；
105.8、流程引擎模块每次接收到订单流转模块的请求后，向关系数据库模块(mysql)查询流程规则信息，并根据流程规则匹配订单的流向；
106.9、流程引擎模块根据规则匹配后，向内存数据库模块写入当前订单的流转记录信息；
107.10、对于以及到最后环节的流转记录信息则生成历史流转记录信息迁移到关系数据库模块(mysql)中，减少内存数据库中的空间占用；
108.11、订单流转模块在进行代办订单查询时，实时向内存数据库发起查询，大大提升查询的效率。
109.本发明的优点：
110.相较于现有订单处理系统中，订单引擎模块将待处理数据存储在mysql数据库中，在订单量超过500w时写入和读取的性能严重下降的情况，本发明采用内存数据库替代mysql数据库存储流程记录信息，可支持1000w级别订单时引擎处理的高性能支持，写性能是现有订单处理系统的3倍，读性能是现有订单处理系统的6倍；本发明通过流程引擎管理订单的整个流程，提升了电信长流程订单的流程驱动能力，使业务处理简单、高效、自动化；在大流量订单的场景下，解决流程引擎处理的性能问题。
111.本发明通过基于流程引擎的电信订单处理系统建设，在现有主机资源未增加的条件下，tps(事务处理系统)处理性能提升2倍，满足了用户对系统性能指标要求，并且系统更
加稳定和高可用，具备分布式扩展能力。
112.以上仅为本发明的优选实施例而已，并不用于限制本发明，对于本领域的技术人员来说，本发明可以有各种更改和变化。凡在本发明的精神和原则之内，所作的任何修改、等同替换、改进等，均应包含在本发明的保护范围之内。

技术特征：
1.一种基于流程引擎的电信订单处理方法，其特征在于，包括：接收各渠道发送来的订单创建请求及各环节请求，将订单完整信息写入关系数据库，对应各环节请求进行所述订单完整信息的更新，并发起流程开始或流程流转请求；流程引擎基于流程开始或流程流转请求向关系数据库查询流程规则信息，根据所述流程规则信息匹配订单流向；根据订单流向，向所述内存数据库写入当前订单的流转记录信息；当进行代办订单查询时，向所述内存数据库发起查询。2.根据权利要求1所述的基于流程引擎的电信订单处理方法，其特征在于：接收各渠道发送来的订单的创建请求时，包括：生成订单id，将订单完整信息写入关系数据库模块，并向流程引擎模块发起流程开始请求；接收订单的各环节请求时，包括：对应在所述关系数据库更新订单状态、物流状态、物流信息，并向流程引擎模块发起流程流转请求。3.根据权利要求2所述的基于流程引擎的电信订单处理方法，其特征在于：订单的各环节请求包括：订单支付请求、订单开户请求、订单打包请求，订单发货请求、订单签收请求和号卡激活请求。4.根据权利要求3所述的基于流程引擎的电信订单处理方法，其特征在于：对应在所述关系数据库更新订单状态、物流状态、物流信息，包括：接受到订单支付请求、订单开户请求、订单打包请求及号卡激活请求时，更新订单状态；接受到订单发货请求时，更新订单物流信息；接受到订单签收请求时，更新订单物流状态和物流信息。5.根据权利要求1所述的基于流程引擎的电信订单处理方法，其特征在于：所述内存数据库对到达最后环节的所述流转记录信息，生成该订单的历史流转记录信息，并迁移至所述关系数据库。6.一种基于流程引擎的电信订单处理系统，应用如权利要求1～5任一项所述的基于流程引擎的电信订单处理方法，其特征在于，包括：订单流转模块、流程引擎模块、内存数据库模块和关系数据库模块；所述订单流转模块，用于：接收各渠道发送来的订单创建请求及各环节请求，将订单完整信息写入关系数据库模块，对应各环节请求进行所述订单完整信息的更新，并发起流程开始请求或流程流转请求；所述流程引擎模块，用于：根据所述流程开始请求或流程流转请求向所述关系数据库模块查询流程规则信息，根据所述流程规则信息匹配订单流向；根据订单流向，向所述内存数据库模块写入当前订单的流转记录信息；所述内存数据库模块，用于：记录各订单的流转记录信息；
所述关系数据库模块，用于：存储供所述流程引擎模块查询的所述流程规则信息；保存并更新订单完整信息；保存订单的历史流转记录信息。7.根据权利要求6所述的基于流程引擎的电信订单处理系统，其特征在于：接收各渠道发送来的订单的创建请求时，包括：生成订单id，将订单完整信息写入关系数据库模块，并向流程引擎模块发起流程开始请求；接收订单的各环节请求时，包括：对应在所述关系数据库更新订单状态、物流状态、物流信息，并向流程引擎模块发起流程流转请求。8.根据权利要求6所述的基于流程引擎的电信订单处理方法，其特征在于：订单的各环节请求包括：订单支付请求、订单开户请求、订单打包请求，订单发货请求、订单签收请求和号卡激活请求。9.根据权利要求8所述的基于流程引擎的电信订单处理方法，其特征在于：对应在所述关系数据库更新订单状态、物流状态、物流信息，包括：接受到订单支付请求、订单开户请求、订单打包请求及号卡激活请求时，更新订单状态；接受到订单发货请求时，更新订单物流信息；接受到订单签收请求时，更新订单物流状态和物流信息。10.根据权利要求6所述的基于流程引擎的电信订单处理方法，其特征在于：所述内存数据库对到达最后环节的所述流转记录信息，生成该订单的历史流转记录信息，并迁移至所述关系数据库。

技术总结
本发明提供了一种基于流程引擎的电信订单处理方法及系统，涉及互联网通讯技术领域，包括：接收各渠道发送来的订单创建请求及各环节请求，将订单完整信息写入关系数据库，对应各环节请求进行订单完整信息的更新，并发起流程开始或流程流转请求；流程引擎基于流程开始或流程流转请求向关系数据库查询流程规则信息，根据流程规则信息匹配订单流向；根据订单流向，向内存数据库写入当前订单的流转记录信息；当进行代办订单查询时，向内存数据库发起查询。本发明提升了电信长流程订单的流程驱动能力，使业务处理简单、高效、自动化，在大流量订单的场景下，解决流程引擎处理的性能问题。解决流程引擎处理的性能问题。解决流程引擎处理的性能问题。


技术研发人员：张清锁
受保护的技术使用者：北京思特奇信息技术股份有限公司
技术研发日：2023.02.01
技术公布日：2023/7/12