CN-121979859-A - Service processing method, device, equipment, medium and product

CN121979859ACN 121979859 ACN121979859 ACN 121979859ACN-121979859-A

Abstract

The invention discloses a service processing method, a device, equipment, a medium and a product. The business processing method comprises the steps of identifying parallelizable logic units in the execution process of serially-connected execution logic in a business function, enabling a main flow of the business function to start parallel branches without depending on immediate execution results of the parallelizable logic units, executing the parallelizable logic units under the condition that the parallelizable logic units are identified, correspondingly storing immediate execution results of the parallelizable logic units and source data identifications corresponding to the immediate execution results into a pre-established temporary table, enabling the parallel branches to execute in parallel with the main flow of the business function, and backfilling immediate execution results in the temporary table into a source business table for storing the execution results of the main flow based on source data identification fields under the condition that the execution of the main flow of the parallel branches and the business function is completed. The technical scheme of the embodiment of the invention can improve the service processing efficiency.

Inventors

LI ZEYUN
XU LEI
YANG CAI
ZHU JINGXUAN

Assignees

中国工商银行股份有限公司

Dates

Publication Date: 20260505
Application Date: 20260116

Claims (11)

1. A method for processing a service, comprising: The main flow of the business function does not depend on the instant execution result of the parallelizable logic units; Under the condition that a parallelizable logic unit is identified, starting a parallel branch, executing the parallelizable logic unit, and correspondingly storing an instant execution result of the parallelizable logic unit and a source data identifier corresponding to the instant execution result into a temporary table established in advance; and under the condition that the main flow execution of the parallel branch and service function is completed, backfilling the instant execution result in the temporary table into a source service table for storing the main flow execution result based on the source data identification field.
2. The method of claim 1, wherein initiating a parallel branch, executing the parallelizable logic unit, comprises: under the condition that the service function is triggered at fixed time, starting parallel branches through a database background task, and executing the parallelizable logic unit; And under the condition that the service function is triggered by an instruction, starting parallel branches by using a thread or asynchronous calling mode, and executing the parallelizable logic unit.
3. The method of claim 1, wherein backfilling immediate execution results in the temporary table into a source traffic table for storing primary flow execution results based on the source data identification field, comprising: Based on the source data identification field, the instant execution result in the temporary table is assigned and backfilled into a source service table for storing the main flow execution result through association updating or merging operation.
4. The method according to claim 1, wherein, in case the main flow execution of the parallel branch and business function is completed, based on the source data identification field, backfilling the immediate execution result in the temporary table into a source business table for storing the main flow execution result, further comprising: Acquiring the number of data entries in the temporary table and the number of data entries generated by the main flow, and judging whether the number of data entries reaches the expected number or not; and under the condition that the number of the data entries reaches the expected number, determining that the parallel branches and the main flow of the service function are executed and completed.
5. The method of claim 1, wherein, in the case where the business function is a check-in function, identifying the parallelizable logic units during execution of the serially executed logic in the business function comprises: In the execution process of serial execution logic in the accounting and accounting function, before each logic unit is executed, identifying whether the logic unit belongs to a summary processing logic unit or not; And the main accounting flow of the accounting function does not depend on the instant execution result of the abstract processing logic unit.
6. The method according to claim 5, wherein, in case a parallelizable logic unit is identified, starting a parallel branch, executing the parallelizable logic unit, and storing an immediate execution result of the parallelizable logic unit and a source data identification corresponding to the immediate execution result in a pre-established temporary table, comprising: under the condition that the abstract processing logic unit is identified, starting parallel branches, extracting at least one item to be filled from a preset abstract template, and searching service data associated with the item to be filled from a database; filling the business data into corresponding items to be filled in the abstract template to obtain abstract information as an immediate execution result; and correspondingly storing the abstract information and the source data identification corresponding to the abstract information into a temporary table established in advance.
7. The method of claim 1, further comprising, prior to identifying the parallelizable logic units during execution of the serial execution logic in the business function: Creating a temporary table in a database, wherein the temporary table comprises a source data identification field serving as a main key field and an execution result field for storing an instant execution result; And the main key field of the temporary table is consistent with the main key field of the source service table.
8. A service processing apparatus, comprising: the system comprises a parallel logic unit identification module, a parallel logic unit processing module and a parallel logic unit processing module, wherein the parallel logic unit identification module is used for identifying a parallelizable logic unit in the execution process of serially-connected execution logic in a service function; The parallel execution module is used for starting parallel branches under the condition that the parallelizable logic unit is identified, executing the parallelizable logic unit, and correspondingly storing an instant execution result of the parallelizable logic unit and a source data identifier corresponding to the instant execution result into a temporary table established in advance; And the result backfilling module is used for backfilling the instant execution result in the temporary table into a source service table for storing the main flow execution result based on the source data identification field under the condition that the main flow execution of the parallel branch and service function is completed.
9. An electronic device, the electronic device comprising: at least one processor, and A memory communicatively coupled to the at least one processor, wherein, The memory stores a computer program executable by the at least one processor to enable the at least one processor to perform the traffic processing method of any one of claims 1-7.
10. A computer-readable storage medium, wherein the computer-readable storage medium stores computer instructions, the computer instructions for causing a processor to perform the business processing method of any of claims 1-7 when executed.
11. A computer program product, characterized in that the computer program product comprises a computer program which, when executed by a processor, implements the service processing method according to any of claims 1-7.

Description

Service processing method, device, equipment, medium and product Technical Field The present invention relates to the technical field of financial science and technology, and in particular, to a business processing method, apparatus, device, medium and product. Background With the deep development of information technology application innovation industry, the migration of key business systems from traditional business databases to new databases has become a necessary trend. In such migration work, ensuring performance of core service functions in a novel database environment is one of the key challenges in determining whether migration is successful or not. Significant performance degradation often occurs after migration in core functions involving complex business logic and high frequency data processing. Such functionality typically has the typical serial processing feature of executing multiple logic units in sequence in one main workflow. Compared with the traditional commercial database, the internal execution efficiency of the novel database is generally different to a certain extent, and the single-cycle execution time delay difference is possibly tiny, but under the scene of high-frequency and large-scale cycle execution of functions such as core account entry and the like, the tiny efficiency differences are accumulated and amplified in a large quantity, and finally the whole processing time is unacceptably greatly increased, so that the business bottleneck is formed. Therefore, how to ensure the data processing performance after the database is migrated is important to ensure the service execution efficiency. Disclosure of Invention The invention provides a service processing method, a device, equipment, a medium and a product, which are used for solving the problem of service performance bottleneck caused by database migration. According to an aspect of the present invention, there is provided a service processing method, including: The main flow of the business function does not depend on the instant execution result of the parallelizable logic units; Under the condition that a parallelizable logic unit is identified, starting a parallel branch, executing the parallelizable logic unit, and correspondingly storing an instant execution result of the parallelizable logic unit and a source data identifier corresponding to the instant execution result into a temporary table established in advance; and under the condition that the main flow execution of the parallel branch and service function is completed, backfilling the instant execution result in the temporary table into a source service table for storing the main flow execution result based on the source data identification field. According to another aspect of the present invention, there is provided a service processing apparatus including: the system comprises a parallel logic unit identification module, a parallel logic unit processing module and a parallel logic unit processing module, wherein the parallel logic unit identification module is used for identifying a parallelizable logic unit in the execution process of serially-connected execution logic in a service function; The parallel execution module is used for starting parallel branches under the condition that the parallelizable logic unit is identified, executing the parallelizable logic unit, and correspondingly storing an instant execution result of the parallelizable logic unit and a source data identifier corresponding to the instant execution result into a temporary table established in advance; And the result backfilling module is used for backfilling the instant execution result in the temporary table into a source service table for storing the main flow execution result based on the source data identification field under the condition that the main flow execution of the parallel branch and service function is completed. According to another aspect of the present invention, there is provided an electronic apparatus including: at least one processor, and A memory communicatively coupled to the at least one processor, wherein, The memory stores a computer program executable by the at least one processor to enable the at least one processor to perform the traffic processing method according to any one of the embodiments of the present invention. According to another aspect of the present invention, there is provided a computer readable storage medium storing computer instructions for causing a processor to execute a service processing method according to any embodiment of the present invention. According to another aspect of the present invention, there is provided a computer program product comprising a computer program which, when executed by a processor, implements the business processing method of any of the embodiments of the present disclosure. According to the technical scheme, in the execution process of the serial execution logic in the service function, the parallelizabl