CN113673832B - A method, device, equipment and medium for generating operation index data - Google Patents

Abstract

The invention relates to a method, a device, equipment and a medium for generating operation index data, wherein the method comprises the following steps of S1: performing polling check according to the cycle time defined in the configuration file, and if the check that the index data file needs to be calculated and generated, entering step S2; if the retransmission cycle is detected, the step S8 is carried out; the device comprises a main control module, an operation index calculation module and an automatic retransmission and cleaning module; the main control module is respectively connected with the operation index calculation module, the automatic retransmission and cleaning module and is provided with interfaces connected with other external service systems. Compared with the prior art, the method has the advantages of unified calculation standard, strong universality and the like.

Description

A method, device, equipment and medium for generating operation index data

Technical Field

The present invention relates to a rail transit signal system, and in particular to a method, device, equipment and medium for generating operation index data.

Background Art

At present, the subway network command center system dispatches, commands and monitors the entire operation of the subway, and its information platform will display information such as line network driving information, passenger flow, and major faults. The daily operation of the subway network command center system requires operation index data as basic data support. The index data includes but is not limited to the number of trains running, delay data, punctuality rate, maximum or minimum departure interval, number of trains departing from each station, number of planned departure trains, fulfillment rate, etc. The original data for the calculation of operation indicators comes from the data generated and stored in the database during subway operation. These massive raw data need to be processed and calculated to obtain different types of operation indicator data. Therefore, it is necessary to provide an operation indicator data generation system that conforms to the characteristics of urban rail transit operation and meets the needs of subway operators.

Since subway operation has certain industry specificity, it is necessary to generate different types of operation indicator data in real time or near real time during the operation, and these indicator data are required for various business applications such as internal subway operation management and external passenger services. The existing technology still calculates operation indicators separately for various business applications, which will lead to problems such as inconsistent indicator calculation standards, inconsistent indicator calculation results, narrow application scope, and duplication of work, which will cause interference and confusion to subway operation management personnel and passengers, and cannot well meet the various business applications and passenger service needs in the subway network.

Summary of the invention

The purpose of the present invention is to overcome the defects of the above-mentioned prior art and to provide a method, device, equipment and medium for generating operating indicator data with unified calculation standards and strong versatility.

The purpose of the present invention can be achieved by the following technical solutions:

According to a first aspect of the present invention, a method for generating operation indicator data is provided, the method comprising the following steps:

Step S1: Perform polling check according to the cycle time defined in the configuration file. If it is found that the indicator data file needs to be calculated and generated, go to step S2; if it is found that it is in the retransmission cycle, go to step S8;

Step S2: according to the operation time defined in the configuration file, the indicator calculation generation module is called through the command line parameters to prepare to generate the indicator data corresponding to the operation time. The indicator calculation generation module checks whether the command line parameters are legal. If they are legal, step S3 is executed;

Step S3: If the parameters are illegal, exit and return an error code, generate a log based on the error code, and end this polling. If the parameters are legal, enter the operation indicator file generation process and execute step S4;

Step S4: Generate an operation indicator data file of a corresponding type according to the command line parameters, and store the operation indicator data file in a designated local folder according to the configuration file, and execute step S5;

Step S5: According to the configuration file definition, if the operation indicator data file needs to be uploaded to a specified location, the main control module uploads the file to the specified remote folder and automatically clears the local expired files, and executes step S7; if the file needs to be imported into the database, execute step S6;

Step S6: Classify the operation index data, each type corresponds to a batch processing operation, and the main control module will call the corresponding batch processing operation according to the data type of the file to import the operation index data file into the database, and execute step S7;

Step S7: After the operation indicator data file is correctly transmitted to the designated location or database, the main control module returns the corresponding value according to the execution situation, judges the returned value, generates a log according to the processing situation, and ends the calculation process;

Step S8: Read the configuration of the current line according to the definition of the configuration file, obtain the list of files that need to be retransmitted by reading the information feedback file, check whether there are retransmitted files, and if so, copy the files to the local folder for FTP upload and retransmit them. If not, record the log and end the detection. Then determine whether it is in the cleaning cycle. If so, go to step S9, otherwise end the calculation process.

Step S9: According to the definition of the configuration file, read the configuration of the current line, delete the expired files in the retransmission directory, record the log and exit, and end the calculation process.

As a preferred technical solution, the operation index data file in step S4 is in CSV format, including data on the number of trains running, delay data, punctuality rate, maximum or minimum departure interval, fulfillment rate and number of online train sets.

As a preferred technical solution, the main control module in step S5 uploads the file to a designated remote folder via FTP.

According to the second aspect of the present invention, a device for the method of generating the operating indicator data is provided, which includes a main control module, an operating indicator calculation module, and an automatic retransmission and cleaning module; the main control module is respectively connected to the operating indicator calculation module, the automatic retransmission and cleaning module, and is provided with an interface for connecting to other external business systems.

As a preferred technical solution, the main control module calls the operation indicator calculation module through command line parameters. If the command line parameters are legal, the planned operation diagram and actual operation diagram data within the time period specified by the command line parameters are obtained from the operation diagram database.

As a preferred technical solution, the operation indicator calculation module generates a corresponding operation indicator data file according to the operation indicator data type specified in the command line parameters, stores it in a local folder, and sends a return value to the main control module.

As a preferred technical solution, the main control module uploads the operation indicator data file in the local folder to other business systems via FTP or calls a database import batch operation to import the operation indicator data into the database.

As a preferred technical solution, the main control module periodically calls the automatic retransmission and cleanup module to retransmit indicator data according to the error log fed back by the external business system and process expired files.

According to a third aspect of the present invention, there is provided an electronic device, comprising a memory and a processor, wherein the memory stores a computer program, and the processor implements the method when executing the program.

According to a fourth aspect of the present invention, there is provided a computer-readable storage medium having a computer program stored thereon, wherein the program implements the method described when executed by a processor.

Compared with the prior art, the present invention has the following advantages:

1. The present invention proposes and designs for the first time a method and system for uniformly calculating and generating line network operation indicators, which overcomes the defect in the prior art that various business application systems of the line network calculate operation indicators independently.

2. The present invention adopts a unified standard calculation method to complete the operation index calculation, submits it to other business application systems for use, and displays consistent index calculation results for the internal subway operation management and external passenger services, thus solving the cognitive deviations of relevant parties.

3. The present invention provides two ways to obtain operation indicator data (data file and database), which is convenient for adapting to the needs of various external business systems and enhances the versatility of the system.

BRIEF DESCRIPTION OF THE DRAWINGS

FIG1 is a schematic diagram of an operation indicator data generating device according to the present invention;

FIG2 is a flowchart of the operation indicator data generating method of the present invention;

FIG3 is a flowchart of the operation indicator data retransmission and cleaning method of the present invention.

DETAILED DESCRIPTION

The following will be combined with the drawings in the embodiments of the present invention to clearly and completely describe the technical solutions in the embodiments of the present invention. Obviously, the described embodiments are part of the embodiments of the present invention, not all of the embodiments. Based on the embodiments of the present invention, all other embodiments obtained by ordinary technicians in this field without creative work should fall within the scope of protection of the present invention.

Referring to FIG1 , the system architecture of the present invention is described. First, referring to FIG1 , the logical architecture of the present invention is introduced. It is easy for a person skilled in the art to understand the valid data unit structure inside the operating index generation system. The core of the system of the present invention is the operating index data calculation generation module and the main control module. The architecture is described separately:

1. The main control module calls the operation indicator calculation module through command line parameters. If the command line parameters are legal, the planned operation diagram and actual operation diagram data within the time period specified by the command line parameters are obtained from the operation diagram database;

2. The operation indicator calculation module generates the corresponding operation indicator data file according to the operation indicator data type specified in the command line parameters, stores it in the local folder, and sends the return value to the main control module;

3. The main control module uploads the indicator files in the local folder to other business systems via FTP or calls the database import batch operation to import the operation indicator data into the database;

4. The main control module periodically calls the automatic retransmission/cleanup module to retransmit indicator data based on the error logs fed back by the external business system and process expired files.

First, referring to FIG. 2 , the workflow of generating an operation indicator data file according to the present invention is introduced. The method comprises the following steps:

Step 100, after the system is started, polling detection is performed on the current operation cycle, and step 101 is executed;

Step 101, the system determines whether it is currently in an operation cycle and whether it is necessary to generate a new operation index file in this operation cycle. If it is necessary to generate a new index file, it goes to step 102, and the main control module calls the operation index calculation module. If it is not in an operation cycle or does not need to generate a new index file, it goes to step 109, and calls the automatic retransmission/cleaning module;

Step 102, the main control module passes the command line parameters to the indicator generation module, and the indicator generation module starts each thread in the module after receiving the command line parameters, and proceeds to step 103 to determine whether the parameters are legal;

Step 103, the operation index calculation module checks whether the command line parameters (including operation lines, operation time, and operation index type information) are legal. If the parameters are legal, it goes to step 104 to generate a specific index file. If the parameters are illegal, it goes to step 107 to exit the operation index calculation module and give a return value;

Step 104: The operation indicator calculation module generates the operation indicators of the specified type in the parameters according to the legal command line parameters, and generates an indicator file in CSV format. The generated file is placed in the local folder specified by the configuration file, and the return value of the generated function is given, and then the process goes to step 105 to judge the return value of the generated function;

Step 105, determine whether the return value of the generation function given by the operation index calculation module is 0. If the return value is 0 (indicating successful generation), end each thread of this module and proceed to step 106, where the main control module uploads the generated index file. If the return value is not 0, proceed to step 108 to generate a log;

Step 106, the main control module uploads the indicator files in the local designated folder to the designated directory in the external business system via FTP, or calls the database batch operation to upload them to the database. After the upload is completed, a return value is given and a log is generated, ending the generation and uploading process;

Step 107: The command line parameters are illegal, the operation indicator calculation module exits the call, the generation function gives a return value corresponding to the error, and then goes to step 108 to generate a log according to the return value;

Step 108, the main control module generates logs according to each return value and then exits the call, ending the current generation and uploading process;

Step 109: The main control module calls the automatic retransmission/cleanup module.

Referring to FIG3 , the workflow of the automatic retransmission/cleanup module for upload failure, missed transmission, and expired index files in this system is introduced.

Step 201: After the system starts, periodic polling is performed to determine whether the system is currently in a retransmission cycle. If the system is in a retransmission cycle, the system proceeds to step 202 to obtain a list of retransmission files. If the system is not in a retransmission cycle, the system proceeds to step 205 to determine whether the system is in a cleanup cycle.

Step 202, the automatic retransmission module reads the feedback file obtained by the system, obtains the retransmission file list of this line, and enters step 203 to perform the retransmission operation;

Step 203, the automatic retransmission module copies the files in the retransmission folder to the local folder for FTP upload or batch imports them into the database, and then goes to step 204 to record the log;

Step 204: after the retransmission operation is completed, a corresponding log is generated and the retransmission process ends;

Step 205: If the current cycle is not in the retransmission cycle, determine whether the current cycle is in the cleaning cycle. If it is in the cleaning cycle, proceed to step 206 to clean up expired files. If it is not in the cleaning cycle, re-determine the current cycle and return to step 201;

Step 206: The automatic cleaning module deletes expired files in the retransmission directory according to the definition of the configuration file, records a log and ends this cleaning process.

Taking the fulfillment rate as an example, the process of generating operating indicators is explained. First, the main control module polls periodically. At the beginning of every 5 minutes, such as 9:00, 9:05, 9:10, etc., it generates command line parameters for generating the fulfillment rate and passes the command line parameters to the indicator generation module. The indicator generation module verifies the legitimacy of the command line parameters. After verification, the indicator generation module starts internal operations, reads the planned timetable data of the day and the actual timetable data of the day to the call time from the database, and groups the timetable data according to the train number. According to the train number of the planned departure train number, the corresponding data is searched in the actual arrival and departure data. If the data exists in the actual arrival and departure data, the trip is marked as fulfilled, and the query and comparison of all planned trains are completed in turn. The number of fulfilled trips is divided by the planned departure train number to obtain the fulfillment rate data. The fulfillment rate calculation result data will be saved in a local folder in the form of a CSV file, and the main control module uploads it to the target folder specified by the external business system by FTP. If an external business system reports that the uploaded indicator data is missing, the missing indicator file will be uploaded again during the retransmission cycle of the automatic retransmission module.

The electronic device of the present invention includes a central processing unit (CPU), which can perform various appropriate actions and processes according to computer program instructions stored in a read-only memory (ROM) or loaded from a storage unit into a random access memory (RAM). In the RAM, various programs and data required for device operation can also be stored. The CPU, ROM and RAM are connected to each other via a bus. An input/output (I/O) interface is also connected to the bus.

Multiple components in the device are connected to the I/O interface, including: input units, such as keyboards, mice, etc.; output units, such as various types of displays, speakers, etc.; storage units, such as disks, optical disks, etc.; and communication units, such as network cards, modems, wireless communication transceivers, etc. The communication unit allows the device to exchange information/data with other devices through computer networks such as the Internet and/or various telecommunication networks.

The processing unit performs the various methods and processes described above, such as steps 100 to 109. For example, in some embodiments, steps 100 to 109 may be implemented as a computer software program, which is tangibly contained in a machine-readable medium, such as a storage unit. In some embodiments, part or all of the computer program may be loaded and/or installed on the device via a ROM and/or a communication unit. When the computer program is loaded into the RAM and executed by the CPU, one or more of steps 100 to 109 described above may be performed. Alternatively, in other embodiments, the CPU may be configured to perform steps 100 to 109 in any other appropriate manner (e.g., by means of firmware).

The functions described above herein may be performed at least in part by one or more hardware logic components. For example, without limitation, exemplary types of hardware logic components that may be used include: field programmable gate arrays (FPGAs), application specific integrated circuits (ASICs), application specific standard products (ASSPs), systems on chip systems (SOCs), complex programmable logic devices (CPLDs), and the like.

The program code for implementing the method of the present invention can be written in any combination of one or more programming languages. These program codes can be provided to a processor or controller of a general-purpose computer, a special-purpose computer or other programmable data processing device, so that the program code, when executed by the processor or controller, enables the functions/operations specified in the flow chart and/or block diagram to be implemented. The program code can be executed entirely on the machine, partially on the machine, partially on the machine as a stand-alone software package and partially on a remote machine, or entirely on a remote machine or server.

In the context of the present invention, a machine-readable medium may be a tangible medium that may contain or store a program for use by or in conjunction with an instruction execution system, device, or equipment. A machine-readable medium may be a machine-readable signal medium or a machine-readable storage medium. A machine-readable medium may include, but is not limited to, electronic, magnetic, optical, electromagnetic, infrared, or semiconductor systems, devices, or equipment, or any suitable combination of the foregoing. A more specific example of a machine-readable storage medium may include an electrical connection based on one or more lines, a portable computer disk, a hard disk, a random access memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disk read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing.

The above is only a specific embodiment of the present invention, but the protection scope of the present invention is not limited thereto. Any person skilled in the art can easily think of various equivalent modifications or substitutions within the technical scope disclosed by the present invention, and these modifications or substitutions should be included in the protection scope of the present invention. Therefore, the protection scope of the present invention shall be based on the protection scope of the claims.

Claims (10)

1. A method for generating operating indicator data, characterized in that the method comprises the following steps: Step S1: Perform polling check according to the cycle time defined in the configuration file. If it is found that the indicator data file needs to be calculated and generated, go to step S2; if it is found that it is in the retransmission cycle, go to step S8; Step S2: according to the operation time defined in the configuration file, the indicator calculation generation module is called through the command line parameters to prepare to generate the indicator data corresponding to the operation time. The indicator calculation generation module checks whether the command line parameters are legal. If they are legal, step S3 is executed; Step S3: If the parameters are illegal, exit and return an error code, generate a log based on the error code, and end this polling. If the parameters are legal, enter the operation indicator file generation process and execute step S4; Step S4: Generate an operation indicator data file of a corresponding type according to the command line parameters, and store the operation indicator data file in a designated local folder according to the configuration file, and execute step S5; Step S5: According to the configuration file definition, if the operation indicator data file needs to be uploaded to a specified location, the main control module uploads the file to the specified remote folder and automatically clears the local expired files, and executes step S7; if the file needs to be imported into the database, execute step S6; Step S6: Classify the operation index data, each type corresponds to a batch processing operation, and the main control module will call the corresponding batch processing operation according to the data type of the file to import the operation index data file into the database, and execute step S7; Step S7: After the operation indicator data file is correctly transmitted to the designated location or database, the main control module returns the corresponding value according to the execution situation, judges the returned value, generates a log according to the processing situation, and ends the calculation process; Step S8: Read the configuration of the current line according to the definition of the configuration file, obtain the list of files that need to be retransmitted by reading the information feedback file, check whether there are retransmitted files, and if so, copy the files to the local folder for FTP upload and retransmit them. If not, record the log and end the detection. Then determine whether it is in the cleaning cycle. If so, go to step S9, otherwise end the calculation process. Step S9: Read the configuration of the current line according to the definition of the configuration file, delete the expired files in the retransmission directory, record the log and exit, and end the calculation process; The workflow of the automatic retransmission or cleanup module for upload failure, missed transmission, and expired index files is as follows: Step 201, after the system starts, periodic polling is performed to determine whether it is currently in a retransmission cycle. If it is in a retransmission cycle, the system proceeds to step 202 to obtain a list of retransmission files. If it is not in a retransmission cycle, the system proceeds to step 205 to determine whether it is in a cleanup cycle. Step 202, the automatic retransmission module reads the feedback file obtained by the system, obtains the retransmission file list of this line, and enters step 203 to perform the retransmission operation; Step 203, the automatic retransmission module copies the files in the retransmission folder to the local folder for FTP upload or batch imports them into the database, and then goes to step 204 to record the log; Step 204: after the retransmission operation is completed, a corresponding log is generated and the retransmission process ends; Step 205, when it is not in the retransmission cycle, determine whether the current cycle is in the cleaning cycle; if it is in the cleaning cycle, proceed to step 206 to clean up expired files; if it is not in the cleaning cycle, re-determine the current cycle and return to step 201; Step 206: The automatic cleaning module deletes expired files in the retransmission directory according to the definition of the configuration file, records a log and ends this cleaning process. 2. A method for generating operating indicator data according to claim 1, characterized in that the operating indicator data file in step S4 is in CSV format, including data on the number of trains running, delay data, punctuality rate, maximum or minimum departure interval, fulfillment rate and number of online train sets. 3. A method for generating operating indicator data according to claim 1, characterized in that the main control module in step S5 uploads the file to a designated remote folder via FTP. 4. A device for the method of generating operating indicator data as described in claim 1, characterized in that the device includes a main control module, an operating indicator calculation module, and an automatic retransmission and cleaning module; the main control module is connected to the operating indicator calculation module, the automatic retransmission and cleaning module respectively, and is provided with an interface for connecting to other external business systems. 5. The device according to claim 4 is characterized in that the main control module calls the operation indicator calculation module through command line parameters, and when the command line parameters are legal, obtains the planned operation diagram and actual operation diagram data within the time period specified by the command line parameters from the operation diagram database. 6. The device according to claim 4 is characterized in that the operating indicator calculation module generates a corresponding operating indicator data file according to the operating indicator data type specified in the command line parameters, stores it in a local folder, and sends a return value to the main control module. 7. The device according to claim 4 is characterized in that the main control module uploads the operation indicator data file in the local folder to other business systems via FTP or calls a database import batch operation to import the operation indicator data into the database. 8. The device according to claim 4 is characterized in that the main control module periodically calls the automatic retransmission and cleaning module to retransmit indicator data according to the error log fed back by the external business system and process expired files. 9. An electronic device comprising a memory and a processor, wherein the memory stores a computer program, wherein the processor implements the method according to any one of claims 1 to 3 when executing the program. 10. A computer-readable storage medium having a computer program stored thereon, wherein when the program is executed by a processor, the method according to any one of claims 1 to 3 is implemented.