Disclosure of Invention
Therefore, the embodiment of the invention provides a checking method and a checking device for inventory data, which can improve the checking efficiency and accuracy of the inventory data and reduce the labor cost.
To achieve the above object, according to a first aspect of an embodiment of the present invention, there is provided a collation method of inventory data, including:
Responding to a received data checking request, and acquiring inventory data of a plurality of systems corresponding to the data checking request;
Determining a reconciliation policy for inventory data applicable to the plurality of systems, the reconciliation policy comprising a reconciliation node responsibility chain;
and checking the inventory data of the systems according to the check node responsibility chain to obtain a check result.
Optionally, the checking node responsibility chain comprises a plurality of checking nodes, and checking the inventory data of the systems according to the checking node responsibility chain comprises the following steps:
checking inventory data of the plurality of systems using a first check node;
When the stock data of the systems are inconsistent, identifying backlog data from the systems by using a second check node, merging the backlog data of each system and the stock data into first correction data, and checking the first correction data of the systems;
when the plurality of first correction data are inconsistent, the third collation node is used to identify system error data from the plurality of systems, and the second correction data are determined according to the system error data and the first correction data of each system, and the second correction data of the plurality of systems are collated.
Optionally, the system error data is generated by different system errors, the check node liability chain includes a plurality of check nodes for identifying the system error data generated by different system errors, the method further includes:
In response to detecting that the systematic error has been repaired, determining a repaired target systematic error;
and removing the target check node corresponding to the target system error from the check node responsibility chain.
Optionally, in a case where the collation results indicate that inventory data of the plurality of systems is inconsistent, the method further comprises:
determining a cause of inconsistent inventory data for the plurality of systems, and generating an inventory data processing plan according to the cause;
repairing the inventory data of the systems according to the inventory data processing plan, so that the repaired inventory data are consistent.
Optionally, before checking the inventory data of the plurality of systems according to the check node responsibility chain, the method further comprises, in response to receiving an extension programming request, displaying a corresponding custom extension programming specification;
Checking the inventory data of the systems according to the check node responsibility chain comprises checking the inventory data of the systems by using the check node responsibility chain included by the self-defined check strategy.
Optionally, acquiring inventory data of a plurality of systems corresponding to the data checking request, wherein the inventory data comprises an inventory checking time point corresponding to the data checking request and a time anchor point of each system;
After reconciling inventory data for the plurality of systems in accordance with the reconciliation node responsibility chain, the method further comprises updating the time anchor for each of the systems with the inventory reconciliation time point.
Optionally, acquiring inventory data of a plurality of systems corresponding to the data verification request includes:
Determining a plurality of systems and target data sources corresponding to the data check request;
Judging whether default data sources of the systems are identical to the target data sources or not;
acquiring inventory data from default data sources of the plurality of systems under the condition that the default data sources are the same as the target data sources;
And switching the default data source to the target data source under the condition that the default data source is different from the target data source, and acquiring inventory data from the target data sources of the systems.
According to a second aspect of the embodiment of the present invention, there is provided a collation apparatus for inventory data, comprising:
The acquisition module is used for responding to the received data checking request and acquiring inventory data of a plurality of systems corresponding to the data checking request;
A determining module for determining a reconciliation policy for inventory data applicable to the plurality of systems, the reconciliation policy comprising a reconciliation node responsibility chain;
And the checking module is used for checking the inventory data of the systems according to the checking node responsibility chain to obtain a checking result.
Optionally, the checking node responsibility chain comprises a plurality of checking nodes, and checking the inventory data of the systems according to the checking node responsibility chain comprises the following steps:
checking inventory data of the plurality of systems using a first check node;
When the stock data of the systems are inconsistent, identifying backlog data from the systems by using a second check node, merging the backlog data of each system and the stock data into first correction data, and checking the first correction data of the systems;
when the plurality of first correction data are inconsistent, the third collation node is used to identify system error data from the plurality of systems, and the second correction data are determined according to the system error data and the first correction data of each system, and the second correction data of the plurality of systems are collated.
Optionally, the system error data is generated by different system errors, the check node liability chain includes a plurality of check nodes for identifying the system error data generated by different system errors, the apparatus further includes:
the searching module is used for determining the repaired target system error in response to detecting that the system error is repaired;
and the removing module is used for removing the target check node corresponding to the target system error from the check node responsibility chain.
Optionally, the apparatus further comprises:
the generation module is used for determining the reasons for the inconsistency of the inventory data of the systems and generating an inventory data processing plan according to the reasons;
And the repair module is used for repairing the inventory data of the systems according to the inventory data processing plan so that the repaired inventory data are consistent.
Optionally, the device further comprises a display module, a packaging module, a verification module and a verification module, wherein the display module is used for displaying corresponding custom extension programming specifications in response to receiving an extension programming request;
Checking the inventory data of the systems according to the check node responsibility chain comprises checking the inventory data of the systems by using the check node responsibility chain included by the self-defined check strategy.
Optionally, acquiring inventory data of a plurality of systems corresponding to the data checking request, wherein the inventory data comprises an inventory checking time point corresponding to the data checking request and a time anchor point of each system;
the device also comprises an updating module for updating the time anchor point of each system by using the stock check time point.
Optionally, acquiring inventory data of a plurality of systems corresponding to the data verification request includes:
Determining a plurality of systems and target data sources corresponding to the data check request;
Judging whether default data sources of the systems are identical to the target data sources or not;
acquiring inventory data from default data sources of the plurality of systems under the condition that the default data sources are the same as the target data sources;
And switching the default data source to the target data source under the condition that the default data source is different from the target data source, and acquiring inventory data from the target data sources of the systems.
According to a third aspect of an embodiment of the present invention, there is provided an electronic apparatus including:
one or more processors;
Storage means for storing one or more programs,
The one or more processors implement the method of any of the embodiments described above when the one or more programs are executed by the one or more processors.
According to a fourth aspect of embodiments of the present invention, there is provided a computer readable medium having stored thereon a computer program which, when executed by a processor, implements a method according to any of the embodiments described above.
The embodiment of the invention has the advantages that the checking efficiency and the accuracy of the inventory data of a plurality of systems can be improved based on the checking strategy and the checking node responsibility chain, the labor cost is reduced, the plurality of checking nodes of the checking node responsibility chain are used for calculating and checking the inventory data, the flexibility of data checking can be improved, different data checking requirements are met, the corresponding target checking nodes are removed from the checking node responsibility chain under the condition that system errors are repaired, the data checking efficiency can be improved, the data checking flow is simplified, an inventory data processing plan is generated according to the reasons of inconsistent inventory data, the inventory data is repaired according to the inventory data processing plan, the automatic data repairing efficiency is improved, the labor cost is reduced, the user is provided with a custom extension programming specification, the user-written custom extension interface is received, the flexibility and the expandability of data checking are further improved according to the custom extension interface, the data checking time point and the time anchor point are determined according to the inventory data, the data needing to be reduced, the data checking efficiency is improved, the data checking environment is improved, the system checking environment is not switched, the system is switched to the default system is not included, the system checking environment is not included, and the system is not default, the system checking environment is not ensured, and the system environment is not default is accurate, and the system checking environment is not ensured.
Further effects of the above-described non-conventional alternatives are described below in connection with the embodiments.
Detailed Description
Exemplary embodiments of the present invention will now be described with reference to the accompanying drawings, in which various details of the embodiments of the present invention are included to facilitate understanding, and are to be considered merely exemplary. Accordingly, those of ordinary skill in the art will recognize that various changes and modifications of the embodiments described herein can be made without departing from the scope and spirit of the invention. Also, descriptions of well-known functions and constructions are omitted in the following description for clarity and conciseness.
In the technical scheme of the invention, the related processes of collecting, using, storing, sharing, transferring and the like of the personal information of the user accord with the regulations of related laws and regulations, the user needs to be informed and obtain the consent or the authorization of the user, and when the personal information of the user is applicable, the technical processes of de-identification and/or anonymization and/or encryption are performed on the personal information of the user.
Data consistency needs to be ensured between different systems, for example, a warehouse operation system and a merchant management system respectively have a set of inventory data, and the inventory data of the two systems should be kept consistent so as to avoid merchant loss or consumer complaints caused by commodity overstock. At present, each system can only ensure the data consistency in the system, the data consistency among a plurality of systems is mainly realized by a manual checking mode, for example, a data manager respectively checks, records and checks inventory data under a plurality of systems, if the inventory data are inconsistent, a work order is sent to a data maintainer, and the data maintainer processes the inconsistent inventory data according to the work order.
The manual checking of the data of a plurality of systems causes the consumption of a great deal of labor cost, the data checking efficiency is low, the manual checking is easy to generate the condition of erroneous judgment or misjudgment, and the accuracy of the data checking is reduced; each system can be used for various system environments, the prior art can not switch the system environments of the system, so that historical data in other system environments are difficult to inquire, manual checking is not timeliness, data inconsistency can not be found in time, and merchant loss is easy to cause or consumer complaints are easy to increase.
In view of this, according to a first aspect of an embodiment of the present invention, there is provided a collation method of inventory data.
Fig. 1 is a schematic diagram of the main flow of a checking method of inventory data according to an embodiment of the present invention. As shown in fig. 1, the checking method of inventory data according to the embodiment of the present invention mainly includes the following steps S101 to S103.
Step S101, in response to receiving a data collation request, acquiring inventory data of a plurality of systems corresponding to the data collation request.
The execution body of the embodiment of the invention analyzes the received data checking request and acquires corresponding inventory data according to the parameters carried by the data checking request. The inventory data is inventory data of the commodities, different commodities correspond to different inventory data, and the inventory data comprises commodity names, commodity numbers, stored warehouses, stored shelves, storage time and the like. The inventory data can be applied to various business fields, such as warehouse logistics, e-commerce platform, commodity information management and the like, and thus, there are various systems for storing inventory data, such as warehouse systems, e-commerce systems and information management systems.
Illustratively, the execution body according to the embodiment of the present invention analyzes the data verification request to obtain the commodity name A1, and determines that the inventory data of the commodity name A1 is stored in the system B1, the system B2 and the system B3 according to the preset association table, and then obtains the inventory data corresponding to the commodity name A1 from the system B1, the system B2 and the system B3, to obtain the inventory data C1, the inventory data C2 and the inventory data C3.
Further illustratively, the execution subject of the embodiment of the present invention analyzes the data verification request to obtain the system B4 and the system B5, and determines, according to the preset association table, that the system B4 and the system B5 both store the inventory data of the commodity name A2, that is, whether there is data consistency between the system B4 and the system B5 that depends on the inventory data of the commodity name A2 stored in the two systems, so that the inventory data C4 of the commodity name A2 is obtained from the system B4, and the inventory data C5 of the commodity name A2 is obtained from the system B5.
According to the correlation table between commodity names and the systems, the inventory data to be checked can be rapidly determined, the data acquisition efficiency is improved, the data acquisition requirements of the same commodity among a plurality of systems can be met, the acquisition requirements of the inventory data with the same commodity name stored among a plurality of systems can also be met, and the flexibility of data acquisition is improved.
According to one embodiment of the present invention, when acquiring inventory data of a plurality of systems corresponding to a data collation request, the data collation request is parsed first to determine a plurality of systems corresponding to the data collation request and a target data source, and the plurality of systems store inventory data to be collated. Specifically, inventory data to be checked is stored in target data sources of multiple systems, each of which may have one or more data sources, e.g., the systems are deployed in different countries, each of which has different data sources, i.e., the systems of each country store different inventory data, the data sources of the systems include the data source of country D1, the data source of country D2, etc., and, further, the systems store inventory data using multiple types of data sources, e.g., the data sources suitable for embodiments of the present invention include Redis, mySQL, gu Geyun, etc., the different types of data sources store different inventory data.
After determining the plurality of systems and the target data source, determining whether the default data source for each system is the same as the target data source, e.g., each data source has a different data source code, comparing the data source code for the target data source with the data source code for the default data source for each system, and determining that the default data source is the same as the target data source if the data source codes are the same. And under the condition that the default data source is different from the target data source, switching the default data source to the target data source by using a preset data source plug-in and a custom annotation, and then acquiring inventory data from the target data source of each system.
The data verification request is parsed to determine a plurality of systems including a system E1 (the default data source is a data source F1), a system E2 (the default data source is a data source F1), and a system E3 (the default data source is a data source F2), wherein the target data source is a data source F1, inventory data is directly obtained from the default data sources of the system E1 and the system E2 without switching the data sources because the default data sources of the system F1 and the system F2 are the same as the target data sources, and because the default data sources of the system E3 are different from the target data sources, the data sources of the system E3 are required to be switched, specifically, the data source F2 of the system E3 is switched to the data source F1 by using a MyBatis Plus plug-in and a custom annotation, and then the inventory data is obtained from the data source F1 of the system E3.
By using the MyBatis Plus plug-in and the custom annotation, the dynamic switching of multiple data sources can be realized, the flexibility and the efficiency of data acquisition are improved, the data acquisition of multiple data sources and multiple system environments is realized, the system resources are saved, and the resource utilization rate and the load rate are improved.
Step S102, determining a checking strategy of inventory data applicable to the plurality of systems, wherein the checking strategy comprises checking a node responsibility chain.
The checking strategy is a checking method of the stock data of a plurality of systems, and is preset, for example, when the plurality of systems respectively store the stock data of the same commodity, the checking strategy comprises the steps of respectively comparing the stock data of the plurality of systems one by one, for example, when part of the systems respectively store the stock data of different production batches of the same commodity, summing the stock data of the part of the systems, checking the stock data with the stock data of other systems, for example, when each system has the stock data of the plurality of commodities, classifying the stock data according to the commodity names, and respectively checking the stock data of the same commodity in the different systems. Screening a checking strategy applicable to inventory data of a plurality of systems from a plurality of preset checking strategies.
Each checking strategy comprises a plurality of checking nodes, and the plurality of checking nodes of the same checking strategy form a checking node responsibility chain. Each check node is a module with a calculation function, and a plurality of check nodes are connected in series to realize a corresponding check strategy. The check node has calculation functions including data classification, data processing (such as data summation, data subtraction and the like), data check, information push and the like. The verification strategies and the application scenes have association relations, and each verification strategy is applicable to one or more application scenes, wherein the application scenes comprise a commodity warehouse-in scene, a commodity warehouse-out scene and the like.
The target policy code is determined from a plurality of preset checking policies according to the target policy code, namely, the checking policies for checking inventory data of a plurality of systems. Further exemplary, three checking strategies are preset, wherein the checking strategy G1 is used for checking the inventory data of the same commodity in the plurality of systems, the checking strategy G2 is used for checking the inventory data of the plurality of commodities in the plurality of systems, the acquired inventory data is identified, whether the acquired inventory data belongs to one commodity or a plurality of commodities is judged, the checking strategy G1 is used for checking the inventory data when the acquired inventory data belongs to one commodity, and the checking strategy G2 is used for checking the inventory data when the acquired inventory data belongs to a plurality of commodities.
The checking strategy is determined according to the inventory data of a plurality of systems, an automatic method can be provided for checking the inventory data, the labor cost is reduced, the efficiency and the accuracy of data checking are improved, and the condition of human error checking is avoided. And a plurality of checking strategies are set, so that different data checking requirements can be met, and the data checking flexibility is improved.
Step S103, checking the inventory data of the systems according to the check node responsibility chain to obtain a check result.
After determining a reconciliation policy applicable to inventory data, reconciling inventory data for a plurality of systems using a reconciliation node responsibility chain included in the reconciliation policy. Specifically, the check node responsibility chain adopts a responsibility chain mode, the inventory data of a plurality of systems is input into the first check node of the check node responsibility chain, the first check node judges whether the inventory data needs to be processed (such as data classification, data processing, data check and the like), if the inventory data needs to be processed, the first check node processes the inventory data, then the processing result and the inventory data are transmitted to the next check node as the inventory data, and if the inventory data does not need to be processed, for example, the inventory data does not meet the processing condition of the check node, the inventory data and the processing result thereof are transmitted between the check nodes along the check node responsibility chain until the last check node of the check node responsibility chain, and the execution subject of the embodiment of the invention receives the processing result of the last check node, namely the check result of the inventory data of the systems. The checking result of the inventory data of the plurality of systems includes that the inventory data of the plurality of systems are consistent, the inventory data of the plurality of systems are inconsistent, the inventory data of a part of the systems are consistent, and the like.
The checking node responsibility chain comprises three checking nodes, namely, a checking node H1, a checking node H2, a checking node H3 and the like, wherein an execution main body of the embodiment of the invention transmits the inventory data of a plurality of systems to the checking node H1, the checking node H1 classifies the inventory data of each system according to commodity names, the inventory data of each system is divided into the inventory data of a commodity J1 and the inventory data of a commodity J2, the checking node H1 transmits the classification result of the inventory data to the checking node H2, the checking node H2 checks the inventory data of the commodity J1 in the plurality of systems and then checks the inventory data of the commodity J2 in the plurality of systems to generate a checking result of the inventory data of the commodity J1 and a checking result of the inventory data of the commodity J2, the checking node H2 transmits the checking result to the checking node H3, and the checking result mail is transmitted to a user (for example, a research and development personnel, an operation and maintenance personnel, a database manager and the like) for manual checking by the user. The execution subject of the embodiment of the present invention receives the processing result of the collation node H3, that is, the collation result of the inventory data of the commodity J1 and the commodity J2 and the information of the collation result mail.
Preferably, a timing task is set, for example, the method for checking the inventory data according to the embodiment of the invention is executed at a fixed time every day, every week or every month, so as to realize automatic inventory data checking, and a user only needs to check mails, push information and short messages with inventory data checking results. And preferably, setting a stock data phase difference threshold, and sending prompt mails, short messages, station messages and the like to the user under the condition that the difference value between the stock data of the systems is larger than or equal to the stock data phase difference threshold so as to remind the user that the stock data difference is too large and the user needs to be processed in time.
The method comprises the steps of checking the inventory data of a plurality of systems based on a checking strategy and a checking node responsibility chain, improving the checking efficiency and accuracy of the inventory data, reducing the labor cost, avoiding the condition of human checking errors, setting a timing task and an inventory data phase difference threshold value, timely determining whether the inventory data are consistent or not, improving the timeliness of data checking, and enabling a user to timely repair the difference of the inventory data.
According to a referenceable embodiment of the invention, the check node responsibility chain comprises a plurality of check nodes, and the check nodes comprised by different check node responsibility chains may be partially identical or completely different. When checking the inventory data of a plurality of systems according to the check node responsibility chain, the first check node is used for checking the inventory data of the plurality of systems, namely the inventory data of the plurality of systems is directly compared, for example, the inventory data is classified according to commodity names, and the inventory data of the same commodity name in different systems is respectively compared.
And judging whether the inventory data in the systems are consistent, and if the inventory data in the systems are inconsistent, identifying backlog data from the systems by using a second check node, wherein the backlog data is the inventory data of the systems which are not recorded yet. For example, a warehouse entry bill has a plurality of commodities, after each time a commodity finishes putting on shelf, the inventory data corresponding to the commodity is input into a warehouse system, and after the plurality of commodities included in the warehouse entry bill all finish putting on shelf, the inventory data corresponding to each commodity is sequentially input into an e-commerce system, so that the commodity is put on shelf, the corresponding inventory data can be acquired in the warehouse system, and the situation that the corresponding inventory data is not acquired in the e-commerce system exists, namely, the inventory data of two systems are inconsistent for a period of time, and the inventory data in the period of time is backlog data of the e-commerce system.
And identifying backlog data of each system by using a preset identification algorithm, for example, in a warehouse-in scene, the inventory data of the system K1 is larger than the inventory data of the system K2, calculating a time difference according to the time for putting the inventory data of the system K1 on shelf and the current time, and judging that the inventory data of the system K1, which is more than the inventory data of the system K2, is the backlog data of the system K2 when the time difference is smaller than or equal to a preset time threshold value. After identifying the backlog data of each system, the second collation node adds the backlog data of each system to the corresponding inventory data to obtain first correction data, and then the second collation node collates the first correction data of the plurality of systems.
Determining whether first correction data in the plurality of systems are consistent, and if the plurality of first correction data are inconsistent, identifying system error data from the plurality of systems using a third check node, the system error data being a difference value of inventory data between different systems due to imperfect business logic (e.g., loopholes, bugs, etc.) running in the systems. The imperfect business logic includes ignoring the stock data of a certain commodity when the data is verified, the format of the stock data does not accord with the verification condition, repeatedly acquiring the stock data of a certain commodity, and the like. The third collation node judges whether or not a difference between first correction data of the plurality of systems is caused by a known systematic error, and then recognizes systematic error data of each system caused by the known systematic error using a recognition algorithm set in advance. The third collation node determines second correction data based on the system error data and the first correction data for each system, for example, in the case where the system error causes an increase in the stock data, the second correction data is obtained by subtracting the system error data from the stock data, and in the case where the system error causes a decrease in the stock data, the second correction data is obtained by adding the system error data to the stock data. The third checking node checks the second correction data of the systems to obtain the final checking result of the inventory data of the systems.
In an exemplary warehousing scene, the inventory data of the system L1 is 100, the inventory data of the system L2 is 300, the inventory data of the system L1 and the inventory data of the system L2 are checked by using a first check node, the inventory data of the two systems are judged to be inconsistent, then, whether 100 commodities are put on shelf just before 5 minutes are identified from the inventory data of the system L2 by using a second check node, and other commodities belonging to the same warehousing bill are put on shelf, therefore, 100 commodities in the inventory data of the system L2 are the backlog data of the system L1, the inventory data of the system L1 and the backlog data are summed to obtain first correction data of the system L1 as 200, the first correction data of the system L1 and the inventory data of the system L2 are checked by using a second check node, and whether the system error data is present in the inventory data of the system L2 is identified by using a third check node, the inventory data of the system L2 is repeatedly obtained, the inventory data is included in the inventory data of the system L2, and the system error is obtained by subtracting the first correction data of the system L2 from the first correction data of the system L1, and the second correction data of the system L2 is judged to be consistent, and the error data of the system L2 is subtracted from the actual correction data of the first correction data of the system L2.
The inventory data is calculated and checked by using a plurality of check nodes of the check node responsibility chain, so that the flexibility of data check can be improved, different data check requirements can be met, the efficiency and accuracy of data check can be improved, manual check errors can be avoided, and the labor cost can be reduced.
According to another referenceable embodiment of the invention, the systematic error data are generated by different systematic errors, and the check node liability chain comprises a plurality of check nodes for identifying systematic error data generated by different systematic errors, i.e. each check node is for identifying systematic error data generated by one systematic error. The method further comprises the step of, in response to detection that the system errors are repaired, determining that the repaired target system errors, for example, after a user repairs the system errors, sending repair information to an execution body of the embodiment of the invention, prompting the execution body of the embodiment of the invention that one or more system errors are repaired, that is, that the system error data generated by the repaired system errors are no longer present, so that a check node is not required to identify the repaired system errors. The repair information includes the name or code of the systematic error, and the execution subject of the embodiment of the present invention determines the corresponding target check node according to the name and code of the systematic error. And then removing the target check node corresponding to the target system error from the check node responsibility chain.
The check node responsibility chain comprises a check node M1, a check node M2 and a check node M3, wherein the check node M1 is used for identifying system error data generated by a system error N1, the check node M2 is used for identifying system error data generated by the system error N2, the check node M3 is used for identifying the system error data generated by the system error N3, the repairing information sent by a user is received, the repairing information is analyzed, and the repaired system errors comprise the system error N1 and the system error N2, so that an executive body of the embodiment removes the check node M1 and the check node M2 from the check node responsibility chain.
Under the condition that the system error is repaired, the corresponding target checking node is removed from the checking node responsibility chain, so that the data checking efficiency can be improved, the data checking flow is simplified, the checking steps of stock data are reduced, and the accuracy of data checking is improved.
According to yet another referenceable embodiment of the invention, in the event that the collation results in the inventory data of the plurality of systems being inconsistent, the method further comprises determining a cause of the inventory data of the plurality of systems being inconsistent, the cause of the inventory data of the plurality of systems being inconsistent including the presence of backlog data for the system that is not entered, the presence of system error data resulting from system errors, and so forth. And identifying the inconsistent inventory data according to a preset identification algorithm. For example, whether or not there is backlog data in the stock data is determined first, and in the case where backlog data is present, it is determined that the cause of the stock data inconsistency is non-entered backlog data, in the case where backlog data is not present, it is determined whether or not there is systematic error data due to a known systematic error, in the case where systematic error data due to a known systematic error is present, it is determined that the cause of the stock data inconsistency is due to a known systematic error, and in the case where there is no systematic error data due to a known systematic error, it is determined that the cause of the stock data inconsistency is due to an unknown systematic error.
After determining the cause of the inventory data inconsistency, an inventory data processing plan is generated from the cause, the inventory data processing plan being a method for repairing the inventory data inconsistency. For example, under the condition that stock data is inconsistent due to backlog data, a corresponding data repair mail is sent according to a preset mail address, a user is reminded to clean the backlog data in time, and the backlog data is input into the system. For another example, in the case that inventory data is inconsistent due to a known system error, an SQL (Structured Query Language ) statement of repair data is generated, the SQL statement is sent to a user, and after the user passes the audit, the execution subject of the embodiment of the invention executes the SQL statement passing the audit to repair the problem of inconsistent inventory data. For another example, under the condition that inventory data is inconsistent due to unknown system errors, a system error repair mail is sent to a user to remind the user that an unknown vulnerability exists in a system, and the user is requested to repair in time.
Illustratively, the executing body of the embodiment of the invention determines that there is a known systematic error caused by the cause of the systematic error, and the systematic error is that the inventory data of the system is not acquired, so that the executing body of the embodiment of the invention generates an SQL statement "SELECT FROM stockTable WHERE ITEMID =123" for acquiring the inventory data of the commodity coded as "123" from a database table "stockTable" storing the inventory data in the system.
According to the method, an inventory data processing plan is generated according to the reasons of inconsistent inventory data, and the inventory data is repaired according to the inventory data processing plan, so that automatic data repair can be realized, the data repair efficiency is improved, and the labor cost is reduced.
According to yet another referenceable embodiment of the invention, before reconciling inventory data of a plurality of systems in accordance with a reconciliation node responsibility chain, the method further comprises, in response to receiving the extended programming request, exposing a corresponding custom extended programming specification. For example, the user considers that the check node responsibility chain cannot recognize the systematic error data caused by a certain systematic error, so the user sends an extended programming request to the execution body of the embodiment of the present invention, and hopes to add a new check policy on the basis of the check node responsibility chain. After receiving the expansion programming request, the execution body of the embodiment of the invention displays the corresponding custom expansion programming specification to the user, so that the user can know how to write the custom expansion interface suitable for the embodiment of the invention. Specifically, different extension programming specifications can be set for different check node responsibility chains, and the extension programming specifications to be displayed can be determined according to the specification codes carried by the extension programming requests, or the same extension programming specifications can be set.
The user writes the custom expansion interface according to the expansion programming specification, and then sends the custom expansion interface to the execution main body of the embodiment of the invention. For example, whether the custom extension interface includes an interface method, a member variable, whether an interface method return value specified by the custom extension specification accords with the custom extension specification, and the like is determined, and if the custom extension interface has an interface method and a member variable necessary for the custom extension specification, and the interface method return value accords with the custom extension specification, the custom extension interface is determined to accord with the custom programming specification. And then the custom expansion interface is packaged into a custom check strategy, the packaged custom check strategy is added into the existing check strategy, or the custom check strategy is used as an independent check strategy, the custom check strategy comprises one or more custom check nodes, and the custom check nodes form a check node responsibility chain of the custom check strategy. When checking the inventory data of a plurality of systems according to the check node responsibility chain, the inventory data of the plurality of systems is checked by using the check node responsibility chain included in the self-defined check policy.
The execution body of the embodiment of the invention receives a custom expansion interface sent by a user, and the custom expansion interface comprises an interface method P1, an interface method P2 and an interface method P3, wherein the interface method P1 and the interface method P2 are interface methods specified by custom expansion standards, and return values of the interface methods meet requirements, so that the custom expansion interface is judged to meet the custom expansion standards, and the custom expansion interface is packaged into a check node responsibility chain, wherein the interface method P1, the interface method P2 and the interface method P3 are respectively used as a custom check node included in the check node responsibility chain.
The method comprises the steps of providing a custom extension programming specification for a user, receiving a custom extension interface written by the user, checking inventory data of a plurality of systems according to the custom extension interface, and further improving flexibility and expandability of data checking.
According to one embodiment of the present invention, when acquiring inventory data of a plurality of systems corresponding to a data check request, an inventory check time point corresponding to the data check request and a time anchor point of each system are determined, where the inventory check time is a time when checking the inventory data, for example, the inventory check time is a real-time when acquiring the inventory data, and the time anchor point is a time when each system last performs inventory data check, and each system has a corresponding time anchor point. And acquiring inventory data to be checked in each system according to the inventory checking time point and the time anchor point. Specifically, there is a time range between the time point of inventory verification and the time anchor point of each system, each inventory data has a generation time, and inventory data generated in the time range corresponding to each system is acquired, that is, the inventory data whose generation time is greater than the time anchor point of the system and less than or equal to the time point of inventory verification is acquired.
After reconciling the inventory data for the plurality of systems according to the reconciliation node responsibility chain, the method further comprises updating the time anchor for each system with the inventory reconciliation time point, i.e., replacing the time anchor for each system with the inventory reconciliation time point.
The system Q1 is exemplified by 1 month and 1 day, the system Q2 is exemplified by 1 month and 2 days, the system Q3 is exemplified by 1 month and 3 days, the inventory check time point is 1 month and 5 days, the inventory data generated on 1 month and 2 days to 1 month and 5 days is acquired from the system Q1, the inventory data generated on 1 month and 3 days to 1 month and 5 days is acquired from the system Q2, the inventory data generated on 1 month and 4 days to 1 month and 5 days is acquired from the system Q3, the time anchor of the system is updated after checking the inventory data of the system, the time anchor of the system Q1 is updated to 1 month and 5 days, the time anchor of the system Q2 is updated to 1 month and 5 days, and the time anchor of the system Q3 is updated to 1 month and 5 days.
According to the inventory checking time point and the time anchor point, the inventory data is determined, the data to be checked can be reduced, repeated checking of the inventory data is avoided, and the data checking efficiency is improved.
Fig. 2 is a timing diagram illustrating a method of checking inventory data according to one embodiment of the present invention. Illustratively, as shown in FIG. 2, the execution body of the embodiment of the present invention includes a data collation module and an operation maintenance module. When executing the inventory data and checking method, the user firstly sends a data checking request to a data checking module, the data checking module requests inventory data to a warehouse management system, the warehouse management system returns the inventory data to the data checking module, the warehouse management system can be IWMS (Internationalization Warehouse MANAGE SYSTEM, internationalization warehouse management system), then the data checking module requests inventory data to a supply chain platform, the supply chain platform returns the inventory data to the data checking module, the supply chain platform can be IFOP (Internationalization Fulfillment Orchestration Platform, international supply chain performance scheduling platform), and the data checking module checks the inventory data according to the checking strategy, generates a checking result of the inventory data and returns the checking result of the inventory data to the user. When the checking result shows that the inventory data is inconsistent, the data checking module generates a data processing plan and sends the data processing plan to the operation maintenance module, a user sends a data repairing request to the operation maintenance module, the operation maintenance module checks the corresponding data processing plan after receiving the data repairing request, and when the data processing plan is judged to be in accordance with the specification, the data repairing request is forwarded to the data checking module, the data checking module repairs the inventory data according to the data repairing request, and after the repairing is completed, the data repairing result of the inventory data is returned to the user.
Fig. 3 is a schematic diagram of the main flow of a checking method of inventory data according to one referenceable embodiment of the present invention. An exemplary embodiment of the present invention, as shown in fig. 3, includes the steps of generating a snapshot of inventory data of each system at regular time, filtering the inventory data based on a time anchor point and an inventory verification time point of each system after receiving a data verification request, acquiring the inventory data from a warehouse system, acquiring the inventory data from an e-commerce system, loading a verification policy and a verification node, performing a warehouse entry process verification on the inventory data, determining whether the inventory data of a plurality of systems are consistent in the warehouse entry process verification or the ex-warehouse process verification, determining whether the inventory data of the plurality of systems are inconsistent, determining whether the backlog data exists in the case that the inventory data of the plurality of systems are inconsistent, performing a verification based on the identified backlog data, determining whether the system error data exists in the case that the backlog data does not exist, and performing a verification based on the identified system error data in the case that the system error data exists, and then generating a verification result and a data processing plan, and sending an inventory data difference warning to a user to repair the inventory data with the data processing plan.
Fig. 4 is a schematic diagram of a main system architecture of a checking method of inventory data according to one embodiment of the present invention. Illustratively, as shown in fig. 4, the warehousing system and the supply chain platform and the e-commerce system provide inventory data for verification to the execution subject of the embodiment of the invention, a user can send various requests such as automatic inventory data verification, inventory data difference early warning, backlog data statistics and the like to the execution subject of the embodiment of the invention through a link on a front-end interface, after the user sends the inventory data verification request, a data routing layer determines the inventory data for verification and the verification policy or custom verification policy from a verification policy set according to the data verification request and then verifies the inventory data, wherein each system is provided with various types of data sources such as Redis, gu Geyun, mySQL and the like, and each system can be deployed in different countries, and each international data source stores different inventory data. The base configuration module provides base configurations, e.g., check node configurations, query statement configurations, early warning threshold configurations, check period configurations, etc., to the data routing layer and the data source.
Fig. 5 is a schematic diagram of the main flow of a checking method of inventory data according to one referenceable embodiment of the present invention. As shown in fig. 5, the checking method of stock data may include:
Step S501, in response to receiving a data checking request, determining an inventory checking time point corresponding to the data checking request and a time anchor point of each system;
Step S502, acquiring inventory data to be checked in each system according to the inventory checking time point and the time anchor point;
step S503, determining a checking strategy of inventory data applicable to a plurality of systems;
step S504, checking the inventory data of a plurality of systems according to a check node responsibility chain included in the check strategy to obtain a check result;
Step S505, judging whether the difference of the stock data is larger than or equal to a difference threshold, if so, jumping to step S506, otherwise, jumping to step S507;
Step S506, a data processing plan is generated, and early warning mails are sent to the user;
step S507, a check result of the stock data is returned to the user.
The implementation of the method for checking stock data according to the above embodiment of the present invention has been described in detail in the above method for checking stock data, and thus, the description thereof will not be repeated here.
Fig. 6 is a schematic diagram of the main flow of a checking method of inventory data according to another embodiment of the present invention. As shown in fig. 6, the checking method of stock data may include:
step S601, in response to receiving the data checking request, determining a plurality of systems and target data sources corresponding to the data checking request;
Step S602, judging whether the default data source is consistent with the target data source, if so, jumping to step S604, otherwise, jumping to step S603;
Step S603, switching a default data source to a target data source, and acquiring inventory data from the target data sources of a plurality of systems;
Step S604, acquiring inventory data from default data sources of a plurality of systems;
step S605, determining a checking strategy of inventory data applicable to a plurality of systems, wherein the checking strategy comprises checking node responsibility chains;
Step S606, checking the inventory data of a plurality of systems by using a first checking node;
step S607, judging whether the inventory data of a plurality of systems are consistent, if yes, jumping to step S613, otherwise jumping to step S608;
Step S608, identifying backlog data from a plurality of systems by using a second check node, and combining the backlog data and the inventory data of each system into first correction data;
Step S609, checking the first correction data of the plurality of systems by using a second checking node;
Step S610, judging whether the first correction data of the systems are consistent, if yes, jumping to step S613, otherwise jumping to step S611;
Step S611, identifying system error data from a plurality of systems by using a third check node, and determining second correction data according to the system error data and the first correction data of each system;
step S612, checking second correction data of the plurality of systems by using a third checking node;
step S613 generates a collation result of the stock data.
The implementation of the inventory data checking method according to the above embodiment of the present invention has been described in detail, and thus, the description thereof will not be repeated here.
Fig. 7 is a schematic diagram of main modules of an apparatus for collating inventory data according to an embodiment of the present invention, and as shown in fig. 7, the apparatus 700 for collating inventory data mainly includes:
An obtaining module 701, configured to obtain inventory data of a plurality of systems corresponding to a data collation request in response to receiving the data collation request;
A determining module 702 for determining a reconciliation policy for inventory data applicable to the plurality of systems, the reconciliation policy comprising a reconciliation node responsibility chain;
And the checking module 703 is configured to check the inventory data of the multiple systems according to the check node responsibility chain, so as to obtain a check result.
According to a referenceable embodiment of the invention, the reconciliation node responsibility chain comprises a plurality of reconciliation nodes, reconciling inventory data of the plurality of systems based on the reconciliation node responsibility chain, comprising:
checking inventory data of the plurality of systems using a first check node;
When the stock data of the systems are inconsistent, identifying backlog data from the systems by using a second check node, merging the backlog data of each system and the stock data into first correction data, and checking the first correction data of the systems;
when the plurality of first correction data are inconsistent, the third collation node is used to identify system error data from the plurality of systems, and the second correction data are determined according to the system error data and the first correction data of each system, and the second correction data of the plurality of systems are collated.
According to another referenceable embodiment of the invention, the systematic error data are generated by different systematic errors, the reconciliation node responsibility chain comprises a plurality of reconciliation nodes for identifying systematic error data generated by different systematic errors, the reconciliation apparatus 700 of inventory data further comprises:
the searching module is used for determining the repaired target system error in response to detecting that the system error is repaired;
and the removing module is used for removing the target check node corresponding to the target system error from the check node responsibility chain.
According to still another embodiment of the present invention, the checking device 700 of stock data further includes:
the generation module is used for determining the reasons for the inconsistency of the inventory data of the systems and generating an inventory data processing plan according to the reasons;
And the repair module is used for repairing the inventory data of the systems according to the inventory data processing plan so that the repaired inventory data are consistent.
According to a further exemplary embodiment of the present invention, the checking device 700 of inventory data further includes a display module for displaying a corresponding custom extension programming specification in response to receiving an extension programming request;
Checking the inventory data of the systems according to the check node responsibility chain comprises checking the inventory data of the systems by using the check node responsibility chain included by the self-defined check strategy.
According to a further referenceable embodiment of the invention, acquiring inventory data of a plurality of systems corresponding to the data collation request comprises determining an inventory collation time point corresponding to the data collation request and a time anchor point of each system;
The checking device 700 of stock data further comprises an updating module for updating the time anchor point of each system using the stock checking time point.
According to a referenceable embodiment of the present invention, acquiring inventory data of a plurality of systems corresponding to the data collation request includes:
Determining a plurality of systems and target data sources corresponding to the data check request;
Judging whether default data sources of the systems are identical to the target data sources or not;
acquiring inventory data from default data sources of the plurality of systems under the condition that the default data sources are the same as the target data sources;
And switching the default data source to the target data source under the condition that the default data source is different from the target data source, and acquiring inventory data from the target data sources of the systems.
The specific implementation of the apparatus for checking inventory data according to the embodiment of the present invention is described in detail in the above method for checking inventory data, and thus the description thereof will not be repeated here.
According to the technical scheme provided by the embodiment of the invention, the inventory data of a plurality of systems are checked based on the checking strategy and the checking node responsibility chain, so that the checking efficiency and accuracy of the inventory data can be improved, and the labor cost is reduced; the method comprises the steps of calculating and checking inventory data by using a plurality of check nodes of a check node responsibility chain, improving flexibility of data check, meeting different data check requirements, removing corresponding target check nodes from the check node responsibility chain under the condition that system errors are repaired, improving data check efficiency, simplifying a data check flow, generating an inventory data processing plan according to the reason that the inventory data are inconsistent, repairing the inventory data according to the inventory data processing plan, improving data repairing efficiency, reducing labor cost, providing a user with a custom extension programming specification, receiving a custom extension interface written by the user, checking inventory data of a plurality of systems according to the custom extension interface, further improving flexibility and scalability of data check, determining the inventory data according to an inventory check time point and a time anchor point, reducing the data to be checked, improving the data check efficiency, switching the default system environment under the condition that the default system environment does not comprise the plurality of systems, acquiring the inventory data of the systems from the target system environment, rapidly switching the different system environment, improving the data check function, and improving the data check accuracy.
According to a third aspect of embodiments of the present invention, there is provided an electronic device comprising one or more processors, and storage means for storing one or more programs which, when executed by the one or more processors, cause the one or more processors to implement the method provided by the first aspect of embodiments of the present invention.
According to a fourth aspect of embodiments of the present invention, there is provided a computer readable medium having stored thereon a computer program which when executed by a processor implements the method provided by the first aspect of embodiments of the present invention.
Fig. 8 shows an exemplary system architecture 800 to which the inventory data collation method or inventory data collation apparatus of the embodiment of the present invention can be applied.
As shown in fig. 8, a system architecture 800 may include terminal devices 801, 802, 803, a network 804, and a server 805. The network 804 serves as a medium for providing communication links between the terminal devices 801, 802, 803 and the server 805. The network 804 may include various connection types, such as wired, wireless communication links, or fiber optic cables, among others.
A user may interact with the server 805 through the network 804 using the terminal devices 801, 802, 803 to receive or send messages or the like. Various communication client applications may be installed on the terminal devices 801, 802, 803, such as an inventory check class application, an inventory query class application, a search class application, an instant messaging tool, a mailbox client, social platform software, and the like (by way of example only).
The terminal devices 801, 802, 803 may be a variety of electronic devices having a display screen and supporting web browsing, including but not limited to smartphones, tablets, laptop and desktop computers, and the like.
The server 805 may be a server that provides various services, such as a background management server (merely an example) that supports a collation request of inventory data sent upstream by the terminal devices 801, 802, 803. The background management server can respond to the received data checking request to acquire the inventory data of a plurality of systems corresponding to the data checking request, determine a checking strategy applicable to the inventory data of the systems, wherein the checking strategy comprises a checking node responsibility chain, check the inventory data of the systems according to the checking node responsibility chain to obtain a checking result, and feed back the checking condition (only an example) of the inventory data to the terminal equipment.
It should be noted that, the method for checking inventory data provided by the embodiment of the present invention is generally performed by the server 805, and accordingly, the checking device for inventory data is generally disposed in the server 805. The checking method of inventory data provided by the embodiment of the present invention may also be performed by the terminal devices 801, 802, 803, and accordingly, the checking apparatus of inventory data may be provided in the terminal devices 801, 802, 803.
It should be understood that the number of terminal devices, networks and servers in fig. 8 is merely illustrative. There may be any number of terminal devices, networks, and servers, as desired for implementation.
Referring now to FIG. 9, there is illustrated a schematic diagram of a computer system 900 suitable for use in implementing an embodiment of the present invention. The terminal device shown in fig. 9 is only an example, and should not impose any limitation on the functions and the scope of use of the embodiment of the present invention.
As shown in fig. 9, the computer system 900 includes a Central Processing Unit (CPU) 901, which can execute various appropriate actions and processes according to a program stored in a Read Only Memory (ROM) 902 or a program loaded from a storage section 908 into a Random Access Memory (RAM) 903. In the RAM 903, various programs and data necessary for the operation of the system 900 are also stored. The CPU 901, ROM 902, and RAM 903 are connected to each other through a bus 904. An input/output (I/O) interface 905 is also connected to the bus 904.
Connected to the I/O interface 905 are an input section 906 including a keyboard, a mouse, and the like, an output section 907 including a Cathode Ray Tube (CRT), a Liquid Crystal Display (LCD), and the like, a speaker, and the like, a storage section 908 including a hard disk, and the like, and a communication section 909 including a network interface card such as a LAN card, a modem, and the like. The communication section 909 performs communication processing via a network such as the internet. The drive 910 is also connected to the I/O interface 905 as needed. A removable medium 911 such as a magnetic disk, an optical disk, a magneto-optical disk, a semiconductor memory, or the like is installed as needed on the drive 910 so that a computer program read out therefrom is installed into the storage section 908 as needed.
In particular, according to embodiments of the present disclosure, the processes described above with reference to flowcharts may be implemented as computer software programs. For example, embodiments of the present disclosure include a computer program comprising a computer program embodied on a computer readable medium, the computer program comprising program code for performing the method shown in the flow chart. In such an embodiment, the computer program may be downloaded and installed from the network via the communication portion 909 and/or installed from the removable medium 911. When the computer program is executed by a Central Processing Unit (CPU) 901, the above-described functions defined in the system of the embodiment of the present invention are performed.
It should be noted that, the computer readable medium shown in the embodiments of the present invention may be a computer readable signal medium or a computer readable storage medium, or any combination of the two. The computer readable storage medium can be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or a combination of any of the foregoing. More specific examples of a computer-readable storage medium may include, but are not limited to, an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In embodiments of the present invention, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device. In contrast, in embodiments of the present invention, the computer-readable signal medium may comprise a data signal propagated in baseband or as part of a carrier wave, with the computer-readable program code embodied therein. Such a propagated data signal may take any of a variety of forms, including, but not limited to, electro-magnetic, optical, or any suitable combination of the foregoing. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device. Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.
The flowcharts and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer programs according to various embodiments of the present invention. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams or flowchart illustration, and combinations of blocks in the block diagrams or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions.
The modules involved in the embodiments of the present invention may be implemented in software or in hardware. The described modules may also be provided in a processor, for example, a processor may be described as comprising an acquisition module, a determination module, a verification module, wherein the names of the modules do not in some cases constitute a limitation of the module itself, for example, the acquisition module may also be described as "a module for acquiring inventory data of a plurality of systems".
As another aspect, the embodiment of the present invention further provides a computer readable medium, which may be included in the apparatus described in the above embodiment, or may exist alone without being assembled into the apparatus. The computer readable medium carries one or more programs, and when the one or more programs are executed by the apparatus, the apparatus implements a method of acquiring inventory data of a plurality of systems corresponding to a data collation request in response to receiving the data collation request, determining a collation policy applicable to the inventory data of the plurality of systems, the collation policy including a collation node responsibility chain, and collating the inventory data of the plurality of systems according to the collation node responsibility chain to obtain a collation result.
According to the technical scheme provided by the embodiment of the invention, the inventory data of a plurality of systems are checked based on the checking strategy and the checking node responsibility chain, so that the checking efficiency and accuracy of the inventory data can be improved, and the labor cost is reduced; the method comprises the steps of calculating and checking inventory data by using a plurality of check nodes of a check node responsibility chain, improving flexibility of data check, meeting different data check requirements, removing corresponding target check nodes from the check node responsibility chain under the condition that system errors are repaired, improving data check efficiency, simplifying a data check flow, generating an inventory data processing plan according to the reason that the inventory data are inconsistent, repairing the inventory data according to the inventory data processing plan, improving data repairing efficiency, reducing labor cost, providing a user with a custom extension programming specification, receiving a custom extension interface written by the user, checking inventory data of a plurality of systems according to the custom extension interface, further improving flexibility and scalability of data check, determining the inventory data according to an inventory check time point and a time anchor point, reducing the data to be checked, improving the data check efficiency, switching the default system environment under the condition that the default system environment does not comprise the plurality of systems, acquiring the inventory data of the systems from the target system environment, rapidly switching the different system environment, improving the data check function, and improving the data check accuracy.
The above detailed description should not be construed as limiting the scope of the embodiments of the present invention. It will be apparent to those skilled in the art that various modifications, combinations, sub-combinations and alternatives can occur depending upon design requirements and other factors. Any modifications, equivalent substitutions and improvements made within the spirit and principles of the embodiments of the present invention should be included in the scope of the embodiments of the present invention.