CN112258298B - Data processing method and device and electronic equipment - Google Patents
Data processing method and device and electronic equipment Download PDFInfo
- Publication number
- CN112258298B CN112258298B CN202011305522.4A CN202011305522A CN112258298B CN 112258298 B CN112258298 B CN 112258298B CN 202011305522 A CN202011305522 A CN 202011305522A CN 112258298 B CN112258298 B CN 112258298B
- Authority
- CN
- China
- Prior art keywords
- identification code
- log
- request message
- message
- data processing
- 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
- 238000003672 processing method Methods 0.000 title claims abstract description 29
- 238000012545 processing Methods 0.000 claims abstract description 223
- 238000000034 method Methods 0.000 claims abstract description 31
- 238000012216 screening Methods 0.000 claims description 30
- 238000004891 communication Methods 0.000 claims description 12
- 238000012795 verification Methods 0.000 claims description 4
- 238000003032 molecular docking Methods 0.000 abstract description 7
- 238000010586 diagram Methods 0.000 description 14
- 230000006870 function Effects 0.000 description 5
- 238000001914 filtration Methods 0.000 description 3
- 230000003287 optical effect Effects 0.000 description 3
- 230000000644 propagated effect Effects 0.000 description 2
- 239000008186 active pharmaceutical agent Substances 0.000 description 1
- 238000013459 approach Methods 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 239000003795 chemical substances by application Substances 0.000 description 1
- 238000004590 computer program Methods 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 229920001971 elastomer Polymers 0.000 description 1
- 239000000806 elastomer Substances 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 239000000835 fiber Substances 0.000 description 1
- 239000012634 fragment Substances 0.000 description 1
- 238000011022 operating instruction Methods 0.000 description 1
- 239000013307 optical fiber Substances 0.000 description 1
- 239000004065 semiconductor Substances 0.000 description 1
- 238000012546 transfer Methods 0.000 description 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q30/00—Commerce
- G06Q30/06—Buying, selling or leasing transactions
- G06Q30/0601—Electronic shopping [e-shopping]
- G06Q30/0633—Lists, e.g. purchase orders, compilation or processing
- G06Q30/0635—Processing of requisition or of purchase orders
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/23—Updating
- G06F16/2379—Updates performed during online database operations; commit processing
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Business, Economics & Management (AREA)
- Accounting & Taxation (AREA)
- Databases & Information Systems (AREA)
- Finance (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Development Economics (AREA)
- Economics (AREA)
- Marketing (AREA)
- Strategic Management (AREA)
- General Business, Economics & Management (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The application discloses a data processing method, a data processing device and electronic equipment. After receiving a first request message sent by a first device, the data processing platform generates and stores a first log generated based on the first request message, processes the first request message into a second request message matched with a target airline company, generates and stores a second log generated based on the second request message, and sends the second request message to a second device; after receiving the first return message sent by the second device, the data processing platform generates and stores a third log generated based on the first return message, processes the first return message into a second return message matched with the first device, generates and stores a fourth log generated based on the second return message, and sends the second return message and the first identification code to the first device. Based on the scheme disclosed by the application, the docking cost of sellers and airlines can be reduced, and faults and fault reasons can be positioned when orders are wrong.
Description
Technical Field
The present application belongs to the technical field of data processing, and in particular, relates to a data processing method, a data processing device, and an electronic device.
Background
With the development of economy and the improvement of living standard of people, an airplane has become one of basic traffic modes. In addition to the flight inquiry, ticket reservation, and ticket return change by the airline ticketing system, the user may also do so by the seller (seller). Vendors include, but are not limited to, agents, OTAs, TMCs, and intermodal partners. Vendors need to interface with the ticketing systems of individual airlines in order to provide good quality service to users.
However, the ticketing systems of the various airlines differ greatly in interface design and logic, which makes interfacing between the seller and the various airlines a significant technical cost.
Disclosure of Invention
Accordingly, the present application is directed to a data processing method, apparatus and electronic device, so as to reduce the docking cost of sellers and airlines.
In order to achieve the above purpose, the present application provides the following technical solutions:
a data processing method applied to a data processing platform, the data processing method comprising:
Receiving a first request message sent by first equipment;
generating a first log based on the first request message, and storing the first log, wherein the first log comprises the first request message, a first identification code, a second identification code and a third identification code;
processing the first request message into a second request message matched with a target airline company;
Generating a second log based on the second request message, and storing the second log, wherein the second log comprises the second request message, a first identification code, a second identification code and a third identification code;
Sending the second request message to second equipment;
receiving a first return message sent by the second device;
generating a third log based on the first return message, storing the third log, wherein the third log comprises the first return message, a first identification code, a second identification code and a third identification code;
processing the first return message into a second return message matched with the first device;
generating a fourth log based on the second return message, storing the fourth log, wherein the fourth log comprises the second return message, a first identification code, a second identification code and a third identification code;
the second return message and the first identification code are sent to the first equipment, so that the first equipment carries the first identification code in a first request message which is sent subsequently;
The first identification codes are used for indicating the order processing flow, the first identification codes in the logs generated in the same order processing flow are the same identification codes, and the first identification codes in the logs generated in different order processing flows are different identification codes; the second identification code is used for indicating an order processing sub-flow in the same order processing flow, the second identification code in the log generated in the same order processing sub-flow is the same identification code, and the second identification code in the log generated in different order processing sub-flows in the same order processing flow is different identification codes; the third identification code is used for indicating a message state, and the message state comprises: a first device-to-data processing platform request, a data processing platform-to-airline request, an airline-to-data processing platform return, and a data processing platform-to-first device return.
Therefore, the application has the beneficial effects that:
After receiving a first request message sent by a first device, the data processing platform generates and stores a first log generated based on the first request message, processes the first request message into a second request message matched with a target airline company, generates and stores a second log generated based on the second request message, and sends the second request message to a second device corresponding to the target airline company; after receiving the first return message sent by the second device, the data processing platform generates and stores a third log generated based on the first return message, processes the first return message into a second return message matched with the first device, generates and stores a fourth log generated based on the second return message, and sends the second return message and the first identification code to the first device; each generated log comprises a first identification code, a second identification code and a third identification code besides the message.
Based on the data processing method provided by the application, the first equipment at the seller side can complete the order processing flow without directly docking with the second equipment at the airline company side, so that the docking cost of the seller is reduced. In addition, when an order is wrong, all messages related to the order can be obtained based on the first identification code corresponding to the order, and the context relation of the messages can be known, so that the fault can be positioned, and the specific reason for the order error can be determined.
Drawings
In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the drawings that are required in the embodiments or the description of the prior art will be briefly described, and it is obvious that the drawings in the following description are some embodiments of the present application, and other drawings may be obtained according to these drawings without inventive effort for a person skilled in the art.
FIG. 1 is a flow chart of a data processing method according to an embodiment of the present application;
FIG. 2 is a schematic diagram of a first request message sent by a first device to a data processing platform;
FIG. 3 is a schematic diagram of a second request message obtained by processing the first request message shown in FIG. 2 by the data processing platform;
FIG. 4 is a schematic diagram of a graphical interface for screening presentation logs according to the present application;
FIG. 5 is a schematic diagram of a data processing apparatus according to an embodiment of the present application;
fig. 6 is a schematic structural diagram of an electronic device according to an embodiment of the present application.
Detailed Description
The embodiment of the application provides a data processing method, a data processing device and electronic equipment, which are used for reducing the docking cost of sellers and airlines.
Embodiments of the present application will be described in more detail below with reference to the accompanying drawings. While the application is susceptible of embodiment in the drawings, it is to be understood that the application may be embodied in various forms and should not be construed as limited to the embodiments set forth herein, but rather are provided to provide a more thorough and complete understanding of the application. It should be understood that the drawings and embodiments of the application are for illustration purposes only and are not intended to limit the scope of the present application.
The term "including" and variations thereof as used herein are intended to be open-ended, i.e., including, but not limited to. The term "based on" is based at least in part on. The term "one embodiment" means "at least one embodiment"; the term "another embodiment" means "at least one additional embodiment"; the term "some embodiments" means "at least some embodiments. Related definitions of other terms will be given in the description below.
It should be noted that the terms "first," "second," and the like herein are merely used for distinguishing between different devices, modules, or units and not for limiting the order or interdependence of the functions performed by such devices, modules, or units.
It should be noted that references to "one", "a plurality" and "a plurality" in this disclosure are intended to be illustrative rather than limiting, and those skilled in the art will appreciate that "one or more" is intended to be construed as "one or more" unless the context clearly indicates otherwise.
Referring to fig. 1, fig. 1 is a flowchart of a data processing method according to an embodiment of the present application. The execution subject of the method is a data processing platform, wherein the data processing platform can be a server or a server cluster, and the data processing platform is deployed by an aggregator. The data processing method comprises the following steps:
s101: and receiving a first request message sent by the first equipment.
The first device is an electronic device on the seller side. In the application, a request message sent by a first device to a data processing platform is called a first request message.
An order processing flow includes a plurality of order processing sub-flows, such as: airShopping (flight inquiry), offerPrice (price check), orderCreate (order creation), orderRetrieve (order inquiry), orderChange (order payment), orderReshop (change), orderCancel (refund).
If the first device is currently executing the flight inquiry sub-flow, the first request message sent by the first device is specifically the flight inquiry request message AirshoppingRQ. If the first device is currently executing an order payment sub-process, then the first request message sent by the first device is specifically an order payment request message OrderChangeRQ, and the other order processing sub-processes are similar.
S102: and generating a first log based on the first request message, and storing the first log.
The first log includes a first request message, a first identification code, a second identification code and a third identification code.
S103: the first request message is processed into a second request message matched with the target airline.
In the application, after a data processing platform receives a first request message sent by a first device, a target airline corresponding to the first request message is determined, and the first request message is processed into a second request message matched with the target airline.
Optionally, the first request message carries an airline identifier, and the data processing platform determines the target airline according to the airline identifier carried by the first request message.
S104: and generating a second log based on the second request message, and storing the second log.
The second log comprises a second request message, a first identification code, a second identification code and a third identification code.
S105: and sending a second request message to the second device.
S106: and receiving a first return message sent by the second equipment.
The second device is an electronic device on the side of the target airline. And after receiving a second request message sent by the data processing platform, the second equipment processes the second request message and returns a corresponding message. In the application, a return message sent by the second device to the data processing platform is called a first return message.
If the first request message sent by the first device is specifically the flight query request message AirshoppingRQ, the first return message sent by the second device is specifically the flight query return message AirshoppingRS. If the first request message sent by the first device is specifically the order payment request message OrderChangeRQ, the first return message sent by the second device is specifically the order payment return message OrderChangeRS, and the other cases are similar.
S107: and generating a third log based on the first return message, and storing the third log.
The third log comprises a first return message, a first identification code, a second identification code and a third identification code.
S108: the first return message is processed into a second return message that matches the first device.
S109: and generating a fourth log based on the second return message, and storing the fourth log.
The fourth log comprises a second return message, a first identification code, a second identification code and a third identification code.
S110: and sending the second return message and the first identification code to the first device, so that the first device carries the first identification code in the subsequently sent first request message.
And after receiving the first return message sent by the second device, the data processing platform processes the first return message into a second return message matched with the first device. In addition, the data processing platform is to send a second return message and a first identification code to the first device, so that the first device carries the first identification code in a first request message sent to the data processing platform subsequently.
The first identification code (TrxID), the second identification code (RequestID) and the third identification code are described herein.
In the foregoing, it was described that an order processing flow includes a plurality of order processing sub-flows.
The first identification codes are used for indicating the order processing flow, the first identification codes in the logs generated in the same order processing flow are the same identification codes, and the first identification codes in the logs generated in different order processing flows are different identification codes.
Taking order processing flows order1 and order2 as an example: the first identification codes in the plurality of logs generated during the execution of the order processing flow order1 are the same identification code (e.g., identification code M1), and the first identification codes in the plurality of logs generated during the execution of the order processing flow order2 are the same identification code (e.g., identification code M2, identification code M1 and identification code M2 are different).
The second identification code is used for indicating an order processing sub-flow in the same order processing flow, the second identification code in the log generated in the same order processing sub-flow is the same identification code, and the second identification code in the log generated in different order processing sub-flows in the same order processing flow is different identification codes.
Taking order processing flow order1 as an example: the first identification codes in the multiple logs generated in the execution process of the order processing flow order1 are the same identification code (such as identification code M1), the second identification codes in the first log, the second log, the third log and the fourth log generated in the flight inquiry sub-flow are the same identification code (such as identification code M3), and the second identification codes in the first log, the second log, the third log and the fourth log generated in the order payment sub-flow are the same identification code (such as identification code M4, and the identification codes M3 and M4 are different).
Optionally, the second identification code in the log generated in the same order processing sub-flow in different order processing flows employs the same identification code.
Still taking order processing flows order1 and order2 as examples here: the first identification code in the plurality of logs generated during the execution of the order processing procedure order1 is the same identification code (such as identification code M1), the first identification code in the plurality of logs generated during the execution of the order processing procedure order2 is the same identification code (such as identification code M2), the second identification code in the first, second, third and fourth logs generated during the execution of the flight inquiry sub-procedure of the order processing procedure order1 and order2 is the same identification code (such as identification code M3), and the second identification code in the first, second, third and fourth logs generated during the execution of the order payment sub-procedure of the order processing procedure order1 and order2 is the same identification code (such as identification code M4, identification code M3 and identification code M4 are different).
The third identification code is used for indicating a message state, and the message state comprises: a first device-to-data processing platform request, a data processing platform-to-airline request, an airline-to-data processing platform return, and a data processing platform-to-first device return.
That is, based on the first identification code, it is possible to distinguish which of the order processing flows the respective logs stored by the data processing platform are specifically generated in, based on the second identification code, it is possible to further determine which of the order processing sub-flows the respective logs stored by the data processing platform are specifically generated in, and based on the third identification code, it is possible to further determine at which stage of the order processing sub-flows the respective logs stored by the data processing platform are generated in.
It can be seen that the data processing platform generates corresponding logs after receiving the first request message sent by the first device, after processing the first request message into the second request message, after receiving the first return message sent by the second device, and after processing the first return message into the second return message, where each log includes the first identifier, the second identifier, and the third identifier.
When an order is wrong, all messages related to the order can be obtained based on a first identification code corresponding to the order, and the context relation of the messages can be known, so that a fault can be positioned, namely whether the fault occurs in a seller, an aggregator or an airline company or a specific cause causing the order error, such as parameter input error, can be determined.
In implementation, the first identifier may be a 32-bit unique identifier (Universally Unique Identifier, UUID), the second identifier may be a 16-bit identifier, and the third identifier may be a single-character english identifier, for example: A. b, C and D.
In practice, the log may be stored in elk+ FileBeat mode. Namely, log is distributed on each node to collect related logs, and the logs are analyzed and filtered and then sent to an elastic search on a remote server for storage. The elastomer search compresses data in fragments and provides multiple APIs for user queries.
After receiving a first request message sent by a first device, the data processing platform generates and stores a first log generated based on the first request message, processes the first request message into a second request message matched with a target airline company, generates and stores a second log generated based on the second request message, and sends the second request message to a second device corresponding to the target airline company; after receiving the first return message sent by the second device, the data processing platform generates and stores a third log generated based on the first return message, processes the first return message into a second return message matched with the first device, generates and stores a fourth log generated based on the second return message, and sends the second return message and the first identification code to the first device; each log generated by the data processing platform comprises a first identification code, a second identification code and a third identification code besides the message.
Based on the data processing method provided by the application, the first equipment at the seller side can complete the order processing flow without directly docking with the second equipment at the airline company side, so that the docking cost of the seller is reduced. In addition, when an order is wrong, all messages related to the order can be obtained based on the first identification code corresponding to the order, and the context relation of the messages can be known, so that the fault can be positioned, and the specific reason for the order error can be determined.
In another embodiment of the present application, a scheme of generating a first log based on a first request message is described.
Generating a first log based on the first request message, including:
If the first request message is a flight inquiry request message, a first identification code, a second identification code and a third identification code are distributed for the first request message; if the first request message is a non-flight inquiry request message, a first identification code carried by the first request message is obtained, and a second identification code and a third identification code are distributed for the first request message.
The first order processing sub-flow of the order processing flow is a flight query sub-flow, if the first request message received by the data processing platform is a flight query request message, this indicates that the first device (i.e. the seller side) starts a new order processing flow, and a first identification code, a second identification code and a third identification code need to be allocated to the first request message.
If the first request message received by the data processing platform is a non-flight inquiry request message, the first device is currently executing other order processing sub-flows except for the flight inquiry sub-flow. It may be understood that the data processing platform has sent the first identifier to the first device in the pre-procedure of order processing, and the first device carries the first identifier in the first request message sent this time, so that the data processing platform obtains the first identifier carried by the first request message, and allocates the second identifier and the third identifier to the first request message.
In another embodiment of the present application, an approach is presented for processing a first request message into a second request message that matches a target airline.
The first request message contains all data required for constructing the second request message, and then the data processing platform acquires all data required for constructing the second request message from the first request message, and generates a second request message matched with the target airline company based on the acquired data.
In another embodiment of the present application, another scheme for processing the first request message into a second request message matching the target airline is described.
There is a large amount of duplicate redundancy information in the request message specified by the airline, and the seller wishes to be able to simplify the request message. Taking the example of a vendor creating an order at an airline, the airline-specified create order request message needs to carry flight leg information, time of day information, and OD information that has been sent to the vendor in the pre-order processing sub-flow, and that does not allow the vendor to modify. And airlines need sellers to provide this information again as well as other new parameters when creating orders.
In order to reduce the burden on the seller side, the first request message is processed into a second request message matched with the target airline company, and the following scheme may be adopted:
Acquiring data required for constructing a second request message from the first request message and the stored log; and generating a second request message matched with the target airline company based on the data.
That is, there may be a portion of the first request message that appears in the pre-order processing sub-flow and a portion of the first return message that appears in the pre-order processing sub-flow. In the current order processing sub-flow, the first request message sent by the first device may not include the data already stored in the log, but only include new data. After receiving the first request message, the data processing platform acquires data required for constructing the second request message from the first request message and the stored log, and generates a second request message matched with the target airline company based on the data.
Taking an example that a seller creates an order at an airline company, the order creation request message (first request message) sent by the first device is only 86 rows, and the order creation request message (second request message) obtained after being processed by the data processing platform is 185 rows. The flight leg information, the time information and the OD information in the second request message are carried in a first return message sent by the second device to the data processing platform in the preamble order processing sub-flow, so that the creation order request message sent by the first device does not need to contain the flight leg information, the time information and the OD information, and the data processing platform can acquire the information in the third log and construct the second request message based on the creation order request message sent by the first device and the acquired information.
Referring to fig. 2 and fig. 3, fig. 2 is a schematic diagram of a first request message sent by a first device to a data processing platform, and fig. 3 is a schematic diagram of a second request message obtained by processing the first request message shown in fig. 2 by the data processing platform.
In another embodiment of the present application, on the basis of the data processing method shown in fig. 1, the following steps are further set:
1) And receiving the screening rule.
2) And acquiring a corresponding log from the stored logs according to the screening rules, and outputting the log.
Wherein the screening rule comprises at least a first identification code.
Optionally, the screening rule includes a first identification code, and correspondingly, a log including the first identification code is obtained according to the screening rule.
Optionally, the screening rule includes a first identifier and a second identifier, and correspondingly, a log including the first identifier and the second identifier is obtained according to the screening rule.
The user can quickly acquire the corresponding message by setting the screening rule.
For example, when the user needs to view all the messages of an order, the user can obtain all the logs corresponding to the order by taking the first identification code corresponding to the order as a screening rule, and can see all the messages of the order. When a user needs to check the message of an order in a certain order processing sub-flow, the user can acquire all logs of the order in the order processing sub-flow by taking the first identification code corresponding to the order and the second identification code corresponding to the order processing sub-flow as screening rules, and can see all messages of the order in the order processing sub-flow.
In one possible implementation, the user enters the screening rules at the data processing platform.
In another possible implementation, the user enters the screening rules at an electronic device associated with the data processing platform, which is transmitted by the electronic device to the data processing platform.
In another possible implementation, the data processing platform presents a list page after the user passes the verification, wherein the list page includes at least a first list of identification codes, and generates the filtering rule based on a selection of the first identification code in the first list of identification codes.
In another possible implementation, the data processing platform presents a list page after the user passes the verification, wherein the list page contains at least a first identifier list and a second identifier list, and generates the filtering rule based on a selection of the first identifier in the first identifier list and a selection of the second identifier in the second identifier list.
Referring to fig. 4, fig. 4 is a schematic diagram of a graphical interface for screening a presentation log according to the present application.
In some embodiments, the clients, servers may communicate using any currently known or future developed network protocol, such as HTTP (HyperText Transfer Protocol ), and may be interconnected with any form or medium of digital data communication (e.g., a communication network). Examples of communication networks include a local area network ("LAN"), a wide area network ("WAN"), the internet (e.g., the internet), and peer-to-peer networks (e.g., ad hoc peer-to-peer networks), as well as any currently known or future developed networks.
It should be understood that the various steps recited in the method embodiments of the present application may be performed in a different order and/or performed in parallel. Furthermore, method embodiments may include additional steps and/or omit performing the illustrated steps. The scope of the application is not limited in this respect.
The embodiment of the application provides a data processing method, and correspondingly, the embodiment of the application also provides a data processing device. The descriptions of the two in the specification can be referred to each other.
Referring to fig. 5, fig. 5 is a schematic structural diagram of a data processing apparatus according to an embodiment of the application. The data processing apparatus includes:
a first message receiving unit 501, configured to receive a first request message sent by a first device.
The first log generating unit 502 is configured to generate a first log based on the first request packet, and store the first log, where the first log includes the first request packet, the first identifier, the second identifier, and the third identifier.
A first message processing unit 503, configured to process the first request message into a second request message matched with the target airline.
The second log generating unit 504 is configured to generate a second log based on the second request packet, and store the second log, where the second log includes the second request packet, the first identifier, the second identifier, and the third identifier.
A first message sending unit 505, configured to send a second request message to the second device.
A second message receiving unit 506, configured to receive the first return message sent by the second device.
And a third log generating unit 507, configured to generate a third log based on the first return packet, and store the third log, where the third log includes the first return packet, the first identification code, the second identification code, and the third identification code.
A second message processing unit 508, configured to process the first return message into a second return message matched with the first device.
The fourth log generating unit 509 is configured to generate a fourth log based on the second return packet, and store the fourth log, where the fourth log includes the second return packet, the first identifier, the second identifier, and the third identifier.
The second message sending unit 510 is configured to send a second return message and a first identifier to the first device, so that the first device carries the first identifier in a first request message that is sent subsequently.
The first identification codes are used for indicating the order processing flow, the first identification codes in the logs generated in the same order processing flow are the same identification codes, and the first identification codes in the logs generated in different order processing flows are different identification codes; the second identification code is used for indicating an order processing sub-flow in the same order processing flow, the second identification code in the log generated in the same order processing sub-flow is the same identification code, and the second identification code in the log generated in different order processing sub-flows in the same order processing flow is different identification codes; the third identification code is used for indicating a message state, and the message state comprises: a first device-to-data processing platform request, a data processing platform-to-airline request, an airline-to-data processing platform return, and a data processing platform-to-first device return.
Optionally, the first log generating unit 502 is specifically configured to: if the first request message is a flight inquiry request message, a first identification code, a second identification code and a third identification code are distributed for the first request message; if the first request message is a non-flight inquiry request message, a first identification code carried by the first request message is obtained, and a second identification code and a third identification code are distributed for the first request message.
Optionally, the first message processing unit 503 is specifically configured to: acquiring data required for constructing a second request message from the first request message and the stored log; and generating a second request message matched with the target airline company based on the acquired data.
Optionally, on the basis of the data processing apparatus shown in fig. 5, the apparatus further includes:
A screening rule receiving unit for receiving a screening rule;
The log obtaining unit is used for obtaining the corresponding log from the stored logs according to the screening rule and outputting the obtained log.
The other embodiment of the application also provides an electronic device for realizing the data processing method provided by the application.
Referring to fig. 6, fig. 6 is a schematic structural diagram of an electronic device according to another embodiment of the present application. The electronic device may include a processor 601, a memory 602, and a communication interface 603.
Optionally, the server may further include: an input unit 604, a display 605 and a communication bus 606. The processor 601, the memory 602, the communication interface 603, the input unit 604, and the display 605 all perform communication with each other through the communication bus 606.
In an embodiment of the present application, the processor 601 may be a central processing unit (Central Processing Unit, CPU), an asic, a dsp, an off-the-shelf programmable gate array, or other programmable logic device.
The processor 601 may call a program stored in the memory 602.
The memory 602 is used to store one or more programs, which may include program code including computer operating instructions. In the embodiment of the present application, a program for implementing any one of the above-described data processing methods is stored in the memory.
In one possible implementation, the memory 602 may include a stored program area and a stored data area, wherein the stored program area may store an operating system, the above-mentioned programs, and the like; the storage data area may store data or the like created during use of the computer device.
In addition, the memory 602 may include high-speed random access memory, and may also include non-volatile memory.
The communication interface 603 may be an interface of a communication module.
The input unit 604 may include a touch sensing unit sensing a touch event on the touch display panel, a keyboard, and the like.
The display 605 includes a display panel such as a touch display panel or the like.
Of course, the structure of the electronic device shown in fig. 6 is not limited to the electronic device in the embodiment of the present application, and the electronic device may include more or fewer components than those shown in fig. 6 or may combine some components in practical applications.
It should be noted that, the electronic device in the embodiment of the present application may include, but is not limited to, a server, for example, a server cluster or a stand-alone server. The electronic device shown in fig. 6 is only an example and should not be construed as limiting the functionality and scope of use of the embodiments of the application.
Another embodiment of the present application provides a storage medium executable by an electronic device, where a program is stored, and when the program is loaded and executed by a processor of the electronic device, the program causes the electronic device to implement any one of the data processing methods disclosed above.
The computer readable medium of the present application may be a computer readable signal medium or a computer readable storage medium, or any combination of the two. The computer readable storage medium may be, but is not limited to: an electrical, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or a combination of any of the foregoing. More specific examples of the computer-readable storage medium may include, but are not limited to: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device. In the present application, however, the computer-readable signal medium may include a data signal propagated in baseband or as part of a carrier wave, with the computer-readable program code embodied therein. Such a propagated data signal may take any of a variety of forms, including, but not limited to, electro-magnetic, optical, or any suitable combination of the foregoing. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device. Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to: electrical wires, fiber optic cables, RF (radio frequency), and the like, or any suitable combination of the foregoing.
According to one or more embodiments of the present application, there is provided a data processing method applied to a data processing platform, the data processing method including:
Receiving a first request message sent by first equipment;
generating a first log based on the first request message, and storing the first log, wherein the first log comprises the first request message, a first identification code, a second identification code and a third identification code;
processing the first request message into a second request message matched with a target airline company;
Generating a second log based on the second request message, and storing the second log, wherein the second log comprises the second request message, a first identification code, a second identification code and a third identification code;
Sending the second request message to second equipment;
receiving a first return message sent by the second device;
generating a third log based on the first return message, storing the third log, wherein the third log comprises the first return message, a first identification code, a second identification code and a third identification code;
processing the first return message into a second return message matched with the first device;
generating a fourth log based on the second return message, storing the fourth log, wherein the fourth log comprises the second return message, a first identification code, a second identification code and a third identification code;
the second return message and the first identification code are sent to the first equipment, so that the first equipment carries the first identification code in a first request message which is sent subsequently;
The first identification codes are used for indicating the order processing flow, the first identification codes in the logs generated in the same order processing flow are the same identification codes, and the first identification codes in the logs generated in different order processing flows are different identification codes; the second identification code is used for indicating an order processing sub-flow in the same order processing flow, the second identification code in the log generated in the same order processing sub-flow is the same identification code, and the second identification code in the log generated in different order processing sub-flows in the same order processing flow is different identification codes; the third identification code is used for indicating a message state, and the message state comprises: a first device-to-data processing platform request, a data processing platform-to-airline request, an airline-to-data processing platform return, and a data processing platform-to-first device return.
According to one or more embodiments of the present application, on the basis of the above data processing method, the generating a first log based on the first request packet includes:
If the first request message is a flight inquiry request message, a first identification code, a second identification code and a third identification code are distributed for the first request message;
If the first request message is a non-flight inquiry request message, a first identification code carried by the first request message is obtained, and a second identification code and a third identification code are distributed for the first request message.
According to one or more embodiments of the present application, on the basis of the above data processing method, the processing the first request packet into a second request packet matched with a target airline includes:
Acquiring data required for constructing the second request message from the first request message and the stored log;
and generating a second request message matched with the target airline company based on the data.
According to one or more embodiments of the present application, on the basis of the above data processing method, the method further includes:
receiving a screening rule;
and acquiring a corresponding log from the stored logs according to the screening rule, and outputting the acquired log.
According to one or more embodiments of the present application, on the basis of the above data processing method, the receiving filtering rule includes:
Displaying a list page after the user passes the verification, wherein the list page at least comprises a first identification code list;
a screening rule is generated based on a selection of a first identification code in the first list of identification codes.
According to one or more embodiments of the present application, there is provided a data processing apparatus for use in a data processing platform, the data processing apparatus comprising:
the first message receiving unit is used for receiving a first request message sent by the first equipment;
a first log generating unit, configured to generate a first log based on the first request packet, and store the first log, where the first log includes the first request packet, a first identifier, a second identifier, and a third identifier;
the first message processing unit is used for processing the first request message into a second request message matched with the target airline company;
A second log generating unit, configured to generate a second log based on the second request packet, and store the second log, where the second log includes the second request packet, a first identifier, a second identifier, and a third identifier;
A first message sending unit, configured to send the second request message to a second device;
A second message receiving unit, configured to receive a first return message sent by the second device;
A third log generating unit, configured to generate a third log based on the first return packet, and store the third log, where the third log includes the first return packet, a first identifier, a second identifier, and a third identifier;
the second message processing unit is used for processing the first return message into a second return message matched with the first device;
A fourth log generating unit, configured to generate a fourth log based on the second return packet, and store the fourth log, where the fourth log includes the second return packet, the first identifier, the second identifier, and the third identifier;
A second message sending unit, configured to send the second return message and the first identifier to the first device, so that the first device carries the first identifier in a first request message that is sent subsequently;
The first identification codes are used for indicating the order processing flow, the first identification codes in the logs generated in the same order processing flow are the same identification codes, and the first identification codes in the logs generated in different order processing flows are different identification codes; the second identification code is used for indicating an order processing sub-flow in the same order processing flow, the second identification code in the log generated in the same order processing sub-flow is the same identification code, and the second identification code in the log generated in different order processing sub-flows in the same order processing flow is different identification codes; the third identification code is used for indicating a message state, and the message state comprises: a first device-to-data processing platform request, a data processing platform-to-airline request, an airline-to-data processing platform return, and a data processing platform-to-first device return.
According to one or more embodiments of the present application, on the basis of the above data processing apparatus, the first log generating unit is specifically configured to: if the first request message is a flight inquiry request message, a first identification code, a second identification code and a third identification code are distributed for the first request message; if the first request message is a non-flight inquiry request message, a first identification code carried by the first request message is obtained, and a second identification code and a third identification code are distributed for the first request message.
According to one or more embodiments of the present application, on the basis of the data processing apparatus described above, the first packet processing unit is specifically configured to: acquiring data required for constructing the second request message from the first request message and the stored log; and generating a second request message matched with the target airline company based on the data.
According to one or more embodiments of the present application, on the basis of the above data processing apparatus, further comprising:
A screening rule receiving unit for receiving a screening rule;
and the log acquisition unit is used for acquiring the corresponding log from the stored logs according to the screening rule and outputting the acquired log.
According to one or more embodiments of the present application, there is provided an electronic device including a processor, a memory, and a communication interface;
the memory is used for storing programs:
the processor is used for executing the program to realize any one of the data processing methods provided by the application.
According to one or more embodiments of the present application, there is provided a storage medium having a program stored therein, which when loaded and executed by a processor, implements any one of the data processing methods provided by the present application.
In practice, computer program code for carrying out operations of the present application may be written in one or more programming languages, including, but not limited to, an object oriented programming language such as Java, smalltalk, C ++ and conventional procedural programming languages, such as the "C" programming language or similar programming languages. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer or entirely on the remote computer or server. In the case of a remote computer, the remote computer may be connected to the user's computer through any kind of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or may be connected to an external computer (for example, through the Internet using an Internet service provider).
It should be noted that the flowcharts and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of methods, apparatus and electronic devices according to various embodiments of the present application. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams and/or flowchart illustration, and combinations of blocks in the block diagrams and/or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions.
The names of messages or information interacted between the devices in the embodiments of the present application are for illustrative purposes only and are not intended to limit the scope of such messages or information.
Although operations are depicted in a particular order, this should not be understood as requiring that such operations be performed in the particular order shown or in sequential order. In certain circumstances, multitasking and parallel processing may be advantageous.
Although the subject matter has been described in language specific to structural features and/or methodological acts, it is to be understood that the subject matter defined in the appended claims is not necessarily limited to the specific features or acts described above. Rather, the specific features and acts described above are example forms of implementing the claims.
While several specific implementation details are included in the above discussion, these should not be construed as limiting the scope of the disclosure. Certain features that are described in the context of separate embodiments can also be implemented in combination in a single embodiment. Conversely, various features that are described in the context of a single embodiment can also be implemented in multiple embodiments separately or in any suitable subcombination.
The foregoing description is only of the preferred embodiments of the present disclosure and description of the principles of the technology being employed. It will be appreciated by persons skilled in the art that the scope of the disclosure referred to in this disclosure is not limited to the specific combinations of features described above, but also covers other embodiments which may be formed by any combination of features described above or equivalents thereof without departing from the spirit of the disclosure. Such as those described above, are mutually substituted with the technical features having similar functions disclosed in the present disclosure (but not limited thereto).
Claims (10)
1. A data processing method, applied to a data processing platform, the data processing method comprising:
Receiving a first request message sent by first equipment;
generating a first log based on the first request message, and storing the first log, wherein the first log comprises the first request message, a first identification code, a second identification code and a third identification code;
processing the first request message into a second request message matched with a target airline company;
Generating a second log based on the second request message, and storing the second log, wherein the second log comprises the second request message, a first identification code, a second identification code and a third identification code;
Sending the second request message to second equipment;
receiving a first return message sent by the second device;
generating a third log based on the first return message, storing the third log, wherein the third log comprises the first return message, a first identification code, a second identification code and a third identification code;
processing the first return message into a second return message matched with the first device;
generating a fourth log based on the second return message, storing the fourth log, wherein the fourth log comprises the second return message, a first identification code, a second identification code and a third identification code;
the second return message and the first identification code are sent to the first equipment, so that the first equipment carries the first identification code in a first request message which is sent subsequently;
The first identification codes are used for indicating the order processing flow, the first identification codes in the logs generated in the same order processing flow are the same identification codes, and the first identification codes in the logs generated in different order processing flows are different identification codes; the second identification code is used for indicating an order processing sub-flow in the same order processing flow, the second identification code in the log generated in the same order processing sub-flow is the same identification code, and the second identification code in the log generated in different order processing sub-flows in the same order processing flow is different identification codes; the third identification code is used for indicating a message state, and the message state comprises: a first device-to-data processing platform request, a data processing platform-to-airline request, an airline-to-data processing platform return, and a data processing platform-to-first device return;
The method comprises the steps of distinguishing which log stored by a data processing platform is generated in an order processing flow based on a first identification code, further determining which log stored by the data processing platform is generated in which order processing sub-flow based on a second identification code, further determining which stage in the order processing sub-flow each log stored by the data processing platform is generated in based on a third identification code, acquiring all messages related to the order based on the first identification code corresponding to the order when the order is wrong, knowing the context relation of each message, positioning a fault, namely determining whether the fault is generated in a seller, an aggregator or an airline company, and determining the specific cause of the order error.
2. The method of claim 1, wherein generating a first log based on the first request message comprises:
If the first request message is a flight inquiry request message, a first identification code, a second identification code and a third identification code are distributed for the first request message;
If the first request message is a non-flight inquiry request message, a first identification code carried by the first request message is obtained, and a second identification code and a third identification code are distributed for the first request message.
3. The method of claim 1, wherein processing the first request message as a second request message matching a target airline comprises:
Acquiring data required for constructing the second request message from the first request message and the stored log;
and generating a second request message matched with the target airline company based on the data.
4. The method as recited in claim 1, further comprising:
receiving a screening rule;
and acquiring a corresponding log from the stored logs according to the screening rule, and outputting the acquired log.
5. The method of claim 4, wherein receiving the screening rule comprises:
Displaying a list page after the user passes the verification, wherein the list page at least comprises a first identification code list;
a screening rule is generated based on a selection of a first identification code in the first list of identification codes.
6. A data processing apparatus for use with a data processing platform, the data processing apparatus comprising:
the first message receiving unit is used for receiving a first request message sent by the first equipment;
a first log generating unit, configured to generate a first log based on the first request packet, and store the first log, where the first log includes the first request packet, a first identifier, a second identifier, and a third identifier;
the first message processing unit is used for processing the first request message into a second request message matched with the target airline company;
A second log generating unit, configured to generate a second log based on the second request packet, and store the second log, where the second log includes the second request packet, a first identifier, a second identifier, and a third identifier;
A first message sending unit, configured to send the second request message to a second device;
A second message receiving unit, configured to receive a first return message sent by the second device;
A third log generating unit, configured to generate a third log based on the first return packet, and store the third log, where the third log includes the first return packet, a first identifier, a second identifier, and a third identifier;
the second message processing unit is used for processing the first return message into a second return message matched with the first device;
A fourth log generating unit, configured to generate a fourth log based on the second return packet, and store the fourth log, where the fourth log includes the second return packet, the first identifier, the second identifier, and the third identifier;
A second message sending unit, configured to send the second return message and the first identifier to the first device, so that the first device carries the first identifier in a first request message that is sent subsequently;
The first identification codes are used for indicating the order processing flow, the first identification codes in the logs generated in the same order processing flow are the same identification codes, and the first identification codes in the logs generated in different order processing flows are different identification codes; the second identification code is used for indicating an order processing sub-flow in the same order processing flow, the second identification code in the log generated in the same order processing sub-flow is the same identification code, and the second identification code in the log generated in different order processing sub-flows in the same order processing flow is different identification codes; the third identification code is used for indicating a message state, and the message state comprises: a first device-to-data processing platform request, a data processing platform-to-airline request, an airline-to-data processing platform return, and a data processing platform-to-first device return;
The method comprises the steps of distinguishing which log stored by a data processing platform is generated in an order processing flow based on a first identification code, further determining which log stored by the data processing platform is generated in which order processing sub-flow based on a second identification code, further determining which stage in the order processing sub-flow each log stored by the data processing platform is generated in based on a third identification code, acquiring all messages related to the order based on the first identification code corresponding to the order when the order is wrong, knowing the context relation of each message, positioning a fault, namely determining whether the fault is generated in a seller, an aggregator or an airline company, and determining the specific cause of the order error.
7. The apparatus of claim 6, wherein the first log generation unit is specifically configured to: if the first request message is a flight inquiry request message, a first identification code, a second identification code and a third identification code are distributed for the first request message; if the first request message is a non-flight inquiry request message, a first identification code carried by the first request message is obtained, and a second identification code and a third identification code are distributed for the first request message.
8. The apparatus of claim 6, wherein the first message processing unit is specifically configured to: acquiring data required for constructing the second request message from the first request message and the stored log; and generating a second request message matched with the target airline company based on the data.
9. The apparatus as recited in claim 6, further comprising:
A screening rule receiving unit for receiving a screening rule;
and the log acquisition unit is used for acquiring the corresponding log from the stored logs according to the screening rule and outputting the acquired log.
10. An electronic device comprising a processor, a memory, and a communication interface;
the memory is used for storing programs:
the processor is configured to execute the program to implement the data processing method according to any one of claims 1 to 5.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011305522.4A CN112258298B (en) | 2020-11-19 | 2020-11-19 | Data processing method and device and electronic equipment |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011305522.4A CN112258298B (en) | 2020-11-19 | 2020-11-19 | Data processing method and device and electronic equipment |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN112258298A CN112258298A (en) | 2021-01-22 |
| CN112258298B true CN112258298B (en) | 2024-08-09 |
Family
ID=74266181
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202011305522.4A Active CN112258298B (en) | 2020-11-19 | 2020-11-19 | Data processing method and device and electronic equipment |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN112258298B (en) |
Families Citing this family (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114356777A (en) * | 2022-01-10 | 2022-04-15 | 中国民航信息网络股份有限公司 | Service scene testing method and device, storage medium and electronic equipment |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN108427619A (en) * | 2018-03-13 | 2018-08-21 | 腾讯科技（深圳）有限公司 | Blog management method, device, computing device and storage medium |
| CN110022289A (en) * | 2018-01-10 | 2019-07-16 | 北龙中网（北京）科技有限责任公司 | Data transmission method, apparatus and system |
| CN111352902A (en) * | 2020-02-28 | 2020-06-30 | 中国平安人寿保险股份有限公司 | Log processing method, device, terminal device and storage medium |
Family Cites Families (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN106878041B (en) * | 2015-12-11 | 2020-11-20 | 阿里巴巴（中国）有限公司 | Log information processing method, device and system |
| CN110322035A (en) * | 2019-07-10 | 2019-10-11 | 中国民航信息网络股份有限公司 | A kind of Airline reservation information processing method and system |
| CN111614757A (en) * | 2020-05-20 | 2020-09-01 | 中国建设银行股份有限公司 | Message interaction method, device, equipment and medium for client and server |
-
2020
- 2020-11-19 CN CN202011305522.4A patent/CN112258298B/en active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110022289A (en) * | 2018-01-10 | 2019-07-16 | 北龙中网（北京）科技有限责任公司 | Data transmission method, apparatus and system |
| CN108427619A (en) * | 2018-03-13 | 2018-08-21 | 腾讯科技（深圳）有限公司 | Blog management method, device, computing device and storage medium |
| CN111352902A (en) * | 2020-02-28 | 2020-06-30 | 中国平安人寿保险股份有限公司 | Log processing method, device, terminal device and storage medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN112258298A (en) | 2021-01-22 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111581291B (en) | Data processing method, device, electronic equipment and readable medium | |
| US10951692B1 (en) | Deployment of microservices based on back-end resource affinity | |
| CN113572689A (en) | Microservice gateway management method, system, device, readable storage medium and product | |
| US11378942B2 (en) | Progressive guidance of digital twin model assembly | |
| CN109818962B (en) | Service data processing method and device, electronic equipment and storage medium | |
| CN114968621B (en) | Data communication method, device, equipment, storage medium and system | |
| CN110019158A (en) | A kind of method and apparatus of monitoring data quality | |
| CN112258298B (en) | Data processing method and device and electronic equipment | |
| CN110852720A (en) | Document processing method, device, equipment and storage medium | |
| CN112507676B (en) | Method and device for generating energy report, electronic equipment and computer readable medium | |
| CN112883697B (en) | Workflow form generation method, device, electronic equipment and computer readable medium | |
| CN114372852A (en) | A self-service ticket change method, system, device and storage medium | |
| CN110780915B (en) | Data processing method, device and storage medium | |
| CN115134372B (en) | Data processing method and related device | |
| CN112417230A (en) | Freight rate data processing method and device and electronic equipment | |
| CN112328603B (en) | User request processing method, device, equipment and computer readable medium | |
| CN116599846A (en) | Inter-tenant network connection method, apparatus, electronic device and computer readable medium | |
| CN113918525A (en) | Data exchange scheduling method, system, electronic device, medium and program product | |
| CN113947434A (en) | A business processing method and device for a multi-business component combination scenario | |
| CN114697206A (en) | Internet of things node management method, device, equipment and computer readable medium | |
| US10652308B2 (en) | Cognitive storage management for a mobile computing device | |
| CN112286773A (en) | Method, device, medium and electronic equipment for collecting crash information | |
| CN113077352B (en) | Insurance service article recommending method based on user information and insurance related information | |
| CN112650528B (en) | Personalized algorithm generation method, device, electronic equipment and computer readable medium | |
| CN112929162B (en) | Password management method and system, electronic equipment and readable 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 |