CN111353841B - 单据数据处理方法、装置及系统 - Google Patents

Abstract

本申请实施例公开了单据数据处理方法、装置及系统，所述系统包括：第二系统，用于对所述链路中目标节点上的商品对象数据进行处理，生成单据数据，并通过所述通信通道将所述单据数据提供给所述第一系统；第一系统，用于获得所述链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点之间的单据数据匹配规则信息，接收到所述第二系统提供的单据数据后，生成核对任务，针对所述核对任务，对所述链路中的节点上的单据数据进行核对。通过本申请实施例，可以实现分布式架构、多个业务应用协同工作时的单据数据核对。

Description

单据数据处理方法、装置及系统

技术领域

本申请涉及单据数据处理技术领域，特别是涉及单据数据处理方法、装置及系统。

背景技术

在商品对象销售系统中，财务数据核对是其中比较重要的一环。以数据量最大的交易链路为例，在以往的数据核对方案中,主要是解决传统门店数据核对问题。在这种场景下，用户在收银台完成付款后，拿走货物，立即就能完成交易，交易付款和商品交付可以认为在同一时点完成，交易链路简单。另外，这种场景交易量小，系统通常采用集中式部署，所有数据都保存在同一个数据库，所有业务在同一数据库，而且同步完成，因此通常通过数据库事务，保证数据一致性即可完成核对。

但是，在“新零售”等线上与线下相结合的模式下，零售商可以通过“新零售”平台提供的线上的应用程序(App)提供商品对象的信息，用户可以通过线上的App进行浏览、购买等行为。同时，零售商还可以开设线下的实体店铺，用户也可以通过线下的实体店铺进行商品对象的购买。其中，线上的订单可以从线下的实体店铺进行发货等一系列的处理，并最终配送到用户指定的收货地址。线下实体店铺中还需要进行一些商品入库、调货、补货等各种处理。在上述交易、入库、调货、补货等场景中，通常都会涉及到很长的处理链路。

其中，以交易场景为例，在“新零售”模式下，具有交易订单量大，线上线下一体，少量交易在门店发生，大部分交易是用户线上下单的特点。其中，对于线上下单的情况，具体的商品需要由配送员送到用户手上完成，只有用户签收商品后才算完成整个交易链路。因此交易付款和商品交付异步完成，两者之间通常相隔1小时至数天不等。并且，整个交易链路可能是由多个不同的业务部门，甚至不同的应用系统来完成，例如，交易过程所使用的应用，与配送过程所使用的应用可能是相互独立的，这些数据可能分布在不同的应用系统的业务服务器的数据库中，因此，无法直接通过数据库事务保证数据一致性。

因此，如何有效地进行复杂链路下的单据数据核对，成为需要本领域技术人员解决的技术问题。

发明内容

本申请提供了单据数据处理方法、装置及系统，可以实现分布式架构、多个业务应用协同工作时的单据数据核对的同时，避免对具体业务节点上的数据处理流程造成影响，并避免单据数据被其中某个业务节点进行篡改等情况，保证核对结果的准确性及有效性。

本申请提供了如下方案：

一种单据数据处理系统，包括：

第一系统以及多个第二系统，所述第二系统与商品对象数据处理链路中的节点相对应；其中，所述第一系统与所述第二系统之间具有通信通道；

所述第二系统，用于对所述链路中目标节点上的商品对象数据进行处理，生成单据数据，通过所述通信通道将所述单据数据提供给所述第一系统；

所述第一系统，用于获得所述链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点之间的单据数据匹配规则信息，接收到所述第二系统提供的单据数据后，生成核对任务，针对所述核对任务，对所述链路中的节点上的单据数据进行核对。

一种单据数据处理方法，包括：

获得商品对象数据处理链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息；

接收到多个第二系统提供的单据数据后，生成核对任务；其中，所述第二系统与商品对象数据处理链路中的节点相对应；

针对所述核对任务，对所述链路中的节点上的单据数据进行核对。

一种单据数据处理方法，包括：

对商品对象数据处理链路中目标节点上的商品对象数据进行处理，并生成单据数据；

将所述单据数据提供给第一系统，以便所述第一系统生成核对任务，并核对任务为单位，按照预先保存的节点之间的上下游关系信息以及匹配规则，对所述链路中的节点上的单据数据进行核对。

一种单据数据处理装置，包括：

信息获得单元，用于获得商品对象数据处理链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息；

核对任务生成单元，用于接收到多个第二系统提供的单据数据后，生成核对任务；其中，所述第二系统与商品对象数据处理链路中的节点相对应；

核对单元，用于针对所述核对任务，对所述链路中的节点上的单据数据进行核对。

一种单据数据处理装置，包括：

单据数据生成单元，用于对商品对象数据处理链路中目标节点上的商品对象数据进行处理，并生成单据数据；

单据数据提供单元，用于将所述单据数据提供给第一系统，以便所述第一系统生成核对任务，并核对任务为单位，按照预先保存的节点之间的上下游关系信息以及匹配规则，对所述链路中的节点上的单据数据进行核对。

一种电子设备，包括：

一个或多个处理器；以及

与所述一个或多个处理器关联的存储器，所述存储器用于存储程序指令,所述程序指令在被所述一个或多个处理器读取执行时,执行如下操作:

获得商品对象数据处理链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息；

接收到多个第二系统提供的单据数据后，生成核对任务；其中，所述第二系统与商品对象数据处理链路中的节点相对应；

针对所述核对任务，对所述链路中的节点上的单据数据进行核对。

根据本申请提供的具体实施例，本申请公开了以下技术效果：

本申请实施例中通过提供与具体的链路中的业务处理节点所在的第二系统相独立的第一系统，并在第一系统与第二系统之间建立通信通道，使得第二系统中产生的单据数据可以通过该通信通道提供给第一系统，可以在第一系统中对同一链路上各个不同节点所在的第二系统中产生的单据数据进行核对。通过这种方式，可以实现分布式架构、多个业务应用协同工作时的单据数据核对，解决了涉及多个业务环节，多个业务服务器，复杂链路的单据数据核对问题，并且不会对具体业务节点上的数据处理流程造成影响。另外，由于第二系统中的单据数据可以发送到第一系统，后续的具体核对过程对于该第二系统而言是透明的，因此，也可以避免单据数据被其中某个业务节点进行篡改等情况，保证核对结果的准确性及有效性。

其中，在核对的过程中，可以从链路的起始节点开始，按照链路中节点之间的上下游关系信息以及预置的匹配规则，对所述链路中的节点上的单据数据进行依次核对。

另外，如果链路中某个环节没有核对成功，核对任务就可以不断重试，这种任务定时重试机制，可以解决交易付款和商品交付间隔较长时间核对的难题。再者，通过任务重试机制，能够确保每一条链路上的全部节点核对完成后，才会置任务状态为成功，保证了不会遗漏任何收入。

当然，实施本申请的任一产品并不一定需要同时达到以上所述的所有优点。

附图说明

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

图1是本申请实施例提供的系统的示意图；

图2是本申请实施例提供的处理流程示意图；

图3是本申请实施例提供的核对顺序示意图；

图4是本申请实施例提供的第一方法的流程图；

图5是本申请实施例提供的第二方法的流程图；

图6是本申请实施例提供的第一装置的示意图；

图7是本申请实施例提供的第二装置的示意图；

图8是本申请实施例提供的电子设备的示意图。

具体实施方式

下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本申请一部分实施例，而不是全部的实施例。基于本申请中的实施例，本领域普通技术人员所获得的所有其他实施例，都属于本申请保护的范围。

在本申请实施例中，为了能够在复杂链路场景中也能够实现对相关单据数据的核对，提供了核对服务器(当然，也可以有其他的名称，在本申请实施例中统一称为“第一系统”)。该第一系统可以与具体的业务系统服务器相独立。当然，本申请实施例中所指的独立具体可以是指功能上的独立，具体的，可以单独部署在一台或者多台专用的物理设备上。或者，也可以部署在其中某个业务系统的服务器中，但在逻辑上需要与具体的业务处理逻辑相隔离；再或者，由于本申请实施例中，第一系统提供的核对结果主要可以用于提供给财务等相关系统来使用，因此，具体的第一系统也可以直接部署在财务系统内的某台或者多台物理设备上，等等。

其中，在本申请实施例中，同一链路中不同的业务节点上的处理操作可能是分布在不同的业务系统的服务器(也即具体商品对象信息处理链路上各个具体节点分别对应的服务器，在本申请实施例中可以称为第二系统)上，甚至通过不同的应用来完成。为此，在本申请实施例中，还可以由各个具体业务节点上的第二系统，将具体产生的单据数据提供给第一系统，然后，由第一系统进行统一的核对处理。

为了达到上述目的，第一系统与所述第二系统之间可以建立通信连接，使得相互之间可以可以进行信息互通。例如，具体实现时，可以采用消息通信机制，使得第二系统可以按照一定的格式生成具体的消息包，第一系统则可以通过消息监听机制，接收到第二系统的消息包，并且能够对消息报中的消息进行识别，等等。

其中，具体的单据数据主要是用于进行与财务等相关的数据核对，因此，第二系统中还可以保存具体的条件信息，第二系统在产生具体的单据数据后，可以与这种条件信息进行匹配，如果单据数据的状态符合该条件信息，就可以生成相应的消息包，并发送给第一系统。例如，具体的条件可以是，单据数据一旦生成便需要进行发送，或者，具体节点上的处理操作一旦完成便进行发送，等等。也就是说，第二系统中的单据数据的状态一旦满足某预先设定的与财务核对相关的条件，就可以自动通过消息的方式发送给第一系统。之后，是在第一系统上对具体的单据数据进行核对操作，该第一系统与第二系统之间相互独立，由此，一方面可以避免对具体业务节点上的数据处理流程造成影响，另一方面，也可以避免单据数据被其中某个业务节点进行篡改等情况，保证核对结果的准确性及有效性。

其中，为了进行具体的核对操作，第一系统中可以预先存储具体的商品对象数据处理链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息。例如，对于交易链路，具体包括的节点可以有交易、履约、库存、配送等，其中，“交易”是链路的起始节点，其下游的第一个节点是“履约”，再下一个节点是“库存”，再下一个节点是“配送”，等等。另外，具体在进行财务等相关的单据数据核对时，通常是在不同的节点产生的单据数据之间进行核对。例如，某消费者通过线上完成一次下单后，在“交易”环节上会产生对应的交易单据后，之后将会进入到“履约”环节进行处理，并产生相应的履约单据，在完成履约之后，又会进入到“库存”环节进行处理，并产生相应的库存单据，等等。具体在进行单据数据核对时，主要是针对具体产生的交易单据，判断后续各个环节上针对该交易单据产生的单据数据是否准确、完整、一致、是否按时完成，等等。

第一系统在收到具体的单据数据后，可以根据具体链路中的起始节点对应的第二系统提供的单据数据，生成核对任务，然后针对所述核对任务，对所述链路中的节点上的单据数据进行核对。其中，在优选的实现方式下，在执行具体的核对任务的过程中，可以从该起始节点开始，依次对链路上下游每个环节上的单据数据进行核对，一个业务环节匹配成功了，才能进入下个业务环节核对，前一个环节没核对成功，还可以将核对任务放入重试队列，等待下一次任务调度，等等。

通过上述方式，实现了分布式架构、多个业务应用协同工作时，单据数据的核对，解决了涉及多个业务环节，多个业务服务器，复杂链路的单据数据核对问题，并且不会对具体业务节点上的数据处理流程造成影响，也可以避免单据数据被其中某个业务节点进行篡改等情况，保证核对结果的准确性及有效性。另外，如果链路中某个环节没有核对成功，核对任务就可以不断重试，这种任务定时重试机制，可以解决交易付款和商品交付间隔较长时间核对的难题。再者，通过任务重试机制，能够确保每一条链路上的全部节点核对完成后，才会置任务状态为成功，保证了不会遗漏任何收入。

下面对本申请实施例提供的具体技术方案进行详细介绍。

实施例一

首先，该实施例一提供了一种单据数据处理系统，具体的，参见图1，该系统具体可以包括：第一系统101以及多个第二系统102，所述第二系统102与商品对象数据处理链路中的节点相对应；其中，所述第一系统101与所述第二系统102之间具有通信通道；

所述第二系统102，用于对所述链路中其中一节点上的商品对象数据进行处理，生成单据数据，并通过所述通信通道将所述单据数据提供给所述第一系统；

所述第一系统101，用于获得所述链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点之间的单据数据匹配规则信息，接收到所述第二系统提供的单据数据后，生成核对任务，针对所述核对任务，对所述链路中的节点上的单据数据进行核对。

其中，具体的商品对象数据处理链路可以有多条，例如，在交易场景下，具体可以是指交易链路，在商品入库场景下，可以是指商品入库链路，等等。在不同的链路中，通常都会包含多个具体的业务节点，这些节点的处理逻辑分布在多个不同的第二系统上。

在本申请实施例中，首先可以预先在第一系统中保存商品对象数据处理链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点之间的单据数据匹配规则信息。例如，在一种实现方式下，第一系统中存储的信息具体可以如表1所示：

表1

其中，具体的链路中包括哪些节点，节点之间的上下游关系以及节点对应的匹配规则等，具体可以是由用户进行定制的。也就是说，对于不同的用户而言，具体需要对哪些节点上的单据数据进行核对，可能是不同的，因此，为了满足不同用户的不同需求，可以为用户提供具体的定制操作入口，这样，服务器可以通过接收用户提交的定制信息，来获得具体的链路中包括的节点信息，节点之间的上下游关系以及节点对应的匹配规则。

其中，具体的匹配规则信息可以根据实际业务场景中的情况而定，另外，在具体实现时，具体的匹配规则也不限于两个节点之间，可能还需要在多个节点之间满足某些规则，等等。例如，仍以交易链路场景为例，在对具体的履约节点上的单据数据进行匹配时，对应的匹配规则可能是交易节点与履约节点之间的匹配规则，包括商品对象名称、数量等是否一致。具体实现时，可以通过写代码的方式配置关于具体链路中的节点、匹配规则等信息，或者，还可以提供相应的配置界面，使得用户可以通过在配置界面中进行可视化配置的方式进行配置，等等。

在第一系统中存储了上述信息的基础上，第二系统便可以将具体产生的单据数据提供给该第一系统。其中，第二系统具体可以是具体业务链路中用于提供其中某个或者某几个节点功能实现的业务系统，也就是说，在本申请实施例中，一个链路中通过包括多个节点，这些节点上的功能分布在多个不同的业务系统中，需要通过多个分布在不同系统内的服务器共同配合，来完成某个链路上的具体数据处理任务。例如，同样以交易链路为例，在消费者通过线上的App等购买了某个商品对象的情况下，首先可以由交易系统生成交易订单，并且会生成与财务相关的单据信息；之后，可以将交易订单中的信息(包括订单号，商品对象名称、数量等)提供给履约系统，履约系统则可以根据交易订单中的信息生成对应的履约任务，对应有履约订单，相应的，也会生成与财务相关的履约单据。完成履约操作后，具体的处理流程还会进入到库存系统，配送系统，分别生成对应的库存单据、配送单据，等等。在每个环节上的第二系统处理本节点内的任务的过程中，都会产生相应的单据数据，这种单据数据主要可以体现财务等部门需要的数据。在本申请实施例中，第二系统中产生了具体的单据数据后，可以根据预先设定的条件信息，这种条件信息中可以包括具体的单据类型，对应的状态触发条件等等。这样，第二系统可以判断具体的单据数据的状态是否满足具体的条件，如果满足，则可以提供给第一系统。其中，所述预先设定的条件信息可以是根据财务等相关系统中所需数据的具体情况来设定。例如，对于“履约”环节，可以是在某个履约单变为“已完成”状态时，向第一系统提供对应的履约单据数据，等等。

也就是说，第二系统在具体所在的业务节点上对实际业务场景中产生的数据进行处理的过程中，会产生相应的单据数据，一旦这种数据满足预置条件，便可以提供给第一系统，由第一系统进行具体的数据核对操作。换言之，第一系统在单据数据产生阶段便已经将具体的单据数据提供给了第一系统，后续的具体的核对操作都是在第一系统中完成，因此，即使核对过程中，某个节点上的单据数据出现了差异，该节点对应的第二系统也无法通过篡改数据的方式来企图逃避处罚。

具体实现时，第一系统可以通过多种方式接收第二系统提供的单据数据。例如，在其中一种方式下，如前文所述，第二系统可以主动向第一系统提供具体的单据数据，具体可以通过消息的方式进行发送，此时，第一系统可以通过监听各个第二系统的消息的方式来进行接收。当然，在其他方式下，还可以是由第一系统向第二系统进行请求的方式来获取，等等。

总之，第一系统能够从第二系统获取到具体的单据数据，其中，由于第二系统为多个，具体第二系统中通常会并发生成多个单据数据，因此，第一系统接收到的单据数据也会是多条。另外，针对同一业务订单(例如，某消费者用户线上下单后生成的交易订单，或者某商家发起补货后生成的补货单等)，同一链路上不同环节处理该业务订单的时间不同，彼此之间还可能会间隔比较长的时间，因此，同一核对任务可能会经历比较长的时间才会最终完成，在此期间，还会不断地从第二系统中收到更多的单据数据。因此，第一系统的处理方式具体可以是，在收到第二系统的单据数据后，可以首先在第一系统本地进行保存。另外，由于每条单据数据会携带有消息来源等信息，例如，来自于具体哪个第二系统，甚至直接可以携带具体的节点标识等信息，等等，这样，使得第一系统可以获知每条单据数据对应的节点标识。例如，具体实现时，第一系统接收到的单据数据的信息可以如表2所示：

表2

单据标识	第二系统标识	节点标识
			10001	2001	交易
10002	2001	交易
			10003	2002	履约
10004	2003	库存
			……	……	……

也就是说，在同一时刻，第一系统接收到的单据数据中，可能包括交易节点的第二系统提供的多个交易单据，履约节点的第二系统提供的多个履约单据，等等。之后，第一系统还可以根据接收到的单据数据生成核对任务，然后逐条核对。

其中，由于具体的核对任务是从链路的起始节点开始，并且，对于同一业务订单，最先由起始节点对应的第二系统进行第一环节的处理，最先生成的也是该起始节点对应的单据数据，其他下游节点上的第二系统中生成的单据数据，通常都是在起始节点完成了第一环节的处理之后产生的。另外，实际进行核对时，主要也是判断起始节点产生的单据数据，在后续的各个下游节点上，是否存在与之匹配的、数据一致性的单据数据，等等。因此，具体在生成核对任务时，可以根据具体起始节点对应的第二系统提供的单据数据，生成多条核对任务。具体实现时，由于第一系统中还保存有每条链路所包含的节点标识以及彼此之间的上下游关系，因此，可以获知具体每条链路的起始节点标识，而接收到的单据数据中携带有具体的第二系统标识或者节点标识，总之，可以确定出每条单据数据对应的节点标识，因此，在收到一条单据数据后，第一系统可以根据其对应的节点标识，确定出是否为某链路的起始节点对应的第二系统生成的单据数据。如果是，则可以据此生成一条核对任务。例如，对于交易链路而言，其起始节点是交易，则可以从收到的单据数据中，提取出交易节点对应的第二系统提供的单据数据，然后，分别根据这些单据数据生成多条核对任务，等等。

其中，由于具体的场景可能会有多个，具体的链路类型也会有多种，不同的链路类型对应的起始节点可能是不同的，因此，可以将各种不同链路类型对应的起始节点进行汇总，然后，针对这些起始节点对应的单据数据，生成多条核对任务，同时可以确定出每条核对任务对应的链路类型。例如，交易链路的起始节点为交易节点，调货链路的起始节点为调货，则如果某条单据数据对应的是交易节点，则可以根据该单据数据生成一条核对任务，并且可以确定出该单据数据是交易链路中产生的单据数据，后续在具体进行核对时，可以根据交易链路中的上下游节点信息，以及匹配规则信息进行核对。如果某条单据数据对应的是调货节点，则同样可以根据该单据数据生成一条核对任务，但此时可以确定出该单据数据是调货链路中产生的单据数据，后续在具体进行核对时，可以根据调货链路中的上下游节点信息，以及匹配规则信息进行核对。

具体实现时，由于核对任务为多条，并且通常需要经过比较长的时间才会完成同一条核对任务的核对，因此，这些核对任务可以根据时间的先后顺序等信息，加入到任务队列中。后续可以从队列中取出具体的核对任务，逐条进行核对。例如，具体实现时，第一系统的任务队列中保存的信息可以如表3所示：

表3

核对任务标识	单据标识	节点标识	链路类型
				30001	10001	交易	交易链路
30002	10002	交易	交易链路
				……	……	……	……

其中，具体对每条核对任务进行核对时，可以从所述起始节点开始，按照所述上下游关系信息以及所述匹配规则，对所述链路中的节点上的单据数据进行依次核对。具体的，在具有多种不同的链路类型的情况下，不同链路类型中包含的节点，各自之间的上下游关系，以及匹配规则等可能都是不同的，因此，还可以根据所述核对任务中的起始节点标识，确定出该核对任务对应的目标链路类型，然后，根据该目标链路类型对应的上下游关系信息以及所述匹配规则信息，对所述单据数据进行核对。例如，某核对任务对应的起始节点标识是“交易”，则可以确定对应的链路类型为交易链路，进而可以确定出该链路中的第二个节点是履约，第三个是库存，最后一个是配送，等等。然后，按照上述上下游的顺序，依次对各个节点上的单据数据进行匹配。

在确定出具体的链路类型等信息后，具体在进行核对时，第一系统首先可以针对所述核对任务中已完成匹配的当前节点，从已收到的单据数据中取出其下一节点对应的单据数据，然后，利用当前节点与下一节点之间的匹配规则信息，对所述下一节点对应的单据数据进行匹配判断，如果匹配成功，则将所述下一节点作为新的当前节点，并对所述新的当前节点的下一节点对应的单据数据进行匹配判断。也就是说，只有在将一条链路上的一个节点对应的单据数据匹配成功后，才会进行下一节点的数据匹配。

需要说明的是，具体在针对某个已完成匹配的当前节点，对其下一节点上的单据数据进行匹配时，主要是在这两个节点之间的单据数据之间进行匹配，例如，交易单据与履约单据之间是否匹配，等等。其中，每条核对任务是与一个具体的交易订单对应，也就是说，假设有三个消费者同时通过在线下单的方式进行了下单，相应的，交易系统分别生成了三份交易订单，并对应三份交易单据数据，具体的交易单据数据会具有单号等信息；相应的，在到达履约环节进行处理时，生成的履约单也会具有单号等标识信息，并与交易单号关联；后续的库存环节、配送环节也均是如此，具体某个环节上的单号等标识信息都会与上一节点中的单号之间具有绑定关系。这样，在第一系统接收到之后，会生成三条核对任务，分别进行核对。其中，在针对其中一条核对任务进行核对时，具体可以通过各个节点对应的第二系统提供的单据数据，在单号等标识信息之间的关联关系，找到与同一核对任务中涉及到的各个节点上的单据数据，然后，再根据节点之间的上下游关系，依次对各节点上的单据数据进行核对。

其中，如果某当前节点对应的下一节点的单据数据中，与当前节点上的单据数据关联的单据数据不存在、不完整、不一致或者状态不符，则可以确定该下一节点的单据数据未匹配成功。例如，交易单据中包括三件商品对象，但是履约单据中仅包括其中两件，则匹配失败，等等。但是，上述匹配失败的原因可能是由于具体节点尚未完全处理完的原因导致的。例如，某交易订单中包括一道需要现场加工制作的菜品，以及一件可以直接打包的成品，此时，在履约系统中，可能会针对该交易订单，拆分成了两个履约单，分别由后场的厨房部门以及前场的货架部门进行履约，相应的，也会分别生成不同的履约单据数据。但是，前场货架对应的履约单可能比较快就能完成，而后场的厨房则需要一段时间进行加工制作等处理，因此，需要相对较长的时间才能完成。此时，就可能出现同一个交易订单中对应两个不同的履约单据，两个单据先后在不同的时间到达第一系统的情况。此时，在后一个履约单据尚未到达时，如果对履约单据进行匹配，则会发现履约单据中的商品对象数量与交易单据中不符的情况。此时，在本申请实施例中，并不是直接将该核对任务认定为匹配失败，而是将所述核对任务加入到重试队列中，并在等待预置的时间间隔后，根据所述第二系统新提供的单据数据，重新执行该核对任务。例如，在前述例子的核对任务中，在对履约节点上的单据数据进行匹配时，发现履约单据不完整，则可以将该核对任务加入到重试队列中，过一段时间之后，再重新进行核对。也就是说，在本申请实施例中，允许一个链路中部分节点上的任务处理存在时间上的滞后性，通过不断的重试，可以解决同一链路中从起始节点(例如，交易付款)到结束节点(例如，商品交付)之间时间间隔较长情况下的数据核对问题。

具体实现时，第一系统的重试队列中还可以分别对各个核对任务中各个节点的当前核对结果进行保存，下次再进行核对时，可以从最近完成匹配的节点开始向下游进行匹配。例如，具体实现时，针对交易链路这种场景，第一系统的重试队列中保存的核对任务状态信息可以如表4所示：

表4

其中，如上所述，在具体实现时，具体的第二系统可能会存在将一个订单拆分成多个来分别进行处理的情况，因此，为了避免第一系统出现误判等情况，第二系统在对所述链路中其中一节点上的商品对象数据进行处理的过程中，还可以确定该节点上生成的单据数据的组成结构信息，并在向所述第一系统提供所述单据数据时，还向所述第一系统提供所述组成结构信息。这里的组成结构信息就可以包括具体的单据拆分情况，具体拆分后的单据数量等信息。这种信息也可以通过消息包的形式提供给第一系统。也就是说，假设履约系统将某订单拆分成三个履约单，则提供给第一系统的消息包将会有四个，其中一个是关于具体拆分情况对应的单据数据组成结构信息，另外三个则是对应三个履约单据数据。通常情况下，单据数据组成结构信息可以最先提供给第一系统，其中也携带有与上一节点中的单据标识相关联的标识，这样，第一系统便可以获知，在对该节点上的单据数据进行匹配时，需要对三份履约单据数据进行匹配，等到三份履约单据数据均到齐之后，如果与上一节点中的商品对象类别、数量等信息一致，则可以确定该履约节点上的单据数据匹配成功。

另外，在实际应用中，可能存在第二系统提供的单据数据不规范的情况，例如，不存在所需的必要字段，等等。此时，第一系统还可以用于存储各节点标识对应的单据数据的核心字段标识信息；在接收到所述第二系统提供的单据数据后，根据所述第二系统对应的节点标识，判断所述单据数据是否包含所述核心字段上的数据，如果包含，则进行保存，否则可以向所述第二系统提供错误提示信息，要求第二系统进行重发等处理。

再者，还可能存在第二系统的单据数据漏发，或者第一系统漏收等情况，上述情况都会对最终的核对结果造成直接影响。为了避免这种情况发生，第一系统还可以按照预置的周期(例如，每隔一小时，等等)，对当前周期内接收到的单据数据，与各自对应的第二系统内的单据数据生成情况及状态进行比对，如果存在不一致的单据数据，则提示第二系统对该单据数据进行重发补偿。其中，具体实现时，可以通过多种方式实现上述比对操作，例如，第一系统可以向第二系统请求获得在一定时间段内的单据数据列表信息，然后由第一系统进行比对，等等。这样，能够及时发现和补偿遗漏单据，保证了核对结果的可靠性。

以商品对象交易链路为例，参见图2所示，具体的交易链路中包括的节点按照上下游关系依次为：交易，履约，库存，配送，此时，第二系统包括分别用于对商品对象进行交易、履约、库存、配送处理的服务器，提供给第一系统的单据数据分别包括交易单据、履约单据、库存单据、配送单据等等。

第一系统在接收到上述各自单据之后，首先可以进行校验，具体包括对核心字段的数据完整性等进行校验，如果不完整，则还可以要求第二系统进行数据补全处理。之后，可以将具体接收到的单据数据保存为单据数据池，也即，其中包括多条单据数据。后续将会根据这些单据数据生成核对任务，并逐条进行核对。另外，还可以每隔一定的时间间隔，将第一系统中的单据数据池与第二系统内部在这段时间内的单据数据进行比对，如果发现有漏发或者漏收的情况，可以提示第二系统对该单据数据进行重发补偿。

其中，具体在针对每条核对任务进行核对时，所述第一系统具体用于：

根据从所述第二系统接收到的交易单据生成核对任务，对于其中一核对任务，从接收到的履约单据数据中，根据交易节点与履约节点之间的匹配规则，判断是否存在符合对应匹配规则的履约单据；

如果匹配成功，则从接收到的库存单据数据中，根据履约单据与库存单据之间的匹配规则，判断是否存在符合对应匹配规则的库存单据；

如果匹配成功，则从接收到的配送单据数据中，根据库存单据与配送单据之间的匹配规则，判断是否存在符合对应匹配规则的配送单据，

如果匹配成功，则该核对任务核对通过。

也就是说，如图3所示，具体针对一条核对任务，可以从交易单据开始进行核对，履约单据核对通过后，再对库存单据进行核对，库存单据核对通过后，再对配送单据进行核对，配送单据核对通过后，则可以确定该核对任务完成，且数据匹配成功。

针对其他的数据处理链路，包括商品入库，调货，补货等等，也可以按照上述方式进行处理，这里不再一一进行举例介绍。

在针对具体的核对任务完成核对处理后，对于一直未核对成功的核对任务，例如某节点处的单据数据在反复重试多次之后仍然未能匹配成功，则可以加入到差异记录中。最终可以输出差异报表等信息，这种信息可以提供给财务等相关部门的作业人员使用。或者，还可以直接将该信息提供给其他的相关作业部门，对信息进行进一步的处理后，生成相关的财务报表等信息。其中，关于所述差异报表，其中具体可以保存具体未通过核对的任务标识，关联的起始节点对应的单据单号，未核对通过的节点标识等信息。例如，具体可以如表5所示：

表5

总之，本申请实施例中通过提供与具体的链路中的业务处理节点所在的第二系统相独立的第一系统，并在第一系统与第二系统之间建立通信通道，使得第二系统中产生的单据数据可以通过该通信通道提供给第一系统，可以在第一系统中对同一链路上各个不同节点所在的第二系统中产生的单据数据进行核对。通过这种方式，可以实现分布式架构、多个业务应用协同工作时的单据数据核对，解决了涉及多个业务环节，多个业务服务器，复杂链路的单据数据核对问题，并且不会对具体业务节点上的数据处理流程造成影响。另外，由于第二系统中的单据数据可以发送到第一系统，后续的具体核对过程对于该第二系统而言是透明的，因此，也可以避免单据数据被其中某个业务节点进行篡改等情况，保证核对结果的准确性及有效性。

其中，在核对的过程中，可以从链路的起始节点开始，按照链路中节点之间的上下游关系信息以及预置的匹配规则，对所述链路中的节点上的单据数据进行依次核对。

另外，如果链路中某个环节没有核对成功，核对任务就可以不断重试，这种任务定时重试机制，可以解决交易付款和商品交付间隔较长时间核对的难题。再者，通过任务重试机制，能够确保每一条链路上的全部节点核对完成后，才会置任务状态为成功，保证了不会遗漏任何收入。

实施例二

该实施例二是与前述实施例一相对应的，从第一系统的角度，提供了一种单据数据处理方法，参见图4，该方法具体可以包括：

S401：获得商品对象数据处理链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息；

S402：接收到多个第二系统提供的单据数据后，生成核对任务；其中，所述第二系统与商品对象数据处理链路中的节点相对应；

S403：针对所述核对任务，对所述链路中的节点上的单据数据进行核对。

具体实现时，可以通过消息监听机制，接收所述第二系统提供的消息包，所述消息包中携带有所述单据数据。

具体在生成核对任务时，可以根据所述链路中的起始节点标识对应的第二系统提供的单据数据生成所述核对任务。也即，对于接收到的某条单据数据，如果提供该单据的第二系统对应的节点是某链路的起始节点，则可以根据该单据数据生成一条核对任务。

具体在进行核对时，可以从所述链路的起始节点开始，按照所述上下游关系信息以及所述匹配规则，对所述链路中的节点上的单据数据进行依次核对。

具体实现时，所述待处理的商品对象数据处理链路类型为多个，分别对应不同的起始节点；此时，可以根据所述核对任务中的起始节点标识，确定该核对任务对应的目标链路类型，并根据该目标链路类型对应的上下游关系信息以及所述匹配规则信息，对所述单据数据进行核对。

其中，具体在对所述链路中的节点上的单据数据进行依次核对时，具体可以首先确定所述核对任务中已完成匹配的当前节点，从已收到的单据数据中取出其下一节点对应的单据数据，利用当前节点与下一节点之间的匹配规则信息，对所述下一节点对应的单据数据进行匹配判断；如果匹配成功，则将该下一节点确定为已完成匹配的当前节点，并对其下一节点对应的单据数据进行匹配判断，直到完成所述链路的结束节点的匹配判断。

其中，在一种具体的场景下，所述商品对象数据处理链路包括商品对象交易链路；所述链路中包括的节点按照上下游关系依次为：交易，履约，库存，配送；所述第二系统包括分别用于对商品对象进行交易、履约、库存、配送处理的第二系统；此时，具体可以根据从所述第二系统接收到的交易单据生成核对任务；对于其中一核对任务，从接收到的履约单据数据中，根据交易节点与履约节点之间的匹配规则，判断是否存在符合对应匹配规则的履约单据；如果匹配成功，则从接收到的库存单据数据中，根据履约单据与库存单据之间的匹配规则，判断是否存在符合对应匹配规则的库存单据；如果匹配成功，则从接收到的配送单据数据中，根据库存单据与配送单据之间的匹配规则，判断是否存在符合对应匹配规则的配送单据，如果匹配成功，则该核对任务核对通过。

另外，在具体实现时，如果某当前节点对应的下一节点的单据数据未匹配成功，则将所述核对任务加入到重试队列中，并在等待预置的时间间隔后，根据所述第二系统新提供的单据数据，重新执行该核对任务。

其中，如果某当前节点对应的下一节点的单据数据中，与当前节点上的单据数据关联的单据数据不存在、不完整、不一致或者状态不符，则确定该下一节点的单据数据未匹配成功。

另外，在具体实现时，还可以接收第二系统提供的对应节点上生成的单据数据的组成结构信息，以便结合所述组成结构信息对所述节点上的单据数据进行核对。

为了保证数据的完整性，还可以存储各节点标识对应的单据数据的核心字段标识信息；在接收到所述第二系统提供的单据数据后，根据所述第二系统对应的节点标识，判断所述单据数据是否包含所述核心字段上的数据，如果包含，则进行保存，否则向所述第二系统提供错误提示信息。

另外，为了避免出现第二系统漏发，或者第一系统漏收等情况，还可以按照预置的周期，对当前周期内接收到的单据数据，与各自对应的第二系统内的单据数据生成情况及状态进行比对，如果存在不一致的单据数据，则提示第二系统对该单据数据进行重发补偿。

具体实现时，可以接收目标用户提供的链路定制请求，所述请求中携带有所述链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息。

实施例二

该实施例二也是与实施例一相对应的，从第二系统的角度，提供了一种单据数据处理方法，参见图5，该方法具体可以包括：

S501：对商品对象数据处理链路中目标节点上的商品对象数据进行处理，并生成单据数据；

S502：将所述单据数据提供给第一系统，以便所述第一系统生成核对任务，并核对任务为单位，按照预先保存的节点之间的上下游关系信息以及匹配规则，对所述链路中的节点上的单据数据进行核对。

关于实施例二以及实施例三中的未详述部分，可以参见前述实施例一中的记载，这里不再赘述。

与实施例二相对应，本申请实施例还提供了一种单据数据处理装置，参见图6，该装置具体可以包括：

信息获得单元601，用于获得商品对象数据处理链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息；

核对任务生成单元602，用于接收到多个第二系统提供的单据数据后，生成核对任务；其中，所述第二系统与商品对象数据处理链路中的节点相对应；

核对单元603，用于针对所述核对任务，对所述链路中的节点上的单据数据进行核对。

具体实现时，该装置还可以包括：

监听单元，用于通过消息监听机制，接收所述第二系统提供的消息包，所述消息包中携带有所述单据数据。

其中，所述核对任务生成单元具体可以用于：

根据所述链路中的起始节点标识对应的第二系统提供的单据数据生成所述核对任务。

其中，核对单元具体可以用于，针对所述核对任务，从所述链路的起始节点开始，按照所述上下游关系信息以及所述匹配规则，对所述链路中的节点上的单据数据进行依次核对。

其中，所述待处理的商品对象数据处理链路类型为多个，分别对应不同的起始节点；

所述核对单元具体可以用于：根据所述核对任务中的起始节点标识，确定该核对任务对应的目标链路类型，并根据该目标链路类型对应的上下游关系信息以及所述匹配规则信息，对所述单据数据进行核对。

具体的，所述核对单元具体可以用于：

确定所述核对任务中已完成匹配的当前节点，从已收到的单据数据中取出其下一节点对应的单据数据，利用当前节点与下一节点之间的匹配规则信息，对所述下一节点对应的单据数据进行匹配判断；

如果匹配成功，则将该下一节点确定为已完成匹配的当前节点，并对其下一节点对应的单据数据进行匹配判断，直到完成所述链路的结束节点的匹配判断。

其中，所述商品对象数据处理链路包括商品对象交易链路；所述链路中包括的节点按照上下游关系依次为：交易，履约，库存，配送；所述第二系统包括分别用于对商品对象进行交易、履约、库存、配送处理的第二系统；

所述核对单元具体可以用于：

根据从所述第二系统接收到的交易单据生成核对任务；

对于其中一核对任务，从接收到的履约单据数据中，根据交易节点与履约节点之间的匹配规则，判断是否存在符合对应匹配规则的履约单据；

如果匹配成功，则从接收到的库存单据数据中，根据履约单据与库存单据之间的匹配规则，判断是否存在符合对应匹配规则的库存单据；

如果匹配成功，则从接收到的配送单据数据中，根据库存单据与配送单据之间的匹配规则，判断是否存在符合对应匹配规则的配送单据，如果匹配成功，则该核对任务核对通过。

另外，该装置还可以包括：

重试单元，用于如果某当前节点对应的下一节点的单据数据未匹配成功，则将所述核对任务加入到重试队列中，并在等待预置的时间间隔后，根据所述第二系统新提供的单据数据，重新执行该核对任务。

其中，如果某当前节点对应的下一节点的单据数据中，与当前节点上的单据数据关联的单据数据不存在、不完整、不一致或者状态不符，则确定该下一节点的单据数据未匹配成功。

为了避免第一系统误判，该装置还可以包括：

结构信息接收单元，用于接收第二系统提供的对应节点上生成的单据数据的组成结构信息，以便结合所述组成结构信息对所述节点上的单据数据进行核对。

另外，该装置还可以包括：

字段标识信息存储单元，用于存储各节点标识对应的单据数据的核心字段标识信息；

字段判断单元，用于在接收到所述第二系统提供的单据数据后，根据所述第二系统对应的节点标识，判断所述单据数据是否包含所述核心字段上的数据，如果包含，则进行保存，否则向所述第二系统提供错误提示信息。

为了避免出现漏发或者漏收的情况，该装置还可以包括：

比对单元，用于按照预置的周期，对当前周期内接收到的单据数据，与各自对应的第二系统内的单据数据生成情况及状态进行比对，如果存在不一致的单据数据，则提示第二系统对该单据数据进行重发补偿。

所述信息获得单元具体可以用于：接收目标用户提供的链路定制请求，所述请求中携带有所述链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息。

与实施例三相对应，本申请实施例还提供了一种单据数据处理装置，参见图7，该装置具体可以包括：

单据数据生成单元701，用于对商品对象数据处理链路中目标节点上的商品对象数据进行处理，并生成单据数据；

单据数据提供单元702，用于将所述单据数据提供给第一系统，以便所述第一系统生成核对任务，并核对任务为单位，按照预先保存的节点之间的上下游关系信息以及匹配规则，对所述链路中的节点上的单据数据进行核对。

另外，本申请实施例还提供了一种电子设备，包括：

一个或多个处理器；以及

与所述一个或多个处理器关联的存储器，所述存储器用于存储程序指令,所述程序指令在被所述一个或多个处理器读取执行时,执行如下操作:

获得商品对象数据处理链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息；

接收到多个第二系统提供的单据数据后，生成核对任务；其中，所述第二系统与商品对象数据处理链路中的节点相对应；

针对所述核对任务，对所述链路中的节点上的单据数据进行核对。

其中，图8示例性的展示出了计算机系统的架构，具体可以包括处理器810，视频显示适配器811，磁盘驱动器812，输入/输出接口813，网络接口814，以及存储器820。上述处理器810、视频显示适配器811、磁盘驱动器812、输入/输出接口813、网络接口814，与存储器820之间可以通过通信总线830进行通信连接。

其中，处理器810可以采用通用的CPU(Central Processing Unit，中央处理器)、微处理器、应用专用集成电路(Application Specific Integrated Circuit，ASIC)、或者一个或多个集成电路等方式实现，用于执行相关程序，以实现本申请所提供的技术方案。

存储器820可以采用ROM(Read Only Memory，只读存储器)、RAM(Random AccessMemory，随机存取存储器)、静态存储设备，动态存储设备等形式实现。存储器820可以存储用于控制电子设备800运行的操作系统821，用于控制电子设备800的低级别操作的基本输入输出系统(BIOS)。另外，还可以存储网页浏览器823，数据存储管理系统824，以及单据数据处理系统825等等。上述单据数据处理系统825就可以是本申请实施例中具体实现前述各步骤操作的应用程序。总之，在通过软件或者固件来实现本申请所提供的技术方案时，相关的程序代码保存在存储器820中，并由处理器810来调用执行。

输入/输出接口813用于连接输入/输出模块，以实现信息输入及输出。输入输出/模块可以作为组件配置在设备中(图中未示出)，也可以外接于设备以提供相应功能。其中输入设备可以包括键盘、鼠标、触摸屏、麦克风、各类传感器等，输出设备可以包括显示器、扬声器、振动器、指示灯等。

网络接口814用于连接通信模块(图中未示出)，以实现本设备与其他设备的通信交互。其中通信模块可以通过有线方式(例如USB、网线等)实现通信，也可以通过无线方式(例如移动网络、WIFI、蓝牙等)实现通信。

总线830包括一通路，在设备的各个组件(例如处理器810、视频显示适配器811、磁盘驱动器812、输入/输出接口813、网络接口814，与存储器820)之间传输信息。

另外，该电子设备800还可以从虚拟资源对象领取条件信息数据库841中获得具体领取条件的信息，以用于进行条件判断，等等。

需要说明的是，尽管上述设备仅示出了处理器810、视频显示适配器811、磁盘驱动器812、输入/输出接口813、网络接口814，存储器820，总线830等，但是在具体实施过程中，该设备还可以包括实现正常运行所必需的其他组件。此外，本领域的技术人员可以理解的是，上述设备中也可以仅包含实现本申请方案所必需的组件，而不必包含图中所示的全部组件。

通过以上的实施方式的描述可知，本领域的技术人员可以清楚地了解到本申请可借助软件加必需的通用硬件平台的方式来实现。基于这样的理解，本申请的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品可以存储在存储介质中，如ROM/RAM、磁碟、光盘等，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行本申请各个实施例或者实施例的某些部分所述的方法。

本说明书中的各个实施例均采用递进的方式描述，各个实施例之间相同相似的部分互相参见即可，每个实施例重点说明的都是与其他实施例的不同之处。尤其，对于系统或系统实施例而言，由于其基本相似于方法实施例，所以描述得比较简单，相关之处参见方法实施例的部分说明即可。以上所描述的系统及系统实施例仅仅是示意性的，其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性劳动的情况下，即可以理解并实施。

以上对本申请所提供的单据数据处理方法、装置及系统，进行了详细介绍，本文中应用了具体个例对本申请的原理及实施方式进行了阐述，以上实施例的说明只是用于帮助理解本申请的方法及其核心思想；同时，对于本领域的一般技术人员，依据本申请的思想，在具体实施方式及应用范围上均会有改变之处。综上所述，本说明书内容不应理解为对本申请的限制。

Claims (17)

1.一种单据数据处理系统，其特征在于，包括：

第一系统以及多个第二系统，所述第二系统与商品对象数据处理链路中的节点相对应；其中，所述第一系统与所述第二系统之间具有通信通道；其中，所述商品对象数据处理链路包括商品对象交易处理链路，或商品对象入库处理链路；

所述第二系统，用于对所述链路中目标节点上的商品对象数据进行处理，生成单据数据，通过所述通信通道将所述单据数据提供给所述第一系统；

所述第一系统，用于获得所述链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点之间的单据数据匹配规则信息，接收到所述第二系统提供的单据数据后，生成核对任务，针对所述核对任务，从所述链路的起始节点开始，按照所述上下游关系信息以及所述匹配规则，对所述链路中的节点上的单据数据进行依次核对；

其中，所述第一系统在进行所述依次核对时，确定所述核对任务中已完成匹配的当前节点，从已收到的单据数据中取出其下一节点对应的单据数据，利用当前节点与下一节点之间的匹配规则信息，对所述下一节点对应的单据数据进行匹配判断；如果匹配成功，则将该下一节点确定为已完成匹配的当前节点，并对其下一节点对应的单据数据进行匹配判断，直到完成所述链路的结束节点的匹配判断。

2.根据权利要求1所述的系统，其特征在于，

所述第一系统具体用于，从所述链路的起始节点开始，按照所述上下游关系信息以及所述匹配规则，对所述链路中的节点上的单据数据进行依次核对。

3.一种单据数据处理方法，其特征在于，包括：

获得商品对象数据处理链路中包括的多个节点的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息；其中，所述商品对象数据处理链路包括商品对象交易处理链路，或商品对象入库处理链路；

接收到多个第二系统提供的单据数据后，生成核对任务；其中，所述第二系统与商品对象数据处理链路中的节点相对应；

针对所述核对任务，从所述链路的起始节点开始，按照所述上下游关系信息以及所述匹配规则，对所述链路中的节点上的单据数据进行依次核对；

其中在进行所述依次核对时，确定所述核对任务中已完成匹配的当前节点，从已收到的单据数据中取出其下一节点对应的单据数据，利用当前节点与下一节点之间的匹配规则信息，对所述下一节点对应的单据数据进行匹配判断；如果匹配成功，则将该下一节点确定为已完成匹配的当前节点，并对其下一节点对应的单据数据进行匹配判断，直到完成所述链路的结束节点的匹配判断。

4.根据权利要求3所述的方法，其特征在于，还包括：

通过消息监听机制，接收所述第二系统提供的消息包，所述消息包中携带有所述单据数据。

5.根据权利要求3所述的方法，其特征在于，

所述生成核对任务，包括：

根据所述链路中的起始节点标识对应的第二系统提供的单据数据生成所述核对任务。

6.根据权利要求3所述的方法，其特征在于，

所述商品对象数据处理链路的类型为多个，分别对应不同的起始节点；

所述对所述链路中的节点上的单据数据进行依次核对，包括：

根据所述核对任务中的起始节点标识，确定该核对任务对应的目标链路类型，并根据该目标链路类型对应的上下游关系信息以及所述匹配规则信息，对所述单据数据进行核对。

7.根据权利要求3所述的方法，其特征在于，

所述商品对象数据处理链路包括商品对象交易链路；所述链路中包括的节点按照上下游关系依次为：交易，履约，库存，配送；所述第二系统包括分别用于对商品对象进行交易、履约、库存、配送处理的第二系统；

所述对所述链路中的节点上的单据数据进行依次核对，包括：

根据从所述第二系统接收到的交易单据生成核对任务；

对于其中一核对任务，从接收到的履约单据数据中，根据交易节点与履约节点之间的匹配规则，判断是否存在符合对应匹配规则的履约单据；

如果匹配成功，则从接收到的库存单据数据中，根据履约单据与库存单据之间的匹配规则，判断是否存在符合对应匹配规则的库存单据；

如果匹配成功，则从接收到的配送单据数据中，根据库存单据与配送单据之间的匹配规则，判断是否存在符合对应匹配规则的配送单据，如果匹配成功，则该核对任务核对通过。

8.根据权利要求3所述的方法，其特征在于，还包括：

如果某当前节点对应的下一节点的单据数据未匹配成功，则将所述核对任务加入到重试队列中，并在等待预置的时间间隔后，根据所述第二系统新提供的单据数据，重新执行该核对任务。

9.根据权利要求8所述的方法，其特征在于，

如果某当前节点对应的下一节点的单据数据中，与当前节点上的单据数据关联的单据数据不存在、不完整、不一致或者状态不符，则确定该下一节点的单据数据未匹配成功。

10.根据权利要求3所述的方法，其特征在于，还包括：

接收第二系统提供的对应节点上生成的单据数据的组成结构信息，以便结合所述组成结构信息对所述节点上的单据数据进行核对。

11.根据权利要求3所述的方法，其特征在于，还包括：

存储各节点标识对应的单据数据的核心字段标识信息；

在接收到所述第二系统提供的单据数据后，根据所述第二系统对应的节点标识，判断所述单据数据是否包含所述核心字段上的数据，如果包含，则进行保存，否则向所述第二系统提供错误提示信息。

12.根据权利要求3所述的方法，其特征在于，还包括：

按照预置的周期，对当前周期内接收到的单据数据，与各自对应的第二系统内的单据数据生成情况及状态进行比对，如果存在不一致的单据数据，则提示第二系统对该单据数据进行重发补偿。

13.根据权利要求3所述的方法，其特征在于，

所述获得商品对象数据处理链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息，包括：

接收目标用户提供的链路定制请求，所述请求中携带有所述链路中包括的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息。

14.一种单据数据处理方法，其特征在于，包括：

对商品对象数据处理链路中目标节点上的商品对象数据进行处理，并生成单据数据；其中，所述商品对象数据处理链路包括商品对象交易处理链路，或商品对象入库处理链路；

将所述单据数据提供给第一系统，以便所述第一系统生成核对任务，并核对任务为单位，从所述链路的起始节点开始，按照预先保存的节点之间的上下游关系信息以及匹配规则，对所述链路中的节点上的单据数据进行依次核对；

其中在进行所述依次核对时，确定所述核对任务中已完成匹配的当前节点，从已收到的单据数据中取出其下一节点对应的单据数据，利用当前节点与下一节点之间的匹配规则信息，对所述下一节点对应的单据数据进行匹配判断；如果匹配成功，则将该下一节点确定为已完成匹配的当前节点，并对其下一节点对应的单据数据进行匹配判断，直到完成所述链路的结束节点的匹配判断。

15.一种单据数据处理装置，其特征在于，包括：

信息获得单元，用于获得商品对象数据处理链路中包括的多个节点的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息；其中，所述商品对象数据处理链路包括商品对象交易处理链路，或商品对象入库处理链路；

核对任务生成单元，用于接收到多个第二系统提供的单据数据后，生成核对任务；其中，所述第二系统与商品对象数据处理链路中的节点相对应；

核对单元，用于针对所述核对任务，从所述链路的起始节点开始，按照所述上下游关系信息以及所述匹配规则，对所述链路中的节点上的单据数据进行依次核对；其中在进行所述依次核对时，确定所述核对任务中已完成匹配的当前节点，从已收到的单据数据中取出其下一节点对应的单据数据，利用当前节点与下一节点之间的匹配规则信息，对所述下一节点对应的单据数据进行匹配判断；如果匹配成功，则将该下一节点确定为已完成匹配的当前节点，并对其下一节点对应的单据数据进行匹配判断，直到完成所述链路的结束节点的匹配判断。

16.一种单据数据处理装置，其特征在于，包括：

单据数据生成单元，用于对商品对象数据处理链路中目标节点上的商品对象数据进行处理，并生成单据数据；其中，所述商品对象数据处理链路包括商品对象交易处理链路，或商品对象入库处理链路；

单据数据提供单元，用于将所述单据数据提供给第一系统，以便所述第一系统生成核对任务，并核对任务为单位，从所述链路的起始节点开始，按照预先保存的节点之间的上下游关系信息以及匹配规则，对所述链路中的节点上的单据数据进行依次核对；

其中在进行所述依次核对时，确定所述核对任务中已完成匹配的当前节点，从已收到的单据数据中取出其下一节点对应的单据数据，利用当前节点与下一节点之间的匹配规则信息，对所述下一节点对应的单据数据进行匹配判断；如果匹配成功，则将该下一节点确定为已完成匹配的当前节点，并对其下一节点对应的单据数据进行匹配判断，直到完成所述链路的结束节点的匹配判断。

17.一种电子设备，其特征在于，包括：

一个或多个处理器；以及

与所述一个或多个处理器关联的存储器，所述存储器用于存储程序指令,所述程序指令在被所述一个或多个处理器读取执行时,执行如下操作:

获得商品对象数据处理链路中包括的多个节点的节点标识信息，节点之间的上下游关系信息，以及节点对应的单据数据匹配规则信息；其中，所述商品对象数据处理链路包括商品对象交易处理链路，或商品对象入库处理链路；

接收到多个第二系统提供的单据数据后，生成核对任务；其中，所述第二系统与商品对象数据处理链路中的节点相对应；

针对所述核对任务，从所述链路的起始节点开始，按照所述上下游关系信息以及所述匹配规则，对所述链路中的节点上的单据数据进行依次核对；

其中在进行所述依次核对时，确定所述核对任务中已完成匹配的当前节点，从已收到的单据数据中取出其下一节点对应的单据数据，利用当前节点与下一节点之间的匹配规则信息，对所述下一节点对应的单据数据进行匹配判断；如果匹配成功，则将该下一节点确定为已完成匹配的当前节点，并对其下一节点对应的单据数据进行匹配判断，直到完成所述链路的结束节点的匹配判断。