基于区块链的交易数据处理方法、系统、设备及存储介质

摘要

本发明涉及区块链技术领域，公开了一种基于区块链的交易数据处理方法、系统、设备及存储介质，方法包括：区块链上的业务受理节点接收第一交易数据，将第一交易数据进行格式转换得到第二交易数据；通过调用智能合约对第二交易数据进行校验得到校验结果；基于校验结果和第二交易数据生成摘要信息，对第二交易数据加密得到加密信息，对加密信息和摘要信息执行区块上链操作。通过将各个渠道商接入区块链，在各个渠道商接入的业务受理节点上定义统一的数据格式，用户进行申购产生的交易数据均会被转换为统一格式送到区块链上校验及存储，这样不仅缩短了IPO申购过程时间，避免用户资金被长时间占用，并且还可以解决渠道商间的数据敏感问题。

说明书

技术领域

本发明涉及区块链技术领域，涉及了一种基于区块链的交易数据处理方法、系统、设备及存储介质。

背景技术

目前港交所证券行业的IPO(Initial Public Offering，首次公开募股)过程中，各个渠道商(如券商、证监会、交易所管网、分销商等)均会进行发售，从而用户的申购数据是来自于不同的渠道商的数据库，在IPO募股结束后，各个渠道商将申购数据会同步到中心化服务器进行统一汇总和校验，由于多个渠道商的数据汇总到一起，存在各种各样的问题需要处理，例如，同一用户在多个渠道商重复性申购、不同渠道商提交的申购数据格式不统一等问题，因此，申购数据在汇总过程中，校验十分繁琐，这样就拉长了整个IPO周期，导致用户资金被占用以及容易受到股价变动影响的问题。

发明内容

本发明的目的是针对上述现有技术的不足提出的一种基于区块链的交易数据处理方法、系统、设备及存储介质，该目的是通过以下技术方案实现的。

本发明的第一方面提出了一种基于区块链的交易数据处理方法，所述方法包括：

区块链上的业务受理节点接收客户端发起的第一交易数据，并将所述第一交易数据进行格式转换，得到第二交易数据；

通过调用智能合约对所述第二交易数据进行校验，得到校验结果；

基于所述校验结果和所述第二交易数据生成摘要信息，并对所述第二交易数据加密得到加密信息，对所述加密信息和所述摘要信息执行区块上链操作。

本发明的第二方面提出了一种基于区块链的交易数据处理系统，所述系统包括多个业务受理节点，每个业务受理节点包括接收模块、格式转换模块、校验模块、上链操作模块；

其中，所述接收模块，用于区块链上的业务受理节点接收客户端发起的第一交易数据；

所述格式转换模块，用于将所述第一交易数据进行格式转换，得到第二交易数据；

所述校验模块，用于通过调用智能合约对所述第二交易数据进行校验，得到校验结果；

所述上链操作模块，用于基于所述校验结果和所述第二交易数据生成摘要信息，并对所述第二交易数据加密得到加密信息，对所述加密信息和所述摘要信息执行区块上链操作。

本发明的第三方面提出了一种计算机设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述处理器执行所述程序时实现如上述第一方面所述的基于区块链的交易数据处理方法的步骤。

本发明的第四方面提出了一种计算机可读存储介质，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如上述第一方面所述的基于区块链的交易数据处理方法的步骤。

基于上述第一方面所述的基于区块链的交易数据处理方法，具有如下有益效果：

通过将各个渠道商接入区块链联盟链上，并且在各个渠道商接入的业务受理节点上定义统一规范的申购数据格式，从而用户在各个渠道商上进行申购产生的交易数据，均会按照统一规范的申购数据格式实时被转换为统一格式的交易数据并送到区块链上调用智能合约进行校验及存储，这样不仅缩短了IPO申购过程时间，避免用户资金被长时间占用，并且由于申购数据上链是加密存储，还可以解决渠道商间的数据敏感问题，同时数据上链后也方便后续的数据追溯。

附图说明

此处所说明的附图用来提供对本发明的进一步理解，构成本发明的一部分，本发明的示意性实施例及其说明用于解释本发明，并不构成对本发明的不当限定。在附图中：

图1为本发明根据一示例性实施例示出的一种基于区块链的交易数据处理方法的实施例流程图；

图2为本发明根据一示例性实施例示出的一种计算机设备的硬件结构示意图；

图3为本发明根据一示例性实施例示出的一种基于区块链的交易数据处理系统的结构示意图。

具体实施方式

这里将详细地对示例性实施例进行说明，其示例表示在附图中。下面的描述涉及附图时，除非另有表示，不同附图中的相同数字表示相同或相似的要素。以下示例性实施例中所描述的实施方式并不代表与本发明相一致的所有实施方式。相反，它们仅是与如所附权利要求书中所详述的、本发明的一些方面相一致的装置和方法的例子。

在本发明使用的术语是仅仅出于描述特定实施例的目的，而非旨在限制本发明。在本发明和所附权利要求书中所使用的单数形式的“一种”、“所述”和“该”也旨在包括多数形式，除非上下文清楚地表示其他含义。还应当理解，本文中使用的术语“和/或”是指并包含一个或多个相关联的列出项目的任何或所有可能组合。

应当理解，尽管在本发明可能采用术语第一、第二、第三等来描述各种信息，但这些信息不应限于这些术语。这些术语仅用来将同一类型的信息彼此区分开。例如，在不脱离本发明范围的情况下，第一信息也可以被称为第二信息，类似地，第二信息也可以被称为第一信息。取决于语境，如在此所使用的词语“如果”可以被解释成为“在……时”或“当……时”或“响应于确定”。

目前港交所创建IPO后，会在线上公开发售，各个散户、机构大户都会进行申购，并且购买渠道多种多样，机构大户购买也各有各的购买系统，最后散户、机构大户的申购数据汇集到一起后缴费，由于各个购买渠道的数据有各种各样，还有数据重复的问题，例如散户在A平台申购后，又去B平台申购，并且各个平台上生成的申购数据的格式也各种各样，这样在中心服务器进行汇总时，数据收集与处理非常耗时。

为解决上述技术问题，本发明提出一种基于区块链的交易数据处理方法，通过将各个渠道商接入港交所IPO区块链联盟链上，并且在各个渠道商接入节点上定义统一规范的申购数据格式，从而用户在各个渠道商上进行申购产生的交易数据，均会按照统一规范的申购数据格式实时被转换为统一格式的交易数据并送到区块链上调用智能合约进行校验及存储，这样交易数据的整个处理过程均在区块链上实时完成，不仅缩短了IPO申购过程时间，避免用户资金被长时间占用，并且由于申购数据上链是加密存储，还可以解决渠道商间的数据敏感问题，同时数据上链后也方便后续的数据追溯。

下面以具体实施例对本发明提出的基于区块链的交易数据处理方法的实现进行详细阐述。

图1为本发明根据一示例性实施例示出的一种基于区块链的交易数据处理方法的实施例流程图，本实施例中所涉及的区块链包括业务受理节点、共识节点以及汇总节点，这些节点可以在同一个设备实现，也可以在不同设备上实现。在证券IPO场景中，业务受理节点可以是渠道商接入节点，用于为渠道商提供服务，用户终端通过安装渠道商提供的APP客户端可以进行IPO申购操作，不同渠道商可以接入不同的业务受理节点，共识节点用于根据共识机制提供共识服务，汇总节点用于对各个业务受理节点上产生的交易数据进行汇总处理。下面以IPO场景为例对图1所示的实施例进行说明。

如图1所示，该基于区块链的交易数据处理方法包括如下步骤：

步骤101：区块链上的业务受理节点接收客户端发起的第一交易数据，并将该第一交易数据进行格式转换，得到第二交易数据。

其中，业务受理节点即为渠道商接入的节点，客户端即为渠道商提供的APP客户端，用户在操作APP客户端进行IPO申购操作过程中，渠道商的业务受理节点会接收到APP客户端生成的交易数据。

示例性的，该第一交易数据可以包括交易内容、交易到达的节点、交易流水号和用户ID等。交易内容用于描述交易的具体内容，例如交易发起方、交易接收方、交易金额、交易数量、交易摘要等内容。交易流水号表示发起该交易的客户端所发起的交易所对应的序号。用户ID代表发起该交易用户的唯一标识，也即向渠道商注册的唯一账号标识。

在一些实施例中，由于不同渠道商所使用的业务受理节点的操作系统或编码语言不同，因此通常在各个业务受理节点上接收到的交易数据的格式各种各样，从而需要在每个业务受理节点上定义一种规范的交易数据格式，并按照该格式对接收的交易数据进行统一格式转换，得到统一格式的交易数据。

基于此，针对将该第一交易数据进行格式转换，得到第二交易数据的过程，通过对第一交易数据进行解析，以获得预设规范格式包含的各个属性字段的内容，然后根据获得的各个属性字段的内容，按照所述预设规范格式中各个属性字段的排列顺序生成第二交易数据。

其中，属性字段可以包括交易发起方、交易接收方、交易时间、交易币种、申购数量、交易流水号、交易金额、用户身份等字段。需要说明的是，用户身份指的是注册账户类型(如散户、机构等)和用户ID。

步骤102：通过调用智能合约对第二交易数据进行校验，得到校验结果。

在一些实施例中，如果交易规则是不允许同一用户重复性申购，在接收到交易数据时，可以通过智能合约对交易数据进行重复性校验。

基于此，针对通过调用智能合约对第二交易数据进行校验的过程，可以先获取所述第二交易数据中的用户ID，通过调用智能合约查找区块链上是否存有所述用户ID的第三交易数据，如果有，则向客户端返回重复性申购的通知，并生成拒绝申购的校验结果，如果没有，则向客户端返回允许申购的通知，并生成允许申购的校验结果。这样，如果用户收到重复性申购的通知，便可以不进行后续的缴费申请，进而避免了用户资金被长时间占用的问题。

需要说明的是，由于重复性校验的目的是为了让同一用户只成功申购一次，因此在区块链上查找的第三交易数据的状态应该为申购成功的状态或申购中的状态，但如果区块链上存有该用户ID的交易数据，但状态为申购失败的状态或申购撤销的状态，那么均会向客户端返回允许申购的通知。

在另一些实施例中，如果交易规则是允许同一用户可以重复性申购，在接收到交易数据时，还可以通过智能合约对交易数据进行合并校验。

基于此，针对通过调用智能合约对第二交易数据进行校验的过程，还可以先获取所述第二交易数据中的用户ID，通过调用智能合约查找区块链上是否存有所述用户ID的第四交易数据，如果有，则获取所述第四交易数据的交易流水号，并将所述第四交易数据的交易流水号添加到所述第二交易数据中，生成重复申购的校验结果，如果没有，则生成首次申购的校验结果。

其中，由于合并校验的目的是为了将同一用户通过不同渠道商提供的平台进行申购的交易数据进行合并，因此在区块链上查找的第四交易数据的状态可以是任意状态。也就是说，用户在各个渠道商提供的平台上的交易均会被汇总起来。

需要说明的是，上述校验实施例仅为示例性说明，当然还可以是对交易数据进行其他类型的校验，例如数据结构是否符合相应区块链系统的要求，相应客户端是否有能力支付该笔交易等。

步骤103：基于该校验结果和该第二交易数据生成摘要信息，并对该第二交易数据加密得到加密信息，对该加密信息和该摘要信息执行区块上链操作。

其中，业务受理节点所生成的摘要信息是用于为该笔交易数据提供索引，以便于后续查询使用。

在一些实施例中，针对基于校验结果和第二交易数据生成摘要信息的过程，可以从第二交易数据中提取与用户身份相关的身份信息，并依据所提取的身份信息、校验结果以及当前的申购状态生成第二交易数据的摘要信息，区块链上的任意节点均可通过查找摘要信息了解该笔交易的情况。

其中，交易数据的申购状态包括申购成功、申购失败、申购中、撤销等。申购成功指的是用户支付成功，申购失败指的是用户未支付成功，申购中指的是用户发起交易后一直未支付，撤销指的是用户发起交易后又取消交易。由此可知，摘要信息中的申购状态会随着用户的操作进行实时变化。

示例性的，与用户身份相关的身份信息可以是账户名、身份证号、护照号、姓名、性别等信息。

需要说明的是，在对该加密信息和该摘要信息执行区块上链操作之前，还可以由区块链上提供的共识机制对第二交易数据进行共识，该共识过程可以是：业务受理节点将该加密信息和第二交易数据发送给区块链上的共识节点，共识节点对接收到的加密信息进行解密，得到加密信息对应的交易数据，然后判断是否与接收的第二交易数据一致，若一致，则向业务受理节点返回共识成功的通知，若不一致，则向业务受理节点返回共识失败的通知，业务受理节点在接收到共识成功的通知时，对该加密信息和该摘要信息执行区块上链操作。

其中，加密信息和第二交易数据可以以广播方式发送给区块链上的共识节点。

需要说明的是，在IPO发售结束后，区块链上的港交所的接入节点(即区块链上的汇总节点)可以获取到所有渠道商的交易信息，并按照渠道商对交易信息进行分组汇总，同时对各渠道商的交易数量进行排序以生成排序报表。

基于此，汇总过程可以是：区块链上的汇总节点通过获取区块链上的所有加密信息，然后针对每一加密信息，利用该加密信息所属业务受理节点授权的公钥解密该加密信息，得到对应的交易数据，然后对解密得到的所有交易数据按照业务受理节点进行分组汇总，并按照属于每个业务受理节点的交易数据的统计数量生成排名报表。

举例说明，假设区块链上包括业务受理节点1、业务受理节点2、业务受理节点3，这三个业务受理节点可以代表三个不同的渠道商。区块链上的汇总节点的汇总结果为：解密得到的属于业务受理节点1的交易数据为20条，解密得到的属于业务受理节点2的交易数据为90条，解密得到属于业务受理节点3的交易数据为300条，生成的排名报表的排名顺序为业务受理节点3、业务受理节点2、业务受理节点1。

至此，完成上述图1所示的处理流程，通过将各个渠道商接入区块链联盟链上，并且在各个渠道商接入的业务受理节点上定义统一规范的申购数据格式，从而用户在各个渠道商上进行申购产生的交易数据，均会按照统一规范的申购数据格式实时被转换为统一格式的交易数据并送到区块链上调用智能合约进行校验及存储，这样交易数据的整个处理过程均在区块链上实时完成，不仅缩短了IPO申购过程时间，避免用户资金被长时间占用，并且由于申购数据上链是加密存储，还可以解决渠道商间的数据敏感问题，同时数据上链后也方便后续的数据追溯。

图2为本发明根据一示例性实施例示出的一种计算机设备的硬件结构示意图。如图2所示，该计算机设备包括通过系统总线连接的处理器、存储介质、存储器和网络接口，所述存储介质可以是非易失性的，也可以是易失性的。其中，该计算机设备的存储介质存储有操作系统、数据库和计算机可读指令，数据库中可存储有控件信息序列，该计算机可读指令被处理器执行时，可使得处理器实现上文描述的基于区块链的交易数据处理方法。该计算机设备的处理器用于提供计算和控制能力，支撑整个计算机设备的运行，该计算机设备可以运行区块链。该计算机设备的存储器中可存储有计算机可读指令，处理器执行计算机可读指令时实现以下步骤：区块链上的业务受理节点接收客户端发起的第一交易数据，并将所述第一交易数据进行格式转换，得到第二交易数据；通过调用智能合约对所述第二交易数据进行校验，得到校验结果；基于所述校验结果和所述第二交易数据生成摘要信息，并对所述第二交易数据加密得到加密信息，对所述加密信息和所述摘要信息执行区块上链操作。

在一实施例中，所述处理器所执行的将所述第一交易数据进行格式转换，得到第二交易数据的步骤包括：对所述第一交易数据进行解析，以获得预设规范格式包含的各个属性字段的内容；根据获得的各个属性字段的内容，按照所述预设规范格式中各个属性字段的排列顺序生成第二交易数据。

在一实施例中，所述处理器所执行的通过调用智能合约对所述第二交易数据进行校验，得到校验结果的步骤包括：获取所述第二交易数据中的用户ID；通过调用智能合约查找区块链上是否存有所述用户ID的第三交易数据；如果有，则向所述客户端返回重复性申购的通知，并生成拒绝申购的校验结果；如果没有，则向所述客户端返回允许申购的通知，并生成允许申购的校验结果。

在一实施例中，所述处理器所执行的通过调用智能合约对所述第二交易数据进行校验，得到校验结果的步骤包括：获取所述第二交易数据中的用户ID；通过调用智能合约查找区块链上是否存有所述用户ID的第四交易数据；如果有，则获取所述第四交易数据的交易流水号，并将所述第四交易数据的交易流水号添加到所述第二交易数据中，生成重复申购的校验结果；如果没有，则生成首次申购的校验结果。

在一实施例中，所述处理器所执行的基于所述校验结果和所述第二交易数据生成摘要信息的步骤包括：从所述第二交易数据中提取与用户身份相关的身份信息；依据所提取的身份信息、所述校验结果以及当前的申购状态生成第二交易数据的摘要信息。

在一实施例中，处理器执行计算机可读指令时还执行以下步骤：业务受理节点在对所述加密信息和所述摘要信息执行区块上链操作之前，将所述加密信息和所述第二交易数据发送给所述区块链上的共识节点；所述共识节点对加密信息进行解密，得到所接收到的加密信息对应的交易数据，并判断是否与已接收的第二交易数据一致，若一致，则向所述业务受理节点返回共识成功的通知，若不一致，则向所述业务受理节点返回共识失败的通知；所述业务受理节点在接收到共识成功的通知时，对所述加密信息和所述摘要信息执行区块上链操作。

在一实施例中，处理器执行计算机可读指令时还执行以下步骤：所述区块链上的汇总节点获取所述区块链上的所有加密信息；针对每一加密信息，利用该加密信息所属业务受理节点授权的公钥解密该加密信息，得到对应的交易数据；对所有解密得到的交易数据按照业务受理节点进行分组汇总，并按照属于每个业务受理节点的交易数据的统计数量生成排名报表。

本领域技术人员可以理解，上述图2中示出的结构，仅仅是与本发明方案相关的部分结构的框图，并不构成对本发明方案所应用于其上的计算机设备的限定，具体的计算机设备可以包括比图中所示更多或更少的部件，或者组合某些部件，或者具有不同的部件布置。

与前述基于区块链的交易数据处理方法的实施例相对应，本发明还提供了基于区块链的交易数据处理系统的实施例。

图3为本发明根据一示例性实施例示出的一种基于区块链的交易数据处理系统的结构示意图，该基于区块链的交易数据处理系统包括业务受理节点310、共识节点320及汇总节点330。可以理解的是，各种类型的节点可以是多个。如图3所示，该业务受理节点310包括：接收模块311、格式转换模块312、校验模块313、上链操作模块314；

其中，所述接收模块311，用于区块链上的业务受理节点接收客户端发起的第一交易数据；

所述格式转换模块312，用于将所述第一交易数据进行格式转换，得到第二交易数据；

所述校验模块313，用于通过调用智能合约对所述第二交易数据进行校验，得到校验结果；

所述上链操作模块314，用于基于所述校验结果和所述第二交易数据生成摘要信息，并对所述第二交易数据加密得到加密信息，对所述加密信息和所述摘要信息执行区块上链操作。

在一可选实现方式中，所述格式转换模块312，具体用于对所述第一交易数据进行解析，以获得预设规范格式包含的各个属性字段的内容；根据获得的各个属性字段的内容，按照所述预设规范格式中各个属性字段的排列顺序生成第二交易数据。

在一可选实现方式中，所述校验模块313，具体用于获取所述第二交易数据中的用户ID；通过调用智能合约查找区块链上是否存有所述用户ID的第三交易数据；如果有，则向所述客户端返回重复性申购的通知，并生成拒绝申购的校验结果；如果没有，则向所述客户端返回允许申购的通知，并生成允许申购的校验结果。

在一可选实现方式中，所述校验模块313，还具体用于获取所述第二交易数据中的用户ID；通过调用智能合约查找区块链上是否存有所述用户ID的第四交易数据；如果有，则获取所述第四交易数据的交易流水号，并将所述第四交易数据的交易流水号添加到所述第二交易数据中，生成重复申购的校验结果；如果没有，则生成首次申购的校验结果。

在一可选实现方式中，所述上链操作模块314，具体用于在基于所述校验结果和所述第二交易数据生成摘要信息过程中，从所述第二交易数据中提取与用户身份相关的身份信息；依据所提取的身份信息、所述校验结果以及当前的申购状态生成第二交易数据的摘要信息。

在一可选实现方式中，所述上链操作模块314，还用于在对所述加密信息和所述摘要信息执行区块上链操作之前将所述加密信息和所述第二交易数据发送给所述区块链上的共识节点320，以及在接收到共识成功的通知时，对所述加密信息和所述摘要信息执行区块上链操作；所述共识节点320，用于对加密信息进行解密，得到所接收到的加密信息对应的交易数据，并判断是否与已接收的第二交易数据一致，若一致，则向所述业务受理节点310返回共识成功的通知，若不一致，则向所述业务受理节点310返回共识失败的通知。

在一可选实现方式中，所述汇总节点330，用于获取所述区块链上的所有加密信息；针对每一加密信息，利用该加密信息所属业务受理节点授权的公钥解密该加密信息，得到对应的交易数据；对所有解密得到的交易数据按照业务受理节点进行分组汇总，并按照属于每个业务受理节点的交易数据的统计数量生成排名报表。

本发明还提供了另一种实施方式，即提供一种计算机可读存储介质，该计算机可读存储介质上存储有计算机程序，该计算机程序可被至少一个处理器执行，以使至少一个处理器执行上文描述的任意一种基于区块链的交易数据处理方法的步骤。

本领域技术人员在考虑说明书及实践这里公开的发明后，将容易想到本发明的其它实施方案。本发明旨在涵盖本发明的任何变型、用途或者适应性变化，这些变型、用途或者适应性变化遵循本发明的一般性原理并包括本发明未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的，本发明的真正范围和精神由下面的权利要求指出。

还需要说明的是，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、商品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、商品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括所述要素的过程、方法、商品或者设备中还存在另外的相同要素。

以上所述仅为本发明的较佳实施例而已，并不用以限制本发明，凡在本发明的精神和原则之内，所做的任何修改、等同替换、改进等，均应包含在本发明保护的范围之内。