CN113902415A

CN113902415A - Financial data checking method and device, computer equipment and storage medium

Info

Publication number: CN113902415A
Application number: CN202111249733.5A
Authority: CN
Inventors: 李灵利; 潘忆恩; 何锦添; 郑友金
Original assignee: Industrial and Commercial Bank of China Ltd ICBC
Current assignee: Industrial and Commercial Bank of China Ltd ICBC
Priority date: 2021-10-26
Filing date: 2021-10-26
Publication date: 2022-01-07

Abstract

The application relates to a financial data checking method, a financial data checking device, a computer device and a storage medium. The method comprises the following steps: acquiring service processing instruction data of a first link node; the service processing instruction data has a corresponding service processing identifier; determining a service scene type corresponding to the service processing instruction data, and calling a data acquisition service corresponding to the service scene type; the data acquisition service is used for acquiring financial data to be checked corresponding to the service processing identifier in a second link node corresponding to the service scene type; the second link node and the first link node belong to the same service processing link, and the second link node is a downstream node of the first link node; receiving financial data to be checked returned by the data acquisition service; and performing consistency check on the financial data in the business processing instruction data and the financial data to be checked to obtain a check result. By adopting the method, the timeliness of the financial data checking result can be improved.

Description

Financial data checking method and device, computer equipment and storage medium

Technical Field

The present application relates to the field of data processing technologies, and in particular, to a financial data checking method, apparatus, computer device, and storage medium.

Background

The data processing is through various fields of social production and social life, and is widely applied to various enterprises and public institutions, a financial institution such as a bank needs to process thousands of financial data every day, the financial data processing of each financial data needs to be cooperated with different platform systems on a transaction link, the financial data on any one platform system is abnormal, the problem of abnormal transaction is possibly caused, and the financial data of different platform systems need to be checked in order to reduce the problem of abnormal transaction.

However, in the conventional technology, a bank adopts a day-end data processing method, financial data of all days are checked one by one at a fixed time, so that all financial data checking results of the day are obtained, and if the financial data are abnormal, a user can only find and process the data every other day, so that the problem that financial transaction accidents are easily caused due to poor timeliness of the financial data checking results is caused.

Therefore, the conventional technology has the problem that the timeliness of the financial data checking result is poor.

Disclosure of Invention

In view of the above, it is necessary to provide a financial data collation method, apparatus, computer device and storage medium capable of improving timeliness of a result of financial data collation.

In a first aspect, the present application provides a financial data reconciliation method. The method comprises the following steps:

acquiring service processing instruction data of a first link node; the service processing instruction data has a corresponding service processing identifier;

determining a service scene type corresponding to the service processing instruction data, and calling a data acquisition service corresponding to the service scene type; the data acquisition service is used for acquiring financial data to be checked corresponding to the service processing identifier in a second link node corresponding to the service scene type; the second link node and the first link node belong to the same service processing link, and the second link node is a downstream node of the first link node;

receiving the financial data to be checked returned by the data acquisition service;

and performing consistency check on the financial data in the business processing instruction data and the financial data to be checked to obtain a check result.

In one embodiment, after the step of obtaining the service processing instruction data of the first link node, the method further includes:

acquiring a white list area identification table;

if the area identification in the business processing instruction data is in the white list area identification table, extracting the business processing instruction data to a task queue;

and returning to the step of determining the service scene type corresponding to the service processing instruction data and calling the data acquisition service corresponding to the service scene type.

In one embodiment, if the area identifier in the service processing instruction data is not in the white list area identifier table, the method further includes:

acquiring a white list user identification table;

if the user identification in the business processing instruction data is in the white list user identification table, extracting the business processing instruction data to a task queue;

executing the step of determining the service scene type corresponding to the service processing instruction data and calling the data acquisition service corresponding to the service scene type;

and if the user identification in the service processing instruction data is not in the white list user identification table, reducing the checking priority level of the service processing instruction data.

In one embodiment, the obtaining the service processing instruction data of the first link node includes:

reading data acquisition parameters; the data acquisition parameters are set according to the total data volume of the service processing instruction data in the first link node;

determining data acquisition conditions according to the data acquisition parameters; the data acquisition conditions comprise preset data acquisition quantity and preset data acquisition frequency;

and acquiring the service processing instruction data of the preset data acquisition quantity in the first link node according to the preset data acquisition frequency.

In one embodiment, before the step of performing consistency check on the financial data in the business processing instruction data and the financial data to be checked to obtain a check result, the method further includes:

analyzing the business processing instruction data to obtain a data field name of the business processing instruction data, and analyzing the financial data to be checked to obtain a data field name of the financial data to be checked;

acquiring a field name mapping table; the field name mapping table comprises the corresponding relation between all data field names and standard field names in the service processing link;

searching a standard field name corresponding to the data field name of the service processing instruction data in the field name mapping table, and replacing the data field name with the standard field name;

and/or the presence of a gas in the gas,

and searching a standard field name corresponding to the data field name of the financial data to be checked in the field name mapping table, and replacing the data field name with the data standard field name.

In one embodiment, the consistency check of the financial data in the business processing instruction data and the financial data to be checked to obtain a check result includes:

determining the key element standard field name in the standard field name based on a key element comparison rule;

acquiring a first field value corresponding to the key element standard field name in financial data in the business processing instruction data, and a second field value corresponding to the key element standard field name in the financial data to be checked;

and carrying out consistency check on the first field value and the second field value to obtain the check result.

if the financial data to be checked returned by the data acquisition service is not received within the preset receiving time, executing the step of calling the data acquisition service corresponding to the service scene type, and recording the repeated execution times;

if the repeated execution times are larger than a preset execution time threshold value, the financial data to be checked returned by the data acquisition service is not received within the preset receiving time, and an alarm prompt is sent; the alert prompt is used to notify a human intervention.

In a second aspect, the present application further provides a financial data reconciliation apparatus. The device comprises:

the data acquisition module is used for acquiring the service processing instruction data of the first link node; the service processing instruction data has a corresponding service processing identifier;

a scene type determining module, configured to determine a service scene type corresponding to the service processing instruction data, and invoke a data acquisition service corresponding to the service scene type; the data acquisition service is used for acquiring financial data to be checked corresponding to the service processing identifier in a second link node corresponding to the service scene type; the second link node and the first link node belong to the same service processing link, and the second link node is a downstream node of the first link node;

the data receiving module is used for receiving the financial data to be checked returned by the data acquisition service;

and the data checking module is used for performing consistency checking on the financial data in the business processing instruction data and the financial data to be checked to obtain a checking result.

In a third aspect, the present application also provides a computer device. The computer device comprises a memory storing a computer program and a processor implementing the steps of the method described above when executing the computer program.

In a fourth aspect, the present application further provides a computer-readable storage medium. The computer-readable storage medium, on which a computer program is stored which, when being executed by a processor, carries out the steps of the method described above.

The financial data checking method, the financial data checking device, the computer equipment and the storage medium acquire the service processing instruction data of the first link node; the service processing instruction data has a corresponding service processing identifier; then, determining a service scene type corresponding to the service processing instruction data, and calling a data acquisition service corresponding to the service scene type; the data acquisition service is used for acquiring financial data to be checked corresponding to the service processing identifier in a second link node corresponding to the service scene type; the second link node and the first link node belong to the same service processing link, and the second link node is a downstream node of the first link node; then, receiving financial data to be checked returned by the data acquisition service; finally, performing consistency check on the financial data in the business processing instruction data and the financial data to be checked to obtain a check result; therefore, the financial data to be checked which needs to be checked with the financial data in the first link node can be timely acquired by calling the data acquisition service, and the financial data to be checked is positioned in a second link node in the same service processing link with the first link node; therefore, the consistency of the financial data of different link nodes belonging to the same service processing link can be checked, the checking results of the financial data of the service systems distributed on different link nodes can be obtained in time, the data checking of the financial data of the whole day can be carried out at the end of the day without storing a large amount of financial data on different link nodes, and the problem that the financial data of upstream and downstream service systems cannot be processed in time and are inconsistent due to the fact that the financial data checking results cannot be obtained in time is avoided; and then the timeliness of the financial data checking result is effectively improved.

Drawings

FIG. 1 is a diagram of an exemplary financial data reconciliation application environment;

FIG. 2 is a schematic flow chart diagram illustrating a financial data reconciliation method in accordance with one embodiment;

FIG. 3 is a flowchart illustrating the steps of a method for checking white list financial data according to one embodiment;

FIG. 4 is a schematic flow chart diagram illustrating a financial data reconciliation method according to another embodiment;

FIG. 5 is a general flowchart of another method of reconciling financial data in one embodiment;

FIG. 6 is a flow diagram of a method for parsing business process instruction data, according to an embodiment;

FIG. 7 is a block diagram of a financial data reconciliation apparatus in accordance with one embodiment;

FIG. 8 is a diagram illustrating an internal structure of a computer device according to an embodiment.

Detailed Description

In order to make the objects, technical solutions and advantages of the present application more apparent, the present application is described in further detail below with reference to the accompanying drawings and embodiments. It should be understood that the specific embodiments described herein are merely illustrative of the present application and are not intended to limit the present application.

The financial data checking method provided by the application can be applied to the application environment shown in FIG. 1. Wherein the local terminal 102 communicates with at least one second link node terminal 104 over a network; the local terminal 102 may be a service system terminal corresponding to the first link node, and the second link node terminal 104 may be a service system terminal corresponding to the second link node. The local terminal 102 acquires service processing instruction data of a first link node; the service processing instruction data has a corresponding service processing identifier; then, the local terminal 102 determines a service scene type corresponding to the service processing instruction data, and invokes a data acquisition service corresponding to the service scene type; the data acquisition service is used for acquiring financial data to be checked corresponding to the service processing identifier in a second link node corresponding to the service scene type; the second link node and the first link node belong to the same service processing link, and the second link node is a downstream node of the first link node; then, the local terminal 102 receives financial data to be checked returned by the data acquisition service; finally, the local terminal 102 performs consistency check on the financial data in the business processing instruction data and the financial data to be checked to obtain a check result. In practical applications, the local terminal 102 and the second link node 104 may be, but not limited to, various personal computers, notebook computers, smart phones, tablet computers, and may also be independent servers or a server cluster composed of a plurality of servers.

In one embodiment, as shown in fig. 2, there is provided a financial data checking method, which is described by taking the method as an example applied to the local terminal in fig. 1, and includes the following steps:

step S210, obtaining service processing instruction data of a first link node; the service processing instruction data has a corresponding service processing identifier.

The first link node is a master node of the service processing link and may be a service processing instruction data processing request initiating end.

The business process instruction data may include, but is not limited to, financial data, business scenario type, business process status, area identifier, user identifier, and other data information.

The service processing identifier may be, but is not limited to, a service ticket number.

In a specific implementation, in a process of responding to a service processing instruction data processing request initiated by a user, a service processing identifier uniquely corresponding to each service processing instruction data is generated, and service systems corresponding to a plurality of link nodes in the upstream and downstream are required to cooperatively process the received data processing request, so that the plurality of service systems form a service processing link. After any service system responds to the data processing request, service processing instruction data corresponding to the service processing identification is generated, namely each service system has the corresponding service processing instruction data; the business processing instruction data may include, but is not limited to, financial data, business scenario type, area identifier, user identifier, business processing status, and other data information. And the service system corresponding to the service processing instruction data processing request initiating end is used as a first link node, and other service systems participating in cooperative processing are used as downstream nodes of the first link node. Specifically, after a user initiates a service processing instruction data processing request to a first link node, a local terminal stores service processing instruction data of the first link node into a plurality of databases corresponding to the first link node according to user information corresponding to the user initiating the processing request; then, the local terminal acquires the service processing instruction data in the multiple databases corresponding to the first link node according to the preset data acquisition condition. In a specific implementation process, the local terminal can call a plurality of timing tasks, and according to a preset data acquisition frequency and a preset data acquisition quantity, service processing instruction data in a plurality of databases corresponding to the first link node are acquired in real time in parallel, and the service processing instruction data all have corresponding service processing identifiers; the service system corresponding to the first link node may be, but is not limited to, an enterprise internet bank transfer remittance system; the business processing instruction data processing request can be but is not limited to a transfer request and a borrowing request; the service processing identifier may be a unique service ticket number corresponding to the service processing instruction data.

Step S220, determining a service scene type corresponding to the service processing instruction data, and invoking a data acquisition service corresponding to the service scene type.

The data acquisition service is used for acquiring the financial data to be checked corresponding to the service processing identifier in a second link node corresponding to the service scene type.

The second link node and the first link node belong to the same service processing link, the second link node is a downstream node of the first link node, and the number of the second link nodes may be one or more.

The service scene type can be but is not limited to same city transfer, remote transfer, same bank transfer and cross bank transfer.

In a specific implementation, after acquiring the service processing instruction data of the first link node, the local terminal performs data analysis on the service processing instruction data of the first link node, determines a service scene type of the service processing instruction data of the first link node, and invokes a data acquisition service corresponding to the service scene type. The data acquisition service is used for determining other link nodes related to the service scene type corresponding to the service processing instruction data, namely a second link node which is used as a downstream node of the first link node in the same service processing link; the data acquisition service further communicates with the second link node terminal through the acquired service processing identifier corresponding to the service processing instruction data of the first link node, and acquires financial data to be checked, which corresponds to the service processing identifier, in the second link node, that is, financial data to be checked, in the service processing instruction data of the second link node, which is generated after the second link node responds to a service processing instruction data processing request initiated by a user.

For example, when the local terminal determines that the service scene type of the service processing instruction data of the first link node is a cross-row transfer type, a cross-row transfer type data acquisition service corresponding to the cross-row transfer type is called, and financial data to be checked in the second link node is acquired based on a service processing identifier; in the cross-bank transfer service scenario type, the second link node may be a service system of a third-party financial institution and a recipient account bank involved in a process of responding to a service processing instruction data processing request initiated by a user, and the number of the second link nodes is not limited and may be one or more downstream link nodes of the first link node. Specifically, after the local terminal calls a plurality of timing tasks and obtains the service processing instruction data of the first link node in parallel, the plurality of timing tasks perform data analysis operation on the service processing instruction data in parallel, and determine each service scene type corresponding to each service processing instruction data; then inquiring each data acquisition service corresponding to each service scene type according to the corresponding relation between the service scene type recorded in the service scene type dictionary and the data acquisition service; and then, calling each data acquisition service corresponding to each service scene type in parallel, enabling each data acquisition service to communicate with a second link node terminal related to the corresponding service scene type, and acquiring financial data needing to be checked with financial data in the service processing instruction data of the first link node in the second link node based on the service processing identifier.

And step S230, receiving the financial data to be checked returned by the data acquisition service.

In the specific implementation, after acquiring the financial data to be checked of the second link node, the data acquisition service returns the financial data to be checked of the second link node to the local terminal, and the local terminal can receive the financial data to be checked of the second link node and divide the financial data to be checked returned by the data acquisition service based on different service scene types, so that the local terminal can determine the financial data to be checked corresponding to the different service scene types; the financial data to be checked may be, but is not limited to, the data of the payer account, the payer account name, the amount, the currency, the receiver account name, etc. involved in the transaction.

Step S240, performing consistency check on the financial data in the business processing instruction data and the financial data to be checked to obtain a check result.

The financial data in the transaction processing instruction data can be, but is not limited to, data of a payer account, a payer account name, an amount, a currency, a receiver account name and the like involved in the transaction.

The checking result comprises any one of the consistency of the financial data in the business processing instruction data and the financial data to be checked and the inconsistency of the financial data in the business processing instruction data and the financial data to be checked.

In specific implementation, the local terminal performs consistency check on financial data in the service processing instruction data of the first link node having the same service processing identifier and financial data to be checked of the second link node, for example, compares whether data of a receiving party account, a paying party account, a transaction amount, a transaction currency type, a transaction state and the like in the first link node and the second link node are consistent, so as to obtain a financial data check result of the first link node and the second link node; if the financial data in the business processing instruction data is inconsistent with the financial data to be checked, marking the financial data in the business processing instruction data of the first link node as not-passing check in a check result table, and sending an alarm prompt for informing manual intervention analysis and timely handling the problem of inconsistent check results; wherein, the check result table is used for recording the financial data check condition; the local terminal can call a plurality of timing tasks and carry out consistency check on the financial data in the business processing instruction data and the financial data to be checked in parallel.

In the financial data checking method, the business processing instruction data of the first link node is obtained; the service processing instruction data has a corresponding service processing identifier; then, determining a service scene type corresponding to the service processing instruction data, and calling a data acquisition service corresponding to the service scene type; the data acquisition service is used for acquiring financial data to be checked corresponding to the service processing identifier in a second link node corresponding to the service scene type; the second link node and the first link node belong to the same service processing link, and the second link node is a downstream node of the first link node; then, receiving financial data to be checked returned by the data acquisition service; finally, performing consistency check on the financial data in the business processing instruction data and the financial data to be checked to obtain a check result; therefore, the financial data to be checked which needs to be checked with the financial data in the first link node can be timely acquired by calling the data acquisition service, and the financial data to be checked is positioned in a second link node in the same service processing link with the first link node; therefore, the consistency of the financial data of different link nodes belonging to the same service processing link can be checked, the financial data checking results of the service systems distributed on different link nodes can be obtained in time, the data checking of the financial data of the whole day can be carried out at the end of the day without storing a large amount of financial data on different link nodes, and the problem that the financial data of upstream and downstream service systems cannot be processed in time and are inconsistent due to the fact that the financial data checking results cannot be obtained in time is avoided; and then the timeliness of the financial data checking result is effectively improved.

In another embodiment, after the step of obtaining the service processing instruction data of the first link node, the method further comprises: acquiring a white list area identification table; if the area identification in the business processing instruction data is in the white list area identification table, extracting the business processing instruction data to a task queue; and returning to determine the service scene type corresponding to the service processing instruction data, and calling the data acquisition service corresponding to the service scene type.

The white list area identification table comprises area identifications with high check priority.

The region identifier is used to determine a region where the user initiates the service processing instruction data processing request, and may be at least one of a country region identifier and a country region code.

The task queue is used for storing business processing instruction data of a first link node waiting for consistency check and financial data to be checked of a second link.

If the area identification in the service processing instruction data is not in the white list area identification table, acquiring a white list user identification table; if the user identification in the business processing instruction data is in the white list user identification table, extracting the business processing instruction data to a task queue; executing the step of determining the service scene type corresponding to the service processing instruction data and calling the data acquisition service corresponding to the service scene type; and if the user identification in the service processing instruction data is not in the white list user identification table, reducing the checking priority level of the service processing instruction data.

The white list user identification list comprises user identifications with high check priority.

The user identifier may be at least one of user identity information and a user account.

In particular implementations, to facilitate understanding by those skilled in the art, FIG. 3 provides a flow chart of a white list financial data reconciliation method. After the local terminal acquires the service processing instruction data of the first link node with preset data volume in the plurality of databases by calling a plurality of timing tasks, a white list region identification table is acquired by reading data acquisition parameters, wherein the white list region identification table comprises region identifications with high checking priority, namely, a processing request initiated in a region corresponding to the region identifications in the white list region identification table can preferentially check the financial data consistency; the region identifier may be at least one of a country region identifier and a country region code; then, the local terminal judges whether the area identifier in the business processing instruction data is in the white list area identifier, if the area identifier in the business processing instruction data is in the white list area identifier table, the business processing instruction data is extracted to a task queue, the step of determining the business scene type corresponding to the business processing instruction data and calling the data acquisition service corresponding to the business scene type is returned to be executed, and the checking with the financial data to be checked of the second link node is waited; if the area identification in the business processing instruction data is not in the white list area identification table, the local terminal can obtain parameters through the read data to determine a white list user identification table, wherein the white list user identification table comprises user identifications with high check priority, namely, the business processing instruction data corresponding to the user identifications in the white list user identification table can be preferentially checked for financial data consistency; the user identifier may be at least one of user identity information and a user account, such as identification information of a user identity card number, a user mobile phone number, a bank card number, a bank account, and the like; then, the local terminal judges whether the user identification in the business processing instruction data is in the white list user identification, if the user identification in the business processing instruction data is in the white list user identification table, the business processing instruction data is extracted to a task queue, the step of determining the business scene type corresponding to the business processing instruction data and calling the data acquisition service corresponding to the business scene type is returned to be executed, and the financial data to be checked with the second link node is waited to be checked; if the user identification in the service processing instruction data is not in the white list user identification table, the check priority level of the service processing instruction data is reduced, the service scene type of the service processing instruction data is not determined and processed at this time, and the next processing is waited.

According to the technical scheme of the embodiment, whether the area identification of the business processing instruction data is in the white list area identification table is judged by obtaining the white list area identification table and the white list user identification table, if the area identification of the business processing instruction data is not in the white list area identification table, whether the user identification of the business processing instruction data is in the white list user identification table is judged, if the user identification of the business processing instruction data is not in the white list user identification table, the checking priority of the business processing instruction data of which the identification is not in the white list area identification table and the white list user identification table is reduced, and the business processing instruction data of which the identification is in the white list area identification table and the white list user identification table is extracted into the task queue to perform business scene type determination processing, so that the business processing instruction data with different checking priorities can be flexibly processed.

In another embodiment, obtaining traffic processing instruction data for a first link node comprises: reading data acquisition parameters; determining data acquisition conditions according to the data acquisition parameters; the data acquisition conditions comprise preset data acquisition quantity and preset data acquisition frequency; and acquiring the service processing instruction data of the preset data acquisition quantity in the first link node according to the preset data acquisition frequency.

The data acquisition parameters are set according to the total data volume of the service processing instruction data in the first link node.

The data acquisition parameters comprise at least one of data acquisition frequency parameters, single data acquisition quantity parameters, a white list region identification table, a white list user identification table, current system time and data acquisition total quantity parameters.

In specific implementation, a data acquisition parameter may be set according to a total data volume of the service processing instruction data stored in the database corresponding to the first link node; after the local terminal reads the data acquisition parameters, the data acquisition conditions can be determined, a plurality of timing tasks are called for multiple times to acquire service processing instruction data in the first link node according to preset data acquisition frequency in the data acquisition conditions, the service processing instruction data of the preset data acquisition amount in the data acquisition conditions are acquired each time until the total data amount of the acquired service processing instruction data is the same as the data acquisition total amount parameter in the data acquisition parameters, and the data acquisition total amount parameters can be set according to the total amount of the service processing instruction data stored in the database corresponding to the first link node within the preset interval of the current system time interval; and each service processing instruction data in the database records corresponding service processing time, so that the time interval with the current system time can be determined.

For example, when there is more service processing instruction data stored in the database corresponding to the first link node, the data acquisition frequency in the data acquisition parameter may be increased, for example, the original timing task started every 20 minutes is changed to the timing task started every 10 minutes to acquire the service processing instruction data; the data acquisition quantity in the data acquisition parameters can be increased, for example, 8000 data acquisition quantities of each time of the original timing task are changed into 10000 data acquisition quantities of each time; the total amount of data acquisition can be reduced by reducing the preset time interval between the acquisition and the current system time, so that the follow-up frequent financial data consistency check processing is prevented, for example, the total amount of data acquisition is the total amount of data of the service processing instruction stored in the database corresponding to the first link node within 20 minutes of the current system time interval, and the total amount of data of the service processing instruction stored in the database corresponding to the first link node within 10 minutes of the current system time interval is changed, so that the excessive service processing instruction data is prevented from being processed, and the system performance is prevented from being reduced.

According to the technical scheme of the embodiment, data acquisition parameters are read, and data acquisition conditions are determined; acquiring service processing instruction data of a preset data acquisition amount from a first link node according to a preset data acquisition frequency; the data acquisition parameters are set according to the total data volume of the business processing instruction data in the first link node; therefore, network resources can be flexibly configured, resources are optimally distributed, and resource waste caused by too high preset data acquisition frequency and too much preset data acquisition amount when the transaction amount is too small is prevented; and the problem that when the transaction amount is too large, the financial data checking efficiency is reduced due to the fact that business processing instruction data cannot be obtained in time caused by too low preset data obtaining frequency and too little preset data obtaining amount is solved.

In another embodiment, before the step of performing consistency check on the financial data in the business processing instruction data and the financial data to be checked to obtain the check result, the method further comprises: analyzing the business processing instruction data to obtain a data field name of the business processing instruction data, and analyzing the financial data to be checked to obtain a data field name of the financial data to be checked; acquiring a field name mapping table; searching a standard field name corresponding to the data field name of the service processing instruction data in a field name mapping table, and replacing the data field name with the standard field name; and/or searching a standard field name corresponding to the data field name of the financial data to be checked in the field name mapping table, and replacing the data field name with the data standard field name.

The field name mapping table includes the corresponding relation between all data field names and standard field names in the service processing link.

In a specific implementation, the business processing instruction data and the financial data to be checked contain a large amount of data, but the local terminal does not check all the data, but only checks the financial data in the first link node and the second link node, such as account numbers of both parties of a transaction, the amount of the transaction, and the transaction state. In order to perform consistency check on the financial data in the business processing instruction data and the financial data to be checked, the local terminal needs to analyze the business processing instruction data and the financial data to be checked so as to determine a specific value of the financial detail information of the financial data in the business processing instruction data and a specific index of the financial detail information of the financial data to be checked, such as an account number of a double transaction number and a transaction amount.

The local terminal analyzes the business instruction processing instruction data and the financial data to be checked, and can respectively obtain the data field name of the business processing instruction data and the data field name of the financial data to be checked; since the field names corresponding to the service processing instruction data corresponding to the same service processing identifier in different link nodes may be different, the data field name of the data to be checked in the service processing instruction data in the second link node returned by the data acquisition service may be different from the data field name of the service processing instruction data in the first link node, and the data field names of the data to be checked returned by the data acquisition service corresponding to different service scene types may also be different, so as to facilitate checking of the financial data in the service processing instruction data of the first link node and the financial data to be checked in the second link node, the data field names of the financial data of different link nodes need to be standardized. Therefore, the local terminal needs to obtain a field name mapping table, where the field name mapping table includes the correspondence between all data field names and standard field names in the service processing link, that is, the field name mapping table stores all field names that may appear in the service processing link, and assigns field names expressing the same semantic meaning to the corresponding standard field names. The local terminal judges whether the data field name of the business processing instruction data and the data field name of the data to be checked are standard field names or not by inquiring the data field name of the business processing instruction data and the data field name of the data to be checked in the field name mapping table, and replaces the data field name of the business processing instruction data and/or the data field name of the data to be checked with the corresponding standard field name if any data field name is judged not to be the standard field name.

For example, if the data field name of the transaction Amount of the transaction processing instruction data in the first link node is "PayAmt" and the data field name of the transaction Amount of the financial data to be checked in the second link node is "Amount", and the local terminal inquires the standard field name corresponding to "PayAmt" and "Amount" in the field name mapping table is "transaminount", the data field name of the transaction processing instruction data in the first link node is "PayAmt" and the data field name of the financial data to be checked in the second link node is converted into the standard field name "transaminount".

According to the technical scheme of the embodiment, the data field name of the business processing instruction data and the data field name of the financial data to be checked are obtained by analyzing the business processing instruction data and the financial data to be checked, the standard field name corresponding to the data field name is searched in a field name mapping table, and the data field name of the business processing instruction data and/or the data field name of the financial data to be checked are/is replaced by the corresponding standard field name; thus, even if the names of the data field names with the same semantic meaning in the business processing instruction data and the financial data to be checked are different, the corresponding field values of the different data field names with the same semantic meaning in the financial data in the business processing instruction data and the corresponding field values in the financial data to be checked can be quickly determined through standard field name conversion so as to carry out consistency check; thereby improving the efficiency of performing the collation process.

In another embodiment, the consistency check of the financial data in the business processing instruction data and the financial data to be checked is performed to obtain a check result, and the check result comprises: determining the key element standard field name in the standard field name based on the key element comparison rule; acquiring a first field value corresponding to the key element standard field name in financial data in business processing instruction data, and a second field value corresponding to the key element standard field name in the financial data to be checked; and carrying out consistency check on the first field value and the second field value to obtain a check result.

The key element standard field name can be a receiver account, a payer account, a transaction amount, a receiver account name and a payer account name for transaction.

The financial data in the business processing instruction data and the financial data to be checked can be but not limited to data such as a payer account, a payer account name, an amount, a currency, a receiver account name and the like involved in the transaction.

In specific implementation, the local terminal analyzes the service instruction processing instruction data and the financial data to be checked, and can also obtain field values corresponding to the field names of the data. Because the financial data in the business processing instruction data and the financial data to be checked comprise a large amount of data, such as data of a payer account, a payer account name, an amount of money, a currency, a receiver account name and the like related to transaction, a key element comparison rule can be formulated, key financial elements in the financial data are determined, and only the financial data corresponding to the key financial elements are subjected to consistency check. The key financial elements may be a recipient account, a payer account, a transaction amount, a recipient username, and a payer username for the transaction. The local terminal determines the standard field names of the key elements in the standard field names based on the key element comparison rule, such as 'RevAcccount' (receiver account), 'PayAcccount' (payer account), 'TransAmount' (transaction amount), 'RevAccName' (receiver account name), 'PayAccName' (payer account name); determining a field value corresponding to the standard field name of the key element in the financial data in the business processing instruction data as a first field value, and determining a field value corresponding to the standard field name of the key element in the financial data to be checked as a second field value; then, the local terminal carries out consistency check on a first field value and a second field value which correspond to the same service processing identification and the standard field name of the same key element, and a check result is obtained. Specifically, the local terminal may invoke a plurality of timing tasks to perform consistency check on a first field value and a second field value in parallel, and if the first field value and the second field value are inconsistent, the inconsistent field value is marked as a non-passing check in a check result table, and an alarm prompt is sent to notify manual intervention analysis and timely handle the problem of inconsistent check results.

According to the technical scheme of the embodiment, the key element standard field name in the standard field name is determined based on the key element comparison rule; then, acquiring a first field value corresponding to the key element standard field name in financial data in the business processing instruction data, and a second field value corresponding to the key element standard field name in the financial data to be checked; finally, carrying out consistency check on the first field value and the second field value to obtain a check result; therefore, when the financial data in the business processing instruction data is checked to be consistent with the financial data to be checked, only a first field value corresponding to the key element standard field name in the financial data in the business processing instruction data and a second field value corresponding to the key element standard field name in the financial data to be checked are checked, and all financial data in the first link node and the second link node are not required to be checked, so that the financial data checking efficiency is improved, and the financial data checking result can be obtained in time; and the timeliness of the financial data checking result is improved.

In another embodiment, before the step of performing consistency check on the financial data in the business processing instruction data and the financial data to be checked to obtain the check result, the method further comprises: if the financial data to be checked returned by the data acquisition service is not received within the preset receiving time, executing the step of calling the data acquisition service corresponding to the service scene type, and recording the repeated execution times; and if the repeated execution times are larger than the preset execution time threshold value, and the financial data to be checked returned by the data acquisition service is not received within the preset receiving time, sending an alarm prompt.

Wherein the alert prompt is used to notify of the manual intervention.

The preset execution time threshold is the maximum repeated execution time.

In the specific implementation, the local terminal can preset different receiving time according to the emergency degree of different service scene types, for example, the emergency degree is higher due to the fact that account fund security of both sides is related to the service types such as transfer and network payment, and financial data to be checked needs to be received in time, so that the preset receiving time corresponding to the transfer service type can be shorter; the emergency degree of business types such as financial product purchase is low, and the preset receiving time can be long; if the data acquisition service reports errors during the acquisition work of the financial data to be checked, or the data acquisition service does not return the financial data to be checked of the second link node, or the returned financial data to be checked lacks key elements, or the local terminal cannot call the data acquisition service, so that the local terminal does not receive the complete financial data to be checked returned by the data acquisition service within the preset receiving time, the local terminal judges that the financial data to be checked is received abnormally; because the network environments and the data transmission speeds of different link nodes are different, when the data acquisition service is called in real time, the financial data to be checked of the second link node is not transmitted, so that the data acquisition service cannot acquire the complete financial data to be checked temporarily, and therefore, the local terminal also sets a retry mechanism and can call the data acquisition service for multiple times to acquire the financial data to be checked of the second link node.

When the local terminal judges that the financial data to be checked is received abnormally, the local terminal marks the service processing instruction data as data to be processed in a checking result table, waits for the next time of calling data acquisition service to acquire the financial data to be checked, and records the current system time as the processing time; then, the local terminal starts a retry mechanism, calls a data acquisition service again aiming at the business processing instruction data which is not provided with the corresponding financial data to be checked temporarily in the first link node so as to carry out the financial data acquisition work to be checked of the second link node, and simultaneously records the repeated execution times when the business processing instruction data is subjected to the financial data receiving work to be checked; if the repeated execution times is greater than the preset execution times threshold value, the local terminal still does not receive the financial data to be checked returned by the data acquisition service within the preset receiving time, the local terminal sends an alarm prompt, can send an alarm and simultaneously displays the business processing instruction data of the corresponding financial data to be checked, which is not received in the first link node, and the reason for receiving the abnormal financial data to be checked is used for notifying manual intervention analysis and timely processing the abnormal receiving condition of the financial data to be checked.

According to the technical scheme of the embodiment, if the financial data to be checked returned by the data acquisition service is not received within the preset receiving time, the step of calling the data acquisition service corresponding to the service scene type is executed, and the repeated execution times are recorded; then, if the repeated execution times are larger than a preset execution time threshold value, within a preset receiving time, the financial data to be checked returned by the data acquisition service is not received, and an alarm prompt is sent; therefore, even if the financial data to be checked returned by the data acquisition service is not received at this time, the data acquisition service can still be called again by starting a retry mechanism, the retry work of the financial data to be checked is continuously carried out until the threshold value of the preset execution times is reached, and the manual intervention is not notified until the financial data to be checked is not received when the repeated execution times is larger than the threshold value of the preset execution times; therefore, the problem of data omission during the acquisition of the financial data to be checked can be effectively reduced, and the accuracy of the acquisition work of the financial data to be checked is improved.

In another embodiment, as shown in fig. 4, there is provided a financial data checking method, which is described by taking the method as an example applied to the local terminal in fig. 1, and includes the following steps:

step S410, acquiring service processing instruction data of a first link node; the service processing instruction data has a corresponding service processing identifier.

Step S420, determining a service scene type corresponding to the service processing instruction data, and calling a data acquisition service corresponding to the service scene type; the data acquisition service is used for acquiring financial data to be checked corresponding to the service processing identifier in a second link node corresponding to the service scene type; the second link node and the first link node belong to the same service processing link, and the second link node is a downstream node of the first link node.

Step S430, receiving the financial data to be checked returned by the data acquisition service.

Step S440, parsing the business processing instruction data to obtain a data field name of the business processing instruction data, and parsing the financial data to be checked to obtain a data field name of the financial data to be checked.

Step S450, acquiring a field name mapping table; the field name mapping table includes a corresponding relationship between all data field names and standard field names in the service processing link.

Step S460, finding a standard field name corresponding to the data field name of the service processing instruction data in the field name mapping table, and replacing the data field name with the standard field name; and/or searching a standard field name corresponding to the data field name of the financial data to be checked in the field name mapping table, and replacing the data field name with the data standard field name.

Step S470, determining the key element standard field name in the standard field names based on the key element comparison rule.

Step S480, acquiring a first field value corresponding to the key element standard field name in the financial data in the business processing instruction data, and a second field value corresponding to the key element standard field name in the financial data to be checked.

Step S490, performing consistency check on the first field value and the second field value to obtain a check result.

The specific limitations of the above steps can be referred to the above specific limitations of a financial data checking method, and are not described herein again.

It should be understood that although the steps in the flowcharts of fig. 2 and 4 are shown in order as indicated by the arrows, the steps are not necessarily performed in order as indicated by the arrows. The steps are not performed in the exact order shown and described, and may be performed in other orders, unless explicitly stated otherwise. Moreover, at least some of the steps in fig. 2 and 4 may include multiple steps or multiple stages, which are not necessarily performed at the same time, but may be performed at different times, which are not necessarily performed in sequence, but may be performed in turn or alternately with other steps or at least some of the other steps.

To facilitate understanding by those skilled in the art, FIG. 5 provides a general flow chart of a financial data reconciliation method in another embodiment. The business system corresponding to the first link node can be an enterprise internet banking system, and the enterprise internet banking system server registers and stores the business processing instruction data of the first link node into a plurality of databases corresponding to the first link node according to the user information corresponding to the user initiating the business processing instruction data processing request; then, the enterprise internet bank system server can call a plurality of timing tasks to parallelly scan and acquire the service processing instruction data of the first link node stored in the corresponding database according to the preset data acquisition condition; then, the plurality of timing tasks respectively analyze the business processing instruction data in parallel, a business scene type corresponding to the business processing instruction data is determined, a data acquisition service corresponding to the business scene type is called, and the data acquisition service acquires financial data to be checked corresponding to a business processing identifier corresponding to the business processing instruction data on a business system corresponding to a second link node; the second link node and the first link node belong to the same service processing link, and the second link node is a downstream node of the first link node; then, the enterprise online banking system server receives the financial data to be checked returned by the data acquisition service, and performs consistency check on the financial data in the business processing instruction data and the financial data to be checked; if the financial data check results are consistent, ending the check work; if the financial data check result is inconsistent, sending an alarm to inform manual intervention analysis; if the financial data to be checked is received abnormally, a retry mechanism is started, the data acquisition service is called again, if the repeated execution times are larger than a preset execution time threshold value, the financial data to be checked returned by the data acquisition service is still not received, an alarm is sent, and manual intervention analysis is notified.

To facilitate understanding by those skilled in the art, fig. 6 provides a flow chart of a business process instruction data parsing method in one embodiment. After calling a plurality of timing tasks to acquire service processing instruction data of a first link node, a local terminal analyzes the service processing instruction data of the first link node in parallel through the plurality of timing tasks and determines service scene type parameter conditions corresponding to each service processing instruction data, such as condition1, condition2 and condition3 … condition n; then the local terminal calls a data acquisition service corresponding to the condition of the service scene type parameter, if the service scene type is condition1, the data acquisition service corresponding to condition1 is called 1, then the data acquisition service communicates with the second link node terminal, the key check element field name is determined in the financial data to be checked of the second link node corresponding to the service scene type parameter, the value of the key check element field corresponding to the service processing identifier and the key check element field name is obtained, and the dynamic parameter dataDetails is returned to the local terminal; the dynamic parameters comprise condition of each service scene type parameter, each data acquisition service corresponding to each service scene type parameter, and financial data cheackData to be checked acquired by each data acquisition service; then, the local terminal segments the dynamic parameter dataDetails and determines a field value to be checked corresponding to each service scene type parameter; the field names corresponding to the field values to be checked returned by different data acquisition service platforms may be different, and the number of the returned fields to be checked may also be different; then, the local terminal checks field values with the same service processing identification and the same key checking element field name in the first link node and the second link node in parallel through a plurality of timing tasks; if the check result is inconsistent, registering the inconsistent financial data as the check result which is not passed in the check result table, and sending an alarm to inform manual intervention analysis; if the field value receiving abnormity problem of the to-be-checked is generated, marking the business processing instruction data as to-be-processed data in a checking result table, waiting for the next time of calling data acquisition service to acquire the financial data to be checked, recording the current system time as the processing time, then starting a retry mechanism, and recording the repeated execution times; and if the repeated execution times are larger than the preset execution time threshold value, the local terminal still does not receive the financial data to be checked returned by the data acquisition service within the preset receiving time, and the local terminal sends an alarm to inform manual intervention analysis.

Based on the same inventive concept, the embodiment of the application also provides a financial data checking device for realizing the financial data checking method. The solution to the problem provided by the apparatus is similar to the solution described in the above method, so the specific limitations in one or more embodiments of the financial data checking apparatus provided below may refer to the limitations of the above financial data checking method, and are not described herein again.

In one embodiment, as shown in fig. 7, there is provided a financial data collation apparatus comprising: a data acquisition module 710, a scene type determination module 720, a data reception module 730, and a data collation module 740, wherein:

a data obtaining module 710, configured to obtain service processing instruction data of a first link node; the service processing instruction data has a corresponding service processing identifier.

A scene type determining module 720, configured to determine a service scene type corresponding to the service processing instruction data, and invoke a data obtaining service corresponding to the service scene type; the data acquisition service is used for acquiring financial data to be checked corresponding to the service processing identifier in a second link node corresponding to the service scene type; the second link node and the first link node belong to the same service processing link, and the second link node is a downstream node of the first link node.

A data receiving module 730, configured to receive the financial data to be checked returned by the data obtaining service.

And the data checking module 740 is configured to perform consistency checking on the financial data in the business processing instruction data and the financial data to be checked to obtain a checking result.

In one embodiment, the financial data checking apparatus further comprises: the area identification table acquisition module is used for acquiring a white list area identification table; the data extraction module is used for extracting the business processing instruction data to a task queue if the area identifier in the business processing instruction data is in the white list area identifier table; and the scene type determining module is used for determining the service scene type corresponding to the service processing instruction data and calling the data acquisition service corresponding to the service scene type.

In one embodiment, if the area identifier in the business process instruction data is not in the white list area identifier table, the financial data checking apparatus further includes: the user identification table acquisition module is used for acquiring a white list user identification table; the data extraction module is used for extracting the business processing instruction data to a task queue if the user identification in the business processing instruction data is in the white list user identification table; a scene type determining module, configured to determine a service scene type corresponding to the service processing instruction data, and invoke a data acquisition service corresponding to the service scene type; and the priority reduction module is used for reducing the check priority level of the business processing instruction data if the user identifier in the business processing instruction data is not in the white list user identifier table.

In one embodiment, the data obtaining module 710 is specifically configured to read data obtaining parameters; the data acquisition parameters are set according to the total data volume of the service processing instruction data in the first link node; determining data acquisition conditions according to the data acquisition parameters; the data acquisition conditions comprise preset data acquisition quantity and preset data acquisition frequency; and acquiring the service processing instruction data of the preset data acquisition quantity in the first link node according to the preset data acquisition frequency.

In one embodiment, the financial data checking apparatus further comprises: the data analysis module is used for analyzing the business processing instruction data to obtain a data field name of the business processing instruction data and analyzing the financial data to be checked to obtain a data field name of the financial data to be checked; the mapping table acquisition module is used for acquiring a field name mapping table; the field name mapping table comprises the corresponding relation between all data field names and standard field names in the service processing link; a field name replacement module, configured to search the field name mapping table for a standard field name corresponding to a data field name of the service processing instruction data, and replace the data field name with the standard field name; and/or searching a standard field name corresponding to the data field name of the financial data to be checked in the field name mapping table, and replacing the data field name with the data standard field name.

In one embodiment, the data checking module 740 is specifically configured to determine a key element standard field name in the standard field names based on a key element comparison rule; acquiring a first field value corresponding to the key element standard field name in financial data in the business processing instruction data, and a second field value corresponding to the key element standard field name in the financial data to be checked; and carrying out consistency check on the first field value and the second field value to obtain the check result.

In one embodiment, the financial data checking apparatus further includes an obtaining service invoking module, configured to execute the step of invoking the data obtaining service corresponding to the service scenario type if the financial data to be checked returned by the data obtaining service is not received within a preset receiving time, and record a number of times of repeated execution; the alarm module is used for sending an alarm prompt if the financial data to be checked returned by the data acquisition service is not received within the preset receiving time when the repeated execution times are larger than a preset execution time threshold value; the alert prompt is used to notify a human intervention.

For the specific definition of a financial data checking device, reference may be made to the above definition of a financial data checking method, which is not described herein again. The modules in the financial data checking device can be wholly or partially realized by software, hardware and a combination thereof. The modules can be embedded in a hardware form or independent from a processor in the computer device, and can also be stored in a memory in the computer device in a software form, so that the processor can call and execute operations corresponding to the modules.

In one embodiment, a computer device is provided, which may be a server, and its internal structure diagram may be as shown in fig. 8. The computer device includes a processor, a memory, and a network interface connected by a system bus. Wherein the processor of the computer device is configured to provide computing and control capabilities. The memory of the computer device comprises a nonvolatile storage medium and an internal memory. The non-volatile storage medium stores an operating system, a computer program, and a database. The internal memory provides an environment for the operation of an operating system and computer programs in the non-volatile storage medium. The database of the computer device is for storing financial data reconciliation data. The network interface of the computer device is used for communicating with an external terminal through a network connection. The computer program is executed by a processor to implement a financial data reconciliation method.

Those skilled in the art will appreciate that the architecture shown in fig. 8 is merely a block diagram of some of the structures associated with the disclosed aspects and is not intended to limit the computing devices to which the disclosed aspects apply, as particular computing devices may include more or less components than those shown, or may combine certain components, or have a different arrangement of components.

In one embodiment, a computer device is provided, comprising a memory and a processor, the memory storing a computer program which, when executed by the processor, causes the processor to perform the steps of one of the financial data reconciliation described above. Here, the step of a financial data collation may be a step in a financial data collation method of the above embodiments.

In one embodiment, a computer readable storage medium is provided, storing a computer program that, when executed by a processor, causes the processor to perform the steps of a financial data reconciliation method as described above. Here, the steps of a financial data checking method may be the steps of a financial data checking method according to the above embodiments.

It should be noted that, the user information (including but not limited to user device information, user personal information, etc.) and data (including but not limited to data for analysis, stored data, presented data, etc.) referred to in the present application are information and data authorized by the user or sufficiently authorized by each party.

It will be understood by those skilled in the art that all or part of the processes of the methods of the embodiments described above can be implemented by hardware instructions of a computer program, which can be stored in a non-volatile computer-readable storage medium, and when executed, can include the processes of the embodiments of the methods described above. Any reference to memory, database, or other medium used in the embodiments provided herein may include at least one of non-volatile and volatile memory. The nonvolatile Memory may include Read-Only Memory (ROM), magnetic tape, floppy disk, flash Memory, optical Memory, high-density embedded nonvolatile Memory, resistive Random Access Memory (ReRAM), Magnetic Random Access Memory (MRAM), Ferroelectric Random Access Memory (FRAM), Phase Change Memory (PCM), graphene Memory, and the like. Volatile Memory can include Random Access Memory (RAM), external cache Memory, and the like. By way of illustration and not limitation, RAM can take many forms, such as Static Random Access Memory (SRAM) or Dynamic Random Access Memory (DRAM), among others. The databases referred to in various embodiments provided herein may include at least one of relational and non-relational databases. The non-relational database may include, but is not limited to, a block chain based distributed database, and the like. The processors referred to in the embodiments provided herein may be general purpose processors, central processing units, graphics processors, digital signal processors, programmable logic devices, quantum computing based data processing logic devices, etc., without limitation.

The technical features of the above embodiments can be arbitrarily combined, and for the sake of brevity, all possible combinations of the technical features in the above embodiments are not described, but should be considered as the scope of the present specification as long as there is no contradiction between the combinations of the technical features.

The above-mentioned embodiments only express several embodiments of the present application, and the description thereof is more specific and detailed, but not construed as limiting the scope of the invention. It should be noted that, for a person skilled in the art, several variations and modifications can be made without departing from the concept of the present application, which falls within the scope of protection of the present application. Therefore, the protection scope of the present patent shall be subject to the appended claims.

Claims

1. A financial data reconciliation method comprising:

2. The method of claim 1, wherein after the step of obtaining traffic handling instruction data for the first link node, the method further comprises:

acquiring a white list area identification table;

3. The method according to claim 2, wherein if the area identifier in the service processing instruction data is not in the white list area identifier table, the method further comprises:

acquiring a white list user identification table;

4. The method of claim 1, wherein obtaining traffic processing instruction data for the first link node comprises:

5. The method according to claim 1, wherein before the step of checking the consistency between the financial data in the business process instruction data and the financial data to be checked, the method further comprises:

and/or the presence of a gas in the gas,

6. The method according to claim 5, wherein the consistency check of the financial data in the business processing instruction data and the financial data to be checked is performed to obtain a check result, and the check result comprises:

7. The method according to claim 1, wherein before the step of checking the consistency between the financial data in the business processing instruction data and the financial data to be checked, the method further comprises:

8. An apparatus for reconciling financial data, the apparatus comprising:

9. A computer device comprising a memory and a processor, the memory storing a computer program, characterized in that the processor, when executing the computer program, implements the steps of the method of any of claims 1 to 7.

10. A computer-readable storage medium, on which a computer program is stored, which, when being executed by a processor, carries out the steps of the method of any one of claims 1 to 7.