CN119273473A - A transaction event processing method, device, equipment and storage medium - Google Patents

A transaction event processing method, device, equipment and storage medium Download PDF

Info

Publication number
CN119273473A
CN119273473A CN202411518767.3A CN202411518767A CN119273473A CN 119273473 A CN119273473 A CN 119273473A CN 202411518767 A CN202411518767 A CN 202411518767A CN 119273473 A CN119273473 A CN 119273473A
Authority
CN
China
Prior art keywords
processing
checkpoint
transaction event
processing request
sub
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.)
Pending
Application number
CN202411518767.3A
Other languages
Chinese (zh)
Inventor
丁源
徐渊林
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
China Construction Bank Corp
CCB Finetech Co Ltd
Original Assignee
China Construction Bank Corp
CCB Finetech Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by China Construction Bank Corp, CCB Finetech Co Ltd filed Critical China Construction Bank Corp
Priority to CN202411518767.3A priority Critical patent/CN119273473A/en
Publication of CN119273473A publication Critical patent/CN119273473A/en
Pending legal-status Critical Current

Links

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06QINFORMATION 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
    • G06Q40/00Finance; Insurance; Tax strategies; Processing of corporate or income taxes
    • G06Q40/04Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange

Landscapes

  • Business, Economics & Management (AREA)
  • Accounting & Taxation (AREA)
  • Finance (AREA)
  • Engineering & Computer Science (AREA)
  • Development Economics (AREA)
  • Economics (AREA)
  • Marketing (AREA)
  • Strategic Management (AREA)
  • Technology Law (AREA)
  • Physics & Mathematics (AREA)
  • General Business, Economics & Management (AREA)
  • General Physics & Mathematics (AREA)
  • Theoretical Computer Science (AREA)
  • Debugging And Monitoring (AREA)

Abstract

本申请实施例提供了一种交易事件处理方法、装置、设备及存储介质,可应用于计算机技术领域,在该方法中,将针对交易事件的处理流程环节,拆分为多个子处理环节;针对每个子处理环节,分别执行以下操作:接收上一个子处理环节发送的针对交易事件的处理请求;对交易事件的处理请求进行准入检测,获得准入检测结果;这样能够将交易事件的处理请求的异常定位到某一个具体的子处理环节中,若准入检测结果为流程中断,则对导致流程中断的异常因素进行修复;并在异常因素修复后,返回执行对交易事件的处理请求进行准入检测,获得准入检测结果的步骤,实现了流程中断的及时修复,提高了交易系统的业务处理效率,同时保障交易系统的可用性和稳定性。

The embodiments of the present application provide a transaction event processing method, apparatus, device and storage medium, which can be applied to the field of computer technology. In the method, the processing flow link for the transaction event is divided into multiple sub-processing links; for each sub-processing link, the following operations are performed respectively: receiving a processing request for the transaction event sent by the previous sub-processing link; performing an access check on the processing request for the transaction event to obtain an access check result; in this way, the anomaly of the processing request for the transaction event can be located in a specific sub-processing link. If the access check result is a process interruption, the abnormal factor causing the process interruption is repaired; and after the abnormal factor is repaired, the step of performing an access check on the processing request for the transaction event to obtain the access check result is returned, thereby realizing timely repair of the process interruption, improving the business processing efficiency of the transaction system, and ensuring the availability and stability of the transaction system.

Description

Transaction event processing method, device, equipment and storage medium
Technical Field
The embodiment of the application relates to the technical field of computers, in particular to a transaction event processing method, a transaction event processing device, transaction event processing equipment and a storage medium.
Background
With the development of internet technology, more and more transaction systems interact, and correspondingly, when the transaction system processes transaction events, more and more processing links are provided. In the related art, when an access abnormality occurs when a transaction event flows between different links, a special technical means is generally adopted to modify an error result in a database and then reprocess the transaction event from the beginning.
However, when an abnormality occurs in a transaction event, the method is difficult to locate a specific link in which the abnormality occurs, and the transaction event needs to be reprocessed from the beginning each time the abnormality occurs, so that the service processing efficiency of the transaction system is seriously affected, and the usability and stability of the transaction system cannot be ensured.
Disclosure of Invention
The embodiment of the invention provides a transaction event processing method, a device, equipment and a storage medium, which are used for locating a specific link with abnormality, improving the service processing efficiency of a transaction system and simultaneously guaranteeing the availability and stability of the transaction system.
In one aspect, an embodiment of the present application provides a transaction event processing method, where the method includes:
splitting a processing flow link aiming at a transaction event into a plurality of sub-processing links;
For each sub-processing link, the following operations are respectively executed:
receiving a processing request for the transaction event sent by the last sub-processing link;
Performing admission detection on the processing request of the transaction event to obtain an admission detection result;
And after the abnormal factors are repaired, returning to execute the step of carrying out admission detection on the processing request of the transaction event to obtain an admission detection result.
Optionally, the performing admission detection on the processing request of the transaction event, and obtaining an admission detection result includes:
Adopting a checking program corresponding to one check point to detect the information of the transaction event processing request at the one check point and obtaining a corresponding check point result;
and determining the admission detection result based on the obtained multiple check point results.
Optionally, the determining the admission detection result based on the obtained multiple checkpoint results includes:
And if at least one check point result in the plurality of check point results is an abnormal result, the admission detection result is a flow interruption.
Optionally, the checking program corresponding to the one checking point is adopted to detect the information of the transaction event processing request at the one checking point to obtain a corresponding checking point result, and the checking method comprises the following steps:
Adopting a checking program corresponding to the data check point to respectively detect abnormality of a plurality of data items in the processing request of the transaction event;
When at least one data item is abnormal, configuring an abnormality for the data according to a check point result of the data check point;
When the plurality of data items are all normal, then the checkpointed result of the data checkpoint is normal for the data configuration.
Optionally, the abnormal factors are data configuration anomalies, and the repairing of the abnormal factors causing the interruption of the flow comprises the following steps:
and returning to the last sub-processing link to modify the abnormal data item in the processing request of the transaction event.
Optionally, the detecting the information of the transaction event processing request at the one check point by adopting a check program corresponding to the one check point to obtain a corresponding check point result comprises:
If the processing identifier configured in the inspection program corresponding to the parameter check point is different from the processing identifier carried by the processing request, the check point result of the parameter check point is abnormal parameter configuration, wherein the processing identifier carried by the processing request is used for representing the type of the processing request;
And if the processing identifier of the inspection program configuration corresponding to the parameter check point is the same as the processing identifier carried by the processing request, the check point result of the parameter check point is the parameter configuration abnormality.
Optionally, the abnormal factors are parameter configuration abnormality, and the repairing of the abnormal factors causing the interruption of the flow comprises the following steps:
and returning to a parameter configuration link, and modifying the processing identifier configured in the inspection program corresponding to the parameter check point.
Optionally, the plurality of sub-processing elements are executed asynchronously.
In one aspect, an embodiment of the present application provides a transaction information processing apparatus, including:
the decomposition module is used for dividing the processing flow links aiming at the transaction event into a plurality of sub-processing links.
The processing module is used for respectively executing the following operations of receiving a processing request for the transaction event sent by the last sub-processing link, carrying out admission detection on the processing request of the transaction event and obtaining an admission detection result;
And after the abnormal factors are repaired, returning to execute the step of carrying out admission detection on the processing request of the transaction event to obtain an admission detection result.
Optionally, the processing module is specifically configured to:
Adopting a checking program corresponding to one check point to detect the information of the transaction event processing request at the one check point and obtaining a corresponding check point result;
and determining the admission detection result based on the obtained multiple check point results.
Optionally, the processing module is specifically configured to:
And if at least one check point result in the plurality of check point results is an abnormal result, the admission detection result is a flow interruption.
Optionally, the processing module is specifically configured to:
Adopting a checking program corresponding to the data check point to respectively detect abnormality of a plurality of data items in the processing request of the transaction event;
When at least one data item is abnormal, configuring an abnormality for the data according to a check point result of the data check point;
When the plurality of data items are all normal, then the checkpointed result of the data checkpoint is normal for the data configuration.
Optionally, the processing module is specifically configured to:
If the processing identifier configured in the inspection program corresponding to the parameter check point is different from the processing identifier carried by the processing request, the check point result of the parameter check point is abnormal parameter configuration, wherein the processing identifier carried by the processing request is used for representing the type of the processing request;
And if the processing identifier of the inspection program configuration corresponding to the parameter check point is the same as the processing identifier carried by the processing request, the check point result of the parameter check point is the parameter configuration abnormality.
Optionally, the processing module is specifically configured to:
and returning to a parameter configuration link, and modifying the processing identifier configured in the inspection program corresponding to the parameter check point.
Optionally, the plurality of sub-processing elements are asynchronously processed.
In one aspect, an embodiment of the present application provides a computer device, including:
A memory for storing program instructions;
And the processor is used for calling the program instructions stored in the memory and executing the steps of the transaction event processing method according to the obtained program.
In one aspect, embodiments of the present application provide a computer-readable storage medium storing a computer program executable by a computer device, which when run on the computer device, causes the computer to perform the steps of the transaction event processing method described above.
In one aspect, embodiments of the present application provide a computer program product comprising a computer program stored on a computer readable storage medium, the computer program comprising program instructions which, when executed by a computer device, cause the computer device to perform the steps of the transaction event processing method described above.
In the embodiment of the application, the processing flow link of the transaction event is split into a plurality of sub-processing links for processing, and in each sub-processing link, the received processing request is subjected to admission detection, so that the abnormality of the processing request of the transaction event can be positioned in a specific sub-processing link, when the admission detection result is flow interruption, the abnormality factor causing the flow interruption can be repaired, and after the abnormality factor is repaired, the step of executing the processing request of the transaction event for admission detection is returned to obtain the admission detection result, thereby realizing the timely repair of the flow interruption, improving the fault tolerance, maintainability and robustness of the transaction system, and simultaneously modeling, normalizing and formatting the increasingly complex transaction system, improving the processing efficiency of the transaction system and enabling the transaction system to be suitable for popularization and multiplexing.
Drawings
In order to more clearly illustrate the technical solutions of the embodiments of the present invention, the drawings that are needed in the description of the embodiments will be briefly described below, it will be apparent that the drawings in the following description are only some embodiments of the present invention, and that other drawings can be obtained according to these drawings without inventive effort for a person skilled in the art.
Fig. 1 is a schematic structural diagram of a system architecture according to an embodiment of the present application;
FIG. 2 is a flow chart of a transaction event processing method according to an embodiment of the present application;
FIG. 3 is a flow chart of a transaction event processing method according to an embodiment of the present application;
FIG. 4 is a flow chart of a transaction event processing method according to an embodiment of the present application;
FIG. 5 is a schematic diagram of a flow processing link according to an embodiment of the present application;
fig. 6 is a schematic structural diagram of a transaction event processing device according to an embodiment of the present application;
fig. 7 is a schematic structural diagram of a computer device according to an embodiment of the present application.
Detailed Description
In order to make the objects, technical solutions and advantageous effects of the present invention more apparent, the present invention will be further described in detail with reference to the accompanying drawings and examples. It should be understood that the specific embodiments described herein are for purposes of illustration only and are not intended to limit the scope of the invention. All other embodiments, which can be made by those skilled in the art based on the embodiments of the invention without making any inventive effort, are intended to be within the scope of the invention.
The following system architecture diagrams applicable to the technical solution of the embodiments of the present application are briefly described, and it should be noted that the flow described below is only for illustrating the embodiments of the present application and is not limited thereto.
Referring to fig. 1, a system architecture diagram applicable to an embodiment of the present application, where the system architecture at least includes a terminal device 101 and a server 102, the number of the terminal devices 101 may be one or more, and the number of the servers 102 may be one or more.
The terminal apparatus 101 installs in advance an application having a transaction function, which is a client application, a web page application, an applet application, or the like. The terminal device 101 may be, but is not limited to, a smart phone, a tablet computer, a notebook computer, a desktop computer, a smart home appliance, a smart voice interaction device, a smart car-mounted device, and the like.
The server 102 is a background server of an application, and the server 102 may be an independent physical server, a server cluster or a distributed system formed by a plurality of physical servers, or may be a cloud server providing basic cloud computing services such as cloud services, cloud databases, cloud computing, cloud functions, cloud storage, network services, cloud communication, middleware services, domain name services, security services, a content distribution network (Content Delivery Network, CDN), big data, an artificial intelligence platform, and the like, but is not limited thereto.
It should be noted that, the method in the embodiment of the present application may be performed by the terminal device 101 or the server 102 alone, or may be performed by the terminal device 101 and the server 102 together.
In the embodiment of the present application, the terminal device 101 and the server 102 may be directly or indirectly connected through one or more networks. The network may be a wired network, or may be a Wireless network, for example, a mobile cellular network, or may be a Wireless-Fidelity (WIFI) network, or may be other possible networks, which embodiments of the present application are not limited in this respect.
Exemplary embodiments of the present application will now be described with reference to the accompanying drawings, in which various details of the embodiments of the present application are included to facilitate understanding, and are to be considered merely exemplary. Accordingly, one of ordinary skill in the art will recognize that various changes and modifications of the embodiments described herein can be made without departing from the scope of the present disclosure. Also, descriptions of well-known functions and constructions are omitted in the following description for clarity and conciseness. It should be noted that, in the embodiments of the present application, some existing solutions in the industry such as software, components, models, etc. may be mentioned, and they should be regarded as exemplary, only for illustrating the feasibility of implementing the technical solution of the present application, but it does not mean that the applicant has or must not use the solution.
It should be noted that, in the technical scheme of the application, the acquisition, transmission, storage, use and the like of the data all conform to the relevant regulations of national laws and regulations.
Based on the system architecture diagram shown in fig. 1, the embodiment of the present application provides a flow of a transaction event processing method, where the flow of the method may be executed by the terminal device 101 shown in fig. 1, may be executed by the server 102, or may be executed by the terminal device 101 and the server 102 interactively, as shown in fig. 2, and includes the following steps:
Step 201, splitting the processing procedure links for transaction events into a plurality of sub-processing links.
Specifically, different treatments are required to be performed according to functions aiming at a transaction event, and because a longer treatment flow link has complex functions, one treatment flow link is split into a plurality of sub-treatment links, and the sub-treatment links are independently managed.
Before the processing flow link of the transaction event is split into a plurality of sub-processing links, the processing flow link generates a processing identifier for each transaction event, and processing requests of the transaction event sent by all subsequent sub-processing links carry the processing identifier, wherein the processing identifier carried by the processing request is used for representing the type of the processing request.
Step 202, for each sub-processing link, executing the following steps 2021 to 2023 respectively:
step 2021, receiving a processing request for the transaction event sent by the last sub-processing link.
Specifically, if the current sub-processing link is the first sub-processing link in the processing flow links, an initial processing request of the transaction event corresponding to the processing flow link is received in the first sub-processing link. In the first sub-processing link, processing is carried out on the initial processing request of the transaction event to obtain a processing result. Then analyzing the operation needed to be executed by the next sub-processing link, generating a corresponding processing request, and sending the processing request to the next sub-processing link.
If the current sub-processing link is not the first sub-processing link in the processing flow link, in the current sub-processing link, a processing request for the transaction event, which is sent after the processing of the last sub-processing link is finished, is received.
When the processing request of the transaction event enters the current sub-processing link from the last sub-processing link, the current sub-processing link needs to record the processing request of the transaction event so that the current sub-processing link can acquire the processing operation needed to be executed on the processing request of the transaction event.
Step 2022, performing admission detection on the processing request of the transaction event, and obtaining an admission detection result.
Specifically, in the conventional transaction system, when processing a processing request of a transaction event, a data error or a parameter configuration error is found, the transaction system cannot recover a normal event processing flow, and an emergency version of the transaction system or a technical repair method is often required to be started, so that the application performs admission detection on the processing request of the transaction event in a plurality of sub-processing links, and then performs the execution method of processing.
In the embodiment of the application, in a plurality of sub-processing links, the operation of firstly admitting detection and then processing the processing request of the transaction event is carried out, compared with the operation of directly processing the processing request of the transaction event in the prior art, the abnormal access of the transaction event is caused after errors are found in the processing process, and the normal transaction event processing flow cannot be restored even if data is repaired.
Specifically, the conventional checking procedure is a fixed way of hard code writing, which results in random error causes, and once the processing request of the transaction event is found to be abnormal, normal processing is not performed by a preset means.
In view of the above, the method and the device respectively execute the following operations on a plurality of preset checkpoints of the processing request of the transaction event, wherein the checkpoints adopt a checking program corresponding to one checkpoint, the information of the processing request of the transaction event at one checkpoint is detected, the corresponding checkpoint result is obtained, and the admission detection result is determined based on the obtained checkpoint results.
Specifically, after the current sub-processing link records the processing request of the transaction event, accuracy and validity check needs to be performed on a plurality of preset check points of the processing request in the current sub-processing link. Each check point corresponds to a checking program, a processing identifier is configured in the checking program, and the processing identifiers configured in the checking programs corresponding to the check points are different. The processing identifier configured in the inspection program determines the inspection rule of the corresponding inspection point.
In the embodiment of the application, the processing identifiers in the current inspection program are flexibly configured, and the processing identifiers configured in the inspection programs corresponding to a plurality of inspection points are different, so that the error of the processing identifier in the inspection program corresponding to a specific inspection point can be rapidly positioned, the subsequent timely repair can be realized, and the transaction system can recover the normal processing flow of the transaction event.
And 2023, if the admission detection result is that the flow is interrupted, repairing the abnormal factors causing the flow interruption, and after repairing the abnormal factors, returning to execute the admission detection on the processing request of the transaction event to obtain the admission detection result.
In some embodiments, the admission detection result is a flow disruption if at least one of the plurality of checkpoint results is an exception result.
Specifically, when at least one check point result is an abnormal result, the processing request of the transaction event sent by the last sub-processing link is considered to be abnormal, so that the last sub-processing link can be deduced to be an abnormal processing link, and therefore, the current sub-processing link cannot process the processing request of the received transaction event, and the flow is interrupted.
In some embodiments, an inspection program corresponding to a data check point is adopted to respectively detect abnormality of a plurality of data items in a processing request of a transaction event, when at least one data item is abnormal, the check point result of the data check point is abnormal for data configuration, and when the plurality of data items are normal, the check point result of the data check point is normal for data configuration.
Specifically, when the data item is missing, the data item is blank, and the like, the data item is considered to be abnormal, namely the data configuration abnormality is detected as a check point result of the data check point. And if the data items are complete and accurate, considering the check point result of the data check point to be normal for data configuration.
In some embodiments, if the abnormality factor is an abnormality in data configuration, the previous sub-processing link is returned to modify the abnormal data item in the processing request of the transaction event.
Specifically, the last sub-processing link sends a processing request of the transaction event to the current sub-processing link, and an inspection program of the current sub-processing link inspects the processing request of the transaction event and generates an inspection point result. When the current sub-processing link judges that the abnormal factor of the processing request of the transaction event is data configuration abnormality according to the check point result, the processing request of the transaction event is returned to the last sub-processing link, the last sub-processing link modifies the data configuration abnormality in the processing request, and if the last sub-processing link cannot modify the data configuration abnormality of the processing request, forced modification is carried out manually.
In some embodiments, if the processing identifier configured in the inspection program corresponding to the parameter checkpoint is different from the processing identifier carried by the processing request, the checkpoint result of the parameter checkpoint is abnormal in parameter configuration, where the processing identifier carried by the processing request is used to characterize the type of the processing request, and if the processing identifier configured in the inspection program corresponding to the parameter checkpoint is the same as the processing identifier carried by the processing request, the checkpoint result of the parameter checkpoint is normal in parameter configuration.
Specifically, before the processing flow link is split into a plurality of sub-processing links, a processing identifier is generated for each transaction event, processing requests of the transaction events sent by all subsequent sub-processing links carry the processing identifier, and the processing identifier carried by the processing request is used for representing the type of the processing request. The processing identifier configured in the inspection program is used to indicate the type of processing request that the inspection program can inspect.
When the processing identifier carried by the processing request is different from the processing identifier configured in the checking program, the type of the processing request which can be checked by the checking program is not matched with the type of the processing request of the transaction event which is actually checked, therefore, the check point result of the parameter check point is judged to be abnormal in parameter configuration, and if the processing identifier carried by the processing request is the same as the processing identifier configured in the checking program, the checking result of the parameter check point is considered to be normal in parameter configuration.
In some embodiments, if the abnormality factor is an abnormality in parameter configuration, a parameter configuration link is returned, and a processing identifier configured in the inspection program corresponding to the parameter check point is modified.
Specifically, if the inspection result of the parameter check point in the sub-processing link is that the parameter configuration is abnormal, the processing request of the transaction event is put into a queue to be repaired with the abnormal parameter configuration, and the parameter configuration link is returned to modify the processing identifier configured in the inspection program.
The processing identifier configured in the inspection program is modified in the parameter configuration link, and the parameter configuration link can be modified by itself according to a preset parameter configuration rule or can be manually and forcedly modified.
In the embodiment of the application, by classifying the abnormal factors of the check point result, the abnormal check point result of the processing request can be positioned as two specific conditions of abnormal data configuration and abnormal parameter configuration, and a repairing mode can be preset correspondingly for the two conditions, so that the automatic repairing of flow interruption is realized, the manual loss is reduced, and the processing efficiency of a transaction system is improved.
If the check point result of the processing request of the transaction event is abnormal in data configuration, repairing the abnormal data configuration of the processing request of the transaction event, enabling the last sub-processing link to automatically initiate re-processing, and re-outputting the processing request of the transaction event. And after the current sub-processing link receives the processing request of the transaction event, re-performing admission detection on the processing request of the transaction event to obtain an admission detection result.
If the check point result of the processing request of the transaction event is abnormal in parameter configuration, modifying the processing identifier configured in the parameter checking program in the parameter configuration link, and re-performing admission detection on the processing request of the transaction event in the current sub-processing link after modification is finished to obtain a detection result.
In the embodiment of the application, the processing flow link of the transaction event is split into a plurality of sub-processing links for processing, and in each sub-processing link, the received processing request is subjected to admission detection, so that the abnormality of the processing request of the transaction event can be positioned in a specific sub-processing link, when the admission detection result is flow interruption, the abnormality factor causing the flow interruption can be repaired, and after the abnormality factor is repaired, the step of executing the processing request of the transaction event for admission detection is returned to obtain the admission detection result, thereby realizing the timely repair of the flow interruption, improving the fault tolerance, maintainability and robustness of the transaction system, and simultaneously modeling, standardizing and formatting the transaction system which is gradually complicated, improving the processing efficiency of the transaction system and enabling the transaction system to be suitable for popularization and multiplexing.
In some embodiments, the plurality of sub-processing elements are executed asynchronously.
Specifically, when processing a plurality of transaction events, after the last sub-processing link processes the received processing request of one transaction event among the sub-processing links, a new processing request is found to the next sub-processing link based on the processing result, at this time, the last sub-processing link cannot wait for the processing feedback of the next sub-processing link to the new processing request, but immediately starts to process the received processing request of the next transaction event, so that the processing efficiency of the transaction system is improved due to asynchronous processing among the sub-processing links.
In addition, the steps in a sub-processing link are also performed asynchronously.
In order to better explain the embodiment of the present application, a method for processing a transaction event provided by the embodiment of the present application is described below in conjunction with an anomaly checking scenario for processing a request, where a flow of the method is executed by a server shown in fig. 1, and includes the following steps, as shown in fig. 3:
Step 301, splitting the processing procedure links for the transaction event into a plurality of sub-processing links.
Step 302, for each sub-processing link, the following steps 3021 to 3028 are performed respectively.
Step 3021, receiving a processing request for a transaction event sent by a previous sub-processing link.
Step 3022, for a plurality of preset checkpoints, performing the following operations respectively, namely detecting the information of the processing request of the transaction event at the checkpoints by adopting a checking program corresponding to one checkpoint, and obtaining a corresponding checkpoint result.
In step 3023, if at least one check point result is an abnormal result, the flow is interrupted.
Step 3024, determining whether the abnormality factor causing the interruption of the flow is abnormal data configuration, if so, executing step 3025, otherwise, executing step 3026.
Step 3025, returning to the last sub-processing step, modifying the abnormal data item in the processing request of the transaction event, and returning to step 3022.
Step 3026, judging whether the abnormal factor causing the interruption of the flow is abnormal in parameter configuration, if so, executing step 3027, otherwise, executing step 3028.
Step 3027, returning to the parameter configuration link, modifying the processing identifier configured in the inspection program corresponding to the parameter inspection point, and returning to step 3022.
Step 3028, returning to the manual processing, and returning to step 3022.
In some embodiments, for each sub-processing link, referring to fig. 4, the current sub-processing link interacts with the previous sub-processing link and the next sub-processing link, where, taking the current sub-processing link as an example, the sub-processing link includes an access module, an inspection module, an anomaly determination module, a repair module, and an admission processing module, where each module included in the sub-processing link is executed asynchronously.
The access module receives a processing request of a transaction event sent by a previous sub-processing link and records information of the processing request, the inspection module comprises inspection programs, one inspection module can be provided with a plurality of inspection programs, each inspection program corresponds to one inspection point, when the inspection program detects each inspection point of the processing request of the transaction event and generates an inspection point result, the abnormality judgment module judges abnormal factors according to the inspection point result, if the inspection point result is normal, the abnormal factors are not generated, and the access processing module is enabled to conduct access processing on the processing request of the transaction event.
The method comprises the steps of adopting a checking program corresponding to a data check point to respectively detect abnormality of a plurality of data items in a processing request of a transaction event, configuring abnormality for data by a check point result of the data check point when at least one data item is abnormal, and configuring normal data by the check point result of the data check point when the plurality of data items are normal.
Specifically, for a parameter check point, if a processing identifier configured in an inspection program corresponding to the parameter check point is different from a processing identifier carried by a processing request, a check point result of the parameter check point is a parameter configuration exception, wherein the processing identifier carried by the processing request is used for representing the type of the processing request, and if the processing identifier configured by the inspection program corresponding to the parameter check point is the same as the processing identifier carried by the processing request, the check point result of the parameter check point is a parameter configuration normal.
If the check point result is abnormal, judging an abnormal factor, if the abnormal factor is abnormal in data configuration, sending a processing request of a current transaction event to a repairing module, returning the processing request of the transaction event to a last sub-processing link by the repairing module, and enabling the last sub-processing link to modify the data configuration abnormality in the processing request and automatically reinitiate the processing;
If the abnormal factor is abnormal in parameter configuration, the repair module returns the processing request of the transaction event to the parameter configuration module, the processing identifier configured in the inspection program corresponding to the parameter check point is modified, and the inspection program restarts the inspection of the processing request of the transaction event after the modification.
In the embodiment of the application, each sub-processing link carries out the execution mode of firstly admitting detection and then processing, thereby effectively improving the accuracy of processing requests of transaction events, carrying out admitting detection on the processing requests of the last link in each sub-processing link, positioning abnormal factors as data configuration abnormality and parameter configuration abnormality according to check point results, carrying out differential restoration, re-entering admitting detection on the processing requests, ensuring the accuracy of the processing requests of the transaction events, and simultaneously effectively improving the processing efficiency and consistency of a transaction system.
For example, referring to fig. 5, a transaction event enters a large flow processing link, the flow processing link generates a processing identifier a for the transaction event, where the processing identifier a represents a type of processing request of the transaction event, and makes processing requests of the transaction event sent by any subsequent sub-processing link carry the processing identifier a, where the flow processing link includes a plurality of sub-processing links.
Assuming that an error exists in a processing request of a transaction event sent by a first sub-processing link to a second sub-processing link, namely, an error exists in a processing result of the transaction event in the first sub-processing link, in the second sub-processing link, a checking program checks that the processing request has data configuration abnormality, and the processing request of the transaction event is returned to the first sub-processing link, so that the first sub-processing link modifies the data configuration abnormality of the processing request and initiates the processing request of the transaction event to the second sub-processing link again.
If the processing identifier in the checking program is mismatched as B in the third sub-processing link, when the second sub-processing link sends a processing request of a transaction event to the third sub-processing link, the processing identifier B of the checking program configured with exception is not matched with the processing identifier a carried by the processing request of the transaction event, which indicates that the type of the processing request which can be checked by the checking program in the third sub-processing link is not matched with the type of the processing request of the transaction event actually checked, so that the flow is interrupted, and therefore, the exception factor of the flow interruption at this time can be positioned as parameter configuration exception according to the check point result. In the parameter configuration link, modifying the parameters configured in the parameter checking program of the third link according to the parameter configuration rule, and re-performing admission detection on the processing request of the transaction event after modification is completed to obtain a detection result.
In the embodiment of the application, the abnormal factors are positioned as the data configuration abnormality and the parameter configuration abnormality according to the check point result, the differential repair is carried out, the processing request reenters the admission detection, the accuracy of the processing request of the transaction event is ensured, the processing efficiency and the continuity of the transaction system are effectively improved, and the breakpoint continuous connection of the transaction event is realized.
Based on the same technical concept, an embodiment of the present application provides a schematic structural diagram of transaction event processing, as shown in fig. 6, the transaction event processing device 600 includes:
the decomposition module 601 is configured to divide a processing procedure link for a transaction event into a plurality of sub-processing links;
the processing module 602 is configured to, for each sub-processing link, respectively receive a processing request for the transaction event sent by a previous sub-processing link;
And after the abnormal factors are repaired, returning to execute the step of carrying out admission detection on the processing request of the transaction event to obtain an admission detection result.
Optionally, the processing module 602 is specifically configured to:
Adopting a checking program corresponding to one check point to detect the information of the transaction event processing request at the one check point and obtaining a corresponding check point result;
and determining the admission detection result based on the obtained multiple check point results.
Optionally, the processing module 602 is specifically configured to:
And if at least one check point result in the plurality of check point results is an abnormal result, the admission detection result is a flow interruption.
Optionally, the processing module 602 is specifically configured to:
Adopting a checking program corresponding to the data check point to respectively detect abnormality of a plurality of data items in the processing request of the transaction event;
When at least one data item is abnormal, configuring an abnormality for the data according to a check point result of the data check point;
When the plurality of data items are all normal, then the checkpointed result of the data checkpoint is normal for the data configuration.
Optionally, the processing module 602 is specifically configured to:
If the processing identifier configured in the inspection program corresponding to the parameter check point is different from the processing identifier carried by the processing request, the check point result of the parameter check point is abnormal parameter configuration, wherein the processing identifier carried by the processing request is used for representing the type of the processing request;
And if the processing identifier of the inspection program configuration corresponding to the parameter check point is the same as the processing identifier carried by the processing request, the check point result of the parameter check point is the parameter configuration abnormality.
Optionally, the processing module 602 is specifically configured to:
and returning to a parameter configuration link, and modifying the processing identifier configured in the inspection program corresponding to the parameter check point.
Optionally, the plurality of sub-processing elements are asynchronously processed.
In the embodiment of the application, the admission detection is carried out on the processing request of the last link in each sub-processing link, thereby effectively improving the accuracy of the processing request of the transaction event, positioning the abnormality as one data configuration field and one parameter configuration abnormality, carrying out differential repair and effectively improving the processing efficiency and consistency of the transaction system.
In addition, the processing flow link of the transaction event is divided into a plurality of sub links, processing requests aiming at the transaction event are processed separately, the fault tolerance of the transaction system is improved, the transaction system can rapidly position errors and rapidly repair the errors, the maintainability and the robustness of the transaction system are improved, and meanwhile, the increasingly complex transaction system is patterned, normalized and formatted, so that the transaction system is suitable for popularization and reuse.
Based on the same technical concept, the embodiment of the present application provides a computer device, which may be a server shown in fig. 1, as shown in fig. 7, and includes at least one processor 701, and a memory 702 connected to the at least one processor, where a specific link medium between the processor 701 and the memory 702 is not limited in the embodiment of the present application, and in fig. 7, the processor 701 and the memory 702 are connected by a bus, for example. The buses may be divided into address buses, data buses, control buses, etc.
In the embodiment of the present application, the memory 702 stores instructions executed by the at least one processor 701, and the at least one processor 701 may execute the steps of the transaction event processing method described above by executing the instructions stored in the memory 702.
Where the processor 701 is the control center of a computer device, various interfaces and lines may be utilized to connect various portions of the computer device, through execution or execution of instructions stored in the memory 702 and invocation of data stored in the memory 702, to effect transaction event processing. Alternatively, the processor 701 may include one or more processing modules, and the processor 701 may integrate an application processor and a modem processor, wherein the application processor primarily processes operating systems, user interfaces, application programs, and the like, and the modem processor primarily processes wireless communications. It will be appreciated that the modem processor described above may not be integrated into the processor 701. In some embodiments, processor 701 and memory 702 may be implemented on the same chip, or they may be implemented separately on separate chips in some embodiments.
The processor 701 may be a general purpose processor such as a Central Processing Unit (CPU), digital signal processor, application SPECIFIC INTEGRATED Circuit (ASIC), field programmable gate array or other programmable logic device, discrete gate or transistor logic, discrete hardware components, or a combination thereof, that may implement or perform the methods, steps, and logic blocks disclosed in embodiments of the application. The general purpose processor may be a microprocessor or any conventional processor or the like. The steps of a method disclosed in connection with the embodiments of the present application may be embodied directly in a hardware processor for execution, or in a combination of hardware and software modules in the processor for execution.
The memory 702 is a non-volatile computer-readable storage medium that can be used to store non-volatile software programs, non-volatile computer-executable programs, and modules. The Memory 702 may include at least one type of storage medium, and may include, for example, flash Memory, hard disk, multimedia card, card Memory, random access Memory (Random Access Memory, RAM), static random access Memory (Static Random Access Memory, SRAM), programmable Read-Only Memory (Programmable Read Only Memory, PROM), read-Only Memory (ROM), charged erasable programmable Read-Only Memory (ELECTRICALLY ERASABLE PROGRAMMABLE READ-Only Memory, EEPROM), magnetic Memory, magnetic disk, optical disk, and the like. Memory 702 is any other medium that can be used to carry or store desired program code in the form of instructions or data structures and that can be accessed by a computer device, but is not limited to such. The memory 702 in embodiments of the present application may also be circuitry or any other device capable of performing storage functions for storing program instructions and/or data.
Based on the same inventive concept, an embodiment of the present application provides a computer-readable storage medium storing a computer program executable by a computer device, which when run on the computer device, causes the computer device to perform the steps of the transaction event processing method described above.
Based on the same inventive concept, an embodiment of the present application provides a computer program product comprising a computer program stored on a computer readable storage medium, the computer program comprising program instructions which, when executed by a computer device, cause the computer device to perform the steps of the transaction event processing method described above.
It will be appreciated by those skilled in the art that embodiments of the present application may be provided as a method, system, or computer program product. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, and the like) having computer-usable program code embodied therein.
The present application is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems) and computer program products according to the application. It will be understood that each flow and/or block of the flowchart illustrations and/or block diagrams, and combinations of flows and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including instruction means which implement the function specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be loaded onto a computer or other programmable data processing apparatus to cause a series of operational steps to be performed on the computer or other programmable apparatus to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide steps for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
It will be apparent to those skilled in the art that various modifications and variations can be made to the present application without departing from the spirit or scope of the application. Thus, it is intended that the present application also include such modifications and alterations insofar as they come within the scope of the appended claims or the equivalents thereof.

Claims (12)

1.一种交易事件处理方法,其特征在于,包括:1. A transaction event processing method, comprising: 将针对交易事件的处理流程环节,拆分为多个子处理环节;Split the transaction event processing process into multiple sub-processing steps; 针对每个子处理环节,分别执行以下操作:For each sub-processing step, perform the following operations: 接收上一个子处理环节发送的针对所述交易事件的处理请求;Receiving a processing request for the transaction event sent by a previous sub-processing link; 对所述交易事件的处理请求进行准入检测,获得准入检测结果;Performing an access detection on the processing request of the transaction event to obtain an access detection result; 若所述准入检测结果为流程中断,则对导致所述流程中断的异常因素进行修复;并在所述异常因素修复后,返回执行对所述交易事件的处理请求进行准入检测,获得准入检测结果的步骤。If the admission detection result is a process interruption, the abnormal factors causing the process interruption are repaired; and after the abnormal factors are repaired, the process returns to the step of performing an admission detection on the processing request of the transaction event to obtain the admission detection result. 2.如权利要求1所述的方法,其特征在于,所述对所述交易事件的处理请求进行准入检测,获得准入检测结果包括:2. The method according to claim 1, wherein the performing an access detection on the processing request of the transaction event and obtaining the access detection result comprises: 针对预设的多个检查点,分别执行以下操作:采用一个检查点对应的检查程序,对所述交易事件的处理请求在所述一个检查点的信息进行检测,获得相应的检查点结果;For the preset multiple checkpoints, the following operations are respectively performed: using a check program corresponding to a checkpoint, detecting the information of the processing request of the transaction event at the checkpoint, and obtaining a corresponding checkpoint result; 基于获得的多个检查点结果,确定所述准入检测结果。The admission detection result is determined based on the obtained multiple checkpoint results. 3.如权利要求2所述的方法,其特征在于,所述基于获得的多个检查点结果,确定所述准入检测结果,包括:3. The method according to claim 2, wherein determining the admission detection result based on the obtained multiple checkpoint results comprises: 若所述多个检查点结果中存在至少一个检查点结果为异常结果,则所述准入检测结果为流程中断。If at least one of the multiple checkpoint results is an abnormal result, the admission detection result is a process interruption. 4.如权利要求2所述的方法,其特征在于,所述若一个检查点为数据检查点;所述采用一个检查点对应的检查程序,对所述交易事件的处理请求在所述一个检查点的信息进行检测,获得相应的检查点结果,包括:4. The method according to claim 2, wherein if a checkpoint is a data checkpoint; and using a check program corresponding to a checkpoint to detect the information of the processing request of the transaction event at the checkpoint to obtain a corresponding checkpoint result, comprises: 采用所述数据检查点对应的检查程序,对所述交易事件的处理请求中的多个数据项分别进行异常检测;Using the check program corresponding to the data checkpoint, respectively perform anomaly detection on multiple data items in the processing request of the transaction event; 当存在至少一个数据项异常时,则所述数据检查点的检查点结果为数据配置异常;When there is at least one data item abnormality, the checkpoint result of the data checkpoint is a data configuration abnormality; 当所述多个数据项均正常时,则所述数据检查点的检查点结果为数据配置正常。When the multiple data items are all normal, the checkpoint result of the data checkpoint is that the data configuration is normal. 5.如权利要求4所述的方法,其特征在于,所述异常因素为数据配置异常;所述对导致所述流程中断的异常因素进行修复,包括:5. The method according to claim 4, wherein the abnormal factor is a data configuration abnormality; and the repairing of the abnormal factor causing the process interruption comprises: 返回所述上一个子处理环节,对所述交易事件的处理请求中异常的数据项进行修改。Return to the previous sub-processing link and modify the abnormal data item in the processing request of the transaction event. 6.如权利要求2所述的方法,其特征在于,所述一个检查点的参数检查点;所述采用一个检查点对应的检查程序,对所述交易事件的处理请求在所述一个检查点的信息进行检测,获得相应的检查点结果,包括:6. The method according to claim 2, wherein the parameter checkpoint of the checkpoint; the use of a check program corresponding to the checkpoint to detect the information of the processing request of the transaction event at the checkpoint to obtain the corresponding checkpoint result, comprises: 若所述参数检查点对应的检查程序中配置的处理标识,与所述处理请求携带的处理标识不同,则所述参数检查点的检查点结果为参数配置异常,其中,所述处理请求携带的处理标识用于表征所述处理请求的类型;If the processing identifier configured in the check program corresponding to the parameter checkpoint is different from the processing identifier carried by the processing request, the checkpoint result of the parameter checkpoint is a parameter configuration exception, wherein the processing identifier carried by the processing request is used to characterize the type of the processing request; 若所述参数检查点对应的检查程序配置的处理标识,与所述处理请求携带的处理标识相同,则所述参数检查点的检查点结果为参数配置正常。If the processing identifier of the check program configuration corresponding to the parameter checkpoint is the same as the processing identifier carried in the processing request, the checkpoint result of the parameter checkpoint is that the parameter configuration is normal. 7.如权利要求6所述的方法,其特征在于,所述异常因素为参数配置异常;所述对导致所述流程中断的异常因素进行修复,包括:7. The method according to claim 6, wherein the abnormal factor is a parameter configuration abnormality; and the repairing of the abnormal factor causing the process interruption comprises: 返回参数配置环节,对所述参数检查点对应的检查程序中配置的处理标识进行修改。Return to the parameter configuration link and modify the processing identifier configured in the inspection program corresponding to the parameter checkpoint. 8.如权利要求1至7任一所述的方法,其特征在于,所述多个子处理环节是异步执行的。8. The method according to any one of claims 1 to 7, characterized in that the multiple sub-processing links are executed asynchronously. 9.一种交易事件处理的装置,其特征在于,包括:9. A device for processing transaction events, comprising: 分解模块,用于将针对交易事件的处理流程环节,拆分为多个子处理环节;A decomposition module is used to split the processing flow of transaction events into multiple sub-processing links; 处理模块,用于针对每个子处理环节,分别执行以下操作:接收上一个子处理环节发送的针对所述交易事件的处理请求;对所述交易事件的处理请求进行准入检测,获得准入检测结果;The processing module is used to perform the following operations for each sub-processing link: receiving a processing request for the transaction event sent by the previous sub-processing link; performing an admission detection on the processing request for the transaction event to obtain an admission detection result; 若所述准入检测结果为流程中断,则对导致所述流程中断的异常因素进行修复;并在所述异常因素修复后,返回执行对所述交易事件的处理请求进行准入检测,获得准入检测结果的步骤。If the admission detection result is a process interruption, the abnormal factors causing the process interruption are repaired; and after the abnormal factors are repaired, the process returns to the step of performing an admission detection on the processing request of the transaction event to obtain the admission detection result. 10.一种计算机设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,其特征在于,所述处理器执行所述程序时实现权利要求1~8任一所述方法的步骤。10. A computer device comprising a memory, a processor and a computer program stored in the memory and executable on the processor, wherein the processor implements the steps of any one of the methods of claims 1 to 8 when executing the program. 11.一种计算机可读存储介质,其特征在于,其存储有可由计算机设备执行的计算机程序,当所述程序在计算机设备上运行时,使得所述计算机设备执行权利要求1~8任一所述方法的步骤。11. A computer-readable storage medium, characterized in that it stores a computer program executable by a computer device, and when the program is run on the computer device, the computer device executes the steps of any one of the methods of claims 1 to 8. 12.一种计算机程序产品,其特征在于,所述计算机程序产品包括存储在计算机可读存储介质上的计算机程序,所述计算机程序包括程序指令,当所述程序指令被计算机设备执行时,使所述计算机设备执行如权利要求1~8任一项所述方法的步骤。12. A computer program product, characterized in that the computer program product comprises a computer program stored on a computer-readable storage medium, the computer program comprises program instructions, and when the program instructions are executed by a computer device, the computer device executes the steps of the method as claimed in any one of claims 1 to 8.
CN202411518767.3A 2024-10-29 2024-10-29 A transaction event processing method, device, equipment and storage medium Pending CN119273473A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202411518767.3A CN119273473A (en) 2024-10-29 2024-10-29 A transaction event processing method, device, equipment and storage medium

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202411518767.3A CN119273473A (en) 2024-10-29 2024-10-29 A transaction event processing method, device, equipment and storage medium

Publications (1)

Publication Number Publication Date
CN119273473A true CN119273473A (en) 2025-01-07

Family

ID=94110861

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202411518767.3A Pending CN119273473A (en) 2024-10-29 2024-10-29 A transaction event processing method, device, equipment and storage medium

Country Status (1)

Country Link
CN (1) CN119273473A (en)

Similar Documents

Publication Publication Date Title
CN112099843B (en) Code hosting platform management methods, devices, computer equipment and storage media
CN114201408A (en) Regression testing method, device, computer equipment and storage medium
CN114218180B (en) A method and device for adjusting and printing log levels of a running system
CN110063042A (en) A kind of response method and its terminal of database failure
CN112632174B (en) A method, device and system for data verification
CN110727575B (en) Information processing method, system, device and storage medium
CN112100070A (en) Version defect detection method and device, server and storage medium
CN115905177B (en) Data migration testing methods, apparatus, computer equipment, and readable storage media
CN110716922A (en) Incep-based database operation and maintenance method and device, computer equipment and storage medium
CN111444101A (en) Method and device for automatically creating product test defects
CN111949518A (en) Method, system, terminal and storage medium for generating fault detection script
CN114661423A (en) Cluster configuration detection method and device, computer equipment and storage medium
CN117499412A (en) Cluster optimization processing method based on high-availability link and related equipment thereof
CN115599401A (en) Publishing method, device, equipment and medium of custom model
CN112363933A (en) Automatic verification method and device for word paragraph table, computer equipment and storage medium
CN111597101B (en) SDK access state detection method, computer equipment and computer readable storage medium
CN116431522A (en) A low-code object storage gateway automated testing method and system
CN112667506B (en) Interface testing method and related device
CN111475400B (en) Verification method of service platform and related equipment
CN119273473A (en) A transaction event processing method, device, equipment and storage medium
CN114356344B (en) Application deployment method and device, electronic equipment and storage medium
CN112650679B (en) Test verification method, device and computer system
CN114817167A (en) Merging data processing method and device
CN114003500A (en) Software testing method and device
CN120353714B (en) Data verification method, device, electronic equipment, medium and program product

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