一种基于异步消息队列的营销智能路由分配方法及系统与流程

本发明涉及金融机构协同影响领域，尤其涉及一种基于异步消息队列的营销智能路由分配方法及系统。

背景技术：

1、本发明所要解决的技术问题包括：

2、1. 大规模企业名单导入的响应延迟问题：在单次导入大量企业名单（如数万条）时，通过异步预处理机制提前完成企业信息补全与缓存，使商机发起时本地命中率大幅提升，降低实时调用耗时。

3、2. 多源数据融合下的商机智能路由问题：将本地工商数据库、外部数据系统、crm营销关系、地理编码服务等多个异构数据源进行流水线式串联，在消息队列消费过程中逐级完成企业信息补全、存量客户校验、行政区划自动匹配，实现分级智能路由。

4、3. 基于地理距离的下发自动匹配问题：利用已存储的客户经纬度坐标，按可配置的距离阈值自动匹配最近的服务网点，并支持「营销关系优先、地理位置兜底」的双策略复选。

5、本发明涉及协同营销领域中商机数据的异步处理、智能路由与自动分配技术。在金融机构协同营销场景中，推荐机构（总行、分行、支行、子公司）需将大批量潜在客户名单导入系统，经企业信息补全、存量客户校验、地理位置匹配后，将商机路由至最合适的目标机构进行跟进。

6、现有技术主要分布于以下三个方向：

7、商机分配方法：cn120450738a 公开了一种商机分配方法，基于行业属性匹配与综合评分两级分配。上述方案均聚焦于单环节分配算法，未涉及批量数据的异步预处理和地理空间路由。

8、客户分配与关系图谱：cn122089491a 公开了基于关系图谱的保单客户分配方法，面向保险业务员离职再分配场景，未涉及跨机构多级路由和距离优先分配。

9、异步数据处理与企业信息补全：cn122153972a 公开了通用交易异步处理方法，使用消息队列分发交易；上述方案未与商机路由业务语义融合，也未涉及地理编码和行政区划匹配。

10、（3）客观评价现有技术的缺点（应与本发明技术特点相对应，也就是说本发明的方案能够克服的现有技术的缺点）；

11、现有技术存在以下核心缺点：

12、1. 缺少批量数据异步预处理机制：现有方案均为同步串行处理，当单次导入企业名单规模较大时，逐条实时查询外部数据导致严重响应延迟。

13、2. 未实现多源数据融合的全链路校验：未将工商补全、客户校验、地理编码等数据源串联为流水线，各环节割裂。

14、3. 缺乏基于地理空间的分级智能路由：现有分配仅依赖行业属性或业绩评分，未引入地理位置维度实现「存量优先、属地就近」的分级路由。

15、4. 缺少可配置距离阈值的双策略就近分配：未提供基于经纬度的自动匹配机制和多策略复选优先级。

技术实现思路

1、鉴于上述问题，提出了本发明以便提供克服上述问题或者至少部分地解决上述问题的一种基于异步消息队列的营销智能路由分配方法及系统。

2、根据本发明的一个方面，提供了一种基于异步消息队列的营销智能路由分配方法，所述分配方法包括：

3、进入预灌入阶段，数据铺底：将待处理的企业名单批量推送至消息队列，预灌入阶段与商机发起请求完全解耦；

4、进入实时消费阶段，商机路由：推荐机构上传excel名单后，名单即刻落库并返回确认；

5、客户下发：目标分行经办人对客户池中的商机执行互斥处置；

6、进度与监控：名单上传后即刻落库返回，页面实时查询消息队列处理进度。

7、可选的，所述进入预灌入阶段，数据铺底：将待处理的企业名单批量推送至消息队列，预灌入阶段与商机发起请求完全解耦具体包括：

8、进入预灌入阶段，数据铺底：定时任务调度器按预设周期扫描企业名单数据库，将待处理的企业名单批量推送至消息队列；

9、消息队列消费者在后台逐条查询本地工商数据库和外部数据系统，将补全后的企业信息回写至本地缓存数据库；

10、预灌入阶段与商机发起请求完全解耦，不阻塞前台操作。

11、可选的，所述补全后的企业信息具体包括：注册地址、联系电话、统一社会信用代码、成立日期。

12、可选的，所述进入实时消费阶段，商机路由：推荐机构上传excel名单后，名单即刻落库并返回确认具体包括：

13、消息队列消费者依次执行步骤：

14、查询本地工商数据库；

15、未命中则调用外部数据系统获取并回写本地数据库；

16、校验是否存量客户、是否集团客户；

17、调用地图服务api获取行政区划及经纬度坐标，利用行政区划信息自动匹配目标协同分行；

18、三级分级路由：存量客户优先路由至已有营销关系的目标分行；新客户按行政区划属地匹配目标分行；匹配失败转入人工干预队列；

19、发起后自动抄送总行备案。

20、可选的，所述客户下发：目标分行经办人对客户池中的商机执行互斥处置具体包括：

21、自动下发，利用商机路由阶段已存储的客户经纬度坐标，按可配置距离阈值计算最近支行，经「营销关系 > 地理位置」双策略复选优先级排序后生成候选分配结果，经办人预览后确认执行；

22、人工下发，经办人手动勾选目标支行或二级分行。

23、可选的，所述进度与监控：名单上传后即刻落库返回，页面可实时查询消息队列处理进度具体包括：商机发起后自动抄送总行备案，形成完整操作审计链路。

24、本发明还提供了一种基于异步消息队列的营销智能路由分配系统，应用上述所述的一种基于异步消息队列的营销智能路由分配方法，所述分配系统包括：

25、定时任务调度器，用于进入预灌入阶段，数据铺底：将待处理的企业名单批量推送至消息队列，预灌入阶段与商机发起请求完全解耦；

26、商机路由决策模块，用于进入实时消费阶段，商机路由：推荐机构上传excel名单后，名单即刻落库并返回确认；

27、客户下发模块，用于客户下发：目标分行经办人对客户池中的商机执行互斥处置；

28、进度与监控模块，用于进度与监控：名单上传后即刻落库返回，页面实时查询消息队列处理进度。

29、本发明提供的一种基于异步消息队列的营销智能路由分配方法及系统，所述分配方法包括：进入预灌入阶段，数据铺底：将待处理的企业名单批量推送至消息队列，预灌入阶段与商机发起请求完全解耦；进入实时消费阶段，商机路由：推荐机构上传excel名单后，名单即刻落库并返回确认；客户下发：目标分行经办人对客户池中的商机执行互斥处置；进度与监控：名单上传后即刻落库返回，页面实时查询消息队列处理进度。定时任务驱动的预灌入阶段与商机触发驱动的实时消费阶段相配合，通过本地缓存复用减少实时外部调用。

30、上述说明仅是本发明技术方案的概述，为了能够更清楚了解本发明的技术手段，而可依照说明书的内容予以实施，并且为了让本发明的上述和其它目的、特征和优点能够更明显易懂，以下特举本发明的具体实施方式。