CN107016548B - 客户系统、信息处理方法和读写方法及装置 - Google Patents

Abstract

本发明提供了一种客户系统、信息处理方法和读写方法及装置，通过接收业务系统发送的用于对客户信息进行操作的目标操作请求之后，根据目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询操作流水标识是否唯一，当操作流水标识唯一时，在工具表中，根据目标操作请求，对用于索引基础表的对应索引字段进行更新，并在活动表中对目标操作请求进行记录。由于采用了活动表记录业务系统针对客户信息所进行的全部操作，并且每一次操作均具有唯一性的操作流水标识，避免了重复操作以及客户数据混乱，不仅解决了在多并发情况下数据一致性问题，同时，提升了系统的性能和容量。

Description

客户系统、信息处理方法和读写方法及装置

技术领域

本发明涉及信息处理技术，尤其涉及一种客户系统、信息处理方法和读写方法及装置。

背景技术

在电子商务平台或者社交平台中，由于联系方式、用户名、好友列表等客户数据与交易记录以及聊天记录相比，修改的频率较低，从而客户系统往往将客户数据作为状态型数据进行设计和处理。

尽管状态型数据占用的存储空间较小，并且具有修改权限的系统都可以对状态型数据进行变更，从而修改也较为灵活，但是，在实际维护过程中，发现多方并发修改同一个客户的客户数据的情况下，这种将客户信息作为状态型数据的方式，容易出现数据记录错误。举例来说，如图1所示，当系统A和系统B同时对同一个客户的客户信息，采用不同手机号进行“修改手机号”操作的情况下，可能会出现系统A和系统B均返回修改成功的提示，但对于不同系统来说该客户的手机号不同，针对系统A，该客户的手机号为137，而针对系统B来说，该客户的手机号为138，而实际在客户系统中所维护的手机号为138和137中的一个。显然，这种方式极易导致数据混乱，出现数据一致性问题。

若采用锁机制，一方对客户数据进行修改时，对该客户数据进行锁定，另一方无法对同一客户数据进行修改，尽管能够在一定程度上解决了数据一致性问题，但由于同一时刻仅能够由多方中的一方对客户数据进行操作，导致系统性能和容量下降。

发明内容

本发明提供一种客户系统、信息处理方法和读写方法及装置，本发明实施例的一个目的在于解决数据一致性问题。

为达到上述目的，本发明的实施例采用如下技术方案：

第一方面，提供了一种基于客户系统的信息处理方法，所述客户系统包括用于维护活动表的活动节点、用于维护基础表的基础节点，以及用于维护工具表的工具节点，所述方法包括：

所述活动节点从业务系统获取对客户信息进行操作的目标操作请求；

所述活动节点根据所述目标操作请求所携带的操作流水标识，在所述活动表各条操作记录中，查询所述操作流水标识是否唯一；其中，所述操作记录用于指示业务系统对客户信息所执行的历史操作；

当所述活动节点确定所述操作流水标识唯一时，所述工具节点根据所述目标操作请求，对所述工具表中的对应索引字段进行更新，并向所述活动节点返回更新成功的消息；其中，所述工具表用于对所述基础表所记录的客户信息进行索引；

所述活动节点接收到所述更新成功的消息之后，在所述活动表中对所述目标操作请求进行记录。

第二方面，提供了一种基于客户系统的信息处理方法，所述客户系统包括用于维护活动表的活动节点、用于维护基础表的基础节点，以及用于维护工具表的工具节点，所述方法包括：

所述活动节点从业务系统获取对客户信息进行查询的目标查询请求；

所述活动节点查询所述活动表的操作记录中，是否涉及所述目标查询请求中的客户；

当在所述活动表中查询到所述客户的操作记录时，向所述基础节点发送所查询到的客户的操作记录；

所述基础节点通过所述工具节点中的工具表，根据所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到对应客户信息记录；

所述基础节点根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并；

所述基础节点向所述业务系统发送数据合并得到的客户信息记录。

第三方面，提供了一种客户信息写方法，所述方法包括：

接收业务系统发送的用于对客户信息进行操作的目标操作请求；

根据所述目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询所述操作流水标识是否唯一；其中，所述操作记录用于指示业务系统对客户信息所执行的历史操作；

当所述操作流水标识唯一时，根据所述目标操作请求，对所述工具表中的对应索引字段进行更新；其中，所述工具表用于对所述基础表所记录的客户信息进行索引；

在所述活动表中对所述目标操作请求进行记录。

第四方面，提供了一种客户信息读方法，所述方法包括：

从业务系统获取对客户信息进行查询的目标查询请求；

查询活动表的操作记录中是否涉及所述目标查询请求中的客户；

当在所述活动表中查询到所述客户的操作记录时，通过工具表对所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到对应客户信息记录；

根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并；

向所述业务系统发送数据合并得到的客户信息记录。

第五方面，提供了一种客户系统，所述客户系统包括活动节点、基础节点，以及工具节点；

所述活动节点，用于从业务系统获取对客户信息进行操作的目标操作请求之后，根据所述目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询所述操作流水标识是否唯一；其中，所述操作记录用于指示业务系统对客户信息所执行的历史操作；

所述工具节点，用于当所述活动节点确定所述操作流水标识唯一时，根据所述目标操作请求，对工具表中的对应索引字段进行更新，并向所述活动节点返回更新成功的消息；其中，所述工具表用于对所述基础表所记录的客户信息进行索引；

所述活动表，还用于接收到所述更新成功的消息之后，在所述活动表中对所述目标操作请求进行记录；

所述基础节点，用于根据所述活动表，在基础表中记录客户信息。

第六方面，提供了一种客户系统，所述客户系统包括活动节点、基础节点，以及工具节点；

所述活动节点，用于从业务系统获取对客户信息进行查询的目标查询请求；查询所述活动表的操作记录中，是否涉及所述目标查询请求中的客户；当在所述活动表中查询到所述客户的操作记录时，向所述基础节点发送所查询到的客户的操作记录；

所述工具节点，用于根据所述目标查询请求所涉及的查询字段，利用工具表，对基础表进行索引；

所述基础节点，用于根据所述工具表，在所述基础表中索引到的对应客户信息记录；根据所查询到的所述客户的操作记录和所查询到的客户信息记录进行数据合并；向所述业务系统发送数据合并得到的客户信息记录。

第七方面，提供了一种客户信息写装置，所述装置包括：

接收模块，用于接收业务系统发送的用于对客户信息进行操作的目标操作请求；

查询模块，用于根据所述目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询所述操作流水标识是否唯一；其中，所述操作记录用于指示业务系统对客户信息所执行的历史操作；

更新模块，用于当所述操作流水标识唯一时，根据所述目标操作请求，对所述工具表中的对应索引字段进行更新；其中，所述工具表用于对所述基础表所记录的客户信息进行索引；

记录模块，用于在所述活动表中对所述目标操作请求进行记录。

第八方面，提供了一种客户信息读装置，所述装置包括：

获取模块，用于从业务系统获取对客户信息进行查询的目标查询请求；

查询模块，用于查询活动表的操作记录中是否涉及所述目标查询请求中的客户；

索引模块，用于当在所述活动表中查询到所述客户的操作记录时，通过工具表对所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到对应客户信息记录；

更新模块，用于根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并；

发送模块，用于向所述业务系统发送数据合并得到的客户信息记录。

本发明实施例提供的客户系统、信息处理方法和读写方法及装置，通过接收业务系统发送的用于对客户信息进行操作的目标操作请求之后，根据目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询操作流水标识是否唯一，当操作流水标识唯一时，在工具表中，根据目标操作请求，对用于索引基础表的对应索引字段进行更新，并在活动表中对目标操作请求进行记录。由于采用了活动表记录业务系统针对客户信息所进行的全部操作，并且每一次操作均具有唯一性的操作流水标识，避免了重复操作以及客户数据混乱，解决了在多并发情况下数据一致性问题，同时，提升了系统的性能和容量。

附图说明

图1为现有技术中客户系统的示意图；

图2为数据表的示意图；

图3为本发明实施例一提供的一种客户信息写方法的流程示意图；

图4为本发明实施例二提供的另一种客户信息写方法的流程示意图；

图5为本发明实施例三提供的一种客户信息读方法的流程示意图；

图6为本发明实施例四提供的客户系统中各节点的交互示意图之一；

图7为本发明实施例四提供的客户系统中各节点的交互示意图之二；

图8为基础表的示意图；

图9为本发明实施例五提供的客户系统中各节点的交互示意图；

图10为客户系统的示意图之一；

图11为客户系统的示意图之二；

图12为本发明实施例七提供的一种客户信息写装置的结构示意图；

图13为本发明实施例八提供的一种客户信息读装置的结构示意图。

具体实施方式

下面结合附图对本发明实施例提供的进行详细描述。

实施例一

为了清楚说明本实施例所提供的方法，首先对本实施例所涉及的数据表进行简要介绍，图2为数据表的示意图，如图2所示，所涉及的数据表包括：

活动表，用于对目标操作请求进行记录。

基础表，用于对客户信息进行记录。

工具表，用于对客户信息表进行索引。

下面将对客户信息写方法进行详细说明，图3为本发明实施例一提供的一种客户信息写方法的流程示意图，如图3所示，方法包括：

步骤101，接收业务系统发送的用于对客户信息进行操作的目标操作请求。

具体地，当业务系统需要对客户信息需要执行添加、修改或删除的操作时，业务系统会发送操作请求，具体来说，在操作请求中，包括操作流水标识，这个操作流水标识为操作的唯一性标识，也就是说，每一次操作具有不同的操作流水标识。另外，操作请求中还包括具体操作的类型，操作对象，即操作所针对的字段。当具体操作类型为添加、修改时，操作请求中还可以包括，操作内容，即该字段所需添加或修改的字段值。

一般来说，客户信息数量庞大，为了进行快速索引，可以在操作请求中携带所需操作的客户信息的客户标识(ID)，由于客户标识具有唯一性，从而能够便于对客户信息记录进行查询。

步骤102，根据目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询操作流水标识是否唯一。

其中，操作记录用于指示业务系统对客户信息所执行的历史操作。具体地，利用幂等性函数，将目标操作请求所携带的操作流水标识，与活动表中各条操作记录的操作流水标识字段进行比对，以查询操作流水标识是否与活动表中各条操作记录的操作流水标识重复，以避免对同一个目标操作请求进行重复处理。

在活动表中记录有各条操作记录，操作记录用于记录操作请求中所携带的信息，以及发送操作请求的业务系统和发送时间等。

步骤103，当操作流水标识唯一时，根据目标操作请求，对工具表中的对应索引字段进行更新。

其中，工具表用于对基础表所记录的客户信息进行索引。具体来说，工具表可以为一个普通索引表，也可以为包含有一些约束条件的唯一索引表，主要用于加速客户信息表的查询速度，以及保证数据满足约束条件。例如：手机号或注册邮箱唯一性。工具表对索引字段进行索引，具体工具表所包含的索引字段是根据业务规则确定的。

具体地，当操作流水标识唯一时，可以确定没有出现重复操作的情况，进而根据目标操作请求，对工具表中的对应索引字段进行更新。

若工具表为普通索引表，可以在对工具表中的对应索引字段进行更新之前，检查操作是否满足约束条件，若满足则对工具表中的对应索引字段进行更新，否则向业务系统返回操作失败的消息。

若工具表为唯一索引表，可以在对工具表中的对应索引字段进行更新过程中，检查操作是否满足唯一性约束条件，若满足则工具表更新成功，否则工具表更新失败，向业务系统返回操作失败的消息。

进一步，若操作流水标识不唯一时，说明活动表已经存在对应该目标操作请求的操作记录，并对该请求进行了处理，因此，本次处理存在重复操作的情况，结束对本次处理过程。

步骤104，在活动表中对目标操作请求进行记录。

具体地，将本次所接收到的目标操作请求的相关信息记录到活动表中，生成对应的操作记录，以便后续进行查询。

例如：活动表中可以包括操作请求中所携带的操作流水标识、操作类型、操作对象和操作内容，以及发送操作请求的业务系统和发送时间等。

可见，由于活动表所记录的信息中，包括操作流水标识，因此，便于控制每一次操作不会被重复进行处理，也就是幂等性，同时保证了操作的可追溯性。

本实施例中，通过接收业务系统发送的用于对客户信息进行操作的目标操作请求之后，根据目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询操作流水标识是否唯一，当操作流水标识唯一时，在工具表中，根据目标操作请求，对用于索引基础表的对应索引字段进行更新，并在活动表中对目标操作请求进行记录。由于采用了活动表记录业务系统针对客户信息所进行的全部操作，并且每一次操作均具有唯一性的操作流水标识，避免了重复操作以及客户数据混乱，解决了在多并发情况下数据一致性问题，同时，提升了系统的性能和容量。

实施例二

为了清楚说明上一实施例，本实施例还提供了另一种客户信息写方法，在上一实施例的基础上，进一步，在步骤104之后，还可以对活动表和客户信息表进行合并，具体来说，图4为本发明实施例二提供的另一种客户信息写方法的流程示意图，如图4所示，方法包括：

步骤201，在满足预设触发条件时，获取活动表中待合并的操作记录。

具体地，预设触发条件包括：满足预设时间间隔；和/或，满足所述活动表中待合并的操作记录条数大于预设阈值。

在图3所提供的方法中，可以看出，在业务系统请求对客户信息进行操作时，并没有对记录客户信息的基础表进行相应的操作，而是将该操作记录到活动表中。在活动表中积累的操作记录条数足够多，从而大于预设阈值时，或者，每隔预设时间间隔，需要对活动表中的操作记录进行合并。这里待合并的操作记录可以是活动表中全部的操作记录，也可以是部分的操作记录，本实施例中对此不做限定。

步骤202，根据待合并的操作记录和基础表中当前版本的客户信息记录进行数据合并，以得到下一版本的客户信息记录。

具体地，从活动表中，以客户为单位，分别获取每一个客户的待合并的操作记录之后，针对每一个客户，利用该客户的待合并的操作记录中各字段取值，更新基础表中当前版本的客户信息记录中该客户的对应字段取值，以完成对操作记录的合并，将所得到的下一版本的客户信息记录存储于基础表中。

步骤203，将待合并的操作记录从活动表移动至历史数据库。

具体地，在对该待合并的操作记录完成合并之后，将待合并的操作记录从活动表移动至历史数据库。以便在客户数据存在混乱时，进行后续溯源查询。

本实施例中，通过接收业务系统发送的用于对客户信息进行操作的目标操作请求之后，根据目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询操作流水标识是否唯一，当操作流水标识唯一时，在工具表中，根据目标操作请求，对用于索引基础表的对应索引字段进行更新，并在活动表中对目标操作请求进行记录。由于采用了活动表记录业务系统针对客户信息所进行的全部操作，并且每一次操作均具有唯一性的操作流水标识，避免了重复操作以及客户数据混乱，解决了在多并发情况下数据一致性问题，同时，相较于锁机制提升了系统的性能和容量。

实施例三

图5为本发明实施例三提供的一种客户信息读方法的流程示意图，本实施例所提供的客户信息读方法，是与前述实施例所提供的客户信息写方法相对应的，如图5所示，方法包括：

步骤301，从业务系统获取对客户信息进行查询的目标查询请求。

步骤302，查询活动表的操作记录中是否涉及所述目标查询请求中的客户。

具体地，作为一种可能的实现形式，在目标查询请求的索引字段为客户标识时，可以直接在活动表的操作记录中根据客户标识进行查询，若存在该客户标识的操作记录，则确定基础表中所记录的该客户的客户信息不是当前最新的客户信息，需要根据查询到的操作记录进行更新。

进一步，作为另一种可能的实现形式，当目标查询请求的索引字段不为客户标识时，可以在工具表中查询目标查询请求的索引字段对应的客户标识。进而在活动表的操作记录中根据该客户标识进行查询，若存在该客户标识的操作记录，则确定基础表中所记录的该客户的客户信息不是当前最新的客户信息，需要根据查询到的操作记录进行更新。

步骤303，当在活动表中查询到该客户的操作记录时，通过工具表对目标查询请求所涉及的查询字段进行索引，以在基础表中，查询到对应客户信息记录。

具体地，通过工具表，对该目标查询请求所涉及的查询字段进行索引，以在基础表中，查询到当前版本的客户信息记录中所述查询字段的取值。

步骤304，根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并。

具体地，根据所述目标查询请求中的客户标识，在所述活动表中查询到具有所述客户标识的操作记录时，在所述基础表中，利用所查询到的操作记录中的字段取值，更新当前版本的客户信息记录中所述客户标识对应的字段取值。

步骤305，向业务系统发送数据合并得到的客户信息记录。

进一步，当在活动表中未查询到所述客户的操作记录时，查询基础表中当前版本的客户信息记录，进而向业务系统发送查询到的客户信息记录。

需要说明的是，由于本实施例是与实施例一对应的客户信息读方法，本实施例中未详尽说明的内容，请参看实施例一中的相关描述。

由于在对客户信息进行写过程中，通过接收业务系统发送的用于对客户信息进行操作的目标操作请求之后，根据目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询操作流水标识是否唯一，当操作流水标识唯一时，在工具表中，根据目标操作请求，对用于索引基础表的对应索引字段进行更新，并在活动表中对目标操作请求进行记录。由于采用了活动表记录业务系统针对客户信息所进行的全部操作，并且每一次操作均具有唯一性的操作流水标识，避免了重复操作以及客户数据混乱，解决了在多并发情况下数据一致性问题，同时，相较于锁机制提升了系统的性能和容量。

与之对应的，在读过程中，从业务系统获取对客户信息进行查询的目标查询请求，进而查询活动表的操作记录中是否涉及所述目标查询请求中的客户，当在所述活动表中查询到所述客户的操作记录时，通过工具表对所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到对应客户信息记录，并根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并，向所述业务系统发送数据合并得到的客户信息记录。

实施例四

为了清楚说明前述实施例所提供的客户信息写方法，本实施例提供了在客户系统这一应用场景下，用于实现客户信息写方法的信息处理过程。图6为本发明实施例四提供的客户系统中各节点的交互示意图之一，如图6所示，客户系统包括活动节点、基础节点和工具节点。

其中，活动节点与业务系统交互，该活动节点用于维护活动表，基础节点用于维护基础表，工具节点用于维护工具表。

如图6所示，信息处理方法，包括：

步骤401，活动节点从业务系统获取对客户信息进行操作的目标操作请求。

步骤402，活动节点根据所述目标操作请求所携带的操作流水标识，在所述活动表各条操作记录中，查询所述操作流水标识是否唯一。

其中，操作记录用于指示业务系统对客户信息所执行的历史操作。

具体地，活动节点获取目标操作请求所携带的操作流水标识，利用幂等性函数，将操作流水标识，与活动表中各条操作记录的操作流水标识字段进行比对，以查询操作流水标识是否与活动表中各条操作记录的操作流水标识重复。

步骤403，当活动节点确定操作流水标识唯一时，工具节点根据所述目标操作请求，对所述工具表中的对应索引字段进行更新，并向所述活动节点返回更新成功的消息。

其中，工具表用于对所述基础表所记录的客户信息进行索引。

步骤404，活动节点接收到更新成功的消息之后，在活动表中对目标操作请求进行记录，并向业务系统返回操作结果。

可以看出，在业务系统请求对客户信息进行操作时，并没有对记录客户信息的基础表进行相应的操作，而是将该操作记录到活动表中。在活动表中积累的操作记录条数足够多，从而大于预设阈值时，或者，每隔预设时间间隔，需要对活动表中的操作记录进行合并。这里待合并的操作记录可以是活动表中全部的操作记录，也可以是部分的操作记录，本实施例中对此不做限定。

具体来说，图7为本发明实施例四提供的客户系统中各节点的交互示意图之二，如图7所示：

步骤501，在满足预设触发条件时，基础节点从活动节点，获取活动表中待合并的操作记录。

具体地，基础节点从所述活动表中，以客户为单位，分别获取每一个客户的待合并的操作记录。

步骤502，基础节点根据待合并的操作记录和基础表中当前版本的客户信息记录进行数据合并，以得到下一版本的客户信息记录，进而向活动节点返回合并成功的消息。

具体地，针对每一个客户，所述基础节点利用所述客户的待合并的操作记录中各字段取值，更新所述基础表中当前版本的所述客户的客户信息记录中对应字段取值。

作为一种可能的实现方式，在基础表中具有多个字段，图8为基础表的示意图，如图8所示，基础表数据内容庞杂，因此，需要依赖工具表对基础表进行索引。

步骤503，活动节点根据合并成功的消息，将待合并的操作记录从活动表移动至历史数据库。

进一步，客户系统还可以包括元数据节点。

基于此，工具节点从元数据节点获取配置的业务规则中所涉及的索引字段，并将业务规则中所涉及的索引字段，增加到工具表中。

由于业务规则中记录了业务系统进行客户信息查询时所遵循的查询维度，具体来说，包括各个索引字段以及所需查询到的查询字段，因此，工具节点可以将业务规则中所涉及的索引字段，增加到工具表中，以便快速对基础表进行查询，提高查询效率。

实施例五

为了清楚说明前述实施例所提供的客户信息读方法，本实施例提供了在客户系统这一应用场景下，用于实现客户信息读方法的信息处理过程。图9为本发明实施例五提供的客户系统中各节点的交互示意图，如图9所示，客户系统包括活动节点、基础节点和工具节点。

其中，活动节点与业务系统交互，该活动节点用于维护活动表，基础节点用于维护基础表，工具节点用于维护工具表。

如图9所示，信息处理方法，包括：

步骤601，活动节点从业务系统获取对客户信息进行查询的目标查询请求。

步骤602，活动节点查询所述活动表的操作记录中，是否涉及目标查询请求中的客户，当在活动表中查询到该客户的操作记录时，向所述基础节点发送所查询到的客户的操作记录。

进一步，当所述目标查询请求的索引字段不为客户标识时，活动节点在查询活动表之前，通过工具节点在工具表中查询目标查询请求的索引字段对应的客户标识。

步骤603，基础节点通过所述工具节点中的工具表，根据目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到对应客户信息记录。

具体地，基础节点通过工具节点中的工具表，对所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到当前版本的客户信息记录中所述查询字段的取值。

步骤604，基础节点根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并，并向业务系统发送数据合并得到的客户信息记录。

具体地，活动节点根据所述目标查询请求对应的客户标识，在所述活动表中查询到具有客户标识的操作记录时，向所述基础节点发送所查询到的操作记录，从而在基础表中，基础节点利用查询到的操作记录中的字段取值，更新当前版本的客户信息记录中客户标识对应的字段取值。

进一步，当在活动表中未查询到所述客户的操作记录时，所述基础节点查询所述基础表中当前版本的客户信息记录；基础节点向所述业务系统发送查询到的客户信息记录。

实施例六

本实施例提供了一种客户系统，图10为客户系统的示意图之一，如图10所示，客户系统包括活动节点、基础节点和工具节点。

其中，活动节点的个数可以为一个或多个，各活动节点与对应的业务系统进行交互。这里的对应关系可以是活动节点和业务系统一一对应，也可以是多活动节点对应一个业务系统，或是一个活动节点对应多个业务系统。

为了清楚说明该客户系统，本实施例提供了两种可能的应用场景下，对应的客户系统两种可能的实现方式。

作为一种可能的实现方式，在业务系统对客户信息进行操作的应用场景下，活动节点用于从业务系统获取对客户信息进行操作的目标操作请求之后，根据所述目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询所述操作流水标识是否唯一。

其中，操作记录用于指示业务系统对客户信息所执行的历史操作。

工具节点，用于当所述活动节点确定所述操作流水标识唯一时，根据所述目标操作请求，对工具表中的对应索引字段进行更新，并向所述活动节点返回更新成功的消息。

其中，工具表用于对所述基础表所记录的客户信息进行索引。

活动表，还用于接收到更新成功的消息之后，在活动表中对目标操作请求进行记录。

基础节点，用于根据活动表，在基础表中记录客户信息。

进一步，基础节点，具体用于在满足预设触发条件时，从所述活动节点，获取所述活动表中待合并的操作记录；根据所述待合并的操作记录和所述基础表中当前版本的客户信息记录进行数据合并，以得到下一版本的客户信息记录；向所述活动节点返回合并成功的消息。

所述活动节点，还用于根据所述合并成功的消息，将所述待合并的操作记录从所述活动表移动至历史数据库。

进一步，图11为客户系统的示意图之二，如图11所示，客户系统还包括：元数据节点。

元数据节点，用于配置业务规则。

基于此，工具节点，还用于从所述元数据节点获取配置的业务规则中所涉及的索引字段；将所述业务规则中所涉及的索引字段，增加到所述工具表中。

作为另一种可能的实现方式，在业务系统对客户信息进行查询的应用场景下，活动节点，用于从业务系统获取对客户信息进行查询的目标查询请求；查询所述活动表的操作记录中，是否涉及所述目标查询请求中的客户；当在所述活动表中查询到所述客户的操作记录时，向所述基础节点发送所查询到的客户的操作记录。

所述工具节点，用于根据所述目标查询请求所涉及的查询字段，利用工具表，对基础表进行索引。

所述基础节点，用于根据所述工具表，在所述基础表中索引到的对应客户信息记录；根据所查询到的所述客户的操作记录和所查询到的客户信息记录进行数据合并；向所述业务系统发送数据合并得到的客户信息记录。

可见，通过接收业务系统发送的用于对客户信息进行操作的目标操作请求之后，根据目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询操作流水标识是否唯一，当操作流水标识唯一时，在工具表中，根据目标操作请求，对用于索引基础表的对应索引字段进行更新，并在活动表中对目标操作请求进行记录。由于采用了活动表记录业务系统针对客户信息所进行的全部操作，并且每一次操作均具有唯一性的操作流水标识，避免了重复操作以及客户数据混乱，解决了在多并发情况下数据一致性问题，同时，提升了系统的性能和容量。

实施例七

图12为本发明实施例七提供的一种客户信息写装置的结构示意图，如图12所示，包括：接收模块71、查询模块72、更新模块73和记录模块74。

接收模块71，用于接收业务系统发送的用于对客户信息进行操作的目标操作请求。

查询模块72，用于根据所述目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询所述操作流水标识是否唯一。

其中，所述操作记录用于指示业务系统对客户信息所执行的历史操作。

更新模块73，用于当所述操作流水标识唯一时，根据所述目标操作请求，对所述工具表中的对应索引字段进行更新。

其中，所述工具表用于对所述基础表所记录的客户信息进行索引。

记录模块74，用于在所述活动表中对所述目标操作请求进行记录。

本实施例中，通过接收业务系统发送的用于对客户信息进行操作的目标操作请求之后，根据目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询操作流水标识是否唯一，当操作流水标识唯一时，在工具表中，根据目标操作请求，对用于索引基础表的对应索引字段进行更新，并在活动表中对目标操作请求进行记录。由于采用了活动表记录业务系统针对客户信息所进行的全部操作，并且每一次操作均具有唯一性的操作流水标识，避免了重复操作以及客户数据混乱，解决了在多并发情况下数据一致性问题，同时，提升了系统的性能和容量。

实施例八

图13为本发明实施例八提供的一种客户信息读装置的结构示意图，如图13所示，该装置包括：获取模块81、查询模块82、索引模块83、更新模块84和发送模块85。

获取模块81，用于从业务系统获取对客户信息进行查询的目标查询请求。

查询模块82，用于查询活动表的操作记录中是否涉及所述目标查询请求中的客户。

索引模块83，用于当在所述活动表中查询到所述客户的操作记录时，通过工具表对所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到对应客户信息记录。

更新模块84，用于根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并。

发送模块85，用于向所述业务系统发送数据合并得到的客户信息记录。

由于在对客户信息进行写过程中，通过接收业务系统发送的用于对客户信息进行操作的目标操作请求之后，根据目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询操作流水标识是否唯一，当操作流水标识唯一时，在工具表中，根据目标操作请求，对用于索引基础表的对应索引字段进行更新，并在活动表中对目标操作请求进行记录。由于采用了活动表记录业务系统针对客户信息所进行的全部操作，并且每一次操作均具有唯一性的操作流水标识，避免了重复操作以及客户数据混乱，解决了在多并发情况下数据一致性问题，同时，提升了系统的性能和容量。

与之对应的，在读过程中，从业务系统获取对客户信息进行查询的目标查询请求，进而查询活动表的操作记录中是否涉及所述目标查询请求中的客户，当在所述活动表中查询到所述客户的操作记录时，通过工具表对所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到对应客户信息记录，并根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并，向所述业务系统发送数据合并得到的客户信息记录。

本领域普通技术人员可以理解：实现上述各方法实施例的全部或部分步骤可以通过程序指令相关的硬件来完成。前述的程序可以存储于一计算机可读取存储介质中。该程序在执行时，执行包括上述各方法实施例的步骤；而前述的存储介质包括：ROM、RAM、磁碟或者光盘等各种可以存储程序代码的介质。

最后应说明的是：以上各实施例仅用以说明本发明的技术方案，而非对其限制；尽管参照前述各实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分或者全部技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例技术方案的范围。

Claims (30)

1.一种基于客户系统的信息处理方法，其特征在于，所述客户系统包括用于维护活动表的活动节点、用于维护基础表的基础节点，以及用于维护工具表的工具节点，所述方法包括：

所述活动节点从业务系统获取对客户信息进行操作的目标操作请求；

所述活动节点根据所述目标操作请求所携带的操作流水标识，在所述活动表各条操作记录中，利用幂等性函数，将所述目标操作请求所携带的操作流水标识，与所述活动表中各条操作记录的操作流水标识字段进行比对以查询所述操作流水标识是否唯一；其中，所述操作记录用于指示业务系统对客户信息所执行的历史操作；其中，所述基础节点能够根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并得到合并的客户信息记录；

当所述活动节点确定所述操作流水标识唯一时，所述工具节点根据所述目标操作请求，对所述工具表中的对应索引字段进行更新，并向所述活动节点返回更新成功的消息；其中，所述工具表用于对所述基础表所记录的客户信息进行索引；

所述活动节点接收到所述更新成功的消息之后，在所述活动表中对所述目标操作请求进行记录。

2.根据权利要求1所述的基于客户系统的信息处理方法，其特征在于，所述方法还包括：

在满足预设触发条件时，所述基础节点从所述活动节点，获取所述活动表中待合并的操作记录；

所述基础节点根据所述待合并的操作记录和所述基础表中当前版本的客户信息记录进行数据合并，以得到下一版本的客户信息记录；

所述基础节点向所述活动节点返回合并成功的消息；

所述活动节点根据所述合并成功的消息，将所述待合并的操作记录从所述活动表移动至历史数据库。

3.根据权利要求2所述的基于客户系统的信息处理方法，其特征在于，所述基础节点从所述活动节点，获取所述活动表中待合并的操作记录，包括：

所述基础节点从所述活动表中，以客户为单位，分别获取每一个客户的待合并的操作记录。

4.根据权利要求3所述的基于客户系统的信息处理方法，其特征在于，所述基础节点根据所述待合并的操作记录和所述基础表中当前版本的客户信息记录进行数据合并，包括：

针对每一个客户，所述基础节点利用所述客户的待合并的操作记录中各字段取值，更新所述基础表中当前版本的所述客户的客户信息记录中对应字段取值。

5.根据权利要求2所述的基于客户系统的信息处理方法，其特征在于，所述预设触发条件包括：

满足预设时间间隔；

和/或，满足所述活动表中待合并的操作记录条数大于预设阈值。

6.根据权利要求1-5任一项所述的基于客户系统的信息处理方法，其特征在于，所述活动节点根据所述目标操作请求所携带的操作流水标识，在所述活动表各条操作记录中，查询所述操作流水标识是否唯一，包括：

所述活动节点获取所述目标操作请求所携带的操作流水标识。

7.根据权利要求1-5任一项所述的基于客户系统的信息处理方法，其特征在于，所述客户系统还包括元数据节点；所述方法还包括：

所述工具节点从所述元数据节点获取配置的业务规则中所涉及的索引字段；

所述工具节点将所述业务规则中所涉及的索引字段，增加到所述工具表中。

8.一种基于客户系统的信息处理方法，其特征在于，所述客户系统包括用于维护活动表的活动节点、用于维护基础表的基础节点，以及用于维护工具表的工具节点，所述方法包括：

所述活动节点从业务系统获取对客户信息进行查询的目标查询请求；

所述活动节点查询所述活动表的操作记录中，是否涉及所述目标查询请求中的客户；其中，所述操作记录包括指示业务系统对客户信息所执行的历史操作以及利用幂等性函数确定出的唯一的操作流水标识；

当在所述活动表中查询到所述客户的操作记录时，向所述基础节点发送所查询到的客户的操作记录；

所述基础节点通过所述工具节点中的工具表，根据所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到对应客户信息记录；

所述基础节点根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并；

所述基础节点向所述业务系统发送数据合并得到的客户信息记录。

9.根据权利要求8所述的基于客户系统的信息处理方法，其特征在于，所述基础节点通过所述工具节点中的工具表，根据所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到对应客户信息记录，包括：

所述基础节点通过所述工具节点中的工具表，对所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到当前版本的客户信息记录中所述查询字段的取值。

10.根据权利要求8所述的基于客户系统的信息处理方法，其特征在于，所述活动节点从业务系统获取对客户信息进行查询的目标查询请求之后，还包括：

当所述目标查询请求的索引字段不为客户标识时，所述活动节点通过所述工具节点在所述工具表中查询所述目标查询请求的索引字段对应的客户标识。

11.根据权利要求8所述的基于客户系统的信息处理方法，其特征在于，所述当在所述活动表中查询到所述客户的操作记录时，所述基础节点根据所查询到的客户的操作记录和所述基础表中当前版本的客户信息记录进行数据合并，包括：

所述活动节点根据所述目标查询请求对应的客户标识，在所述活动表中查询到具有所述客户标识的操作记录时，向所述基础节点发送所查询到的操作记录；

在所述基础表中，所述基础节点利用所述查询到的操作记录中的字段取值，更新当前版本的客户信息记录中所述客户标识对应的字段取值。

12.根据权利要求8-11任一项所述的基于客户系统的信息处理方法，其特征在于，所述活动节点查询所述活动表的操作记录中，是否涉及所述目标查询请求中的客户之后，还包括：

当在所述活动表中未查询到所述客户的操作记录时，所述基础节点查询所述基础表中当前版本的客户信息记录；

所述基础节点向所述业务系统发送查询到的客户信息记录。

13.一种客户信息写方法，其特征在于，所述方法包括：

接收业务系统发送的用于对客户信息进行操作的目标操作请求；

根据所述目标操作请求所携带的操作流水标识，在活动表各条操作记录中，利用幂等性函数，将所述目标操作请求所携带的操作流水标识，与所述活动表中各条操作记录的操作流水标识字段进行比对以查询所述操作流水标识是否唯一；其中，所述操作记录用于指示业务系统对客户信息所执行的历史操作；其中，基础节点能够根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并得到合并的客户信息记录；

当所述操作流水标识唯一时，根据所述目标操作请求，对工具表中的对应索引字段进行更新；其中，所述工具表用于对基础表所记录的客户信息进行索引；

在所述活动表中对所述目标操作请求进行记录。

14.根据权利要求13所述的客户信息写方法，其特征在于，所述方法，还包括：

在满足预设触发条件时，获取所述活动表中待合并的操作记录；

根据所述待合并的操作记录和所述基础表中当前版本的客户信息记录进行数据合并，以得到下一版本的客户信息记录；

将所述待合并的操作记录从所述活动表移动至历史数据库。

15.根据权利要求14所述的客户信息写方法，其特征在于，所述在满足预设触发条件时，获取所述活动表中待合并的操作记录，包括：

从所述活动表中，以客户为单位，分别获取每一个客户的待合并的操作记录。

16.根据权利要求15所述的客户信息写方法，其特征在于，所述根据所述待合并的操作记录和所述基础表中当前版本的客户信息记录进行数据合并，包括：

针对每一个客户，利用所述客户的待合并的操作记录中各字段取值，更新所述基础表中当前版本的所述客户的客户信息记录中对应字段取值。

17.根据权利要求15所述的客户信息写方法，其特征在于，所述预设触发条件包括：

满足预设时间间隔；

和/或，满足所述活动表中待合并的操作记录条数大于预设阈值。

18.根据权利要求14-17任一项所述的客户信息写方法，其特征在于，所述根据所述目标操作请求所携带的操作流水标识，在活动表各条操作记录中，查询所述操作流水标识是否唯一，包括：

获取所述目标操作请求所携带的操作流水标识；

利用幂等性函数，将所述操作流水标识，与所述活动表中各条操作记录的操作流水标识字段进行比对，以查询所述操作流水标识是否与所述活动表中各条操作记录的操作流水标识重复。

19.根据权利要求14-17任一项所述的客户信息写方法，其特征在于，所述方法，还包括：

根据配置的业务规则，将所述业务规则中所涉及的索引字段，增加到所述工具表中。

20.一种客户信息读方法，其特征在于，所述方法包括：

从业务系统获取对客户信息进行查询的目标查询请求；

查询活动表的操作记录中是否涉及所述目标查询请求中的客户；其中，所述操作记录包括指示业务系统对客户信息所执行的历史操作以及操作流水标识；

当在所述活动表中查询到所述客户的操作记录时，通过工具表对所述目标查询请求所涉及的查询字段进行索引，以在基础表中，查询到对应客户信息记录；

根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并；

向所述业务系统发送数据合并得到的客户信息记录。

21.根据权利要求20所述的客户信息读方法，其特征在于，所述当在所述活动表中查询到所述客户的操作记录时，通过工具表对所述目标查询请求所涉及的查询字段进行索引，以在基础表中，查询到对应客户信息记录，包括：

通过所述工具表，对所述目标查询请求所涉及的查询字段进行索引，以在所述基础表中，查询到当前版本的客户信息记录中所述查询字段的取值。

22.根据权利要求20所述的客户信息读方法，其特征在于，所述从业务系统获取对客户信息进行查询的目标查询请求之后，还包括：

当所述目标查询请求的索引字段不为客户标识时，在所述工具表中查询所述目标查询请求的索引字段对应的客户标识。

23.根据权利要求20所述的客户信息读方法，其特征在于，所述根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并，包括：

根据所述目标查询请求中的客户标识，在所述活动表中查询到具有所述客户标识的操作记录时，在所述基础表中，利用所查询到的操作记录中的字段取值，更新当前版本的客户信息记录中所述客户标识对应的字段取值。

24.根据权利要求20-23任一项所述的客户信息读方法，其特征在于，所述查询活动表的操作记录中是否涉及所述目标查询请求中的客户之后，还包括：

当在所述活动表中未查询到所述客户的操作记录时，查询所述基础表中当前版本的客户信息记录；

向所述业务系统发送查询到的客户信息记录。

25.一种客户系统，其特征在于，所述客户系统包括活动节点、基础节点，以及工具节点；

所述活动节点，用于从业务系统获取对客户信息进行操作的目标操作请求之后，根据所述目标操作请求所携带的操作流水标识，在活动表各条操作记录中，利用幂等性函数，将所述目标操作请求所携带的操作流水标识，与所述活动表中各条操作记录的操作流水标识字段进行比对以查询所述操作流水标识是否唯一；其中，所述操作记录用于指示业务系统对客户信息所执行的历史操作；其中，所述基础节点能够根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并得到合并的客户信息记录；

所述工具节点，用于当所述活动节点确定所述操作流水标识唯一时，根据所述目标操作请求，对工具表中的对应索引字段进行更新，并向所述活动节点返回更新成功的消息；其中，所述工具表用于对基础表所记录的客户信息进行索引；

所述活动节点，还用于接收到所述更新成功的消息之后，在所述活动表中对所述目标操作请求进行记录；

所述基础节点，用于根据所述活动表，在基础表中记录客户信息。

26.根据权利要求25所述的客户系统，其特征在于，

所述基础节点，具体用于在满足预设触发条件时，从所述活动节点，获取所述活动表中待合并的操作记录；根据所述待合并的操作记录和所述基础表中当前版本的客户信息记录进行数据合并，以得到下一版本的客户信息记录；向所述活动节点返回合并成功的消息；

所述活动节点，还用于根据所述合并成功的消息，将所述待合并的操作记录从所述活动表移动至历史数据库。

27.根据权利要求25所述的客户系统，其特征在于，所述客户系统还包括：元数据节点；

所述元数据节点，用于配置业务规则；

所述工具节点，还用于从所述元数据节点获取配置的业务规则中所涉及的索引字段；将所述业务规则中所涉及的索引字段，增加到所述工具表中。

28.一种客户系统，其特征在于，所述客户系统包括活动节点、基础节点，以及工具节点；

所述活动节点，用于从业务系统获取对客户信息进行查询的目标查询请求；查询活动表的操作记录中，是否涉及所述目标查询请求中的客户；当在所述活动表中查询到所述客户的操作记录时，向所述基础节点发送所查询到的客户的操作记录；其中，所述操作记录包括指示业务系统对客户信息所执行的历史操作以及利用幂等性函数确定出的唯一的操作流水标识；

所述工具节点，用于根据所述目标查询请求所涉及的查询字段，利用工具表，对基础表进行索引；

所述基础节点，用于根据所述工具表，在所述基础表中索引到的对应客户信息记录；根据所查询到的所述客户的操作记录和所查询到的客户信息记录进行数据合并；向所述业务系统发送数据合并得到的客户信息记录。

29.一种客户信息写装置，其特征在于，所述装置包括：

接收模块，用于接收业务系统发送的用于对客户信息进行操作的目标操作请求；

查询模块，用于根据所述目标操作请求所携带的操作流水标识，在活动表各条操作记录中，利用幂等性函数，将所述目标操作请求所携带的操作流水标识，与所述活动表中各条操作记录的操作流水标识字段进行比对以查询所述操作流水标识是否唯一；其中，所述操作记录用于指示业务系统对客户信息所执行的历史操作；其中，基础节点能够根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并得到合并的客户信息记录；

更新模块，用于当所述操作流水标识唯一时，根据所述目标操作请求，对工具表中的对应索引字段进行更新；其中，工具表用于对基础表所记录的客户信息进行索引；

记录模块，用于在所述活动表中对所述目标操作请求进行记录。

30.一种客户信息读装置，其特征在于，所述装置包括：

获取模块，用于从业务系统获取对客户信息进行查询的目标查询请求；

查询模块，用于查询活动表的操作记录中是否涉及所述目标查询请求中的客户；

索引模块，用于当在所述活动表中查询到所述客户的操作记录时，通过工具表对所述目标查询请求所涉及的查询字段进行索引，以在基础表中，查询到对应客户信息记录；其中，所述操作记录包括指示业务系统对客户信息所执行的历史操作以及利用幂等性函数确定出的唯一的操作流水标识；

更新模块，用于根据所查询到的客户的操作记录和所查询到的客户信息记录进行数据合并；

发送模块，用于向所述业务系统发送数据合并得到的客户信息记录。

Images