CN115048198A - 基于分布式交互系统的业务处理方法、装置、设备及介质 - Google Patents
基于分布式交互系统的业务处理方法、装置、设备及介质 Download PDFInfo
- Publication number
- CN115048198A CN115048198A CN202210521829.0A CN202210521829A CN115048198A CN 115048198 A CN115048198 A CN 115048198A CN 202210521829 A CN202210521829 A CN 202210521829A CN 115048198 A CN115048198 A CN 115048198A
- Authority
- CN
- China
- Prior art keywords
- transaction
- type
- operations
- transaction operation
- processed
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/48—Program initiating; Program switching, e.g. by interrupt
- G06F9/4806—Task transfer initiation or dispatching
- G06F9/4843—Task transfer initiation or dispatching by program, e.g. task dispatcher, supervisor, operating system
- G06F9/4881—Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/04—Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Business, Economics & Management (AREA)
- Finance (AREA)
- General Physics & Mathematics (AREA)
- Physics & Mathematics (AREA)
- Accounting & Taxation (AREA)
- Software Systems (AREA)
- General Engineering & Computer Science (AREA)
- Development Economics (AREA)
- Economics (AREA)
- Marketing (AREA)
- Strategic Management (AREA)
- Technology Law (AREA)
- General Business, Economics & Management (AREA)
- Financial Or Insurance-Related Operations Such As Payment And Settlement (AREA)
Abstract
本申请提供一种基于分布式交互系统的业务处理方法、装置、设备及介质,可应用于金融领域。该方法包括:获取用户的交易操作请求,所述交易操作请求包括交易类型字段;响应于所述交易操作请求,确定所述用户的待处理交易操作;调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,所述共有执行操作是通过分析各种交易操作得到,各种所述交易操作包括共有执行操作和特定交易操作;若确定处理完所述共有执行操作,则根据所述交易类型字段确定对应的待调用交易类型接口;调用所述交易类型接口处理所述特定交易操作,以完成所述待处理交易操作。采用本申请的方法,能使分布式交互系统的量级轻简,降低开发难度。
Description
技术领域
本申请涉及分布式交互系统技术,尤其涉及一种基于分布式交互系统的业务处理方法、装置、设备及介质。
背景技术
随着分布式交互系统技术的发展,为了适应于网络交易的发展,出现了基于各金融机构的分布式交互系统的业务处理方法。
目前,网络交易模式主要是:用户、商家将银行卡与第三方机构绑定,才能使用户通过购物APP与商家间进行网络交易。在这种网络交易模式下,由于不同第三方机构的交易报文数据结构不同,每个银行需要分别针对不同第三方机构构建适配的分布式交互系统,如分布式交互系统的软件基础框架,以为实现交易操作构建底层运算逻辑支撑。
然而,这种网购模式下的分布式交互系统,由于字段名称、交易报文上的差异性,对于每个第三方机构,金融机构服务器针对每一种交易操作通常需要开发一个专用的调用接口,以完成交易操作,使得分布式交互系统的量级不够轻简,增大了开发过程的开发难度。
发明内容
本申请提供一种基于分布式交互系统的业务处理方法、装置、设备及介质,用以解决现有技术中分布式交互系统的量级不够轻简,增加了开发难度的技术问题。
第一方面,本申请提供一种基于分布式交互系统的业务处理方法,包括:
获取用户的交易操作请求,所述交易操作请求包括交易类型字段;
响应于所述交易操作请求,确定所述用户的待处理交易操作;
调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,所述共有执行操作是通过分析各种交易操作得到,各种所述交易操作包括共有执行操作和特定交易操作;
若确定处理完所述共有执行操作,则根据所述交易类型字段确定对应的待调用交易类型接口;
调用所述交易类型接口处理所述特定交易操作,以完成所述待处理交易操作。
第二方面,本申请提供一种基于分布式交互系统的业务处理装置,包括:
操作请求模块,用于获取用户的交易操作请求,所述操作请求包括交易类型字段;
操作确定模块,用于响应于所述交易操作请求,确定所述用户的待处理交易操作;
共有操作执行模块,用于调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,所述共有执行操作是通过分析各种交易操作得到,各种所述交易操作包括共有执行操作和特定交易操作;
接口类型确定模块,用于若确定处理完所述共有执行操作,则根据所述交易类型字段确定调用对应的交易类型接口;
特定操作执行模块,用于调用所述交易类型接口处理所述特定交易操作,以完成所述待处理交易操作。
第三方面,本申请提供一种金融机构服务器,包括:处理器,以及与所述处理器通信连接的存储器;
所述存储器存储计算机执行指令;
所述处理器执行所述存储器存储的计算机执行指令,以实现第一方面所述的方法。
第四方面,本申请提供一种计算机可读存储介质,所述计算机可读存储介质中存储有计算机执行指令,所述计算机执行指令被处理器执行时用于实现第一方面所述的方法。
第五方面,本申请提供一种计算机程序产品,包括计算机程序,该计算机程序被处理器执行时实现第一方面所述的方法。
本申请提供的基于分布式交互系统的业务处理方法、装置、设备及介质,获取用户的交易操作请求,所述交易操作请求包括交易类型字段;响应于所述交易操作请求,确定所述用户的待处理交易操作;调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,所述共有执行操作是通过分析各种交易操作得到,各种所述交易操作包括共有执行操作和特定交易操作;若确定处理完所述共有执行操作,则根据所述交易类型字段确定对应的待调用交易类型接口;调用所述交易类型接口处理所述特定交易操作,以完成所述待处理交易操作。由于对于各种交易操作,将涉及共有执行操作的调用统一处理接口处理,从而无需像传统方式中,针对每种交易操作分别设置一个专用接口,通过该专用接口处理整个的待处理交易操作。因而基于本方法,可以使得分布式交互系统的量级更为轻简,在开发时不必再为每种交易操作分别开发一个执行整个待处理交易操作的逻辑链路,可以减小开发过程的难度。
附图说明
此处的附图被并入说明书中并构成本说明书的一部分,示出了符合本申请的实施例,并与说明书一起用于解释本申请的原理。
图1为实现本申请实施例的基于分布式交互系统的业务处理方法的一种应用场景图;
图2为本申请一实施例的实现基于分布式交互系统的业务处理方法的流程示意图;
图3为本申请另一实施例的实现基于分布式交互系统的业务处理方法的流程示意图;
图4为本申请实现基于分布式交互系统的业务处理方法的结构示意图;
图5为用来实现基于分布式交互系统的业务处理方法中的金融机构服务器的结构示意图。
通过上述附图,已示出本申请明确的实施例,后文中将有更详细的描述。这些附图和文字描述并不是为了通过任何方式限制本申请构思的范围,而是通过参考特定实施例为本领域技术人员说明本申请的概念。
具体实施方式
这里将详细地对示例性实施例进行说明,其示例表示在附图中。下面的描述涉及附图时,除非另有表示,不同附图中的相同数字表示相同或相似的要素。以下示例性实施例中所描述的实施方式并不代表与本申请相一致的所有实施方式。相反,它们仅是与如所附权利要求书中所详述的、本申请的一些方面相一致的装置和方法的例子。
首先对本申请所涉及的名词进行解释:
分布式交互系统:是指建立在网络之上的基础组件框架,包括接入层和服务逻辑层,接入层获取数据,服务逻辑层对数据进行业务逻辑处理。
为了清楚理解本申请的技术方案,首先对现有技术的方案进行详细介绍。
传统方式中,网络交易模式主要是:用户、商家将银行卡与第三方机构绑定,才能使用户通过购物APP与商家间进行网络交易。在这种网络交易模式下,由于不同第三方机构的交易报文数据结构不同,每个银行需要分别针对不同第三方机构构建适配的分布式交互系统,如分布式交互系统的软件基础框架,以为实现交易操作构建底层运算逻辑支撑。然而,这种网购模式下的分布式交互系统,由于字段名称、交易报文上的差异性,对于每个第三方机构,金融机构服务器针对每一种交易操作通常需要开发一个专用的调用接口,以完成交易操作,使得分布式交互系统的量级不够轻简,增大了开发过程的开发难度。
所以在面对现有技术的技术问题时,发明人通过创造性的研究后发现,为了使得分布式交互系统的量级尽可能轻简,减小开发过程的开发难度。因此,对于各种类型的交易操作的特定交易操作分别调用对于的交易类型接口处理,而将各种类型的交易操作的共有执行操作通过调用一个统一处理接口依次进行处理。具体地,在获取到用户的交易操作请求时,根据其中的交易类型字段确定待处理交易操作,无论待处理交易操作属于何种类型的交易操作,均可先调用统一处理接口对待处理交易操作中涉及到的共有执行操作依次进行处理,而后再调用与待处理交易操作类型对应的交易类型接口处理特定交易操作,从而完成待处理交易操作。由于对于各种交易操作,将涉及共有执行操作的调用统一处理接口处理,从而可以使得分布式交互系统的量级更为轻简,在开发时不必再为每种交易操作分别开发一个执行整个待处理交易操作的逻辑链路,可以减小开发过程的难度。
如图1所示,本申请实施例提供的基于分布式交互系统的业务处理方法的应用场景,在该应用场景中对应的网络架构中包括金融机构服务器20和用户终端10,用户终端10与金融机构服务器20进行通信连接。用户终端10安装有金融机构商城,用户可以通过金融机构商城进行网络交易,金融机构商城与金融机构服务器20对应两个不同的金融机构,例如金融机构商城可以对应是A银行的银行商城,金融机构服务器20可以对应是B银行的服务器。用户通过金融机构商城进行网络交易时,金融机构服务器20首先获取到用户的交易操作请求,确定用户的待处理交易操作,再调用分布式交互系统的统一处理接口对其涉及的共有执行操作进行处理,后调用对应的交易类型接口处理特定交易操作,从而完成待处理交易操作,完成待处理交易操作时可以指令形式返回给用户终端10以告知用户。图1所示的金融机构服务器20可以为一个服务器集群,服务器集群中包括n个金融机构服务器20,图1仅显示了金融机构服务器1和金融机构服务器n。通常,用户终端10与服务器集群中的一个金融机构服务器20进行交互即可,但在金融机构服务器20处理的交易操作量较多时,也可以转发给服务器集群中的其他服务器进行处理,或者也可以采用限制业务操作量的流量方式由该金融机构服务器20处理。
下面以具体地实施例对本申请的技术方案以及本申请的技术方案如何解决上述技术问题进行详细说明。下面这几个具体的实施例可以相互结合,对于相同或相似的概念或过程可能在某些实施例中不再赘述。下面将结合附图,对本申请的实施例进行描述。
图2是本申请一实施例提供的基于分布式交互系统的业务处理方法,如图2所示,本实施例提供的基于分布式交互系统的业务处理方法的执行主体是金融机构服务器。则本实施例提供的基于分布式交互系统的业务处理方法,包括以下步骤:
步骤101,获取用户的交易操作请求,交易操作请求包括交易类型字段。
其中,用户的交易操作请求是用户终端监测到用户在金融机构的商城进行交易操作时,向金融机构服务器发送的请求指令。交易类型字段是指表示用户交易操作类型的字段,例如,支付即支付交易操作对应的交易类型字段。
步骤102,响应于交易操作请求,确定用户的待处理交易操作。
具体地,金融机构服务器响应于交易操作请求,根据交易操作请求中的交易类型字段可以确定待处理交易操作的类型。待处理交易操作是用户当前需要处理的交易操作。
步骤103,调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,共有执行操作是通过分析各种交易操作得到,各种交易操作包括共有执行操作和特定交易操作。
其中,统一处理接口是人为基于特有业务类型,提取各业务类型的公共特性,标准化服务调用过程,定义统一接口标准得到的接口。共有执行操作是人工通过分析各种类型的交易操作得到的,具体是梳理各种类型的交易操作之间共有的执行操作得到。各种类型的交易操作,除了共有执行操作,还有非共有的执行操作,即仅属于每种类型交易操作的特定交易操作。即,各种交易操作均包括共有执行操作和特定交易操作。
调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理。依次进行处理是指按照固定的执行顺序,对各共有执行操作进行处理。对于每个交易操作请求,无论其所属的交易操作类型,均按照该固定的执行顺序依次执行涉及的共有执行操作。
步骤104,若确定处理完共有执行操作,则根据交易类型字段确定对应的待调用交易类型接口。
具体地,对于相近种类的交易操作,其涉及共有执行操作相同,对于完全不同种类的交易操作,其涉及的共有执行操作不完全相同。因此,并非所有类型的交易操作具有完全一致的共有执行操作。金融机构服务器在确定处理完共有执行操作时,是根据分布式交互系统的接入层所获取的交易类型字段,确定待处理交易操作所属的类型,并根据待处理交易操作所属的类型确定最后一个共有执行操作,当监测到执行完最后一个共有执行操作时,确定处理完共有执行操作。在确定处理完共有执行操作之后,根据交易类型字段确定对应的待调用交易类型接口。其中,交易类型接口是专门为各种交易操作的特定交易操作设置的接口,调用交易类型接口处理对应的特定交易操作。
步骤105,调用交易类型接口处理特定交易操作,以完成待处理交易操作。
具体地,在处理完待交易操作涉及的共有执行操作之后,再调用交易类型接口处理对应的特定交易操作,在特定交易操作完成后,即完成整个待处理交易操作。
本申请中的基于分布式交互系统的业务处理方法,获取用户的交易操作请求,交易操作请求包括交易类型字段;响应于交易操作请求,确定用户的待处理交易操作;调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,共有执行操作是通过分析各种交易操作得到,各种交易操作包括共有执行操作和特定交易操作;若确定处理完共有执行操作,则根据交易类型字段确定对应的待调用交易类型接口;调用交易类型接口处理特定交易操作,以完成待处理交易操作。由于对于各种交易操作,将涉及共有执行操作的调用统一处理接口处理,从而无需像传统方式中,针对每种交易操作分别设置一个专用接口,通过该专用接口处理整个的待处理交易操作。因而基于本方法,可以使得分布式交互系统的量级更为轻简,在开发时不必再为每种交易操作分别开发一个执行整个待处理交易操作的逻辑链路,可以减小开发过程的难度。
作为一种可选实施方式,共有执行操作包括报文获取、日志记录和字段校验。
具体地,报文获取是指金融机构服务器获取用户的交易报文,交易报文包括交易类型字段和用户信息。日志记录是指金融机构服务器实时监控待处理交易操作的处理过程,如出现异常或者校验失败的情况则进行记录。字段校验是指对表示用户信息的字段和交易类型字段进行校验。
本实施例提供的基于分布式交互系统的业务处理方法,无论何种类型的交易操作,均会涉及报文获取、日志记录和字段校验,固化这些共有执行操作,调用统一处理接口进行处理,从而使只具有这些共有执行操作的交易操作可以无需另外开发对应的专用处理接口,可以减小开发难度。
作为一种可选实施方式,交易操作的类型包括以下类型的任意一种:账务类交易操作和非账务类交易操作。
其中,账务类交易操作是指涉及财务交易的交易操作类型,例如支付、退款等,是相近种类的交易操作,其涉及的共有执行操作相同。非账务类交易操作是指不涉及财务交易的交易操作类型,例如用户签约电子银行。财务类交易操作和非财务类交易操作是完全不同种类的交易操作,其涉及的共有执行操作不完全相同。前述的交易类型字段可以是支付、退款和签约等,根据具体的支付、退款和签约等交易类型字段,可以判断待处理交易操作所属的交易操作的类型。前述的各种交易应理解为账务类交易操作和非账务类交易操作下更具体的交易类型,例如支付、退款和签约等。
本实施例提供的基于分布式交互系统的业务处理方法,根据交易操作的类型分为账务类交易操作和非财务类交易操作,其分别对应的共有执行操作虽然是不完全相同的,但金融机构服务器在确定待处理交易操作所属的类型后,可以对应确定何时处理完共有执行操作,从而有利于提高共有执行操作的包容度,减少开发难度。
作为一种可选实施方式,如图3所示,待处理交易操作的类型为非账务类交易操作时,步骤103,包括以下步骤:
步骤201,调用统一处理接口获取用户的交易报文,将交易报文上送至数据库中。
其中,金融机构服务器获取到用户的交易操作请求时,即调用统一处理接口获取用户的交易报文,交易报文包括交易类型字段和用户信息。在获取到用户的交易报文时,金融机构服务器将交易报文写入到底层业务数据库中。
步骤202,对交易报文进行日志记录,以获得业务初始日志。
其中,对交易报文进行日志记录,是指金融机构服务器对获取到的交易报文的初始情况进行记录。业务初始日志是基于对交易报文的初始情况进行日志记录后,所获得的初始业务日志。对交易报文进行日志记录的目的是,确保待处理交易操作出现异常后能在持久化的数据库中查到交易信息,定位问题发生的环节。
步骤203,对交易报文的各个字段进行字段校验。
具体地,对交易报文中涉及的各个字段进行校验,称为字段校验,具体校验是根据对应的字段类型,确定对应的校验规则。例如,交易报文中表示手机号的字段,是否为合法的手机号。对各个字段进行字段校验的目的是,确保交易报文中各字段是合法字段。
本实施例提供的基于分布式交互系统的业务处理方法,调用统一处理接口获取用户的交易报文,将交易报文上送至数据库中;对交易报文进行日志记录,以获得业务初始日志;对交易报文的各个字段进行字段校验。由于待处理交易操作的类型为非财务类交易操作,不涉及财务交易,因此将交易报文的日志记录和字段的校验确定为非财务类交易操作的共有执行操作,较为准确。
作为一种可选实施方式,待处理交易操作为账务类交易操作时,在步骤203之后,还包括步骤301,将各字段中通过字段校验的第一类字段进行交易准入检查,根据第一类字段中通过交易准入检查的第二类字段以生成流水号。
具体地,第一类字段是指在进行字段校验过程中通过校验的字段,且该通过校验的字段与财务交易相关。在前述的待处理交易操作为非账务类交易操作时,仅校验字段本身的合法性,各字段包括与财务交易相关的字段,也包括与财务交易不相关的字段。
当待处理交易操作为账务类交易操作时,涉及到财务交易,因此还需在字段校验之后,对第一类字段进行交易准入检查。交易准入检查可以校验第一类字段是否符合交易合法性。第二类字段是第一类字段中能够通过交易准入检查的字段。若根据交易准入检查从第一类字段中筛选出第二类字段,则确定各个环节均符合交易的合法性要求,此时可以根据第二类字段校验通过的时间点生成流水号的时间戳,根据第二类字段所属的交易类型确定流水号的交易类型,可以确保全局唯一性。
本实施例提供的基于分布式交互系统的业务处理方法,将各字段中通过字段校验的第一类字段进行交易准入检查,根据第一类字段中通过交易准入检查的第二类字段以生成流水号。由于待处理交易操作的类型为财务类交易操作,涉及财务交易,因此还需进行交易准入检查,以确保账务类交易操作的安全性。
作为一种可选实施方式,步骤201的将交易报文上送至数据库中,包括以下步骤:
步骤301,库中存储的各动态数据库的可用状态标识,确定第一动态数据库是否可用,第一动态数据库为金融机构服务器的底层业务数据库。
其中,数据库包括全局数据库和动态数据库,全局数据库存储的内容包括全局变量,全局变量呈静态,因而全局数据库且趋于稳定。动态数据库存储的内容包括动态变量,动态变量呈动态,因而动态数据库的稳定性较差。此处动态变量可以是交易报文中的字段数据,动态数据库是服务器上的底层业务数据库。
包括金融机构服务器在内的各服务器,均包括一个全局数据库和至少一个动态数据库。在全局数据库中存储有动态数据库的可用状态标识,可用状态标识是标志动态数据库是否为可用状态的标识。可用状态标识可以用具体的值标识,当可用状态标识为第一值时,则确定动态数据库可用;当可用状态标识为第二值时,则确定动态数据库不可用。例如,第一值可以为1,第二值为-1,若金融机构服务器查找全局数据库时确定动态数据库为1,则确定动态数据库可用。
其中,第一动态数据库是金融机构服务器上的底层业务数据库。
步骤302,若第一动态数据库可用,则将交易报文上送至第一动态数据库中。
其中,第一动态数据库可用是指,动态数据库中的数据交易量或者CPU使用程度相对较低,可以用于继续存储以及更新交易报文等,此时可以将交易报文上送至第一动态数据库中。
步骤303,若第一动态数据库不可用,则将交易报文上送至可用的第二动态数据库中存储,第二动态数据库为与金融机构服务器组成服务器集群的其他服务器的底层业务数据库。
其中,第一动态数据库不可用是指,动态数据库中的数据交易量或者CPU使用程度相对较高,无法继续存储以及更新交易报文等,此时可以将交易报文转发给第二动态数据库中存储,第二动态数据库是金融机构服务器确定的可用的动态数据库。如前述,金融机构服务器是具体处理交易业务的服务器,金融机构服务器所处理的交易业务也可以通过服务器集群中的其他服务器进行处理。如前述,服务器集群中的每个服务器,包括金融机构服务器在内,均有至少一个动态数据库,第二动态数据库即其他服务器的动态数据库,也是一种底层业务数据库。
本实施例提供的基于分布式交互系统的业务处理方法,根据全局数据库中存储的各动态数据库的可用状态标识,确定第一动态数据库是否可用,第一动态数据库为金融机构服务器的底层业务数据库;若第一动态数据库可用,则将交易报文上送至第一动态数据库中;若第一动态数据库不可用,则将交易报文上送至可用的第二动态数据库中存储,第二动态数据库为与金融机构服务器组成服务器集群的其他服务器的底层业务数据库。当第一动态数据库可用时,则仍由金融机构服务器的第一动态数据库处理交易报文,只有在第一动态数据库不可用时,将交易报文转发到其他服务器的第二动态数据库中,从而使得动态数据库更好地处理交易报文。
作为一种可选实施方式,步骤301,包括:根据待处理交易操作的类型对应的准入检查策略,对各字段中通过字段校验的第一类字段进行交易准入检查,以确定待处理交易操作是否交易合法。
其中,对于每种类型的交易操作,均有对应的准入检查策略,例如针对具体的支付交易操作,准入检查策略包括检测支付银行卡是否为异常状态等;针对具体的退款交易操作,准入检查策略包括检测用户是否恶意申请退款等。在对第一类字段进行交易准入检查时,根据待处理交易操作的类型,确定与之对应的准入检查策略,从而对第一类字段进行交易准入检查。
本实施例提供的基于分布式交互系统的业务处理方法,根据待处理交易操作的类型对应的准入检查策略,对各字段中通过字段校验的第一类字段进行交易准入检查,以确定待处理交易操作是否交易合法。由于根据待处理交易操作的类型,确定对应的准入检查策略对第一字段进行检查,从而可以更准确地校验待处理交易操作是否交易合法。
作为一种可选实施方式,步骤103,还包括:将各字段中未通过字段校验的第三类字段、以及第一类字段中未通过交易准入检查的第四类字段进行日志记录,以获得业务过程日志。
其中,业务过程日志记录的是在字段校验以及交易准入检查未通过的字段,记录的目的是,便于后续根据输出的业务过程日志,确定哪些字段存在问题,或者,在对待处理交易操作过程中,若出现问题,可以确定是问题出现在业务方面还者是分布式交互系统上
本实施例提供的基于分布式交互系统的业务处理方法,由于将各字段中未通过字段校验的第三类字段、以及第一类字段中未通过交易准入检查的第四类字段进行日志记录,以获得业务过程日志。通过获取业务过程日志,若待处理交易操作出现问题,便于定位是否为业务出现问题。
作为一种可选实施方式,交易类型接口包括特定账务类操作接口和特定非账务类操作接口,特定交易操作包括特定账务类操作和特定非账务类操作。
作为一种可选实施方式,步骤105之后,基于分布式交互系统的业务处理方法,还包括:若获取到用户查询交易操作结果的请求,则从数据库中获取更新后的交易报文,将更新后的交易报文中的交易操作结果发送给用户,更新后的交易报文是完成待处理交易操作之后更新的交易报文。
具体地,交易操作结果是金融机构服务器完成待处理交易操作之后得到的结果,例如,用户累计支付金额,交易操作结果以更新后的交易报文形式存储于数据库中。更新后的交易报文是完成待处理交易操作之后即在数据库中进行更新的交易报文。当用户需要查询交易操作结果时,向金融机构服务器发起查询交易操作结果的请求,金融机构服务器获取到查询交易操作结果的请求时,会从数据库中获取更新后的交易报文,将更新后的交易报文中的交易操作结果发送给用户终端,以使用户获取到交易操作结果。
本实施例提供的基于分布式交互系统的业务处理方法,若获取到所述用户查询交易操作结果的请求,则从所述数据库中获取更新后的交易报文,将所述更新后的交易报文中的交易操作结果发送给用户,所述更新后的交易报文是完成所述待处理交易操作之后更新的交易报文。金融机构服务器在完成待处理交易操作之后,即对数据库中的交易报文进行更新,从而便于后续查询或核对工作。
图4是本申请一实施例提供的基于分布式交互系统的业务处理装置40的结构示意图,如图4所示,本实施例提供的基于分布式交互系统的业务处理装置40位于金融机构服务器中,则本实施例提供的基于分布式交互系统的业务处理装置40,包括:操作请求模块41,操作确定模块42,共有操作执行模块43,接口类型确定模块44和特定操作执行模块45。
其中,操作请求模块41,用于获取用户的交易操作请求,操作请求包括交易类型字段。操作确定模块42,用于响应于交易操作请求,确定用户的待处理交易操作。共有操作执行模块43,用于调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,共有执行操作是通过分析各种交易操作得到,各种交易操作包括共有执行操作和特定交易操作。接口类型确定模块44,用于若确定处理完共有执行操作,则根据交易类型字段确定调用对应的交易类型接口。特定操作执行模块45,用于调用交易类型接口处理特定交易操作,以完成待处理交易操作。
可选地,共有操作执行模块43中的共有执行操作包括报文获取、日志记录、字段校验、交易准入检查和流水号生成。
可选地,共有操作执行模块43中的交易操作的类型包括以下类型的任意一种:账务类交易操作和非账务类交易操作。
可选地,待处理交易操作的类型为非账务类交易操作时,共有操作执行模块43中的调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,具体用于:调用统一处理接口获取用户的交易报文,将交易报文上送至数据库中;对交易报文进行日志记录,以获得业务初始日志;对交易报文的各个字段进行字段校验。
可选地,待处理交易操作为账务类交易操作;基于分布式交互系统的业务处理,还包括交易准入检查模块,具体用于:将各字段中通过字段校验的第一类字段进行交易准入检查,根据第一类字段中通过交易准入检查的第二类字段以生成流水号。
可选地,共有操作执行模块43中的将交易报文上送至数据库中,具体用于:根据全局数据库中存储的各动态数据库的可用状态标识,确定第一动态数据库是否可用,第一动态数据库为金融机构服务器的底层业务数据库;若第一动态数据库可用,则将交易报文上送至第一动态数据库中;若第一动态数据库不可用,则将交易报文上送至可用的第二动态数据库中存储,第二动态数据库为与金融机构服务器组成服务器集群的其他服务器的底层业务数据库。
可选地,交易准入检查模块中的将各字段中通过字段校验的第一类字段进行交易准入检查,具体用于:根据待处理交易操作的类型对应的准入检查策略,对各字段中通过字段校验的第一类字段进行交易准入检查,以确定待处理交易操作是否交易合法。
可选地,共有操作执行模块43,还具体用于:将各字段中未通过字段校验的第三类字段、以及第一类字段中未通过交易准入检查的第四类字段进行日志记录,以获得业务过程日志。
可选地,交易类型接口包括特定账务类操作接口和特定非账务类操作接口,特定交易操作包括特定账务类操作和特定非账务类操作。
可选地,基于分布式交互系统的业务处理装置40,还包括结果查询模块,具体用于:若获取到用户的查询交易操作结果,则从数据库中获取更新后的交易报文,更新后的交易报文是进行特定交易操作之后更新的交易报文。
图5是根据一示例性实施例示出的一种金融机构服务器的框图,该设备可以是如图5所示,金融机构服务器,包括:存储器51,处理器52;存储器51用于存储处理器可执行指令的存储器;处理器52用于运行计算机程序或指令,以实现如上任意一个实施例提供的基于分布式交互系统的业务处理方法。
其中,存储器51,用于存放程序。具体地,程序可以包括程序代码,程序代码包括计算机操作指令。存储器51可能包含高速RAM存储器,也可能还包括非易失性存储器(non-volatile memory),例如至少一个磁盘存储器。
其中,处理器52可能是一个中央处理器(Central Processing Unit,简称为CPU),或者是特定集成电路(Application Specific Integrated Circuit,简称为ASIC),或者是被配置成实施本公开实施例的一个或多个集成电路。
可选的,在具体实现上,如果存储器51和处理器52独立实现,则存储器51和处理器52可以通过总线53相互连接并完成相互间的通信。总线53可以是工业标准体系结构(Industry Standard Architecture,简称为ISA)总线53、外部设备互连(PeripheralComponent,简称为PCI)总线53或扩展工业标准体系结构(Extended Industry StandardArchitecture,简称为EISA)总线53等。总线53可以分为地址总线53、数据总线53、控制总线53等。为便于表示,图5中仅用一条粗线表示,但并不表示仅有一根总线53或一种类型的总线53。
可选的,在具体实现上,如果存储器51和处理器52集成在一块芯片上实现,则存储器51和处理器52可以通过内部接口完成相同间的通信。
一种非临时性计算机可读存储介质,当该存储介质中的指令由金融机构服务器的处理器执行时,使得金融机构服务器能够执行上述金融机构服务器的基于分布式交互系统的业务处理方法。
本领域技术人员在考虑说明书及实践这里公开的发明后,将容易想到本申请的其它实施方案。本申请旨在涵盖本申请的任何变型、用途或者适应性变化,这些变型、用途或者适应性变化遵循本申请的一般性原理并包括本申请未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的,本申请的真正范围和精神由下面的权利要求书指出。
应当理解的是,本申请并不局限于上面已经描述并在附图中示出的精确结构,并且可以在不脱离其范围进行各种修改和改变。本申请的范围仅由所附的权利要求书来限制。
Claims (14)
1.一种基于分布式交互系统的业务处理方法,应用于金融机构服务器上,其特征在于,所述方法包括:
获取用户的交易操作请求,所述交易操作请求包括交易类型字段;
响应于所述交易操作请求,确定所述用户的待处理交易操作;
调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,所述共有执行操作是通过分析各种交易操作得到,各种所述交易操作包括共有执行操作和特定交易操作;
若确定处理完所述共有执行操作,则根据所述交易类型字段确定对应的待调用交易类型接口;
调用所述交易类型接口处理所述特定交易操作,以完成所述待处理交易操作。
2.根据权利要求1所述的方法,其特征在于,所述共有执行操作包括报文获取、日志记录、字段校验。
3.根据权利要求2所述的方法,其特征在于,所述交易操作的类型包括以下类型的任意一种:账务类交易操作和非账务类交易操作。
4.根据权利要求3所述的方法,其特征在于,所述待处理交易操作的类型为所述非账务类交易操作;所述调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,包括:
调用所述统一处理接口获取所述用户的交易报文,将所述交易报文上送至数据库中;
对所述交易报文进行日志记录,以获得业务初始日志;
对所述交易报文的各个字段进行字段校验。
5.根据权利要求4所述的方法,其特征在于,所述待处理交易操作为账务类交易操作;对所述交易报文的各个字段进行字段校验之后,还包括:
将各所述字段中通过所述字段校验的第一类字段进行交易准入检查,根据所述第一类字段中通过所述交易准入检查的第二类字段以生成流水号。
6.根据权利要求5所述的方法,其特征在于,将所述交易报文上送至数据库中,包括:
根据全局数据库中存储的各动态数据库的可用状态标识,确定第一动态数据库是否可用,所述第一动态数据库为所述金融机构服务器的底层业务数据库;
若所述第一动态数据库可用,则将所述交易报文上送至所述第一动态数据库中;
若所述第一动态数据库不可用,则将所述交易报文上送至可用的第二动态数据库中存储,所述第二动态数据库为与所述金融机构服务器组成服务器集群的其他服务器的底层业务数据库。
7.根据权利要求5所述的方法,其特征在于,将各所述字段中通过所述字段校验的第一类字段进行交易准入检查,包括:
根据所述待处理交易操作的类型对应的准入检查策略,对各所述字段中通过所述字段校验的第一类字段进行交易准入检查,以确定所述待处理交易操作是否交易合法。
8.根据权利要求5所述的方法,其特征在于,所述调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,还包括:
将各所述字段中未通过所述字段校验的第三类字段、以及所述第一类字段中未通过所述交易准入检查的第四类字段进行日志记录,以获得业务过程日志。
9.根据权利要求1-8任一项所述的方法,其特征在于,所述交易类型接口包括特定账务类操作接口和特定非账务类操作接口,所述特定交易操作包括特定账务类操作和特定非账务类操作。
10.根据权利要求9所述的方法,其特征在于,调用所述交易类型接口处理所述特定交易操作,以完成所述待处理交易操作之后,所述方法还包括:
若获取到所述用户查询交易操作结果的请求,则从所述数据库中获取更新后的交易报文,将所述更新后的交易报文中的交易操作结果发送给用户,所述更新后的交易报文是完成所述待处理交易操作之后更新的交易报文。
11.一种基于分布式交互系统的业务处理装置,其特征在于,所述装置包括:
操作请求模块,用于获取用户的交易操作请求,所述操作请求包括交易类型字段;
操作确定模块,用于响应于所述交易操作请求,确定所述用户的待处理交易操作;
共有操作执行模块,用于调用统一处理接口对待处理交易操作中涉及的共有执行操作依次进行处理,所述共有执行操作是通过分析各种交易操作得到,各种所述交易操作包括共有执行操作和特定交易操作;
接口类型确定模块,用于若确定处理完所述共有执行操作,则根据所述交易类型字段确定调用对应的交易类型接口;
特定操作执行模块,用于调用所述交易类型接口处理所述特定交易操作,以完成所述待处理交易操作。
12.一种金融机构服务器,包括:处理器,以及与所述处理器通信连接的存储器;
所述存储器存储计算机执行指令;
所述处理器执行所述存储器存储的计算机执行指令,以实现如权利要求1-10中任一项所述的方法。
13.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质中存储有计算机执行指令,所述计算机执行指令被处理器执行时用于实现如权利要求1-10任一项所述的方法。
14.一种计算机程序产品,包括计算机程序,该计算机程序被处理器执行时实现权利要求1-10中任一项所述的方法。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210521829.0A CN115048198A (zh) | 2022-05-13 | 2022-05-13 | 基于分布式交互系统的业务处理方法、装置、设备及介质 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210521829.0A CN115048198A (zh) | 2022-05-13 | 2022-05-13 | 基于分布式交互系统的业务处理方法、装置、设备及介质 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN115048198A true CN115048198A (zh) | 2022-09-13 |
Family
ID=83157865
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202210521829.0A Pending CN115048198A (zh) | 2022-05-13 | 2022-05-13 | 基于分布式交互系统的业务处理方法、装置、设备及介质 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN115048198A (zh) |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20120078794A1 (en) * | 1996-10-31 | 2012-03-29 | Citicorp Development Center, Inc. | System and Method for Delivering Financial Services |
| CN111857888A (zh) * | 2020-07-10 | 2020-10-30 | 中国建设银行股份有限公司 | 一种交易处理方法及装置 |
| CN114049122A (zh) * | 2021-11-30 | 2022-02-15 | 中国建设银行股份有限公司 | 一种业务处理方法和系统 |
| CN114119206A (zh) * | 2021-11-30 | 2022-03-01 | 中国工商银行股份有限公司 | 卡组织数据的处理方法和处理装置 |
-
2022
- 2022-05-13 CN CN202210521829.0A patent/CN115048198A/zh active Pending
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20120078794A1 (en) * | 1996-10-31 | 2012-03-29 | Citicorp Development Center, Inc. | System and Method for Delivering Financial Services |
| CN111857888A (zh) * | 2020-07-10 | 2020-10-30 | 中国建设银行股份有限公司 | 一种交易处理方法及装置 |
| CN114049122A (zh) * | 2021-11-30 | 2022-02-15 | 中国建设银行股份有限公司 | 一种业务处理方法和系统 |
| CN114119206A (zh) * | 2021-11-30 | 2022-03-01 | 中国工商银行股份有限公司 | 卡组织数据的处理方法和处理装置 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| TWI705346B (zh) | 基於中心化結算與區塊鏈存證的交易方法及系統 | |
| EP3629272A1 (en) | Method and device for running chaincode | |
| CN110262889B (zh) | 一种链路追踪方法及装置 | |
| WO2020029629A1 (zh) | 一种基于中心化结算与区块链存证的交易方法及系统 | |
| CN110309022B (zh) | 模拟交易测试的方法、模拟器、设备及存储介质 | |
| CN105389488B (zh) | 身份认证方法及装置 | |
| CN110020846B (zh) | 一种转账业务处理方法及系统 | |
| CN111415146A (zh) | 资源数据的处理方法、装置及设备 | |
| CN113835780A (zh) | 一种事件响应方法及装置 | |
| WO2020082829A1 (zh) | 一种用户年龄预测方法、装置及设备 | |
| CN115061924A (zh) | 自动化测试案例的生成方法、生成装置 | |
| CN113807969A (zh) | 一种业务系统并行验证方法及相关设备 | |
| CN111367776A (zh) | 资源转移业务的记录方法、装置、设备及存储介质 | |
| CN115187336A (zh) | 订单处理方法、装置和设备及存储介质 | |
| CN119941387A (zh) | 一种平台盾的确定方法和相关装置 | |
| CN111932255B (zh) | 一种基于加密货币实现交易对账的方法和装置 | |
| CN116107781A (zh) | 日志追踪方法、装置、电子设备、及计算机程序产品 | |
| CN117743306A (zh) | 数据迁移方法、装置、计算机设备和存储介质 | |
| CN115048198A (zh) | 基于分布式交互系统的业务处理方法、装置、设备及介质 | |
| CN111737262B (zh) | 一种数据处理方法及装置 | |
| CN110348843A (zh) | 资源整合方法、装置、计算机装置及存储介质 | |
| US10217087B2 (en) | Multicomputer processing of client device request data using centralized event orchestrator | |
| CN116010171A (zh) | 资源记录处理方法、装置、计算机设备和存储介质 | |
| CN115248697A (zh) | 系统灰度升级方法、装置、电子设备和存储介质 | |
| CN114549205A (zh) | 交易流程的处理方法、装置、处理器及电子设备 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20220913 |