[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

CN111639086A - Data reconciliation method, device, equipment and storage medium - Google Patents

Data reconciliation method, device, equipment and storage medium Download PDF

Info

Publication number
CN111639086A
CN111639086A CN202010454417.0A CN202010454417A CN111639086A CN 111639086 A CN111639086 A CN 111639086A CN 202010454417 A CN202010454417 A CN 202010454417A CN 111639086 A CN111639086 A CN 111639086A
Authority
CN
China
Prior art keywords
data
reconciliation
missing
account checking
delay
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.)
Granted
Application number
CN202010454417.0A
Other languages
Chinese (zh)
Other versions
CN111639086B (en
Inventor
杨尚京
王枫
谭仕朝
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Shenzhen Lexin Software Technology Co Ltd
Original Assignee
Shenzhen Lexin Software Technology Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Shenzhen Lexin Software Technology Co Ltd filed Critical Shenzhen Lexin Software Technology Co Ltd
Priority to CN202010454417.0A priority Critical patent/CN111639086B/en
Publication of CN111639086A publication Critical patent/CN111639086A/en
Application granted granted Critical
Publication of CN111639086B publication Critical patent/CN111639086B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Classifications

    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/23Updating
    • G06F16/2358Change logging, detection, and notification
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/27Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06QINFORMATION 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/00Finance; Insurance; Tax strategies; Processing of corporate or income taxes
    • G06Q40/12Accounting
    • G06Q40/125Finance or payroll
    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02DCLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
    • Y02D10/00Energy efficient computing, e.g. low power processors, power management or thermal management

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Business, Economics & Management (AREA)
  • Finance (AREA)
  • Databases & Information Systems (AREA)
  • Physics & Mathematics (AREA)
  • General Physics & Mathematics (AREA)
  • Accounting & Taxation (AREA)
  • General Engineering & Computer Science (AREA)
  • Data Mining & Analysis (AREA)
  • Computing Systems (AREA)
  • Development Economics (AREA)
  • Economics (AREA)
  • Marketing (AREA)
  • Strategic Management (AREA)
  • Technology Law (AREA)
  • General Business, Economics & Management (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
  • Debugging And Monitoring (AREA)

Abstract

本发明实施例公开了一种数据对账方法、装置、设备及存储介质。该方法包括:根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据;根据对账数据进行对账操作;若对账结果为对账不平,判断对账数据是否存在缺失;根据对账数据的缺失情况,发送对账结果信息。本发明实施例的技术方案可以在对账时,准确发送对账结果信息,产生告警信号,避免出现由于对账数据缺失造成对账结果不可靠时,从而误报告警的情况。

Figure 202010454417

The embodiments of the present invention disclose a data reconciliation method, device, device and storage medium. The method includes: obtaining corresponding reconciliation data from at least two data sources respectively according to the received data change message; performing reconciliation operations according to the reconciliation data; if the reconciliation result is that the reconciliation is uneven, judging whether the reconciliation data is not There is a lack; according to the lack of reconciliation data, the reconciliation result information is sent. The technical solution of the embodiment of the present invention can accurately send the reconciliation result information and generate an alarm signal during reconciliation, so as to avoid false alarms when the reconciliation result is unreliable due to the lack of reconciliation data.

Figure 202010454417

Description

一种数据对账方法、装置、设备及存储介质A data reconciliation method, device, equipment and storage medium

技术领域technical field

本发明实施例涉及数据对账技术领域,尤其涉及一种数据对账方法、装置、设备及存储介质。Embodiments of the present invention relate to the technical field of data reconciliation, and in particular, to a data reconciliation method, apparatus, device, and storage medium.

背景技术Background technique

随着互联网技术的发展,不同系统间时刻会存在大量产生交互的数据。例如,商品购买、支付或者还款时,用户账户系统与商家账户系统中的数据会交互。事件发生在两个系统之间时,交互的数据需要符合预期,判断交互的数据是否符合预期,实现的手段是对账。With the development of Internet technology, there will always be a large amount of interactive data between different systems. For example, when a product is purchased, paid or repaid, the data in the user account system and the merchant account system will interact. When an event occurs between two systems, the interactive data needs to meet expectations, and to determine whether the interactive data meets expectations, the means of realization is reconciliation.

现有技术中,在对不同系统进行对账时,如果出现对账异常,即会产生告警信号。例如,对账结果是对账不平时,会产生告警信号。但是,在对账数据或者系统自身出现异常情况下进行对账时会导致对账异常,并直接产生告警信号,而此时产生的告警信号是一种误报告警信号,现有技术中无法避免该误报告警信号的产生。In the prior art, when reconciliation between different systems is performed, an alarm signal will be generated if the reconciliation is abnormal. For example, if the reconciliation result is uneven, an alarm signal will be generated. However, when the reconciliation data or the system itself is abnormal, the reconciliation will be abnormal, and an alarm signal will be generated directly. The alarm signal generated at this time is a false alarm signal, which cannot be avoided in the prior art. This false alarm signal is generated.

发明内容SUMMARY OF THE INVENTION

本发明实施例提供了一种数据对账方法、装置、设备及存储介质,可以准确发送对账结果信息,避免误报告警。The embodiments of the present invention provide a data reconciliation method, device, equipment and storage medium, which can accurately send reconciliation result information and avoid false alarms.

第一方面,本发明实施例提供了一种数据对账方法,该方法包括:In a first aspect, an embodiment of the present invention provides a data reconciliation method, which includes:

根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据;Obtain corresponding reconciliation data from at least two data sources according to the received data change message;

根据所述对账数据进行对账操作;perform a reconciliation operation according to the reconciliation data;

若对账结果为对账不平,判断所述对账数据是否存在缺失;If the reconciliation result is that the reconciliation is uneven, determine whether the reconciliation data is missing;

根据所述对账数据的缺失情况,发送对账结果信息。According to the lack of the reconciliation data, the reconciliation result information is sent.

第二方面,本发明实施例还提供了一种数据对账装置,该装置包括:In a second aspect, an embodiment of the present invention further provides a data reconciliation device, the device comprising:

对账数据获取模块,用于根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据;A reconciliation data acquisition module, configured to acquire corresponding reconciliation data from at least two data sources according to the received data change message;

对账操作执行模块,用于根据所述对账数据进行对账操作;a reconciliation operation execution module, configured to perform a reconciliation operation according to the reconciliation data;

对账数据缺失判断模块,用于若对账结果为对账不平,判断所述对账数据是否存在缺失;A judging module for missing reconciliation data, configured to determine whether the reconciliation data is missing if the reconciliation result is uneven;

信息发送模块,用于根据所述对账数据的缺失情况,发送对账不结果消息。An information sending module, configured to send a reconciliation failure message according to the lack of the reconciliation data.

第三方面,本发明实施例还提供了一种对账设备,该对账设备包括:In a third aspect, an embodiment of the present invention further provides an account reconciliation device, where the account reconciliation device includes:

一个或多个处理器;one or more processors;

存储装置,用于存储一个或多个程序,storage means for storing one or more programs,

当所述一个或多个程序被所述一个或多个处理器执行,使得所述一个或多个处理器实现如本发明任意实施例所述的一种数据对账方法。When the one or more programs are executed by the one or more processors, the one or more processors implement a data reconciliation method according to any embodiment of the present invention.

第四方面,本发明实施例还提供了一种计算机可读存储介质,其上存储有计算机程序,该程序被处理器执行时实现如本发明任意实施例所述的一种数据对账方法。In a fourth aspect, an embodiment of the present invention further provides a computer-readable storage medium on which a computer program is stored, and when the program is executed by a processor, implements a data reconciliation method according to any embodiment of the present invention.

本发明通过根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据;根据对账数据进行对账操作;若对账结果为对账不平,判断对账数据是否存在缺失;根据对账数据的缺失情况,发送对账结果信息,解决了对账数据缺失导致对账结果不可靠时,产生误报告警的问题,实现了准确发送对账结果信息,避免误报告警的效果。The present invention obtains the corresponding reconciliation data from at least two data sources respectively according to the received data change message; performs reconciliation operation according to the reconciliation data; if the reconciliation result is that the reconciliation is uneven, it is judged whether the reconciliation data exists Missing; according to the lack of reconciliation data, the reconciliation result information is sent, which solves the problem of false alarms when the reconciliation results are unreliable due to the lack of reconciliation data, realizes the accurate sending of reconciliation result information, and avoids false alarms Effect.

附图说明Description of drawings

图1是本发明实施例一提供的一种数据对账方法的流程图;1 is a flowchart of a data reconciliation method provided in Embodiment 1 of the present invention;

图2是本发明实施例二提供的一种数据对账方法的流程图;2 is a flowchart of a data reconciliation method provided in Embodiment 2 of the present invention;

图3是本发明实施例二提供的一种数据对账系统的数据流程图;3 is a data flow chart of a data reconciliation system provided by Embodiment 2 of the present invention;

图4是本发明实施例二提供的一种数据对账系统的数据流程图;4 is a data flow chart of a data reconciliation system provided by Embodiment 2 of the present invention;

图5是本发明实施例三提供的一种数据对账装置的结构示意图;5 is a schematic structural diagram of a data reconciliation device according to Embodiment 3 of the present invention;

图6是本发明实施例四提供的一种对账设备的结构示意图。FIG. 6 is a schematic structural diagram of an account reconciliation device according to Embodiment 4 of the present invention.

具体实施方式Detailed ways

下面结合附图和实施例对本发明作进一步的详细说明。可以理解的是,此处所描述的具体实施例仅仅用于解释本发明,而非对本发明的限定。另外还需要说明的是,为了便于描述,附图中仅示出了与本发明相关的部分而非全部结构。The present invention will be further described in detail below in conjunction with the accompanying drawings and embodiments. It should be understood that the specific embodiments described herein are only used to explain the present invention, but not to limit the present invention. In addition, it should be noted that, for the convenience of description, the drawings only show some but not all structures related to the present invention.

实施例一Example 1

图1是本发明实施例一提供的一种数据对账方法的流程图,本实施例可适用于实时对账中数据缺失时避免造成误报告警的情况,该方法可以由数据对账装置来执行,该装置可以通过软件和/或硬件的方式实现,该装置可以集成在计算机设备中,如图1所示,该方法具体包括:FIG. 1 is a flowchart of a data reconciliation method provided in Embodiment 1 of the present invention. This embodiment can be applied to avoid false alarms when data is missing in real-time reconciliation. The method can be performed by a data reconciliation device. Execution, the apparatus can be implemented by means of software and/or hardware, and the apparatus can be integrated in computer equipment, as shown in FIG. 1 , the method specifically includes:

步骤110、根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据。Step 110: Acquire corresponding reconciliation data from at least two data sources respectively according to the received data change message.

其中,通常事件会发生在至少两个系统中,一个系统会对应两个数据库一个是主数据库,用于真正的业务使用;另一个是备数据库,用于将主数据库的数据进行复制存储,在主数据库出现问题时,进行使用。当数据从主数据库同步至备数据库时,会向对账设备发送数据变更消息,当对账设备接收到数据变更消息时,会从系统对应的数据源中获取对应的对账数据。本发明实施例中的数据源可以是系统对应的存储数据的备数据库。对账数据可以是事件发生时,不同系统对应的数据源中存在关联的数据。Among them, events usually occur in at least two systems, one system will correspond to two databases, one is the primary database, which is used for real business use; the other is the standby database, which is used to replicate and store the data of the primary database. It is used when there is a problem with the main database. When the data is synchronized from the primary database to the standby database, a data change message will be sent to the reconciliation device. When the reconciliation device receives the data change message, it will obtain the corresponding reconciliation data from the corresponding data source of the system. The data source in the embodiment of the present invention may be a standby database corresponding to the system for storing data. Reconciliation data can be associated data in data sources corresponding to different systems when an event occurs.

示例的,事件是贷款还款事件,贷款对应订单系统,还款对应账单系统,订单系统和账单系统均具有主数据库和备数据库。数据源可以是贷款的订单系统和还款的账单系统分别对应的备数据库,对账数据是订单系统对应的备数据库中的贷款数据,和账单系统对应的备数据库中的还款数据。For example, the event is a loan repayment event. The loan corresponds to the order system, and the repayment corresponds to the billing system. Both the order system and the billing system have a primary database and a standby database. The data source may be the standby database corresponding to the loan order system and the repayment billing system respectively, and the reconciliation data is the loan data in the standby database corresponding to the order system and the repayment data in the standby database corresponding to the billing system.

步骤120、根据对账数据进行对账操作。Step 120: Perform a reconciliation operation according to the reconciliation data.

其中,对账设备会根据获取的对账数据按照预设对账规则进行对账操作,预设对账规则可以是执行对账操作的脚本。示例的,可以是订单系统对应的备数据库中的贷款数据,与账单系统对应的备数据库中的还款数据进行对账操作。The reconciliation device will perform a reconciliation operation according to a preset reconciliation rule according to the acquired reconciliation data, and the preset reconciliation rule may be a script for performing the reconciliation operation. For example, the loan data in the standby database corresponding to the order system can be reconciled with the repayment data in the standby database corresponding to the billing system.

步骤130、若对账结果为对账不平,判断对账数据是否存在缺失。Step 130: If the reconciliation result is that the reconciliation is uneven, determine whether the reconciliation data is missing.

其中,对账结果可以是对账平或对账不平。对账平表明对账数据符合预设对账规则,不存在问题;而对账不平表明对账数据不符合预设对账规则,存在问题,存在的问题可能是由于对账数据缺失造成的,也可能是由于对账数据本身存在问题造成的。在对账不平时,对账设备会发送对账不平告警,以使系统的管理者对系统进行调整,找出系统存在的问题。因此,由于对账数据本身存在问题造成对账不平时,发送对账不平告警是正常的。但是,由于对账数据缺失造成对账不平时,对账数据可能不存在问题,而可能是由于网络问题、数据量大等使对账数据延迟造成对账不平,不需要系统的管理者对系统进行调整,不属于需要发送对账不平告警的情况。这种情况下,发送对账不平告警会造成误报告警。Wherein, the reconciliation result may be a balance of the reconciliation or an unevenness of the reconciliation. Reconciliation level indicates that the reconciliation data conforms to the preset reconciliation rules, and there is no problem; while the reconciliation difference indicates that the reconciliation data does not conform to the preset reconciliation rules, and there is a problem. The existing problem may be caused by the lack of reconciliation data. It may also be caused by problems with the reconciliation data itself. When the reconciliation is uneven, the reconciliation device will send a reconciliation uneven alarm, so that the system administrator can adjust the system and find out the problems existing in the system. Therefore, it is normal to send a reconciliation inconsistency alarm due to problems in the reconciliation data itself. However, due to the lack of reconciliation data resulting in uneven reconciliation, there may not be a problem with the reconciliation data, but the reconciliation data may be delayed due to network problems and large amounts of data. Adjustment is not a situation that needs to send a reconciliation inequity alarm. In this case, sending a reconciliation discrepancy alarm will cause a false alarm.

在本发明实施例的一个实施方式中,可选的,判断对账数据是否存在缺失,包括:判断从全部数据源获取到的对账数据是否满足预设对账规则;若对账数据满足预设对账规则,确定对账数据不存在缺失;若对账数据不满足预设对账规则,确定对账数据存在缺失。In one implementation of the embodiment of the present invention, optionally, judging whether the reconciliation data is missing includes: judging whether the reconciliation data obtained from all data sources satisfies the preset reconciliation rules; Set up reconciliation rules to determine that the reconciliation data is not missing; if the reconciliation data does not meet the preset reconciliation rules, determine that the reconciliation data is missing.

其中,从预设对账规则中,可以知晓需要进行对账操作需要的对账数据,当获取的对账数据满足预设对账规则的要求时,可以判断对账数据不存在缺失;而当获取的对账数据不满足预设对账规则的要求时,例如,对账规则需要两个备数据库的数据,但仅获取到一个备数据库的数据,可以判断对账数据存在缺失。The reconciliation data required for the reconciliation operation can be known from the preset reconciliation rules, and when the acquired reconciliation data meets the requirements of the preset reconciliation rules, it can be determined that the reconciliation data is not missing; When the acquired reconciliation data does not meet the requirements of the preset reconciliation rules, for example, the reconciliation rules require data from two standby databases, but only the data from one standby database is acquired, so it can be judged that the reconciliation data is missing.

步骤140、根据对账数据的缺失情况,发送对账结果信息。Step 140: Send reconciliation result information according to the lack of reconciliation data.

其中,当对账数据不存在缺失时,对账设备会发送对账结果信息。例如,对账结果信息可以是对账不平以及对账不平告警。当对账数据存在缺失时,对账设备会发送对账结果信息。例如,对账结果信息可以是对账不平,对账数据存在缺失,但是不会发送对账不平告警。可以准确发送对账不平告警,避免出现由于对账数据缺失造成对账结果不可靠时,从而误报告警的情况。Among them, when the reconciliation data is not missing, the reconciliation device will send the reconciliation result information. For example, the reconciliation result information may be reconciliation discrepancies and reconciliation discrepancies alarms. When the reconciliation data is missing, the reconciliation device will send the reconciliation result information. For example, the reconciliation result information may be that the reconciliation is not equal, and the reconciliation data is missing, but the reconciliation inconsistency alarm will not be sent. Reconciliation inequity alarms can be sent accurately to avoid false alarms when reconciliation results are unreliable due to lack of reconciliation data.

本发明实施例的技术方案,通过根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据;根据对账数据进行对账操作;若对账结果为对账不平,判断对账数据是否存在缺失;根据对账数据的缺失情况,发送对账结果信息,解决了对账数据缺失导致对账结果不可靠时,误报告警的问题,实现了准确发送对账结果信息,准确产生告警信号,避免误报告警的效果。The technical solution of the embodiment of the present invention is to obtain corresponding reconciliation data from at least two data sources respectively according to the received data change message; perform reconciliation operations according to the reconciliation data; if the reconciliation result is that the reconciliation is uneven, Determine whether the reconciliation data is missing; send the reconciliation result information according to the lack of reconciliation data, solve the problem of false alarm when the reconciliation result is unreliable due to the lack of reconciliation data, and realize the accurate sending of the reconciliation result information , to accurately generate the alarm signal, to avoid the effect of false alarm.

实施例二Embodiment 2

图2是本发明实施例二提供的一种数据对账方法的流程图,本实施例是对上述技术方案的进一步细化,本实施例中的技术方案可以与上述一个或者多个实施例中的各个可选方案结合。FIG. 2 is a flowchart of a data reconciliation method provided in Embodiment 2 of the present invention. This embodiment is a further refinement of the above technical solution. The technical solution in this embodiment may be different from that in one or more of the above embodiments. combination of various options.

如图2所示,该方法具体包括:As shown in Figure 2, the method specifically includes:

步骤210、根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据。Step 210: Acquire corresponding reconciliation data from at least two data sources respectively according to the received data change message.

步骤220、根据对账数据进行对账操作。Step 220: Perform a reconciliation operation according to the reconciliation data.

步骤230、若对账结果为对账不平,判断从全部数据源获取到的对账数据是否满足预设对账规则;若对账数据满足预设对账规则,确定对账数据不存在缺失;若对账数据不满足预设对账规则,确定对账数据存在缺失。Step 230: If the reconciliation result is that the reconciliation is uneven, determine whether the reconciliation data obtained from all the data sources satisfy the preset reconciliation rules; if the reconciliation data satisfies the preset reconciliation rules, determine that the reconciliation data is not missing; If the reconciliation data does not meet the preset reconciliation rules, it is determined that the reconciliation data is missing.

步骤240、若对账数据存在缺失,检查缺失的对账数据对应的数据源是否存在延迟;若缺失的对账数据对应的数据源存在延迟,将缺失的对账数据标记为延迟数据。Step 240: If the reconciliation data is missing, check whether the data source corresponding to the missing reconciliation data is delayed; if the data source corresponding to the missing reconciliation data is delayed, mark the missing reconciliation data as delayed data.

其中,当对账数据存在缺失时,可以检查缺失的对账数据对应的数据源是否存在延迟,若数据源存在延迟,对账数据也将存在延迟,可以将延迟的对账数据标记为延迟数据,可以便于后续再对延迟数据进行对账。也可以排除其他原因造成的对账数据缺失,例如,如果是由于数据延迟造成的对账数据缺失,可能不需要系统的管理者进行调整,但是如果是系统故障造成的对账数据缺失,可能需要及时通知系统的管理者。因此,需要进一步判断对账数据的缺失是否是由于对账数据延迟引起的,可以是对账不平告警的发送更加准确。Among them, when the reconciliation data is missing, you can check whether the data source corresponding to the missing reconciliation data is delayed. If the data source is delayed, the reconciliation data will also be delayed, and the delayed reconciliation data can be marked as delayed data. , which can facilitate subsequent reconciliation of delayed data. It is also possible to rule out the lack of reconciliation data caused by other reasons. For example, if the reconciliation data is missing due to data delay, the system administrator may not need to adjust it, but if the reconciliation data is missing due to a system failure, it may be necessary. Notify the administrator of the system in a timely manner. Therefore, it is necessary to further judge whether the lack of the reconciliation data is caused by the delay of the reconciliation data, and it may be that the sending of the reconciliation discrepancy alarm is more accurate.

在本发明实施例的一个实施方式中,可选的,检查缺失的对账数据对应的数据源是否存在延迟,包括:从非缺失的对账数据对应的数据源获取对账数据的变更时间,以及从缺失的对账数据对应的数据源获取对账数据的同步时间;若变更时间在同步时间之后,确定缺失的对账数据对应的数据源存在延迟;若变更时间未在同步时间之后,确定缺失的对账数据对应的数据源不存在延迟;其中,变更时间是数据源中每条对账数据发生变更对应的时间;同步时间是数据源中所有数据进行同步备份的时间。In one implementation of the embodiment of the present invention, optionally, checking whether there is a delay in the data source corresponding to the missing reconciliation data includes: obtaining the change time of the reconciliation data from the data source corresponding to the non-missing reconciliation data, And obtain the synchronization time of the reconciliation data from the data source corresponding to the missing reconciliation data; if the change time is after the synchronization time, determine that there is a delay in the data source corresponding to the missing reconciliation data; if the change time is not after the synchronization time, determine There is no delay in the data source corresponding to the missing reconciliation data; the change time is the time corresponding to the change of each reconciliation data in the data source; the synchronization time is the time when all data in the data source is backed up synchronously.

其中,每条数据都具有变更时间,数据的变更时间是该数据从主数据库同步到备数据库的时间。备数据库中的数据也会存在同步时间,同步时间是指在此同步时间之前的所有数据,均从主数据库同步至备数据库。Among them, each piece of data has a change time, and the change time of the data is the time when the data is synchronized from the primary database to the standby database. The data in the standby database also has a synchronization time. The synchronization time means that all data before this synchronization time is synchronized from the primary database to the standby database.

当判断缺失的对账数据对应的数据源是否存在延迟时,可以从非缺失的对账数据对应的数据源获取对账数据的变更时间,以及从缺失的对账数据对应的数据源获取对账数据的同步时间;若变更时间在同步时间之后,可以确定缺失的对账数据对应的数据源存在延迟。例如,订单系统与账单系统进行对账操作,账单系统对应的对账数据存在缺失,订单系统对应的对账数据的变更时间为5点35分,账单系统对应的备数据库的同步时间为5点30分。在订单系统数据变更时,账单系统数据应该同时变更。但,此时同步时间在变更时间之前,说明订单系统的数据变更时,账单系统的数据没有从主数据库同步至备数据库,可以确定账单系统存在延迟,从而导致账单系统对应的对账数据缺失。When judging whether the data source corresponding to the missing reconciliation data is delayed, the change time of the reconciliation data can be obtained from the data source corresponding to the non-missing reconciliation data, and the reconciliation data can be obtained from the data source corresponding to the missing reconciliation data Data synchronization time; if the change time is after the synchronization time, it can be determined that there is a delay in the data source corresponding to the missing reconciliation data. For example, the reconciliation operation between the order system and the billing system is performed, and the reconciliation data corresponding to the billing system is missing, the change time of the reconciliation data corresponding to the order system is 5:35, and the synchronization time of the standby database corresponding to the billing system is 5:00 30 points. When the order system data is changed, the billing system data should be changed at the same time. However, when the synchronization time is before the change time, it means that when the data of the order system is changed, the data of the billing system is not synchronized from the primary database to the standby database. It can be determined that there is a delay in the billing system, which leads to the lack of reconciliation data corresponding to the billing system.

若变更时间未在同步时间之后,确定缺失的对账数据对应的数据源不存在延迟。例如,订单系统与账单系统进行对账操作,账单系统对应的对账数据存在缺失,订单系统对应的对账数据的变更时间为5点35分,账单系统对应的备数据库的同步时间为5点40分。在订单系统数据变更时,账单系统数据应该同时变更。但,此时同步时间在变更时间之后,说明订单系统的数据变更时,账单系统的数据应该从主数据库同步至备数据库,不是由于账单系统存在延迟导致账单系统对应的对账数据缺失,可以确定账单系统不存在延迟,可能是由于账单系统故障造成对账数据缺失。If the change time is not after the synchronization time, there is no delay in determining the data source corresponding to the missing reconciliation data. For example, the reconciliation operation between the order system and the billing system is performed, and the reconciliation data corresponding to the billing system is missing, the change time of the reconciliation data corresponding to the order system is 5:35, and the synchronization time of the standby database corresponding to the billing system is 5:00 40 marks. When the order system data is changed, the billing system data should be changed at the same time. However, at this time, the synchronization time is after the change time, indicating that when the data of the order system changes, the data of the billing system should be synchronized from the primary database to the standby database. It is not due to the delay in the billing system that the reconciliation data corresponding to the billing system is missing. It can be determined that There is no delay in the billing system, which may be due to the lack of reconciliation data due to the failure of the billing system.

步骤250、以预设时间间隔,定期从延迟数据对应的数据源获取延迟数据的同步时间;若延迟数据的同步时间在变更时间之后,从延迟数据对应的数据源中获取缺失的对账数据进行对账操作。Step 250: At preset time intervals, periodically obtain the synchronization time of the delayed data from the data source corresponding to the delayed data; if the synchronization time of the delayed data is after the change time, obtain the missing reconciliation data from the data source corresponding to the delayed data and carry out the process. Reconciliation operation.

其中,为对延迟数据进行对账操作,对账设备会以预设时间间隔,获取延迟数据的同步时间,判断延迟数据是否能够获取到。当延迟数据的同步时间在变更时间之后时,认为此时延迟数据应该从主数据库同步至备数据库,可以获取到延迟数据,即可以获取到缺失的对账数据。对账设备会从延迟数据对应的备数据库中获取缺失的对账数据,并进行对账操作,当对账不平时,发送对账不平告警。Among them, in order to perform the reconciliation operation on the delayed data, the reconciliation device will obtain the synchronization time of the delayed data at preset time intervals, and judge whether the delayed data can be obtained. When the synchronization time of the delayed data is after the change time, it is considered that the delayed data should be synchronized from the primary database to the standby database at this time, and the delayed data can be obtained, that is, the missing reconciliation data can be obtained. The reconciliation device will obtain the missing reconciliation data from the standby database corresponding to the delayed data, and perform reconciliation operations.

本实施例的技术方案,通过根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据;根据对账数据进行对账操作;若对账结果为对账不平,判断从全部数据源获取到的对账数据是否满足预设对账规则;若对账数据满足预设对账规则,确定对账数据不存在缺失;若对账数据不满足预设对账规则,确定对账数据存在缺失;若对账数据存在缺失,检查缺失的对账数据对应的数据源是否存在延迟;若缺失的对账数据对应的数据源存在延迟,将缺失的对账数据标记为延迟数据;以预设时间间隔,定期从延迟数据对应的数据源获取延迟数据的同步时间;若延迟数据的同步时间在变更时间之后,从延迟数据对应的数据源中获取缺失的对账数据进行对账操作,解决了对账数据延迟导致对账结果不可靠时,误报告警的问题,实现了准确发送对账结果信息,准确产生告警信号,避免误报告警的效果。The technical solution of this embodiment is to obtain corresponding reconciliation data from at least two data sources respectively according to the received data change message; perform reconciliation operations according to the reconciliation data; if the reconciliation result is that the reconciliation is uneven, determine Whether the reconciliation data obtained from all data sources satisfies the preset reconciliation rules; if the reconciliation data satisfies the preset reconciliation rules, determine that the reconciliation data is not missing; if the reconciliation data does not meet the preset reconciliation rules, determine The reconciliation data is missing; if the reconciliation data is missing, check whether the data source corresponding to the missing reconciliation data is delayed; if the data source corresponding to the missing reconciliation data is delayed, mark the missing reconciliation data as delayed data ; At preset time intervals, periodically obtain the synchronization time of the delayed data from the data source corresponding to the delayed data; if the synchronization time of the delayed data is after the change time, obtain the missing reconciliation data from the data source corresponding to the delayed data for reconciliation The operation solves the problem of false alarms when the reconciliation results are unreliable due to the delay of reconciliation data, and realizes the effect of accurately sending the reconciliation result information, accurately generating alarm signals, and avoiding false alarms.

图3是本发明实施例二提供的一种数据对账系统的数据流程图,如图3所示,在实时对账过程中,对账设备会获取进行对账的多个数据源的对账数据,根据获取的对账数据进行对账操作。例如,获取第一数据源的对账数据1存在,获取第二数据源的对账数据2缺失,进行实时对账,对账结果是对账不平。对账设备会检查缺失的对账数据2对应的第二数据源是否存在延迟,若第二数据源存在延迟,会将第二数据源对应的对账数据2标记为延迟数据,不发送对账不平告警,可以准确发送对账结果信息,产生告警信号,避免误报告警。FIG. 3 is a data flow chart of a data reconciliation system provided in Embodiment 2 of the present invention. As shown in FIG. 3 , during the real-time reconciliation process, the reconciliation device will obtain reconciliations from multiple data sources for reconciliation. data, and perform reconciliation operations based on the acquired reconciliation data. For example, if the reconciliation data 1 obtained from the first data source exists, and the reconciliation data 2 obtained from the second data source is missing, real-time reconciliation is performed, and the reconciliation result is that the reconciliation is uneven. The reconciliation device will check whether there is a delay in the second data source corresponding to the missing reconciliation data 2. If there is a delay in the second data source, the reconciliation data 2 corresponding to the second data source will be marked as delayed data, and the reconciliation will not be sent. Uneven alarm can accurately send the reconciliation result information, generate an alarm signal, and avoid false alarms.

图4是本发明实施例二提供的一种数据对账系统的数据流程图,如图4所示,对于实时对账中存在延迟的对账数据,会标记为延迟数据,对于延迟数据,对账设备会定时检查其对应的数据源的同步时间,如果同步时间符合预期,即延迟的对账数据对应的数据源的同步时间在非延迟的对账数据的变更时间之后,会触发延迟数据对账,对实时对账中由于延迟导致对账结果异常的对账数据重新进行对账。如果同步时间不符合预期,会继续定时检查其对应的数据源的同步时间,直至同步时间符合预期,进行对账操作。根据对账结果发送对账结果信息,可以是对账平,也可以是对账不平,并在对账不平时发送对账不平告警。可以准确发送对账结果信息,准确产生告警信号,避免误报告警,同时对延迟的对账数据也可以再次进行对账操作,提高对账结果的准确性。Fig. 4 is a data flow chart of a data reconciliation system provided in Embodiment 2 of the present invention. As shown in Fig. 4, for reconciliation data that is delayed in real-time reconciliation, it will be marked as delayed data. The accounting device will regularly check the synchronization time of its corresponding data source. If the synchronization time is as expected, that is, the synchronization time of the data source corresponding to the delayed reconciliation data is after the change time of the non-delayed reconciliation data, the delayed data pair will be triggered. Reconciliation is performed on the reconciliation data whose reconciliation result is abnormal due to the delay in the real-time reconciliation. If the synchronization time does not meet the expectations, it will continue to regularly check the synchronization time of the corresponding data source until the synchronization time meets the expectations, and perform the reconciliation operation. According to the reconciliation result, the reconciliation result information is sent, which may be a balance of the reconciliation, or an unbalance of the reconciliation, and an unbalanced alarm is sent when the reconciliation is uneven. The reconciliation result information can be sent accurately, alarm signals can be accurately generated, and false alarms can be avoided. At the same time, the reconciliation operation can be performed again for the delayed reconciliation data to improve the accuracy of the reconciliation results.

实施例三Embodiment 3

图5是本发明实施例三提供的一种数据对账装置的结构示意图。结合图5,该装置包括:对账数据获取模块310,对账操作执行模块320,对账数据缺失判断模块330和信息发送模块340。FIG. 5 is a schematic structural diagram of a data reconciliation device provided in Embodiment 3 of the present invention. Referring to FIG. 5 , the apparatus includes: a reconciliation data acquisition module 310 , an account reconciliation operation execution module 320 , a reconciliation data missing judgment module 330 and an information sending module 340 .

其中,对账数据获取模块310,用于根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据;Wherein, the reconciliation data acquisition module 310 is configured to acquire corresponding reconciliation data from at least two data sources respectively according to the received data change message;

对账操作执行模块320,用于根据对账数据进行对账操作;a reconciliation operation execution module 320, configured to perform a reconciliation operation according to the reconciliation data;

对账数据缺失判断模块330,用于若对账结果为对账不平,判断对账数据是否存在缺失;A judging module 330 for missing reconciliation data, configured to judge whether the reconciliation data is missing if the reconciliation result is an unbalanced reconciliation;

信息发送模块340,用于根据对账数据的缺失情况,发送对账不结果消息。The information sending module 340 is configured to send a reconciliation failure message according to the lack of reconciliation data.

可选的,信息发送模块340,包括:Optionally, the information sending module 340 includes:

延迟检查单元,用于若对账数据存在缺失,检查缺失的对账数据对应的数据源是否存在延迟;The delay checking unit is used to check whether the data source corresponding to the missing reconciliation data is delayed if the reconciliation data is missing;

延迟数据标记单元,用于若缺失的对账数据对应的数据源存在延迟,将缺失的对账数据标记为延迟数据。The delayed data marking unit is used to mark the missing reconciliation data as delayed data if the data source corresponding to the missing reconciliation data is delayed.

可选的,延迟检查单元,包括:Optional, delayed checking unit, including:

时间获取子单元,用于从非缺失的对账数据对应的数据源获取对账数据的变更时间,以及从缺失的对账数据对应的数据源获取对账数据的同步时间;The time obtaining subunit is used to obtain the change time of the reconciliation data from the data source corresponding to the non-missing reconciliation data, and obtain the synchronization time of the reconciliation data from the data source corresponding to the missing reconciliation data;

延迟确定子单元,用于若变更时间在同步时间之后,确定缺失的对账数据对应的数据源存在延迟;若变更时间未在同步时间之后,确定缺失的对账数据对应的数据源不存在延迟;The delay determination subunit is used to determine that the data source corresponding to the missing reconciliation data is delayed if the change time is after the synchronization time; if the change time is not after the synchronization time, determine that the data source corresponding to the missing reconciliation data is not delayed ;

其中,变更时间是数据源中每条对账数据发生变更对应的时间;同步时间是数据源中所有数据进行同步备份的时间。Among them, the change time is the time corresponding to the change of each reconciliation data in the data source; the synchronization time is the time when all data in the data source is backed up synchronously.

可选的,对账数据缺失判断模块330,包括:Optionally, the judging module 330 for missing reconciliation data includes:

对账数据缺失判断单元,用于判断从全部数据源获取到的对账数据是否满足预设对账规则;若对账数据满足预设对账规则,确定对账数据不存在缺失;若对账数据不满足预设对账规则,确定对账数据存在缺失。The reconciliation data missing judgment unit is used to judge whether the reconciliation data obtained from all data sources satisfies the preset reconciliation rules; if the reconciliation data satisfies the preset reconciliation rules, it is determined that the reconciliation data is not missing; If the data does not meet the preset reconciliation rules, it is determined that the reconciliation data is missing.

可选的,该装置,还包括:Optionally, the device further includes:

同步时间定期获取模块,用于在若缺失的对账数据对应的数据源存在延迟,将缺失的对账数据标记为延迟数据之后,以预设时间间隔,定期从延迟数据对应的数据源获取延迟数据的同步时间;The synchronization time periodic acquisition module is used to periodically obtain the delay from the data source corresponding to the delayed data at preset time intervals after marking the missing reconciliation data as delayed data if the data source corresponding to the missing reconciliation data is delayed. data synchronization time;

对账操作进行模块,用于若延迟数据的同步时间在变更时间之后,从延迟数据对应的数据源中获取缺失的对账数据进行对账操作。The reconciliation operation module is used to obtain the missing reconciliation data from the data source corresponding to the delayed data to perform the reconciliation operation if the synchronization time of the delayed data is after the change time.

本发明实施例所提供的数据对账装置可执行本发明任意实施例所提供的数据对账方法,具备执行方法相应的功能模块和有益效果。The data reconciliation device provided by the embodiment of the present invention can execute the data reconciliation method provided by any embodiment of the present invention, and has functional modules and beneficial effects corresponding to the execution method.

实施例四Embodiment 4

图6是本发明实施例四提供的一种对账设备的结构示意图,如图6所示,该对账设备包括:FIG. 6 is a schematic structural diagram of an account reconciliation device according to Embodiment 4 of the present invention. As shown in FIG. 6 , the account reconciliation device includes:

一个或多个处理器410,图6中以一个处理器410为例;One or more processors 410, one processor 410 is taken as an example in FIG. 6;

存储器420;memory 420;

所述设备还可以包括:输入装置430和输出装置440。The apparatus may further include: an input device 430 and an output device 440 .

所述设备中的处理器410、存储器420、输入装置430和输出装置440可以通过总线或者其他方式连接,图6中以通过总线连接为例。The processor 410 , the memory 420 , the input device 430 and the output device 440 in the device may be connected by a bus or in other ways, and the connection by a bus is taken as an example in FIG. 6 .

存储器420作为一种非暂态计算机可读存储介质,可用于存储软件程序、计算机可执行程序以及模块,如本发明实施例中的一种数据对账方法对应的程序指令/模块(例如,附图5所示的对账数据获取模块310,对账操作执行模块320,对账数据缺失判断模块330和信息发送模块340)。处理器410通过运行存储在存储器420中的软件程序、指令以及模块,从而执行计算机设备的各种功能应用以及数据处理,即实现上述方法实施例的一种数据对账方法,即:As a non-transitory computer-readable storage medium, the memory 420 can be used to store software programs, computer-executable programs, and modules, such as program instructions/modules corresponding to a data reconciliation method in this embodiment of the present invention (for example, appendix. The reconciliation data acquisition module 310 shown in FIG. 5 , the reconciliation operation execution module 320 , the reconciliation data missing judgment module 330 and the information sending module 340 ). The processor 410 executes various functional applications and data processing of the computer device by running the software programs, instructions and modules stored in the memory 420, that is, a data reconciliation method of the above method embodiment is implemented, namely:

根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据;Obtain corresponding reconciliation data from at least two data sources according to the received data change message;

根据所述对账数据进行对账操作;perform a reconciliation operation according to the reconciliation data;

若对账结果为对账不平,判断所述对账数据是否存在缺失;If the reconciliation result is that the reconciliation is uneven, determine whether the reconciliation data is missing;

根据所述对账数据的缺失情况,发送对账结果信息。According to the lack of the reconciliation data, the reconciliation result information is sent.

存储器420可以包括存储程序区和存储数据区,其中,存储程序区可存储操作系统、至少一个功能所需要的应用程序;存储数据区可存储根据计算机设备的使用所创建的数据等。此外,存储器420可以包括高速随机存取存储器,还可以包括非暂态性存储器,例如至少一个磁盘存储器件、闪存器件、或其他非暂态性固态存储器件。在一些实施例中,存储器420可选包括相对于处理器410远程设置的存储器,这些远程存储器可以通过网络连接至终端设备。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。The memory 420 may include a storage program area and a storage data area, wherein the storage program area may store an operating system, an application program required for at least one function; the storage data area may store data created according to the use of the computer equipment, and the like. Additionally, memory 420 may include high-speed random access memory, and may also include non-transitory memory, such as at least one magnetic disk storage device, flash memory device, or other non-transitory solid-state storage device. In some embodiments, the memory 420 may optionally include memory located remotely from the processor 410, and these remote memories may be connected to the terminal device through a network. Examples of such networks include, but are not limited to, the Internet, an intranet, a local area network, a mobile communication network, and combinations thereof.

输入装置430可用于接收输入的数字或字符信息,以及产生与计算机设备的用户设置以及功能控制有关的键信号输入。输出装置440可包括显示屏等显示设备。The input device 430 may be used to receive input numerical or character information, and to generate key signal input related to user settings and function control of the computer device. The output device 440 may include a display device such as a display screen.

实施例五Embodiment 5

本发明实施例提供了一种计算机可读存储介质,其上存储有计算机程序,该程序被处理器执行时实现如本发明实施例提供的一种数据对账方法:An embodiment of the present invention provides a computer-readable storage medium on which a computer program is stored, and when the program is executed by a processor, implements a data reconciliation method as provided in the embodiment of the present invention:

根据接收到的数据变更消息,从至少两个数据源中分别获取对应的对账数据;Obtain corresponding reconciliation data from at least two data sources according to the received data change message;

根据所述对账数据进行对账操作;perform a reconciliation operation according to the reconciliation data;

若对账结果为对账不平,判断所述对账数据是否存在缺失;If the reconciliation result is that the reconciliation is uneven, determine whether the reconciliation data is missing;

根据所述对账数据的缺失情况,发送对账结果信息。According to the lack of the reconciliation data, the reconciliation result information is sent.

可以采用一个或多个计算机可读的介质的任意组合。计算机可读介质可以是计算机可读信号介质或者计算机可读存储介质。计算机可读存储介质例如可以是——但不限于——电、磁、光、电磁、红外线、或半导体的系统、装置或器件,或者任意以上的组合。计算机可读存储介质的更具体的例子(非穷举的列表)包括:具有一个或多个导线的电连接、便携式计算机磁盘、硬盘、随机存取存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑磁盘只读存储器(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。在本文件中,计算机可读存储介质可以是任何包含或存储程序的有形介质,该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。Any combination of one or more computer-readable media may be employed. The computer-readable medium may be a computer-readable signal medium or a computer-readable storage medium. The computer readable storage medium can be, for example, but not limited to, an electrical, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus or device, or a combination of any of the above. More specific examples (a non-exhaustive list) of computer readable storage media include: electrical connections having one or more wires, portable computer disks, hard disks, random access memory (RAM), read only memory (ROM), Erasable Programmable Read Only Memory (EPROM or Flash), fiber optics, portable compact disk read only memory (CD-ROM), optical storage devices, magnetic storage devices, or any suitable combination of the foregoing. In this document, a computer-readable storage medium can be any tangible medium that contains or stores a program that can be used by or in conjunction with an instruction execution system, apparatus, or device.

计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号,其中承载了计算机可读的程序代码。这种传播的数据信号可以采用多种形式,包括——但不限于——电磁信号、光信号或上述的任意合适的组合。计算机可读的信号介质还可以是计算机可读存储介质以外的任何计算机可读介质,该计算机可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。A computer-readable signal medium may include a propagated data signal in baseband or as part of a carrier wave, with computer-readable program code embodied thereon. Such propagated data signals may take a variety of forms including, but not limited to, electromagnetic signals, optical signals, or any suitable combination of the foregoing. A computer-readable signal medium can also be any computer-readable medium other than a computer-readable storage medium that can transmit, propagate, or transport the program for use by or in connection with the instruction execution system, apparatus, or device .

计算机可读介质上包含的程序代码可以用任何适当的介质传输,包括——但不限于——无线、电线、光缆、RF等等,或者上述的任意合适的组合。Program code embodied on a computer readable medium may be transmitted using any suitable medium including, but not limited to, wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.

可以以一种或多种程序设计语言或其组合来编写用于执行本发明操作的计算机程序代码,所述程序设计语言包括面向对象的程序设计语言—诸如Java、Smalltalk、C++,还包括常规的过程式程序设计语言—诸如”C”语言或类似的程序设计语言。程序代码可以完全地在用户计算机上执行、部分地在用户计算机上执行、作为一个独立的软件包执行、部分在用户计算机上部分在远程计算机上执行、或者完全在远程计算机或服务器上执行。在涉及远程计算机的情形中,远程计算机可以通过任意种类的网络——包括局域网(LAN)或广域网(WAN)—连接到用户计算机,或者,可以连接到外部计算机(例如利用因特网服务提供商来通过因特网连接)。Computer program code for carrying out operations of the present invention may be written in one or more programming languages, including object-oriented programming languages—such as Java, Smalltalk, C++, but also conventional Procedural programming language - such as "C" language or similar programming language. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer, or entirely on the remote computer or server. In the case of a remote computer, the remote computer may be connected to the user's computer through any kind of network, including a local area network (LAN) or a wide area network (WAN), or may be connected to an external computer (eg, using an Internet service provider through Internet connection).

注意,上述仅为本发明的较佳实施例及所运用技术原理。本领域技术人员会理解,本发明不限于这里所述的特定实施例,对本领域技术人员来说能够进行各种明显的变化、重新调整和替代而不会脱离本发明的保护范围。因此,虽然通过以上实施例对本发明进行了较为详细的说明,但是本发明不仅仅限于以上实施例,在不脱离本发明构思的情况下,还可以包括更多其他等效实施例,而本发明的范围由所附的权利要求范围决定。Note that the above are only preferred embodiments of the present invention and applied technical principles. Those skilled in the art will understand that the present invention is not limited to the specific embodiments described herein, and various obvious changes, readjustments and substitutions can be made by those skilled in the art without departing from the protection scope of the present invention. Therefore, although the present invention has been described in detail through the above embodiments, the present invention is not limited to the above embodiments, and can also include more other equivalent embodiments without departing from the concept of the present invention. The scope is determined by the scope of the appended claims.

Claims (10)

1. A data reconciliation method, comprising:
respectively acquiring corresponding reconciliation data from at least two data sources according to the received data change message;
performing account checking operation according to the account checking data;
if the account checking result is that the account checking is not smooth, whether the account checking data is missing or not is judged;
and sending account checking result information according to the missing condition of the account checking data.
2. The method of claim 1, wherein the sending reconciliation result information according to the missing condition of the reconciliation data comprises:
if the reconciliation data is missing, checking whether a data source corresponding to the missing reconciliation data has delay;
and if the data source corresponding to the missing reconciliation data has delay, marking the missing reconciliation data as delay data.
3. The method of claim 2, wherein checking whether a data source corresponding to the missing reconciliation data has a delay comprises:
acquiring the change time of the reconciliation data from a data source corresponding to the non-missing reconciliation data, and acquiring the synchronization time of the reconciliation data from a data source corresponding to the missing reconciliation data;
if the change time is after the synchronization time, determining that a delay exists in a data source corresponding to the missing reconciliation data;
if the change time is not after the synchronization time, determining that no delay exists in a data source corresponding to the missing reconciliation data;
wherein the change time is the time corresponding to the change of each piece of account checking data in the data source; the synchronous time is the time for synchronously backing up all data in the data source.
4. The method of claim 1, wherein the determining whether the reconciliation data is missing comprises:
judging whether the reconciliation data acquired from all the data sources meet a preset reconciliation rule or not;
if the account checking data meet a preset account checking rule, determining that the account checking data are not missing;
and if the account checking data do not meet the preset account checking rule, determining that the account checking data are missing.
5. The method of claim 3, wherein after the marking the missing reconciliation data as deferred data if there is a delay in the data source corresponding to the missing reconciliation data, further comprising:
periodically acquiring the synchronization time of the delay data from a data source corresponding to the delay data at preset time intervals;
and if the synchronization time of the delay data is after the change time, acquiring missing reconciliation data from a data source corresponding to the delay data to perform reconciliation operation.
6. A data reconciliation apparatus, comprising:
the account checking data acquisition module is used for respectively acquiring corresponding account checking data from at least two data sources according to the received data change message;
the account checking operation execution module is used for carrying out account checking operation according to the account checking data;
the account checking data missing judging module is used for judging whether the account checking data is missing or not if the account checking result is that the account checking is not smooth;
and the information sending module is used for sending the account checking non-result message according to the missing condition of the account checking data.
7. The apparatus of claim 6, wherein the information sending module comprises:
the delay checking unit is used for checking whether a data source corresponding to the missing reconciliation data has delay or not if the reconciliation data has missing;
and the delayed data marking unit is used for marking the missing reconciliation data as delayed data if the data source corresponding to the missing reconciliation data has delay.
8. The apparatus of claim 7, wherein the delay check unit comprises:
the time acquisition subunit is used for acquiring the change time of the reconciliation data from the data source corresponding to the non-missing reconciliation data and acquiring the synchronization time of the reconciliation data from the data source corresponding to the missing reconciliation data;
the delay determining subunit is configured to determine that a delay exists in a data source corresponding to the missing reconciliation data if the change time is after the synchronization time; if the change time is not after the synchronization time, determining that no delay exists in a data source corresponding to the missing reconciliation data;
wherein the change time is the time corresponding to the change of each piece of account checking data in the data source; the synchronous time is the time for synchronously backing up all data in the data source.
9. A reconciliation apparatus, comprising:
one or more processors;
a storage device for storing one or more programs,
when executed by the one or more processors, cause the one or more processors to implement a data reconciliation method as claimed in any one of claims 1-5.
10. A computer-readable storage medium, on which a computer program is stored, which program, when being executed by a processor, carries out a data reconciliation method according to any one of claims 1 to 5.
CN202010454417.0A 2020-05-26 2020-05-26 A data reconciliation method, device, equipment and storage medium Active CN111639086B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202010454417.0A CN111639086B (en) 2020-05-26 2020-05-26 A data reconciliation method, device, equipment and storage medium

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202010454417.0A CN111639086B (en) 2020-05-26 2020-05-26 A data reconciliation method, device, equipment and storage medium

Publications (2)

Publication Number Publication Date
CN111639086A true CN111639086A (en) 2020-09-08
CN111639086B CN111639086B (en) 2023-06-09

Family

ID=72329429

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202010454417.0A Active CN111639086B (en) 2020-05-26 2020-05-26 A data reconciliation method, device, equipment and storage medium

Country Status (1)

Country Link
CN (1) CN111639086B (en)

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN112734450A (en) * 2021-01-14 2021-04-30 上海尧信惠达信息科技有限公司 Double-sided accounting method and system based on online guarantee and electronic equipment
US11526491B1 (en) * 2022-02-21 2022-12-13 Clari Inc. Method and system for collecting data from data sources with commit lag to maintain data consistency in a data store

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20150081481A1 (en) * 2013-09-16 2015-03-19 International Business Machines Corporation Analytics-driven automated reconciliation of financial transactions
CN104462568A (en) * 2014-12-26 2015-03-25 山东中创软件商用中间件股份有限公司 Data reconciliation method, device and system
CN109325028A (en) * 2018-08-22 2019-02-12 平安普惠企业管理有限公司 A kind of reconciliation file verification method and terminal device
CN110458681A (en) * 2019-08-15 2019-11-15 深圳乐信软件技术有限公司 Method, device, server and storage medium for data reconciliation decision-making

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20150081481A1 (en) * 2013-09-16 2015-03-19 International Business Machines Corporation Analytics-driven automated reconciliation of financial transactions
CN104462568A (en) * 2014-12-26 2015-03-25 山东中创软件商用中间件股份有限公司 Data reconciliation method, device and system
CN109325028A (en) * 2018-08-22 2019-02-12 平安普惠企业管理有限公司 A kind of reconciliation file verification method and terminal device
CN110458681A (en) * 2019-08-15 2019-11-15 深圳乐信软件技术有限公司 Method, device, server and storage medium for data reconciliation decision-making

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN112734450A (en) * 2021-01-14 2021-04-30 上海尧信惠达信息科技有限公司 Double-sided accounting method and system based on online guarantee and electronic equipment
US11526491B1 (en) * 2022-02-21 2022-12-13 Clari Inc. Method and system for collecting data from data sources with commit lag to maintain data consistency in a data store

Also Published As

Publication number Publication date
CN111639086B (en) 2023-06-09

Similar Documents

Publication Publication Date Title
US20180165185A1 (en) Automatic testing of disaster recovery scenarios in cloud environments
US11086766B1 (en) Web services comparison tool
US9384114B2 (en) Group server performance correction via actions to server subset
CN108920257B (en) Transaction processing method, device, equipment and storage medium
US9658917B2 (en) Server performance correction using remote server actions
US20210295343A1 (en) Success rate of an online transaction
US10152400B2 (en) Method and system for dynamically unblocking customers in critical workflows by pushing community contributed solutions just-in-time when an error is encountered
US9888084B2 (en) Automatic network domain diagnostic repair and mapping
US20210294888A1 (en) Login to a suspended account
US20130124971A1 (en) Real time web script refresh using asynchronous polling without full web page reload
CN111639086B (en) A data reconciliation method, device, equipment and storage medium
WO2023284892A1 (en) Configurable data computing method and apparatus, device, and medium
CN113515510A (en) Data processing method, data processing system, electronic device and readable storage medium
CN109299124B (en) Method and apparatus for updating a model
CN112131092A (en) Page debugging method and device
CN112363935A (en) Data joint debugging method and device, electronic equipment and storage medium
CN110875832A (en) Abnormal service monitoring method, device and system and computer readable storage medium
US10027598B2 (en) Providing network resources based on available user information
US20230393965A1 (en) Method and system for an automated virtual assistant testing framework
WO2023197917A1 (en) Payment security management method and apparatus and payment system
CN114218313B (en) Data management method, device, electronic device, storage medium and product
WO2018233365A1 (en) Information query method, terminal, device and storage medium
US20140101309A1 (en) Dynamic and selective management of integration points using performance metrics
CN109743232B (en) Interface detection method and device
CN114281697A (en) Method and device for generating test data

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
GR01 Patent grant
GR01 Patent grant