CN101237331A - Generation method, transmission method, system and device of bill file - Google Patents
Generation method, transmission method, system and device of bill file Download PDFInfo
- Publication number
- CN101237331A CN101237331A CN 200810006118 CN200810006118A CN101237331A CN 101237331 A CN101237331 A CN 101237331A CN 200810006118 CN200810006118 CN 200810006118 CN 200810006118 A CN200810006118 A CN 200810006118A CN 101237331 A CN101237331 A CN 101237331A
- Authority
- CN
- China
- Prior art keywords
- file
- bill
- serial number
- node
- processing node
- 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.)
- Granted
Links
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04M—TELEPHONIC COMMUNICATION
- H04M15/00—Arrangements for metering, time-control or time indication ; Metering, charging or billing arrangements for voice wireline or wireless communications, e.g. VoIP
- H04M15/41—Billing record details, i.e. parameters, identifiers, structure of call data record [CDR]
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
本发明公开了一种话单文件的生成方法,包括:处理节点接收到计费信息后进行处理,当满足生成话单文件的条件时发送请求消息,所述请求消息中携带有表示待生成的话单文件中需要包含的话单数量信息,所述信息用于请求分配在所有处理节点范围内唯一且连续的文件序列号和所述待生成的话单文件内唯一且连续的话单流水号;接收返回的与所述请求消息对应的文件序列号和话单流水号;本发明还提供了一种话单文件的生成系统,一种话单文件的传输方法、系统和装置,以及一种计费网关系统和计费系统。应用本发明可以保证所有处理节点产生唯一且连续的话单流水号和话单序列号,避免了计费中心对重复话单和话单文件的识别,由此降低计费中心对话单校验的复杂度。
The invention discloses a method for generating a bill file, which includes: processing a processing node after receiving billing information, and sending a request message when the conditions for generating a bill file are met, and the request message carries words indicating to be generated The single file needs to contain the number information of the bill, and the information is used to request the allocation of a unique and continuous file serial number within the range of all processing nodes and a unique and continuous serial number of the bill in the bill file to be generated; receive the returned The file serial number and bill serial number corresponding to the request message; the present invention also provides a generation system of a bill file, a transmission method, system and device of a bill file, and a billing gateway system and billing system. The application of the present invention can ensure that all processing nodes generate unique and continuous bill serial numbers and bill serial numbers, avoiding the identification of duplicate bills and bill files by the billing center, thereby reducing the complexity of checking bills in the billing center Spend.
Description
技术领域technical field
本发明涉及通信技术领域,特别涉及一种话单文件的生成方法、系统和装置,一种话单文件的传输方法、系统和装置,以及一种计费网关系统和计费系统。The present invention relates to the technical field of communication, in particular to a method, system and device for generating bill files, a method, system and device for transmitting bill files, and a billing gateway system and billing system.
背景技术Background technique
计费网关系统是处于交换机与计费中心之间完成话单接收、预处理及缓存功能的网关设备。随着交换机承载用户数量的不断扩大,计费网关系统需要提供的话单处理能力和话单存储能力都不断增加。早期的计费网关系统中,由一台独立的服务器来接收和处理计费信息、生成话单文件以及提供计费接口给计费中心。由于通过一台独立服务器完成所有计费网关系统的功能,因此要求该服务器具有较高的性能,而性能越高的服务器相应的成本也就越高;由于独立服务器扩容较难,因此当计费需求超过该服务器的处理能力和存储能力后,要提高处理能力只能更换性能更高的服务器,要提高存储能力则只能通过增加硬盘数量或更换更大容量的硬盘来解决。The billing gateway system is a gateway device located between the switch and the billing center to complete the bill receiving, preprocessing and buffering functions. With the continuous expansion of the number of users carried by the switch, the bill processing and bill storage capabilities that the billing gateway system needs to provide continue to increase. In the early billing gateway system, an independent server was used to receive and process billing information, generate bill files, and provide a billing interface to the billing center. Since all the functions of the billing gateway system are completed through an independent server, the server is required to have high performance, and the corresponding cost of the server with higher performance is higher; When the demand exceeds the processing power and storage capacity of the server, the only way to improve the processing power is to replace the server with higher performance. To improve the storage capacity, the only solution is to increase the number of hard drives or replace hard drives with larger capacity.
为了满足高性能和大容量的需求,现有的计费网关系统主要采用分布式处理结构,由多个服务器分担存储和处理功能,所有的服务器都与计费中心相连,每一台服务器具有独立的IP地址,所有服务器的网络位置和访问权限均向计费中心开放,计费中心可以从任意的服务器上获取话单文件,并通过判断文件序列号和话单流水号查看话单文件和话单是否重复和丢失。In order to meet the requirements of high performance and large capacity, the existing billing gateway system mainly adopts a distributed processing structure, and multiple servers share storage and processing functions. All servers are connected to the billing center, and each server has an independent The IP address of the server, the network location and access rights of all servers are open to the billing center. The billing center can obtain bill files from any server, and check the bill files and bills by judging the file serial number and bill serial number Whether the list is duplicated and lost.
本发明的发明人在对现有计费系统的研究过程中发现,现有计费系统中的计费中心需要识别重复的话单和话单文件,由此增加了计费中心对话单校验的复杂度。The inventor of the present invention finds in the research process to existing billing system, the billing center in the existing billing system needs to identify duplicate bills and bill files, thus increasing the cost of checking the billing center dialog the complexity.
发明内容Contents of the invention
本发明实施例在于提供一种话单文件的生成方法、系统和装置,用于降低计费中心对话单校验的复杂度。The embodiments of the present invention provide a method, system and device for generating bill files, which are used to reduce the complexity of checking bills in a billing center.
本发明实施例在于提供一种话单文件的传输方法、系统和装置,用于降低计费中心对话单校验的复杂度。The embodiment of the present invention provides a method, system and device for transmitting bill files, which are used to reduce the complexity of checking bills in a billing center.
本发明实施例在于提供一种计费网关系统和计费系统,用于降低计费中心的对话单校验的复杂度。An embodiment of the present invention provides a charging gateway system and a charging system, which are used to reduce the complexity of checking a dialog ticket in a charging center.
为实现本发明实施例的目的,本发明实施例提供如下技术方案:In order to achieve the purpose of the embodiments of the present invention, the embodiments of the present invention provide the following technical solutions:
一种话单文件的生成方法,包括:A method for generating a bill file, comprising:
处理节点接收到计费信息后进行处理,当满足生成话单文件的条件时发送请求消息,所述请求消息中携带有表示待生成的话单文件中需要包含的话单数量信息,所述信息用于请求分配在所有处理节点范围内唯一且连续的文件序列号和所述待生成的话单文件内唯一且连续的话单流水号;The processing node performs processing after receiving the billing information, and sends a request message when the conditions for generating the bill file are satisfied, and the request message carries information indicating the number of bills that need to be included in the bill file to be generated, and the information is used for Request to assign a unique and continuous file sequence number within the scope of all processing nodes and a unique and continuous bill serial number in the bill file to be generated;
接收返回的与所述请求消息对应的文件序列号和话单流水号;Receive the returned file serial number and bill serial number corresponding to the request message;
根据所述文件序列号和话单流水号生成所述话单文件。The bill file is generated according to the file serial number and the bill serial number.
一种话单文件的生成系统,包括:分配节点和至少一个处理节点,A system for generating bill files, comprising: a distribution node and at least one processing node,
所述处理节点,用于接收并处理计费信息,当满足生成话单文件的条件时,向所述分配节点发送携带有表示待生成的话单文件中需要包含的话单数量信息的请求消息,并接收所述分配节点返回的与所述请求消息对应的文件序列号和话单流水号,根据所述文件序列号和话单流水号生成相应的话单文件;The processing node is configured to receive and process the billing information, and when the conditions for generating the bill file are met, send to the distribution node a request message carrying information indicating the number of bills that need to be included in the bill file to be generated, and receiving the file serial number and bill serial number corresponding to the request message returned by the distribution node, and generating a corresponding bill file according to the file serial number and bill serial number;
所述分配节点,用于根据所述请求消息为待生成的话单文件分配相应的文件序列号和话单流水号,其中所述文件序列号和话单流水号为在所有处理节点范围内唯一且连续的文件序列号,所述话单流水号为在所述待生成的话单文件内唯一且连续的话单流水号。The allocation node is configured to assign a corresponding file serial number and bill serial number to the bill file to be generated according to the request message, wherein the file serial number and bill serial number are unique within the range of all processing nodes and A continuous file serial number, the bill serial number is a unique and continuous bill serial number in the bill file to be generated.
一种话单文件的传输方法,所述方法包括:A method for transmitting a bill file, the method comprising:
汇总节点获得文件序列号,并根据所述文件序列号从对应的处理节点获得相应的话单文件,所述汇总节点为与所述处理节点位于同一计费网关系统的节点;The collection node obtains the file serial number, and obtains the corresponding bill file from the corresponding processing node according to the file serial number, and the collection node is a node located in the same billing gateway system as the processing node;
根据所述获得的文件序列号的大小,顺序汇总所述获得的话单文件;According to the size of the serial numbers of the obtained files, sequentially summarize the obtained bill files;
将所述汇总后的话单文件输出给计费中心。Output the summarized bill file to the billing center.
一种话单文件的传输系统,包括:汇总节点和至少一个处理节点,A bill file transmission system, comprising: a summary node and at least one processing node,
所述处理节点,用于存储生成的话单文件,所述话单文件为在所有处理节点范围内具有唯一且连续的文件序列号的话单文件,所述话单文件内的话单具有唯一且连续的话单流水号;The processing node is used to store and generate a bill file, the bill file is a bill file with unique and continuous file serial numbers within the scope of all processing nodes, and the bill in the bill file has unique and continuous words single serial number;
所述汇总节点,用于获得文件序列号后,根据所述文件序列号从对应的处理节点获得相应的话单文件,根据所述获得文件序列号的大小,顺序汇总所述获得的话单文件,并将所述汇总后的话单文件输出。The summary node is configured to obtain the corresponding bill file from the corresponding processing node according to the file serial number after obtaining the file serial number, and sequentially summarize the obtained bill file according to the size of the obtained file serial number, and Outputting the summarized bill file.
一种话单文件的传输装置,包括:A device for transmitting bill files, comprising:
获得单元,用于获得文件序列号,并根据所述文件序列号从对应的处理节点获得相应的话单文件,所述汇总节点为与所述处理节点位于同一计费网关系统中的节点;An obtaining unit, configured to obtain a file serial number, and obtain a corresponding bill file from a corresponding processing node according to the file serial number, and the collection node is a node located in the same billing gateway system as the processing node;
汇总单元,用于根据所述获得的文件序列号的大小,顺序汇总所述获得的话单文件;An aggregation unit, configured to sequentially summarize the obtained bill files according to the size of the obtained file serial numbers;
输出单元,用于输出所述汇总后的话单文件。An output unit, configured to output the summarized bill file.
一种计费网关系统,包括:汇总节点和与所述汇总节点相连的至少一个处理节点,A billing gateway system, comprising: a summary node and at least one processing node connected to the summary node,
所述处理节点,用于接收并处理计费信息,当满足生成话单文件的条件时,发送为携带有表示待生成的话单文件中需要包含的话单数量信息的请求消息,并接收返回的与所述请求消息对应的文件序列号和话单流水号,根据所述文件序列号和话单流水号生成所述话单文件并存储;The processing node is used to receive and process the billing information, and when the conditions for generating the bill file are met, send a request message carrying the bill quantity information indicating that the bill file to be generated needs to be included, and receive the returned and The file serial number and bill serial number corresponding to the request message, generating and storing the bill file according to the file serial number and bill serial number;
所述汇总节点,用于获得文件序列号后,根据所述文件序列号从对应的处理节点获得相应的话单文件,根据所述获得文件序列号的大小,顺序汇总所述获得的话单文件,并将所述汇总后的话单文件输出。The summary node is configured to obtain the corresponding bill file from the corresponding processing node according to the file serial number after obtaining the file serial number, and sequentially summarize the obtained bill file according to the size of the obtained file serial number, and Outputting the summarized bill file.
一种计费系统,包括:计费网关系统和计费中心,所述计费网关系统包括汇总节点和与所述汇总节点通信的至少一个处理节点,A billing system, comprising: a billing gateway system and a billing center, the billing gateway system including a summary node and at least one processing node communicating with the summary node,
所述处理节点,用于接收并处理计费信息,当满足生成话单文件的条件时,发送携带有表示待生成的话单文件中需要包含的话单数量信息的请求消息,并接收返回的与所述请求消息对应的文件序列号和话单流水号,根据所述文件序列号和话单流水号生成并存储所述话单文件;The processing node is used to receive and process the billing information, and when the conditions for generating the bill file are met, send a request message carrying information indicating the number of bills that need to be included in the bill file to be generated, and receive the returned information related to the bill. The file serial number corresponding to the request message and the bill serial number, generate and store the bill file according to the file serial number and the bill serial number;
所述汇总节点,用于获得文件序列号,根据所述文件序列号从对应的处理节点获得相应的话单文件,根据所述获得文件序列号的大小,顺序汇总所述获得的话单文件,并将所述汇总后的话单文件输出至所述计费中心;The collection node is used to obtain the file serial number, obtain the corresponding bill file from the corresponding processing node according to the file serial number, and summarize the obtained bill file in order according to the size of the obtained file serial number, and The bill file after the summary is output to the billing center;
所述计费中心,用于获得所述计费网关系统通过所述汇总节点输出的话单文件并进行计费处理。The billing center is configured to obtain the bill file output by the billing gateway system through the summarizing node and perform billing processing.
由以上本发明实施例提供的技术方案可见,本发明实施例中处理节点接收到计费信息后,发送为待生成的话单文件请求文件序列号和话单流水号的消息,根据分配的文件序列号和话单流水号生成并存储所述话单文件,汇总节点根据所述处理节点存储的话单文件的文件序列号汇总所述话单文件,并将汇总后的话单文件输出给计费中心。应用本发明实施例可以保证所有处理节点产生唯一且连续的话单流水号和话单序列号,避免了计费中心对重复话单和话单文件的识别,由此减少计费中心对话单校验的复杂度;其次,由于通过一个汇总节点获取各个处理节点的话单文件,因此可以向计费中心提供统一的计费接口,节约了各个处理节点直接与计费中心相连时所要消耗的IP资源,避免计费网关系统的组网结构暴露给外部,提高了系统的安全性。It can be seen from the technical solutions provided by the above embodiments of the present invention that after the processing node receives the billing information in the embodiments of the present invention, it sends a message requesting the file serial number and the bill serial number for the bill file to be generated, and according to the assigned file sequence number and bill serial number to generate and store the bill file, the summarizing node summarizes the bill file according to the file serial number of the bill file stored by the processing node, and outputs the bill file after summarization to the billing center. The application of the embodiment of the present invention can ensure that all processing nodes generate unique and continuous bill serial numbers and bill serial numbers, avoiding the identification of duplicate bills and bill files by the billing center, thereby reducing the number of bill checks in the billing center secondly, since the bill file of each processing node is obtained through a collection node, a unified charging interface can be provided to the billing center, saving the IP resources consumed when each processing node is directly connected to the billing center, The networking structure of the billing gateway system is prevented from being exposed to the outside, and the security of the system is improved.
附图说明Description of drawings
图1为本发明计费网关系统和计费中心接口的组网结构示意图;Fig. 1 is a schematic diagram of the networking structure of the charging gateway system and the charging center interface of the present invention;
图2为本发明计费网关系统的第一实施例框图;Fig. 2 is a block diagram of the first embodiment of the billing gateway system of the present invention;
图3为本发明计费网关系统的第二实施例框图;Fig. 3 is the block diagram of the second embodiment of the billing gateway system of the present invention;
图4为本发明话单文件生成系统的实施例框图;Fig. 4 is the embodiment block diagram of bill file generation system of the present invention;
图5为本发明话单文件生成方法的第一实施例流程图;Fig. 5 is the flowchart of the first embodiment of the bill file generation method of the present invention;
图6为本发明话单文件生成方法的第二实施例流程图;Fig. 6 is the flow chart of the second embodiment of the bill file generation method of the present invention;
图7为本发明话单文件传输系统的实施例框图;Fig. 7 is the embodiment block diagram of bill file transmission system of the present invention;
图8为本发明话单文件传输装置的实施例框图;FIG. 8 is a block diagram of an embodiment of the bill file transmission device of the present invention;
图9为本发明话单文件传输方法的第一实施例流程图;Fig. 9 is the flowchart of the first embodiment of the bill file transmission method of the present invention;
图10为本发明话单文件传输方法的第二实施例流程图;Fig. 10 is the flowchart of the second embodiment of the bill file transmission method of the present invention;
图11为本发明中汇总节点获取话单文件的一种示意图;Fig. 11 is a kind of schematic diagram that summarization node obtains bill file in the present invention;
图12为本发明话单文件传输方法的第三实施例流程图;Fig. 12 is the flow chart of the third embodiment of the bill file transmission method of the present invention;
图13为本发明中汇总节点获取话单文件的另一种示意图。Fig. 13 is another schematic diagram of the summarization node obtaining bill files in the present invention.
具体实施方式Detailed ways
本发明实施例提供了一种话单文件的生成方法和系统,一种话单文件的传输方法、系统和装置,以及一种计费网关系统和计费系统。处理节点接收并处理计费信息,当满足生成话单文件的条件时,发送携带有表示待生成的话单文件中需要包含的话单数量信息的请求消息,并接收返回的与所述请求消息对应的文件序列号和话单流水号,根据所述文件序列号和话单流水号生成并存储所述话单文件,汇总节点获得文件序列号后,根据所述文件序列号从对应的处理节点获取相应的话单文件,根据所述获得文件序列号的大小,顺序汇总所述获取的话单文件,并将所述汇总后的话单文件输出至所述计费中心。The embodiment of the present invention provides a method and system for generating a bill file, a method, system and device for transmitting a bill file, a billing gateway system and a billing system. The processing node receives and processes the billing information, and when the conditions for generating the bill file are met, sends a request message carrying information indicating the number of bills that need to be included in the bill file to be generated, and receives the returned corresponding to the request message File serial number and bill serial number, generate and store the bill file according to the file serial number and bill serial number, after the summary node obtains the file serial number, obtain the corresponding processing node from the corresponding processing node according to the file serial number For the bill file, according to the size of the serial number of the obtained file, sequentially summarize the obtained bill file, and output the summarized bill file to the billing center.
为了使本技术领域的人员更好地理解本发明实施例提供的技术方案,下面结合附图和具体实施方式对本发明实施例提供的技术方案作进一步的详细说明。In order to enable those skilled in the art to better understand the technical solutions provided by the embodiments of the present invention, the technical solutions provided by the embodiments of the present invention will be further described in detail below in conjunction with the drawings and specific implementation methods.
本发明实施例一种计费网关系统和计费中心接口的计费系统组网结构示意图如图1所示,包括:计费网关系统和计费中心,其中:计费网关系统包括至少一个处理节点和一个汇总节点,处理节点之间并联且没有协同交互,每一个处理节点独立产生话单,每一张话单具有唯一且连续的话单流水号,一定数量的话单组成话单文件,每一个话单文件具有唯一且连续的文件序列号。在计费网关系统中增加了汇总节点,所有并行的处理节点与汇总节点相连,通过汇总节点与外部的计费中心相连。计费网关系统中的各个处理节点和汇总节点可以采用相同或不同的服务器。A schematic diagram of a charging system network structure of a charging gateway system and a charging center interface according to an embodiment of the present invention is shown in Figure 1, including: a charging gateway system and a charging center, wherein: the charging gateway system includes at least one processing Node and a summary node, the processing nodes are connected in parallel without collaborative interaction, each processing node generates bills independently, each bill has a unique and continuous bill serial number, a certain number of bills form a bill file, each Bill files have unique and continuous file serial numbers. A summarization node is added to the billing gateway system, and all parallel processing nodes are connected to the summarization node, and connected to the external billing center through the summarization node. Each processing node and aggregation node in the billing gateway system can use the same or different servers.
其中,处理节点用于完成对计费信息的接收和处理工作并生成话单和话单文件,具体的,处理节点用于接收并处理计费信息,当满足生成话单文件的条件时,发送携带有表示待生成的话单文件中需要包含的话单数量信息的请求消息,并接收返回的与所述请求消息对应的文件序列号和话单流水号,根据所述文件序列号和话单流水号生成并存储所述话单文件。汇总节点作为计费网关系统对计费中心的统一接口,获得文件序列号后,根据所述文件序列号从对应的处理节点获取相应的话单文件,根据所述获得文件序列号的大小,顺序汇总所述获取的话单文件,并缓存部分计费中心所需要的话单文件,在需要时从各个处理节点上提取计费中心所需的话单文件到本地。计费网关系统还具有为各个处理节点分配连续且唯一的话单流水号和文件序列号的功能,该功能可以由汇总节点实现,也可以由任意一个处理节点实现。计费中心用于获得通过汇总节点输出的话单文件。Among them, the processing node is used to complete the receiving and processing of billing information and generate bills and bill files. Specifically, the processing node is used to receive and process billing information. When the conditions for generating bill files are met, send Carrying a request message indicating that the bill quantity information to be included in the bill file to be generated, and receiving the returned file serial number and bill serial number corresponding to the request message, according to the file serial number and bill serial number Generate and store the bill file. The summary node is used as the unified interface of the billing gateway system to the billing center. After obtaining the file serial number, the corresponding call list file is obtained from the corresponding processing node according to the file serial number, and the sequence is summarized according to the size of the obtained file serial number. The bill files are obtained, and part of the bill files required by the billing center is cached, and the bill files required by the billing center are extracted from each processing node to the local when needed. The billing gateway system also has the function of assigning continuous and unique bill serial numbers and file serial numbers to each processing node. This function can be realized by the summary node or any processing node. The billing center is used to obtain the bill file output by the summary node.
本发明提供了一种计费网关系统的实施例,该计费网关系统中包含至少一个处理节点和一个汇总节点。The present invention provides an embodiment of a billing gateway system, which includes at least one processing node and one aggregation node.
本发明计费网关系统的第一实施例框图如图2所示,该实施例中示出了N个处理节点和一个汇总节点。其中,每个处理节点均包含话单处理模块和话单存储模块,话单处理模块具体用于接收并处理计费信息,当满足生成话单文件的条件时,向流水号及序列号分配模块发送携带有表示待生成的话单文件中需要包含的话单数量信息的请求消息,并接收所述流水号及序列号分配模块返回的与所述请求对应的文件序列号和话单流水号,根据所述文件序列号和话单流水号生成相应的话单文件;话单存储模块用于存储所述话单处理模块生成的话单文件。汇总节点中包含话单文件汇总存储模块,用于获得所述处理节点存储的话单文件的文件序列号后,根据所述文件序列号从对应的处理节点获取相应的话单文件,根据所述获得文件序列号的大小,顺序汇总所述获取的话单文件。在该实施例中,流水号及序列号分配模块位于处理节点1中,用于接收到话单处理模块发送的请求消息后,为待生成的话单文件分配在所有处理节点范围内唯一且连续的文件序列号和话单流水号。The block diagram of the first embodiment of the billing gateway system of the present invention is shown in FIG. 2 , and this embodiment shows N processing nodes and one aggregation node. Among them, each processing node includes a bill processing module and a bill storage module. The bill processing module is specifically used to receive and process billing information. When the conditions for generating bill files are met, the serial number and serial number allocation module Sending a request message carrying the bill quantity information that needs to be included in the bill file to be generated, and receiving the file serial number and the bill serial number corresponding to the request returned by the serial number and serial number distribution module, according to the The serial number of the described file and the bill serial number generate the corresponding bill file; the bill storage module is used to store the bill file generated by the bill processing module. Contain bill file summary storage module in the collection node, after obtaining the file serial number of the bill file stored in the processing node, obtain the corresponding bill file from the corresponding processing node according to the file serial number, obtain the file according to the The size of the serial number, and sequentially summarize the obtained bill files. In this embodiment, the serial number and serial number allocation module is located in the
本发明计费网关系统的第二实施例框图如图3所示,该实施例中示出了N个处理节点和一个汇总节点。其中,处理节点和汇总节点包含的功能模块与第一实施例类似,在此不再赘述。不同的是,该实施例中流水号及序列号分配模块位于汇总节点中。The block diagram of the second embodiment of the billing gateway system of the present invention is shown in FIG. 3 , and this embodiment shows N processing nodes and one aggregation node. Wherein, the functional modules included in the processing node and the summarizing node are similar to those in the first embodiment, and will not be repeated here. The difference is that in this embodiment, the serial number and serial number allocation module is located in the aggregation node.
本发明还提供了一种话单文件的生成系统的实施例,该实施例的框图如图4所示:The present invention also provides an embodiment of a generation system of a bill file, and the block diagram of this embodiment is as shown in Figure 4:
该话单文件生成系统包括至少一个处理节点和一个分配节点,所述至少一个处理节点分别与所述分配节点相连。为了示例和描述方便,图4中仅示出了一个处理节点410和分配节点420。The bill file generation system includes at least one processing node and a distribution node, and the at least one processing node is respectively connected to the distribution node. For convenience of illustration and description, only one
其中,处理节点410用于接收并处理计费信息,当满足生成话单文件的条件时,向所述分配节点发送携带有表示待生成的话单文件中需要包含的话单数量信息的请求消息,并接收所述分配节点返回的与所述请求消息对应的文件序列号和话单流水号,根据所述文件序列号和话单流水号生成相应的话单文件;分配节点420用于根据所述请求消息为待生成的话单文件分配相应的文件序列号和话单流水号,其中所述文件序列号和话单流水号为在所有处理节点范围内唯一且连续的文件序列号,所述话单流水号为在所述待生成的话单文件内唯一且连续的话单流水号。Wherein, the
具体的,处理节点410包括收发单元411,用于向所述分配节点发送携带有表示待生成的话单文件中需要包含的话单数量信息的请求消息,并接收所述分配节点返回的与所述请求消息对应的文件序列号和话单流水号;生成单元412,用于接收并处理计费信息,在满足生成话单文件的条件时,由所述收发单元发送请求消息,并根据所述收发单元接收的文件序列号和话单流水号生成相应的话单文件;存储单元413,用于存储所述生成的话单文件。收发单元411进一步用于在所述生成单元生成话单文件后向所述分配节点发送成功接收所述文件序列号和话单流水号的消息。Specifically, the
分配节点420可以进一步包括序列号分配单元,用于接收到所述请求消息,根据记录的已经分配的文件序列号为所述待生成的话单文件分配相对所述已经分配的文件序列号唯一且连续的文件序列号;流水号分配单元,用于根据所述请求消息中携带的话单数量信息为所述待生成的话单文件内的话单分配在所述待生成的话单文件内唯一且连续的的话单流水号。The
本发明还提供了一种话单文件生成方法的实施例。The invention also provides an embodiment of a method for generating a bill file.
本发明话单文件的生成方法的第一实施例流程图如图5所示:The flow chart of the first embodiment of the generation method of the bill file of the present invention is as shown in Figure 5:
步骤501:处理节点接收到计费信息后进行处理,当满足生成话单文件的条件时发送请求消息。Step 501: The processing node performs processing after receiving the billing information, and sends a request message when the conditions for generating the bill file are met.
其中,满足生成话单文件的条件具体包括:对接收到的计费信息进行处理后生成了相应的处理记录;或者距离上一次生成话单文件的时间超过预设时间;或者生成的处理记录达到预设的数量。Wherein, meeting the conditions for generating the bill file specifically includes: the received billing information is processed and a corresponding processing record is generated; or the time since the last generation of the bill file exceeds the preset time; or the generated processing record reaches preset quantity.
其中,请求消息中携带有表示待生成的话单文件中需要包含的话单数量信息,所述信息用于请求分配在所有处理节点范围内唯一且连续的文件序列号和所述待生成的话单文件内唯一且连续的话单流水号。Wherein, the request message carries information indicating the number of bills that need to be included in the bill file to be generated, and the information is used to request the allocation of unique and continuous file serial numbers within the scope of all processing nodes and the number of bills in the bill file to be generated. Unique and continuous call ticket serial number.
步骤502:接收返回的与所述请求消息对应的文件序列号和话单流水号。Step 502: Receive the returned file serial number and bill serial number corresponding to the request message.
其中,分配在所有处理节点范围内唯一且连续的文件序列号和在待生成的话单文件内唯一且连续的话单流水号具体为,为所述待生成的话单文件分配相对于已经分配的文件序列号的唯一且连续的文件序列号,根据所述请求消息中携带的话单数量信息为所述待生成的话单文件中的话单分配在所述待生成的话单文件内唯一且连续的话单流水号。Wherein, allocating the unique and continuous file serial number within the scope of all processing nodes and the unique and continuous bill serial number in the bill file to be generated is specifically, assigning the file sequence relative to the already allocated file for the bill file to be generated The unique and continuous file serial number of the number, and according to the bill quantity information carried in the request message, the bills in the bill file to be generated are assigned a unique and continuous bill serial number in the bill file to be generated.
这里实现分配功能的分配节点可以是计费网关系统中的另一个处理节点,也可以是计费网关系统中的汇总节点。Here, the distribution node that implements the distribution function may be another processing node in the charging gateway system, or may be a collection node in the charging gateway system.
步骤503:根据文件序列号和话单流水号生成话单文件。Step 503: Generate a bill file according to the serial number of the file and the serial number of the bill.
本发明话单文件的生成方法的第二实施例流程图如图6所示,该实施例以计费网关系统中的某个处理节点为例,详细描述了该处理节点中生成话单文件的过程,假设该处理节点为处理节点K:The flow chart of the second embodiment of the generation method of the bill file of the present invention is shown in Figure 6. This embodiment takes a certain processing node in the billing gateway system as an example, and describes in detail the process of generating the bill file in the processing node. process, assuming that the processing node is processing node K:
步骤601:处理节点K接收到计费信息后准备生成话单及包含话单的话单文件。Step 601: After receiving the billing information, the processing node K prepares to generate a bill and a bill file including the bill.
每个话单文件中包含多个话单,每个话单中保存有接收到的计费信息,假设处理节点K当前准备生成的话单文件中包含100个话单。Each bill file contains multiple bills, and each bill stores received billing information. It is assumed that processing node K is currently preparing to generate 100 bills in the bill file.
步骤602:处理节点K向分配节点发送用于请求话单流水号和文件序列号的消息。Step 602: The processing node K sends a message for requesting the serial number of the bill and the serial number of the file to the distribution node.
计费网关系统中分配话单流水号和文件序列号的功能可以由分配节点来实现,分配节点可以是本发明实施例的计费网关系统中的某个处理节点,也可以是独立于所有处理节点的节点,例如:汇总节点、独立于处理节点、汇总节点的第三方节点;The function of distributing bill serial numbers and file serial numbers in the billing gateway system can be realized by the distribution node, which can be a certain processing node in the billing gateway system of the embodiment of the present invention, or can be independent of all processing nodes. Nodes of nodes, for example: summary nodes, third-party nodes independent of processing nodes, summary nodes;
本实施例中以独立于所有处理节点的节点作为分配节点为例,处理节点K向该分配节点发送请求话单流水号和文件序列号的消息,该消息中携带了该话单文件中包含的话单数量100个。In this embodiment, taking a node independent of all processing nodes as an example of a distribution node, processing node K sends a message requesting a bill serial number and a file serial number to the distribution node, and the message carries the words contained in the bill file. Order quantity 100 pcs.
步骤603:按照话单文件的生成顺序为该话单文件分配文件序列号。Step 603: Allocate a file serial number to the bill file according to the generation sequence of the bill file.
分配节点接收到该请求消息后,根据当前已经分配过的文件序列号为该处理节点K分配相对于已经分配的文件序列号连续且唯一的文件序列号。假设分配节点上一次分配的文件序列号为“10”,若文件序列号的步长值为1,则分配节点为处理节点K的话单文件分配顺序的文件序列号为“11”,当然文件序列号的步长值可以设置为其它值。After the allocation node receives the request message, it allocates a file serial number that is continuous and unique to the processing node K according to the currently allocated file serial number. Assume that the file serial number assigned by the distribution node last time is "10", if the step size of the file serial number is 1, then the file serial number of the distribution order of the bill file distribution sequence of the distribution node is "11" for the processing node K, of course the file sequence The step value of the number can be set to other values.
步骤604:根据该请求消息中携带的该话单文件中的话单数量为话单分配话单流水号。Step 604: Assign a bill serial number to the bill according to the number of bills in the bill file carried in the request message.
分配节点进一步根据当前已经分配过的话单流水号为该处理节点K分配连续且唯一的话单流水号。假设分配节点上一次分配的话单流水号为“100”,则分配节点为话单文件中的100个话单顺序分配从“101”到“200”的话单流水号。The allocation node further allocates continuous and unique bill serial numbers to the processing node K according to the currently allocated bill serial numbers. Assuming that the bill serial number assigned by the allocation node last time is "100", the allocation node sequentially allocates the bill serial numbers from "101" to "200" for the 100 bills in the bill file.
步骤605:分配节点向处理节点K发送话单流水号和文件序列号。Step 605: The distribution node sends the bill serial number and file serial number to the processing node K.
步骤606:处理节点K根据话单流水号和文件序列号生成话单和话单文件。Step 606: The processing node K generates the bill and the bill file according to the bill serial number and the file serial number.
处理节点K接收到分配的文件序列号“11”以及话单流水号“101”至“200”后,根据上述文件序列号和话单流水号生成话单文件,并保存生成的话单文件。After processing node K receives the assigned file serial number "11" and bill serial numbers "101" to "200", it generates a bill file according to the file serial number and bill serial number, and saves the generated bill file.
步骤607:处理节点K发送接收文件序列号和话单流水号成功的消息。Step 607: The processing node K sends a message that the file serial number and bill serial number are successfully received.
本发明话单文件的生成方法的实施例中,处理节点通过请求应答的方式获取话单流水号和文件序列号,由于话单流水号和文件序列号由分配节点统一进行分内配,因此可以保证计费网关系统中所有处理节点产生的文件序列号和话单流水号保持唯一且连续。In the embodiment of the generation method of the bill file of the present invention, the processing node obtains the bill serial number and the file serial number through the mode of request response, because the bill serial number and the file serial number are uniformly assigned by the distribution node, so it can be Ensure that the file serial numbers and bill serial numbers generated by all processing nodes in the billing gateway system remain unique and continuous.
本发明还提供了一种话单文件的传输系统的实施例,用于对生成的话单文件进行传输,该实施例的框图如图7所示:The present invention also provides an embodiment of the transmission system of a bill file, which is used to transmit the generated bill file, and the block diagram of this embodiment is as shown in Figure 7:
该话单文件生成系统包括至少一个处理节点710和一个汇总节点720,所述至少一个处理节点710分别与所述分配节点720相连。处理节点710用于存储生成的话单文件,所述话单文件为在所有处理节点范围内具有唯一且连续的文件序列号的话单文件,所述话单文件内的话单具有唯一且连续的话单流水号;汇总节点720用于获得文件序列号后,根据所述文件序列号从对应的处理节点获得相应的话单文件,根据所述获得文件序列号的大小,顺序汇总所述获得的话单文件,并将所述汇总后的话单文件输出。The bill file generation system includes at least one processing node 710 and a collection node 720, and the at least one processing node 710 is connected to the distribution node 720 respectively. The processing node 710 is used for storing and generating the bill file, and the bill file is a bill file with a unique and continuous file sequence number within the scope of all processing nodes, and the bill in the bill file has a unique and continuous bill flow No.; after collecting node 720 is used for obtaining file sequence number, obtains corresponding bill file from corresponding processing node according to described file sequence number, according to the size of described obtaining file sequence number, sequentially summarizes described obtaining bill file, and Outputting the summarized bill file.
进一步,该汇总节点还可以包括保存单元,用于保存预先设置的每次向计费中心提供的话单文件的数量。Further, the collection node may also include a storage unit, configured to store the preset number of bill files provided to the billing center each time.
本发明还提供了一种话单文件的传输装置的实施例,用于对生成的话单文件进行传输,该实施例的框图如图8所示:The present invention also provides an embodiment of a transmission device for bill files, which is used to transmit the generated bill files. The block diagram of this embodiment is shown in Figure 8:
该话单文件的传输装置包括:获得单元810、汇总单元820和输出单元830。其中,获得单元810用于获得文件序列号,并根据所述文件序列号从对应的处理节点获得相应的话单文件,所述汇总节点为与所述处理节点位于同一计费网关系统的节点;汇总单元820用于根据所述获得的文件序列号的大小,顺序汇总所述获得的话单文件;输出单元830用于输出所述汇总后的话单文件。The device for transmitting the bill file includes: an obtaining unit 810 , a summarizing unit 820 and an output unit 830 . Wherein, the obtaining unit 810 is used to obtain the file serial number, and obtain the corresponding bill file from the corresponding processing node according to the file serial number, and the collection node is a node located in the same billing gateway system as the processing node; The unit 820 is configured to sequentially summarize the obtained bill files according to the size of the obtained file sequence numbers; the output unit 830 is configured to output the summarized bill files.
具体的,获得单元810可以进一步包括:接收单元,用于接收各个处理节点发送的文件序列号,所述文件序列号为所述各个处理节点当前文件序列号值最小的文件序列号;比较单元,用于比较所述文件序列号,确定当前需要获得的话单文件的序列号;提取单元,用于根据所述文件序列号从对应的处理节点提取与所述文件序列号对应的话单文件。Specifically, the obtaining unit 810 may further include: a receiving unit, configured to receive the file serial number sent by each processing node, where the file serial number is the file serial number with the smallest value of the current file serial number of each processing node; a comparison unit, It is used to compare the file serial number to determine the serial number of the bill file that needs to be obtained currently; the extraction unit is used to extract the bill file corresponding to the file serial number from the corresponding processing node according to the file serial number.
获得单元810也可以进一步包括:查询单元,用于向分配节点查询与当前已成功分配的文件序列号对应的处理节点;提取单元,用于从所述处理节点提取与所述当前已成功分配的文件序列号对应的话单文件。The obtaining unit 810 may further include: a query unit, configured to query the distribution node for a processing node corresponding to the currently successfully distributed file serial number; an extraction unit, used to extract from the processing node the The file serial number corresponds to the bill file.
获得单元810也可以进一步包括:收发单元,用于接收各个处理节点发送的文件序列号,所述文件序列号为所述各个处理节点当前文件序列号值最小的文件序列号;比较单元,用于比较所述文件序列号,确定当前需要获得的话单文件的序列号;所述收发单元进一步用于,发送响应给与所述当前能够上传的话单文件的序列号对应的处理节点,并接收所述处理节点返回的与所述发送的文件序列号对应的话单文件。The obtaining unit 810 may further include: a transceiver unit configured to receive the file serial number sent by each processing node, the file serial number being the file serial number with the smallest value of the current file serial number of each processing node; a comparison unit configured to Compare the file serial number to determine the serial number of the bill file that needs to be obtained at present; the transceiver unit is further used to send a response to the processing node corresponding to the serial number of the bill file that can be uploaded at present, and receive the The bill file corresponding to the sent file serial number returned by the processing node.
本发明还提供了对话单文件进行传输的方法的实施例,该方法实施例应用于包含计费网关系统和计费中心的计费系统中,计费网关系统包含若干处理节点和与所述计费中心唯一相连的汇总节点。The present invention also provides an embodiment of a method for transmitting a bill file, and the method embodiment is applied to a charging system including a charging gateway system and a charging center, and the charging gateway system includes several processing nodes and is connected to the charging system. The only aggregation node connected to the fee center.
本发明话单文件的传输方法的第一实施例流程图如图9所示:The flow chart of the first embodiment of the transmission method of the bill file of the present invention is as shown in Figure 9:
步骤901:汇总节点获得文件序列号,并根据所述文件序列号从对应的处理节点获得相应的话单文件。Step 901: The summary node obtains the file serial number, and obtains the corresponding bill file from the corresponding processing node according to the file serial number.
其中,汇总节点可以直接从各个处理节点获取话单文件,也可以查询文件序列号后向对应的处理节点获取话单文件。Wherein, the summarizing node can directly obtain the bill file from each processing node, or can obtain the bill file from the corresponding processing node after querying the serial number of the file.
汇总节点具有监控功能,当监控到该汇总节点中的话单文件数量减少时,可以向计费网关系统中的各个处理节点获取话单文件。The summarization node has a monitoring function, and when it is monitored that the number of bill files in the summarization node decreases, the bill files can be obtained from each processing node in the billing gateway system.
步骤902:根据所述获得的文件序列号的大小,顺序汇总所述获得的话单文件。Step 902: Summarize the obtained bill files sequentially according to the size of the obtained file sequence numbers.
步骤903:将汇总后的话单文件输出给计费中心。Step 903: Output the summarized bill file to the billing center.
其中,汇总节点汇总话单文件后,可以由计费中心主动向该汇总节点提取话单文件,也可以由汇总节点主动向计费中心推送话单文件。计费中心对计费网关系统中的汇总节点提供的话单文件进行进一步的计费处理,Wherein, after the summarizing node sums up the bill file, the billing center may actively extract the bill file from the summarizing node, or the summarizing node may actively push the bill file to the billing center. The billing center performs further billing processing on the bill file provided by the summary node in the billing gateway system,
汇总节点作为计费网关系统唯一对外的接口,与计费中心连接,该汇总节点具有IP地址,计费中心预先获取该IP地址,并且具有访问该汇总节点的权限,计费中心与汇总节点之间传输文件通常使用FTP、FTAM或SFTP等基本的网络传输协议。As the only external interface of the billing gateway system, the summary node is connected to the billing center. The summary node has an IP address. The billing center obtains the IP address in advance and has the authority to access the summary node. Transferring files between files usually uses basic network transfer protocols such as FTP, FTAM or SFTP.
由于汇总节点通常向计费中心提供顺序的话单文件,例如,汇总节点第一次向计费中心提供了文件序列号为1至100的话单文件,则下一次向计费中心顺序提供序列号为101至200的话单文件。由于各个处理节点上会不断产生新的话单文件,因此当汇总节点上缓存汇总后的话单文件的空间有限时,汇总节点可以在将话单文件提供给计费中心后,将已经缓存的上述话单文件删除,以释放存储空间用于汇总存储新的话单文件。例如,汇总节点具有最多存储1000个话单文件的空间,初始时对1000个话单文件编号从1至1000,当汇总节点向计费中心提供了100个话单文件并删除了该话单文件后,汇总节点将对1000个话单文件的编号调整为101至1100。因此,只要汇总节点从处理节点获取话单文件的速度大于向计费中心提供话单文件的速度,就能满足计费中心进行持续的话单采集和计费处理工作。Because the summarization node usually provides sequential bill files to the billing center, for example, the summarization node provides bill files with file serial numbers from 1 to 100 to the billing center for the first time, then the next time the billing node provides serial numbers to the billing center in order 101 to 200 bill files. Since new bill files will be continuously generated on each processing node, when the space for caching and summarizing bill files on the summarizing node is limited, the summarizing node can provide the bill files to the billing center after the summarizing node has cached the above-mentioned Delete single file to free up storage space for collectively storing new bill files. For example, the summarization node has a space to store up to 1000 bill files, and the 1000 bill files are numbered from 1 to 1000 initially, when the summarization node provides 100 bill files to the billing center and deletes the bill files Finally, the aggregation node adjusts the numbering of the 1000 bill files to 101 to 1100. Therefore, as long as the summarization node obtains the bill file from the processing node faster than the speed of providing the bill file to the billing center, the billing center can be satisfied with continuous bill collection and billing processing.
本发明话单文件的传输方法的第二实施例流程图如图10所示,该实施例示出了汇总节点将直接从各个处理节点获取话单文件传输给计费中心的过程:The flow chart of the second embodiment of the transmission method of the bill file of the present invention is shown in Figure 10, this embodiment shows the process that the summary node will directly obtain the bill file from each processing node and transmit it to the billing center:
步骤1001:汇总节点保存预先设置的每次向计费中心提供的话单文件的数量。Step 1001: The summarizing node saves the preset number of bill files provided to the billing center each time.
步骤1002:各个处理节点发送当前适合的话单文件的文件序列号。Step 1002: Each processing node sends the file serial number of the currently applicable bill file.
步骤1003:汇总节点比较文件序列号并确定当前需要获得的话单文件的序列号。各个处理节点记录已经提供给汇总节点的话单文件的状态信息,即最近一次提供给汇总节点的话单文件的文件序列号,并且各个处理将当前能够上传的话单文件的序列号发送给汇总节点,能够上传的话单文件为各个处理单元当前序列号值最小的话单文件。以处理节点K为例,假设该处理节点存储有文件序列号为1、5、7、8等的话单文件,如果当前文件序列号为1的话单文件已经提供给汇总节点,则当前处理节点K能够上传的话单文件为文件序列号5对应的话单文件。Step 1003: the summarizing node compares the serial numbers of the files and determines the serial number of the bill file that needs to be obtained currently. Each processing node records the status information of the bill file that has been provided to the summarizing node, that is, the file serial number of the bill file provided to the summarizing node last time, and each processing sends the serial number of the bill file that can be uploaded currently to the summarizing node, which can The uploaded bill file is the bill file with the smallest current serial number value of each processing unit. Taking the processing node K as an example, assuming that the processing node stores bill files with file serial numbers of 1, 5, 7, 8, etc., if the current file serial number is 1, the bill file has been provided to the summary node, then the current processing node K The bill file that can be uploaded is the bill file corresponding to file serial number 5.
步骤1004:根据文件序列号从对应的处理节点提取与该序列号对应的话单文件。Step 1004: extract the bill file corresponding to the serial number from the corresponding processing node according to the serial number of the file.
其中,提取的话单文件为所述对应的处理节点中当前文件序列号值最小的话单文件,或为各个处理节点发送的文件序列号中值最小的文件序列号对应的话单文件。Wherein, the extracted bill file is the bill file with the smallest value of the current file serial number in the corresponding processing node, or the bill file corresponding to the smallest file serial number among the file serial numbers sent by each processing node.
具体的,汇总节点收到各个处理节点发送的当前能够提供的话单文件的文件序列号后,将文件序列号进行排序,通过分析话单文件序列号与话单文件的存储情况,从各个处理节点提取与其提供的文件序列号对应的话单文件。例如,处理节点K向汇总节点发送当前能够上传文件序列号为5的话单文件,则汇总节点根据文件序列号5从处理节点K上提取文件序列号5对应的话单文件。Specifically, after receiving the file serial numbers of bill files currently available from each processing node, the summarizing node sorts the file serial numbers, and analyzes the serial numbers of bill files and the storage conditions of bill files, and collects data from each processing node. Extract the bill file corresponding to the provided file serial number. For example, the processing node K sends the bill file with file serial number 5 that can be uploaded to the summarizing node at present, and the summarizing node extracts the bill file corresponding to the file serial number 5 from the processing node K according to the file serial number 5.
当然,汇总节点接收到各个处理节点发送的文件序列号,将文件序列号进行排序后,通过分析话单文件序列号与话单文件的存储情况,也可以向处理节点发送提取与所述文件序列号对应的话单文件的请求消息,处理节点接收到请求消息后再将话单文件发送到汇总节点。例如,处理节点K向汇总节点发送当前能够上传文件序列号为5的话单文件,汇总节点向处理节点K发送提取文件序列号5对应的话单文件的请求消息,处理节点K接收到请求消息后将文件序列号5对应的话单文件发送到汇总节点。Of course, after the summary node receives the file serial numbers sent by each processing node, after sorting the file serial numbers, it can also send the extraction and the file sequence to the processing node by analyzing the serial number of the bill file and the storage situation of the bill file. number corresponding to the bill file request message, the processing node sends the bill file to the summary node after receiving the request message. For example, the processing node K sends the bill file that can currently upload the file serial number 5 to the summarizing node, and the summarizing node sends a request message to extract the bill file corresponding to the file serial number 5 to the processing node K. After receiving the request message, the processing node K will The bill file corresponding to the file sequence number 5 is sent to the aggregation node.
需要说明的是,步骤1003中确定当前需要获取的话单文件的文件序列号之后,汇总节点也可以发送响应给发送该文件序列号的处理节点,然后接收该处理节点返回的对应该文件序列的话单文件。It should be noted that, after determining the file serial number of the bill file that needs to be obtained in step 1003, the summary node can also send a response to the processing node that sent the file serial number, and then receive the bill corresponding to the file sequence returned by the processing node. document.
步骤1005:根据话单文件的文件序列号的先后顺序汇总获取的话单文件。Step 1005: Summarize and acquire the bill files according to the order of the file serial numbers of the bill files.
步骤1006:汇总节点按文件序列号的顺序将不超过预设数量的话单文件发送给计费中心。Step 1006: The summarizing node sends the bill files not exceeding a preset number to the billing center according to the order of file serial numbers.
在上述话单文件传输方法实施例中,汇总节点从各个处理节点获取相应的话单文件的示意图如图11所示:In the above embodiment of the bill file transmission method, a schematic diagram of the collection node obtaining the corresponding bill file from each processing node is shown in Figure 11:
假设有N个处理节点,以处理节点1、2、N为例,处理节点1存储有文件序列号为1、5、7、8等的话单文件若干,处理节点2存储有文件序列号为3、4、9、12等的话单文件若干,处理节点N存储有文件序列号为2、6、10、11等的话单文件若干。对于处理节点1,假设文件序列号为1的话单文件已经上传过,则当前最适合上传的是文件序列号为5的话单文件;对于处理节点2,当前最适合上传的是文件序列号为3的话单文件;对于处理节点N,当前最适合上传的是文件序列号为2的话单文件。上述三个处理节点分别将当前能够上传的文件序列号发送给汇总节点,汇总节点按照文件序列号到对应的处理节点,从上述处理节点1、2、N上提取与文件序列号5、3、2对应的话单文件。Assuming that there are N processing nodes, taking
本发明话单文件的传输方法的第三实施例流程图如图12所示,该实施例示出了汇总节点将查询文件序列号后向对应的处理节点获取的话单文件传输给计费中心的过程:The flow chart of the third embodiment of the transmission method of the bill file of the present invention is shown in Figure 12. This embodiment shows the process that the summarizing node obtains the bill file from the query file serial number to the corresponding processing node and transmits it to the billing center :
步骤1201:汇总节点保存预先设置的每次向计费中心提供的话单文件的数量。Step 1201: The summarizing node saves the preset number of bill files provided to the billing center each time.
步骤1202:汇总节点向分配节点查询与当前已分配的文件序列号对应的处理节点。Step 1202: The aggregation node inquires the allocation node for the processing node corresponding to the currently allocated file serial number.
如果计费网关系统中存在独立于处理节点的分配节点为各个处理节点分配唯一且连续的文件序列号和话单流水号,则分配节点在每一次分配后可以保存分配成功的文件序列号与处理节点之间的对应关系。例如,如果分配节点将文件序列号5分配给了处理节点K,则在分配节点中保存文件序列号5和处理节点K之间的对应关系。根据上述存储的对应关系,汇总节点可以向分配节点查询与已分配的文件序列号对应的处理节点。If there is an allocation node independent of the processing nodes in the billing gateway system that assigns unique and continuous file serial numbers and bill serial numbers to each processing node, the allocation node can save the successfully allocated file serial numbers and processing numbers after each allocation. Correspondence between nodes. For example, if the distribution node distributes the file serial number 5 to the processing node K, the corresponding relationship between the file serial number 5 and the processing node K is saved in the distribution node. According to the above-mentioned stored correspondence, the summarizing node can inquire about the processing node corresponding to the allocated file serial number from the allocating node.
假设汇总节点向分配节点查询文件序列号为5的话单文件的存储位置,则分配节点根据对应关系获知该话单文件存储于处理节点K,则将处理节点K的信息发送给汇总节点。Assuming that the summarization node inquires the storage location of the bill file whose file serial number is 5 from the distribution node, the distribution node knows that the bill file is stored in the processing node K according to the corresponding relationship, and then sends the information of the processing node K to the summarization node.
步骤1203:从查询到的处理节点提取与该文件序列号对应的话单文件。Step 1203: Extract the bill file corresponding to the file serial number from the queried processing node.
处理节点根据获得的话单文件的存储位置,从处理节点K上提取与文件序列号5对应的话单文件。当然,也可以由汇总节点根据获得的话单文件的存储位置,向处理节点K发送提取文件序列号为5的话单文件的请求消息,处理节点K接收到请求消息后将文件序列号5对应的话单文件发送到汇总节点。The processing node extracts the bill file corresponding to the file serial number 5 from the processing node K according to the storage location of the obtained bill file. Of course, it is also possible for the summarizing node to send a request message for extracting the bill file whose file serial number is 5 to the processing node K according to the storage location of the obtained bill file. Files are sent to summarization nodes.
步骤1204:根据话单文件的文件序列号的先后顺序汇总获取的话单文件。Step 1204: Summarize and acquire the bill files according to the order of the file serial numbers of the bill files.
步骤1205:计费中心按文件序列号的顺序从汇总节点提取不超过预设数量的话单文件。Step 1205: The billing center extracts the bill files not exceeding a preset number from the summarizing node according to the sequence of file serial numbers.
需要说明的是,计费中心获得话单文件的方式除向汇总节点主动提取(PULL方式)话单文件外,还可以由汇总节点将汇总后的话单文件推送(PUSH方式)到计费中心。It should be noted that the billing center obtains the bill file in addition to actively extracting the bill file from the summarizing node (PULL mode), or the summarizing node pushes the summarized bill file to the billing center (PUSH mode).
在上述话单文件传输方法实施例中,汇总节点从各个处理节点获取相应的话单文件的示意图如图13所示:In the above embodiment of the bill file transmission method, a schematic diagram of the collection node obtaining the corresponding bill file from each processing node is shown in Figure 13:
假设有N个处理节点,由于分配节点中顺序分配了若干文件序列号,该图13示出了文件序列号55、56、57、58,其中文件序列号55已经分配给了处理节点2,文件序列号56已经分配给了处理节点4,文件序列号57已经分配给了处理节点1,文件序列号58已经分配给了处理节点N,汇总节点查询分配节点后,可以获取上述文件序列号55、56、57、58分别对应的处理节点2、4、1、N,然后汇总节点向上述四个处理节点提取对应四个话单文件。Assuming that there are N processing nodes, since a number of file serial numbers are sequentially allocated in the allocation node, this figure 13 shows file serial numbers 55, 56, 57, and 58, wherein file serial number 55 has been assigned to
通过本发明实施例的描述可知,应用本发明实施例可以保证所有处理节点产生唯一且连续的话单流水号和话单序列号,避免了计费中心对重复话单和话单文件的识别,由此减少计费中心对话单校验的复杂度;其次,由于通过一个汇总节点获取各个处理节点的话单文件,因此可以向计费中心提供统一的计费接口,节约了各个处理节点直接与计费中心相连时所要消耗的IP资源,避免计费网关系统的组网结构暴露给外部,在增加新的处理节点时,计费中心无需获取新增的处理节点的IP地址,使得计费中心与外部互连更加简单;再次,由于只有汇总节点与外部计费中心相连,因此避免了对外公开处理节点的组网结构和地址信息,提高了整个计费网关系统的安全性。Through the description of the embodiment of the present invention, it can be known that the application of the embodiment of the present invention can ensure that all processing nodes generate unique and continuous bill serial numbers and bill serial numbers, avoiding the billing center from identifying duplicate bills and bill files, by This reduces the complexity of bill verification in the billing center; secondly, since the bill files of each processing node are obtained through a summary node, a unified billing interface can be provided to the billing center, saving each processing node from directly contacting billing The IP resources to be consumed when the center is connected to avoid exposing the network structure of the billing gateway system to the outside. The interconnection is simpler; thirdly, since only the aggregation node is connected to the external billing center, it avoids disclosing the network structure and address information of the processing nodes to the outside world, and improves the security of the entire billing gateway system.
本领域普通技术人员可以理解实现上述实施例方法中的全部或部分步骤是可以通过程序来指令相关的硬件来完成,所述的程序可以存储于一计算机可读取存储介质中,话单文件的生成程序在执行时,包括如下步骤:处理节点接收到计费信息后进行处理,当满足生成话单文件的条件时发送请求消息,所述请求消息中携带有表示待生成的话单文件中需要包含的话单数量信息,所述信息用于请求分配在所有处理节点范围内唯一且连续的文件序列号和所述待生成的话单文件内唯一且连续的话单流水号;接收返回的与所述请求消息对应的文件序列号和话单流水号;根据所述文件序列号和话单流水号生成所述话单文件。话单文件的传输程序在执行时,包括如下步骤:汇总节点获得文件序列号,并根据所述文件序列号从对应的处理节点获取相应的话单文件,所述汇总节点为与所述处理节点位于同一计费网关系统的节点;根据所述获得文件序列号的大小,顺序汇总所述获取的话单文件;将所述汇总后的话单文件输出给计费中心。所述的存储介质,如:ROM/RAM、磁碟、光盘等。虽然通过实施例描绘了本发明,本领域普通技术人员知道,本发明有许多变形和变化而不脱离本发明的精神,希望所附的权利要求包括这些变形和变化而不脱离本发明的精神。Those of ordinary skill in the art can understand that all or part of the steps in the method of the above-mentioned embodiments can be completed by instructing related hardware through a program, and the program can be stored in a computer-readable storage medium, and the bill file When the generation program is executed, it includes the following steps: after the processing node receives the billing information, it processes it, and when it meets the conditions for generating the bill file, it sends a request message. Bill quantity information, the information is used to request the allocation of unique and continuous file serial numbers within the range of all processing nodes and the unique and continuous bill serial number in the bill file to be generated; receive the returned and the request message Corresponding file serial number and bill serial number; generating the bill file according to the file serial number and bill serial number. The transmission program of bill file comprises the following steps when executing: the collection node obtains the file serial number, and obtains the corresponding bill file from the corresponding processing node according to the file serial number, and the collection node is located at the processing node Nodes of the same billing gateway system; according to the size of the sequence numbers of the obtained files, sequentially summarize the obtained bill files; and output the summarized bill files to the billing center. The storage medium, such as: ROM/RAM, magnetic disk, optical disk, etc. While the invention has been described by way of example, those skilled in the art will appreciate that there are many variations and changes to the invention without departing from the spirit of the invention, and it is intended that the appended claims cover such variations and changes without departing from the spirit of the invention.
Claims (19)
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN 200810006118 CN101237331B (en) | 2007-12-27 | 2008-02-03 | CDR file generation method, transmission method, system and device |
Applications Claiming Priority (3)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN200710300296.9 | 2007-12-27 | ||
CN200710300296 | 2007-12-27 | ||
CN 200810006118 CN101237331B (en) | 2007-12-27 | 2008-02-03 | CDR file generation method, transmission method, system and device |
Publications (2)
Publication Number | Publication Date |
---|---|
CN101237331A true CN101237331A (en) | 2008-08-06 |
CN101237331B CN101237331B (en) | 2011-11-02 |
Family
ID=39920705
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN 200810006118 Expired - Fee Related CN101237331B (en) | 2007-12-27 | 2008-02-03 | CDR file generation method, transmission method, system and device |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN101237331B (en) |
Cited By (12)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN101415170B (en) * | 2008-11-24 | 2010-06-02 | 华为软件技术有限公司 | Custom processing method, device and system for bill |
WO2011066788A1 (en) * | 2009-12-01 | 2011-06-09 | 华为技术有限公司 | Method, apparatus and system for file transmission between support region systems |
US20110280384A1 (en) * | 2008-11-28 | 2011-11-17 | Rao Zhengguo | Method and device for generating phone bill |
CN103514216A (en) * | 2012-06-29 | 2014-01-15 | 中国银联股份有限公司 | Serial number generating method based on database system |
CN103780401A (en) * | 2014-02-26 | 2014-05-07 | 中国联合网络通信集团有限公司 | Charging method and system |
CN105119728A (en) * | 2015-09-11 | 2015-12-02 | 中国联合网络通信集团有限公司 | Network telephone charging method and network telephone charging device |
CN105871563A (en) * | 2015-01-21 | 2016-08-17 | 中国移动通信集团安徽有限公司 | Call bill acquisition method and electronic devices |
CN108074086A (en) * | 2016-11-14 | 2018-05-25 | 咪咕音乐有限公司 | Charge system |
CN109219006A (en) * | 2017-06-30 | 2019-01-15 | 中兴通讯股份有限公司 | Bill transmission method, relevant device and computer readable storage medium |
CN109981548A (en) * | 2017-12-28 | 2019-07-05 | 中移信息技术有限公司 | A kind of analysis method and device of charging message |
CN111781890A (en) * | 2020-07-14 | 2020-10-16 | 厦门海为科技有限公司 | Multi-equipment engineering communication method and system in configuration engineering |
CN111953655A (en) * | 2017-02-28 | 2020-11-17 | 华为技术有限公司 | A method and device for a server to respond to a request message in a communication system |
Family Cites Families (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
FI99073C (en) * | 1995-06-28 | 1997-09-25 | Finland Telecom Oy | Procedure for billing a computer system user as well as a computer system |
CN101005383A (en) * | 2006-01-18 | 2007-07-25 | 华为技术有限公司 | Off-line charging system and method |
CN101005532A (en) * | 2007-01-16 | 2007-07-25 | 华为技术有限公司 | Informing method, device and system for system time revision |
-
2008
- 2008-02-03 CN CN 200810006118 patent/CN101237331B/en not_active Expired - Fee Related
Cited By (19)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN101415170B (en) * | 2008-11-24 | 2010-06-02 | 华为软件技术有限公司 | Custom processing method, device and system for bill |
US20110280384A1 (en) * | 2008-11-28 | 2011-11-17 | Rao Zhengguo | Method and device for generating phone bill |
US8462924B2 (en) * | 2008-11-28 | 2013-06-11 | Zte Corporation | Method and device for generating phone bill |
EP2357857A4 (en) * | 2008-11-28 | 2014-11-12 | Zte Corp | Method and apparatus for generating phone bill |
WO2011066788A1 (en) * | 2009-12-01 | 2011-06-09 | 华为技术有限公司 | Method, apparatus and system for file transmission between support region systems |
CN103514216A (en) * | 2012-06-29 | 2014-01-15 | 中国银联股份有限公司 | Serial number generating method based on database system |
CN103514216B (en) * | 2012-06-29 | 2016-12-21 | 中国银联股份有限公司 | Serial numbers based on Database Systems generate method |
CN103780401A (en) * | 2014-02-26 | 2014-05-07 | 中国联合网络通信集团有限公司 | Charging method and system |
CN105871563A (en) * | 2015-01-21 | 2016-08-17 | 中国移动通信集团安徽有限公司 | Call bill acquisition method and electronic devices |
CN105871563B (en) * | 2015-01-21 | 2019-11-12 | 中国移动通信集团安徽有限公司 | A bill collection method and electronic equipment |
CN105119728A (en) * | 2015-09-11 | 2015-12-02 | 中国联合网络通信集团有限公司 | Network telephone charging method and network telephone charging device |
CN105119728B (en) * | 2015-09-11 | 2018-07-24 | 中国联合网络通信集团有限公司 | Networking telephone charging method and device |
CN108074086A (en) * | 2016-11-14 | 2018-05-25 | 咪咕音乐有限公司 | Charge system |
CN111953655A (en) * | 2017-02-28 | 2020-11-17 | 华为技术有限公司 | A method and device for a server to respond to a request message in a communication system |
CN111953655B (en) * | 2017-02-28 | 2023-03-10 | 华为云计算技术有限公司 | Method and equipment for server to respond to request message in communication system |
CN109219006A (en) * | 2017-06-30 | 2019-01-15 | 中兴通讯股份有限公司 | Bill transmission method, relevant device and computer readable storage medium |
CN109981548A (en) * | 2017-12-28 | 2019-07-05 | 中移信息技术有限公司 | A kind of analysis method and device of charging message |
CN109981548B (en) * | 2017-12-28 | 2021-09-10 | 中移信息技术有限公司 | Method and device for analyzing charging message |
CN111781890A (en) * | 2020-07-14 | 2020-10-16 | 厦门海为科技有限公司 | Multi-equipment engineering communication method and system in configuration engineering |
Also Published As
Publication number | Publication date |
---|---|
CN101237331B (en) | 2011-11-02 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN101237331B (en) | CDR file generation method, transmission method, system and device | |
US11411897B2 (en) | Communication method and communication apparatus for message queue telemetry transport | |
CN101827302B (en) | Processing method and unified service platform are unified in multi-service | |
CN112130996B (en) | Data monitoring control system, method, device, electronic device and storage medium | |
CN108243264A (en) | Method and system for generating a serial number | |
CN108011915A (en) | A kind of collection front-end system based on cloud communication | |
CN102130959A (en) | A system and method for implementing cloud storage resource scheduling | |
CN111629052B (en) | MEC-based content caching method, node, device and storage medium | |
CN113900810A (en) | Distributed graph processing method, system and storage medium | |
CN102930056B (en) | The search method of cloud storage system and equipment | |
CN102904913B (en) | Management method and system for cloud storage space and gateway equipment using management method | |
CN107092686A (en) | A kind of file management method and device based on cloud storage platform | |
CN107622064A (en) | A data reading method and system | |
CN102904823B (en) | A Precise Flow Control Method for Multi-User and Multi-service Based on Memory | |
CN113452806A (en) | Container adaptation SDN network management method and system based on Kubernetes system | |
CN109271113B (en) | Data management system and method based on cloud storage | |
CN103581317A (en) | Method for sharing network resources | |
Chen | Design of computer big data processing system based on genetic algorithm | |
CN115225138A (en) | Service data processing method, device and system for satellite communication service | |
CN114641014B (en) | User plane entity, configuration method, system and equipment | |
CN102904916B (en) | Set up the method for point-to-point communication, index server and system | |
CN113791733A (en) | Information storage method, device, equipment and storage medium | |
CN108418871A (en) | A cloud storage performance optimization method and system | |
CN110417860A (en) | File transfer management method, apparatus, equipment and storage medium | |
CN115580404B (en) | Data transmission method, device, computer readable medium and electronic device |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
C06 | Publication | ||
PB01 | Publication | ||
C10 | Entry into substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
C14 | Grant of patent or utility model | ||
GR01 | Patent grant | ||
CF01 | Termination of patent right due to non-payment of annual fee | ||
CF01 | Termination of patent right due to non-payment of annual fee |
Granted publication date: 20111102 Termination date: 20170203 |