1.本技术涉及消息处理技术领域，具体涉及一种消息发送的数据处理系统。
背景技术：2.现有技术中，当某一app需要对其对应的用户下发消息时，往往通过app本身与用户之间的连接渠道进行发送，当用户与app之间的连接通道为在线状态时，用户可以接收到app发送的消息，然而当用户与app之间的连接通道为离线状态时，用户就接收不到app发送的消息，从而可能会导致没有告知用户重要消息的情况。
技术实现要素：3.针对上述技术问题，本发明采用的技术方案为：
4.一种消息发送的数据处理系统，所述系统包括：数据库sk、处理器和存储有计算机程序的存储器，所述数据库sk＝(sk1，sk2，...，skr，...，sks)，skr为第r个数据库，r的取值为1到s，s为数据库的数量，skr中第j个app列表pj＝(p
j1
，p
j2
，...，p
jg
，...，p
jzj
)，p
jg
为第j个app中第g个用户id，y的取值为1到gj，gj为第j个app中用户id数量，j的取值为1到nr，nr为第r个数据库中包括的app列表的数量，当所述计算机程序被处理器执行时，实现如下步骤：
5.s100、根据pj，获取目标用户id列表ap＝(ap1，ap2，...，api，...，apm)，api为第i个目标用户，i的取值为1到m，m为目标用户的数量，所述目标用户id为在目标消息下发前的预观察时间段在数据库中记录状态为离线状态的用户；
6.s200、根据pj，获取中间用户id列表bp＝(bp1，bp2，....，bp
t
，...，bpk)，bp
t
为pj中第t个中间用户id，t的取值为1到k，k为pj中中间用户id的数量，所述中间用户id为在目标消息下发前的预观察时间段在数据库中记录状态为在线状态的用户id；
7.s300、根据bp，获取关键用户id列表cp＝(cp1，cp2，...，cpf，...，cpd)，cpf为第f个关键用户id，f的取值为1到d，d为关键用户id的数量，所述关键用户id为没有成功对bp中关键用户id下发目标消息的用户id；
8.s400、根据ap和cp，获取最终用户id列表zp＝(zp1，zp2，...，zpb，...，zpv)，zpb为第b个最终用户id列表，b的取值为1到v，v为最终用户id的数量，所述最终用户id为需要通过短信渠道下发目标消息的用户id；
9.s500、根据zp，判断是否符合短信发送条件，当符合短信发送条件时，通过短信渠道对zpb下发目标消息。
10.本技术至少具有以下技术效果：获取预设时间段内处于第一状态的原始用户对应的的原始用户id以及预设时间段内处于第二状态的原始用户对应的的原始用户id，基于预设时间段内处于第二状态的原始用户对应的的原始用户id，获取第一状态的原始用户id中没有通过第一方式接收到目标消息的原始用户id，并通过第二方式向没有接收到目标消息地原始用户id发送目标消息，这样，下发目标消息不遗漏每一个原始用户id，并且使目标消息下发更加精准；此外，对于原始用户id中符合第三方服务器设置的关键条件的原始用户
id，通过第三方式发送目标消息，节省了用户资源；
11.通过将app对应用户id超出预设阈值用户id单独存储至数据库中，且对其余app进行聚类处理，构成优先级列表的方式，并且不同优先级列表中的用户id也可以进行并行处理，可知，可以保证处理用户id的时效性，节省用户的时间资源。
附图说明
12.为了更清楚地说明本技术实施例中的技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本技术的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
13.图1为本技术实施例提供的一种基于消息发送的数据处理系统执行计算机程序的流程图。
具体实施方式
14.下面将结合本技术实施例中的附图，对本技术实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本技术一部分实施例，而不是全部的实施例。基于本技术中的实施例，本领域技术人员在没有作出创造性劳动前提下所获得的所有其他实施例，都属于本技术保护的范围。
15.需要说明的是，本发明的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换，以便这里描述的本发明的实施例能够以除了在这里图示或描述的那些以外的顺序实施。此外，术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或单元的过程、方法、系统、产品或服务器不必限于清楚地列出的那些步骤或单元，而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。
16.本技术实施例提供一种消息发送的数据处理系统，其特征在于，所述系统包括：app集合p、处理器和存储有计算机程序的存储器，所述p＝{p1，p2，...，pj，...，pn}，pj＝(p
j1
，p
j2
，...，p
jr
，...，p
jsj
)，p
jr
＝(p
jr1
，p
jr2
，...，p
jrg
，...，p
jrzr
)，p
jrg
为第j个app列表中的第r个app的第g个原始用户id，j的取值为1到n，n为app列表的数量，r的取值为1到sj，sj为第j个app列表中app的数量，g的取值为1到zr，zr为第r个app中原始用户id的数量，当所述计算机程序被处理器执行时，实现如下步骤：
17.s100、从p
jr
中获取目标用户id列表ap＝(ap1，ap2，...，api，...，apm)，api为第i个目标用户id，i的取值为1到m，m为目标用户id的数量，所述目标用户id为预设时间段内处于第一状态的原始用户对应的的原始用户id。
18.具体地，所述原始用户id为原始用户的唯一身份标识，且所述p
jr
的字段可包括所述原始用户id对应的原始id，本领域技术人员可根据实际需求设置所述原始id，所述原始用户id对应的电子设备，所述电子设备对应的第三方服务器。
19.本发明实施例的电子设备以多种形式存在，包括但不限于：
20.(1)移动通信设备:这类设备的特点是具备移动通信功能，并且以提供话音、数据
通信为主要目标。这类终端包括：智能手机(例如iphone)、多媒体手机、功能性手机，以及低端手机等。
21.(2)超移动个人计算机设备:这类设备属于个人计算机的范畴，有计算和处理功能，一般也具备移动上网特性。这类终端包括:pda、mid和umpc设备等，例如ipad。
22.(3)便携式娱乐设备:这类设备可以显示和播放多媒体内容。该类设备包括:音频、视频播放器(例如ipod)，掌上游戏机，电子书，以及智能玩具和便携式车载导航设备。
23.(4)服务器:提供计算服务的设备，服务器的构成包括处理器、硬盘、内存、系统总线等，服务器和通用的计算机架构类似，但是由于需要提供高可靠的服务，因此在处理能力、稳定性、可靠性、安全性、可扩展性、可管理性等方面要求较高。
24.(5)其他具有数据交互功能的电子设备。进一步地，对p
jr
中原始用户id的状态根据进行更新。
25.优选地，每隔10ms对p
jr
中用户id的状态进行一次监测，当监测到p
jr
中原始用户id的状态变化时将变化状态更新，并将p
jr
中上一个状态对应的存储记录删除。
26.具体地，本领域技术人员可根据实际情况设置所述预时间段，在此不在赘述。
27.进一步地，所述第一状态为原始用户id对应的原始用户处于离线状态。
28.进一步地，所述离线状态可以理解为目标用户与app消息下发渠道为断开状态，接收不到app下发渠道发送的目标消息，并且没有与第三方服务器连接的目标用户id。
29.在s100中还包括如下步骤：
30.s110、遍历pj，获取fp＝(fp1，fp2，...，fpe，...，fph)，fe为pj中第e个与第三方服务器连接的用户id，e的取值为1到h，h为与pj中第三方服务器连接的用户id的数量。
31.具体地，所述预第三方服务器连接的用户id可以理解为可以通过第三方服务器接收到app目标消息的用户id。
32.s120、基于第三方服务器设置的目标超限条件，遍历f，获取dp＝(dp1，dp2，...，dp
x
，...，dpq)，dp
x
为f中第x个符合第三方服务器设置的目标条件的用户id，x的取值为1到q，q为f中符合第三方服务器设置的目标条件的用户id的数量。
33.具体地，对于所述符合第三方服务器设置的目标超限条件的用户id，通过第三方式下发目标消息。
34.进一步地，所述第三方式与第一方式和第二方式为不同方式。
35.进一步地，所述第三方服务器的目标条件包括第一目标条件和/或第二目标条件，且当任一目标条件没有符合时，不通过第三方式对目标消息进行发送。
36.进一步地，所述第一目标条件为在时间阈值内发送至当前移动终端的目标消息没有超过预设发送目标消息阈值，所述第二目标条件为目标消息中不带有限制词语，例如，测试等词语。
37.优选地，所述时间阈值为24h。
38.s130、根据pj和dp，获取ap。
39.具体地，
40.s200、从p
jr
中获取中间用户id列表bp＝(bp1，bp2，....，bp
t
，...，bpk)，bp
t
为pj中第t个中间用户id，t的取值为1到k，k为pj中中间用户id的数量，所述中间用户id为预设时间段内处于第二状态的原始用户对应的的原始用户id。
41.具体地，所述在线状态可以理解为用户与app消息下发渠道为连接状态，可以接收到app下发渠道发送的目标消息。
42.s300、通过第一方式对bp
t
下发目标消息，获取关键用户id列表cp＝(cp1，cp2，...，cpf，...，cpd)，cpf为第f个关键用户id，f的取值为1到d，d为关键用户id的数量，所述关键用户id为未收到目标消息的中间用户对应的中间用户id。
43.具体地，s300中包括如下步骤：
44.s310、在目标消息发送时对bp中数据进行时间监视，获取在通过第一方式对bp中关键用户id下发目标消息中途处于第一状态的用户id。
45.具体地，所述通过第一方式对bp中关键用户id下发目标消息中途处于第一状态的用户id可以理解为，在发送消息过程中，实时监测到的又第二状态更新为第一状态的中间用户id。
46.s320、在目标消息发送时对bp中数据进行实时监视，对bp中一直处于第二状态的中间用户id第一方式发送目标消息，获取没有接收到反馈消息的中间用户id。
47.具体地，所述反馈消息由app方发送至cp。
48.s330、将通过第一方式对bp中关键用户id下发目标消息中途处于第一状态的用户id和没有接收到反馈消息的中间用户id相加，获取cp。
49.s400、根据ap和cp，获取最终用户id列表zp＝(zp1，zp2，...，zpb，...，zpv)，zpb为第b个最终用户id列表，b的取值为1到v，v为最终用户id的数量，所述最终用户id为需要通过第二方式下发目标消息的用户id。
50.s500、当zpb对应的下发目标消息条件满足关键条件时，将提示消息通过第二方式发送至zpb，所述提示消息内容与目标消息内容一致。
51.具体地，所述关键条件包括第一关键条件和/或第二关键条件。
52.进一步地，所述第一关键条件为发送数量阈值，所述第二关键条件为发送资源阈值。
53.进一步地，本领域技术人员可以根据需求设置发送数量阈值v0，当v＜v0时，为符合发送条件；本领域技术人员可以根据需求设置发送资源阈值，当通过第三渠道对zp下发目标消息的使用资源＜发送资源阈值时，为符合发送条件。
54.进一步地，当判断为不符合目标条件时，在显示装置上进行预警，对用户进行提示。
55.基于s100到s500，获取预设时间段内处于第一状态的原始用户对应的的原始用户id以及预设时间段内处于第二状态的原始用户对应的的原始用户id，基于预设时间段内处于第二状态的原始用户对应的的原始用户id，获取第一状态的用户id中没有通过第一方式接收到目标消息的原始用户id，并通过第二方式向没有接收到目标消息地原始用户id发送目标消息，这样，下发目标消息不遗漏每一个原始用户id，并且使目标消息下发更加精准；此外，对于原始用户id中符合第三方服务器设置的关键条件的原始用户id，通过第三方式发送目标消息，节省了用户资源。
56.在s100之前还包括如下步骤：
57.s10、获取原始app列表rp＝(rp1，rp2，...，rpc，...，rpu)，
rp
cw
为第c个目标app中的第w个用户id，c的取值为1到u，u为目标app的数量，w的取值为1到值为1到u，u为目标app的数量，w的取值为1到为第c个原始app中原始用户id的数量。
58.具体地，u＝s1+s2+...+sj+...+sn。
59.s20、从rp中获取每分种查询用户id请求量≥预设阈值的原始app，单独存储至pj中。
60.具体地，不同pj中可以同时查询原始用户id的状态，也就是不同pj之间为并行处理的状态。
61.s30、将rp中除每分种查询用户id请求量＜预设阈值的的原始app进行聚类处理，构建优先级列表sh＝(sh1，sh2，sh3)，且存储在同一pj中，sh1为第一优先集列表，sh2为第二优先集列表，sh3为第三优先集列表。
62.具体地，在本发明实施例中，第一优先集列表为高优先级列表，第二优先集列表为中优先集列表，第三优先集列表为低优先集列，sh1、sh2和sh3初始状态均为空集。
63.进一步地，可以同时对第一优先级列表、第二优先级列表和第三优先级列表中目标用户的状态进行检测，可以理解为可以对第一优先级列表、第二优先级列表和第三优先级列表进行并行处理。
64.进一步地，本领域技术人员知晓，任意一种对原始app进行聚类处理的方法，均落入本发明保护范围内。
65.优选地，在本发明实施例中，使用k-means聚类算法构建优先级列表sh。
66.具体地，对rp中每分种查询用户id请求量＜预设阈值的原始app形成的目标app列表进行向量化处理得到fp＝(fp1，fp2，...，fp
ɑ
，...，fp
ε
)，fp
ɑ
为第
ɑ
个目标app，
ɑ
的取值为1到ε，ε为目标app的数量，本领域技术人员知晓，任意一种对目标app进行标准化处理的方法，均落在本发明保护范围。
67.进一步地，需要分为三个优先级列表，因此，创建3个点作为初始质心，任一初始质心之间的取值不同。
68.进一步地，计算fp
ɑ
到每一个初始质心的欧式距离fp
ou
ɑ
。
69.进一步地，获取fp
ɑ
到初始质心的最小欧式距离fp
ou0
ɑ
，将fp
ɑ
分配到fp
ou0
ɑ
对应的初始质心的优先级列表中；设置
ɑ
＝
ɑ
+1，如果
ɑ
＜ε，重复上述步骤，否则，得到3个优先级列表。
70.使用k-means进行处理的优点在于实现简单、需要调节参数少且在聚类速度快的同时还保证了聚类的效果。
71.上述，s10-s30步骤通过将app对应用户id超出预设阈值用户id单独存储至数据库中，且对其余app进行聚类处理，构成优先级列表的方式，并且不同优先级列表中的用户id也可以进行并行处理，可知，可以保证处理用户id的时效性，节省用户的时间资源。
72.虽然已经通过示例对本技术的一些特定实施例进行了详细说明，但是本领域的技术人员应该理解，以上示例仅是为了进行说明，而不是为了限制本技术的范围。本领域的技术人员还应理解，可以对实施例进行多种修改而不脱离本技术的范围和精神。本技术公开的范围由所附权利要求来限定。
技术特征：1.一种消息发送的数据处理系统，其特征在于，所述系统包括：app集合p、处理器和存储有计算机程序的存储器，所述p＝{p1，p2，...，p
j
，...，p
n
}，p
j
＝(p
j1
，p
j2
，...，p
jr
，...，p
jsj
)，p
jr
＝(p
jr1
，p
jr2
，...，p
jrg
，...，p
jrzr
)，p
jrg
为第j个app列表中的第r个app的第g个原始用户id，j的取值为1到n，n为app列表的数量，r的取值为1到sj，sj为第j个app列表中app的数量，g的取值为1到zr，zr为第r个app中原始用户id的数量，当所述计算机程序被处理器执行时，实现如下步骤：s100、从p
jr
中获取目标用户id列表ap＝(ap1，ap2，...，ap
i
，...，ap
m
)，ap
i
为第i个目标用户id，i的取值为1到m，m为目标用户id的数量，所述目标用户id为预设时间段内处于第一状态的原始用户对应的的原始用户id；s200、从p
jr
中获取中间用户id列表bp＝(bp1，bp2，....，bp
t
，...，bp
k
)，bp
t
为p
j
中第t个中间用户id，t的取值为1到k，k为p
j
中中间用户id的数量，所述中间用户id为预设时间段内处于第二状态的原始用户对应的的原始用户id；s300、通过第一方式对bp
t
下发目标消息，获取关键用户id列表cp＝(cp1，cp2，...，cp
f
，...，cp
d
)，cp
f
为第f个关键用户id，f的取值为1到d，d为关键用户id的数量，所述关键用户id为未收到目标消息的中间用户对应的中间用户id；s400、根据ap和cp，获取最终用户id列表zp＝(zp1，zp2，...，zp
b
，...，zp
v
)，zp
b
为第b个最终用户id列表，b的取值为1到v，v为最终用户id的数量，所述最终用户id为需要通过第二方式下发目标消息的用户id；s500、当zp
b
对应的下发目标消息条件满足关键条件时，将提示消息通过第二方式发送至zp
b
，所述提示消息内容与目标消息内容一致。2.根据权利要求1所述的系统，其特征在于，在s100之前还包括如下步骤：s10、获取原始app列表rp＝(rp1，rp2，...，rp
c
，...，rp
u
)，rp
c
＝(rp
c1
，rp
c2
，...，rp
cw
，...，)，rp
cw
为第c个目标app中的第w个用户id，c的取值为1到u，u为目标app的数量，w的取值为1到量，w的取值为1到为第c个原始app中原始用户id的数量；s20、从rp中获取每分种查询用户id请求量＞预设阈值的原始app，单独存储至p
j
中；s30、将rp中除每分种查询用户id请求量＞预设阈值的app以外的原始app进行聚类处理，构建优先级列表sh＝(sh1，sh2，sh3)，且存储在同一p
j
中，sh1为第一优先集列表，sh2为第二优先集列表，sh3为第三优先集列表。3.根据权利要求1所述的系统，其特征在于，所述第一方式与第二方式不同。4.根据权利要求1所述的系统，其特征在于，所述第一状态为原始用户id对应的原始用户处于离线状态，所述第二状态为原始用户id对应原始用户处于第二状态。5.根据权利要求1所述的系统，其特征在于，在s100中，还包括如下步骤：s110、遍历p
j
，获取fp＝(fp1，fp2，...，fp
e
，...，fp
h
)，f
e
为p
j
中第e个与第三方服务器连接的用户id，e的取值为1到h，h为与p
j
中第三方服务器连接的用户id的数量；s120、基于第三方服务器设置的目标超限条件，遍历f，获取dp＝(dp1，dp2，...，dp
x
，...，dp
q
)，dp
x
为f中第x个符合第三方服务器设置的目标条件的用户id，x的取值为1到q，q为f中符合第三方服务器设置的目标条件的用户id的数量；s130、根据p
j
和dp，获取ap。6.根据权利要求5所述的系统，其特征在于，
7.根据权利要求5所述的系统，其特征在于，所述第三方服务器的目标条件包括第一目标条件和/或第二目标条件；所述第一目标条件为在时间阈值内发送至当前移动终端的目标消息没有超过预设发送目标消息阈值，所述第二目标条件为目标消息中不带有限制词语。8.根据权利要求1所述的系统，其特征在于，在s500中，所述关键条件包括第一关键条件和/或第二关键条件；所述第一关键条件为发送数量阈值，所述第二关键条件为发送资源阈值。9.根据权利要求1所述的系统，其特征在于，在s500中，当判断为不符合目标条件时，在显示装置上进行预警，对用户进行提示。
技术总结本申请提供了一种消息发送的数据处理系统，该系统通过获取原始用户ID中没有通过第一方式接收到目标消息的原始用户ID，并通过第二方式向没有接收到目标消息地原始用户ID发送目标消息，这样，下发目标消息不遗漏每一个原始用户ID，并且使目标消息下发更加精准；此外，对于原始用户ID中符合第三方服务器设置的关键条件的原始用户ID，通过第三方式发送目标消息，节省了用户资源；还通过将APP对应用户ID超出预设阈值用户ID单独存储至数据库中，且对其余APP进行聚类处理，构成优先级列表的方式，并且不同优先级列表中的用户ID也可以进行并行处理，这样，可以保证处理用户ID的时效性，节省用户的时间资源。用户的时间资源。用户的时间资源。
技术研发人员：陈建斌 叶新江 彭雷 刘汉兴
受保护的技术使用者：每日互动股份有限公司
技术研发日：2022.07.25
技术公布日：2022/11/1
