CN116204295B - Task execution method and device, electronic equipment and storage medium - Google Patents
Task execution method and device, electronic equipment and storage mediumInfo
- Publication number
- CN116204295B CN116204295B CN202310219881.5A CN202310219881A CN116204295B CN 116204295 B CN116204295 B CN 116204295B CN 202310219881 A CN202310219881 A CN 202310219881A CN 116204295 B CN116204295 B CN 116204295B
- Authority
- CN
- China
- Prior art keywords
- time
- reference information
- consuming process
- information
- newspaper
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/48—Program initiating; Program switching, e.g. by interrupt
- G06F9/4806—Task transfer initiation or dispatching
- G06F9/4843—Task transfer initiation or dispatching by program, e.g. task dispatcher, supervisor, operating system
- G06F9/4881—Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3003—Monitoring arrangements specially adapted to the computing system or computing system component being monitored
- G06F11/3006—Monitoring arrangements specially adapted to the computing system or computing system component being monitored where the computing system is distributed, e.g. networked systems, clusters, multiprocessor systems
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3003—Monitoring arrangements specially adapted to the computing system or computing system component being monitored
- G06F11/3017—Monitoring arrangements specially adapted to the computing system or computing system component being monitored where the computing system is implementing multitasking
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/34—Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation ; Recording or statistical evaluation of user activity, e.g. usability assessment
- G06F11/3409—Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation ; Recording or statistical evaluation of user activity, e.g. usability assessment for performance assessment
- G06F11/3419—Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation ; Recording or statistical evaluation of user activity, e.g. usability assessment for performance assessment by assessing time
- G06F11/3423—Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation ; Recording or statistical evaluation of user activity, e.g. usability assessment for performance assessment by assessing time where the assessed time is active or idle time
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/54—Indexing scheme relating to G06F9/54
- G06F2209/547—Messaging middleware
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Computing Systems (AREA)
- Software Systems (AREA)
- Quality & Reliability (AREA)
- Mathematical Physics (AREA)
- Computer Hardware Design (AREA)
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
Abstract
The embodiment of the application provides a task execution method, a task execution device, electronic equipment and a storage medium, and relates to the technical field of data processing. The method comprises the steps of responding to an execution instruction of a designated processing task aiming at least one designated time consuming process, determining target entrusting information serving as an analysis standard, determining reference information corresponding to each designated time consuming process based on a preset mapping relation between the time consuming process in a newspaper and newspaper flow and the reference information, calculating time consumption corresponding to each designated time consuming process according to a time consumption calculation mode corresponding to the designated time consuming process by utilizing the reference information corresponding to the designated time consuming process aiming at each designated time consuming process, and carrying out the designated processing task by utilizing the time consumption corresponding to each designated time consuming process. Therefore, by the scheme, the appointed processing task related to the time-consuming process existing in the newspaper-disc flow can be effectively executed under the condition that the trading exchange gateway and the trading exchange matching system do not disclose logs.
Description
Technical Field
The present application relates to the field of data processing technologies, and in particular, to a task execution method, a task execution device, an electronic device, and a storage medium.
Background
The securities newspaper-disc system is widely applied to securities trade systems and is used for realizing trade and newspaper-disc flow. The trade flow is the flow of the dealer accepting client commission and returning commission result to the client, and the report flow is the process of sending client commission to the exchange matching system and receiving commission receipt information returned by the exchange matching system.
In the process of realizing the trade and the newspaper-disc process, data transmission of a plurality of components is generally involved, for example, in a securities newspaper-disc system, there are four components of trade middleware, newspaper-disc middleware, exchange gateway and exchange matching system, wherein the trade middleware is used for receiving client consignment information and converting the consignment information into a format acceptable by the exchange matching system, for example, a FIX (FINANCIAL INFORMATION EXCHANGE PROTOCOL ) format, the newspaper-disc middleware, the exchange gateway and the exchange matching system are used for the newspaper-disc process, the newspaper-disc middleware receives consignment information sent by the trade middleware and sends the consignment information to the exchange matching system through the exchange gateway so as to process the consignment information, and when the exchange matching system receives the consignment information, return receipt information representing the consignment information immediately and send the consignment information to the newspaper-disc middleware through the exchange gateway. Based on data transmission of multiple components, the newspaper disc flow of any consignment information of a client is generally divided into five time consuming processes, namely a first time consuming process, a second time consuming process, a third time consuming process, a fourth time consuming process and a fifth time consuming process, wherein the first time consuming process is a time consuming process that a transaction middleware sends a first newspaper disc request message carrying consignment information to the newspaper disc middleware, the second time consuming process is a time consuming process that the newspaper disc middleware processes a second newspaper disc request message carrying consignment information to be forwarded by the newspaper disc middleware, the third time consuming process is a time consuming process that a transaction exchange matching system sends a first receipt message carrying receipt content corresponding to consignment information to a transaction exchange gateway, the fourth time consuming process is a time consuming process that the transaction exchange gateway sends a second receipt message carrying receipt content to the newspaper disc middleware, the second receipt message is generated based on receipt content in the first receipt message, and the fifth time consuming process is an overall newspaper disc executing process corresponding to the consignment information.
For the above time consuming process, there are typically some designated processing tasks that need to take advantage of the time consumption of each time consuming process, such as an abnormal time consuming early warning for the time consuming process. However, the system for matching the exchange gateway with the exchange generally does not disclose logs, which certainly affects the acquisition of time information related to the system for matching the exchange gateway with the exchange in the newspaper board process, thereby limiting the execution of the designated processing task.
Then, how to effectively execute the specified processing task related to the time-consuming process existing in the newspaper-disc process is a problem to be solved under the condition that the exchange gateway and the exchange matching system do not generally disclose logs.
Disclosure of Invention
The embodiment of the application aims to provide a task execution method, a device, electronic equipment and a storage medium, so as to effectively execute a designated processing task related to a time-consuming process existing in a newspaper-disc flow under the condition that a trade gateway and a trade matching system do not disclose logs. The specific technical scheme is as follows:
In a first aspect, an embodiment of the present application provides a task execution method, which is applied to an electronic device, where the method includes:
Determining target commission information serving as an analysis reference in response to receiving an execution instruction of a designated processing task for at least one designated time-consuming process, wherein the at least one designated time-consuming process is at least one time-consuming process in each time-consuming process in the newspaper-disc flow;
Determining reference information corresponding to each appointed time consuming process based on a preset mapping relation between time consuming processes and reference information in a newspaper disc process, wherein the reference information corresponding to any time consuming process is time consuming information for calculating the time consuming process, and the reference information corresponding to any time consuming process comprises one or more of first reference information, second reference information and third reference information, wherein the first reference information is a target newspaper disc request message which is generated by the newspaper disc middleware and carries the target consignment information, the second reference information is log information which is recorded by the newspaper disc middleware and aims at the target consignment information, and the third reference information is a target receipt message which is sent by a transaction gateway and carries receipt contents corresponding to the target consignment information and is received by the newspaper disc middleware;
Calculating the time consumption corresponding to the appointed time consuming process according to the time consumption calculation mode corresponding to the appointed time consuming process by utilizing the reference information corresponding to the appointed time consuming process;
and carrying out the appointed processing task by using the time consumption corresponding to each appointed time consumption process.
Optionally, the appointed processing task comprises an early warning analysis task;
performing the specified processing task by using the time consumption corresponding to each specified time consumption process, including:
And outputting early warning information for representing that the specified time consuming process has abnormal time consumption if the time consumption corresponding to the specified time consuming process exceeds a preset time consumption threshold corresponding to the specified time consuming process aiming at each specified time consuming process.
Optionally, the specified processing task comprises a time-consuming output task;
performing the specified processing task by using the time consumption corresponding to each specified time consumption process, including:
and sending the time consumption corresponding to each appointed time consumption process to a preset data receiving end so that the data receiving end displays the time consumption corresponding to each appointed time consumption process.
Optionally, the reference information corresponding to the first time consuming process includes the first reference information and the second reference information, the reference information corresponding to the second time consuming process includes the first reference information and the second reference information, the reference information corresponding to the third time consuming process includes the third reference information, the reference information corresponding to the fourth time consuming process includes the second reference information and the third reference information, and the reference information corresponding to the fifth time consuming process includes the second reference information.
Optionally, the time-consuming calculation mode corresponding to the first time-consuming process includes subtracting the first time carried by the first reference information from the second time carried by the first reference information to obtain the time consumption of the first time-consuming process;
the time consumption calculation formula corresponding to the second time consumption process comprises subtracting the second time from the third time recorded in the second reference information to obtain the time consumption corresponding to the second time consumption process;
Subtracting the fourth time carried in the third reference information from the fifth time carried in the third reference information to obtain the time consumption corresponding to the third time consumption process;
the time consumption calculation mode corresponding to the fourth time consumption process comprises the steps of subtracting the fifth time by utilizing the sixth time recorded by the second reference information to obtain the time consumption corresponding to the fourth time consumption process;
The time consumption calculation formula corresponding to the fifth time consumption process comprises subtracting the third time from the sixth time to obtain the time consumption of the fifth time consumption process;
The method comprises the steps of generating a receipt request message carrying target entrusting information for a trading gateway according to a first time, generating a receipt request message carrying target entrusting information for the trading gateway according to a second time, wherein the second time is the generation time of the first reference information, the third time is the sending time of the first reference information, the fourth time is the time for generating a receipt message carrying receipt content for sending to the trading gateway by the trading matching system, the fifth time is the time for generating the target receipt message by the trading gateway, and the sixth time is the time for receiving the target receipt message by the newspaper disc middleware.
In a second aspect, an embodiment of the present application provides a task execution device, including:
The system comprises a first determining module, a first processing module and a second determining module, wherein the first determining module is used for determining target commission information serving as an analysis reference in response to receiving an execution instruction of a designated processing task aiming at least one designated time-consuming process, wherein the at least one designated time-consuming process is at least one time-consuming process in various time-consuming processes in a newspaper-disc process;
The system comprises a first determining module, a second determining module and a third determining module, wherein the first determining module is used for determining reference information corresponding to each appointed time consuming process based on a preset mapping relation between time consuming processes and reference information in a newspaper disc process, the reference information corresponding to any time consuming process is time consuming information used for calculating the time consuming process, the reference information corresponding to any time consuming process comprises one or more of first reference information, second reference information and third reference information, the first reference information is a target newspaper disc request message which is generated by the newspaper disc middleware and carries the target consignment information, the second reference information is log information which is recorded by the newspaper disc middleware and aims at the target consignment information, and the third reference information is a target receipt message which is sent by a transaction gateway and carries receipt contents corresponding to the target consignment information and is received by the newspaper disc middleware;
The computing module is used for computing the time consumption corresponding to the appointed time consumption process according to the time consumption computing mode corresponding to the appointed time consumption process by utilizing the reference information corresponding to the appointed time consumption process;
and the task processing module is used for carrying out the appointed processing task by utilizing the time consumption corresponding to each appointed time consumption process.
Optionally, the appointed processing task comprises an early warning analysis task;
the task processing module comprises:
The output unit is used for outputting early warning information used for representing that the specified time consuming process has abnormal time consuming according to each specified time consuming process if the time consuming corresponding to the specified time consuming process exceeds a preset time consuming threshold corresponding to the specified time consuming process.
Optionally, the specified processing task comprises a time-consuming output task;
the task processing module comprises:
And the sending unit is used for sending the time consumption corresponding to each appointed time consumption process to a preset data receiving end so that the data receiving end displays the time consumption corresponding to each appointed time consumption process.
In a third aspect, an embodiment of the present application provides an electronic device, including a processor, a communication interface, a memory, and a communication bus, where the processor, the communication interface, and the memory complete communication with each other through the communication bus;
a memory for storing a computer program;
and the processor is used for realizing any one of the task execution methods when executing the program stored in the memory.
In a fourth aspect, an embodiment of the present application further provides a computer readable storage medium, where a computer program is stored, where the computer program is executed by a processor to implement any one of the task execution methods described above.
The embodiment of the application has the beneficial effects that:
According to the task execution method, the device, the electronic equipment and the storage medium, after an execution instruction of an appointed processing task aiming at least one appointed time consuming process is received, target entrusting information serving as an analysis reference is determined, then, based on a preset mapping relation between the time consuming process in a newspaper-disc process and reference information, reference information corresponding to each appointed time consuming process is determined, the time consumption of the appointed time consuming process is calculated by using the determined reference information corresponding to the appointed time consuming process, and then, the appointed processing task is carried out by using the time consumption corresponding to each appointed time consuming process.
Therefore, the time consumption corresponding to each appointed time consumption process can be calculated only by using the data acquired by the newspaper disc middleware, and the appointed processing task can be carried out by using the time consumption corresponding to each appointed time consumption process. Therefore, the scheme can effectively execute the appointed processing task related to the time-consuming process existing in the newspaper-disc flow under the condition that the exchange gateway and the exchange matching system do not disclose logs.
Of course, it is not necessary for any one product or method of practicing the application to achieve all of the advantages set forth above at the same time.
Drawings
In order to more clearly illustrate the embodiments of the application or the technical solutions in the prior art, the drawings used in the embodiments or the description of the prior art will be briefly described below, and it is obvious that the drawings in the following description are only some embodiments of the application, and other embodiments may be obtained according to these drawings to those skilled in the art.
FIG. 1 is a schematic flow diagram of a newspaper disc flow according to an embodiment of the present application;
FIG. 2 is a schematic flow chart of a task execution method according to an embodiment of the present application;
FIG. 3 is a schematic diagram of a task execution device according to an embodiment of the present application;
fig. 4 is a schematic structural diagram of an electronic device according to an embodiment of the present application.
Detailed Description
The following description of the embodiments of the present application will be made clearly and completely with reference to the accompanying drawings, in which it is apparent that the embodiments described are only some embodiments of the present application, but not all embodiments. Based on the embodiments of the present application, all other embodiments obtained by the person skilled in the art based on the present application are included in the scope of protection of the present application.
The following first explains the terms involved in the present application:
FIX (FINANCIAL INFORMATION EXCHANGE PROTOCOL ), each FIX message is composed of a series of fields with < reference > = < value >. Each label represents a different meaning and may be the type of information, the name of the target business, the price of the securities purchase, etc.
In order to better understand the scheme of the present application, a description will be given below of the newspaper disc process in detail with reference to fig. 1.
As shown in fig. 1, there are four components in the newspaper disc process, namely, transaction middleware, newspaper disc middleware, exchange gateway and exchange matching system. The exchange gateway and the exchange matching system are components of exchanges, the exchange matching system is arranged at the exchange end, but the exchange gateway is arranged at the dealer end and used for realizing data interaction between the dealer end components and the exchange end components. The transaction middleware generates FIX message content, which is the format of the transaction middleware converting the client's target commission information into FIX protocol, each FIX message is composed of a series of fields with < reference number > = < value >, the value corresponding to reference number 60 in the figure indicates the time of generating FIX message content, and the value corresponding to reference number 52 indicates the time of generating FIX message. The FIX message content generated by the transaction middleware not only comprises the content of the target commission information, but also comprises the time of generating the FIX message content by the transaction middleware.
The newspaper disc middleware receives the FIX message which is sent by the transaction middleware and contains the target commission information, generates the FIX message (also called newspaper disc FIX information in fig. 1) carrying the target commission information, and the newspaper disc FIX information generated by the newspaper disc middleware contains the content of the target commission information, the transaction middleware generation FIX message content time and the newspaper disc FIX information time generated by the newspaper disc middleware (namely, the newspaper disc middleware generation FIX message time in fig. 1), so that the transaction middleware generation FIX message content time and the newspaper disc FIX message time generated by the newspaper disc middleware can be obtained only by using the newspaper disc FIX information generated by the newspaper disc middleware.
The first time-consuming process in the newspaper-disc process is the time-consuming process that the transaction middleware sends the FIX message content generated by the transaction middleware to the newspaper-disc middleware. It can be understood that the first time-consuming process is also the time consumed by the newspaper disc middleware to receive the FIX message content generated by the transaction middleware and generate newspaper disc FIX information at the same time, and the first time-consuming process is a preparation stage in the newspaper disc process.
After generating the newspaper disc FIX information, the newspaper disc middleware sends the newspaper disc FIX information to the exchange matching system through the exchange gateway, but the newspaper disc middleware receives the newspaper disc FIX messages corresponding to a plurality of different consignment information, and needs to send the newspaper disc FIX messages corresponding to the consignment information to the corresponding exchanges according to the content of the consignment information aiming at the different consignment information. Therefore, after the newspaper disc middleware receives the FIX message sent by the transaction middleware and generates newspaper disc FIX information at the same time, it is necessary to queue each newspaper disc FIX message until the newspaper disc FIX message is sent. The time when the newspaper disc middleware sends the newspaper disc FIX information is recorded by the newspaper disc middleware log, namely the time when the newspaper disc FIX information is sent in the figure 1. The second time-consuming process is the time consumed by the newspaper disc middleware to process and send newspaper disc FIX information.
And the exchange matching system immediately returns an execution return message representing the received target commission message after receiving the newspaper disc FIX message forwarded by the exchange gateway, and sends the execution return message to the newspaper disc middleware through the exchange gateway, wherein the execution return message is transmitted in a FIX protocol format. The time of generating FIX message marked under the exchange matching system as shown in fig. 1 is the time of generating execution return information by the exchange matching system, and the time of generating FIX message marked under the exchange gateway is the time of generating FIX message carrying the execution return information corresponding to the target commission information by the exchange gateway. The FIX information generated by the exchange gateway not only carries the execution return information corresponding to the target commission information, but also comprises the time when the exchange matching system generates the FIX information containing the execution return information and the time when the exchange gateway generates the FIX information carrying the execution return information corresponding to the target commission information, so that after receiving the FIX information sent by the exchange gateway, the newspaper disc middleware can acquire the time when the exchange matching system generates the FIX information containing the execution return information and the time when the exchange gateway generates the FIX information carrying the execution return information corresponding to the target commission information. The execution report information may also be called a receipt message, which carries receipt content corresponding to the target delegated information, and in the embodiment described below, the physical meaning of the execution report information is the same as that described herein. And, the execution return information corresponding to the target commission information generated by the exchange gateway is generated based on the execution return information adding information generated by the exchange matching system, for example, the added information may include information such as time when the exchange gateway generates the execution return information corresponding to the target commission information, where the carried response piece content corresponding to the target commission information is unchanged.
The third time-consuming process in the newspaper-disc process is the time-consuming process that the exchange matching system sends FIX messages containing execution return information to the exchange gateway. And the fourth time consumption is the time consumption of the transaction gateway to send the generated FIX message carrying the execution return information corresponding to the target consignment information to the newspaper disc middleware.
The time when the newspaper disc middleware receives the FIX message which is generated by the exchange gateway and carries the execution return information corresponding to the target entrusting information is recorded in the log information of the newspaper disc middleware, namely the log record time of the received execution return FIX message shown in the figure. The fifth time consuming process of the newspaper board flow is the time consuming of the whole newspaper board executing process, the newspaper board middleware starts to send the generated FIX message carrying the target commission information, and the newspaper board middleware finishes to receive the FIX message carrying the execution return information corresponding to the target commission information and generated by the exchange gateway, wherein the second time consuming process, the third time consuming process and the fourth time consuming process all belong to a part of the fifth time consuming process.
In order to effectively execute a specified processing task related to a time-consuming process existing in a newspaper-disc flow under the condition that an exchange gateway and an exchange matching system do not normally disclose logs, the embodiment of the application provides a task execution method, a task execution device, electronic equipment and a storage medium.
The following first describes a task execution method provided by the embodiment of the present application. The task execution method provided by the embodiment of the application is applied to the electronic equipment. In a specific application, the electronic device may be a terminal device, a server, etc., and the terminal device may be a tablet computer, a desktop computer, etc., which is not limited by the present application.
It can be known that the newspaper-disc process involves dealer and exchange, so both dealer and exchange have the need to use the task execution method of the present application, and because the data used in the scheme of the present application are generated or received by newspaper-disc middleware, and the log information of newspaper-disc middleware is public, third party users can also use the task execution method of the present application.
Specifically, the execution subject of the task execution method may be a task execution device. When the dealer applies the task execution method provided by the application, the task execution method can be applied to dealer terminal equipment, the task execution device can be a task execution client installed on the dealer terminal equipment, the task execution device can be deployed in a newspaper-disc middleware in the form of a plug-in unit, the task execution method can also be applied to a dealer server, and the task execution device can be a computer program running in the server and used for executing the task execution method. For example, when the task execution method of the present application is applied to an exchange, the task execution method may be applied to an exchange terminal, and the task execution device may be a task execution client installed at the exchange terminal. Of course, the use scenario of the task execution method of the present application is not limited thereto, and other scenarios in which a third party user such as a regulatory department uses the method exist, which the present application is not limited thereto.
The task execution method provided by the embodiment of the application can comprise the following steps:
Determining target commission information serving as an analysis reference in response to receiving an execution instruction of a designated processing task for at least one designated time-consuming process, wherein the at least one designated time-consuming process is at least one time-consuming process in each time-consuming process in the newspaper-disc flow;
Determining reference information corresponding to each appointed time consuming process based on a preset mapping relation between time consuming processes and reference information in a newspaper disc process, wherein the reference information corresponding to any time consuming process is time consuming information for calculating the time consuming process, and the reference information corresponding to any time consuming process comprises one or more of first reference information, second reference information and third reference information, wherein the first reference information is a target newspaper disc request message which is generated by the newspaper disc middleware and carries the target consignment information, the second reference information is log information which is recorded by the newspaper disc middleware and aims at the target consignment information, and the third reference information is a target receipt message which is sent by a transaction gateway and carries receipt contents corresponding to the target consignment information and is received by the newspaper disc middleware;
Calculating the time consumption corresponding to the appointed time consuming process according to the time consumption calculation mode corresponding to the appointed time consuming process by utilizing the reference information corresponding to the appointed time consuming process;
and carrying out the appointed processing task by using the time consumption corresponding to each appointed time consumption process.
In the scheme, after an execution instruction of a specified processing task aiming at least one specified time consuming process is received, target entrusting information serving as an analysis reference is determined, then, based on a preset mapping relation between the time consuming process in a newspaper-in-a-disc process and reference information, reference information corresponding to each specified time consuming process is determined, the time consumption of the specified time consuming process is calculated by using the determined reference information corresponding to the specified time consuming process, and then, the time consumption corresponding to each specified time consuming process is used for carrying out the specified processing task.
Therefore, the time consumption corresponding to each appointed time consumption process can be calculated only by using the data acquired by the newspaper disc middleware, and the appointed processing task can be carried out by using the time consumption corresponding to each appointed time consumption process. Therefore, the scheme can effectively execute the appointed processing task related to the time-consuming process existing in the newspaper-disc flow under the condition that the exchange gateway and the exchange matching system do not disclose logs.
The following describes a task execution method provided by an embodiment of the present application with reference to the accompanying drawings.
As shown in fig. 2, the task performing method may include the steps of:
S201, determining target commission information serving as an analysis reference in response to receiving an execution instruction of a specified processing task for at least one specified time-consuming process, wherein the at least one specified time-consuming process is at least one time-consuming process in each time-consuming process in the newspaper-board process, and the target commission is any commission for completing the newspaper-board process.
The target commission information may be, specifically, a stock buying commission, a stock selling commission, a stock price inquiring commission, etc., which is not limited in the present application, and any commission information capable of completing a stock report process may be the target commission information.
The execution instructions are for triggering a specified processing task for at least one specified time consuming process. The user can give out an execution instruction by clicking a specified button in the human-computer interaction interface, and can give out an execution instruction by giving out a preset gesture operation to the human-computer interaction interface. The present application is not limited to the manner in which the execution instruction is issued.
In this solution, there are multiple time consuming processes and processing tasks, and it is enough that the execution instruction triggers at least one designated processing task for one designated time consuming process, or the execution instruction triggers at least one designated processing task for multiple time consuming processes.
By way of example, at least one of the specified processing tasks may include an early warning analysis task, which is a task for analyzing whether time is abnormal, a time-consuming output task, which is a task for performing time-consuming information output, and the like. The specific details of the designated processing task will be described in detail later, and will not be described in detail here.
S202, determining reference information corresponding to each appointed time consuming process based on a preset mapping relation between time consuming processes and reference information in a newspaper disc process, wherein the reference information corresponding to any time consuming process is time consuming information for calculating the time consuming process, and the reference information corresponding to any time consuming process comprises one or more of first reference information, second reference information and third reference information, wherein the first reference information is a target newspaper disc request message which is generated by the newspaper disc middleware and carries the target consignment information, the second reference information is log information which is recorded by the newspaper disc middleware and aims at the target consignment information, and the third reference information is a target receipt message which is received by the newspaper disc middleware and is sent by a transaction gateway and carries receipt content corresponding to the target consignment information;
The first reference information is generated by the newspaper disc middleware according to the newspaper disc request message which is generated by the transaction middleware and carries the target entrusting information. When the disc-broadcasting process is performed, the transaction middleware can generate a disc-broadcasting request message according to target commission information of a client, the disc-broadcasting request message format can be a FIX format, FIX information generated by the transaction middleware not only comprises the target commission information but also comprises time for generating the FIX information by the transaction middleware, the transaction middleware sends the generated FIX information to the disc-broadcasting middleware, the disc-broadcasting middleware generates one FIX information on the basis of the FIX information generated by the transaction middleware, and the FIX information generated by the disc-broadcasting middleware comprises the target commission information, time for generating the FIX information by the transaction middleware and time for generating the FIX information by the disc-broadcasting middleware. The first reference information may be FIX information generated by the newspaper disc middleware. Each FIX message is composed of a series of fields with < reference number > = < value >, in the FIX message generated by the transaction middleware, for example, the value corresponding to reference number 60 in fig. 1 represents the time when the transaction middleware generates the FIX message content, and the value corresponding to reference number 52 in the FIX message generated by the newspaper middleware represents the time when the newspaper middleware generates the FIX message.
The newspaper disc FIX information generated by the newspaper disc middleware in fig. 1 is the first reference information, the log information recorded by the newspaper disc middleware is the second reference information, and the FIX information generated by the transaction and carrying the execution return information corresponding to the target commission information is the third reference information.
In addition, in one implementation manner, the execution body of the task execution method of the present application may be a task execution device, and when the task execution device is deployed in the newspaper disc middleware, because the first reference information, the second reference information and the third reference information in the solution of the present application are generated or received by the newspaper disc middleware, when the newspaper disc middleware generates or receives the first reference information, the second reference information and the third reference information, the task execution device deployed in the newspaper disc middleware may acquire the first reference information, the second reference information and the third reference information, so as to implement the task execution method of the present application, and at this time, the task execution method may be performed in real time.
In one implementation manner, the second reference information and the third reference information can be recorded in the log information of the newspaper disc middleware, so that the task execution device deployed in any device can acquire the second reference information and the third reference information from the first reference information, so as to implement the task execution method of the application. It can be understood that, because the log information of the newspaper disc middleware is stored in real time, the task execution method can be implemented either in real time or for some historical entrusting information.
Optionally, in an implementation manner, the reference information corresponding to the first time consuming process includes the first reference information, the reference information corresponding to the second time consuming process includes the first reference information and the second reference information, the reference information corresponding to the third time consuming process includes the third reference information, the reference information corresponding to the fourth time consuming process includes the second reference information and the third reference information, and the reference information corresponding to the fifth time consuming process includes the second reference information.
The above reference information about each time consuming process is only an example and should not be construed as limiting the present application.
S203, calculating the time consumption corresponding to the specified time consumption process according to the time consumption calculation mode corresponding to the specified time consumption process by utilizing the reference information corresponding to the specified time consumption process, wherein the time consumption calculation mode corresponding to any time consumption process is a mode for performing time consumption calculation by utilizing the time information carried by the reference information corresponding to the time consumption process.
And under the condition that the reference information corresponding to each time consuming process is determined, a time consuming calculation mode corresponding to each time consuming process can be preset. In this way, since the specified time-consuming process belongs to one time-consuming process of the time-consuming processes, after determining the corresponding reference information for each specified time-consuming process, the time consumption corresponding to the specified time-consuming process can be calculated according to the time-consuming calculation mode corresponding to the specified time-consuming process by using the reference information corresponding to the specified time-consuming process. In addition, because the reference information corresponding to the time consuming process to be calculated carries time information, the time consuming calculation mode corresponding to any time consuming process is a mode of performing time consuming calculation by utilizing the time information carried by the reference information corresponding to the time consuming process.
In the case of the above-mentioned reference information corresponding to each time-consuming process, the present application exemplarily provides a time-consuming calculation manner corresponding to each time-consuming process:
Subtracting the first time carried by the first reference information from the second time carried by the first reference information to obtain the time consumption of the first time consuming process;
the time consumption calculation formula corresponding to the second time consumption process comprises subtracting the second time from the third time recorded in the second reference information to obtain the time consumption corresponding to the second time consumption process;
Subtracting the fourth time carried in the third reference information from the fifth time carried in the third reference information to obtain the time consumption corresponding to the third time consumption process;
the time consumption calculation mode corresponding to the fourth time consumption process comprises the steps of subtracting the fifth time by utilizing the sixth time recorded by the second reference information to obtain the time consumption corresponding to the fourth time consumption process;
The time consumption calculation formula corresponding to the fifth time consumption process comprises subtracting the third time from the sixth time to obtain the time consumption of the fifth time consumption process;
The method comprises the steps of generating a receipt request message carrying target entrusting information for a trading gateway according to a first time, generating a receipt request message carrying target entrusting information for the trading gateway according to a second time, wherein the second time is the generation time of the first reference information, the third time is the sending time of the first reference information, the fourth time is the time for generating a receipt message carrying receipt content for sending to the trading gateway by the trading matching system, the fifth time is the time for generating the target receipt message by the trading gateway, and the sixth time is the time for receiving the target receipt message by the newspaper disc middleware.
Illustratively, in fig. 1, the transaction middleware generates FIX message content time (reference numeral 60) as a first time, the newspaper disc middleware generates FIX message time (reference numeral 52) as a second time, the newspaper disc middleware transmits newspaper disc FIX information log record time as a third time, the exchange matching system generates FIX message content time (reference numeral 60) as a fourth time, the exchange gateway generates FIX message time (reference numeral 52) as a fifth time, and the newspaper disc middleware receives and returns FIX information log record time as a sixth time.
According to the time-consuming computing manner given in the above embodiment, the time-consuming computing process corresponding to the first time-consuming process may be expressed as time consumption of the first time-consuming process=second time-first time by a formula;
The time-consuming calculation process corresponding to the second time-consuming process can be expressed as a time-consuming=third time-the second time corresponding to the second time-consuming process by a formula;
The time-consuming calculation process corresponding to the third time-consuming process can be expressed as a time-consuming=fifth time-fourth time corresponding to the third time-consuming process by a formula;
The time consumption calculation process corresponding to the fourth time consumption process can be expressed as that the time consumption corresponding to the fourth time consumption process=sixth time-fifth time;
The time-consuming calculation process corresponding to the fifth time-consuming process may be expressed as a time-consuming of the fifth time-consuming process=the sixth time-the third time by a formula.
According to the above-mentioned correspondence between the disc reporting process in fig. 1 and each time consuming process and each time in the disc reporting process in this embodiment, according to the disc reporting process scheme in fig. 1, each time consuming computing process can be expressed as follows by a formula:
overall newspaper disc execution process time-receiving execution return FIX information log record time-sending newspaper disc FIX information log record time;
transaction middleware time = newspaper disc middleware generation FIX message time (reference numeral 52) -transaction middleware generation FIX message content time (reference numeral 60);
Newspaper disc middleware processing time-sending newspaper disc FIX information log record time-newspaper disc middleware generation FIX message time (reference numeral 52);
The time spent by the exchange matching system on the exchange newspaper board = the exchange gateway generates FIX message time (reference numeral 52) -the exchange matching system generates FIX message content time (reference numeral 60);
The transaction center reporting machine processes the execution report time (that is, the time spent by the transaction center gateway sending the generated FIX message carrying the execution report information corresponding to the target commission information to the reporting center middleware, the transaction center reporting machine updates the relevant data of the target commission information in the dealer database according to the content of the FIX message while receiving the FIX message, the processing execution report is the operation of updating the database, and the reporting center middleware receives the FIX message and the operation of updating the database can be performed simultaneously and is completed) =the record time of receiving the execution report FIX information and the time of generating the FIX message by the transaction center gateway (reference numeral 52).
The scheme of the embodiment can accurately calculate the time consumption of the whole newspaper disc executing process, the time consumption of the transaction middleware, the time consumption of the newspaper disc middleware processing, the time consumption of the exchange matching system to the exchange gateway and the time consumption of the exchange newspaper disc machine processing execution report. Therefore, the method and the device can solve the problem that the time consumption of the newspaper disc process is difficult to measure in a refined manner, and take a complete transaction process as a gripper to qualitatively and quantitatively analyze the time consumption process in the newspaper disc process related to each component in the newspaper disc system. Under the condition that only the newspaper disc middleware log is used, time consumption of time consuming processes in newspaper disc processes related to all components is analyzed with high accuracy through the log recording time and the FIX protocol detailed content, and the exchange gateway detailed log and the exchange matching gateway detailed log do not need to be opened, so that the method is easy and convenient to operate, reliable in evaluation effect and suitable for various newspaper disc systems.
In one implementation, the clarking middleware required by some transactions obtains commission information from a dealer database, and the clarking middleware generates a clarking request message carrying the target commission information according to the target commission information in the database. Specifically, since the exchange generally uses FIX protocol, the newspaper middleware obtains the target commission information in the database and generates the newspaper disc request message in FIX format carrying the target commission information, and in this scenario, there is no time spent by the transaction middleware, that is, the first time spent is not spent, and other calculation manners of the second time spent, the third time spent, the fourth time spent and the fifth time spent are the same as those in the above embodiment. Therefore, the method and the device can be suitable for calculating the time consumption of each time-consuming process for the newspaper-board flows of different exchanges so as to effectively execute the designated processing task of the time-consuming process existing in the newspaper-board flows.
S204, performing the designated processing task by using the time consumption corresponding to each designated time consumption process.
Optionally, if the specified processing task includes an early warning analysis task, performing the specified processing task by using the time consumption corresponding to each specified time consumption process may include:
And outputting early warning information for representing that the specified time consuming process has abnormal time consumption if the time consumption corresponding to the specified time consuming process exceeds a preset time consumption threshold corresponding to the specified time consuming process aiming at each specified time consuming process.
It is known that the time consumption of each specified time-consuming process is relatively stable under normal conditions, if the predetermined time consumption threshold corresponding to the specified time-consuming process is exceeded, the time consumption process is indicated to have abnormality, and therefore when the time consumption corresponding to the specified time-consuming process exceeds the predetermined time consumption threshold corresponding to the specified time-consuming process, early warning information for representing that the specified time-consuming process has abnormality can be output to terminal equipment such as display equipment of a dealer.
In one implementation, since the stock report process involves both the dealer and the exchange, when the dealer uses the scheme of the present application, if the time consuming process involved in the exchange is abnormal, for example, the third time consuming process and the fourth time consuming process are abnormal, the exchange end may send the exchange early warning information about the time consuming process abnormal to the exchange, and similarly, when the exchange uses the scheme of the present application, the time consuming process involved in the dealer is abnormal, for example, the first time consuming process and the second time consuming process are abnormal, the dealer end is abnormal, and the dealer end may send the early warning information about the time consuming process abnormal to the exchange. Thus being helpful to solve the abnormal problems existing in the newspaper disc process more quickly.
Optionally, if the specified processing task includes a time-consuming data display task, performing the specified processing task by using time consumption corresponding to each specified time-consuming process may include:
and sending the time consumption corresponding to each appointed time consumption process to a preset data receiving end so that the data receiving end displays the time consumption corresponding to each appointed time consumption process.
The data receiving end receives each time-consuming data, and can visually display the time consumption corresponding to each appointed time-consuming process, so that the time-consuming information of each time-consuming process can be conveniently and quickly acquired by a worker.
Optionally, if the specified processing task includes a component efficiency analysis task, performing the specified processing task by using the time consumption corresponding to each specified time consumption process may include:
And analyzing the working efficiency of the components corresponding to each appointed time consuming process in the newspaper file process according to the time consumption corresponding to each appointed time consuming process.
The method includes that, in the newspaper disc process, the time consumption of a second time consuming process is short, that is, the newspaper disc middleware realizing the second time consuming process has high working efficiency, and if the time consumption of the second time consuming process is long but does not exceed a corresponding preset time consumption threshold, that is, the newspaper disc middleware realizing the second time consuming process has low working efficiency, and at the moment, tasks can be distributed to servers corresponding to other newspaper disc middleware to improve working efficiency.
In the scheme, after an execution instruction of a specified processing task aiming at least one specified time consuming process is received, target entrusting information serving as an analysis reference is determined, then, based on a preset mapping relation between the time consuming process in a newspaper-in-a-disc process and reference information, reference information corresponding to each specified time consuming process is determined, the time consumption of the specified time consuming process is calculated by using the determined reference information corresponding to the specified time consuming process, and then, the time consumption corresponding to each specified time consuming process is used for carrying out the specified processing task.
Therefore, the time consumption corresponding to each appointed time consumption process can be calculated only by using the data acquired by the newspaper disc middleware, and the appointed processing task can be carried out by using the time consumption corresponding to each appointed time consumption process. Therefore, the scheme can effectively execute the appointed processing task related to the time-consuming process existing in the newspaper-disc flow under the condition that the exchange gateway and the exchange matching system do not disclose logs.
For a better understanding of the present solution, the task execution method is described below by means of a specific embodiment:
step one, an execution instruction of an early warning analysis task aiming at a second time consuming process of the newspaper-disc process is received.
Step two, acquiring reference information corresponding to a second time consuming process;
It can be known from the above embodiment that a mapping relationship between a time consuming process and reference information in the newspaper-disc process is preset, so that reference information corresponding to a second time consuming process can be obtained based on the mapping relationship, and the reference information corresponding to the second time consuming process of the newspaper-disc process includes the first reference information and the second reference information.
And thirdly, calculating the time consumption corresponding to the second time consumption process by using a time consumption calculation mode corresponding to the second time consumption process of the newspaper board process based on the reference information corresponding to the second time consumption process.
According to the time-consuming calculation mode corresponding to the second time-consuming process, the time of generating the FIX message by the newspaper disc middleware acquired from the first reference information, that is, the generation time of the first reference information (referred to as the second time in the above embodiment), and the time of transmitting the FIX message by the newspaper disc middleware acquired from the second reference information, that is, the transmission time of the first reference information (referred to as the third time in the above embodiment) may be subtracted. For example, the generation time of the first reference information is denoted by 52, the specific time is 10:23:01, the time for obtaining the newspaper disc middleware from the second reference information to send the FIX message is 10:23:04, that is, the sending time of the first reference information is 10:23:04. In this embodiment, the second time-consuming calculation manner is to subtract the generation time 10:23:01 of the first reference information from the transmission time 10:23:04 of the first reference information, so as to obtain a time-consuming 3S, that is, subtracting the second time from the third time in the above embodiment, so as to obtain a time-consuming corresponding to the second time-consuming process.
And step four, aiming at the second time consuming process, if the time consumption corresponding to the second time consuming process exceeds a preset time consumption threshold corresponding to the second time consuming process, outputting early warning information for representing that the second time consuming process has abnormal time consumption.
In this embodiment, the set threshold of the second time-consuming process is 2S, and the calculated actual time consumption is 3S, so that the abnormal condition exists in the time consumption of the second time-consuming process, and early warning information indicating that the abnormal time consumption exists in the second time-consuming process is sent to the dealer terminal device.
In the scheme, an execution instruction of an early warning analysis task for a second time consuming process of a newspaper-out flow is received, reference information corresponding to the second time consuming process is acquired, a time consuming calculation mode corresponding to the second time consuming process of the newspaper-out flow is utilized, time consumption corresponding to the second time consuming process is calculated based on the reference information corresponding to the second time consuming process, and early warning information used for representing that the second time consuming process has abnormal time consumption is output if the time consumption corresponding to the second time consuming process exceeds a preset time consuming threshold corresponding to the second time consuming process.
According to the scheme, the time consumption of the second time consuming process is calculated by utilizing the data acquired by the newspaper disc middleware, whether the time consuming process is abnormal or not is judged, and the early warning information is sent if the time consuming process is abnormal, so that the time consumption of the second time consuming process can be monitored, and the early warning information is sent once the time consumption is abnormal, and the abnormal condition of the second time consuming process can be solved in time.
Based on the embodiment content of the task execution method, the embodiment of the disclosure also provides a task execution device. Fig. 3 is a schematic structural diagram of a task execution device according to an embodiment of the present disclosure, where, as shown in fig. 3, the task execution device may include:
the first determining module 301 is configured to determine, in response to receiving an execution instruction of a specified processing task for at least one specified time-consuming process, target delegation information as an analysis reference, where the at least one specified time-consuming process is at least one time-consuming process in each time-consuming process in the inventory process;
The second determining module 302 is configured to determine reference information corresponding to each specified time consuming process based on a preset mapping relationship between a time consuming process and reference information in a newspaper disc process, where the reference information corresponding to any time consuming process is time consuming information for calculating the time consuming process, and the reference information corresponding to any time consuming process includes one or more of first reference information, second reference information and third reference information, where the first reference information is a target newspaper disc request message generated by the newspaper disc middleware and carrying the target delegation information, the second reference information is log information recorded by the newspaper disc middleware and aiming at the target delegation information, and the third reference information is a target receipt message which is sent by a transaction gateway and carries receipt content corresponding to the target delegation information and received by the newspaper disc middleware;
The calculation module 303 is configured to calculate, for each specified time consuming process, a time consuming corresponding to the specified time consuming process according to a time consuming calculation mode corresponding to the specified time consuming process by using reference information corresponding to the specified time consuming process, where the time consuming calculation mode corresponding to any time consuming process is a mode of performing time consuming calculation by using time information carried by the reference information corresponding to the time consuming process;
the task processing module 304 is configured to perform a specified processing task by using the time consumption corresponding to each specified time consumption process.
In the scheme, after an execution instruction of a specified processing task aiming at least one specified time consuming process is received, target entrusting information serving as an analysis reference is determined, then, based on a preset mapping relation between the time consuming process in a newspaper-in-a-disc process and reference information, reference information corresponding to each specified time consuming process is determined, the time consumption of the specified time consuming process is calculated by using the determined reference information corresponding to the specified time consuming process, and then, the time consumption corresponding to each specified time consuming process is used for carrying out the specified processing task.
Therefore, the time consumption corresponding to each appointed time consumption process can be calculated only by using the data acquired by the newspaper disc middleware, and the appointed processing task can be carried out by using the time consumption corresponding to each appointed time consumption process. Therefore, the scheme can effectively execute the appointed processing task related to the time-consuming process existing in the newspaper-disc flow under the condition that the exchange gateway and the exchange matching system do not disclose logs.
Optionally, the appointed processing task comprises an early warning analysis task;
the task processing module comprises:
The output unit is used for outputting early warning information used for representing that the specified time consuming process has abnormal time consuming according to each specified time consuming process if the time consuming corresponding to the specified time consuming process exceeds a preset time consuming threshold corresponding to the specified time consuming process.
Optionally, the specified processing task comprises a time-consuming output task;
the task processing module comprises:
And the sending unit is used for sending the time consumption corresponding to each appointed time consumption process to a preset data receiving end so that the data receiving end displays the time consumption corresponding to each appointed time consumption process.
Optionally, the reference information corresponding to the first time consuming process includes the first reference information and the second reference information, the reference information corresponding to the second time consuming process includes the first reference information and the second reference information, the reference information corresponding to the third time consuming process includes the third reference information, the reference information corresponding to the fourth time consuming process includes the second reference information and the third reference information, and the reference information corresponding to the fifth time consuming process includes the second reference information.
Optionally, the time-consuming calculation mode corresponding to the first time-consuming process includes subtracting the first time carried by the first reference information from the second time carried by the first reference information to obtain the time consumption of the first time-consuming process;
the time consumption calculation formula corresponding to the second time consumption process comprises subtracting the second time from the third time recorded in the second reference information to obtain the time consumption corresponding to the second time consumption process;
Subtracting the fourth time carried in the third reference information from the fifth time carried in the third reference information to obtain the time consumption corresponding to the third time consumption process;
the time consumption calculation mode corresponding to the fourth time consumption process comprises the steps of subtracting the fifth time by utilizing the sixth time recorded by the second reference information to obtain the time consumption corresponding to the fourth time consumption process;
The time consumption calculation formula corresponding to the fifth time consumption process comprises subtracting the third time from the sixth time to obtain the time consumption of the fifth time consumption process;
The method comprises the steps of generating a receipt request message carrying target entrusting information for a trading gateway according to a first time, generating a receipt request message carrying target entrusting information for the trading gateway according to a second time, wherein the second time is the generation time of the first reference information, the third time is the sending time of the first reference information, the fourth time is the time for generating a receipt message carrying receipt content for sending to the trading gateway by the trading matching system, the fifth time is the time for generating the target receipt message by the trading gateway, and the sixth time is the time for receiving the target receipt message by the newspaper disc middleware.
The embodiment of the application also provides an electronic device, as shown in fig. 4, which comprises a processor 401, a communication interface 402, a memory 403 and a communication bus 404, wherein the processor 401, the communication interface 402 and the memory 403 complete communication with each other through the communication bus 404,
A memory 403 for storing a computer program;
The processor 401 is configured to implement the steps of any task execution method in the above embodiments when executing the program stored in the memory 403.
The communication bus mentioned above for the electronic device may be a peripheral component interconnect standard (PERIPHERAL COMPONENT INTERCONNECT, PCI) bus or an extended industry standard architecture (Extended Industry Standard Architecture, EISA) bus, etc. The communication bus may be classified as an address bus, a data bus, a control bus, or the like. For ease of illustration, the figures are shown with only one bold line, but not with only one bus or one type of bus.
The communication interface is used for communication between the electronic device and other devices.
The Memory may include random access Memory (Random Access Memory, RAM) or may include Non-Volatile Memory (NVM), such as at least one disk Memory. Optionally, the memory may also be at least one memory device located remotely from the aforementioned processor.
The Processor may be a general-purpose Processor including a central processing unit (Central Processing Unit, CPU), a network Processor (Network Processor, NP), etc., or may be a digital signal Processor (DIGITAL SIGNAL Processor, DSP), application SPECIFIC INTEGRATED Circuit (ASIC), field-Programmable gate array (Field-Programmable GATE ARRAY, FPGA) or other Programmable logic device, discrete gate or transistor logic device, discrete hardware components.
In yet another embodiment of the present application, there is also provided a computer readable storage medium having stored therein a computer program which, when executed by a processor, implements the steps of any of the task execution methods described above.
In yet another embodiment of the present application, there is also provided a computer program product containing instructions that, when run on a computer, cause the computer to perform any of the task execution methods of the above embodiments.
In the above embodiments, it may be implemented in whole or in part by software, hardware, firmware, or any combination thereof. When implemented in software, may be implemented in whole or in part in the form of a computer program product. The computer program product includes one or more computer instructions. When loaded and executed on a computer, produces a flow or function in accordance with embodiments of the present application, in whole or in part. The computer may be a general purpose computer, a special purpose computer, a computer network, or other programmable apparatus. The computer instructions may be stored in or transmitted from one computer-readable storage medium to another, for example, by wired (e.g., coaxial cable, optical fiber, digital Subscriber Line (DSL)), or wireless (e.g., infrared, wireless, microwave, etc.). The computer readable storage medium may be any available medium that can be accessed by a computer or a data storage device such as a server, data center, etc. that contains an integration of one or more available media. The usable medium may be a magnetic medium (e.g., floppy disk, hard disk, tape), an optical medium (e.g., DVD), or a semiconductor medium (e.g., solid state disk Solid STATE DISK (SSD)), etc.
It is noted that relational terms such as first and second, and the like are used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Moreover, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising one does not exclude the presence of other like elements in a process, method, article, or apparatus that comprises an element.
In this specification, each embodiment is described in a related manner, and identical and similar parts of each embodiment are all referred to each other, and each embodiment mainly describes differences from other embodiments.
The foregoing description is only of the preferred embodiments of the present application and is not intended to limit the scope of the present application. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present application are included in the protection scope of the present application.
Claims (10)
1. A task execution method is characterized by being applied to electronic equipment, and comprises the following steps:
determining target commission information serving as an analysis reference in response to receiving an execution instruction of a designated processing task aiming at least one designated time-consuming process, wherein the at least one designated time-consuming process is at least one time-consuming process in each time-consuming process in a newspaper-disc process;
Determining reference information corresponding to each appointed time consuming process based on a preset mapping relation between time consuming processes and reference information in a newspaper disc process, wherein the reference information corresponding to any time consuming process is time consuming information for calculating the time consuming process, and the reference information corresponding to any time consuming process comprises one or more of first reference information, second reference information and third reference information, wherein the first reference information is a target newspaper disc request message which is generated by the newspaper disc middleware and carries the target consignment information, the second reference information is log information which is recorded by the newspaper disc middleware and aims at the target consignment information, and the third reference information is a target receipt message which is sent by a transaction gateway and carries receipt contents corresponding to the target consignment information and is received by the newspaper disc middleware;
Calculating the time consumption corresponding to the appointed time consuming process according to the time consumption calculation mode corresponding to the appointed time consuming process by utilizing the reference information corresponding to the appointed time consuming process;
and carrying out the appointed processing task by using the time consumption corresponding to each appointed time consumption process.
2. The method of claim 1, wherein the specified processing tasks include an early warning analysis task;
performing the specified processing task by using the time consumption corresponding to each specified time consumption process, including:
And outputting early warning information for representing that the specified time consuming process has abnormal time consumption if the time consumption corresponding to the specified time consuming process exceeds a preset time consumption threshold corresponding to the specified time consuming process aiming at each specified time consuming process.
3. The method of claim 1, wherein the specified processing tasks include a time-consuming output task;
performing the specified processing task by using the time consumption corresponding to each specified time consumption process, including:
and sending the time consumption corresponding to each appointed time consumption process to a preset data receiving end so that the data receiving end displays the time consumption corresponding to each appointed time consumption process.
4. The method according to any one of claims 1 to 3, wherein each time consuming process comprises a first time consuming process, a second time consuming process, a third time consuming process, a fourth time consuming process and a fifth time consuming process, wherein the reference information corresponding to the first time consuming process comprises the first reference information and the second reference information, the reference information corresponding to the second time consuming process comprises the first reference information and the second reference information, the reference information corresponding to the third time consuming process comprises the third reference information, the reference information corresponding to the fourth time consuming process comprises the second reference information and the third reference information, and the reference information corresponding to the fifth time consuming process comprises the second reference information.
5. The method of claim 4, wherein the newspaper board process further comprises two components of a transaction middleware and a transaction exchange matching system, and the time consumption calculation mode corresponding to the first time consumption process comprises the steps of subtracting the first time carried by the first reference information from the second time carried by the first reference information to obtain the time consumption of the first time consumption process;
the time consumption calculation formula corresponding to the second time consumption process comprises subtracting the second time from the third time recorded in the second reference information to obtain the time consumption corresponding to the second time consumption process;
Subtracting the fourth time carried in the third reference information from the fifth time carried in the third reference information to obtain the time consumption corresponding to the third time consumption process;
the time consumption calculation mode corresponding to the fourth time consumption process comprises the steps of subtracting the fifth time by utilizing the sixth time recorded by the second reference information to obtain the time consumption corresponding to the fourth time consumption process;
The time consumption calculation formula corresponding to the fifth time consumption process comprises subtracting the third time from the sixth time to obtain the time consumption of the fifth time consumption process;
The method comprises the steps of generating a receipt request message carrying target commission information for a trading gateway according to a first time, generating a receipt request message carrying the target commission information for the trading gateway according to a second time, generating the receipt request message carrying the target commission information for the trading middleware according to the first time, generating the receipt request message carrying the target commission information for the trading gateway according to the second time, wherein the second time is the generation time of the first reference information, the third time is the sending time of the first reference information, the fourth time is the time for generating the receipt message carrying the receipt content for sending to the trading gateway by the trading gateway according to the fourth time, and the fifth time is the time for generating the target receipt message by the trading gateway, and the sixth time is the time for receiving the target receipt message by the newspaper disc middleware.
6. A task execution device is characterized by being applied to electronic equipment, and comprises:
The system comprises a first determining module, a first processing module, a second determining module and a third determining module, wherein the first determining module is used for determining target commission information serving as an analysis reference in response to receiving an execution instruction of a designated processing task aiming at least one designated time consuming process, wherein the at least one designated time consuming process is at least one time consuming process in various time consuming processes in a newspaper board process;
The system comprises a first determining module, a second determining module and a third determining module, wherein the first determining module is used for determining reference information corresponding to each appointed time consuming process based on a preset mapping relation between time consuming processes and reference information in a newspaper disc process, the reference information corresponding to any time consuming process is time consuming information used for calculating the time consuming process, the reference information corresponding to any time consuming process comprises one or more of first reference information, second reference information and third reference information, the first reference information is a target newspaper disc request message which is generated by the newspaper disc middleware and carries the target consignment information, the second reference information is log information which is recorded by the newspaper disc middleware and aims at the target consignment information, and the third reference information is a target receipt message which is sent by a transaction gateway and carries receipt contents corresponding to the target consignment information and is received by the newspaper disc middleware;
The computing module is used for computing the time consumption corresponding to the appointed time consumption process according to the time consumption computing mode corresponding to the appointed time consumption process by utilizing the reference information corresponding to the appointed time consumption process;
and the task processing module is used for carrying out the appointed processing task by utilizing the time consumption corresponding to each appointed time consumption process.
7. The apparatus of claim 6, wherein the designated processing task comprises an early warning analysis task;
the task processing module comprises:
The output unit is used for outputting early warning information used for representing that the specified time consuming process has abnormal time consuming according to each specified time consuming process if the time consuming corresponding to the specified time consuming process exceeds a preset time consuming threshold corresponding to the specified time consuming process.
8. The apparatus of claim 6, wherein the specified processing tasks comprise time-consuming output tasks;
the task processing module comprises:
And the sending unit is used for sending the time consumption corresponding to each appointed time consumption process to a preset data receiving end so that the data receiving end displays the time consumption corresponding to each appointed time consumption process.
9. The electronic equipment is characterized by comprising a processor, a communication interface, a memory and a communication bus, wherein the processor, the communication interface and the memory are communicated with each other through the communication bus;
a memory for storing a computer program;
A processor for implementing the method of any of claims 1-5 when executing a program stored on a memory.
10. A computer readable storage medium, characterized in that the computer readable storage medium has stored therein a computer program which, when executed by a processor, implements the method of any of claims 1-5.
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202310219881.5A CN116204295B (en) | 2023-03-07 | 2023-03-07 | Task execution method and device, electronic equipment and storage medium |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202310219881.5A CN116204295B (en) | 2023-03-07 | 2023-03-07 | Task execution method and device, electronic equipment and storage medium |
Publications (2)
Publication Number | Publication Date |
---|---|
CN116204295A CN116204295A (en) | 2023-06-02 |
CN116204295B true CN116204295B (en) | 2025-08-08 |
Family
ID=86515701
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202310219881.5A Active CN116204295B (en) | 2023-03-07 | 2023-03-07 | Task execution method and device, electronic equipment and storage medium |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN116204295B (en) |
Citations (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN112669158A (en) * | 2021-01-06 | 2021-04-16 | 深圳市金证科技股份有限公司 | Transaction system and control method and device of transaction service thereof |
Family Cites Families (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US8176127B2 (en) * | 2004-07-30 | 2012-05-08 | Pivot Solutions, Inc. | System and method for processing securities trading instructions and communicating order status via a messaging interface |
-
2023
- 2023-03-07 CN CN202310219881.5A patent/CN116204295B/en active Active
Patent Citations (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN112669158A (en) * | 2021-01-06 | 2021-04-16 | 深圳市金证科技股份有限公司 | Transaction system and control method and device of transaction service thereof |
Also Published As
Publication number | Publication date |
---|---|
CN116204295A (en) | 2023-06-02 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN112801666B (en) | Monitoring management method, system, medium and equipment based on enterprise service bus | |
CN107392722B (en) | Order processing method and device, electronic equipment and storage medium | |
CN106548402B (en) | Resource transfer monitoring method and device | |
US11669423B2 (en) | Systems and methods for monitoring application health in a distributed architecture | |
CN111078140B (en) | Nuclear power station file uploading management method and device, terminal equipment and medium | |
CN111726358A (en) | Attack path analysis method and device, computer equipment and storage medium | |
CN111400294B (en) | Data anomaly monitoring method, device and system | |
CN116107789A (en) | Method for monitoring and analyzing application fault reasons and storage medium | |
WO2021174684A1 (en) | Cutover information processing method, system and apparatus | |
CN109711849B (en) | Ether house address portrait generation method and device, electronic equipment and storage medium | |
CN116645082A (en) | System inspection method, device, equipment and storage medium | |
CN110704273A (en) | Configuration information processing method and device, electronic equipment and storage medium | |
CN113836204A (en) | Interface abnormality detection method, device, electronic device and storage medium | |
CN114817031A (en) | Service testing method, device, electronic equipment and storage medium | |
CN116204295B (en) | Task execution method and device, electronic equipment and storage medium | |
CN115083030A (en) | Service inspection method and device and electronic equipment | |
CN116776363A (en) | Data leakage risk analysis method and data leakage risk analysis system | |
CN118132376A (en) | Data monitoring method and device, electronic equipment and storage medium | |
CN110162982B (en) | Method and device for detecting illegal rights, storage medium and electronic equipment | |
CN115168489B (en) | Data certification method and device based on blockchain | |
CN112767166B (en) | Risk control method and device for transaction behaviors, computer equipment and storage medium | |
CN113992436B (en) | Local information generating method, device, equipment and storage medium | |
CN115131147A (en) | Transaction data processing method, apparatus, electronic device and readable medium | |
CN114399380A (en) | Block chain-based information security monitoring method and related equipment | |
CN112801453A (en) | Risk assessment method, device, terminal and storage medium |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |