[go: up one dir, main page]

WO2020119115A1 - 数据审核方法、装置、设备及存储介质 - Google Patents

数据审核方法、装置、设备及存储介质 Download PDF

Info

Publication number
WO2020119115A1
WO2020119115A1 PCT/CN2019/095841 CN2019095841W WO2020119115A1 WO 2020119115 A1 WO2020119115 A1 WO 2020119115A1 CN 2019095841 W CN2019095841 W CN 2019095841W WO 2020119115 A1 WO2020119115 A1 WO 2020119115A1
Authority
WO
WIPO (PCT)
Prior art keywords
data
review
audit
reviewed
queue
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.)
Ceased
Application number
PCT/CN2019/095841
Other languages
English (en)
French (fr)
Inventor
罗成洋
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Ping An Medical and Healthcare Management Co Ltd
Original Assignee
Ping An Medical and Healthcare Management Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Ping An Medical and Healthcare Management Co Ltd filed Critical Ping An Medical and Healthcare Management Co Ltd
Publication of WO2020119115A1 publication Critical patent/WO2020119115A1/zh
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Classifications

    • 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
    • G06Q10/103—Workflow collaboration or project 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
    • G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
    • G06Q40/08—Insurance

Definitions

  • the present application relates to the field of data processing technology, and in particular, to a data review method, device, device, and computer-readable storage medium.
  • the main purpose of the present application is to provide a data review method, device, equipment, and computer-readable storage medium, which are aimed at solving the technical problems of low medical data review efficiency.
  • the present application provides a data review method, which includes the following steps:
  • each group of data to be reviewed in the current input queue is subject to parallel review, and each review result is sent to a preset message output queue to output each review result in parallel.
  • the step of grouping the data to be audited according to the number of queues in the current input queue, and correspondingly assigning the grouped data to be audited to the current input queue includes:
  • the classified data to be audited is grouped according to the data type, and the grouped data to be audited is allocated to the corresponding current input queue.
  • the plurality of preset review modules respectively conduct parallel review of each grouped data to be reviewed in the current input queue, and send each review result to a preset message output queue to output each in parallel
  • the steps to review the results include:
  • each type of grouped data to be audited is audited in parallel, and each audit result is sent to a preset message output queue to output each audit result in parallel.
  • the plurality of preset review modules respectively review each packet data to be reviewed in the current input queue in parallel, and send each review result to a preset message output queue to output each in parallel After the steps to review the results, it also includes:
  • the plurality of preset review modules respectively review each packet data to be reviewed in the current input queue in parallel, and send each review result to a preset message output queue to output each in parallel
  • the steps to review the results include:
  • each of the grouped data to be reviewed in the current input queue is subject to parallel review
  • each audit result is sent to a preset message output queue to output each audit result in parallel.
  • the method further includes:
  • the second review is performed on the group data to be reviewed corresponding to the abnormal review result through other review modules, and the review result of the second review is sent to the message output queue and the review result of the second review is output.
  • the data review method further includes:
  • the present application also provides a data review device, the data review device includes:
  • each of the grouped data to be reviewed in the current input queue is subject to parallel review, and each review result is sent to a preset message output queue to output each review result in parallel.
  • the present application also provides a data review device, the data review device includes a processor, a memory, and computer readable instructions stored on the memory and executable by the processor, wherein When the computer-readable instructions are executed by the processor, the steps of the data review method described above are implemented.
  • the present application also provides a computer-readable storage medium having computer-readable instructions stored on the computer-readable storage medium, wherein when the computer-readable instructions are executed by a processor, the implementation is as described above Of the data review method.
  • This application provides a data review method, that is, when a data review instruction is received, the data to be reviewed is obtained, and an idle input queue is obtained in a preset message input queue cluster as a current input queue; according to the current input The number of queues in the queue, grouping the data to be reviewed and grouping the grouped data to be reviewed to the current input queue; through several preset review modules, each of the current input queues The group data to be reviewed are subject to parallel review, and each review result is sent to a preset message output queue to output each review result in parallel.
  • this application adds a message input queue, and then groups the data to be reviewed, and through several review modules, parallel processing of the grouped data in each message input queue, and then parallel output through the preset message output queue Audit results.
  • FIG. 1 is a schematic diagram of a hardware structure of a data auditing device involved in an embodiment of this application;
  • FIG. 3 is a schematic flowchart of a second embodiment of the data review method of the application.
  • FIG. 5 is a schematic diagram of functional modules of the first embodiment of the data review device of the present application.
  • the data review method involved in the embodiments of the present application is mainly applied to data review equipment, and the data review equipment may be a device with display and processing functions such as a PC, a portable computer, and a mobile terminal.
  • FIG. 1 is a schematic diagram of a hardware structure of a data auditing device involved in an embodiment of the present application.
  • the data review device may include a processor 1001 (for example, a CPU), a communication bus 1002, a user interface 1003, a network interface 1004, and a memory 1005.
  • the communication bus 1002 is used to realize the connection and communication between these components;
  • the user interface 1003 may include a display (Display), an input unit such as a keyboard (Keyboard);
  • the network interface 1004 may optionally include a standard wired interface, a wireless interface (Such as WI-FI interface);
  • the memory 1005 can be a high-speed RAM memory or a stable memory (non-volatile memory), such as a disk storage, the storage 1005 may optionally be a storage device independent of the foregoing processor 1001.
  • FIG. 1 does not constitute a limitation on the data auditing device, and may include more or less components than those illustrated, or combine certain components, or arrange different components.
  • the memory 1005 in FIG. 1 as a computer-readable storage medium may include an operating system, a network communication module, and computer-readable instructions.
  • the network communication module is mainly used to connect to a server and perform data communication with the server; and the processor 1001 can call computer-readable instructions stored in the memory 1005 and execute the data review method provided by the embodiments of the present application.
  • the embodiments of the present application provide a data review method.
  • FIG. 2 is a schematic flowchart of a first embodiment of a data review method of this application.
  • the data review method includes the following steps:
  • Step S10 When receiving the data review instruction, obtain the data to be reviewed, and obtain the idle input queue in the preset message input queue cluster as the current input queue;
  • a data review method is provided, which is applied to the data review system.
  • the data review system includes a server and computer-readable instructions.
  • the data review system verifies medical review data in terms of the medical review data.
  • the medical review data is collected by the medical insurance provider during the entire process from claim settlement to payment of claims.
  • Related data the data to be reviewed specifically includes the diagnosis and treatment data (such as diagnosis results, medication conditions, and test conditions) generated during the insured’s treatment and the insured’s related cost data during the claims process (such as treatment settlement amount, medication cost details, Social security compensation amount, compensation amount, etc.).
  • the above medical audit data can be obtained as the data to be audited according to the audit items in the risk control audit rules.
  • the server constructs multiple message queues in advance to form a message queue cluster.
  • the message queue cluster may specifically include an input message queue cluster and an output message queue cluster.
  • the input message queue cluster is used to receive the original medical audit data
  • the output message queue cluster is used to receive the audit result of the medical audit data.
  • redis may be used as a message queue, and the message queue does not persistently store data (storing the message in memory and not persistently on devices such as hard disks).
  • the server receives the data review instruction triggered by the user through computer-readable instructions, it determines the message queue in the idle state in the input message queue cluster, and uses the idle message queue as the current input queue.
  • Step S20 Group the data to be audited according to the number of queues in the current input queue, and allocate the grouped data to be audited to the current input queue correspondingly;
  • data is grouped according to the current number of input queues, that is, the number of current input queues is the same as the number of groups to be reviewed.
  • random grouping methods such as random numbers, line numbers, and modulus can be used.
  • the grouped data to be reviewed can be randomly paired with the current input queue, and each grouped data to be reviewed can be sent to the corresponding current input queue.
  • different types of data to be reviewed may correspond to different message queues, and different types of message queues use corresponding processing processes to perform data review to improve the efficiency of data review.
  • Step S30 through a plurality of preset review modules, respectively reviewing each packet data to be reviewed in the current input queue in parallel, and sending each review result to a preset message output queue to output each review result in parallel.
  • each of the grouped data to be reviewed in the current input queue is processed in parallel by the review module preset in the server.
  • an audit module includes multiple audit processes. Each process runs the same computer-readable instructions, which are compiled according to the audit items in the risk control audit rules. Each process can contain one or more threads. Each process used for data review can separately read the medical data in each group data to be reviewed, and each current input queue can use one or more at the same time. The process reads and audits the packet data to be audited in the current input queue. In order to optimize resource allocation, the number of processes and the number of threads in each process can be determined according to the processing time required by the user and the amount of data that needs to be processed. Different types of data can run different processes for review.
  • each thread can review the extracted data in accordance with each audit item in the order in which the risk control audit rules are preset, and generate the corresponding audit results for the data items that failed the audit.
  • the audit results can be The details include the original data that failed the review, the reason for the failure, and the risk level.
  • Each thread sends the audit results in parallel.
  • the threads and the output message queue are randomly matched. Way to establish communication.
  • the server of the database can monitor the change data in each output message queue, read and save the change data in the output message queue. In the process of saving, according to different audit items, the failed data can be distributed and stored.
  • step S30 it further includes:
  • the review efficiency of each group data to be reviewed is calculated based on the number and review time.
  • the qualified audit efficiency is the audit efficiency that reaches a preset threshold.
  • a hardware upgrade prompt message is sent to remind the user to upgrade the hardware, such as increasing hardware resources and replacing hardware with higher processing power Resources etc.
  • This embodiment provides a data auditing method, that is, when a data auditing instruction is received, data to be audited is obtained, and an idle input queue is obtained in a preset message input queue cluster as a current input queue; according to the current The number of queues in the input queue, group the data to be audited, and allocate the grouped data to be audited to the current input queue correspondingly; through a number of preset audit modules, separate the current input queue Each group data to be reviewed is subject to parallel review, and each review result is sent to a preset message output queue to output each review result in parallel.
  • this application adds a message input queue, and then groups the data to be reviewed, and through several review modules, parallel processing of the grouped data in each message input queue, and then parallel output through the preset message output queue Audit results.
  • FIG. 3 is a schematic flowchart of a second embodiment of a data review method of this application.
  • the step S20 includes:
  • Step S21 classify the data to be reviewed according to the preset data type and the data identifier of the data to be reviewed;
  • different types of medical review data may correspond to different message queues, and different types of message queues use corresponding processing processes to perform data review to improve the efficiency of data review. Therefore, when the data to be audited is received, the data to be audited can be classified first according to the data type.
  • the data such as diagnosis results, medication conditions, and test conditions are divided into diagnosis and treatment data types, and data such as treatment settlement amount, medication cost details, social insurance compensation amounts, and compensation amounts are divided into expense data types.
  • Step S22 Obtain the number of types of data to be reviewed and the number of queues in the current input queue, and determine whether the number of types matches the number of queues;
  • the number of types of data to be reviewed and the number of queues in the current input queue are obtained, and the number of types is compared with the number of queues to determine whether the number of types is equal to the number of queues. If the number of queues in the current input queue is the same as the number of types of the data to be reviewed, data of each type can be allocated to each queue.
  • step S23 if the number of types matches the number of queues, the classified data to be reviewed is grouped according to the data type, and the grouped data to be reviewed is allocated to the corresponding current input queue.
  • each type of data can be allocated to each queue, so that different types of message queues are subject to corresponding processing processes for data review .
  • step S30 specifically includes:
  • each type of grouped data to be audited is audited in parallel, and each audit result is sent to a preset message output queue to output each audit result in parallel.
  • the grouping data type corresponding to each grouping data to be audited in the current input queue is determined, and then the auditing data type corresponding to each auditing module in the preset auditing module is obtained. Based on the grouping data type and auditing data type, the The data of each group to be audited is matched with each audit module.
  • Each message type can be associated with a message queue, and the same type of audit module can only process data in a certain message queue, or only process a specific type of message in each message queue. Multiple instances of the same type of audit module can be executed at the same time, processing data in parallel, and dynamically increasing the number of processing module instances to improve system throughput.
  • FIG. 4 is a schematic flowchart of a third embodiment of a data review method of this application.
  • step S10 it further includes:
  • Step S41 When receiving the data re-audit instruction, obtain the change data in each of the group data to be audited;
  • Step S42 Run several processes in the corresponding review module to review the change data in the corresponding group data to be reviewed in parallel;
  • Step S43 Send the audit results of each pending packet data to the message output queue, and read the audit result data in the message output queue in an asynchronous manner to output each audit result in parallel.
  • the other medical data uploaded by the user needs to be reviewed.
  • the received other medical data can be allocated to each group data to be reviewed.
  • Each input message queue can simultaneously use one or more processes to read and review the changed data in the input message queue.
  • the number of processes and the number of threads in each process can be determined according to the processing time required by the user and the amount of data that needs to be processed. Different types of data can run different processes for review. Determine the free message queue in the output message queue cluster as the message output queue, and send the audit result to any output message queue.
  • Each thread sends the audit result in parallel, and the communication between the thread and the output message queue is established in a random match.
  • the server of the database can monitor the change data in each message output queue, read and save the change data in the message output queue. In the process of saving, according to different audit items, the failed data can be distributed and stored.
  • step S30 it further includes:
  • each of the grouped data to be reviewed in the current input queue is subject to parallel review
  • each audit result is sent to a preset message output queue to output each audit result in parallel.
  • the second review is performed on the group data to be reviewed corresponding to the abnormal review result through other review modules, and the review result of the second review is sent to the message output queue and the review result of the second review is output.
  • a retry queue may be set up to save abnormal execution data, and other audit modules may be selected for re-execution according to the retry strategy.
  • Group data to be audited corresponding to the abnormal audit data where the group data to be audited corresponding to the abnormal audit data may be a specific piece of data or multiple pieces of data in the group data.
  • Add the to-be-audited grouping data corresponding to the abnormal audit data to the secondary audit queue, and perform the secondary audit by reviewing the audit module other than the abnormal audit data. Then, the audit results of the second audit are sent to the message output queue for parallel output.
  • embodiments of the present application also provide a data review device.
  • FIG. 5 is a schematic diagram of functional modules of the first embodiment of the data review device of the present application.
  • the data review device includes:
  • the queue generation module 10 is used to obtain data to be reviewed when receiving the data review instruction, and obtain an idle input queue in the preset message input queue cluster as the current input queue;
  • the data grouping module 20 is configured to group the data to be audited according to the number of queues in the current input queue, and allocate the grouped data to be audited to the current input queue correspondingly;
  • the parallel review module 30 is used to perform parallel review on each of the pending packet data in the current input queue through several preset review modules, and send each review result to a preset message output queue for parallel output The results of each audit.
  • the data review device further includes:
  • the efficiency calculation module is used to obtain the data quantity and audit time of each group data to be audited, and calculate each audit efficiency corresponding to each group data to be audited according to the data quantity and audit time;
  • the proportion judgment module is used to obtain the qualified audit efficiency among the respective audit efficiencies, and judge whether the proportion of the qualified audit efficiency reaches a standard proportion value, wherein the qualified audit efficiency is the audit efficiency that reaches a preset threshold;
  • the data grouping module 20 includes:
  • a data classification unit configured to classify the data to be reviewed according to a preset data type and a data identifier of the data to be reviewed;
  • a quantity judgment unit used to obtain the number of types of the data to be reviewed and the number of queues of the current input queue, and judge whether the number of types matches the number of queues;
  • the data grouping unit is configured to group the classified data to be reviewed according to the data type if the number of types matches the number of queues, and allocate the grouped data to be reviewed to the corresponding current input queue.
  • the parallel review module 30 includes:
  • a module matching unit configured to obtain several corresponding types of audit modules in the preset audit module according to the packet data types corresponding to each packet data to be audited in the current input queue;
  • the parallel review unit is used to perform parallel review on each type of grouped data to be reviewed through the corresponding review modules, and send each review result to a preset message output queue to output each review result in parallel .
  • the data review device further includes:
  • the data monitoring module is used to obtain the changed data in each of the grouped data to be reviewed when the data re-audit instruction is received;
  • the first review module is used to run several processes in the corresponding review module, and review the change data in the corresponding group data to be reviewed in parallel;
  • the first output module is used to send the audit results of each pending packet data to the message output queue, and read the audit result data in the message output queue in an asynchronous manner to output each audit result in parallel.
  • the data review device further includes:
  • a first review module configured to perform parallel review on each group data to be reviewed in the current input queue through several preset review modules
  • the abnormality judgment module is used to obtain the audit result corresponding to each of the grouped data to be audited and determine whether there is abnormal audit data in the audit result;
  • the second output module is used to send each audit result to a preset message output queue if the abnormal audit data does not exist to output each audit result in parallel.
  • a data adding module used to add the grouped data to be audited corresponding to the abnormal audit data to the preset secondary audit queue if the abnormal audit data exists;
  • the second review module is used to perform second review on the group data to be reviewed corresponding to the abnormal review result through other review modules, and send the review result of the second review to the message output queue and output the second review Audit results.
  • each module in the above-mentioned data auditing device corresponds to each step in the above-mentioned data auditing method embodiment, and its function and implementation process will not be repeated here one by one.
  • embodiments of the present application also provide a computer-readable storage medium, and the computer-readable storage medium may be a non-volatile readable storage medium.
  • the computer-readable storage medium of the present application stores computer-readable instructions, where the computer-readable instructions are executed by a processor to implement the steps of the data review method as described above.
  • the method implemented when the computer-readable instructions are executed can refer to various embodiments of the data review method of the present application, and details are not described herein again.
  • the methods in the above embodiments can be implemented by means of software plus a necessary general hardware platform, and of course, can also be implemented by hardware, but in many cases the former is better Implementation.
  • the technical solution of the present application can be embodied in the form of a software product in essence or part that contributes to the existing technology, and the computer software product is stored in a storage medium (such as ROM/RAM as described above) , Magnetic disk, optical disk), including several instructions to make a terminal device (which can be a mobile phone, computer, server, air conditioner, or network equipment, etc.) to perform the method described in each embodiment of the present application.

Landscapes

  • Business, Economics & Management (AREA)
  • Engineering & Computer Science (AREA)
  • Strategic Management (AREA)
  • Human Resources & Organizations (AREA)
  • Accounting & Taxation (AREA)
  • General Physics & Mathematics (AREA)
  • Economics (AREA)
  • Marketing (AREA)
  • Finance (AREA)
  • Entrepreneurship & Innovation (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Business, Economics & Management (AREA)
  • Quality & Reliability (AREA)
  • Tourism & Hospitality (AREA)
  • Data Mining & Analysis (AREA)
  • Operations Research (AREA)
  • Development Economics (AREA)
  • Technology Law (AREA)
  • Medical Treatment And Welfare Office Work (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

一种数据审核方法、装置、设备及存储介质，即在接收到数据审核指令时，获取待审核数据，并在预设的消息输入队列集群中获取空闲状态的输入队列，作为当前输入队列（S10）；根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列（S20）；通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果（S30）。所述方法在云端增设消息输入队列、进行数据分组，并通过若干个审核模块进行数据并行处理，提高了大批量医疗数据的审核效率，解决了现有医疗数据审核效率低下的技术问题。

Description

数据审核方法、装置、设备及存储介质
本申请要求于2018年12月13日提交中国专利局、申请号为201811525851.2、发明名称为“数据审核方法、装置、设备及存储介质”的中国专利申请的优先权，其全部内容通过引用结合在申请中。
技术领域
本申请涉及数据处理技术领域，尤其涉及一种数据审核方法、装置、设备及计算机可读存储介质。
背景技术
随着医疗费用的急剧上升，保险基金穿底的事件时有发生。因此，对医疗保险进行风险控制就显的十分重要与迫切。目前，由于医疗保险理赔的业务量不断增多，因此需要进行风险审核的医疗数据也大批量增加。目前医疗数据审核规则是按照接收医疗数据的先后顺序依次进行数据审核，导致现有医疗数据审核效率低下。
因此，如何解决现有医疗数据审核效率低下，成为了目前亟待解决的技术问题。
发明内容
本申请的主要目的在于提供一种数据审核方法、装置、设备及计算机可读存储介质，旨在解决现有医疗数据审核效率低下的技术问题。
为实现上述目的，本申请提供一种数据审核方法，所述数据审核方法包括以下步骤：
在接收到数据审核指令时，获取待审核数据，并在预设的消息输入队列集群中获取空闲状态的输入队列，作为当前输入队列；
根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列；
通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
可选地，所述根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列的步骤包括：
根据预设数据类型和所述待审核数据的数据标识，将所述待审核数据进行分类；
获取所述待审核数据的类型数量以及所述当前输入队列的队列数量，判断所述类型数量是否与所述队列数量相匹配；
若所述类型数量与所述队列数量相匹配，则将分类后的待审核数据按照数据类型进行分组，并将分组后的待审核分组数据分配至对应的当前输入队列。
可选地，所述通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果的步骤包括：
根据所述当前输入队列中各个待审核分组数据对应的分组数据类型，分别在所述预设审核模块中获取若干个对应类型的审核模块；
分别通过所述若干个对应类型的审核模块，对各个类型的待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
可选地，所述通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果的步骤之后，还包括：
在接收到数据再审核指令时，获取所述各个待审核分组数据中的变更数据；
运行对应审核模块中的若干个进程，分别将对应的待审核分组数据中的变更数据进行并行审核；
将各个待审分组数据的审核结果发送至所述消息输出队列，并通过异步方式读取所述消息输出队列中的审核结果数据，以并行输出各个审核结果。
可选地，所述通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果的步骤包括：
通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核；
获取所述各个待审核分组数据对应的审核结果，判断所述审核结果中是否存在异常审核数据；
若不存在所述异常审核数据，则将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
可选地，所述获取所述各个待审核分组数据对应的审核结果，判断所述审核结果中是否存在异常审核数据的步骤之后，还包括：
若存在所述异常审核数据，则将所述异常审核数据对应的待审核分组数据添加至预设二次审核队列；
通过其他审核模块对所述异常审核结果对应的待审核分组数据进行二次审核，将二次审核的审核结果发送至所述消息输出队列并输出所述二次审核的审核结果。
可选地，所述数据审核方法还包括：
获取各个待审核分组数据的数据数量以及审核时间，并根据所述数据数量和审核时间，计算各个待审核分组数据对应的各个审核效率；
获取所述各个审核效率中合格审核效率，并判断所述合格审核效率的占比是否达到标准比例值，其中，所述合格审核效率为达到预设阈值的审核效率；
若所述合格审核效率的占比未达到标准比例值，则生成并显示硬件需升级的提醒消息，以通过增加硬件资源而增多审核模块数量。
此外，为实现上述目的，本申请还提供一种数据审核装置，所述数据审核装置包括：
在接收到数据审核指令时，获取待审核数据，并在预设的消息输入队列集群中获取空闲状态的输入队列，作为当前输入队列；
根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列；
通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
此外，为实现上述目的，本申请还提供一种数据审核设备，所述数据审核设备包括处理器、存储器、以及存储在所述存储器上并可被所述处理器执行的计算机可读指令，其中所述计算机可读指令被所述处理器执行时，实现如上述的数据审核方法的步骤。
此外，为实现上述目的，本申请还提供一种计算机可读存储介质，所述计算机可读存储介质上存储有计算机可读指令，其中所述计算机可读指令被处理器执行时，实现如上述的数据审核方法的步骤。
本申请提供一种数据审核方法，即在接收到数据审核指令时，获取待审核数据，并在预设的消息输入队列集群中获取空闲状态的输入队列，作为当前输入队列；根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列；通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。通过上述方式，本申请增设消息输入队列，然后将待审核数据进行分组，并通过若干个审核模块，对各个消息输入队列中的待审核分组数据进行并行处理，然后通过预设消息输出队列并行输出审核结果。通过并行处理数据，提高了大批量医疗数据的审核效率，解决了现有医疗数据审核效率低下的技术问题。
附图说明
图1为本申请实施例方案中涉及的数据审核设备的硬件结构示意图；
图2为本申请数据审核方法第一实施例的流程示意图；
图3为本申请数据审核方法第二实施例的流程示意图；
图4为本申请数据审核方法第三实施例的流程示意图；
图5为本申请数据审核装置第一实施例的功能模块示意图。
本申请目的的实现、功能特点及优点将结合实施例，参照附图做进一步说明。
具体实施方式
应当理解，此处所描述的具体实施例仅仅用以解释本申请，并不用于限定本申请。
本申请实施例涉及的数据审核方法主要应用于数据审核设备，该数据审核设备可以是PC、便携计算机、移动终端等具有显示和处理功能的设备。
参照图1，图1为本申请实施例方案中涉及的数据审核设备的硬件结构示意图。本申请实施例中，数据审核设备可以包括处理器1001（例如CPU），通信总线1002，用户接口1003，网络接口1004，存储器1005。其中，通信总线1002用于实现这些组件之间的连接通信；用户接口1003可以包括显示屏（Display）、输入单元比如键盘（Keyboard）；网络接口1004可选的可以包括标准的有线接口、无线接口（如WI-FI接口）；存储器1005可以是高速RAM存储器，也可以是稳定的存储器（non-volatile memory），例如磁盘存储器，存储器1005可选的还可以是独立于前述处理器1001的存储装置。
本领域技术人员可以理解，图1中示出的硬件结构并不构成对数据审核设备的限定，可以包括比图示更多或更少的部件，或者组合某些部件，或者不同的部件布置。
继续参照图1，图1中作为一种计算机可读存储介质的存储器1005可以包括操作系统、网络通信模块以及计算机可读指令。
在图1中，网络通信模块主要用于连接服务器，与服务器进行数据通信；而处理器1001可以调用存储器1005中存储的计算机可读指令，并执行本申请实施例提供的数据审核方法。
本申请实施例提供了一种数据审核方法。
参照图2，图2为本申请数据审核方法第一实施例的流程示意图。
本实施例中，所述数据审核方法包括以下步骤：
步骤S10, 在接收到数据审核指令时，获取待审核数据，并在预设的消息输入队列集群中获取空闲状态的输入队列，作为当前输入队列；
本实施例中，为了解决现有医疗数据审核效率低下的技术问题，提供一种数据审核方法，应用于数据审核系统。所述数据审核系统包括服务器以及计算机可读指令。所述数据审核系统用语审核医疗审核数据，该医疗审核数据为医疗保险的被保险人在申请理赔到得到赔付的整个过程中，医疗保险的提供机构所收集的关于被保险人诊治过程、赔付过程的相关数据。其中，待审核数据具体包括被保险人治疗过程中产生的诊治数据（如诊断结果、用药情况、检验情况等）以及被保险人在理赔过程相关的费用数据（如治疗结算金额、用药费用明细、社保赔付金额、赔付金额等）。具体可根据风控审核规则中的审核项目获取上述医疗审核数据，作为待审核数据。具体地，服务器预先构建多个消息队列形成消息队列集群。消息队列集群可具体包括输入消息队列集群和输出消息队列集群，输入消息队列集群用于接收原始的医疗审核数据，输出消息队列集群用于接收医疗审核数据的审核结果。其中，本实施例可采用redis作为消息队列，消息队列不持久化存储数据(将消息保存到内存中，不持久化到硬盘等设备上)。服务器在接收到用户通过计算机可读指令触发的数据审核指令时，确定输入消息队列集群中处于空闲状态的消息队列，将空闲的消息队列作为当前输入队列。
步骤S20，根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列；
本实施例中，根据当前输入队列的队列数量进行数据分组，即当前输入队列的数量与待审核数据所分的组数相同。具体可采用随机分组的方式，如随机数、行号、取模等。分组后的各个待审核分组数据可与当前输入队列进行随机配对，将各个待审核分组数据分别发送至对应的当前输入队列。具体实施例，不同类型的待审核数据可对应有不同的消息队列，不同类型的消息队列采用对应的处理进程进行数据审核，以提高数据审核的效率。
步骤S30，通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
本实施例中，通过服务器中预置的审核模块并行处理当前输入队列中的各个待审核分组数据。其中，一个审核模块包括多个审核进程。每个进程运行同样的计算机可读指令，计算机可读指令根据风控审核规则中的审核项目进行编译。每个进程中可包含一个或多个线程，用于数据审核的每个进程可分别对各个待审核分组数据中的医疗数据进行异步读取，每个当前输入队列可分别同时采用一个或多个进程对该当前输入队列中的待审核分组数据进行读取以及审核。为了优化资源配置，进程的数量及每个进程中线程的数量具体可依据用户需求的处理时间以及需要处理的数据量进行确定，不同类型的数据可运行不同的进程进行审核。采用随机分配的方式为各个当前输入队列分配进程及其对应的线程进行数据读取以及审核。从各个输入消息队列中选取与所分配的线程数一样个数的数据，多个进程同步对当前输入队列中的待审核分组数据进行处理。在数据审核的过程中，每个线程可按照风控审核规则中的预设顺序依次按照每个审核项目对提取相应数据进行审核，将审核不通过的数据项生成相应的审核结果，审核结果可具体包括审核不通过的原始数据、不通过的判定原因、风险等级等。在确定审核结果后，确定输出消息队列集群中空闲的消息队列作为输出消息队列，将审核结果发送至任意一个输出消息队列，各线程并行发送审核结果，线程与输出消息队列之间按照随机匹配的方式建立通讯。数据库的服务器可对各个输出消息队列中的变更数据进行监控，读取输出消息队列中的变更数据并进行保存。在保存的过程中，可按照不同的审核项目对审核不通过的数据进行分布式存储。
进一步地，所述步骤S30之后，还包括：
获取各个待审核分组数据的数据数量以及审核时间，并根据所述数据数量和审核时间，计算各个待审核分组数据对应的各个审核效率；
获取所述各个审核效率中合格审核效率，并判断所述合格审核效率的占比是否达到标准比例值，其中，所述合格审核效率为达到预设阈值的审核效率；
若所述合格审核效率的占比未达到标准比例值，则生成并显示硬件需升级的提醒消息，以通过增加硬件资源而增多审核模块数量。
本实施例中，在预设次按照上述方式进行审核后，获取各个待审核分组数据的数量及其审核时间（即审核完成时间），根据数量和审核时间计算各个待审核分组数据的审核效率。确定各个审核效率中达到标准的合格审核效率数目，并计算所述合格审核效率占各个审核效率总数的比例。其中，所述合格审核效率为达到预设阈值的审核效率。并在所述合格审核效率的占比未达到标准比例至时，即当前审核效率低下，发出硬件升级的提示信息，以提醒用户对硬件进行升级，如增加硬件资源、更换处理能力更高的硬件资源等。
本实施例提供一种数据审核方法，即在接收到数据审核指令时，获取待审核数据，并在预设的消息输入队列集群中获取空闲状态的输入队列，作为当前输入队列；根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列；通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。通过上述方式，本申请增设消息输入队列，然后将待审核数据进行分组，并通过若干个审核模块，对各个消息输入队列中的待审核分组数据进行并行处理，然后通过预设消息输出队列并行输出审核结果。通过并行处理数据，提高了大批量医疗数据的审核效率，解决了现有医疗数据审核效率低下的技术问题。
参照图3，图3为本申请数据审核方法第二实施例的流程示意图。
基于上述图2所示实施例，本实施例中，所述步骤S20包括：
步骤S21，根据预设数据类型和所述待审核数据的数据标识，将所述待审核数据进行分类；
本实施例中，不同类型的医疗审核数据可对应有不同的消息队列，不同类型的消息队列采用对应的处理进程进行数据审核，以提高数据审核的效率。因此，在接收到待审核数据时，可先将待审核数据按照数据类型进行分类。即将诊断结果、用药情况、检验情况等数据划分为诊治数据类型，将治疗结算金额、用药费用明细、社保赔付金额、赔付金额等数据划分为费用数据类型等。
步骤S22，获取所述待审核数据的类型数量以及所述当前输入队列的队列数量，判断所述类型数量是否与所述队列数量相匹配；
本实施例中，获取待审核数据的类型数量以及当前输入队列的队列数量，并将类型数量与所述队列数量进行比对，判断所述类型数量是否与队列数量相等。若当前输入队列的队列数量与所述待审核数据的类型数量相同，即可将各个类型的数据分配至各个队列。
步骤S23，若所述类型数量与所述队列数量相匹配，则将分类后的待审核数据按照数据类型进行分组，并将分组后的待审核分组数据分配至对应的当前输入队列。
本实施例中，若当前输入队列的队列数量与所述待审核数据的类型数量相同，即可将各个类型的数据分配至各个队列，以将不同类型的消息队列采用对应的处理进程进行数据审核。
进一步地，所述步骤S30具体包括：
根据所述当前输入队列中各个待审核分组数据对应的分组数据类型，分别在所述预设审核模块中获取若干个对应类型的审核模块；
分别通过所述若干个对应类型的审核模块，对各个类型的待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
本实施例中，确定当前输入队列中各个待审核分组数据对应的分组数据类型，然后获取预设审核模块中各个审核模块对应的审核数据类型，根据所述分组数据类型和审核数据类型，将所述各个待审核分组数据与各个审核模块进行匹配。可将每个消息类型对应一个消息队列，同一类型的审核模块只处理某一消息队列中的数据，或者只处理各个消息队列中某一特定类型的消息。多个同类型审核模块实例可同时执行，并行性地处理数据，还可动态增加处理模块实例，提高系统吞吐率。
参照图4，图4为本申请数据审核方法第三实施例的流程示意图。
基于上述图3所示实施例，本实施例中，所述步骤S10之后，还包括：
步骤S41，在接收到数据再审核指令时，获取所述各个待审核分组数据中的变更数据；
步骤S42，运行对应审核模块中的若干个进程，分别将对应的待审核分组数据中的变更数据进行并行审核；
步骤S43，将各个待审分组数据的审核结果发送至所述消息输出队列，并通过异步方式读取所述消息输出队列中的审核结果数据，以并行输出各个审核结果。
本实施例中，在审核完成后，若再次接收到用户上传的其他医疗数据操作触发的数据再审核指令时，即需要对用户上传的其他医疗数据进行审核。可将接收到的其他医疗数据，对应分配至各个待审核分组数据中。每个输入消息队列可分别同时采用一个或多个进程对该输入消息队列中的变更数据进行读取以及审核。为了优化资源配置，进程的数量及每个进程中线程的数量具体可依据用户需求的处理时间以及需要处理的数据量进行确定，不同类型的数据可运行不同的进程进行审核。确定输出消息队列集群中空闲的消息队列作为消息输出队列，将审核结果发送至任意一个输出消息队列，各线程并行发送审核结果，线程与输出消息队列之间按照随机匹配的方式建立通讯。数据库的服务器可对各个消息输出队列中的变更数据进行监控，读取消息输出队列中的变更数据并进行保存。在保存的过程中，可按照不同的审核项目对审核不通过的数据进行分布式存储。
进一步地，所述步骤S30之后，还包括：
通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核；
获取所述各个待审核分组数据对应的审核结果，判断所述审核结果中是否存在异常审核数据；
若不存在所述异常审核数据，则将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
若存在所述异常审核数据，则将所述异常审核数据对应的待审核分组数据添加至预设二次审核队列；
通过其他审核模块对所述异常审核结果对应的待审核分组数据进行二次审核，将二次审核的审核结果发送至所述消息输出队列并输出所述二次审核的审核结果。
本实施例中，可设置重试队列，保存执行异常的数据，根据重试策略选择其他审核模块重新执行。在通过若干个审核模块审核完所述当前输入队列中的各个待审核分组数据之后，判断是否存在异常审核数据，如审核过程被中断，审核结果参数为错误参数等。将该异常审核数据对应的待审核分组数据，其中，该异常审核数据对应的待审核分组数据可以是分组数据中具体的某一条数据或者多条数据。将该异常审核数据对应的待审核分组数据添加至二次审核队列中，并通过审核出该异常审核数据之外的审核模块进行二次审核。然后将将二次审核的审核结果发送至所述消息输出队列进行并行输出。
此外，本申请实施例还提供一种数据审核装置。
参照图5，图5为本申请数据审核装置第一实施例的功能模块示意图。
本实施例中，所述数据审核装置包括：
队列生成模块10，用于在接收到数据审核指令时，获取待审核数据，并在预设的消息输入队列集群中获取空闲状态的输入队列，作为当前输入队列；
数据分组模块20，用于根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列；
并行审核模块30，用于通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
进一步地，所述数据审核装置还包括：
效率计算模块，用于获取各个待审核分组数据的数据数量以及审核时间，并根据所述数据数量和审核时间，计算各个待审核分组数据对应的各个审核效率；
占比判断模块，用于获取所述各个审核效率中合格审核效率，并判断所述合格审核效率的占比是否达到标准比例值，其中，所述合格审核效率为达到预设阈值的审核效率；
若所述合格审核效率的占比未达到标准比例值，则生成并显示硬件需升级的提醒消息，以通过增加硬件资源而增多审核模块数量。
进一步地，所述数据分组模块20包括：
数据分类单元，用于根据预设数据类型和所述待审核数据的数据标识，将所述待审核数据进行分类；
数量判断单元，用于获取所述待审核数据的类型数量以及所述当前输入队列的队列数量，判断所述类型数量是否与所述队列数量相匹配；
数据分组单元，用于若所述类型数量与所述队列数量相匹配，则将分类后的待审核数据按照数据类型进行分组，并将分组后的待审核分组数据分配至对应的当前输入队列。
进一步地，所述并行审核模块30包括：
模块匹配单元，用于根据所述当前输入队列中各个待审核分组数据对应的分组数据类型，分别在所述预设审核模块中获取若干个对应类型的审核模块；
并行审核单元，用于分别通过所述若干个对应类型的审核模块，对各个类型的待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
进一步地，所述数据审核装置还包括：
数据监控模块，用于在接收到数据再审核指令时，获取所述各个待审核分组数据中的变更数据；
第一审核模块，用于运行对应审核模块中的若干个进程，分别将对应的待审核分组数据中的变更数据进行并行审核；
第一输出模块，用于将各个待审分组数据的审核结果发送至所述消息输出队列，并通过异步方式读取所述消息输出队列中的审核结果数据，以并行输出各个审核结果。
进一步地，所述数据审核装置还包括：
第一审核模块，用于通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核；
异常判断模块，用于获取所述各个待审核分组数据对应的审核结果，判断所述审核结果中是否存在异常审核数据；
第二输出模块，用于若不存在所述异常审核数据，则将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
数据添加模块，用于若存在所述异常审核数据，则将所述异常审核数据对应的待审核分组数据添加至预设二次审核队列；
二次审核模块，用于通过其他审核模块对所述异常审核结果对应的待审核分组数据进行二次审核，将二次审核的审核结果发送至所述消息输出队列并输出所述二次审核的审核结果。
其中，上述数据审核装置中各个模块与上述数据审核方法实施例中各步骤相对应，其功能和实现过程在此处不再一一赘述。
此外，本申请实施例还提供一种计算机可读存储介质，所述计算机可读存储介质可以为非易失性可读存储介质。
本申请计算机可读存储介质上存储有计算机可读指令，其中所述计算机可读指令被处理器执行时，实现如上述的数据审核方法的步骤。
其中，计算机可读指令被执行时所实现的方法可参照本申请数据审核方法的各个实施例，此处不再赘述。
需要说明的是，在本文中，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者系统不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者系统所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括该要素的过程、方法、物品或者系统中还存在另外的相同要素。
上述本申请实施例序号仅仅为了描述，不代表实施例的优劣。
通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本申请的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品存储在如上所述的一个存储介质(如ROM/RAM、磁碟、光盘)中，包括若干指令用以使得一台终端设备(可以是手机，计算机，服务器，空调器，或者网络设备等)执行本申请各个实施例所述的方法。
以上仅为本申请的优选实施例，并非因此限制本申请的专利范围，凡是利用本申请说明书及附图内容所作的等效结构或等效流程变换，或直接或间接运用在其他相关的技术领域，均同理包括在本申请的专利保护范围内。

Claims (20)

  1. 一种数据审核方法，其特征在于，所述数据审核方法包括以下步骤：
    在接收到数据审核指令时，获取待审核数据，并在预设的消息输入队列集群中获取空闲状态的输入队列，作为当前输入队列；
    根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列；
    通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
  2. 如权利要求1所述的数据审核方法，其特征在于，所述根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列的步骤包括：
    根据预设数据类型和所述待审核数据的数据标识，将所述待审核数据进行分类；
    获取所述待审核数据的类型数量以及所述当前输入队列的队列数量，判断所述类型数量是否与所述队列数量相匹配；
    若所述类型数量与所述队列数量相匹配，则将分类后的待审核数据按照数据类型进行分组，并将分组后的待审核分组数据分配至对应的当前输入队列。
  3. 如权利要求2所述的数据审核方法，其特征在于，所述通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果的步骤包括：
    根据所述当前输入队列中各个待审核分组数据对应的分组数据类型，分别在所述预设审核模块中获取若干个对应类型的审核模块；
    分别通过所述若干个对应类型的审核模块，对各个类型的待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
  4. 如权利要求1所述的数据审核方法，其特征在于，所述通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果的步骤之后，还包括：
    在接收到数据再审核指令时，获取所述各个待审核分组数据中的变更数据；
    运行对应审核模块中的若干个进程，分别将对应的待审核分组数据中的变更数据进行并行审核；
    将各个待审分组数据的审核结果发送至所述消息输出队列，并通过异步方式读取所述消息输出队列中的审核结果数据，以并行输出各个审核结果。
  5. 如权利要求1所述的数据审核方法，其特征在于，所述通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果的步骤包括：
    通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核；
    获取所述各个待审核分组数据对应的审核结果，判断所述审核结果中是否存在异常审核数据；
    若不存在所述异常审核数据，则将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
  6. 如权利要求5所述的数据审核方法，其特征在于，所述获取所述各个待审核分组数据对应的审核结果，判断所述审核结果中是否存在异常审核数据的步骤之后，还包括：
    若存在所述异常审核数据，则将所述异常审核数据对应的待审核分组数据添加至预设二次审核队列；
    通过其他审核模块对所述异常审核结果对应的待审核分组数据进行二次审核，将二次审核的审核结果发送至所述消息输出队列并输出所述二次审核的审核结果。
  7. 如权利要求1所述的数据审核方法，其特征在于，所述数据审核方法还包括：
    获取各个待审核分组数据的数据数量以及审核时间，并根据所述数据数量和审核时间，计算各个待审核分组数据对应的各个审核效率；
    获取所述各个审核效率中合格审核效率，并判断所述合格审核效率的占比是否达到标准比例值，其中，所述合格审核效率为达到预设阈值的审核效率；
    若所述合格审核效率的占比未达到标准比例值，则生成并显示硬件需升级的提醒消息，以通过增加硬件资源而增多审核模块数量。
  8. 一种数据审核装置，其特征在于，所述数据审核装置包括：
    队列生成模块，用于在接收到数据审核指令时，获取待审核数据，并在预设的消息输入队列集群中获取空闲状态的输入队列，作为当前输入队列；
    数据分组模块，用于根据所述当前输入队列的队列数量，将所述待审核数据进行分组，并将分组后的待审核分组数据对应分配至所述当前输入队列；
    并行审核模块，用于通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
  9. 如权利要求8所述的数据审核装置，其特征在于，所述数据审核装置还包括：
    第一审核模块，用于通过若干个预设审核模块，分别对所述当前输入队列中的各个待审核分组数据进行并行审核；
    异常判断模块，用于获取所述各个待审核分组数据对应的审核结果，判断所述审核结果中是否存在异常审核数据；
    第二输出模块，用于若不存在所述异常审核数据，则将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
    数据添加模块，用于若存在所述异常审核数据，则将所述异常审核数据对应的待审核分组数据添加至预设二次审核队列；
    二次审核模块，用于通过其他审核模块对所述异常审核结果对应的待审核分组数据进行二次审核，将二次审核的审核结果发送至所述消息输出队列并输出所述二次审核的审核结果。
  10. 如权利要求8所述的数据审核装置，其特征在于，所述数据分组模块包括：
    数据分类单元，用于根据预设数据类型和所述待审核数据的数据标识，将所述待审核数据进行分类；
    数量判断单元，用于获取所述待审核数据的类型数量以及所述当前输入队列的队列数量，判断所述类型数量是否与所述队列数量相匹配；
    数据分组单元，用于若所述类型数量与所述队列数量相匹配，则将分类后的待审核数据按照数据类型进行分组，并将分组后的待审核分组数据分配至对应的当前输入队列。
  11. 如权利要求8所述的数据审核装置，其特征在于，所述并行审核模块包括：
    模块匹配单元，用于根据所述当前输入队列中各个待审核分组数据对应的分组数据类型，分别在所述预设审核模块中获取若干个对应类型的审核模块；
    并行审核单元，用于分别通过所述若干个对应类型的审核模块，对各个类型的待审核分组数据进行并行审核，并将各个审核结果发送至预设的消息输出队列，以并行输出各个审核结果。
  12. 如权利要求8所述的数据审核装置，其特征在于，所述数据审核装置还包括：
    数据监控模块，用于在接收到数据再审核指令时，获取所述各个待审核分组数据中的变更数据；
    第一审核模块，用于运行对应审核模块中的若干个进程，分别将对应的待审核分组数据中的变更数据进行并行审核；
    第一输出模块，用于将各个待审分组数据的审核结果发送至所述消息输出队列，并通过异步方式读取所述消息输出队列中的审核结果数据，以并行输出各个审核结果。
  13. 一种数据审核设备，其特征在于，所述数据审核设备包括处理器、存储器、以及存储在所述存储器上并可被所述处理器执行的计算机可读指令，其中所述计算机可读指令被所述处理器执行时，实现如权利要求1所述的数据审核方法的步骤。
  14. 一种数据审核设备，其特征在于，所述数据审核设备包括处理器、存储器、以及存储在所述存储器上并可被所述处理器执行的计算机可读指令，其中所述计算机可读指令被所述处理器执行时，实现如权利要求2所述的数据审核方法的步骤。
  15. 一种数据审核设备，其特征在于，所述数据审核设备包括处理器、存储器、以及存储在所述存储器上并可被所述处理器执行的计算机可读指令，其中所述计算机可读指令被所述处理器执行时，实现如权利要求3所述的数据审核方法的步骤。
  16. 一种数据审核设备，其特征在于，所述数据审核设备包括处理器、存储器、以及存储在所述存储器上并可被所述处理器执行的计算机可读指令，其中所述计算机可读指令被所述处理器执行时，实现如权利要求4所述的数据审核方法的步骤。
  17. 一种计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有计算机可读指令，其中所述计算机可读指令被处理器执行时，实现如权利要求1的数据审核方法的步骤。
  18. 一种计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有计算机可读指令，其中所述计算机可读指令被处理器执行时，实现如权利要求2的数据审核方法的步骤。
  19. 一种计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有计算机可读指令，其中所述计算机可读指令被处理器执行时，实现如权利要求3的数据审核方法的步骤。
  20. 一种计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有计算机可读指令，其中所述计算机可读指令被处理器执行时，实现如权利要求4的数据审核方法的步骤。
PCT/CN2019/095841 2018-12-13 2019-07-12 数据审核方法、装置、设备及存储介质 Ceased WO2020119115A1 (zh)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN201811525851.2 2018-12-13
CN201811525851.2A CN109685454A (zh) 2018-12-13 2018-12-13 数据审核方法、装置、设备及存储介质

Publications (1)

Publication Number Publication Date
WO2020119115A1 true WO2020119115A1 (zh) 2020-06-18

Family

ID=66186614

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2019/095841 Ceased WO2020119115A1 (zh) 2018-12-13 2019-07-12 数据审核方法、装置、设备及存储介质

Country Status (2)

Country Link
CN (1) CN109685454A (zh)
WO (1) WO2020119115A1 (zh)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US11922026B2 (en) 2022-02-16 2024-03-05 T-Mobile Usa, Inc. Preventing data loss in a filesystem by creating duplicates of data in parallel, such as charging data in a wireless telecommunications network

Families Citing this family (11)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN109685454A (zh) * 2018-12-13 2019-04-26 平安医疗健康管理股份有限公司 数据审核方法、装置、设备及存储介质
CN110610344A (zh) * 2019-07-29 2019-12-24 黑龙江金域医学检验所有限公司 一种提高自动审核系统审核速度的方法、装置及设备
CN110648054B (zh) * 2019-09-04 2022-05-17 中国建设银行股份有限公司 机器人流程自动化的任务并行处理方法及装置
CN111240846A (zh) * 2020-01-15 2020-06-05 平安医疗健康管理股份有限公司 数据审核方法、装置、计算机设备和存储介质
CN111414585B (zh) * 2020-03-26 2023-05-05 深圳前海微众银行股份有限公司 变量管理方法、装置、设备及计算机可读存储介质
CN111639902A (zh) * 2020-04-29 2020-09-08 深圳壹账通智能科技有限公司 基于kafka的数据审核方法、控制装置及计算机设备、存储介质
CN111628859B (zh) * 2020-06-05 2021-01-05 上海创蓝文化传播有限公司 一种基于分布式高并发条件下审核短信文本的方法及装置
CN113779472B (zh) * 2021-07-30 2024-10-01 淘宝（中国）软件有限公司 内容审核方法、装置及电子设备
CN114003395B (zh) * 2021-09-17 2025-07-15 广州市网星信息技术有限公司 一种审核数据获取方法、装置、设备及存储介质
CN114255019B (zh) * 2022-03-01 2022-05-27 飞狐信息技术（天津）有限公司 一种数据推送方法及装置、存储介质及电子设备
CN115713368A (zh) * 2022-11-21 2023-02-24 加和（北京）信息科技有限公司 针对多客户多媒体的广告并行送审方法及装置

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2002096026A1 (en) * 2001-05-22 2002-11-28 Proquent Systems Corporation Service platform on wireless network
CN102158408A (zh) * 2011-04-01 2011-08-17 华为技术有限公司 数据流处理方法和装置
CN103078897A (zh) * 2012-11-29 2013-05-01 中山大学 一种实现Web业务细粒度分类与管理的系统
CN109685454A (zh) * 2018-12-13 2019-04-26 平安医疗健康管理股份有限公司 数据审核方法、装置、设备及存储介质

Family Cites Families (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108257029A (zh) * 2017-09-13 2018-07-06 平安科技（深圳）有限公司 保险数据审核方法、装置、计算机设备及可读存储介质
CN107784205B (zh) * 2017-10-17 2020-08-14 百度在线网络技术（北京）有限公司 一种用户产品审核的方法、装置、服务器和存储介质

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2002096026A1 (en) * 2001-05-22 2002-11-28 Proquent Systems Corporation Service platform on wireless network
CN102158408A (zh) * 2011-04-01 2011-08-17 华为技术有限公司 数据流处理方法和装置
CN103078897A (zh) * 2012-11-29 2013-05-01 中山大学 一种实现Web业务细粒度分类与管理的系统
CN109685454A (zh) * 2018-12-13 2019-04-26 平安医疗健康管理股份有限公司 数据审核方法、装置、设备及存储介质

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US11922026B2 (en) 2022-02-16 2024-03-05 T-Mobile Usa, Inc. Preventing data loss in a filesystem by creating duplicates of data in parallel, such as charging data in a wireless telecommunications network
US12248687B2 (en) 2022-02-16 2025-03-11 T-Mobile Usa, Inc. Preventing data loss in a filesystem by creating duplicates of data in parallel, such as charging data in a wireless telecommunications network

Also Published As

Publication number Publication date
CN109685454A (zh) 2019-04-26

Similar Documents

Publication Publication Date Title
WO2020119115A1 (zh) 数据审核方法、装置、设备及存储介质
WO2020015064A1 (zh) 系统故障处理方法、装置、设备及存储介质
WO2020147385A1 (zh) 数据录入方法、装置、终端及计算机可读存储介质
WO2020087981A1 (zh) 风控审核模型生成方法、装置、设备及可读存储介质
WO2020233077A1 (zh) 系统服务的监控方法、装置、设备及存储介质
WO2019037196A1 (zh) 任务分配方法、装置及计算机可读存储介质
WO2021027143A1 (zh) 信息推送方法、装置、设备及计算机可读存储介质
WO2020253135A1 (zh) 自动化分析方法、用户设备、存储介质及装置
WO2020119369A1 (zh) 智能it运维故障定位方法、装置、设备及可读存储介质
WO2020224246A1 (zh) 基于区块链的数据管理方法、装置、设备和存储介质
WO2020233089A1 (zh) 测试用例生成方法、装置、终端及计算机可读存储介质
WO2020253116A1 (zh) 数据跑批方法、装置、存储介质及集群中的成员主机
WO2020048047A1 (zh) 系统故障的预警方法、装置、设备及存储介质
WO2020098075A1 (zh) 金融数据处理方法、装置、设备和存储介质
WO2020107591A1 (zh) 重复投保限制方法、装置、设备及可读存储介质
WO2021003956A1 (zh) 产品信息的管理方法、装置、设备及存储介质
WO2020019405A1 (zh) 数据库监控方法、装置、设备及可读存储介质
WO2020224249A1 (zh) 基于区块链的事务处理方法、装置、设备及存储介质
WO2020233073A1 (zh) 区块链环境检测方法、设备、装置及存储介质
WO2020224250A1 (zh) 智能合约的触发方法、装置、设备及存储介质
WO2020062661A1 (zh) 合同数据一致性的核实方法、装置、设备及存储介质
WO2020015060A1 (zh) 用电量异常评估方法、装置、设备和计算机存储介质
WO2020220412A1 (zh) 基于零知识证明的公民隐私保护的方法、系统及存储介质
WO2020098078A1 (zh) Ocr训练样本的生成方法、装置、设备及可读存储介质
WO2020233060A1 (zh) 事件通知方法、事件通知服务器、存储介质及装置

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 19895625

Country of ref document: EP

Kind code of ref document: A1

NENP Non-entry into the national phase

Ref country code: DE

32PN Ep: public notification in the ep bulletin as address of the adressee cannot be established

Free format text: NOTING OF LOSS OF RIGHTS PURSUANT TO RULE 112(1) EPC (EPO FORM 1205A DATED 15/10/2021)

122 Ep: pct application non-entry in european phase

Ref document number: 19895625

Country of ref document: EP

Kind code of ref document: A1