CN117216142A - Service data processing method, device and system, electronic equipment and storage medium - Google Patents

Abstract

The embodiment of the invention provides a method, a device and a system for processing service data, wherein the method comprises the following steps: acquiring a service data processing notification command packet from a service data processing system; analyzing the service data processing notification command packet to obtain an analysis result; acquiring target service data from a target server according to the analysis result; and transmitting the target service data to the service data processing system so that the service data processing system processes the target service data. The processing scheme of the service data provided by the embodiment of the invention has obvious beneficial effects on improving efficiency, accuracy and the like compared with manual statistics of the service data.

Description

Business data processing methods, devices, systems, electronic equipment and storage media

Technical field

The present invention relates to the technical field of data processing, and in particular to a business data processing method, a business data processing device, a business data processing system, an electronic device, and a computer-readable storage medium.

Background technique

At present, the application of video network is becoming more and more extensive. Accordingly, business data of different businesses will also be generated in video network. If you need to collect statistics on business data in the video network, you usually need to manually obtain the business data and then perform statistical processing.

When there are many types and huge quantities of business data, manual acquisition and statistics of business data consumes a lot of labor costs, resulting in low statistical efficiency of business data and prone to statistical errors.

Contents of the invention

In view of the above problems, embodiments of the present invention are proposed to provide a business data processing method, a business data processing device, and a business data processing system that overcome the above problems or at least partially solve the above problems.

In order to solve the above problem, an embodiment of the present invention discloses a business data processing method, which is applied to the first server. The method includes: obtaining the business data processing notification command packet from the business data processing system; parsing the business data processing Notify the command package to obtain the parsing result; obtain the target business data from the target server according to the parsing result; transmit the target business data to the processing system of the business data, so that the processing system of the business data can process the target business data for processing.

Optionally, parsing the business data processing notification command packet to obtain a parsing result includes: parsing the business data processing notification command packet to obtain an identification list of the target server.

Optionally, obtaining the target service data from the target server according to the parsing result includes: when the identification list contains the identification information of the first server and the second server, notifying the service data processing command package Forwarding to the second server; obtaining the target service data from the first server and the second server.

Optionally, forwarding the business data processing notification command packet to the second server includes: if the second server is a superior cascade server of the first server, then After the identification information of the subordinate cascade server of the first server is deleted, the business data processing notification command packet is forwarded to the second server; if the second server is a subordinate cascade server of the first server, then After deleting the identification information of the upper-level cascade server of the first server in the identification list, the business data processing notification command packet is forwarded to the second server.

Optionally, obtaining the target service data from the first server and the second server includes: receiving second service data forwarded step by step by the second server; The first service data and the second service data are aggregated to obtain the target service data.

Embodiments of the present invention also disclose a business data processing method, which is applied to a business data processing system. The method includes: generating and transmitting a business data processing notification command packet to a first server; receiving data from the first server. The target business data is processed, and the target business data is processed; wherein the target business data is obtained from the target server by the parsing result of the first server according to the business data processing notification command packet.

Embodiments of the present invention also disclose a business data processing device, which is applied to the first server. The device includes: a command packet acquisition module, used to acquire the business data processing notification command packet from the business data processing system; command packet parsing Module, used to parse the business data processing notification command packet to obtain the parsing result; business data acquisition module, used to obtain the target business data from the target server according to the parsing result; business data transmission module, used to transmit the target business data to the business data processing system, so that the business data processing system processes the target business data.

Optionally, the command packet parsing module is configured to parse the business data processing notification command packet to obtain the identification list of the target server.

Optionally, the business data acquisition module includes: a command packet forwarding module, configured to forward the business data processing notification command packet when the identification list contains the identification information of the first server and the second server. to the second server; a target service data acquisition module, configured to acquire the target service data from the first server and the second server.

Optionally, the command packet forwarding module is configured to, if the second server is an upper-level cascade server of the first server, add the identifier of the lower-level cascade server of the first server in the identifier list to After the information is deleted, the business data processing notification command packet is forwarded to the second server; if the second server is a subordinate cascade server of the first server, the first server's name in the identification list is After the identification information of the upper-level cascade server is deleted, the service data processing notification command packet is forwarded to the second server.

Optionally, the target business data acquisition module includes: a level-by-level business data receiving module, used to receive the second business data forwarded level by level by the second server; a business data summary module, used to aggregate the data from the The first service data of the first server and the second service data are aggregated to obtain the target service data.

Embodiments of the present invention also disclose a business data processing system. The system includes: a command packet generation module for generating and transmitting a business data processing notification command packet to the first server; a business data processing module for receiving source data. Target business data of the first server, and process the target business data; wherein, the target business data is the parsing result of the notification command packet processed by the first server based on the business data, from the target server Get get.

Embodiments of the present invention also disclose an electronic device, including: one or more processors; and one or more machine-readable media having instructions stored thereon. When executed by the one or more processors, The electronic device is caused to execute the business data processing method as described above.

An embodiment of the present invention also discloses a computer-readable storage medium, which stores a computer program that causes the processor to execute the business data processing method as described above.

Embodiments of the present invention include the following advantages:

The business data processing solution provided by the embodiment of the present invention is applied to the first server. The first server obtains the business data processing notification command packet from the business data processing system, then parses the business data processing notification command packet to obtain the parsing result, and then obtains the target business data from the target server based on the parsing result, and finally transmits the target business data to the business Data processing system.

The business data processing solution provided by the embodiment of the present invention is applied to the first server and utilizes automation technology to process business data. Compared with manual statistics of business data, the business data processing task can be automatically performed without waiting for manual intervention, and has more advantages. High processing efficiency greatly reduces business data processing time. By parsing the business data processing notification command package and obtaining the target business data from the target server, the accuracy and consistency of the business data are improved, the possibility of human error is reduced, and the quality of business data processing is ensured. In addition, it is suitable for large-scale business data processing without manual fatigue or loss of efficiency.

To sum up, the business data processing solution provided by the embodiment of the present invention has significant beneficial effects in improving efficiency, accuracy, etc. compared with manual statistics of business data.

Description of drawings

Figure 1 is a step flow chart of a business data processing method according to an embodiment of the present invention;

Figure 2 is a step flow chart of another business data processing method according to an embodiment of the present invention;

Figure 3 is a schematic diagram of the operation flow of the business data processing system according to the embodiment of the present invention;

Figure 4 is a schematic structural diagram of a business statistics solution according to an embodiment of the present invention;

Figure 5 is a schematic flow chart of a business statistics solution according to an embodiment of the present invention;

Figure 6 is a structural block diagram of a business data processing device according to an embodiment of the present invention;

Figure 7 is a structural block diagram of a service data processing system according to an embodiment of the present invention.

Detailed ways

In order to make the above objects, features and advantages of the present invention more obvious and understandable, the present invention will be described in further detail below with reference to the accompanying drawings and specific embodiments.

The business data processing solution provided by the embodiment of the present invention is applied to the first server to process the business data. First, obtain the business data processing notification command package (command package for short) from the business data processing system. The command package contains instructions and parameters for business data processing. Parse command packages and convert them into actionable parsing results. Next, based on the parsing results, communicate with the target server and obtain the required target business data from the target server. Finally, the obtained target business data will be transmitted back to the business data processing system for further analysis and processing. The embodiments of the present invention greatly improve the efficiency and accuracy of business data processing, while reducing the reliance on manual intervention, making the business data processing process more automated and controllable.

When the service data processing method provided by the embodiment of the present invention is applied to the video network, the first server may be the core server of the video network. All business execution of the video network is based on the core server. The business data processing system sends a business data processing notification command packet to the core server. The core server parses the business data processing notification command package to obtain the parsing result. Then, the core server can obtain the target business data from the target server (current core server and/or other core servers) based on the parsing results. Finally, the core server returns the target business data to the business data processing system. The above-mentioned other core servers may be core servers cascaded with the current core server. That is, other core servers can be the upper-level cascading core servers of the current core server, and other core servers can also be the lower-level cascading core servers of the current core server.

Referring to FIG. 1 , a flow chart of steps of a business data processing method according to an embodiment of the present invention is shown. The business data processing method may be applied to the first server. The business data processing method may specifically include the following steps:

Step 101: Obtain the business data processing notification command package from the business data processing system.

In the embodiment of the present invention, the service data processing system may generate a service data processing notification command package. This command package is used to obtain business data and perform related processing on the business data. The command package can contain instructions and parameters on how to process business data, etc. These instructions and parameters can include the type of data processing (for example, statistics, filtering, grouping), time range, location of the data source and other information. The command package can be in a standardized format, such as JavaScript Object Notation (JSON for short) or Extensible Markup Language (XML for short), to facilitate parsing and processing.

Step 102: Parse the business data processing notification command package to obtain the parsing result.

In an embodiment of the present invention, the first server may use a parser or parsing algorithm to process the received business data processing notification command packet. The goal of parsing is to convert the contents of the command package into an understandable and operable form, usually represented in the form of a data structure or object. The parsing results may include all or part of the information required to perform business data processing tasks, including but not limited to: data processing type, time range, target server address, etc.

Step 103: Obtain target business data from the target server according to the parsing results.

In the embodiment of the present invention, the first server uses the information contained in the parsing result to determine the target server and communicate with the target server. Normally, the communication between the first server and the target server is based on network protocols, which may involve Hypertext Transfer Protocol (HTTP), File Transfer Protocol (FTP), security Communication protocols such as Secure FileTransfer Protocol (SFTP). Through communication with the target server, the first server requests and obtains the required target business data. The target server may be located in a local or remote location, depending on the source of the target business data. The obtained target business data can be database records, files, application programming interface (Application Programming Interface, API for short) responses, etc.

Step 104: Transmit the target business data to the business data processing system, so that the business data processing system processes the target business data.

In the embodiment of the present invention, the first server transmits the target business data obtained from the target server back to the business data processing system. The transfer is usually also over a network, using an appropriate data transfer protocol. The transmitted target business data may need to be encrypted or compressed to ensure the security and transmission efficiency of the target business data. Once the target business data transmission is completed, the business data processing system can start further data processing, analysis, storage or report generation operations to meet specific business needs.

The business data processing solution provided by the embodiment of the present invention is applied to the first server. The first server obtains the business data processing notification command packet from the business data processing system, then parses the business data processing notification command packet to obtain the parsing result, and then obtains the target business data from the target server based on the parsing result, and finally transmits the target business data to the business Data processing system.

The business data processing solution provided by the embodiment of the present invention is applied to the first server and utilizes automation technology to process business data. Compared with manual statistics of business data, the business data processing task can be automatically performed without waiting for manual intervention, and has more advantages. High processing efficiency greatly reduces business data processing time. By parsing the business data processing notification command package and obtaining the target business data from the target server, the accuracy and consistency of the business data are improved, the possibility of human error is reduced, and the quality of business data processing is ensured. In addition, it is suitable for large-scale business data processing without manual fatigue or loss of efficiency.

To sum up, the business data processing solution provided by the embodiment of the present invention has significant beneficial effects in improving efficiency, accuracy, etc. compared with manual statistics of business data.

In an exemplary embodiment of the present invention, an implementation manner of parsing the business data processing notification command packet to obtain the parsing result is to parse the business data processing notification command packet to obtain the identification list of the target server. Among them, the identification list of the target server can be used as the parsing result or a part of the parsing result. The target server's identification list can contain identification information for the target server. In the business data processing process, parsing the business data processing notification command package is a key task. This process involves decoding and analyzing the data in the command packet to extract the required information from it. In practical applications, the identification list usually contains identification information about the target server, such as IP address, host name, port number, etc.

For example: Suppose a company's business data processing system needs to obtain target business data from multiple target servers. The business data processing system delivers the notification of obtaining the target business data to the core server through a command package. The command package may contain the following content: operation code (obtaining business data), identification information of the core server where the current statistical user is located, user ID, target Server identification list (empty means all core servers are target servers), business data type (1 is conference business; 2 is live broadcast business; 3 is video phone business), data reporting method (0 means closed reporting; 1 Immediate reporting; 2 means active reporting when the network is idle; 3 means unified reporting at a designated time), reporting time, etc. Among them, if the data reporting method is 0, it means that the business data statistics function of the core server is turned off, and the core server will no longer cache, count, and report business data.

The parsing results of the embodiment of the present invention provide a clear identification list of target servers, enabling the first server to communicate with the target server in a targeted manner, which helps to improve the accuracy and efficiency of business data acquisition. In addition, since the identification information of the target server is clarified through the identification list, it helps to reduce the occurrence of business data acquisition errors.

In an exemplary embodiment of the present invention, an implementation method of obtaining target business data from the target server according to the parsing result is to notify the business data processing when the identification list contains the identification information of the first server and the second server. The command packet is forwarded to the second server, and the target service data is obtained from the first server and the second server. In the business data processing process, deciding how to obtain the target business data based on the parsing results is a key task. In actual applications, the parsing result contains the identification information of the target server, which may include the identification information of multiple target servers. According to the plurality of identification information, the first server selectively forwards the business data processing notification command packet to a specific target server, and then obtains the required target business data from the target server.

For example: Suppose an e-commerce website needs to obtain sales data from different target servers. Pass the request to core server A through a command package. The parsing result contains the identification information of core server A and core server B. Core server A forwards the command packet to core server B, and then obtains the target sales data from core server A itself and core server B.

The embodiment of the present invention allows the first server to selectively send the command packet to the appropriate target server. Using the first server as the forwarding center of the command packet not only obtains the target business data on the first server, but also obtains the target business data on the second server, achieving the acquisition of target business data distributed on multiple target servers.

In an exemplary embodiment of the present invention, another implementation method of obtaining the target business data from the target server according to the parsing result is to directly obtain the target service data from the first server when the identification list only contains the identification information of the first server. business data.

In an exemplary embodiment of the present invention, an implementation method of forwarding the business data processing notification command packet to the second server is: if the second server is the superior cascade server of the first server, then the identification list is After the identification information of the subordinate cascade server of the first server is deleted, the business data processing notification command packet is forwarded to the second server. If the second server is a subordinate cascade server of the first server, then the business data processing notification command packet is forwarded to the second server after deleting the identification information of the upper-level cascade server of the first server in the identification list.

The embodiment of the present invention can filter the identification information in the identification list according to the cascade relationship between servers, and then forward the command packet to the target server. When there are multiple target servers, there may be a cascading relationship between the target servers, where some servers may be cascading superiors to other servers and other servers may be cascading subordinates to them. In practical applications, according to the cascading relationship between servers, the first server can selectively delete the identification information of a specific server in the identification list, and then forward the business data processing notification command package to another level server to implement data processing. Distribution and coordination of processing.

For example: a global retailer's sales data is stored in multiple cascaded servers. Sales data needs to be obtained from various servers. If the first server is core server A, core server B is the upper-level cascade server of core server A, and core server C is the lower-level cascade server of core server A. When core server A forwards the command packet, it can delete the identification information of core server B from the identification list in the command packet and then forward the command packet to core server C. Moreover, when core server A forwards the command packet, it can delete the identification information of core server C from the identification list in the command packet and then forward the command packet to core server B.

The embodiment of the present invention allows deletion of redundant identification information according to the cascade relationship between servers, thereby realizing orderly distribution and coordination of command packets, improving the efficiency of business data acquisition, reducing unnecessary data transmission, thereby reducing network bandwidth and Usage of server resources.

In an exemplary embodiment of the present invention, an implementation method of obtaining target service data from the first server and the second server is to receive the second service data forwarded step by step by the second server and obtain the target service data from the first server. The first business data and the second business data are aggregated to obtain the target business data. Embodiments of the present invention involve obtaining target business data from multiple target servers, including receiving business data forwarded step by step, and then summarizing these business data to generate target business data. In actual applications, target business data may be distributed on multiple target servers. The first server receives the business data forwarded step by step and merges the business data from multiple target servers to generate target business data.

For example: Suppose a global retailer needs to aggregate sales data from different branches. The sales data of each branch is stored on a different core server. Among them, core server A collects sales data of branch m, and core server B collects sales data of branch n. Core server A receives the business data processing notification command packet sent by the business data processing system, and forwards the command packet to core server B. Core server B forwards the sales data t of branch n to its superior cascade server, namely core server A. The core server A receives the sales data t, and summarizes the sales data p of the branch m collected by it to obtain the target business data o.

Embodiments of the present invention allow the first server to effectively aggregate and integrate business data distributed on different target servers to generate comprehensive target business data without the need to manually organize and analyze multiple data sources. In addition, business data originating from different target servers can be forwarded step by step. Specifically, a core server can forward the collected business data to an upper-level cascade or lower-level cascade core server that directly sends command packets to it. This avoids the loss or duplication of business data from different target servers and helps Reduce the risk of business data errors, thereby improving the accuracy of business data summary.

Referring to FIG. 2 , a flow chart of steps of another business data processing method according to an embodiment of the present invention is shown. The business data processing method can be applied to the business data processing system. The business data processing method specifically includes the following steps:

Step 201: Generate and transmit a business data processing notification command package to the first server.

In the embodiment of the present invention, the business data processing system may include a client and a back-end server. Among them, the back-end server can include a user interaction module, a business data receiving module and a data processing module. The data processing module can store business data, generate report data, etc. The client mainly provides users with visual interface operation settings and data report display. The user interaction module mainly receives and processes the client's business data processing notification command packet, connects to the first server, sends the business data processing notification command packet to the first server, and at the same time forwards the user operation notification and reception to other modules of the business data processing system. Report data returned by other modules to users. The business data receiving module receives the business data reported by the first server, parses the business data and reassembles the business data that is consistent with the display to the user. The assembled business data is stored in the data storage queue in the data processing module. The data processing module obtains the business data in the data storage queue in real time and stores it in the local database. Moreover, it obtains business data from the local database and generates different business statistical report data according to user needs.

Step 202: Receive target business data from the first server and process the target business data.

In the embodiment of the present invention, the target service data is the parsing result of the first server processing the notification command packet according to the service data, and is obtained from the target server. For the introduction of this step 202, reference may be made to the relevant descriptions in the above embodiments, which will not be described again here.

Referring to FIG. 3 , a schematic diagram of the operation flow of the business data processing system in the embodiment of the present invention is shown.

The business data processing system can include clients and back-end servers. Among them, the back-end server can include a user interaction module, a business data receiving module and a data processing module. The data processing module can store business data, generate report data, etc. On the client, the system administrator logs in to the system and sets the business data acquisition mode. The main parameters include: 1. Log in to the core server user name and password; 2. Obtain business data type and other parameters. The user interaction module logs in to the core server by specifying the statistical account on the core server according to the main parameters set by the system administrator on the client. After successful login, the user interaction module sends a business data acquisition notification (business data processing notification command package) to the core server. The user interaction module receives the notification result returned from the core server. The notification result may be the response result of the core server receiving the notification of obtaining business data. The client prompts the notification result based on the notification result received by the user interaction module. Users can log in to the business data processing system through the client and obtain business statistical reports. The user interaction module obtains the statistical report type required by the user from the client and informs the data processing module of the statistical report type. The data processing module obtains database data, generates statistical reports according to statistical report types, and returns statistical report data to the user interaction module. The user interaction module returns statistical report data to the client. The client visually displays statistical report data through the user interface.

The storage process of business data in the above database is mainly as follows: the business data receiving module receives the business data reported by the core server, parses the business data and stores the parsed business data in the data storage queue of the data processing module. The data processing module obtains business data from the data storage queue and stores the business data in the database.

On the client, the system administrator can set up scheduled statistical reports and send them to designated users. The user interaction module receives the system administrator's setting information from the client, such as recording the user account, time, report type, etc. that receive the email. When the specified date is reached, the user interaction module obtains business data according to the report type. The data processing module obtains business data from the database, generates statistical reports according to the report types notified by the user interaction model, and returns statistical report data to the user interaction module. The user interaction module pushes statistical report data to the email mailbox of the specified user.

The system administrator in the embodiment of the present invention can set parameters for obtaining business data on the client, including login core server information and the type of business data obtained. The flexibility of configuration enables the business data processing system to meet different user and business needs. The user interaction module can automatically log in to the core server and send notifications to obtain business data according to the parameters set by the system administrator. It reduces the workload of system administrators and reduces errors that may be introduced by manual operations. The user interaction module can instantly feedback the results of obtaining business data notifications to the client, helping system administrators and users understand whether the operation was successful or whether further measures need to be taken. The data processing module can automatically generate statistical reports based on user needs, improving the efficiency of generating statistical reports. The client can present statistical report data to users in a visual way, making business data easier to understand and analyze. The system administrator sets up scheduled statistical reports and sends them to designated users, ensuring timely report updates and enabling users to obtain business data as planned without waiting for manual requests. The user interaction module pushes statistical report data to the designated user's email mailbox, providing an effective communication method that helps users obtain important business data in a timely manner.

In short, the above-mentioned business data processing system greatly improves the efficiency of acquiring, processing and displaying business data by providing functions such as flexibility, automation, real-time feedback and scheduled push, and helps improve the quality of decision support and data management.

Based on the above description of the embodiment of a business data processing method, a business statistics solution is introduced below. Referring to Figure 4, a schematic structural diagram of a business statistics solution according to an embodiment of the present invention is shown. The business statistics solution involves the business statistics system, core server A, and core server C. Among them, core server A and core server C each include their own main control equipment, sub-control equipment, terminal equipment, upper boundary routing equipment, and lower boundary routing equipment. The main control device serves as the brain of the core server, and there is one main control device in each core server. Each core server can have multiple sub-control devices, and the sub-control devices are cascaded under the main control device. Moreover, each core server can have multiple terminal devices, and the terminal devices are cascaded under the sub-control device. The upper boundary routing device in the core server can communicate with the main control device and is used to communicate with the lower boundary routing device in the upper-level cascade core server of the core server. The lower boundary routing device in the core server can be cascaded under the sub-control device to communicate with the upper boundary routing device in the lower-level cascaded core server of the core server. Core server A and core server C communicate based on the video network. Moreover, each device within the core server A and core server C also communicates based on the video network. Communication between the business statistics system and core server A is based on the Internet.

Referring to FIG. 5 , a schematic flow chart of a business statistics solution according to an embodiment of the present invention is shown.

The business statistics solution involves the business statistics system, core server A, core server B, and core server C. The business statistics system connects to the core server through Transmission Control Protocol Socket (TCP Socket), and logs in to the core server using the statistics account registered in the core server. The business statistics system encapsulates and obtains the business data notification command packet and sends it to the main control device of core server A. The command packet follows the rules of the video network protocol. The command includes main information: operation code (obtaining business data), prefix (identification information) of the core server where the current statistics account is located, user ID, obtaining core server prefix list (empty means obtaining all core servers), obtaining business data type (1 : Conference business; 2 Live broadcast business; 3: Video phone business), data reporting method (0: Close; 1: Instant reporting; 2: Active reporting when the video network is idle; 3: Unified reporting at a designated time), reporting time, etc. The data reporting mode is 0, which means the business data statistics function is turned off, and the core server no longer caches, counts, and reports business data.

The main control device of core server A parses the command package and obtains the core server prefix list. At the same time, according to the cascading information of the video network, the cascading relationship of all core servers in the current video network is obtained. The main control device of core server A determines whether there is an upper/lower-level cascade core server in core server A based on the core server prefix list and cascading relationship. If core server A does not have an upper/lower-level cascade core server, a notification response result is returned to the business statistics system. The notification response result may indicate that core server A does not have a cascade core server. If core server A has an upper-level/lower-level cascade core server, the main control device of core server A will forward the command packet to the upper-level/lower-level cascade server. The superior cascade core server B of core server A receives the command package. The main control device of core server B parses the command package, opens the business data reporting channel and returns the notification response result to core server A. The notification response result can represent the core Server B receives the command packet forwarded by core server A. The subordinate cascade core server C of the core server A receives the command package. The main control device of the core server C parses the command package, opens the business data reporting channel and returns the notification response result to the core server A. The notification response result can represent the core Server C receives the command packet forwarded by core server A. Core server A can return notification response results from core server B and core server C to the business statistics system. The business statistics system displays notification response results. The notification response results mainly include: operation code (obtaining business data notification response), response core server prefix, setting result (0 indicates success, other values indicate failure), etc. If the setting result is failure, the core server logged in by the business statistics system will send a command packet again at intervals, such as 5 seconds, until the setting result in the returned notification response result is success.

Core server A can forward the command packet to the upper/lower level core server through its border routing device. Specifically, if the master control device of core server A forwards the command packet to the upper-level cascading core server, it removes the prefix of the lower-level cascading core server of core server A in the identification list. If the master control device of core server A forwards the command packet to the lower-level cascading core server, it will remove the prefix of the upper-level cascading core server of core server A in the identification list.

The above-mentioned core server A is cascaded under core server B, and core server C is cascaded above core server A. The business statistics system uses the statistics account to log in to core server A. The specific forwarding process of command packets between core servers is as follows:

The main control device of core server A forwards the command packet to the sub-control device under it, and then the sub-control device forwards it to the lower boundary routing device under it. The lower boundary routing device of core server A and the upper boundary routing device of core server C are in a cascade state, so the lower boundary routing device of core server A forwards the command packet to the upper boundary routing device of core server C, and then the core server The upper boundary routing device of C forwards the command packet to the main control device of core server C.

The main control device of core server A forwards the command packet to its upper boundary routing device. The upper boundary routing device of core server A and the lower boundary routing device of core server B are in a cascade state, so the upper boundary routing device of core server A forwards the command packet to the lower boundary routing device of core server B, and then the core server The lower boundary routing device of B forwards the command packet to the sub-control device of core server B. The sub-control device of core server B forwards the command packet to the main control device of core server B.

After receiving the command packet, the master control device of the upper/lower level core server parses the command packet to obtain the prefix list (identification list). If the current core server prefix is in the prefix list, the business statistics function takes effect and the business data reporting channel is enabled. If the current core server prefix is not in the prefix list, the business statistics function is prohibited from taking effect and the business data reporting channel is closed.

After the core server that needs to report business data receives the command package, it records the source core server prefix of the command package (subsequent statistical business data is reported to the source core server. It can be simply understood as: Whoever notifies me, I will return the statistical business data to whom). The core server statistics logged in by the business statistics system come from the business data of each core server, and the business statistics results are obtained, and finally reported to the business statistics system.

When business data is generated in the core server, the main control device determines the type of business data that needs to be obtained and records the business data that meets the conditions. When the business is completed, record the business completion details and report the business data according to the data reporting method issued by the business statistics system (timely or idle or specified time). The core server internally clears the reported business data.

After the core server generates business data, if it is detected that the user account of the business statistics system has not logged in to the core server, the main control device in the core server will first save the local business data, and wait until the user account of the business statistics system logs in to the core server. Then report business data.

After the core server generates business data, it determines whether the business data reporting channel is open. If the business data reporting channel is not opened, the business data is stored locally, and then the business data is uploaded after the business data reporting channel is opened. If the business data reporting channel is enabled, the business data will be reported. Among them, core servers B and C report business data to core server A. Core server A summarizes the business data of each core server and reports it to the business statistics system. The business statistics system performs statistical analysis on the received business data.

If the core server logged in to the business statistics system is disconnected from the cascaded core server (no communication is detected), the core server logged in to the business statistics system first reports the obtained business data, and then obtains it after the communication with the cascaded core server is restored. Cascade the business data on the core server and report it to the business statistics system.

The business statistics system provided by the embodiment of the present invention establishes a connection with the core server through TCP Socket, and can automatically send the business data acquisition notification command package to the core server, reducing the need for manual intervention and making the data collection process more efficient and reliable. The core server can immediately respond to notification requests from the business statistics system, whether successful or failed. The notification response results are quickly fed back to the business statistics system, which helps the business statistics system understand the request status and avoid unnecessary waiting. Since the core server prefix of the source of business data is recorded, the business statistics system can track the source of business data and ensure the attribution and accuracy of business data. The core server determines the forwarding method of the command packet based on the prefix list and cascade relationship, which helps route the command packet to the correct core server and reduces unnecessary data transmission and processing. When the user account of the business statistics system is not logged in to the core server, the core server can automatically save the business data and report it after the user logs in, ensuring that the business data will not be lost because the user is not logged in. The communication mechanism between the business statistics system and the core server can handle disconnection situations, ensure that business data will not be lost, and continue data transmission after communication is restored, improving fault tolerance and reliability.

It should be noted that for the sake of simple description, the method embodiments are expressed as a series of action combinations. However, those skilled in the art should know that the embodiments of the present invention are not limited by the described action sequence because According to embodiments of the present invention, certain steps may be performed in other orders or simultaneously. Secondly, those skilled in the art should also know that the embodiments described in the specification are preferred embodiments, and the actions involved are not necessarily necessary for the embodiments of the present invention.

Referring to FIG. 6 , a structural block diagram of a service data processing device according to an embodiment of the present invention is shown. The business data processing device is applied to the first server. The business data processing device may specifically include the following modules.

The command package acquisition module 61 is used to obtain the business data processing notification command package from the business data processing system;

The command packet parsing module 62 is used to parse the business data processing notification command packet to obtain the parsing result;

The business data acquisition module 63 is used to acquire the target business data from the target server according to the parsing result;

The business data transmission module 64 is used to transmit the target business data to the business data processing system, so that the business data processing system processes the target business data.

In an exemplary embodiment of the present invention, the command packet parsing module 62 is configured to parse the business data processing notification command packet to obtain an identification list of the target server.

In an exemplary embodiment of the present invention, the business data acquisition module 63 includes:

A command packet forwarding module, configured to forward the business data processing notification command packet to the second server when the identification list contains the identification information of the first server and the second server;

A target service data acquisition module is configured to obtain the target service data from the first server and the second server.

In an exemplary embodiment of the present invention, the command packet forwarding module is configured to forward the first server in the identification list if the second server is a superior cascade server of the first server. After the identification information of the server's subordinate cascade server is deleted, the business data processing notification command packet is forwarded to the second server; if the second server is a subordinate cascade server of the first server, the identification information is forwarded to the second server. After the identification information of the upper-level cascade server of the first server in the list is deleted, the business data processing notification command packet is forwarded to the second server.

In an exemplary embodiment of the present invention, the target business data acquisition module includes:

A step-by-step service data receiving module, configured to receive the second service data forwarded step by step by the second server;

A business data summary module is used to summarize the first business data and the second business data from the first server to obtain the target business data.

Referring to FIG. 7 , a structural block diagram of a service data processing system according to an embodiment of the present invention is shown. The business data processing system may specifically include the following modules.

The command packet generation module 71 is used to generate and transmit the business data processing notification command packet to the first server;

The business data processing module 72 is used to receive target business data from the first server and process the target business data;

Wherein, the target service data is the parsing result of the first server processing notification command packet according to the service data, and is obtained from the target server.

As for the device and system embodiments, since they are basically similar to the method embodiments, the descriptions are relatively simple. For relevant details, please refer to the partial description of the method embodiments.

Each embodiment in this specification is described in a progressive manner. Each embodiment focuses on its differences from other embodiments. The same and similar parts between the various embodiments can be referred to each other.

It should be understood by those skilled in the art that embodiments of the present invention may be provided as methods, devices, or computer program products. Thus, embodiments of the present invention may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment that combines software and hardware aspects. Furthermore, embodiments of the invention may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, etc.) having computer-usable program code embodied therein.

Embodiments of the invention are described with reference to flowcharts and/or block diagrams of methods, terminal devices (systems), and computer program products according to embodiments of the invention. It will be understood that each process and/or block in the flowchart illustrations and/or block diagrams, and combinations of processes and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general-purpose computer, special-purpose computer, embedded processor, or other programmable data processing terminal device to produce a machine such that the instructions are executed by the processor of the computer or other programmable data processing terminal device. Means are generated for implementing the functions specified in the process or processes of the flowchart diagrams and/or the block or blocks of the block diagrams.

These computer program instructions may also be stored in a computer-readable memory that causes a computer or other programmable data processing terminal equipment to operate in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including the instruction means, the The instruction means implements the functions specified in a process or processes of the flowchart and/or a block or blocks of the block diagram.

These computer program instructions can also be loaded onto a computer or other programmable data processing terminal equipment, so that a series of operating steps are performed on the computer or other programmable terminal equipment to produce computer-implemented processing, thereby causing the computer or other programmable terminal equipment to perform a computer-implemented process. The instructions executed on provide steps for implementing the functions specified in a process or processes of the flow diagrams and/or a block or blocks of the block diagrams.

Although preferred embodiments of the embodiments of the present invention have been described, those skilled in the art will be able to make additional changes and modifications to these embodiments once the basic inventive concepts are apparent. Therefore, it is intended that the appended claims be construed to include the preferred embodiments and all changes and modifications that fall within the scope of embodiments of the invention.

Finally, it should be noted that in this article, relational terms such as first and second are only used to distinguish one entity or operation from another entity or operation, and do not necessarily require or imply that these entities or any such actual relationship or sequence between operations. Furthermore, the terms "comprises," "comprises," or any other variation thereof are intended to cover a non-exclusive inclusion such that a process, method, article, or end device that includes a list of elements includes not only those elements, but also elements not expressly listed or other elements inherent to such process, method, article or terminal equipment. Without further limitation, an element defined by the statement "comprises a..." does not exclude the presence of additional identical elements in a process, method, article or terminal device including the stated element.

The above has introduced in detail a business data processing method, a business data processing device and a business data processing system provided by the present invention. Specific examples are used in this article to illustrate the principles and implementations of the present invention. The description of the above embodiments is only used to help understand the method and its core idea of the present invention; at the same time, for those of ordinary skill in the art, there will be changes in the specific implementation and application scope according to the idea of the present invention. In summary, the contents of this description should not be construed as limitations of the present invention.

Claims (10)

1. A method for processing business data, characterized in that it is applied to the first server, and the method includes: Obtain the business data processing notification command package from the business data processing system; Parse the business data processing notification command package to obtain the parsing result; Obtain target business data from the target server according to the parsing results; The target service data is transmitted to the service data processing system, so that the service data processing system processes the target service data. 2. The method according to claim 1, characterized in that said parsing the business data processing notification command packet to obtain parsing results includes: The service data processing notification command packet is parsed to obtain the identification list of the target server. 3. The method according to claim 2, characterized in that, obtaining the target business data from the target server according to the parsing result includes: When the identification list contains the identification information of the first server and the second server, forward the business data processing notification command packet to the second server; Obtain the target service data from the first server and the second server. 4. The method according to claim 3, wherein forwarding the business data processing notification command packet to the second server includes: If the second server is the upper-level cascade server of the first server, then after deleting the identification information of the lower-level cascade server of the first server in the identification list, the business data processing notification command packet is forwarded to the second server; If the second server is a lower-level cascade server of the first server, then after deleting the identification information of the upper-level cascade server of the first server in the identification list, the business data processing notification command packet is forwarded to the second server. 5. The method according to claim 3, wherein the obtaining the target service data from the first server and the second server includes: Receive second service data forwarded step by step by the second server; The first service data and the second service data originating from the first server are summarized to obtain the target service data. 6. A business data processing method, characterized in that it is applied to a business data processing system, and the method includes: Generate and transmit the business data processing notification command package to the first server; Receive target business data from the first server, and process the target business data; Wherein, the target service data is the parsing result of the first server processing notification command packet according to the service data, and is obtained from the target server. 7. A business data processing device, characterized in that it is applied to the first server, and the device includes: The command package acquisition module is used to obtain the business data processing notification command package from the business data processing system; A command package parsing module, used to parse the business data processing notification command package to obtain parsing results; A business data acquisition module, configured to acquire target business data from the target server according to the parsing results; A business data transmission module is used to transmit the target business data to the business data processing system, so that the business data processing system processes the target business data. 8. A business data processing system, characterized in that the system includes: The command packet generation module is used to generate and transmit the business data processing notification command packet to the first server; A business data processing module, configured to receive target business data from the first server and process the target business data; Wherein, the target service data is the parsing result of the first server processing notification command packet according to the service data, and is obtained from the target server. 9. An electronic device, characterized in that it includes: one or more processors; and One or more machine-readable media having instructions stored thereon that, when executed by the one or more processors, cause the electronic device to perform processing of business data as claimed in any one of claims 1 to 6 method. 10. A computer-readable storage medium, characterized in that the computer program stored therein causes the processor to execute the business data processing method according to any one of claims 1 to 6.