CN113259878A - Call bill settlement method, system, electronic device and computer readable storage medium - Google Patents

Abstract

Translated fromChinese

本发明实施例提供了一种基于Actor模型的物联网话单结算方法、系统、电子设备及计算机可读存储介质，把话单文件处理分成五个独立的Actor任务，每个Actor节点互相隔离，独立处理，他们之间通过安全可靠的消息机制通知对方业务处理，在同等系统计算物理资源的情况下大大提高了运营商对物联网卡流量结算的运营管理效率，并且对系统的稳定性、数据的准确性、实效性都能够得到很大的提升。因此，本发明实施例提供的技术方案能够实现物联网话单流量高并发、高容错性、高性能集群处理的结算。

The embodiment of the present invention provides a method, system, electronic device, and computer-readable storage medium for bill settlement of the Internet of Things based on the Actor model, which divides the processing of the bill file into five independent Actor tasks, and each Actor node is isolated from each other, Independent processing, they notify each other of business processing through a safe and reliable message mechanism, which greatly improves the operator's operation and management efficiency of IoT card traffic settlement under the condition of the same system computing physical resources, and has a great impact on system stability and data. The accuracy and effectiveness can be greatly improved. Therefore, the technical solutions provided by the embodiments of the present invention can realize the settlement of IoT bill traffic with high concurrency, high fault tolerance, and high-performance cluster processing.

Description

Call bill settlement method, system, electronic device and computer readable storage medium

[ technical field ] A method for producing a semiconductor device

The invention relates to the technical field of mobile communication, in particular to an internet of things ticket settlement method and system based on an Actor model, electronic equipment and a computer readable storage medium.

[ background of the invention ]

With the revolution of wireless network communication technology and the explosive application development of the internet of things industry, the world enters a new era of interconnection of everything in various fields, mobile users including internet of things users also rapidly develop exponentially, and internet of things card telephone uniflow has operation requirements of various types, huge data, real-time management and the like, so that the effectiveness of internet of things card flow settlement is an important index for credit measurement of the internet of things users by an operator, and new challenges are provided for the operator in centralized operation and settlement of the internet of things card telephone uniflow.

The basic processing link of the Internet of things card flow settlement comprises the following steps: (1) the method comprises the steps of obtaining a ticket (2), sorting the ticket (3), analyzing the ticket (4), uploading the ticket (5), settling and warehousing. The traditional technical scheme for clearing the traffic of the internet of things card of an operator is to use a file processing framework to read a ticket file acquired from a business support system into a memory, and process the ticket file in a single-event sequential circulation mode according to a basic flow of traffic settlement, wherein the specific flow is shown in fig. 1.

In the process of implementing the invention, the inventor finds that at least the following problems exist in the prior art:

1) the call ticket file single event sequence circulation processing flow is adopted, only the call ticket files can be processed one by one according to the rule sequence, the steps of each event processing process are too many, the efficiency is low, the phenomenon of large file system blocking is easy to occur, and the operation management of some users with higher requirements on timeliness is influenced.

2) During bill analysis and flow calculation, if the system is under the condition of multithreading, and simultaneously the bills of some large files are processed, a large amount of physical computing resources are consumed, faults such as system multithreading deadlock, message blocking, shared memory overflow and the like easily occur, the system stability is influenced, and the operation efficiency is low.

[ summary of the invention ]

In view of this, embodiments of the present invention provide an internet of things ticket settlement method, system, electronic device and computer-readable storage medium based on an Actor model, so as to solve the problems in the prior art that the internet of things ticket traffic calculation has too many steps, low efficiency, more resource consumption, easy occurrence of failure, and the like.

In a first aspect, an embodiment of the present invention provides a method for clearing a call ticket, including: the method comprises the steps of creating a model, wherein the Actor model is created when a call ticket file processing task is detected, the Actor model comprises a plurality of Actor nodes, the Actor nodes are communicated in a message transmission mode, and the Actor nodes comprise a supervision Actor node and at least one task node; and executing the tasks, namely calling the at least one task node by using the supervision Actor node to execute a call ticket acquisition task, a call ticket sorting task, a call ticket analysis task, a call ticket uploading task and a call ticket settlement task in parallel.

According to the scheme provided by the embodiment, the basic flow of the flow settlement of the internet of things card is optimized, the framework of parallel calculation of the Actor model is integrated into each link of the bill settlement of the internet of things card, and links such as bill acquisition, bill sorting, bill analysis, bill uploading and bill settlement in the bill settlement flow of the internet of things card are isolated and independently processed by establishing a plurality of Actor nodes. The method greatly improves the operation management efficiency of operators for the flow settlement of the Internet of things card under the condition that the same system calculates physical resources, and can greatly improve the stability, the data accuracy and the effectiveness of the system.

In a preferred implementation scheme, the plurality of Actor nodes are created simultaneously, and comprise a call ticket acquiring Actor node, a call ticket sorting Actor node, a call ticket analyzing Actor node, a call ticket uploading Actor node and a call ticket clearing Actor node; the call ticket acquisition Actor node informs the call ticket sorting Actor node of the received call ticket file in real time, and simultaneously monitors and receives a new call ticket file in a concurrent mode; after receiving the sorting notification, the call ticket sorting Actor node processes the sorting of the call ticket files in parallel, notifies the call ticket analysis Actor node to process the sorted call ticket files, and notifies the call ticket uploading Actor node to process the call ticket files to upload; the call ticket analysis Actor node decomposes the call ticket file into a plurality of call ticket record processing results, and notifies the settlement Actor node of the processing result of each call ticket record in real time; the call ticket uploading Actor node uploads the call ticket file after successful sorting to the terminal; the call ticket settlement Actor node processes the settlement of each call ticket record and obtains call ticket results, and each call ticket result is separately stored in a warehouse; the supervision Actor node is used for processing the working states and the life cycles of the call ticket acquisition Actor node, the call ticket sorting Actor node, the call ticket analysis Actor node, the call ticket uploading Actor node and the call ticket settlement Actor node.

According to the scheme provided by the embodiment, the call ticket acquisition Actor node, the call ticket sorting Actor node, the call ticket analysis Actor node, the call ticket uploading Actor node, the call ticket settlement Actor node and the supervision Actor node which are simultaneously created are used for processing call ticket flow settlement in parallel, so that the speed and the accuracy of call ticket file processing are improved, and the self-repairing capability of system operation is ensured.

In a preferred embodiment, each of the Actor nodes is decomposed into a plurality of sub Actor nodes for parsing the Actor task and a sub Actor supervision node for processing the working state and the life cycle of the sub Actor nodes when executing the Actor task.

Through the scheme provided by the embodiment, the correct work of each task is ensured, and the performance of the system is greatly improved.

In a preferred embodiment, a call ticket parsing sub-Actor node of the call ticket parsing Actor node is configured to classify a plurality of call ticket records in the call ticket file.

Through the scheme provided by the embodiment, the call ticket record can be orderly analyzed, the warehousing and filing are convenient, and the working efficiency of the system is improved.

In a preferred implementation, the call ticket acquiring Actor node may also be configured to monitor and receive a call ticket file in a server in real time.

By the scheme provided by the embodiment, the efficiency of receiving the ticket file by the system is further improved, and the working efficiency of the system is improved.

In a second aspect, an embodiment of the present invention provides a ticket settlement system, including a model creation module and a task execution module; the system comprises a model creating module, a task processing module and a task processing module, wherein the model creating module is used for creating an Actor model when a call ticket file processing task is detected, the Actor model comprises a plurality of Actor units, the Actor units are communicated in a message transmission mode, and the Actor units comprise a monitoring Actor unit and at least one task unit; the task execution module is used for calling the at least one task unit by using the supervision Actor unit to execute a call ticket acquisition task, a call ticket sorting task, a call ticket analysis task, a call ticket uploading task and a call ticket settlement task in parallel.

According to the scheme provided by the embodiment, the Actor model working mechanism is adopted, so that the parallel operation of all Actor units is guaranteed, the call ticket file receiving efficiency of the system is improved, the working efficiency of the system is improved, each Actor task only consumes hundreds of bytes, the quick release time of the system memory is guaranteed, the communication mechanism of the system components is transparent and non-blocking, millions of concurrent applications and treatments are allowed to exist in a single application program, the working efficiency of the system is very high, and the method is a high-reliability and high-elasticity cluster computing strategy.

In a preferred implementation scheme, the plurality of Actor units are created simultaneously, and comprise a call ticket acquiring Actor unit, a call ticket sorting Actor unit, a call ticket analyzing Actor unit, a call ticket uploading Actor unit and a call ticket clearing Actor unit; the call ticket acquisition Actor unit is used for informing the call ticket sorting Actor unit of the received call ticket file in real time and simultaneously monitoring and receiving a new call ticket file in a concurrent processing way; the call ticket sorting Actor unit is used for parallelly processing the sorting of the call ticket files after receiving the sorting notification, notifying the call ticket analysis Actor unit to process the sorted call ticket files and notifying the call ticket uploading Actor unit to process the call ticket files for uploading; the call ticket analysis Actor unit is used for decomposing the call ticket file into a plurality of call ticket record processing results and informing the call ticket settlement Actor unit of the processing result of each call ticket record in real time; the call ticket uploading Actor unit is used for uploading the successfully sorted call ticket file to the terminal; the call ticket settlement Actor unit is used for processing the settlement of each call ticket record and obtaining call ticket results, and separately storing each call ticket result; the supervision Actor unit is used for processing the working states and the life cycles of the call ticket acquisition Actor unit, the call ticket sorting Actor unit, the call ticket analysis Actor unit, the call ticket uploading Actor unit and the call ticket settlement Actor unit.

According to the scheme provided by the embodiment, the call ticket acquisition Actor unit, the call ticket sorting Actor unit, the call ticket analysis Actor unit, the call ticket uploading Actor unit, the call ticket settlement Actor unit and the supervision Actor unit which are simultaneously created are used for processing call ticket flow settlement in parallel, so that the speed and the accuracy of call ticket file processing are improved, and the self-repairing capability of system operation is ensured.

In a preferred embodiment, each Actor unit includes a plurality of sub-processing units and a sub-supervision unit, the sub-processing units are configured to analyze a plurality of call ticket records in the call ticket file after classifying the call ticket records, and the sub-supervision unit is configured to process a working state and a life cycle of the sub-processing units.

Through the scheme provided by the embodiment, correct work of each task is guaranteed, the performance of the system is greatly improved, ticket record analysis can be performed orderly, warehousing and filing are facilitated, and the working efficiency of the system is improved.

In a third aspect, an embodiment of the present invention provides an electronic device, where a storage unit stores a ticket settlement program; and the processing unit is used for executing the call ticket settlement method in the first aspect when the call ticket settlement program is operated.

In a fourth aspect, an embodiment of the present invention provides a computer-readable storage medium, where the computer-readable storage medium stores a ticket settlement system, and when executed by a processor, the ticket settlement system implements the ticket settlement method according to the first aspect.

Compared with the prior art, the technical scheme at least has the following beneficial effects:

1) the method has high concurrency, obviously improves the system analysis speed under the condition of the same physical resources, can realize the parallel and simultaneous processing of the flow steps of obtaining the conversation bill, sorting the bill, analyzing the bill, uploading the bill, settling and warehousing and the like, and provides guarantee for the credit management and the operation efficiency of the user.

2) The method has high fault tolerance, and the monitoring logic of the Actor model is utilized, so that the steps of call ticket acquisition, call ticket sorting, call ticket analysis, call ticket uploading and settlement warehousing in the service process are independently carried out without influencing each other, the abnormity of each step does not influence the normal processes of other steps, and the self-repairing operation management capability of the system abnormity is ensured.

3) The high-performance cluster processing establishes an Actor model cluster mechanism through a distributed network environment, and greatly improves the computing efficiency of a system and the centralized management capability of operators.

[ description of the drawings ]

In order to more clearly illustrate the technical solutions of the embodiments of the present invention, the drawings needed to be used in the embodiments will be briefly described below, and it is obvious that the drawings in the following description are only some embodiments of the present invention, and it is obvious for those skilled in the art to obtain other drawings based on these drawings without creative efforts.

FIG. 1 is a diagram illustrating an example of a flow of settlement of a card phone traffic of the Internet of things in the prior art;

fig. 2 is a flowchart of a method for clearing a call ticket according to embodiment 1 of the present invention;

fig. 3 is a schematic diagram of a call ticket flow calculation process of the call ticket settlement method provided in embodiment 1 of the present invention;

fig. 4 is a main flow chart of creation of an Actor task of a call ticket traffic settlement system of the call ticket settlement method provided in embodiment 1 of the present invention;

fig. 5 is a flow chart of Actor task decomposition and self-supervision of the call ticket settlement method provided in embodiment 1 of the present invention;

fig. 6 is a system diagram of a ticket settlement method provided in embodiment 2 of the present invention.

[ detailed description ] embodiments

For better understanding of the technical solutions of the present invention, the following detailed descriptions of the embodiments of the present invention are provided with reference to the accompanying drawings.

It should be understood that the described embodiments are only some embodiments of the invention, and not all embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.

The terminology used in the embodiments of the invention is for the purpose of describing particular embodiments only and is not intended to be limiting of the invention. As used in the examples of the present invention and the appended claims, the singular forms "a," "an," and "the" are intended to include the plural forms as well, unless the context clearly indicates otherwise.

As shown in fig. 1 to 6, wherein fig. 1 is a diagram illustrating a card-phone single flow settlement process of the internet of things in the prior art; fig. 2 is a flowchart of a method for clearing a call ticket according to embodiment 1 of the present invention; fig. 3 is a schematic diagram of a call ticket flow calculation process of the call ticket settlement method provided in embodiment 1 of the present invention; fig. 4 is a main flow chart of creation of an Actor task of a call ticket traffic settlement system of the call ticket settlement method provided in embodiment 1 of the present invention; fig. 5 is a flow chart of Actor task decomposition and self-supervision of the call ticket settlement method provided in embodiment 1 of the present invention; fig. 6 is a system diagram of a ticket settlement method provided in embodiment 2 of the present invention.

The traditional call ticket document event processing flow strictly carries out cyclic processing according to the sequence of five steps of call ticket acquisition, call ticket sorting, call ticket analysis, call ticket uploading and settlement and storage, and each event enters the next document processing event after the current five steps are correctly completed; in the meantime, once a micro error occurs in a certain step link, the current event flow is damaged and needs to be reprocessed.

The method, the system, the electronic equipment and the computer-readable storage medium for clearing the phone bill of the internet of things based on the Actor model provided by the embodiment 1 and the embodiment 2 improve the process, upgrade the system, divide the phone bill file processing into five independent Actor tasks, isolate and independently process each Actor, and inform the other party of service processing through a safe and reliable message mechanism. Because of the mass data volume and high receiving frequency of the telephone bill system in the Internet of things industry, the Actor model system has the characteristics of high concurrency, distribution and high fault tolerance, and is very suitable for analyzing and processing the card and telephone bill data of the Internet of things.

Example 1

As shown in fig. 2 to fig. 5, embodiment 1 of the present invention provides a method for clearing a call ticket, including: the method comprises the steps of creating a model, wherein the Actor model is created when a call ticket file processing task is detected, the Actor model comprises a plurality of Actor nodes, the Actor nodes are communicated in a message transmission mode, and the Actor nodes comprise a monitoring Actor node and at least one task node; and (4) executing the tasks, namely calling at least one task node by using the supervision Actor node to execute a call ticket acquisition task, a call ticket sorting task, a call ticket analysis task, a call ticket uploading task and a call ticket settlement task in parallel.

The method disclosed in this embodiment 1 optimizes a basic flow of traffic settlement of the internet of things card, integrates a framework of Actor model parallel computation into each link of call ticket settlement of the internet of things card, and isolates links of call ticket acquisition, call ticket sorting, call ticket analysis, call ticket uploading, call ticket settlement and the like in the call ticket settlement flow of the internet of things card by establishing a plurality of Actor nodes, and performs independent processing. The method greatly improves the operation management efficiency of operators for the flow settlement of the Internet of things card under the condition that the same system calculates physical resources, and can greatly improve the stability, the data accuracy and the effectiveness of the system.

In the method for clearing a call ticket disclosed in this embodiment 1, a plurality of Actor nodes are created at the same time, and include a call ticket acquiring Actor node, a call ticket sorting Actor node, a call ticket analyzing Actor node, a call ticket uploading Actor node, and a call ticket clearing Actor node; the call ticket acquisition Actor node informs the call ticket sorting Actor node of the received call ticket file in real time, and simultaneously monitors and receives a new call ticket file in a concurrent mode; after receiving the sorting notification, the call ticket sorting Actor node processes the sorting of the call ticket files in parallel, notifies the call ticket analysis Actor node to process the sorted call ticket files, and notifies the call ticket uploading Actor node to process the call ticket files to upload; the call ticket analysis Actor node decomposes the call ticket file into a plurality of call ticket record processing results, and informs the settlement Actor node of the processing result of each call ticket record in real time; the call ticket uploading Actor node uploads the call ticket file after successful sorting to the terminal; the call ticket settlement Actor node processes the settlement of each call ticket record and obtains call ticket results, and each call ticket result is separately stored in a warehouse; the supervision Actor node is used for processing the working states and life cycles of the call ticket acquisition Actor node, the call ticket sorting Actor node, the call ticket analysis Actor node, the call ticket uploading Actor node and the call ticket settlement Actor node, and the call ticket acquisition Actor node, the call ticket sorting Actor node, the call ticket analysis Actor node, the call ticket uploading Actor node, the call ticket settlement Actor node and the supervision Actor node which are simultaneously created are used for processing call ticket flow settlement in parallel, so that the speed and the accuracy of call ticket file processing are improved, and the self-repairing capability of system operation is ensured.

In the method for clearing a call ticket disclosed in this embodiment 1, each Actor node is decomposed into a plurality of sub Actor nodes and sub Actor surveillance nodes when executing an Actor task, the sub Actor nodes are used for analyzing the Actor task, and the sub Actor surveillance nodes are used for processing the working state and the life cycle of the sub Actor nodes, so that each task works correctly, and the performance of the system is greatly improved.

In the method for clearing a ticket disclosed in this embodiment 1, a ticket analysis sub Actor node of a ticket analysis Actor node is used to classify a plurality of ticket records in a ticket file, so that the ticket records can be orderly analyzed, warehousing and filing are facilitated, and system working efficiency is improved.

In the method for clearing a ticket disclosed in this embodiment 1, the ticket acquiring Actor node may also be configured to monitor and receive a ticket file in the server in real time, so as to further improve the efficiency of receiving the ticket file by the system and improve the working efficiency of the system.

Specifically, the method of this embodiment 1 creates several Actor tasks at the same time: the method comprises the following steps of call ticket obtaining Actor, call ticket sorting Actor, call ticket analyzing Actor, call ticket uploading Actor and call ticket clearing Actor.

As shown in fig. 2 to fig. 5, the whole settlement process is created by starting the Actor model through the system, the call ticket acquiring Actor task is used for receiving call ticket file notification of the FTP file server, when the FTP server acquires a new call ticket file, the call ticket is notified in real time through a message mechanism to sort the Actor task for processing, and simultaneously, the current call ticket acquiring Actor task also concurrently processes monitoring work and receiving task of the new call ticket file in real time.

The task of the call ticket sorting Actor synchronously and concurrently processes three message events: splitting a new call ticket file into a plurality of call ticket records, performing call ticket sorting processing, notifying a call ticket analysis Actor task to execute the call ticket analysis Actor task to process a newly received message event, and notifying a call ticket uploading Actor node to execute the call ticket uploading Actor task to process the newly received message event. In addition, the call ticket sorting Actor task can also back up the processed call ticket files.

And the call ticket analysis Actor task starts the content of the call ticket file to be analyzed. Due to the characteristics of the internet of things industry, each ticket file may contain data of multiple customer types such as different industries and different customer grades, and therefore each ticket file may contain tens of millions of ticket recording data. And the bill analysis Actor processes the analysis work of the bill file simultaneously through a recursion mechanism by decomposing a plurality of smaller sub Actor nodes. When the call ticket analysis Actor task completes each call ticket flow record in the call ticket file, the call ticket analysis Actor task feeds back a message to the call ticket settlement Actor task in real time, so that the file processing result is decomposed into the processing result of each call ticket record contained in the file, and the processing result of each call ticket record is abnormal and does not influence the processing result of other call ticket records.

The purpose of the call ticket uploading Actor task is to upload call ticket files after successful sorting to a client or a terminal of other management departments according to the rule requirements and the service requirements after receiving the message of the call ticket sorting Actor task.

The call ticket settlement Actor task is used for processing the settlement of each call ticket record, and the call ticket result obtained by the settlement of each call ticket record is independently used as an effective result to be put in storage. The operator node does not care about the overall processing condition of the call ticket file, and is responsible for the call ticket record after the file containing a plurality of call ticket records is analyzed and split, thereby greatly improving the fault tolerance and the working efficiency of the system.

A supervision Actor node used for overall management and used for self supervision is created at the root node of the five Actor nodes, and is used for processing the working states and the life cycles of various Actor nodes related to all Actor task flows in the system, so that the self-repairing capability of the system operation is ensured.

In the method disclosed in this embodiment 1, five independent Actor nodes of call ticket acquisition, call ticket sorting, call ticket analysis, call ticket uploading, and call ticket settlement may all adopt a method of decomposing a current Actor node into a plurality of smaller Actor nodes, for example, Actor 1 task processing node, Actor 2 task processing node … … Actor n task processing node, and meanwhile, a new sub supervision node manages and supervises details of analysis tasks of each Actor node, detects whether the analysis tasks are normally processed, ensures that each task works correctly, and greatly improves system performance.

In the method disclosed in this embodiment 1, the processing of the call ticket analysis Actor task is a key to improve the system working efficiency. According to the properties of different industries, different scenes and different customers, the sizes of the call ticket records contained in the call ticket files are different, and the priority level of each call ticket record needing to be processed in time is also different. The call ticket analysis Actor task can create a special Actor node according to the requirement to process the call ticket record in the call ticket file into different priority levels according to the preset Internet of things network number segment and the client property. And (4) each ticket record processed by the ticket analysis Actor task is filed as an effective result in a warehouse and is provided for a system as a final processing result without concerning the processing result of the whole ticket file.

Therefore, by using the ticket settlement method disclosed in this embodiment 1, the operation management efficiency of the operator for the traffic settlement of the internet of things card is greatly improved under the condition that the physical resources are calculated by the same system, and the stability, the data accuracy and the effectiveness of the system can be greatly improved.

Example 2

As shown in fig. 6, embodiment 2 of the present invention provides a call ticket settlement system, which adopts the call ticket settlement method provided in embodiment 1 of the present invention. The system comprises a model creating module and a task executing module; the system comprises a model creating module, a processing module and a processing module, wherein the model creating module is used for creating an Actor model when a call ticket file processing task is detected, the Actor model comprises a plurality of Actor units, the Actor units are communicated in a message transmission mode, and the Actor units comprise a monitoring Actor unit and at least one task unit; the task execution module is used for calling at least one task unit by using the supervision Actor unit to execute a call ticket acquisition task, a call ticket sorting task, a call ticket analysis task, a call ticket uploading task and a call ticket settlement task in parallel.

The system provided by this embodiment 2 adopts an Actor model working mechanism, ensures parallel operation of each Actor unit, improves the efficiency of receiving a ticket file by the system, improves the working efficiency of the system, and each Actor task only consumes hundreds of bytes, ensures that the release time of a system memory is fast, and the system component communication mechanism is transparent and non-blocking, allows millions of concurrent applications in a single application program to be processed, and has very high working efficiency, and is a high-reliability and high-elasticity cluster computing strategy.

In the call ticket settlement system disclosed in this embodiment 2, a plurality of Actor units are created at the same time, and include a call ticket acquiring Actor unit, a call ticket sorting Actor unit, a call ticket analyzing Actor unit, a call ticket uploading Actor unit, and a call ticket settlement Actor unit; the call ticket acquisition Actor unit is used for notifying the received call ticket file to the call ticket sorting Actor unit in real time and simultaneously monitoring and receiving a new call ticket file in a concurrent processing way; the call ticket sorting Actor unit is used for parallelly processing the sorting of the call ticket files after receiving the sorting notification, notifying the call ticket analysis Actor unit to process the sorted call ticket files and notifying the call ticket uploading Actor unit to process the call ticket files for uploading; the call ticket analysis Actor unit is used for decomposing the call ticket file into a plurality of call ticket record processing results and informing the call ticket settlement Actor unit of the processing result of each call ticket record in real time; the call ticket uploading Actor unit is used for uploading the successfully sorted call ticket file to the terminal; the call ticket settlement Actor unit is used for processing the settlement of each call ticket record and obtaining call ticket results, and separately storing each call ticket result; the supervision Actor unit is used for processing the working states and life cycles of the call ticket acquisition Actor unit, the call ticket sorting Actor unit, the call ticket analysis Actor unit, the call ticket uploading Actor unit and the call ticket settlement Actor unit, and the call ticket acquisition Actor unit, the call ticket sorting Actor unit, the call ticket analysis Actor unit, the call ticket uploading Actor unit, the call ticket settlement Actor unit and the supervision Actor unit which are simultaneously created are used for processing call ticket flow settlement in parallel, so that the speed and the accuracy of call ticket file processing are improved, and the self-repairing capability of system operation is ensured.

In the ticket settlement system disclosed in this embodiment 2, each Actor unit includes a plurality of sub-processing units and a sub-supervision unit, the sub-processing units are configured to analyze a plurality of ticket records in the ticket file after classifying the ticket records, and the sub-supervision unit is configured to process a working state and a life cycle of the sub-processing units, so as to ensure that each task works correctly, greatly improve the performance of the system, and enable the ticket records to be analyzed in order, thereby facilitating warehousing and filing, and improving the working efficiency of the system.

Example 3

Embodiment 3 of the present invention provides an electronic device, which includes a storage unit storing a ticket settlement program; and the processing unit is used for executing the call ticket settlement method in the first aspect when the call ticket settlement program is operated.

Example 4

An embodiment 4 of the present invention provides a computer-readable storage medium, where a ticket settlement system is stored on the computer-readable storage medium, and when the ticket settlement system is executed by a processor, the ticket settlement method in the first aspect is implemented.

Compared with the prior art, the technical scheme at least has the following beneficial effects:

1) high concurrency. Under the condition of the same physical resources, the system analysis speed is obviously improved, the parallel and simultaneous processing of the flow steps of dialog note acquisition, call note sorting, call note analysis, call note uploading, settlement and warehousing and the like can be realized, and the guarantee is provided for the credit management and the operation efficiency of the user.

2) The method has high fault tolerance, and the monitoring logic of the Actor model is utilized, so that the steps of call ticket acquisition, call ticket sorting, call ticket analysis, call ticket uploading and settlement warehousing in the service process are independently carried out without influencing each other, the abnormity of each step does not influence the normal processes of other steps, and the self-repairing operation management capability of the system abnormity is ensured.

3) The high-performance cluster processing establishes an Actor model cluster mechanism through a distributed network environment, and greatly improves the computing efficiency of a system and the centralized management capability of operators.

It is clear to those skilled in the art that, for convenience and brevity of description, the specific working processes of the above-described systems, apparatuses and units may refer to the corresponding processes in the foregoing method embodiments, and are not described herein again.

The above description is only for the purpose of illustrating the preferred embodiments of the present invention and is not to be construed as limiting the invention, and any modifications, equivalents, improvements and the like made within the spirit and principle of the present invention should be included in the scope of the present invention.

Claims (10)

Translated fromChinese

1.一种话单结算方法，其特征在于，所述方法包括：1. A bill settlement method, wherein the method comprises:模型创建，当检测到话单文件处理任务时，创建Actor模型，所述Actor模型包括多个Actor节点，所述多个Actor节点之间通过消息传递的方式通信，所述多个Actor节点包括监督Actor节点和至少一个任务节点；Model creation. When a CDR file processing task is detected, an Actor model is created. The Actor model includes multiple Actor nodes, and the multiple Actor nodes communicate through message passing, and the multiple Actor nodes include supervisory nodes. Actor node and at least one task node;任务执行，利用所述监督Actor节点调用所述至少一个任务节点并行执行话单获取任务、话单分拣任务、话单解析任务、话单上传任务和话单结算任务。For task execution, the supervising Actor node is used to call the at least one task node to execute the task of acquiring the bills, sorting the bills, parsing the bills, uploading the bills, and clearing the bills in parallel.2.根据权利要求1所述的话单结算方法，其特征在于，2. The bill settlement method according to claim 1, wherein,所述多个Actor节点同时创建，包括话单获取Actor节点、话单分拣Actor节点、话单解析Actor节点、话单上传Actor节点和话单结算Actor节点；The multiple Actor nodes are created at the same time, including the CDR obtaining Actor node, the CDR sorting Actor node, the CDR parsing Actor node, the CDR uploading Actor node, and the CDR settlement Actor node;所述话单获取Actor节点将接收到的话单文件实时通知话单分拣Actor节点，同时并发处理对新话单文件的监听和接收；The bill acquisition Actor node will notify the bill sorting Actor node of the received bill file in real time, and concurrently process the monitoring and reception of the new bill file;所述话单分拣Actor节点在接收到分拣通知后，并行处理话单文件的分拣、通知话单解析Actor节点处理分拣后的话单文件、通知话单上传Actor节点处理话单文件上传；After receiving the sorting notification, the CDR sorting Actor node processes the CDR file sorting in parallel, notifies the CDR parsing Actor node to process the CDR file after sorting, and notifies the CDR uploading Actor node to process the CDR file upload. ;所述话单解析Actor节点将话单文件分解成多个话单记录的处理结果，并将每个话单记录的处理结果实时通知所述结算Actor节点；The bill parsing Actor node decomposes the bill file into processing results of multiple bill records, and notifies the settlement Actor node of the processing result of each bill record in real time;所述话单上传Actor节点将分拣成功后的话单文件上传至终端；The bill uploading Actor node uploads the bill file to the terminal after the sorting is successful;所述话单结算Actor节点处理每个所述话单记录的结算并得出话单结果，将每个所述话单结果分别单独入库；The bill settlement Actor node processes the settlement of each of the bill records and obtains a bill result, and stores each of the bill results separately;所述监督Actor节点用于处理所述话单获取Actor节点、所述话单分拣Actor节点、所述话单解析Actor节点、所述话单上传Actor节点和所述结算入库Actor节点的工作状态和生命周期。The Supervising Actor node is used to process the work of the CDR acquisition Actor node, the CDR sorting Actor node, the CDR parsing Actor node, the CDR uploading Actor node, and the settlement and storage Actor node State and Lifecycle.3.根据权利要求1所述的话单结算方法，其特征在于，每个所述Actor节点在执行任务时均会分解成多个子Actor节点和子Actor监督节点，所述子Actor节点用于解析所述Actor任务，所述子Actor监督节点用于处理所述子Actor节点的工作状态和生命周期。3. The bill settlement method according to claim 1, wherein each of the Actor nodes is decomposed into a plurality of sub-Actor nodes and sub-Actor supervision nodes when performing tasks, and the sub-Actor nodes are used to parse the Actor task, the sub-Actor supervising node is used to process the working status and life cycle of the sub-Actor node.4.根据权利要求3所述的话单结算方法，其特征在于，所述话单解析Actor节点的话单解析子Actor节点用于将所述话单文件中的多个话单记录进行分级。4 . The bill settlement method according to claim 3 , wherein the bill parsing sub-Actor node of the bill parsing Actor node is used to classify multiple bill records in the bill file. 5 .5.根据权利要求1所述的话单结算方法，其特征在于，所述话单获取Actor节点还可用于对服务器中的话单文件进行实时监控和接收。5 . The bill settlement method according to claim 1 , wherein the bill acquiring Actor node can also be used to monitor and receive bill files in the server in real time. 6 .6.一种话单结算系统，其特征在于，所述系统包括模型创建模块和任务执行模块；6. A bill settlement system, wherein the system comprises a model creation module and a task execution module;所述模型创建模块用于当检测到话单文件处理任务时，创建Actor模型，所述Actor模型包括多个Actor单元，所述多个Actor单元之间通过消息传递的方式通信，所述多个Actor单元包括监督Actor单元和至少一个任务单元；The model creation module is configured to create an Actor model when a CDR file processing task is detected. The Actor model includes a plurality of Actor units. The Actor unit includes a supervisory Actor unit and at least one task unit;所述任务执行模块用于利用所述监督Actor单元调用所述至少一个任务单元并行执行话单获取任务、话单分拣任务、话单解析任务、话单上传任务和话单结算任务。The task execution module is configured to use the supervisory Actor unit to call the at least one task unit to execute the task of acquiring the bills, sorting the bills, parsing the bills, uploading the bills and settling the bills in parallel.7.根据权利要求6所述的话单结算系统，其特征在于，7. The bill settlement system according to claim 6, wherein,所述多个Actor单元同时创建，包括话单获取Actor单元、话单分拣Actor单元、话单解析Actor单元、话单上传Actor单元和话单结算Actor单元；The multiple Actor units are created at the same time, including the CDR obtaining Actor unit, the CDR sorting Actor unit, the CDR parsing Actor unit, the CDR uploading Actor unit, and the CDR settlement Actor unit;所述话单获取Actor单元用于将接收到的话单文件实时通知话单分拣Actor单元，同时并发处理对新话单文件的监听和接收；The CDR acquisition Actor unit is used to notify the CDR sorting Actor unit of the received CDR file in real time, and concurrently process the monitoring and reception of new CDR files;话单分拣Actor单元用于在接收到分拣通知后，并行处理话单文件的分拣、通知话单解析Actor单元处理分拣后的话单文件、通知话单上传Actor单元处理话单文件上传；CDR Sorting Actor unit is used to process CDR file sorting in parallel after receiving the sorting notification, notify CDR parsing Actor unit to process CDR files after sorting, and notify CDR upload Actor unit to process CDR file upload ;话单解析Actor单元用于将话单文件分解成多个话单记录的处理结果，并将每个话单记录的处理结果实时通知话单结算Actor单元；The bill parsing Actor unit is used to decompose the bill file into the processing results of multiple bill records, and notify the bill settlement Actor unit of the processing result of each bill record in real time;话单上传Actor单元用于将分拣成功后的话单文件上传至终端；The CDR uploading Actor unit is used to upload the CDR file to the terminal after the sorting is successful;话单结算Actor单元用于处理每个所述话单记录的结算并得出话单结果，将每个所述话单结果分别单独入库；The bill settlement Actor unit is used to process the settlement of each of the bill records and obtain a bill result, and store each of the bill results separately;所述监督Actor单元用于处理所述话单获取Actor单元、所述话单分拣Actor单元、所述话单解析Actor单元、所述话单上传Actor单元和所述话单结算Actor单元的工作状态和生命周期。The Supervising Actor unit is used to process the work of the CDR obtaining Actor unit, the CDR sorting Actor unit, the CDR parsing Actor unit, the CDR uploading Actor unit, and the CDR settlement Actor unit State and Lifecycle.8.根据权利要求6所述的话单结算系统，其特征在于，每个所述Actor单元均包括多个子处理单元和子监督单元，所述子处理单元用于将所述话单文件中的多个话单记录进行分级后进行解析，所述子监督单元用于处理所述子处理单元的工作状态和生命周期。8 . The bill settlement system according to claim 6 , wherein each of the Actor units comprises a plurality of sub-processing units and sub-supervision units, and the sub-processing units are configured to The phone bill record is classified and then parsed, and the sub-supervision unit is used to process the working status and life cycle of the sub-processing unit.9.一种电子设备，其特征在于，所述电子设备包括9. An electronic device, characterized in that the electronic device comprises存储单元，存储有话单结算程序；a storage unit, storing the bill settlement program;处理单元，用于在运行所述话单结算程序时，执行权利要求1至5任一项所述的话单结算方法。The processing unit is configured to execute the bill settlement method according to any one of claims 1 to 5 when running the bill settlement program.10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有话单结算系统，所述话单结算系统被处理器执行时实现如权利要求1至5任一项所述的话单结算方法。10. A computer-readable storage medium, wherein a bill settlement system is stored on the computer-readable storage medium, and when the bill settlement system is executed by a processor, any one of claims 1 to 5 is implemented. The bill settlement method described.

Images