一种账单查询的方法及装置与流程

专利2022-06-29  71


本申请涉及通讯网络领域,尤其涉及一种账单查询的方法及装置。



背景技术:

随着网络的迅速发展,网络技术在人们生活和工作中已经随处可见,网络技术的应用即丰富了人们的生活,又给人们的生活带来了许多的便捷;例如,现在可以依赖网络直接处理大部分金融业务,这种方式极大地节省了人力资源,又可以快速且准确的处理金融业务,提高了金融业务处理的精确性和实时性。

金融业务包括保险、信托、风险投资、实业投资等,这些业务几乎都离不开账单的查询与获取,以银行信用卡为例;有些银行会自建系统,在这些银行自建系统中用户可以在用户端快速查询和展示该用户在这一银行的银行信用卡的账单信息。这种方式虽然可以快速为用户获取账单信息,但只能为用户管理单个银行的信用卡,不能集中管理多个银行的信用卡。另一种可以集中管理银行信用卡的app,包含为用户集中管理多张信用卡的功能,但获取账单的速度慢,用户在使用中需要等带,时间成本高。

因此,现在亟需一种账单查询的方法及装置,用于集中管理账户,快速获取各账户对应的账单信息。



技术实现要素:

本发明实施例提供一种账单查询的方法及装置,用于集中管理账户,快速获取各账户对应的账单信息。

第一方面,本发明实施例提供一种账单查询的方法,该方法包括:

接收用户的账单查询请求;根据所述账单查询请求,从第一存储系统中查找所述用户的各账户的账单信息;将从所述第一存储系统查询到的所述用户的第一账户的第一账单信息发送给所述用户;向所述用户的第二账户所在的银行系统发起异步查询请求,所述第二账户为所述用户的各账户中除所述第一账户之外的账户;将通过所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户。

采用上述方法,通过接收用户的账单查询请求查询第一存储系统中该用户的各账户的账单信息,并将第一存储系统中查找到的账单信息发送到用户端,若没有查找到的账单信息,则发起对应该账单信息账户的异步查询请求,将异步查询请求获得的账单信息发送至用户端。通过这种方式可以同时管理用户的多个账户,将第一存储系统中存在的账单信息先提供给用户,再将异步查询获取的账单信息提供给用户,减少用户查询账单信息的等待时间。

在一种可能的设计中,向所述用户的第二账户所在的银行系统发起异步查询请求,包括:针对每个第二账户,创建所述第二账户的异步查询请求并发送至所述第二账户所在的银行系统;将从所述第二账户所在的银行系统获取的所述第二账户的第二账单信息存储在所述第一存储系统。

采用上述方法,将第二账单信息存储在第一存储系统中,便于后续用户查询账单信息时,快速提供第二账户的第二账单信息。

在一种可能的设计中,通过将所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户,包括:通过轮询的方式从所述第一存储系统中获取所述第二账单信息并在轮询过程中将所述第二账单信息发送给所述用户。

采用上述方法,通过轮询的方式可以及时获得异步查询请求获得的第二账户的第二账单信息,将第二账单信息及时反馈给用户。

在一种可能的设计中,所述方法还包括:确定满足订阅要求的第三账户;所述订阅要求为所述用户预先设置的;将从所述第一存储系统获取的所述第三账户的第三账单信息存储至第二存储系统;根据从所述第二存储系统中获取的所述第三账单信息,生成所述第三账户的提醒消息;将所述提醒消息发送至所述第三账户对应的所述用户。

采用上述方法,通过确定用户预先设置的订阅要求,从第一存储系统中获取第三账单信息,将账单信息存储到第二存储系统中并发送第三账户的提醒消息,将提醒消息发送至该第三账户对应的用户。通过这种方式,可以将第三账户的发送提醒消息的任务解耦到第二储存系统中,加快提醒消息的生成和发送。

在一种可能的设计中,所述方法包括:所述账单查询请求是在接收到所述提醒消息后触发的。

采用上述方法,用户在接收到提醒消息后查询账单信息,因为账单信息在用户接收到提醒消息前就存储在第一存储系统和第二存储系统,因此可以加快用户账单信息的获取,减少用户获取账单信息的等待时间。

在一种可能的设计中,将从所述第一存储系统获取的所述第三账户的第三账单信息存储至第二存储系统之前,还包括:确定所述第一存储系统是否存储有所述第三账单信息;若未存储所述第三账单信息,则向所述第三账户所在的银行系统发送所述异步查询请求;将通过所述异步查询请求获得的所述第三账单信息存储至所述第一存储系统。

采用上述方法,根据用户预先设置的订阅要求从第一存储系统中获取第三账单信息,若第一存储系统中没有第三账单信息,则发起异步查询请求获取第三账单信息存储在第一存储系统。如此,当用户再次查看该账单信息时,可以从第一存储系统中获取账单信息,为用户快速展示账单信息。

在一种可能的设计中,确定满足订阅要求的第三账户之前,还包括:

将接收的所述第三账户的所述订阅要求存储至所述第二存储系统;根据从所述第二存储系统中获取的所述订阅要求,生成所述第三账户的订阅操作;在第三存储系统中写入所述订阅操作。

采用上述方法,接收用户设置第三账户的订阅要求后,将第三账户的订阅要求存储在第二存储系统中。如此,不需要服务层一直提供内存,记录第三账户对应的订阅要求,可以减轻服务层系统的压力。从第二存储系统中获取第三账户的订阅请求,生成订阅操作,并写入第三存储系统中。实现将生成订阅操作从获取账单的业务流程中解耦,加快获取账单的速度,也可以完成生成订阅操作,以使后续获取该订阅操作,为用户发送提醒消息。

在一种可能的设计中,确定满足订阅要求的第三账户,包括:采用分布式任务的方式通过所述第三存储系统确定满足订阅要求的第三账户。

采用上述方法,通过分布式任务方式确定第三存储系统满足订阅要求的第三账户,分布式任务方式可以将当前所有用户的账户分开存储和管理,以此可以实现弹性扩容缩容,当访问量升高或降低时,可以通过增加或减少服务器的数量,提升处理业务能力,降低业务处理成本。

第二方面,本发明实施例提供一种账单查询的装置,该装置包括:

接收模块,用于接收用户的账单查询请求;

处理模块,用于根据所述账单查询请求,从第一存储系统中查找所述用户的各账户的账单信息;

发送模块,用于将从所述第一存储系统查询到的所述用户的第一账户的第一账单信息发送给所述用户;

所述发送模块还用于,向所述用户的第二账户所在的银行系统发起异步查询请求,所述第二账户为所述用户的各账户中除所述第一账户之外的账户;

所述发送模块还用于,将通过所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户。

在一种可能的设计中,所述发送模块具体用于:针对每个第二账户,创建所述第二账户的异步查询请求并发送至所述第二账户所在的银行系统;将从所述第二账户所在的银行系统获取的所述第二账户的第二账单信息存储在所述第一存储系统。

在一种可能的设计中,所述发送模块具体用于:通过轮询的方式从所述第一存储系统中获取所述第二账单信息并在轮询过程中将所述第二账单信息发送给所述用户。

在一种可能的设计中,所述处理模块还用于:

确定满足订阅要求的第三账户;所述订阅要求为所述用户预先设置的;

将从所述第一存储系统获取的所述第三账户的第三账单信息存储至第二存储系统;根据从所述第二存储系统中获取的所述第三账单信息,生成所述第三账户的提醒消息;

所述发送模块还用于,将所述提醒消息发送至所述第三账户对应的所述用户。

在一种可能的设计中,所述接收模块还用于:所述账单查询请求是在接收到所述提醒消息后触发的。

在一种可能的设计中,所述处理模块还用于:确定所述第一存储系统是否存储有所述第三账单信息;若未存储所述第三账单信息,则向所述第三账户所在的银行系统发送所述异步查询请求;将通过所述异步查询请求获得的所述第三账单信息存储至所述第一存储系统。

在一种可能的设计中,所述处理模块还用于:将接收的所述第三账户的所述订阅要求存储至所述第二存储系统;根据从所述第二存储系统中获取的所述订阅要求,生成所述第三账户的订阅操作;在第三存储系统中写入所述订阅操作。

在一种可能的设计中,包括:采用分布式任务的方式通过所述第三存储系统确定满足订阅要求的第三账户。

第三方面,本申请实施例还提供一种计算设备,包括:存储器,用于存储程序指令;处理器,用于调用所述存储器中存储的程序指令,按照获得的程序执行如第一方面的各种可能的设计中所述的方法。

第四方面,本申请实施例还提供一种计算机可读非易失性存储介质,包括计算机可读指令,当计算机读取并执行所述计算机可读指令时,使得计算机执行如第一方面的各种可能的设计中所述的方法。

本申请的这些实现方式或其他实现方式在以下实施例的描述中会更加简明易懂。

附图说明

为了更清楚地说明本发明实施例中的技术方案,下面将对实施例描述中所需要使用的附图作简要介绍,显而易见地,下面描述中的附图仅仅是本发明的一些实施例,对于本领域的普通技术人员来讲,在不付出创造性劳动性的前提下,还可以根据这些附图获得其他的附图。

图1为本发明实施例提供的一种账单查询的架构示意图;

图2为本发明实施例提供的一种账单查询方法的流程示意图;

图3为本发明实施例提供的又一种账单查询方法的流程示意图;

图4为本发明实施例提供的一种账单查询的架构示意图;

图5为本发明实施例提供的一种账单查询方法的流程示意图;

图6为本发明实施例提供的一种账单查询方法的流程示意图;

图7为本发明实施例提供的一种账单查询方法的装置示意图。

具体实施方式

为了使本发明的目的、技术方案和优点更加清楚,下面将结合附图对本发明作进一步地详细描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其它实施例,都属于本发明保护的范围。

本发明实施例提供的一种账单查询的架构示意图,如图1所示,服务模块102接收用户的账单查询请求,在第一存储系统中查找该用户的每个账户对应的账单信息,将查找到的账户的账单信息返回至用户端,未查找到的账户对应的账单信息,则由查询模块101发起异步查询请求,服务模块102将接收到异步查询请求获取的账户对应的账单信息发送至用户。

基于此,本申请实施例提供了一种账单查询的方法流程,如图2所示,包括:

步骤201、接收用户账单查询请求;

此处,账单查询请求为针对于该用户至少一个账户的账单信息的查询请求。

步骤202、根据所述账单查询请求,从第一存储系统中查找所述用户的各账户的账单信息;

此处,第一存储系统可以为kafka、redis等存储系统。根据账单查询请求,在第一存储系统中,查找该用户的各个账户的账单信息。

例如,该用户有a、b、c、d信用卡,该用户发起账单查询请求后,从第一存储系统中查询a、b、c、d信用卡对应的账单信息。

步骤203、将从所述第一存储系统查询到的所述用户的第一账户的第一账单信息发送给所述用户;

此处,所述第一账户为在第一存储系统中查找到账单信息的账户,第一账单信息为对应第一账户的账单信息,将查找到的第一账户的账单信息返发送至用户端。

在上一个示例中,若在第一存储系统中查找到a信用卡和b信用卡的账单信息,则将a信用卡的账单信息和b信用卡的账单信息发送至用户。

步骤204、向所述用户的第二账户所在的银行系统发起异步查询请求,所述第二账户为所述用户的各账户中除所述第一账户之外的账户;

此处,第二账户为在第一存储系统中没有查找到账单信息的账户,异步查询请求为向各账户对应的银行系统发起的账单信息获取请求。

在上一个示例中,在第一存储系统中没有查找到c信用卡和d信用卡的账单信息,则分别向c信用卡对应的银行系统和d信用卡对应的银行系统发起异步查询请求。

其中,向所述用户的第二账户所在的银行系统发起异步查询请求,包括:针对每个第二账户,创建所述第二账户的异步查询请求并发送至所述第二账户所在的银行系统;将从所述第二账户所在的银行系统获取的所述第二账户的第二账单信息存储在所述第一存储系统。

此处,第二账单信息为第二账户的账单信息,对于每个第二账户,创建针对该第二用账户的异步查询请求,并发送至第二账户对应的银行系统,获取银行系统返回的第二账户的账单信息,并将该第二账户的账单信息存储在第一存储系统中。

在上一个示例中,向c信用卡对应的银行系统和d信用卡对应的银行系统发起异步查询请求,获取c信用卡对应的银行系统返回的c信用卡的账单信息,将c信用卡的账单信息存储在第一存储系统中;获取d信用卡对应的银行系统返回的d信用卡的账单信息,将d信用卡的账单信息存储在第一存储系统中。

步骤205、将通过所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户。

此处,将发送异步查询请求从第二账户对应的银行系统获取到的该第二账户对应的账单信息发送至用户。

其中,通过将所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户,包括:通过轮询的方式从所述第一存储系统中获取所述第二账单信息并在轮询过程中将所述第二账单信息发送给所述用户。

此处,设置轮询机制从第一存储系统中查找第二账户对应的账单信息,若存在第二账户对应的账单信息,则将该账单信息发送至用户。也就是说,若每个第二账户对应的银行系统返回第二账单信息的时间不同,则每个第二账户在第一存储系统中存储第二账单信息的时间前后不同,轮询机制可以实现每存储一个第二账单信息,则将第二账单信息发送至用户。

在上一个示例中,若轮询机制每200ms查找一次第一存储系统,c信用卡对应的银行系统反应时间是400ms,d信用卡对应的银行系统反应时间是800ms;向c信用卡对应的银行系统和d信用卡对应的银行系统发起异步查询请求,400ms时获取到c信用卡对应的银行系统返回的c信用卡的账单信息,将c信用卡的账单信息存储在第一存储系统中,轮询机制查找第一存储系统先获取c信用卡的账单信息将c信用卡的账单信息发送至用户;800ms时获取到d信用卡对应的银行系统返回的d信用卡的账单信息,将d信用卡的账单信息存储在第一存储系统中,轮询机制查找第一存储系统获取d信用卡的账单信息将d信用卡的账单信息发送至用户。

采用上述方法,通过接收用户的账单查询请求查询第一存储系统中该用户的各账户的账单信息,并将第一存储系统中查找到的账单信息发送到用户端,若没有查找到的账单信息,则发起对应该账单信息账户的异步查询请求,将异步查询请求获得的账单信息发送至用户端。通过这种方式可以同时管理用户的多个账户,将第一存储系统中存在的账单信息先提供给用户,再将异步查询获取的第一存储系统中原来不存在的账单信息提供给用户,减少用户查询账单信息的等待时间。

基于上述流程,本申请实施例提供了一种账单查询的方法流程,如图3所示,包括:

步骤301、确定满足订阅要求的第三账户;所述订阅要求为所述用户预先设置的;

此处,订阅要求可以是设置信用卡对应的还款提醒请求、设置银行卡对应的固定日期的账单推送请求等预先设置的操作对应的请求。第三账户为符合订阅要求的账户,例如,今日为2019年2月28日,则订阅要求中设置还款提醒日为2019年2月28日的账户为第三账户。

其中,确定满足订阅要求的第三账户之前,还包括:将接收的所述第三账户的所述订阅要求存储至所述第二存储系统;根据从所述第二存储系统中获取的所述订阅要求,生成所述第三账户的订阅操作;在第三存储系统中写入所述订阅操作。

此处,第二存储系统可以为kafka、redis等存储系统。第三存储系统为存储订阅操作的数据库或存储系统。这里第二存储系统和第三存储系统可以有多个,以此可以根据数据量设置少的或更多的第二存储系统和/或第三存储系统。订阅操作为根据用户的订阅要求设置的相应操作,例如,订阅要求设置信用卡对应的还款提醒请求和设置银行卡对应的固定日期的账单推送请求对应的订阅操作为信用卡对应的还款提醒和银行卡对应的固定日期的账单推送。在确定满足订阅要求的第三账户之前,接收第三账户的订阅要求,存储至第二存储系统,再从第二存储系统中获取第三账户的订阅要求生成第三账户的订阅操作,将第三账户的订阅操作写入第三存储系统。例如,用户发送设置2019年2月28日为还款提醒日请求,将该请求缓存在第二存储系统中,从第二存储系统中获取设置2019年2月28日为还款提醒日请求,并根据该请求生成2019年2月28日发送提醒消息这一订阅操作,将2019年2月28日发送提醒消息这一订阅操作存储在第三存储系统中。以此,当2019年2月28日时,确定第三账户需要发送还款提醒。

步骤302、将从所述第一存储系统获取的所述第三账户的第三账单信息存储至第二存储系统;

此处,第三账单信息为对应第三账户的账单信息。确定满足订阅要求的第三账户后,从第一存储系统查找到该第三账户的第三账单信息,将第三账单信息存储在第二存储系统中。在上一个示例中,当2019年2月28日时,确定第三账户需要发送还款提醒,从第一存储系统查找到该第三账户的第三账单信息,将第三账单信息存储在第二存储系统中。

其中,将从所述第一存储系统获取的所述第三账户的第三账单信息存储至第二存储系统之前,还包括:确定所述第一存储系统是否存储有所述第三账单信息;若未存储所述第三账单信息,则向所述第三账户所在的银行系统发送所述异步查询请求;将通过所述异步查询请求获得的所述第三账单信息存储至所述第一存储系统。也就是说,在确定满足订阅要求的第三账户后,从第一存储系统没有查找到该第三账户的第三账单信息时,则向第三账户所在的银行系统发送异步查询请求,在每次接收到异步查询请求对应的第三账单信息后,将第三账单信息存储在第一存储系统中,继而,将从第一存储系统获取的第三账户的第三账单信息存储至第二存储系统,也可以在将第三账单信息存储在第一存储系统中的同时将第三账单信息存储在第二存储系统中。

步骤303、根据从所述第二存储系统中获取的所述第三账单信息,生成所述第三账户的提醒消息;

此处,第三账户的提醒消息可以为信用卡的还款提醒、银行卡的账单推送、游戏卡的账单推送等。

步骤304、将所述提醒消息发送至所述第三账户对应的所述用户。

此处,将提醒消息发送至第三账户对应的用户。

上述方法中,确定满足订阅要求的第三账户可以采用分布式任务的方式通过所述第三存储系统确定满足订阅要求的第三账户。

也就是说,第三存储系统可以有多个,每个第三存储系统中存储账户的订阅操作及对应的账户基本信息,每个第三存储系统对应一个子系统,该子系统可以用来确定满足订阅要求的第三账户。如此,每个子系统对应一个第三存储系统,当第三存储系统中的账户的订阅操作及对应的账户基本信息过多,对服务器处理工作造成压力,使得服务器处理工作变慢,则可以增加子系统和对应的第三存储系统,将子系统和对应的第三存储系统放置在另一个服务器上,可以加快服务器处理工作的速度。

其中,用户发送的所述账单查询请求是在接收到所述提醒消息后触发的。

此处,用户在接收到提醒消息后,可以通过点击该提醒消息发出账单查询请求,从第一存储系统中获取第一账户的第一账单信息发送至用户,减少了去银行系统获取账单信息的流程,可以快速将账单信息展示给用户。

采用上述方法,通过确定用户预先设置的订阅要求,从第一存储系统中获取第三账单信息,将账单信息存储到第二存储系统中并发送第三账户的提醒消息,将提醒消息发送至该第三账户对应的用户。通过这种方式,可以将第三账户的发送提醒消息的任务解耦到第二储存系统中,以此减轻第三存储系统和对应的子系统的工作压力,加快提醒消息的生成和发送。

基于图2和图3中的方法流程,本申请实施例提供了又一种账单查询的架构示意图,如图4所示,包括:

当用户在用户端查询账单时,向服务层401发送账单查询请求,服务层401接收到账单查询请求后,从第一存储系统(如redis)402中获取该用户的各账户对应的账单信息,将获取到的账单信息返回至用户,对于未获取到的账单信息向异步账单查询服务403发起异步查询账单请求;异步账单查询服务403创建对应未获取到账单信息的账户的异步查询请求,异步账单查询服务403将对应该账户的异步查询请求发送至该账户对应的银行接口404,异步账单查询服务403接收银行接口404返回的该账户的账单信息,并将该账户的账单信息发送至服务层401,由redis402存储;服务层401的轮询机制获取到该账户的账单信息,则发送至用户。

当该用户在用户端设置订阅要求后,服务层401接收订阅要求,并将接收订阅要求存储在第三存储系统(如kafka)405;数据库操作和提醒服务406从kafka405中获取订阅要求并生成订阅操作,将该用户的订阅操作存储在分布系统407中该用户账号所在的账号db数据库中;分布系统407为包括多个用于执行订阅操作的任务单元job,即分布式任务的方式进行订阅操作;具体的,job根据各订阅操作,确定该用户对应的账户为第三账户,分布系统407从redis402查询到该第三账户的账单信息,将该第三账户的账单信息发送至kafka405;数据库操作和提醒服务406从kafka405中获取该第三账户的账单信息生成提醒消息发送至用户。若分布系统407从redis402中没有查询该第三账户的账单信息,则向异步账单查询服务403发起异步查询账单请求;异步账单查询服务403创建对应该第三账户的异步查询请求,异步账单查询服务403将对应该第三账户的异步查询请求发送至该第三账户对应的银行接口404,异步账单查询服务403接收银行接口404返回的该第三账户的账单信息,并将该第三账户的账单信息发送至服务层401,由redis402存储,并同时发送至kafka405中;数据库操作和提醒服务406从kafka405中获取该第三账户的账单信息,生成提醒消息,发送至用户。

基于此,本申请实施例提供了一种账单查询的方法流程,如图5所示,包括:

步骤501、用户在用户端查询账单,对应发送账单查询请求至服务层。

步骤502、服务层接收到账单查询请求后,查询redis中是否含有该用户的各账户的账单信息,设该用户账单查询请求查询a、b、c、d信用卡对应的账单信息。

步骤503、若在redis中查询到信用卡a的账单信息,返回至用户。

步骤504、服务层接收到账单查询请求后,在redis中,没有查询到信用卡b、c、d的账单信息,则向异步账单查询服务发起账单查询请求。

步骤505、异步账单查询服务接收服务层发送的账单查询请求后创建异步查询信用卡b的账单信息请求并发送至银行接口。

步骤506、创建异步查询信用卡c的账单信息请求并发送至银行接口。

步骤507、创建异步查询信用卡d的账单信息请求并发送至银行接口。

步骤508、银行接口根据异步查询信用卡b的账单信息请求返回信用卡b的账单信息。

步骤509、异步账单查询服务将信用卡b的账单信息写入redis中。

步骤510、用户端轮询该用户的信用卡b、c、d的账单信息。

步骤511、服务层在redis中轮询该用户的信用卡b、c、d的账单信息。

步骤512、在redis中获取信用卡b的账单信息。

步骤513、将信用卡b的账单信息发送至用户。

步骤514、银行接口根据异步查询信用卡c的账单信息请求返回信用卡c的账单信息。

步骤515、异步账单查询服务将信用卡c的账单信息写入redis中。

步骤516、用户端轮询该用户的信用卡c、d的账单信息。

步骤517、服务层在redis中轮询该用户的信用卡c、d的账单信息。

步骤518、在redis中获取信用卡c的账单信息。

步骤519、将信用卡c的账单信息发送至用户。

步骤520、银行接口根据异步查询信用卡d的账单信息请求返回信用卡d的账单信息。

步骤521、异步账单查询服务将信用卡d的账单信息写入redis中。

步骤522、用户端轮询该用户的信用卡d的账单信息。

步骤523、服务层在redis中轮询该用户的信用卡d的账单信息。

步骤524、在redis中获取信用卡d的账单信息。

步骤525、将信用卡d的账单信息发送至用户。

基于图4架构,本申请实施例提供了一种账单查询的方法流程,如图6所示,包括:

步骤601、job轮询其对应的账户db数据库,确定a、b、c信用卡为第三账户,也就是a、b、c信用卡需要获取其对应的账单信息。

步骤602、job从redis中查询a、b、c信用卡的账单信息。

步骤603、job获取到a信用卡的账单信息,未获取到b、c信用卡的账单信息。job将a信用卡的账单信息写入kafka中。

步骤604、数据库操作和提醒服务从kafka中获取到a信用卡的账单信息,生成提醒消息。

步骤605、数据库操作和提醒服务将a信用卡的提醒消息发送至用户。

步骤606、job向异步账单查询服务发送异步查询信用卡b、c账单信息请求。

步骤607、异步账单查询服务接收异步查询信用卡b、c账单信息请求,创建异步查询信用卡b的账单信息的请求并发送至银行接口。

步骤608、异步账单查询服务创建异步查询信用卡c的账单信息的请求并发送至银行接口。

步骤609、银行接口返回信用卡b的账单信息。

步骤610、异步账单查询服务将信用卡b的账单信息写入redis中。

步骤611、异步账单查询服务将信用卡b的账单信息写入kafka中。

步骤612、数据库操作和提醒服务获取信用卡b的账单信息,并生成提醒消息。

步骤613、数据库操作和提醒服务将提醒消息发送至用户。

步骤614、银行接口返回信用卡c的账单信息。

步骤615、异步账单查询服务将信用卡c的账单信息写入redis中。

步骤616、异步账单查询服务将信用卡c的账单信息写入kafka中。

步骤617、数据库操作和提醒服务获取信用卡c的账单信息,并生成提醒消息。

步骤618、数据库操作和提醒服务将提醒消息发送至用户。

这里需要说明的是,图5和图6中所述的流程步骤顺序不唯一,如图5中的步骤503和步骤504可以同时进行,也可以步骤504在步骤503前进行。图6中的步骤604和步骤606可以同时进行,也可以步骤606在步骤604前进行。

基于同样的构思,本发明实施例提供一种账单查询的装置,图7为本申请实施例提供的账单查询的装置示意图,如图7示,包括:

接收模块701,用于接收用户的账单查询请求;

处理模块702,用于根据所述账单查询请求,从第一存储系统中查找所述用户的各账户的账单信息;

发送模块703,用于将从所述第一存储系统查询到的所述用户的第一账户的第一账单信息发送给所述用户;

所述发送模块703还用于,向所述用户的第二账户所在的银行系统发起异步查询请求,所述第二账户为所述用户的各账户中除所述第一账户之外的账户;

所述发送模块703还用于,将通过所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户。

在一种可能的设计中,所述发送模块703具体用于:针对每个第二账户,创建所述第二账户的异步查询请求并发送至所述第二账户所在的银行系统;将从所述第二账户所在的银行系统获取的所述第二账户的第二账单信息存储在所述第一存储系统。

在一种可能的设计中,所述发送模块703具体用于:通过轮询的方式从所述第一存储系统中获取所述第二账单信息并在轮询过程中将所述第二账单信息发送给所述用户。

在一种可能的设计中,所述处理模块702还用于:

确定满足订阅要求的第三账户;所述订阅要求为所述用户预先设置的;将从所述第一存储系统获取的所述第三账户的第三账单信息存储至第二存储系统;根据从所述第二存储系统中获取的所述第三账单信息,生成所述第三账户的提醒消息;

所述发送模块703还用于,将所述提醒消息发送至所述第三账户对应的所述用户。

在一种可能的设计中,所述接收模块701还用于:所述账单查询请求是在接收到所述提醒消息后触发的。

在一种可能的设计中,所述处理模块702还用于:确定所述第一存储系统是否存储有所述第三账单信息;若未存储所述第三账单信息,则向所述第三账户所在的银行系统发送所述异步查询请求;将通过所述异步查询请求获得的所述第三账单信息存储至所述第一存储系统。

在一种可能的设计中,所述处理模块702还用于:将接收的所述第三账户的所述订阅要求存储至所述第二存储系统;根据从所述第二存储系统中获取的所述订阅要求,生成所述第三账户的订阅操作;在第三存储系统中写入所述订阅操作。

在一种可能的设计中,包括:采用分布式任务的方式通过所述第三存储系统确定满足订阅要求的第三账户。

本领域内的技术人员应明白,本申请的实施例可提供为方法、系统、或计算机程序产品。因此,本申请可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且,本申请可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、cd-rom、光学存储器等)上实施的计算机程序产品的形式。

本申请是参照根据本申请的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。

显然,本领域的技术人员可以对本申请进行各种改动和变型而不脱离本申请的精神和范围。这样,倘若本申请的这些修改和变型属于本申请权利要求及其等同技术的范围之内,则本申请也意图包含这些改动和变型在内。


技术特征:

1.一种账单查询的方法,其特征在于,包括:

接收用户的账单查询请求;

根据所述账单查询请求,从第一存储系统中查找所述用户的各账户的账单信息;

将从所述第一存储系统查询到的所述用户的第一账户的第一账单信息发送给所述用户;

向所述用户的第二账户所在的银行系统发起异步查询请求,所述第二账户为所述用户的各账户中除所述第一账户之外的账户;

将通过所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户。

2.如权利要求1所述的方法,其特征在于,向所述用户的第二账户所在的银行系统发起异步查询请求,包括:

针对每个第二账户,创建所述第二账户的异步查询请求并发送至所述第二账户所在的银行系统;

将从所述第二账户所在的银行系统获取的所述第二账户的第二账单信息存储在所述第一存储系统。

3.如权利要求1所述的方法,其特征在于,通过将所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户,包括:

通过轮询的方式从所述第一存储系统中获取所述第二账单信息并在轮询过程中将所述第二账单信息发送给所述用户。

4.如权利要求1所述的方法,其特征在于,所述方法还包括:

确定满足订阅要求的第三账户;所述订阅要求为所述用户预先设置的;

将从所述第一存储系统获取的所述第三账户的第三账单信息存储至第二存储系统;

根据从所述第二存储系统中获取的所述第三账单信息,生成所述第三账户的提醒消息;

将所述提醒消息发送至所述第三账户对应的所述用户。

5.如权利要求4所述的方法,其特征在于,所述方法包括:

所述账单查询请求是在接收到所述提醒消息后触发的。

6.如权利要求4所述的方法,其特征在于,将从所述第一存储系统获取的所述第三账户的第三账单信息存储至第二存储系统之前,还包括:

确定所述第一存储系统是否存储有所述第三账单信息;

若未存储所述第三账单信息,则向所述第三账户所在的银行系统发送所述异步查询请求;

将通过所述异步查询请求获得的所述第三账单信息存储至所述第一存储系统。

7.如权利要求4所述的方法,其特征在于,确定满足订阅要求的第三账户之前,还包括:

将接收的所述第三账户的所述订阅要求存储至所述第二存储系统;

根据从所述第二存储系统中获取的所述订阅要求,生成所述第三账户的订阅操作;

在第三存储系统中写入所述订阅操作。

8.如权利要求7所述的方法,其特征在于,确定满足订阅要求的第三账户,包括:

采用分布式任务的方式通过所述第三存储系统确定满足订阅要求的第三账户。

9.一种账单查询的装置,其特征在于,所述装置包括:

接收模块,用于接收用户的账单查询请求;

处理模块,用于根据所述账单查询请求,从第一存储系统中查找所述用户的各账户的账单信息;

发送模块,用于将从所述第一存储系统查询到的所述用户的第一账户的第一账单信息发送给所述用户;

所述发送模块还用于,向所述用户的第二账户所在的银行系统发起异步查询请求,所述第二账户为所述用户的各账户中除所述第一账户之外的账户;

所述发送模块还用于,将通过所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户。

10.一种计算设备,其特征在于,包括:

存储器,用于存储程序指令;

处理器,用于调用所述存储器中存储的程序指令,按照获得的程序执行权利要求1至8任一项所述的方法。

11.一种计算机可读非易失性存储介质,其特征在于,包括计算机可读指令,当计算机读取并执行所述计算机可读指令时,使得计算机执行如权利要求1至8任一项所述的方法。

技术总结
本发明实施例提供一种账单查询的方法及装置,该方法包括:接收用户的账单查询请求;根据所述账单查询请求,从第一存储系统中查找所述用户的各账户的账单信息;将从所述第一存储系统查询到的所述用户的第一账户的第一账单信息发送给所述用户;向所述用户的第二账户所在的银行系统发起异步查询请求,所述第二账户为所述用户的各账户中除所述第一账户之外的账户;将通过所述异步查询请求获得的所述第二账户的第二账单信息发送给所述用户。采用上述方法,可以同时管理用户的多个账户,将第一存储系统中存在的账单信息先提供给用户,再将异步查询获取的账单信息提供给用户,减少用户查询账单信息所用的时间。

技术研发人员:周自飞;李丽
受保护的技术使用者:中国银联股份有限公司
技术研发日:2020.02.03
技术公布日:2020.06.09

转载请注明原文地址: https://bbs.8miu.com/read-25380.html

最新回复(0)