CN115114303A - Service data auditing method, platform and system - Google Patents
Service data auditing method, platform and system Download PDFInfo
- Publication number
- CN115114303A CN115114303A CN202110304310.2A CN202110304310A CN115114303A CN 115114303 A CN115114303 A CN 115114303A CN 202110304310 A CN202110304310 A CN 202110304310A CN 115114303 A CN115114303 A CN 115114303A
- Authority
- CN
- China
- Prior art keywords
- data
- platform
- business
- audited
- audit
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/23—Updating
- G06F16/2365—Ensuring data consistency and integrity
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/21—Design, administration or maintenance of databases
- G06F16/215—Improving data quality; Data cleansing, e.g. de-duplication, removing invalid entries or correcting typographical errors
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q10/00—Administration; Management
- G06Q10/10—Office automation; Time management
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q50/00—Information and communication technology [ICT] specially adapted for implementation of business processes of specific business sectors, e.g. utilities or tourism
- G06Q50/40—Business processes related to the transportation industry
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- Databases & Information Systems (AREA)
- Business, Economics & Management (AREA)
- General Physics & Mathematics (AREA)
- Data Mining & Analysis (AREA)
- Strategic Management (AREA)
- Human Resources & Organizations (AREA)
- General Engineering & Computer Science (AREA)
- Marketing (AREA)
- General Business, Economics & Management (AREA)
- Economics (AREA)
- Tourism & Hospitality (AREA)
- Entrepreneurship & Innovation (AREA)
- Quality & Reliability (AREA)
- Operations Research (AREA)
- Computer Security & Cryptography (AREA)
- Computing Systems (AREA)
- Health & Medical Sciences (AREA)
- General Health & Medical Sciences (AREA)
- Primary Health Care (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
本发明提供一种业务数据稽核方法、平台和系统,其中方法包括:接收任一业务平台在完成数据同步后的待稽核数据,将待稽核数据上链存储至该业务平台的业务数据中;链上查询关联业务平台的业务数据中是否包含与待稽核数据一致的数据,确定待稽核数据的稽核结果,关联业务平台是与该业务平台进行数据同步的业务平台。本发明提供的方法、平台和系统,保证了稽核平台和业务平台之间数据同步的可靠性、健壮性。链上比对不同业务平台的业务数据,为不可信平台之间提供了一种信任补充机制,且在完成业务数据稽核的同时,保证了稽核方法可以扩展适应各种业务稽核场景,且不影响目前的业务流程,在现有平台的基础上改动小,易于部署和实施。
The present invention provides a business data auditing method, platform and system, wherein the method includes: receiving data to be audited on any business platform after data synchronization is completed, uploading the data to be audited and storing it in the business data of the business platform; Query whether the business data of the associated business platform contains data consistent with the data to be audited, and determine the audit result of the data to be audited. The associated business platform is a business platform that synchronizes data with the business platform. The method, platform and system provided by the invention ensure the reliability and robustness of data synchronization between the audit platform and the business platform. Comparing the business data of different business platforms on the chain provides a trust supplementary mechanism between untrusted platforms, and while completing the business data audit, it ensures that the audit method can be extended to adapt to various business audit scenarios without affecting the The current business process, based on the existing platform, is easy to deploy and implement with minor changes.
Description
技术领域technical field
本发明涉及计算机技术领域,尤其涉及一种业务数据稽核方法、平台和系统。The invention relates to the field of computer technology, in particular to a business data auditing method, platform and system.
背景技术Background technique
电信运营场景下,业务支撑系统在很多情况下都需要在多个系统、平台之间同步业务数据,此处的业务数据可以包括用户状态、用户订购关系等。如果业务数据同步失败,相关的系统、平台之间数据不一致,则会引发很多问题,例如计费系统前后端数据不一致,往往会引起计费不准确、用户业务无法办理等问题。In the telecom operation scenario, the business support system needs to synchronize business data among multiple systems and platforms in many cases. The business data here may include user status, user subscription relationship, and so on. If the business data synchronization fails and the data between the related systems and platforms is inconsistent, many problems will arise. For example, the front-end and back-end data of the billing system are inconsistent, which often leads to inaccurate billing and inability to handle user services.
目前,针对不同系统、平台上业务数据不一致的问题,通常采用线下稽核比对的方式进行补救,具体操作方式为:当任一平台获取到另一平台的数据后,该平台将数据存入本地数据库,并与本地对应的表进行记录比对,找到差异后进行本地数据更新。At present, for the problem of inconsistent business data on different systems and platforms, offline auditing and comparison are usually used to remedy the problem. The local database is compared with the local corresponding table, and the local data is updated after the difference is found.
而然,上述稽核方式因为涉及的业务千差万别,不同平台和系统之间比对方式和机制也不同,没有统一的稽核规范和支撑系统,另外,上述稽核方式通常还需要人工参与,不仅效率低而且错误率较高。However, due to the vastly different businesses involved in the above-mentioned audit methods, the comparison methods and mechanisms between different platforms and systems are also different, and there is no unified audit specification and support system. In addition, the above-mentioned audit methods usually require manual participation, which is not only inefficient but also Error rate is high.
发明内容SUMMARY OF THE INVENTION
本发明提供一种业务数据稽核方法、平台和系统,用以解决现有的业务数据稽核方法效率低下、可靠性差的问题。The invention provides a business data auditing method, platform and system, which are used to solve the problems of low efficiency and poor reliability of the existing business data auditing method.
本发明提供一种业务数据稽核方法,所述方法应用于基于区块链的稽核平台,所述方法包括:The present invention provides a business data auditing method. The method is applied to a blockchain-based auditing platform, and the method includes:
接收任一业务平台在完成数据同步后的待稽核数据,将所述待稽核数据上链存储至所述任一业务平台的业务数据中;Receive the data to be audited after the data synchronization of any business platform is completed, and store the data to be audited in the business data of any business platform on the chain;
链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果,所述关联业务平台是与所述任一业务平台进行数据同步的业务平台。Query on the chain whether the business data of the associated business platform contains data consistent with the data to be audited, and determine the audit result of the data to be audited. The associated business platform is a business that synchronizes data with any of the business platforms. platform.
根据本发明提供的一种业务数据稽核方法,所述链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果,包括:According to a business data auditing method provided by the present invention, the on-chain query of whether the business data of the associated business platform includes data consistent with the data to be audited, and determining the audit result of the data to be audited, includes:
基于稽核智能合约,链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据;Based on the audit smart contract, query on the chain whether the business data of the associated business platform contains data consistent with the data to be audited;
若包含,则确定所述稽核结果为正常,否则确定所述稽核结果为异常。If included, the audit result is determined to be normal; otherwise, the audit result is determined to be abnormal.
根据本发明提供的一种业务数据稽核方法,所述将所述待稽核数据上链存储至所述任一业务平台的业务数据中,包括:According to a business data auditing method provided by the present invention, storing the data to be audited in the business data of any business platform on the chain includes:
基于上链智能合约,将所述待稽核数据上链存储至所述任一业务平台的业务数据中。Based on the on-chain smart contract, the data to be audited is uploaded to the chain and stored in the business data of any of the business platforms.
根据本发明提供的一种业务数据稽核方法,所述确定所述待稽核数据的稽核结果,之后还包括:According to a business data auditing method provided by the present invention, the determining of the auditing result of the data to be audited further includes:
若所述稽核结果为正常,则向所述任一业务平台和所述关联业务平台发送稽核正常通知,以供所述任一业务平台和所述关联业务平台将所述待稽核数据更新为正常数据;If the audit result is normal, send an audit normal notification to the any business platform and the associated business platform, so that the any business platform and the associated business platform can update the data to be audited to be normal data;
若所述稽核结果为异常,则向所述任一业务平台发送稽核异常通知,以供所述任一业务平台将所述待稽核数据更新为异常数据。If the audit result is abnormal, an audit abnormality notification is sent to any business platform, so that any business platform can update the data to be audited into abnormal data.
本发明提供一种业务数据稽核方法,所述方法应用于业务平台,所述方法包括:The present invention provides a business data auditing method, the method is applied to a business platform, and the method includes:
与关联业务平台进行数据同步,得到完成数据同步后的待稽核数据;Synchronize data with the associated business platform to obtain the data to be audited after data synchronization is completed;
将所述待稽核数据发送至基于区块链的稽核平台,以触发所述稽核平台将所述待稽核数据上链存储至所述业务平台的业务数据中,并链上查询所述关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果。Send the data to be audited to the blockchain-based auditing platform to trigger the auditing platform to store the data to be audited in the business data of the business platform, and query the associated business platform on the chain Whether the business data contained in the data is consistent with the data to be audited, the audit result of the data to be audited is determined.
根据本发明提供的一种业务数据稽核方法,所述将所述待稽核数据发送至基于区块链的稽核平台,之后还包括:According to a business data auditing method provided by the present invention, the sending of the data to be audited to a blockchain-based auditing platform further includes:
若接收到所述稽核结果为正常时所述稽核平台返回的稽核正常通知,则将所述待稽核数据更新为正常数据;If receiving a normal audit notification returned by the audit platform when the audit result is normal, update the data to be audited to normal data;
若接收到所述稽核结果为异常时所述稽核平台返回的稽核异常通知,则将所述待稽核数据更新为异常数据。If the audit abnormality notification returned by the audit platform when the audit result is abnormal is received, the data to be audited is updated to abnormal data.
根据本发明提供的一种业务数据稽核方法,还包括:A business data auditing method provided according to the present invention further includes:
每隔预设时间,基于本地存储的异常数据更新异常日志。Every preset time, the exception log is updated based on the locally stored exception data.
本发明提供一种基于区块链的稽核平台,包括:The present invention provides a blockchain-based audit platform, including:
上链存储单元,用于接收任一业务平台在完成数据同步后的待稽核数据,将所述待稽核数据上链存储至所述任一业务平台的业务数据中;An on-chain storage unit, configured to receive the data to be audited on any business platform after data synchronization is completed, and upload the data to be audited to the business data of any of the business platforms;
链上查询单元,用于链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果,所述关联业务平台是与所述任一业务平台进行数据同步的业务平台。The on-chain query unit is used to query on the chain whether the business data of the associated business platform contains data consistent with the data to be audited, and to determine the audit result of the data to be audited, and the associated business platform is related to any of the data to be audited. Business Platform A business platform for data synchronization.
本发明提供一种业务平台,包括:The present invention provides a business platform, including:
数据同步单元,用于与关联业务平台进行数据同步,得到完成数据同步后的待稽核数据;The data synchronization unit is used to synchronize data with the associated business platform, and obtain the data to be audited after the data synchronization is completed;
同步上传单元,用于将所述待稽核数据发送至基于区块链的稽核平台,以触发所述稽核平台将所述待稽核数据上链存储至所述业务平台的业务数据中,并链上查询所述关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果。A synchronous uploading unit is used to send the data to be audited to the audit platform based on blockchain, so as to trigger the audit platform to upload the data to be audited to the business data of the business platform, and upload the data to the chain. Query whether the business data of the associated business platform includes data consistent with the data to be audited, and determine the audit result of the data to be audited.
本发明提供一种业务数据稽核系统,包括如上述的基于区块链的稽核平台,以及多个如上述的业务平台。The present invention provides a business data auditing system, including the above-mentioned blockchain-based auditing platform, and a plurality of the above-mentioned business platforms.
本发明提供的业务数据稽核方法、平台和系统,通过基于区块链的稽核平台的应用,将各业务平台的业务数据同步到区块链,从而保证了稽核平台和业务平台之间数据同步的可靠性、健壮性。链上比对不同业务平台的业务数据,为不可信平台之间提供了一种信任补充机制,且在完成业务数据稽核的同时,保证了稽核方法可以扩展适应各种业务稽核场景,且不影响目前的业务流程,在现有平台的基础上改动小,易于部署和实施。The business data auditing method, platform and system provided by the present invention synchronize the business data of each business platform to the block chain through the application of the audit platform based on the blockchain, thereby ensuring the data synchronization between the audit platform and the business platform. Reliability and robustness. Comparing the business data of different business platforms on the chain provides a trust supplement mechanism between untrusted platforms, and while completing the business data audit, it ensures that the audit method can be extended to adapt to various business audit scenarios without affecting the The current business process, based on the existing platform, is easy to deploy and implement with minor changes.
附图说明Description of drawings
为了更清楚地说明本发明或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作一简单地介绍,显而易见地,下面描述中的附图是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。In order to explain the present invention or the technical solutions in the prior art more clearly, the following will briefly introduce the accompanying drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are the For some embodiments of the invention, for those of ordinary skill in the art, other drawings can also be obtained according to these drawings without any creative effort.
图1是本发明提供的业务数据稽核方法的流程示意图之一;Fig. 1 is one of the schematic flow charts of the business data auditing method provided by the present invention;
图2是本发明提供的业务数据稽核方法的流程示意图之二;Fig. 2 is the second schematic flow chart of the business data auditing method provided by the present invention;
图3是本发明提供的业务数据稽核方法的流程示意图之三;3 is the third schematic flow chart of the business data auditing method provided by the present invention;
图4是本发明提供的业务数据稽核方法的流程示意图之四;Fig. 4 is the fourth schematic flow chart of the business data auditing method provided by the present invention;
图5是本发明提供的基于区块链的稽核平台的结构示意图;5 is a schematic structural diagram of a blockchain-based audit platform provided by the present invention;
图6是本发明提供的业务平台的结构示意图;6 is a schematic structural diagram of a service platform provided by the present invention;
图7是本发明提供的业务数据稽核系统的结构示意图;7 is a schematic structural diagram of a business data auditing system provided by the present invention;
图8是本发明提供的电子设备的结构示意图。FIG. 8 is a schematic structural diagram of an electronic device provided by the present invention.
具体实施方式Detailed ways
为使本发明的目的、技术方案和优点更加清楚,下面将结合本发明中的附图,对本发明中的技术方案进行清楚、完整地描述,显然,所描述的实施例是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例,都属于本发明保护的范围。In order to make the objectives, technical solutions and advantages of the present invention clearer, the technical solutions in the present invention will be clearly and completely described below with reference to the accompanying drawings. Obviously, the described embodiments are part of the embodiments of the present invention. , not all examples. Based on the embodiments of the present invention, all other embodiments obtained by those of ordinary skill in the art without creative efforts shall fall within the protection scope of the present invention.
现有的稽核方式因为涉及的业务千差万别,不同平台和系统之间比对方式和机制也不同,没有统一的稽核规范和支撑系统。另外通常需要人工参与,人工通过脚本比对,对结果进行分析,处理稽核差异。The existing audit methods vary widely because of the various businesses involved, and the comparison methods and mechanisms between different platforms and systems are also different, and there is no unified audit specification and support system. In addition, manual participation is usually required, and manual comparisons are performed through scripts to analyze the results and deal with audit differences.
深入分析平台之间业务数据不一致的原因,业务数据同步主要有如下几个场景,存在多个平台业务数据同步的情况,简单以两个平台为例:In-depth analysis of the reasons for the inconsistency of business data between platforms. There are mainly the following scenarios for business data synchronization. There are situations where business data is synchronized on multiple platforms. Simply take two platforms as an example:
场景A:平台A发送业务同步消息给平台B,平台B响应处理成功,这种场景一般不会出现业务数据不一致情况,特殊情况是,平台B在返回处理成功后,后端是异步处理机制,异步处理失败会导致平台A和平台B业务数据不一致情况。Scenario A: Platform A sends a business synchronization message to platform B, and platform B responds successfully. In this scenario, there is generally no business data inconsistency. The special case is that after platform B returns the processing successfully, the backend is an asynchronous processing mechanism. Asynchronous processing failure will result in inconsistent business data between platform A and platform B.
场景B:平台A发送业务同步消息给平台B,平台B响应业务级处理失败,该场景下,一般通过A重试可以解决业务数据不一致问题。Scenario B: Platform A sends a business synchronization message to platform B, and platform B responds to the failure of business-level processing. In this scenario, the problem of business data inconsistency can generally be resolved by retrying from A.
场景C:平台A发送业务同步消息给平台B,平台B响应系统级失败,该场景如果平台B没收到同步请求,则可以重试;如果平台B收到请求并且处理成功,但是返回给A时出现系统级失败,则平台A不能重试。Scenario C: Platform A sends a service synchronization message to platform B, and platform B responds to a system-level failure. In this scenario, if platform B does not receive the synchronization request, it can retry; if platform B receives the request and processes it successfully, but returns to A In the event of a system-level failure, platform A cannot retry.
场景D:平台A发送业务同步消息给平台B,未收到平台B响应消息,导致超时。该场景可能是消息没发送到平台B,导致超时,或者平台B处理后返回消息给平台A时失败,A未收到响应消息导致超时。Scenario D: Platform A sends a service synchronization message to platform B, but does not receive a response message from platform B, resulting in a timeout. In this scenario, the message may not be sent to platform B, resulting in a timeout, or platform B fails to return the message to platform A after processing, and A does not receive a response message, resulting in a timeout.
以上的B、C、D场景均会导致平台A和平台B业务数据不一致。针对上述各种场景下的问题,本发明实施例提供一种业务数据稽核方法。图1是本发明提供的业务数据稽核方法的流程示意图,如图1所示,该方法的执行主体是基于区块链的稽核平台,该方法包括:The above scenarios B, C, and D will cause inconsistent business data between platform A and platform B. Aiming at the problems in the above-mentioned various scenarios, an embodiment of the present invention provides a business data auditing method. FIG. 1 is a schematic flowchart of a business data auditing method provided by the present invention. As shown in FIG. 1 , the execution subject of the method is a blockchain-based auditing platform, and the method includes:
步骤110,接收任一业务平台在完成数据同步后的待稽核数据,将待稽核数据上链存储至所述任一业务平台的业务数据中。Step 110: Receive the data to be audited after the data synchronization of any business platform is completed, and upload the data to be audited to the business data of the any business platform.
具体地,稽核平台是独立于各个业务平台之外的,用于进行业务数据稽核的平台。基于区块链技术建立的稽核平台,具备区块链不可篡改的特质,可以通过区块链特有的共识算法保证稽核平台上存储数据的完整可信。Specifically, the auditing platform is independent of each business platform and is used for conducting business data auditing. The audit platform established based on blockchain technology has the characteristics that the blockchain cannot be tampered with, and can ensure the integrity and credibility of the data stored on the audit platform through the unique consensus algorithm of the blockchain.
稽核平台和各个业务平台之间均建立数据传输通道,例如各业务平台可以通过DAAPP(Decentralized Application)与稽核平台进行数据交互。A data transmission channel is established between the audit platform and each business platform. For example, each business platform can exchange data with the audit platform through DAAPP (Decentralized Application).
针对于任意一个业务平台,该业务平台可以与其余业务平台进行数据同步,并确认数据同步完成,例如该业务平台将业务数据同步到另一业务平台,并接收到另一业务平台返回的成功响应后,该业务平台可以确认数据同步完成,又例如该业务平台接收到另一业务平台的业务数据并进行业务处理,处理完成后通知另一业务平台处理成功,此时该业务平台可以确认数据同步完成。For any business platform, the business platform can synchronize data with other business platforms and confirm that the data synchronization is completed. For example, the business platform synchronizes business data to another business platform and receives a successful response returned by the other business platform. After that, the business platform can confirm that the data synchronization is completed. For example, the business platform receives the business data of another business platform and performs business processing. After the processing is completed, the other business platform is notified that the processing is successful. At this time, the business platform can confirm the data synchronization. Finish.
在该业务平台确认数据同步完成后,可以将数据同步后的业务数据,作为待稽核数据,发送到稽核平台,以请求稽核平台对待稽核数据进行稽核。此处的业务数据具体可以是用户状态、用户订购关系等。After the business platform confirms that the data synchronization is completed, the business data after data synchronization can be sent to the audit platform as the data to be audited to request the audit platform to audit the data to be audited. The service data here may specifically be user status, user subscription relationship, and the like.
稽核平台在接收到待稽核数据后,可以将待稽核数据上链存储至该业务平台的业务数据中。此处,稽核平台本地存储的各个业务平台的业务数据,均是以区块的形式存储的。每次稽核平台接收到任一业务平台发送的新的数据之后,都会把新接收到的数据存储在该业务平台的业务数据所对应的区块中,从而保证稽核平台中存储的业务数据与业务平台本身的业务数据能够同步。After the audit platform receives the data to be audited, it can upload the data to be audited and store it in the business data of the business platform. Here, the business data of each business platform stored locally on the audit platform is stored in the form of blocks. Every time the audit platform receives new data sent by any business platform, it will store the newly received data in the block corresponding to the business data of the business platform, so as to ensure that the business data stored in the audit platform is consistent with the business The business data of the platform itself can be synchronized.
步骤120,链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果,所述关联业务平台是与所述任一业务平台进行数据同步的业务平台。Step 120: Query on the chain whether the business data of the associated business platform contains data consistent with the data to be audited, and determine the audit result of the data to be audited, and the associated business platform is the data that is performed with any of the business platforms. Synchronized business platform.
具体地,稽核平台在接收到该业务平台发送的待稽核数据后,需要确定该业务平台的关联业务平台,即与该业务平台发生数据同步的业务平台,此处的关联业务平台可以是一个或者多个。基于区块链的分布式架构能力,稽核平台可以支持多平台之间的业务数据稽核。Specifically, after receiving the data to be audited sent by the business platform, the audit platform needs to determine the business platform associated with the business platform, that is, the business platform that synchronizes data with the business platform. The associated business platform here may be one or a multiple. Based on the distributed architecture capability of blockchain, the audit platform can support business data audit between multiple platforms.
在确定关联业务平台之后,稽核平台可以查询在区块链上存储的关联业务平台的业务数据中,是否包含有与待稽核数据一致的数据。如果有,则说明关联业务平台也完成了数据同步,两者在数据同步后的业务数据是一致的,由此确定稽核结果为正常;如果没有,则说明关联业务平台并未完成数据同步,两者在数据同步后的业务数据存在差异,由此确定稽核结果为异常。After determining the associated business platform, the audit platform can query whether the business data of the associated business platform stored on the blockchain contains data consistent with the data to be audited. If yes, it means that the associated business platform has also completed data synchronization, and the business data of the two after data synchronization is consistent, thus confirming that the audit result is normal; if not, it means that the associated business platform has not completed data synchronization, and the two If there are differences in the business data after data synchronization, the audit result is determined to be abnormal.
在此之后,稽核平台可以直接将稽核结果通知相关人员,也可以将稽核结果返回到对应业务平台,本发明实施例对此不作具体限定。After that, the auditing platform may directly notify the relevant personnel of the auditing result, or may return the auditing result to the corresponding business platform, which is not specifically limited in this embodiment of the present invention.
本发明实施例提供的方法,通过基于区块链的稽核平台的应用,将各业务平台的业务数据同步到区块链,从而保证了稽核平台和业务平台之间数据同步的可靠性、健壮性。链上比对不同业务平台的业务数据,为不可信平台之间提供了一种信任补充机制,且在完成业务数据稽核的同时,保证了稽核方法可以扩展适应各种业务稽核场景,且不影响目前的业务流程,在现有平台的基础上改动小,易于部署和实施。The method provided by the embodiment of the present invention synchronizes the business data of each business platform to the blockchain through the application of the audit platform based on the blockchain, thereby ensuring the reliability and robustness of the data synchronization between the audit platform and the business platform . Comparing the business data of different business platforms on the chain provides a trust supplement mechanism between untrusted platforms, and while completing the business data audit, it ensures that the audit method can be extended to adapt to various business audit scenarios without affecting the The current business process, based on the existing platform, is easy to deploy and implement with minor changes.
基于上述实施例,步骤120包括:Based on the above embodiment,
基于稽核智能合约,链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据;Based on the audit smart contract, query on the chain whether the business data of the associated business platform contains data consistent with the data to be audited;
若包含,则确定所述稽核结果为正常,否则确定所述稽核结果为异常。If included, the audit result is determined to be normal; otherwise, the audit result is determined to be abnormal.
具体地,智能合约是一些运行在区块链上的特定代码,一旦在区块链节点上部署了上述代码,当合约触发条件发生时,合约就会自动触发执行。通常实现智能合约的区块链中采用虚拟机机制,智能合约代码运行在虚拟机中,智能合约代码存储在区块链上保证一致性、不可篡改。外部输入数据和事件触发合约中的条件和规则,生成新的动作。通过智能合约可以实现外部和区块链的交互,可以将数据保存到区块链或者从区块链查询数据。Specifically, a smart contract is some specific code running on the blockchain. Once the above code is deployed on the blockchain node, when the contract triggering condition occurs, the contract will automatically trigger execution. Usually, the virtual machine mechanism is used in the blockchain that implements smart contracts. The smart contract code runs in the virtual machine, and the smart contract code is stored on the blockchain to ensure consistency and cannot be tampered with. External input data and events trigger conditions and rules in the contract, generating new actions. The external interaction with the blockchain can be realized through smart contracts, and data can be saved to the blockchain or queried from the blockchain.
此处,稽核智能合约是基于区块链的智能合约技术实现的,负责将多个业务平台的业务数据进行稽核比对,还可以负责将比对结果及时通知到相关平台和系统进行处理。步骤120的执行即可在预先设定的稽核智能合约下实现。Here, the audit smart contract is implemented based on the smart contract technology of the blockchain. It is responsible for auditing and comparing the business data of multiple business platforms, and also responsible for notifying the relevant platforms and systems of the comparison results in time for processing. The execution of
基于上述任一实施例,步骤110中,将所述待稽核数据上链存储至所述任一业务平台的业务数据中,包括:Based on any of the above embodiments, in
基于上链智能合约,将所述待稽核数据上链存储至所述任一业务平台的业务数据中。Based on the on-chain smart contract, the data to be audited is uploaded to the chain and stored in the business data of any of the business platforms.
具体地,上链智能合约是基于区块链的智能合约技术实现的,负责在接收到业务平台发送的业务数据中,将业务数据存储到区块链中。待稽核数据的上链存储即可基于上链智能合约实现。Specifically, the on-chain smart contract is implemented based on the smart contract technology of the blockchain, and is responsible for storing the business data in the blockchain after receiving the business data sent by the business platform. The on-chain storage of the data to be audited can be realized based on the on-chain smart contract.
基于上述任一实施例,步骤120之后还包括:Based on any of the above embodiments, after
若所述稽核结果为正常,则向所述任一业务平台和所述关联业务平台发送稽核正常通知,以供所述任一业务平台和所述关联业务平台将所述待稽核数据更新为正常数据;If the audit result is normal, send an audit normal notification to the any business platform and the associated business platform, so that the any business platform and the associated business platform can update the data to be audited to be normal data;
若所述稽核结果为异常,则向所述任一业务平台发送稽核异常通知,以供所述任一业务平台将所述待稽核数据更新为异常数据。If the audit result is abnormal, an audit abnormality notification is sent to any business platform, so that any business platform can update the data to be audited into abnormal data.
具体地,在得到稽核结果之后,稽核平台可以根据稽核结果是否正常,向不同的对象返回通知:Specifically, after obtaining the audit results, the audit platform can return notifications to different objects according to whether the audit results are normal:
当稽核结果正常时,可以确定数据同步成功,向该业务平台及其关联业务平台均发送稽核正常通知,接收到稽核正常通知的业务平台,即可将稽核正常通知所指示的业务数据确定为正常数据;When the audit result is normal, it can be determined that the data synchronization is successful, and an audit normal notification is sent to the business platform and its related business platforms. The business platform that receives the normal audit notification can determine the business data indicated by the normal audit notification as normal. data;
当稽核结果异常时,可以确定数据同步异常,向该业务平台发送稽核异常通知,接收到稽核异常通知的业务平台,即可将稽核异常通知所指示的业务数据确定为异常数据。When the audit result is abnormal, it can be determined that the data synchronization is abnormal, an audit abnormality notification can be sent to the business platform, and the business platform that receives the audit abnormality notification can determine the business data indicated by the audit abnormality notification as abnormal data.
进一步地,考虑到不同业务平台之间进行数据同步的完成时间可能不同,业务平台及其关联业务平台在完成数据同步之后会分别将数据同步完成的数据上传到稽核平台,相应地稽核平台更新各业务平台的业务数据的时间可能不同,稽核平台在接收到业务平台的更新数据时,可能关联业务平台的更新数据尚未完成。此时进行稽核产生的结果是稽核异常,业务平台将业务数据确定为异常数据,此后关联业务平台上传更新数据后会再次触发业务数据稽核,此时进行稽核产生的结果是稽核正常,业务平台再将异常数据更新为正常数据。Further, considering that the completion time of data synchronization between different business platforms may be different, the business platform and its associated business platform will upload the data that has been synchronized to the audit platform respectively after the data synchronization is completed, and the audit platform will update each data accordingly. The time of the business data of the business platform may be different. When the audit platform receives the update data of the business platform, the update data of the associated business platform may not be completed. At this time, the result of the audit is that the audit is abnormal. The business platform determines the business data as abnormal data. After that, the associated business platform uploads the updated data and triggers the business data audit again. At this time, the result of the audit is that the audit is normal, and the business platform will restart the audit. Update abnormal data to normal data.
基于上述任一实施例,图2是本发明提供的业务数据稽核方法的流程示意图之二,如图2所示,该方法的执行主体是业务平台,该方法包括:Based on any of the above embodiments, FIG. 2 is the second schematic flowchart of the business data auditing method provided by the present invention. As shown in FIG. 2 , the execution subject of the method is a business platform, and the method includes:
步骤210,与关联业务平台进行数据同步,得到完成数据同步后的待稽核数据。
具体地,针对于任意一个业务平台,该业务平台可以与关联业务平台进行数据同步,并确认数据同步完成。此处,关联业务平台即与该业务平台发生数据同步的业务平台,关联业务平台可以是一个或者多个。Specifically, for any business platform, the business platform can perform data synchronization with the associated business platform, and confirm that the data synchronization is completed. Here, the associated service platform is a service platform that synchronizes data with the service platform, and there may be one or more associated service platforms.
例如该业务平台将业务数据同步到另一业务平台,并接收到另一业务平台返回的成功响应后,该业务平台可以确认数据同步完成,又例如该业务平台接收到另一业务平台的业务数据并进行业务处理,处理完成后通知另一业务平台处理成功,此时该业务平台可以确认数据同步完成。For example, after the business platform synchronizes business data to another business platform, and receives a successful response returned by the other business platform, the business platform can confirm that the data synchronization is completed. For example, the business platform receives business data from another business platform. And perform business processing. After the processing is completed, it will notify another business platform that the processing is successful. At this time, the business platform can confirm that the data synchronization is completed.
在该业务平台确认数据同步完成后,可以将数据同步后的业务数据,作为待稽核数据。此处的业务数据具体可以是用户状态、用户订购关系等。After the business platform confirms that the data synchronization is completed, the business data after the data synchronization can be used as the data to be audited. The service data here may specifically be user status, user subscription relationship, and the like.
步骤220,将所述待稽核数据发送至基于区块链的稽核平台,以触发所述稽核平台将所述待稽核数据上链存储至所述业务平台的业务数据中,并链上查询所述关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果。Step 220: Send the data to be audited to a blockchain-based auditing platform to trigger the auditing platform to upload the data to be audited to the business data of the business platform, and query the data on the chain. Whether the business data of the associated business platform includes data consistent with the data to be audited, the audit result of the data to be audited is determined.
具体地,核平台是独立于各个业务平台之外的,用于进行业务数据稽核的平台。基于区块链技术建立的稽核平台,具备区块链不可篡改的特质,可以通过区块链特有的共识算法保证稽核平台上存储数据的完整可信。Specifically, the core platform is independent of each business platform and is used for business data auditing. The audit platform established based on blockchain technology has the characteristics that the blockchain cannot be tampered with, and can ensure the integrity and credibility of the data stored on the audit platform through the unique consensus algorithm of the blockchain.
稽核平台和各个业务平台之间均建立数据传输通道,例如各业务平台可以通过DAAPP与稽核平台进行数据交互。A data transmission channel is established between the audit platform and each business platform. For example, each business platform can exchange data with the audit platform through DAAPP.
在该业务平台确认数据同步完成后,可以将数据同步后的业务数据,作为待稽核数据,发送到稽核平台,以请求稽核平台对待稽核数据进行稽核。After the business platform confirms that the data synchronization is completed, the business data after data synchronization can be sent to the audit platform as the data to be audited to request the audit platform to audit the data to be audited.
稽核平台在接收到待稽核数据后,可以将待稽核数据上链存储至该业务平台的业务数据中。此处,稽核平台本地存储的各个业务平台的业务数据,均是以区块的形式存储的。每次稽核平台接收到任一业务平台发送的新的数据之后,都会把新接收到的数据存储在该业务平台的业务数据所对应的区块中,从而保证稽核平台中存储的业务数据与业务平台本身的业务数据能够同步。After the audit platform receives the data to be audited, it can upload the data to be audited and store it in the business data of the business platform. Here, the business data of each business platform stored locally on the audit platform is stored in the form of blocks. Every time the audit platform receives new data sent by any business platform, it will store the newly received data in the block corresponding to the business data of the business platform, so as to ensure that the business data stored in the audit platform is consistent with the business The business data of the platform itself can be synchronized.
在完成上链存储后,稽核平台可以查询在区块链上存储的关联业务平台的业务数据中,是否包含有与待稽核数据一致的数据。如果有,则说明关联业务平台也完成了数据同步,两者在数据同步后的业务数据是一致的,由此确定稽核结果为正常;如果没有,则说明关联业务平台并未完成数据同步,两者在数据同步后的业务数据存在差异,由此确定稽核结果为异常。After the storage on the chain is completed, the audit platform can query whether the business data of the associated business platform stored on the blockchain contains data consistent with the data to be audited. If yes, it means that the associated business platform has also completed data synchronization, and the business data of the two after data synchronization is consistent, thus confirming that the audit result is normal; if not, it means that the associated business platform has not completed data synchronization, and the two If there are differences in the business data after data synchronization, the audit result is determined to be abnormal.
在此之后,稽核平台可以直接将稽核结果通知相关人员,也可以将稽核结果返回到对应业务平台,本发明实施例对此不作具体限定。After that, the auditing platform may directly notify the relevant personnel of the auditing result, or may return the auditing result to the corresponding business platform, which is not specifically limited in this embodiment of the present invention.
本发明实施例提供的方法,通过基于区块链的稽核平台的应用,将各业务平台的业务数据同步到区块链,从而保证了稽核平台和业务平台之间数据同步的可靠性、健壮性。链上比对不同业务平台的业务数据,为不可信平台之间提供了一种信任补充机制,且在完成业务数据稽核的同时,保证了稽核方法可以扩展适应各种业务稽核场景,且不影响目前的业务流程,在现有平台的基础上改动小,易于部署和实施。The method provided by the embodiment of the present invention synchronizes the business data of each business platform to the blockchain through the application of the audit platform based on the blockchain, thereby ensuring the reliability and robustness of the data synchronization between the audit platform and the business platform . Comparing the business data of different business platforms on the chain provides a trust supplement mechanism between untrusted platforms, and while completing the business data audit, it ensures that the audit method can be extended to adapt to various business audit scenarios without affecting the The current business process, based on the existing platform, is easy to deploy and implement with minor changes.
基于上述任一实施例,步骤220之后还包括:Based on any of the above embodiments, after step 220, the method further includes:
若接收到所述稽核结果为正常时所述稽核平台返回的稽核正常通知,则将所述待稽核数据更新为正常数据;If receiving a normal audit notification returned by the audit platform when the audit result is normal, update the data to be audited to normal data;
若接收到所述稽核结果为异常时所述稽核平台返回的稽核异常通知,则将所述待稽核数据更新为异常数据。If the audit abnormality notification returned by the audit platform when the audit result is abnormal is received, the data to be audited is updated to abnormal data.
具体地,在得到稽核结果之后,稽核平台可以根据稽核结果是否正常,向不同的对象返回通知:Specifically, after obtaining the audit results, the audit platform can return notifications to different objects according to whether the audit results are normal:
当稽核结果正常时,可以确定数据同步成功,向该业务平台及其关联业务平台均发送稽核正常通知,接收到稽核正常通知的业务平台,即可将稽核正常通知所指示的业务数据确定为正常数据;When the audit result is normal, it can be determined that the data synchronization is successful, and an audit normal notification is sent to the business platform and its related business platforms. The business platform that receives the normal audit notification can determine the business data indicated by the normal audit notification as normal. data;
当稽核结果异常时,可以确定数据同步异常,向该业务平台发送稽核异常通知,接收到稽核异常通知的业务平台,即可将稽核异常通知所指示的业务数据确定为异常数据。When the audit result is abnormal, it can be determined that the data synchronization is abnormal, an audit abnormality notification can be sent to the business platform, and the business platform that receives the audit abnormality notification can determine the business data indicated by the audit abnormality notification as abnormal data.
进一步地,考虑到不同业务平台之间进行数据同步的完成时间可能不同,业务平台及其关联业务平台在完成数据同步之后会分别将数据同步完成的数据上传到稽核平台,相应地稽核平台更新各业务平台的业务数据的时间可能不同,稽核平台在接收到业务平台的更新数据时,可能关联业务平台的更新数据尚未完成。此时进行稽核产生的结果是稽核异常,业务平台将业务数据确定为异常数据,此后关联业务平台上传更新数据后会再次触发业务数据稽核,此时进行稽核产生的结果是稽核正常,业务平台再将异常数据更新为正常数据。Further, considering that the completion time of data synchronization between different business platforms may be different, the business platform and its associated business platform will upload the data that has been synchronized to the audit platform respectively after the data synchronization is completed, and the audit platform will update each data accordingly. The time of the business data of the business platform may be different. When the audit platform receives the update data of the business platform, the update data of the associated business platform may not be completed. At this time, the result of the audit is that the audit is abnormal. The business platform determines the business data as abnormal data. After that, the associated business platform uploads the updated data and triggers the business data audit again. At this time, the result of the audit is that the audit is normal, and the business platform will restart the audit. Update abnormal data to normal data.
基于上述任一实施例,该方法还包括:Based on any of the above embodiments, the method further includes:
每隔预设时间,基于本地存储的异常数据更新异常日志。Every preset time, the exception log is updated based on the locally stored exception data.
此处的异常数据即接收到稽核平台发送的稽核异常通知后确定的异常数据。针对异常数据,可以设置定时任务,每隔预设时间,对平台上所有稽核结果为异常的异常数据进行记录,以更新异常日志,并通知运维人员处理。The abnormal data here is the abnormal data determined after receiving the abnormal audit notification sent by the audit platform. For abnormal data, you can set timed tasks to record all abnormal data on the platform with abnormal audit results every preset time, so as to update the abnormal log and notify the operation and maintenance personnel to deal with it.
基于上述任一实施例,图3是本发明提供的业务数据稽核方法的流程示意图之三,如图3所示,基于业务平台A的业务数据稽核流程如下:Based on any of the above-mentioned embodiments, FIG. 3 is the third schematic flowchart of the business data auditing method provided by the present invention. As shown in FIG. 3 , the business data auditing process based on the business platform A is as follows:
首先,业务平台A产生业务数据后,同步业务数据到业务平台B,如果业务平台A收到业务平台B的响应消息是业务级失败,开始重试,直到成功。First, after business platform A generates business data, it synchronizes the business data to business platform B. If business platform A receives a response message from business platform B that it is a business-level failure, it starts to retry until it succeeds.
业务平台A收到业务平台B的成功响应后,将同步给业务平台B的业务数据作为待稽核数据发送到稽核平台。After the business platform A receives the successful response from the business platform B, it sends the business data synchronized to the business platform B to the audit platform as the data to be audited.
接着,稽核平台通过智能合约查看业务平台B是否有与接收到的待稽核数据一致的业务数据,如果有则通知业务平台A和业务平台B该数据稽核结果正常。Next, the audit platform checks whether business platform B has business data consistent with the received data to be audited through the smart contract, and if so, informs business platform A and business platform B that the data audit result is normal.
如果稽核平台未查询到业务平台B有该业务数据,则通知业务平台A该业务数据稽核结果异常。If the audit platform does not find that the business platform B has the business data, it notifies the business platform A that the business data audit result is abnormal.
此外,业务平台A会设置定时任务,定时处理业务平台A中所有业务数据稽核结果异常的数据,发现超过设定的时间状态还异常的则记录日志,通知运维人员处理。In addition, business platform A will set up timed tasks to regularly process all data with abnormal business data audit results in business platform A. If it is found that the status is abnormal after the set time, it will record the log and notify the operation and maintenance personnel to deal with it.
基于上述任一实施例,图4是本发明提供的业务数据稽核方法的流程示意图之四,如图4所示,基于业务平台B的业务数据稽核流程如下:Based on any of the above-mentioned embodiments, FIG. 4 is the fourth schematic flowchart of the business data auditing method provided by the present invention. As shown in FIG. 4 , the business data auditing process based on the business platform B is as follows:
首先,业务平台B接收业务平台A的业务数据,进行业务处理,并将处理结果通知业务平台A。First, the business platform B receives the business data of the business platform A, performs business processing, and notifies the business platform A of the processing result.
如果业务处理失败,通知业务平台A业务处理失败,便于业务平台A进行重试;If the business processing fails, notify the business platform A that the business processing fails, so that the business platform A can retry;
如果系统级失败,并且本地未处理成功,通知业务平台A系统级失败,便于业务平台A进行重试;If the system level fails and the local processing is not successful, notify business platform A of the system level failure, so that business platform A can retry;
如果本地处理成功,则业务数据本地已保存,通知业务平台A处理成功,同时将业务数据作为待稽核数据发送到稽核平台。If the local processing is successful, the business data has been saved locally, and the business platform A is notified that the processing is successful, and the business data is sent to the audit platform as the data to be audited.
稽核平台收到业务平台B的业务数据后,判断业务平台A是否有该业务数据,如果有则通知业务平台A和业务平台B该条业务数据稽核正常,业务平台A和业务平台B更新该条数据的稽核状态;After the audit platform receives the business data of business platform B, it determines whether business platform A has the business data, and if so, notifies business platform A and business platform B that the business data audit is normal, and business platform A and business platform B update the article. the audit status of the data;
稽核平台如果未找到业务平台A有该条业务数据,则通知业务平台B该条业务数据稽核异常。If the audit platform does not find that business platform A has this piece of business data, it will notify business platform B that the audit of this piece of business data is abnormal.
业务平台B定时任务定时处理平台B中所有业务数据稽核结果异常的数据,发现超过设定的时间状态还异常的则记录日志,通知运维人员处理。The timed task of business platform B regularly processes all the data with abnormal business data audit results in platform B. If it is found that the status is abnormal beyond the set time, it will record the log and notify the operation and maintenance personnel to deal with it.
基于上述任一实施例,图5是本发明提供的基于区块链的稽核平台的结构示意图,如图5所示,稽核平台包括:Based on any of the above embodiments, FIG. 5 is a schematic structural diagram of a blockchain-based audit platform provided by the present invention. As shown in FIG. 5 , the audit platform includes:
上链存储单元510,用于接收任一业务平台在完成数据同步后的待稽核数据,将所述待稽核数据上链存储至所述任一业务平台的业务数据中;The on-
链上查询单元520,用于链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果,所述关联业务平台是与所述任一业务平台进行数据同步的业务平台。The on-
本发明实施例提供的稽核平台,将各业务平台的业务数据同步到区块链,从而保证了稽核平台和业务平台之间数据同步的可靠性、健壮性。链上比对不同业务平台的业务数据,为不可信平台之间提供了一种信任补充机制,且在完成业务数据稽核的同时,保证了稽核方法可以扩展适应各种业务稽核场景,且不影响目前的业务流程,在现有平台的基础上改动小,易于部署和实施。The audit platform provided by the embodiment of the present invention synchronizes the business data of each business platform to the blockchain, thereby ensuring the reliability and robustness of data synchronization between the audit platform and the business platform. Comparing the business data of different business platforms on the chain provides a trust supplement mechanism between untrusted platforms, and while completing the business data audit, it ensures that the audit method can be extended to adapt to various business audit scenarios without affecting the The current business process, based on the existing platform, is easy to deploy and implement with minor changes.
基于上述任一实施例,链上查询单元520用于:Based on any of the above embodiments, the on-
基于稽核智能合约,链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据;Based on the audit smart contract, query on the chain whether the business data of the associated business platform contains data consistent with the data to be audited;
若包含,则确定所述稽核结果为正常,否则确定所述稽核结果为异常。If included, the audit result is determined to be normal; otherwise, the audit result is determined to be abnormal.
基于上述任一实施例,上链存储单元510用于:Based on any of the above embodiments, the on-
基于上链智能合约,将所述待稽核数据上链存储至所述任一业务平台的业务数据中。Based on the on-chain smart contract, the data to be audited is uploaded to the chain and stored in the business data of any of the business platforms.
基于上述任一实施例,稽核平台还包括结果返回单元,用于:Based on any of the above embodiments, the auditing platform further includes a result returning unit for:
若所述稽核结果为正常,则向所述任一业务平台和所述关联业务平台发送稽核正常通知,以供所述任一业务平台和所述关联业务平台将所述待稽核数据更新为正常数据;If the audit result is normal, send an audit normal notification to the any business platform and the associated business platform, so that the any business platform and the associated business platform can update the data to be audited to be normal data;
若所述稽核结果为异常,则向所述任一业务平台发送稽核异常通知,以供所述任一业务平台将所述待稽核数据更新为异常数据。If the audit result is abnormal, an audit abnormality notification is sent to any business platform, so that any business platform can update the data to be audited into abnormal data.
基于上述任一实施例,图6是本发明提供的业务平台的结构示意图,如图6所示,业务平台包括:Based on any of the above embodiments, FIG. 6 is a schematic structural diagram of a service platform provided by the present invention. As shown in FIG. 6 , the service platform includes:
数据同步单元610,用于与关联业务平台进行数据同步,得到完成数据同步后的待稽核数据;The
同步上传单元620,用于将所述待稽核数据发送至基于区块链的稽核平台,以触发所述稽核平台将所述待稽核数据上链存储至所述业务平台的业务数据中,并链上查询所述关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果。The
本发明实施例提供的业务平台,通过将业务数据同步到区块链,从而保证了稽核平台和业务平台之间数据同步的可靠性、健壮性。链上比对不同业务平台的业务数据,为不可信平台之间提供了一种信任补充机制,且在完成业务数据稽核的同时,保证了稽核方法可以扩展适应各种业务稽核场景,且不影响目前的业务流程,在现有平台的基础上改动小,易于部署和实施。The business platform provided by the embodiment of the present invention ensures the reliability and robustness of data synchronization between the audit platform and the business platform by synchronizing business data to the blockchain. Comparing the business data of different business platforms on the chain provides a trust supplement mechanism between untrusted platforms, and while completing the business data audit, it ensures that the audit method can be extended to adapt to various business audit scenarios without affecting the The current business process, based on the existing platform, is easy to deploy and implement with minor changes.
基于上述任一实施例,业务平台还包括数据更新单元,用于:Based on any of the above embodiments, the service platform further includes a data update unit for:
若接收到所述稽核结果为正常时所述稽核平台返回的稽核正常通知,则将所述待稽核数据更新为正常数据;If receiving a normal audit notification returned by the audit platform when the audit result is normal, update the data to be audited to normal data;
若接收到所述稽核结果为异常时所述稽核平台返回的稽核异常通知,则将所述待稽核数据更新为异常数据。If the audit abnormality notification returned by the audit platform when the audit result is abnormal is received, the data to be audited is updated to abnormal data.
基于上述任一实施例,业务平台还包括日志更新单元,用于:Based on any of the above embodiments, the business platform further includes a log update unit for:
每隔预设时间,基于本地存储的异常数据更新异常日志。Every preset time, the exception log is updated based on the locally stored exception data.
基于上述任一实施例,图7是本发明提供的业务数据稽核系统的结构示意图,如图7所示,该系统包括基于区块链的稽核平台710,以及多个业务平台720。Based on any of the above embodiments, FIG. 7 is a schematic structural diagram of a business data auditing system provided by the present invention. As shown in FIG. 7 , the system includes a blockchain-based
其中,稽核系统710基于区块链构建,区块链底层平台负责数据的打包、出块,上链智能合约负责数据上链,稽核智能合约符合数据链上稽核。业务平台通过DAAPP、智能合约与基于区块链的稽核系统进行交互。Among them, the
图8示例了一种电子设备的实体结构示意图,如图8所示,该电子设备可以包括:处理器(processor)810、通信接口(Communications Interface)820、存储器(memory)830和通信总线840,其中,处理器810,通信接口820,存储器830通过通信总线840完成相互间的通信。处理器810可以调用存储器830中的逻辑指令,以执行业务数据稽核方法,该方法包括:接收任一业务平台在完成数据同步后的待稽核数据,将所述待稽核数据上链存储至所述任一业务平台的业务数据中;链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果,所述关联业务平台是与所述任一业务平台进行数据同步的业务平台。FIG. 8 illustrates a schematic diagram of the physical structure of an electronic device. As shown in FIG. 8 , the electronic device may include: a processor (processor) 810, a communication interface (Communications Interface) 820, a memory (memory) 830, and a
处理器810还可以调用存储器830中的逻辑指令,以执行业务数据稽核方法,该方法包括:与关联业务平台进行数据同步,得到完成数据同步后的待稽核数据;将所述待稽核数据发送至基于区块链的稽核平台,以触发所述稽核平台将所述待稽核数据上链存储至所述业务平台的业务数据中,并链上查询所述关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果。The
此外,上述的存储器830中的逻辑指令可以通过软件功能单元的形式实现并作为独立的产品销售或使用时,可以存储在一个计算机可读取存储介质中。基于这样的理解,本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质中,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括:U盘、移动硬盘、只读存储器(ROM,Read-Only Memory)、随机存取存储器(RAM,Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质。In addition, the above-mentioned logic instructions in the
另一方面,本发明还提供一种计算机程序产品,所述计算机程序产品包括存储在非暂态计算机可读存储介质上的计算机程序,所述计算机程序包括程序指令,当所述程序指令被计算机执行时,计算机能够执行上述各方法所提供的业务数据稽核方法,该方法包括:接收任一业务平台在完成数据同步后的待稽核数据,将所述待稽核数据上链存储至所述任一业务平台的业务数据中;链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果,所述关联业务平台是与所述任一业务平台进行数据同步的业务平台。In another aspect, the present invention also provides a computer program product, the computer program product comprising a computer program stored on a non-transitory computer-readable storage medium, the computer program comprising program instructions, when the program instructions are executed by a computer When executing, the computer can execute the business data auditing method provided by the above methods, and the method includes: receiving data to be audited on any business platform after data synchronization is completed, and uploading the data to be audited on the chain and storing the data to any one of the In the business data of the business platform; query on the chain whether the business data of the associated business platform contains data consistent with the data to be audited, and determine the audit result of the data to be audited, and the associated business platform is related to any of the data to be audited. Business Platform A business platform for data synchronization.
本发明还提供一种计算机程序产品,所述计算机程序产品包括存储在非暂态计算机可读存储介质上的计算机程序,所述计算机程序包括程序指令,当所述程序指令被计算机执行时,计算机能够执行上述各方法所提供的业务数据稽核方法,该方法包括:与关联业务平台进行数据同步,得到完成数据同步后的待稽核数据;将所述待稽核数据发送至基于区块链的稽核平台,以触发所述稽核平台将所述待稽核数据上链存储至所述业务平台的业务数据中,并链上查询所述关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果。The present invention also provides a computer program product, the computer program product comprising a computer program stored on a non-transitory computer-readable storage medium, the computer program comprising program instructions, when the program instructions are executed by a computer, the computer program The business data auditing method provided by the above methods can be executed, and the method includes: synchronizing data with an associated business platform to obtain data to be audited after the data synchronization is completed; sending the data to be audited to a blockchain-based auditing platform , to trigger the audit platform to store the data to be audited on the chain to the business data of the business platform, and to query on the chain whether the business data of the associated business platform contains data consistent with the data to be audited , and determine the audit result of the data to be audited.
又一方面,本发明还提供一种非暂态计算机可读存储介质,其上存储有计算机程序,该计算机程序被处理器执行时实现以执行上述各提供的业务数据稽核方法,该方法包括:接收任一业务平台在完成数据同步后的待稽核数据,将所述待稽核数据上链存储至所述任一业务平台的业务数据中;链上查询关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果,所述关联业务平台是与所述任一业务平台进行数据同步的业务平台。In yet another aspect, the present invention also provides a non-transitory computer-readable storage medium on which a computer program is stored, and when the computer program is executed by a processor, is implemented to execute the above-mentioned business data auditing methods provided, the method comprising: Receive the data to be audited after the data synchronization of any business platform is completed, and store the data to be audited in the business data of any business platform on the chain; query on the chain whether the business data of the associated business platform contains the same The data to be audited is consistent with the data to be audited, the audit result of the data to be audited is determined, and the associated business platform is a business platform that synchronizes data with any of the business platforms.
本发明还提供一种非暂态计算机可读存储介质,其上存储有计算机程序,该计算机程序被处理器执行时实现以执行上述各提供的业务数据稽核方法,该方法包括:与关联业务平台进行数据同步,得到完成数据同步后的待稽核数据;将所述待稽核数据发送至基于区块链的稽核平台,以触发所述稽核平台将所述待稽核数据上链存储至所述业务平台的业务数据中,并链上查询所述关联业务平台的业务数据中是否包含与所述待稽核数据一致的数据,确定所述待稽核数据的稽核结果。The present invention also provides a non-transitory computer-readable storage medium on which a computer program is stored, the computer program is implemented by a processor to execute the business data auditing methods provided above, the method includes: associating with a business platform Perform data synchronization to obtain the data to be audited after the data synchronization is completed; send the data to be audited to the blockchain-based auditing platform to trigger the auditing platform to upload the data to be audited to the business platform Query the business data of the associated business platform on the chain to determine whether the business data of the associated business platform contains data consistent with the data to be audited, and determine the audit result of the data to be audited.
以上所描述的装置实施例仅仅是示意性的,其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,或者也可以分布到多个网络单元上。可以根据实际的需要选取其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下,即可以理解并实施。The device embodiments described above are only illustrative, wherein the units described as separate components may or may not be physically separated, and the components shown as units may or may not be physical units, that is, they may be located in One place, or it can be distributed over multiple network elements. Some or all of the modules may be selected according to actual needs to achieve the purpose of the solution in this embodiment. Those of ordinary skill in the art can understand and implement it without creative effort.
通过以上的实施方式的描述,本领域的技术人员可以清楚地了解到各实施方式可借助软件加必需的通用硬件平台的方式来实现,当然也可以通过硬件。基于这样的理解,上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品可以存储在计算机可读存储介质中,如ROM/RAM、磁碟、光盘等,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行各个实施例或者实施例的某些部分所述的方法。From the description of the above embodiments, those skilled in the art can clearly understand that each embodiment can be implemented by means of software plus a necessary general hardware platform, and certainly can also be implemented by hardware. Based on this understanding, the above-mentioned technical solutions can be embodied in the form of software products in essence or the parts that make contributions to the prior art, and the computer software products can be stored in computer-readable storage media, such as ROM/RAM, magnetic A disc, an optical disc, etc., includes several instructions for causing a computer device (which may be a personal computer, a server, or a network device, etc.) to perform the methods described in various embodiments or some parts of the embodiments.
最后应说明的是:以上实施例仅用以说明本发明的技术方案,而非对其限制;尽管参照前述实施例对本发明进行了详细的说明,本领域的普通技术人员应当理解:其依然可以对前述各实施例所记载的技术方案进行修改,或者对其中部分技术特征进行等同替换;而这些修改或者替换,并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。Finally, it should be noted that the above embodiments are only used to illustrate the technical solutions of the present invention, but not to limit them; although the present invention has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that it can still be The technical solutions described in the foregoing embodiments are modified, or some technical features thereof are equivalently replaced; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the spirit and scope of the technical solutions of the embodiments of the present invention.
Claims (10)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110304310.2A CN115114303A (en) | 2021-03-22 | 2021-03-22 | Service data auditing method, platform and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110304310.2A CN115114303A (en) | 2021-03-22 | 2021-03-22 | Service data auditing method, platform and system |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN115114303A true CN115114303A (en) | 2022-09-27 |
Family
ID=83323088
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110304310.2A Pending CN115114303A (en) | 2021-03-22 | 2021-03-22 | Service data auditing method, platform and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN115114303A (en) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| TWI812510B (en) * | 2022-10-17 | 2023-08-11 | 可立可資安股份有限公司 | Blockchain audit system |
| CN118364511A (en) * | 2024-06-17 | 2024-07-19 | 广州亚信技术有限公司 | Data auditing method, device, electronic equipment and storage medium |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105719185A (en) * | 2016-01-22 | 2016-06-29 | 杭州复杂美科技有限公司 | Block chain data comparison and consensus method |
| CN109522363A (en) * | 2018-10-18 | 2019-03-26 | 上海达家迎信息科技有限公司 | Cloud platform synchronous method, system, equipment and storage medium based on block chain |
| CN111259070A (en) * | 2019-11-28 | 2020-06-09 | 国网山东省电力公司 | Method and related device for storing and acquiring service data |
| CN111666287A (en) * | 2020-06-01 | 2020-09-15 | 北京思特奇信息技术股份有限公司 | Data auditing method based on block chain |
| CN111708794A (en) * | 2020-06-22 | 2020-09-25 | 中国平安财产保险股份有限公司 | Data comparison method and device based on big data platform and computer equipment |
| CN111727428A (en) * | 2017-11-20 | 2020-09-29 | 欧簿客科技股份有限公司 | Blockchain-based room inventory management system |
-
2021
- 2021-03-22 CN CN202110304310.2A patent/CN115114303A/en active Pending
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105719185A (en) * | 2016-01-22 | 2016-06-29 | 杭州复杂美科技有限公司 | Block chain data comparison and consensus method |
| CN111727428A (en) * | 2017-11-20 | 2020-09-29 | 欧簿客科技股份有限公司 | Blockchain-based room inventory management system |
| CN109522363A (en) * | 2018-10-18 | 2019-03-26 | 上海达家迎信息科技有限公司 | Cloud platform synchronous method, system, equipment and storage medium based on block chain |
| CN111259070A (en) * | 2019-11-28 | 2020-06-09 | 国网山东省电力公司 | Method and related device for storing and acquiring service data |
| CN111666287A (en) * | 2020-06-01 | 2020-09-15 | 北京思特奇信息技术股份有限公司 | Data auditing method based on block chain |
| CN111708794A (en) * | 2020-06-22 | 2020-09-25 | 中国平安财产保险股份有限公司 | Data comparison method and device based on big data platform and computer equipment |
Cited By (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| TWI812510B (en) * | 2022-10-17 | 2023-08-11 | 可立可資安股份有限公司 | Blockchain audit system |
| CN118364511A (en) * | 2024-06-17 | 2024-07-19 | 广州亚信技术有限公司 | Data auditing method, device, electronic equipment and storage medium |
| CN118364511B (en) * | 2024-06-17 | 2024-09-24 | 广州亚信技术有限公司 | Data auditing method, device, electronic equipment and storage medium |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| RU2438263C2 (en) | Methods and apparatus for dataset synchronisation in wireless environment | |
| US8719386B2 (en) | System and method for providing configuration synchronicity | |
| CN111124755A (en) | Fault recovery method, device, electronic device and storage medium for cluster nodes | |
| CN107870982B (en) | Data processing method, system and computer readable storage medium | |
| CN105512244A (en) | Database transaction processing method and device based on message queue | |
| CN111277639A (en) | Method and device for maintaining data consistency | |
| CN110457059A (en) | A kind of sequence number generation method and device based on redis | |
| CN111061498A (en) | Configuration information management system | |
| CN112732756A (en) | Data query method, device, equipment and storage medium | |
| CN113779153A (en) | A data synchronization method, device, electronic device and storage medium | |
| CN113064950A (en) | Data synchronization method, device, equipment and storage medium | |
| CN114328033B (en) | Method and device for maintaining service configuration consistency of high-availability equipment group | |
| CN115114303A (en) | Service data auditing method, platform and system | |
| CN114900531A (en) | Data synchronization method, device and system | |
| CN107688489A (en) | A kind of method and system of scheduler task | |
| CN112650629B (en) | Blockchain index data recovery method, device, equipment and computer storage medium | |
| CN111241200B (en) | Master-slave synchronous processing method and device based on SQLite database | |
| CN113760519B (en) | Distributed transaction processing method, device, system and electronic equipment | |
| CN115309582A (en) | Data auditing method and device, electronic equipment and storage medium | |
| CN110413686B (en) | Data writing method, device, equipment and storage medium | |
| US20200099788A1 (en) | Context data management interface for contact center | |
| CN110502460B (en) | Methods and Nodes for Data Processing | |
| CN110489208B (en) | Virtual machine configuration parameter checking method, system, computer equipment and storage medium | |
| CN112711466B (en) | Hanging affair inspection method and device, electronic equipment and storage medium | |
| CN115633046A (en) | Kafka high-availability scheme optimization method, device, equipment and storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination |