CN115311092A - 用于资源处理系统的方法、装置，资源处理系统以及计算机可读存储介质 - Google Patents

Abstract

公开了一种用于资源处理系统的方法，包括：在第一处理时段的第一时刻，将资源处理系统的待结算资源流水数据同步至结算系统用于结算；在第一处理时段的第二时刻，中止资源处理系统的业务，接收结算系统的结算数据，并用之对资源处理系统进行更新，其中，在第一处理时段的第二时刻之前，保持资源处理系统的业务；将资源处理系统的处理时段从第一处理时段切换至其后的下一个处理时段；响应于切换，还原资源处理系统在第二时刻之前的未经结算的资源处理对应的用户指令并再次执行；以及结束中止，以继续资源处理系统的业务。还公开了相应的装置、设备和计算机可读存储介质等。

Description

用于资源处理系统的方法、装置，资源处理系统以及计算机可 读存储介质

技术领域

本公开涉及资源处理技术领域，特别涉及一种用于资源处理系统的方法、装置，资源处理系统以及计算机可读存储介质。

背景技术

通常，资源处理（例如金融领域的交易）系统，与其结算系统是相互独立的。由于面向全球的资源处理系统往往需要持续不断地运行，这对交易系统与结算系统的同步带来了强挑战。

目前在金融领域中，交易系统与结算系统同步的通用做法是，在每日的结算时间，交易系统暂停交易，并将待结算的数据发送到结算系统，等待结算系统完成结算后，将结算数据同步至交易系统，交易系统切换日期，而后再开启下一日的交易。通常，结算系统日终结算的时间一般是下午16：00-19：00之间，交易系统需在此期间停摆，但这样就不能提供持续的交易服务，特别对于面向全球的交易，往往是每个交易日23小时不间断的，如果由于系统的结算限制了交易，会导致用户体验不佳。

发明内容

有鉴于此，本公开提供了一种用于资源处理系统的方法、装置、资源处理系统以及计算机可读存储介质，可以缓解、减轻或甚至消除上述问题。

根据本公开的第一方面，提供一种用于资源处理系统的方法。该方法包括步骤：在第一处理时段的第一时刻，将资源处理系统的待结算资源流水数据同步至结算系统用于结算，以便结算系统生成结算数据；在第一处理时段的第二时刻，中止资源处理系统的业务，接收结算系统的结算数据，并用结算数据对资源处理系统进行更新，其中，在第一处理时段的第二时刻之前，保持资源处理系统的业务，其中，业务包括对用户指令进行接收和相应的业务处理，第二时刻是第一处理时段结束的时刻；将资源处理系统的处理时段从第一处理时段切换至其后的下一个处理时段；响应于切换，还原资源处理系统在第二时刻之前的未经结算的资源处理对应的用户指令，并再次执行第二时刻之前的未经结算的资源处理对应的用户指令；以及结束中止，以继续资源处理系统的业务。

在一个实施例中，对用户指令进行相应的业务处理包括：建立指令队列，用于按接收顺序存储用户指令；按照资源处理系统的业务规则处理用户指令；以及建立临时流水列表，用于记录成功执行的用户指令产生的资源流水数据。

在一个实施例中，建立指令队列进一步包括：对用户指令进行分类，其中影响用户的资源的指令归入第一类用户指令，而不影响用户的资源的指令归入第二类用户指令，将第一类用户指令存储到第一类指令队列中，并将第二类用户指令存储到第二类指令队列中；以及建立临时流水列表进一步包括：在执行用户指令产生的流水数据中，仅将第一类指令队列中成功执行的用户指令产生的资源流水数据存储到临时流水列表中。

在一个实施例中，建立指令队列进一步包括：将第一类用户指令封装成数据结构，数据结构中包括用户指令的信息、时间戳和序列号；将数据结构存储到第一类指令队列中。

在一个实施例中，建立临时流水列表进一步包括：在执行用户指令产生的流水数据中，仅将第一类指令队列中成功执行的用户指令产生的原始资源流水数据存储到临时流水列表中。

在一个实施例中，还原资源处理系统在第二时刻之前的未经结算的资源处理对应的用户指令进一步包括：基于临时流水列表中的未结算数据，按相同顺序生成对应的用户指令对应的数据结构，其中数据结构中的时间戳取值为生成对应的用户指令对应的数据结构时的时间戳；以及将所生成的数据结构存储到第一类指令队列中。

在一个实施例中，再次执行进一步包括：按照资源处理系统的资源处理规则执行经还原的用户指令；以及在执行经还原的用户指令产生的流水数据中，仅将原始资源流水数据存储到临时流水列表中，并清除临时流水列表中的未结算数据。

在一个实施例中，按照资源处理系统的资源处理规则执行经还原的用户指令进一步包括：省略对资源处理是否能成功执行的判断步骤。

在一个实施例中，按照资源处理系统的资源处理规则执行经还原的用户指令进一步包括：响应于确定用户指令对应的时间戳处于下一个处理时段内的预定时刻之内，省略对资源处理是否能成功执行的判断步骤。

在一个实施例中，临时流水列表设置有第一编号和第二编号，第一编号用于记录临时流水列表的资源流水数据的最大序号，第二编号用于记录临时流水列表的未结算资源流水数据的起始序号并在第一时刻更新，将资源处理系统的待结算资源流水数据同步至结算系统包括：将序号大于等于第二编号且小于等于第一编号的临时流水列表的资源流水数据发送至结算系统；其中，第一时刻是结算系统设定的结算时刻。

在一个实施例中，临时流水列表的每个资源流水数据设置有时间戳字段，用于记录对应用户指令进入指令队列时的时间，将资源处理系统的待结算资源流水数据同步至结算系统包括：将临时流水列表的资源流水数据中时间戳处于下一个处理时段内的预定时刻之前的资源流水数据发送至结算系统。

在一个实施例中，用结算数据对资源处理系统进行更新后，根据本公开第一方面的方法还包括：删除临时流水列表的已结算资源流水数据。

在一个实施例中，处理时段是资源处理日，第一时刻是结算系统的结算时刻。

在一个实施例中，资源处理是否能成功执行的判断包括对以下事项的判断：资源存量是否足够，用户是否被授权处理。

根据本公开的第二方面，提供一种用于资源处理系统的装置，包括：结算同步模块，配置来在第一处理时段的第一时刻，将资源处理系统的待结算资源流水数据同步至结算系统用于结算，以便结算系统生成结算数据；结算更新模块，配置来在第一处理时段的第二时刻，中止资源处理系统的业务，接收结算系统的结算数据，并用结算数据对资源处理系统进行更新，其中，在第一处理时段的第二时刻之前，保持资源处理系统的业务，其中，业务包括对用户指令进行接收和相应的业务处理，第二时刻是第一处理时段结束的时刻；切换模块，配置来将资源处理系统的处理时段从第一处理时段切换至其后的下一个处理时段；再处理模块，配置来响应于切换，还原资源处理系统在第二时刻之前的未经结算的资源处理对应的用户指令，并再次执行第二时刻之前的未经结算的资源处理对应的用户指令；以及启动模块，配置来结束中止，以继续资源处理系统的业务。

根据本公开的第三方面，提供一种资源处理系统，包括：处理器；以及存储器，配置为在其上存储有计算机可执行指令，指令当在处理器中执行时使得实现根据本公开第一方面的方法。

根据本公开的第四方面，提供一种计算机可读存储介质，计算机可读存储介质中存储有指令，当指令在计算机上运行时，使得计算机实现根据本公开第一方面的方法。

通过用结算数据对资源处理系统进行更新，实现了结算系统和资源处理系统第一时刻之前的数据对齐，而后通过还原和再次执行在第二时刻之前的未经结算的资源处理对应的用户指令，确保了资源处理系统在更新之前的未结算数据是以对齐后的数据为起点的，保障了数据的安全性，确保了资源处理系统的鲁棒性和资源处理安全。

通过本公开实施例，实现了在结算系统与资源处理系统的异步对齐，特别对于资源处理系统不便与结算系统的结算操作同步中断的情况，能够帮助实现资源处理系统提供持续的用户服务，提高了用户体验，同时也确保了资源处理的安全性。例如对于涉及全球交易所的场外衍生品交易，实现交易时段23小时不间断服务，同时还确保了资金移转的安全和交易安全，极大地提高了用户的交易体验。

附图说明

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

图1图示了本发明实施例提供的资源处理所能够应用的一个示例性环境架构图。

图2a图示了根据本发明实施例的用于资源处理系统的方法的流程图。

图2b图示了根据本发明实施例的用于资源处理系统的方法的进一步的流程图。

图3a图示了根据本发明实施例的用于资源处理系统的方法的另一进一步的流程图。

图3b图示了根据本发明实施例的用于资源处理系统的方法的更进一步的流程图。

图3c图示了根据本发明实施例的用于资源处理系统的方法的再一进一步的流程图。

图3d图示了根据本发明实施例的用于资源处理系统的方法的又一进一步的流程图。

图4图示了本发明实施例在场外衍生品交易场景中的一个具体应用实施例。

图5图示了根据本发明实施例的用于资源处理系统的装置的框图。

图6图示了根据本发明实施例的与资源处理有关的硬件环境图。

具体实施方式

为使本公开的目的、技术方案和优点更加清楚，下面将结合附图对本公开实施方式作进一步地详细描述。

可以理解，本公开所使用的术语“第一”、“第二”等可在本文中用于描述各种概念，但除非特别说明，这些概念不受这些术语限制。这些术语仅用于将一个概念与另一个概念区分。举例来说，在不脱离本公开的范围的情况下，能够将第一时刻称为第二时刻，将第二时刻称为第一时刻。

本公开所使用的术语“每个”、“多个”等，多个包括两个或两个以上，每个是指对应的多个中的每一个。

本公开所使用的术语“资源处理”，包括金融领域通常意义下的“交易”，例如场外衍生品交易，也包括任何资源分配或资源交换。同样地，本公开所使用术语“结算”，包括金融领域中的“结算”，例如资金的划拨确认、核算等操作中的一种或多种，也包括任何对资源分配或资源交换进行的与划拨确认、核算等类似的操作的一种或多种。可以理解，本公开实施例所述的资源处理的方法，不限于针对资金和金融产品 ，而可以是针对任何可以分配或交换的资源。

本公开所使用的术语“队列”，是数据结构中的概念，其是一种特殊的线性表，特殊之处在于它只允许在表的前端进行删除操作，而在表的后端进行插入操作，队列是一种操作受限制的线性表。进行插入操作的端称为队尾，进行删除操作的端称为队头。队列中没有元素时，称为空队列。队列的数据元素又称为队列元素。在队列中插入一个队列元素称为入队，从队列中删除一个队列元素称为出队。因为队列只允许在一端插入，在另一端删除，所以只有最早进入队列的元素才能最先从队列中删除，故队列又称为先进先出（FIFO—firstin first out）线性表。

本公开所使用的“流水”，包括金融领域通常意义下的“流水”，例如进账资金数目，出掌资金数目，持仓增加数目，持仓减少数目等，也包括所引申意义下的任何资源分配或资源交换涉及的类似“流水”的信息，例如资源增减或交换的信息。

本公开所使用的“列表”， 是数据结构中的概念，一般指线性列表的简称。列表是一种数据项构成的有限序列，即按照一定的线性顺序，排列而成的数据项的集合，在这种数据结构上进行的基本操作包括对元素的的查找、插入和删除。队列也是一种特殊类型的列表。

图1是本公开实施例提供的资源处理的方法的实施环境示意图，参见图1，该实施环境中可以包括终端110、资源处理系统120和结算系统130。终端110、资源处理系统120和结算系统130之间可以通过无线网络或有线网络140相连。

终端110可以是智能手机、平板电脑、便携计算机、专用计算机等设备。终端110安装和运行有可以进行资源查询和发出资源处理指令的应用程序。示意性的，终端110是用户使用的终端，终端110中运行的应用程序内登录有用户账户。本领域技术人员可以知晓，实施环境中的上述终端的数量可以更多或更少。比如，终端110可以仅为一个，或者上述终端为几十个或几百个，或者更多数量。本公开实施例对终端的数量和设备类型不加以限定。

在一些示例中，终端110本身能够独立支持资源处理的应用而无需依赖于资源处理系统120。此时可以将终端110视为资源处理系统120。通常，用户通过操作终端110上的应用而触发对资源处理系统120支持功能的请求。注意，这里的“用户”应作广义理解，可以是人，也可以是任何能够操作应用的功能实体，例如，基于对人的操作行为分析而触发对资源处理的应用程序进行操作的功能实体。

资源处理系统120可以是独立的物理系统，也可以是多个物理系统构成的系统集群或者分布式系统，还可以是提供云服务、云数据库、云计算、云函数、云存储、网络服务、云通信、中间件服务、域名服务、安全服务、分发网络(Content Delivery Network，CDN)、以及大数据和人工智能平台等基础云计算服务的云系统。终端110以及资源处理系统120可以通过有线或无线通信方式进行直接或间接地连接，本公开在此不做限制。

结算系统130可以是独立的物理系统，也可以是多个物理系统构成的系统集群或者分布式系统，还可以是提供云服务、云数据库、云计算、云函数、云存储、网络服务、云通信、中间件服务、域名服务、安全服务、分发网络(Content Delivery Network，CDN)、以及大数据和人工智能平台等基础云计算服务的云系统。资源处理系统120与结算系统130可以通过有线或无线通信方式进行直接或间接地连接，本公开在此不做限制。

云计算(cloud computing)是一种计算模式，它将计算任务分布在大量计算机构成的资源池上，使各种应用系统能够根据需要获取计算力、存储空间和信息服务。提供资源的网络被称为“云”。“云”中的资源在使用者看来是可以无限扩展的，并且可以随时获取，按需使用，随时扩展，按使用付费。作为云计算的基础能力提供商，会建立云计算资源池(简称云平台，一般称为IaaS(Infrastructure as a Service，基础设施即服务)平台，在资源池中部署多种类型的虚拟资源，供外部客户选择使用。云计算资源池中主要包括：计算设备(为虚拟化机器，包含操作系统)、存储设备、网络设备。按照逻辑功能划分,在IaaS(Infrastructure as a Service，基础设施即服务)层上可以部署PaaS(Platform as aService,平台即服务)层，PaaS层之上再部署SaaS(Software as a Service,软件即服务)层，也可以直接将SaaS部署在IaaS上。PaaS为软件运行的平台，如数据库、web容器等。SaaS为各式各样的业务软件，如web门户网站、短信群发器等。一般来说，SaaS和PaaS相对于IaaS是上层。作为云计算的基础能力提供商，会建立云计算资源池(简称云平台，一般称为IaaS(Infrastructure as a Service，基础设施即服务)平台，在资源池中部署多种类型的虚拟资源，供外部客户选择使用。云计算资源池中主要包括：计算设备(为虚拟化机器，包含操作系统)、存储设备、网络设备。

资源处理系统120可以基于云而协作而支持不同的终端110，也可以各自独立支持不同的终端，例如可以按照终端110登录的IP地址或者应用类型等划分方式对终端进行划分，从而分配给不同的终端110进行服务，当然，也可以响应于实时的集中调度而分配给不同的终端110。

网络140可以包括但不限于广域网、局域网、有线网络、无线网络，或者其任意组合。

在本公开实施例中，可以由资源处理系统120或具有资源处理功能的终端110作为执行主体来实施本公开实施例提供的技术方案，也可以由资源处理系统120和终端110分别执行本公开的不同实施例，本公开实施例对此不作限定。

图2a是本公开实施例提供的一种用于资源处理系统的方法的流程图，该方法可以应用于计算机设备中，该计算机设备可以为上述结合图1所描述的实施环境中的资源处理系统120或具有资源处理功能的终端设备110，也可以是任何其他环境中的设备。如前面所述，本公开的资源处理，包括资源分配和资源交换，在本公开实施例的场景下，该资源处理需要定期进行结算，新的资源处理需在结算的基础上继续进行。

参见图2a，该方法可以包括以下步骤，并具体地以场外衍生品交易为例进行说明，然而，本公开实施例并不限于场外衍生品交易。

在步骤201，在第一处理时段的第一时刻，将资源处理系统的待结算资源流水数据同步至结算系统用于结算，以便结算系统生成结算数据。

示例性的，第一处理时段的长度是一日，例如，对于资源处理系统是交易系统的情况下，第一处理时段是一个交易日。当然，本公开不限于此，并且不排除第一处理时段是更短或更长的时间段的情况，例如，第一处理时段可以是半日，也可以是多日、一周甚至更长，这取决于系统的设置，系统设置的资源处理周期可能是半日、多日、一周甚至更长，则该第一处理时段的长度就相应地为半日、多日、一周甚至更长。本公开对此不作限定。

可以理解，步骤201中的待结算资源流水数据意为结算系统本次结算所要求的数据。例如如果结算系统要求结算16：00以前的数据，则步骤210中的待结算资源流水数据为16：00以前的数据。

示例性地，第一时刻是清洁算系统设定的时间，例如对于场外衍生品交易的结算系统，该时间一般为16：00，则第一时刻就是16：00。可以理解，此时的待结算资源流水数据即第一时刻之前的资源处理涉及的资源流水数据。当然，本公开不限于此，并且不排除第一时刻是其它时间的可能性，例如在一个应用场景中，第一时刻可以晚于结算系统设定的时间，例如对于场外衍生品交易的结算系统，该时间一般为16：00，而第一时刻可以是16：30，但资源处理系统可以在16：30这个时刻只发送16：00之前的资源流水数据。可以理解，此时的待结算资源流水数据不是第一时刻之前的资源流水数据，而是结算系统要求的16：00之前的资源流水数据。

在步骤202，在第一处理时段的第二时刻，中止资源处理系统的业务，接收结算系统的结算数据，并用结算数据对资源处理系统进行更新，其中，在第一处理时段的第二时刻之前，保持资源处理系统的业务，这里所称的业务包括对用户指令进行接收和相应的业务处理，第二时刻是第一处理时段结束的时刻。照此，结算系统在结算期间，资源处理系统并不中断新的用户指令的接收和业务处理，直到当前处理时段结束，才中止业务，也直到当前处理时段结束，才接收结算系统的结算数据，并用结算数据对资源处理系统进行更新。

进一步地，在步骤202中，用结算数据对资源处理系统进行更新之后，还包括步骤2021，删除临时流水列表的已结算资源流水数据，如图2b所示。

在步骤203，将资源处理系统的处理时段从第一处理时段切换至其后的下一个处理时段。切换之后，系统发生的资源处理就属于下一处理时段的资源处理了。可以理解，第一时段切换到第二时刻不必与自然日、周、月的切换重合，例如交易日的切换不必在24：00。还可以理解，第一处理时段的结束时刻和其后的下一个处理时段的开始时刻是可以有间隔的。例如在全球场外衍生品交易中，第一处理时段的结束时刻是每日凌晨的5：00，而第二处理时段的开始时间是每日凌晨的6：00，其中有一个小时的间隔，在此期间，资源处理系统可以进行数据备份、维护等。

在步骤204，响应于切换，还原资源处理系统在第二时刻之前的未经结算的资源处理对应的用户指令，并再次执行这些用户指令。可以理解，由于还原发生在切换之后，因此还原发生在第一处理时段之后的下一个处理时段。切换时系统已做好了现有技术中应做的维护、备份、指令队列的清除等操作，将还原步骤的触发点设置在切换可以确保还原步骤的执行环境安全。

在步骤205，结束中止，以继续资源处理系统的业务。此时可以接收新的用户指令并进行处理了。

通过用结算数据对资源处理系统进行更新，实现了结算系统和资源处理系统第一时刻之前的数据对齐，而后通过还原和再次执行在第二时刻之前的未经结算的资源处理对应的用户指令，确保了资源处理系统在更新之前的未结算数据是以对齐后的数据为起点的，保障了数据的安全性，确保了资源处理系统的鲁棒性和资源处理安全。

通过本公开实施例，实现了在结算系统与资源处理系统的异步对齐，特别对于资源处理系统不便与结算系统的结算操作同步中断的情况，能够帮助实现资源处理系统提供持续的用户服务，提高了用户体验，同时也确保了资源处理的安全性。例如对于涉及全球交易所的场外衍生品交易，实现交易时段23小时不间断服务，同时还确保了资金移转的安全和交易安全，极大地提高了用户的交易体验。

图3a图示了根据本发明实施例的用于资源处理系统的方法的另一进一步的流程图。其图示了当资源处理系统接收到用户指令后，进行相应的业务处理的步骤。

在步骤310，建立指令队列，用于按接收顺序存储所述用户指令。队列是先进先出线性表，因此先存储的指令先取出以进行下面的处理。

在步骤320，按照所述资源处理系统的业务规则处理所述用户指令。不同的资源处理系统、不同业务类型，都有其自己的业务规则，在该步骤中，遵照已有的业务规则进行处理。

在步骤330，建立临时流水列表，用于记录成功执行的用户指令产生的资源流水数据。应注意，这里建立的是临时流水列表，不同于系统的流水日志，系统中原本要记录和备份的各种数据依然按照原有的设置进行操作，并不受影响，以确保系统其它相关功能的正常进行。用户指令可能被成功地执行，也可能执行失败，例如由于用户资源存量不足够、用户没有被授权处理等原因，执行失败的数据不存入临时流水列表中，只有执行成功的数据存入临时流水列表中。

可以理解，临时流水列表中的待结算数据，将在步骤201中发送给结算系统用于结算。在一个示例中，临时流水列表设置有第一编号和第二编号，第一编号用于记录临时流水列表的资源流水数据的最大序号，第二编号用于记录临时流水列表的未结算资源流水数据的起始序号并在每次发送给结算系统的第一时刻更新，于是，待结算数据为序号大于等于第二编号且小于等于第一编号的临时流水列表的资源流水数据。如果步骤201的发送时刻晚于结算系统设定的时间，则该示例并不适用。在另一个示例中，临时流水列表的每个数据项设置有时间戳字段，用于记录对应用户指令进入用户指令队列时的时间，于是，待结算数据为临时流水列表的资源流水数据中时间戳处于下一个处理时段内的预定时刻之前的资源流水数据。该示例可以适用步骤201的发送时刻等于或晚于结算系统设定的时间的情形。

应注意，进入指令队列的时间和进入临时流水列表的时间应是有时间差的，后者有滞后。上述实施例中统一以进入用户指令队列的时间为准，确保用户体验到的实际结算时间与系统声称的结算时间一致。

图3b图示了根据本发明实施例的用于资源处理系统的方法的更进一步的流程图。其图示了步骤310的建立指令队列的进一步的步骤。

在步骤311，对用户指令进行分类，其中影响用户的资源的指令归入第一类用户指令，而不影响用户的资源的指令归入第二类用户指令。影响用户的资源的指令例如，资源分配（包括分配入用户的资源和从用户的资源分配出），资源交换（包括用户自己的不同种类的资源之间的交换，以及不同用户之间的资源的交换）等。在金融交易的场景下，资源分配例如资金转入和资金转出，而资源交换例如金融产品的买入和卖出。不影响用户的资源的指令例如查询指令。

在步骤312，将第一类用户指令存储到第一类指令队列中，并将第二类用户指令存储到第二类指令队列中。两类指令在系统中的处理规则不变，对于第一类指令，在处理之后，会产生资源流水数据，而第二类指令在处理之后不会产生资源流水数据。

通过这样的分类，系统在每次执行第一类指令队列的指令后，将统一地自动发起资源流水数据的存储，有利于增强系统的执行程式化。同时，也为后续还原指令的步骤提供简化的可能性。

相应地，在步骤331，在执行用户指令产生的流水数据中，仅将第一类指令队列中成功执行的用户指令产生的资源流水数据存储到临时流水列表中。如图3c所示。图3c示出了有关步骤330的进一步的方法。

进一步地，在步骤3311，在执行用户指令产生的流水数据中，仅将第一类指令队列中成功执行的用户指令产生的原始资源流水数据存储到临时流水列表中。如图3c所示。在对第一类用户指令的执行过程中，除了会产生原始资源流水数据，还可能在计算过程中产生中间流水数据。仅存储原始资源流水数据可以在保证临时流水列表的功能的基础上，压缩存储空间，简化系统复杂度。

可选地，临时流水列表中还可以有额外的数据，例如，指示是否已经结算的数据，如上文所述的第一编号、第二编号、时间戳等。

在一个示例中，步骤312还可以进一步包括以下步骤：

在步骤3121，将第一类用户指令封装成数据结构，数据结构中包括用户指令的信息、时间戳和序列号。时间戳可以采用系统时间，也可以采用自然日时间，或任何其它可以识别的时间，格式例如可以是年月日时秒分但不限于此。该时间戳可以在步骤330或331或3311中随着资源流水数据写入临时流水列表。

在步骤3122，将数据结构存储到第一类指令队列中。

相应地，如图3c所示，在步骤33111，在执行用户指令产生的流水数据中，将第一类指令队列中成功执行的用户指令产生的原始资源流水数据封装成数据结构，该数据结构中除了包括原始资源流水数据，还可以包括时间戳和序列号，在一个示例中，该时间戳和指令队列里对应的数据结构中的时间戳相同。而后在步骤33112，将该数据结构存储到临时流水列表中。

图3d图示了根据本发明实施例的用于资源处理系统的方法的又一进一步的流程图。步骤204进一步包括步骤2041和步骤2042。

在步骤2041，基于临时流水列表中的未结算数据，按相同顺序生成对应的第一类用户指令对应的数据结构。对于步骤3311或步骤33111存储的临时流水列表中的数据项，因为其与第一类指令相关联，又是原始流水数据，因此与第一队列的指令是一一对应的，对于步骤331存储的临时流水列表中的数据项，虽然仅与第一类指令相关联，但不限于是原始流水数据，还可能存在非原始流水数据，而这部分数据在还原用户指令时用不上。因此优选地，选择步骤3311或步骤33111存储的临时流水列表中的数据项，可以简化还原用户指令的步骤。在一个示例中，数据结构中的时间戳取值为生成对应的用户指令对应的数据结构时的资源处理系统的时间戳，此时已经过资源处理时段的切换，该时间戳指示的是新的资源处理时段中的时刻。该时间戳可以在下文所描述的步骤20431中用于判断。

在步骤2042，将所生成的数据结构存储到第一类指令队列中。

而后在步骤2043，按照资源处理系统的资源处理规则执行经还原的用户指令，可选地，在步骤20432，省略对资源处理是否能成功执行的判断步骤。鉴于本公开实施例提出的临时流水列表中存储的都是成功执行的用户指令生成的资源流水数据，因此这里可以作出简化处理，默认再次执行也是可以成功的，省略对资源处理是否能成功执行的判断步骤，例如资源存量是否足够，用户是否被授权处理等。例如在金融交易的场景下，省略对用户资金余额、持仓余额、风险控制等是否满足条件的判断。在一个示例中，省略对资源处理是否能成功执行的判断步骤可以基于对用户指令的时间戳的判断而触发，如果在步骤20431确定用户指令对应的时间戳处于下一个处理时段内的预定时刻之内，则确定可以省略对资源处理是否能成功执行的判断步骤。

在步骤2044，在执行经还原的用户指令产生的流水数据中，仅将原始资源流水数据存储到临时流水列表中，并清除临时流水列表中的未结算数据。下一次结算将使用执行经还原的用户指令产生的流水数据，该流水数据是在资源处理系统在步骤203利用结算系统发来的结算数据更新之后生成的，因此更加安全、鲁棒，而用于还原用户指令的资源流水数据已完成使命，可以退出历史舞台。

图4图示了本发明实施例在场外衍生品交易场景中的一个具体应用实施例。用户在终端110的应用程序上用其账号登录，例如账号为123。用户指令可以包括会影响资金的指令，例如存入、取出资金的指令等，可以包括会影响持仓的指令，例如交易指令，也可以包括不会影响资金和持仓的指令，例如查询指令。

在一个示例中，在上午10点多，用户123发出以下两条指令：

“出金100元”；

“买入10手标的AL2209”。

上述信息发送到资源处理系统120，封装成数据结构，由于这两条指令都是会影响资金或持仓的，因此均划分成第一类指令。封装成的数据结构例如：

[

序列号：1；

时间戳：202205191006；

用户账号：123；

资金方向：出金；

金额：100；

交易标的：N/A；

交易方向：N/A；

手数：N/A；

单价：N/A；

]

以及

[

序列号：2；

时间戳：202205191016；

用户账号：123；

资金方向：N/A；

金额：N/A；

交易标的：AL2209;

交易方向：B（买入）；

手数：10；

单价：20360；

]

资源处理系统120执行该指令，产生资源流水数据，其中对原始资源流水数据进行封装，封装后的数据结构例如：

[

序列号：1；

时间戳：202205191006；

用户账号：123；

资金方向：出金；

金额：100；

交易标的：N/A；

交易方向：N/A；

手数：N/A；

单价：N/A；

]

以及

[

序列号：2；

时间戳：202205191016；

用户账号：123；

资金方向：N/A；

金额：N/A；

交易标的：AL2209;

交易方向：B（买入）；

手数：10；

单价：20360元；

]。

在该示例中，此数据结构与指令队列中的数据结构相同，但该示例并不旨在限制本公开，例如指令队列和临时流水列表中的序号可以是分别编号而不同的。

在指令执行过程中产生的中间数据，例如交易总价（=单价20360*手数10=203600元）可以不存入此数据结构中，而后将此数据结构存入临时流水列表。在一个示例中，该临时流水列表具有第一编号和第二编号，第一编号用于记录临时流水列表中数据项的最大序号，在上面的示例中即为2，第二编号用于记录临时流水列表的未结算资源流水数据的起始序号，在上面的示例中即为1。

结算时间设定为16：00，假定在16：00前，资源处理系统中没有再收到其它产生资源流水数据的指令，在16：00，资源处理系统将始于第一编号、止于第二编号的资源流水数据发送给结算系统130，并且资源处理系统不中止服务。发送之后，第二编号更新为3。

待结算系统130完成结算后，将结算数据发送给资源处理系统120，用于对该系统的数据进行更新。资源处理系统还可以删除临时流水列表中序号1和序号2的数据项。

在下午16：00之后，资源处理系统又收到来自另一用户345的两条指令：

“入金100元”；

“卖出10手标的AL2209”。

上述信息发送到资源处理系统120，封装成数据结构，由于这两条指令都是会影响资金或持仓的，因此均划分成第一类指令。封装成的数据结构例如：

[

序列号：3；

时间戳：202205191650；

用户账号：456；

资金方向：入金；

金额：100；

交易标的：N/A；

交易方向：N/A；

手数：N/A；

单价：N/A；

]

以及

[

序列号：4；

时间戳：202205191656；

用户账号：456；

资金方向：N/A；

金额：N/A；

交易标的：AL2209；

交易方向：S（卖出）；

手数：10；

单价：20360；

]

资源处理系统120执行该指令，产生资源流水数据，其中对原始资源流水数据进行封装，封装后的数据结构例如：

[

序列号：3；

时间戳：202205191650；

用户账号：456；

资金方向：入金；

金额：100；

交易标的：N/A；

交易方向：N/A；

手数：N/A；

单价：N/A；

]

以及

[

序列号：4；

时间戳：202205191656；

用户账号：456；

资金方向：N/A；

金额：N/A；

交易标的：AL2209；

交易方向：S（卖出）；

手数：10；

单价：20360；

]

到了凌晨5：00，全球的资源处理系统休市，资源处理系统120中止服务，进入数据备份、维护等常规操作，指令队列被清空，系统切换到下一个交易日。同时，将资源处理系统120的临时流水列表中尚未结算的序列号3和序列号4的资源流水数据还原到指令队列，同样以数据结构的形式保存到指令队列中，其中数据结构中的时间戳取值为还原时的时间戳，可以取系统时间戳，也可以取自然日时间戳等。当采用系统时间戳时，因为已切日，有利于系统的执行逻辑识别这是还原的指令，当然，对于其它时间戳，例如自然日时间戳，系统的执行逻辑也能够识别出是还原的指令。可选地，还可以将休市后、开市前这个时间段需执行的指令都默认为还原的指令，而无需根据指令的属性来识别。

在识别出是还原的指令后，资源处理系统120可以简化处理，例如省略对资源处理是否能成功执行的判断步骤。

而后在早晨6：00，资源处理系统开启新一个交易日的服务，接收用户指令以及进行相应的业务处理。

本公开通过用结算数据对资源处理系统进行更新，实现了结算系统和资源处理系统16；00之前的数据对齐，而后通过还原和再次执行16；00-5：00之间的用户指令确保了资源处理系统在16：00之后的数据是以对齐后的数据为起点的，保障了数据的安全性，确保了资源处理系统的鲁棒性和资源处理安全。

通过本公开实施例，实现了在结算系统与资源处理系统的异步对齐，对于涉及全球交易所的场外衍生品交易，交易时段23小时不间断。本公开让7*23场外衍生品交易系统支持成为现实，在提高客户交易体验的情况下也确保了交易的安全。

图5图示了根据本发明实施例的用于资源处理系统的装置的框图。用于资源处理系统的装置500包括结算同步模块501、结算更新模块502、切换模块503、再处理模块504和启动模块505。其中，结算同步模块501配置来在第一处理时段的第一时刻，将所述资源处理系统的待结算资源流水数据同步至结算系统用于结算，以便所述结算系统生成结算数据，即图2a的步骤201。结算更新模块502配置来在所述第一处理时段的第二时刻，中止所述资源处理系统的业务，接收所述结算系统的结算数据，并用所述结算数据对所述资源处理系统进行更新，其中，在所述第一处理时段的第二时刻之前，保持所述资源处理系统的业务，其中，所述业务包括对用户指令进行接收和相应的业务处理，所述第二时刻是所述第一处理时段结束的时刻，即图2a的步骤202。切换模块503配置来将所述资源处理系统的处理时段从所述第一处理时段切换至其后的下一个处理时段；图2a的步骤203。再处理模块504配置来响应于所述切换，还原所述资源处理系统在所述第二时刻之前的未经结算的资源处理对应的用户指令，并再次执行所述第二时刻之前的未经结算的资源处理对应的用户指令，图2a的步骤204。启动模块505配置来结束所述中止，以继续所述资源处理系统的业务，图2a的步骤205。

关于这些模块的更多内容可以参见图2a、2b、3a-3d中的描述，在此不再赘述。

参见图6，在本发明的实施方式中，用于资源处理的设备600是资源处理设备130，也可以是具有资源处理功能的终端110，其包括处理器604，其中包括硬件原件610。处理器604例如包括一个或多个数字信号处理器(DSP)、通用微处理器、专用集成电路(ASIC)、现场可编程逻辑阵列(FPGA)或其它等效集成或离散逻辑电路等一个或多个处理器。如本文中所使用的术语“处理器”可指上述结构或适合于实施本文中所描述的技术的任一其它结构中的任一者。另外，在一些方面中，本文描述的功能性可提供于经配置以用于资源处理的专用硬件和/或软件模块内，或并入在组合式的硬件和/或软件模块中。并且，可将所述技术完全实施于一个或多个电路或逻辑元件中。本公开中的方法可以在各种组件、模块或单元中实现，但不一定需要通过不同硬件单元来实现。而是，如上所述，各种组件、模块或单元可组合或由互操作硬件单元(包含如上所述的一个或多个处理器)的集合结合合适软件和/或固件来提供。

在一个或多个示例中，以上结合图1、图2a-2b、图3a-3d、图4、图5所描述的内容可以硬件、软件、固件或其任一组合来实施。如果以软件实施，那么功能可作为一个或多个指令或代码存储在计算机可读介质606上或经由计算机可读介质606传输，且由基于硬件的处理器执行。计算机可读介质606可包含对应于例如数据存储介质等有形介质的计算机可读存储介质，或包含促进计算机程序（包括上述一个或多个指令或代码）例如根据通信协议从一处传送到另一处的任何介质的通信介质。以此方式，计算机可读介质606通常可对应于（1）非暂时性的有形计算机可读存储介质，或（2）例如信号或载波等通信介质。数据存储介质可为可由一个或多个计算机或者一个或多个处理器读取以检索用于实施本公开中描述的技术的指令、代码和/或数据结构的任何可用介质。计算机程序产品可包含计算机可读介质606以及存储其上的一个或多个指令或代码。

举例来说且并非限制，此类计算机可读存储介质可包括RAM、ROM、EEPROM、CD_ROM或其它光盘等存储器、磁盘存储器或其它磁性存储器、快闪存储器或可用来以指令或数据结构的形式存储所要程序代码且可由计算机读取的任何其它存储器612。而且，恰当地将任何连接称作计算机可读介质606。举例来说，如果使用同轴电缆、光纤电缆、双绞线、数字订户线(DSL)或例如红外线、无线电及微波等无线技术从网站、结算系统或其它远程源传输指令，则同轴电缆、光纤电缆、双绞线、DSL或例如红外线、无线电及微波等无线技术包含于介质的定义中。然而应了解，计算机可读存储介质和数据存储介质不包含连接、载波、信号或其它瞬时介质，而是针对非瞬时有形存储介质。如本文中所使用，磁盘及光盘包含压缩光盘(CD)、激光光盘、光学光盘、数字多功能光盘(DVD)、软磁盘及蓝光光盘，其中磁盘通常以磁性方式再生数据，而光盘使用激光以光学方式再生数据。上文的组合也应包含在计算机可读介质606的范围内。

用于资源处理的设备还可以包括用于传输数据的I/O接口、以及其他功能614。用于资源处理的设备可以包括在不同的终端中，诸如计算机616、移动装置618和其他终端620等等。这些配置中的每个包括可以具有一般不同的构造和能力的设备，并且因此可以根据不同设备类别中的一个或多个配置用于资源处理的设备。此外本发明的技术还可以通过使用分布式系统、诸如通过如下所述的平台624在“云”622上全部或部分地实现。

云622包括和/或代表用于元素626的平台624。平台624抽象云622的硬件（例如，结算系统）和软件资源的底层功能。元素626可以包括在远离计算设备的资源处理系统上执行计算机处理时可以使用的应用和/或数据。元素626还可以包括通过因特网和/或通过诸如蜂窝或Wi-Fi网络的订户网络提供的服务。

平台624可以抽象资源和功能以将计算设备与其他计算设备连接。平台624还可以用于抽象资源的分级以提供遇到的对于经由平台624实现的元素626的需求的相应水平的分级。因此，在互连设备实施例中，本文描述的功能的实现可以分布在整个设备600内。例如，功能可以部分地在计算设备上以及通过抽象云622的功能的平台624来实现。

需要说明，本公开中出现的“第一”、“第二”等表述不代表指示重要性或步骤的先后，仅是用于区分。方法步骤在没有特别说明或者没有前提约束（即一个步骤的执行需以另一个步骤的执行结果为前提）的情况下，方法步骤的描述先后不代表他们的执行先后，所描述的方法步骤可以以可能的、合理的顺序执行。

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

应当理解的是，本公开并不局限于上面已经描述并在附图中示出的精确结构，并且可以在不脱离其范围进行各种修改和改变。本公开的范围仅由所附的权利要求来限制。

Claims (17)

1.一种用于资源处理系统的方法，其特征在于，包括步骤：

在第一处理时段的第一时刻，将所述资源处理系统的待结算资源流水数据同步至结算系统用于结算，以便所述结算系统生成结算数据；

在所述第一处理时段的第二时刻，中止所述资源处理系统的业务，接收所述结算系统的结算数据，并用所述结算数据对所述资源处理系统进行更新，其中，在所述第一处理时段的所述第二时刻之前，保持所述资源处理系统的业务，其中，所述业务包括对用户指令进行接收和相应的业务处理，所述第二时刻是所述第一处理时段结束的时刻；

将所述资源处理系统的处理时段从所述第一处理时段切换至其后的下一个处理时段；

响应于所述切换，还原所述资源处理系统在所述第二时刻之前的未经结算的资源处理对应的用户指令，并再次执行所述第二时刻之前的未经结算的资源处理对应的用户指令；以及

结束所述中止，以继续所述资源处理系统的业务。

2.如权利要求1所述的方法，其特征在于，所述对用户指令进行相应的业务处理包括：

建立指令队列，用于按接收顺序存储所述用户指令；

按照所述资源处理系统的业务规则处理所述用户指令；以及

建立临时流水列表，用于记录成功执行的用户指令产生的资源流水数据。

3.如权利要求2所述的方法，其特征在于，所述建立指令队列进一步包括：

对所述用户指令进行分类，其中影响用户的资源的指令归入第一类用户指令，而不影响用户的资源的指令归入第二类用户指令，

将所述第一类用户指令存储到第一类指令队列中，并将所述第二类用户指令存储到第二类指令队列中；以及

所述建立临时流水列表进一步包括：

在执行用户指令产生的流水数据中，仅将所述第一类指令队列中成功执行的用户指令产生的资源流水数据存储到所述临时流水列表中。

4.如权利要求3所述的方法，其特征在于，所述建立指令队列进一步包括：

将所述第一类用户指令封装成数据结构，所述数据结构中包括所述用户指令的信息、时间戳和序列号；

将所述数据结构存储到所述第一类指令队列中。

5.如权利要求4所述的方法，其特征在于，

所述建立临时流水列表进一步包括：

在执行用户指令产生的流水数据中，仅将所述第一类指令队列中成功执行的用户指令产生的原始资源流水数据存储到所述临时流水列表中。

6. 如权利要求5所述的方法，其特征在于，所述还原所述资源处理系统在所述第二时刻之前的未经结算的资源处理对应的用户指令进一步包括：

基于所述临时流水列表中的未结算数据，按相同顺序生成对应的用户指令对应的数据结构，其中所述数据结构中的时间戳取值为所述生成所述对应的用户指令对应的数据结构时的时间戳；以及

将所生成的数据结构存储到所述第一类指令队列中。

7. 如权利要求6所述的方法，其特征在于，所述再次执行进一步包括：

按照所述资源处理系统的资源处理规则执行经还原的用户指令；以及

在执行经还原的用户指令产生的流水数据中，仅将原始资源流水数据存储到所述临时流水列表中，并清除所述临时流水列表中的未结算数据。

8.如权利要求7所述的方法，其特征在于，所述按照所述资源处理系统的资源处理规则执行经还原的用户指令进一步包括：

省略对资源处理是否能成功执行的判断步骤。

9.如权利要求7所述的方法，其特征在于，所述按照所述资源处理系统的资源处理规则执行经还原的用户指令进一步包括：

响应于确定所述用户指令对应的时间戳处于所述下一个处理时段内的预定时刻之内，省略对资源处理是否能成功执行的判断步骤。

10.如权利要求2所述的方法，其特征在于，所述临时流水列表设置有第一编号和第二编号，所述第一编号用于记录所述临时流水列表的资源流水数据的最大序号，所述第二编号用于记录所述临时流水列表的未结算资源流水数据的起始序号并在所述第一时刻更新，所述将所述资源处理系统的待结算资源流水数据同步至结算系统包括：

将序号大于等于所述第二编号且小于等于所述第一编号的所述临时流水列表的资源流水数据发送至所述结算系统；

其中，所述第一时刻是所述结算系统设定的结算时刻。

11.如权利要求2所述的方法，其特征在于，所述临时流水列表的每个资源流水数据设置有时间戳字段，用于记录对应用户指令进入所述指令队列时的时间，所述将所述资源处理系统的待结算资源流水数据同步至结算系统包括：

将所述临时流水列表的资源流水数据中时间戳处于所述下一个处理时段内的预定时刻之前的资源流水数据发送至所述结算系统。

12.如权利要求2所述的方法，其特征在于，所述用所述结算数据对所述资源处理系统进行更新后，所述方法还包括：

删除所述临时流水列表的已结算资源流水数据。

13.如权利要求1所述的方法，其特征在于：所述处理时段是资源处理日，所述第一时刻是所述结算系统的结算时刻。

14.如权利要求8或9所述的方法，其特征在于：所述资源处理是否能成功执行的判断包括对以下事项的判断：资源存量是否足够，用户是否被授权处理。

15.一种用于资源处理系统的装置，其特征在于，包括：

结算同步模块，配置来在第一处理时段的第一时刻，将所述资源处理系统的待结算资源流水数据同步至结算系统用于结算，以便所述结算系统生成结算数据；

结算更新模块，配置来在所述第一处理时段的第二时刻，中止所述资源处理系统的业务，接收所述结算系统的结算数据，并用所述结算数据对所述资源处理系统进行更新，其中，在所述第一处理时段的所述第二时刻之前，保持所述资源处理系统的业务，其中，所述业务包括对用户指令进行接收和相应的业务处理，所述第二时刻是所述第一处理时段结束的时刻；

切换模块，配置来将所述资源处理系统的处理时段从所述第一处理时段切换至其后的下一个处理时段；

再处理模块，配置来响应于所述切换，还原所述资源处理系统在所述第二时刻之前的未经结算的资源处理对应的用户指令，并再次执行所述第二时刻之前的未经结算的资源处理对应的用户指令；以及

启动模块，配置来结束所述中止，以继续所述资源处理系统的业务。

16. 一种资源处理系统，其特征在于，包括：

处理器；以及

存储器，配置为在其上存储有计算机可执行指令，所述指令当在所述处理器中执行时使得实现如权利要求1-14中任一项所述的方法。

17.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质中存储有指令，当所述指令在计算机上运行时，使得所述计算机实现如权利要求1-14中任一项所述的方法。

Images