CN110795171B

CN110795171B - Service data processing method, device, computer equipment and storage medium

Info

Publication number: CN110795171B
Application number: CN201910881775.7A
Authority: CN
Inventors: 付慧颖
Original assignee: Ping An Bank Co Ltd
Current assignee: Ping An Bank Co Ltd
Priority date: 2019-09-18
Filing date: 2019-09-18
Publication date: 2023-08-04
Anticipated expiration: 2039-09-18
Also published as: CN110795171A

Abstract

The present invention relates to the field of business process optimization for operation and maintenance of a base frame, and in particular, to a business data processing method, a device, a computer device, and a storage medium. The method comprises the following steps: receiving a service access application, and searching a corresponding service account; identifying a service type corresponding to the service access application, wherein the service type comprises a resource transfer-in service and a resource transfer-out service; and obtaining a corresponding service processing result according to the service type. According to the business data processing method, the hot-spot account in the business account is identified, the resource variation in the account is recorded according to the scene, when the scene is shifted into for the resource, the batch asynchronous processing is directly carried out, when the scene is shifted out for the resource, the resource variation of the account is registered, the corresponding variation result is obtained, the corresponding hot-spot account business data is not needed to be carried out through splitting the account, and the complexity of business data processing is not increased.

Description

Service data processing method, device, computer equipment and storage medium

Technical Field

The present invention relates to the field of computer technologies, and in particular, to a service data processing method, a device, a computer device, and a storage medium.

Background

The hot spot account refers to an account for performing resource transfer operation at high frequency, and is divided into two scenes of a hot spot account for transferring resources and a hot spot account for transferring resources according to the resource transfer direction of the operation. Frequent resource volume changes can cause the same account record to be repeatedly operated, so that resource contention and performance pressure on a database are generated, and further the transaction timeliness, the system throughput and the transaction success rate are affected.

Under the condition of hot spots, the verification code can be prompted to be input when the abnormal high-frequency operation of the client is identified so as to reduce the operation frequency, the steps of caching data and splitting business are increased, the transaction operation content of the database is further reduced so as to reduce the time length of locking the table, and the synchronous data operation is converted into asynchronous data operation, batch data operation and other modes so as to improve the performance.

However, in a service scenario with a particularly large concurrency, the processing complexity of the above method is too high, and the processing efficiency is affected.

Disclosure of Invention

Based on this, there is a need to provide a simple business data processing method, device, computer equipment and storage medium, which solve the problem of high business processing complexity in the existing business scenario with large concurrency.

A business data processing method, the method comprising:

Receiving a service access application submitted by a terminal, and searching a corresponding service account;

identifying a service type corresponding to the service access application;

when the service type is determined to be a resource transfer service and the account attribute of the service account is a hot spot account, registering resource variation information of the service account through an asynchronous batch processing mode, triggering a batch processing process of resource variation of the service account, acquiring a first processing result corresponding to the resource variation of the service account, and feeding back the first processing result to the terminal;

or when the service type is determined to be the resource transfer-out service and the account attribute of the service account is a hot spot account, acquiring resource variation information corresponding to the service access application, registering the resource variation of the service account according to the existing resource quantity of the service account and the resource variation information, acquiring a second processing result corresponding to the resource variation of the service account, and feeding back the second processing result to the terminal.

In one embodiment, the first processing result includes current resource information and a historical resource variation information table, and when determining that the service type is a resource transfer service and the account attribute of the service account is a hot account, registering the resource variation of the service account through an asynchronous batch processing mode, triggering a batch processing process of the resource variation of the service account, and obtaining a first processing result corresponding to the resource variation of the service account, and feeding back the first processing result to the terminal includes:

When the service type is a resource transfer service and the account attribute of the service account is a hot spot account, acquiring the current service processing flow;

triggering a batch processing process of resource variation of the service account according to the current service processing flow;

when a batch processing process of resource variation of the service account is triggered, acquiring an application record of the service account in a preset timing time;

acquiring resource change information corresponding to each application record, and sequentially registering the resource change information to the historical resource change information table according to the time sequence of the application records;

acquiring current resource information according to the resource variation information of the last time in the preset timing time;

and storing and feeding back the current resource information and the historical resource change information table to the terminal.

In one embodiment, the process of triggering the resource variation of the service account according to the current service processing flow includes:

when the current business processing flow is lower than a preset flow threshold, the batch resource processing process is triggered by the timing trigger, and when the current business processing flow is higher than or equal to the preset flow threshold, the batch resource processing process is triggered by the advanced queue.

In one embodiment, the second processing result includes current resource information and a historical resource variation information table, and when determining that the service type is a resource transfer service and the account attribute of the service account is a hot account, registering the resource variation information of the service account through an asynchronous batch processing mode, triggering a batch processing process of resource variation of the service account, and obtaining a first processing result corresponding to the resource variation of the service account, where feeding back the first processing result to the terminal includes:

when the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account, acquiring an application record of the service account in a preset timing time;

sequentially registering resource variation information of the service account according to the time sequence of the application records, and judging whether the account resource remaining amount of the service account is greater than or equal to zero after registering the current resource variation information;

when the account resource surplus of the service account is greater than or equal to zero, maintaining the operation of sequentially registering the resource variation of the service account according to the application records, acquiring the application records of the service account in preset timing time, acquiring resource variation information corresponding to each application record, sequentially registering the resource variation information to the historical resource variation information table according to the time sequence of the application records, acquiring current resource information according to the resource variation information, and storing and feeding back the current resource information and the historical resource variation information table to the terminal;

And stopping registering the resource variation information of the current service account when the account resource remaining amount of the service account is smaller than zero, and feeding back failure information to the terminal.

In one embodiment, the second processing result includes current resource information and a historical resource variation information table, when it is determined that the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account, acquiring resource variation information corresponding to the service access application, registering, according to the existing resource amount of the service account and the resource variation information, resource variation of the service account, acquiring a second processing result corresponding to the resource variation of the service account, and feeding back the second processing result to the terminal includes:

splitting each application record into a first resource variation record and a second resource variation record according to the time sequence, wherein the first resource variation record is used for recording the resource variation amount corresponding to the current application record, the second resource variation record is used for recording the resource remaining amount of the business account corresponding to the current application record, and the second resource variation record is determined according to the second resource variation record of the previous application record corresponding to the current application record in the time sequence;

Judging whether the account resource remaining amount of the business account is larger than or equal to zero in the second resource change record corresponding to the current application record;

when the account resource surplus of the service account is greater than or equal to zero, maintaining the operation of splitting each application record into a first resource change record and a second resource change record according to time sequence, after a preset time, acquiring a historical resource change information table according to the first resource change record and the second resource change record, acquiring current resource information according to the second resource change record, and storing and feeding back the current resource information and the historical resource change information table to the terminal;

and stopping registering the resource variation information of the current service account when the account resource of the service account is smaller than zero, and feeding back failure information to the terminal.

In one embodiment, the identifying the service type corresponding to the service access application includes:

when the service account does not belong to the hot spot account, registering the resource variation of the service account in a synchronous mode to obtain a synchronous processing result, and feeding back the synchronous processing result to the terminal.

In one embodiment, the identifying the service type corresponding to the service access application includes, before the resource transfer-in service and the resource transfer-out service,:

acquiring current account flow of each service account;

and changing the account attribute of the corresponding service account according to the account flow.

A traffic data processing apparatus, the apparatus comprising:

the application receiving module is used for receiving a service access application submitted by the terminal and searching a corresponding service account;

the service identification module is used for identifying the service type corresponding to the service access application;

the first scene processing module is used for registering resource variation information of the service account through an asynchronous batch processing mode when the service type is determined to be a resource transfer service and the account attribute of the service account is a hot spot account, triggering a batch processing process of resource variation of the service account, acquiring a first processing result corresponding to the resource variation of the service account, and feeding back the first processing result to the terminal;

and the second scene processing module is used for acquiring resource variation information corresponding to the service access application when the service type is determined to be a resource transfer-out service and the account attribute of the service account is a hot spot account, registering the resource variation of the service account according to the existing resource quantity of the service account and the resource variation information, acquiring a second processing result corresponding to the resource variation of the service account, and feeding back the second processing result to the terminal.

A computer device comprising a memory storing a computer program and a processor which when executing the computer program performs the steps of:

identifying a service type corresponding to the service access application;

A computer readable storage medium having stored thereon a computer program which when executed by a processor performs the steps of:

identifying a service type corresponding to the service access application;

The service data processing method, the device, the computer equipment and the storage medium firstly receive a service access application submitted by a terminal and search a corresponding service account; identifying a service type corresponding to the service access application; when the service type is determined to be a resource transfer service and the account attribute of the service account is a hot account, registering resource variation information of the service account through an asynchronous batch processing mode, triggering a batch processing process of resource variation of the service account, acquiring a first processing result corresponding to the resource variation of the service account, and feeding back the first processing result to the terminal; or when the service type is determined to be the resource transfer-out service and the account attribute of the service account is the hot spot account, acquiring the resource variation information corresponding to the service access application, registering the resource variation of the service account according to the existing resource quantity of the service account and the resource variation information, acquiring a second processing result corresponding to the resource variation of the service account, and feeding back the second processing result to the terminal. According to the business data processing method, the hot-spot account in the business account is identified, the resource variation in the account is recorded according to the scene, when the scene is shifted into for the resource, the batch asynchronous processing is directly carried out, when the scene is shifted out for the resource, the resource variation of the account is registered, the corresponding variation result is obtained, the corresponding hot-spot account business data is not needed to be carried out through splitting the account, and the complexity of business data processing is not increased.

Drawings

FIG. 1 is an application environment diagram of a business data processing method in one embodiment;

FIG. 2 is a flow chart of a business data processing method in one embodiment;

FIG. 3 is a schematic flow chart illustrating a sub-process of step S610 of FIG. 2 in one embodiment;

FIG. 4 is a block diagram of a business data processing device in one embodiment;

fig. 5 is an internal structural diagram of a computer device in one embodiment.

Detailed Description

In order to make the objects, technical solutions and advantages of the present application more apparent, the present application 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 present application.

The service data processing method provided by the application can be applied to an application environment as shown in fig. 1, wherein the terminal 102 can communicate with the service data processing server 104 in a network mode, the corresponding service is processed through the service data processing server 104, the service data processing server 104 firstly acquires a service access application submitted by the terminal 102, and then searches a corresponding service account; identifying a service type corresponding to the service access application; when the service type is determined to be a resource transfer service and the account attribute of the service account is a hot spot account, registering resource variation information of the service account through an asynchronous batch processing mode, triggering a batch processing process of resource variation of the service account, acquiring a first processing result corresponding to the resource variation of the service account, and feeding back the first processing result to the terminal 102; or when the service type is determined to be the resource transfer-out service and the account attribute of the service account is the hot spot account, acquiring the resource variation information corresponding to the service access application, registering the resource variation of the service account according to the existing resource quantity of the service account and the resource variation information, acquiring a second processing result corresponding to the resource variation of the service account, and feeding back the second processing result to the terminal 102. Wherein the terminal 102 may be, but is not limited to, various personal computers, notebook computers, smart phones, tablet computers.

As shown in fig. 2, in one embodiment, the service data processing method of the present application is implemented by a service data processing server, and specifically includes the following steps:

s200, the service data processing server receives a service access application submitted by the terminal and searches a corresponding service account.

The service data processing server comprises a database storing account information under a user name, and can process and update the account information in the database according to the specific information of the current service access application so as to fulfill the aim of current service data processing. And the database may specifically be an oracle database. The service access application is attached with account information and transaction type information of the corresponding application, and the server can search a corresponding account in the database according to the application and judge which type the current transaction access application belongs to.

S400, the service data processing server identifies the service type corresponding to the service access application.

The service types include a resource-in service and a resource-out service. The service access application types specifically comprise a resource transfer-in scene and a resource transfer-out scene, wherein the resource transfer-in scene refers to transferring in a resource into a current service account, and the resource transfer-out scene refers to transferring out the resource in the current service account. The resource transfer scene only needs to carry out the operation of resource change on the current account, and the resource transfer scene also needs to carry out the operation of detecting the account resource remaining quantity so as to prevent the situation that the quantity of the resources to be transferred exceeds the existing quantity of the account. And judging the current corresponding processing mode by identifying the service type of the service application submitted by the user terminal.

S610, when the service type is determined to be the resource transfer service and the account attribute of the service account is the hot account, registering the resource variation information of the service account through an asynchronous batch processing mode, triggering a batch processing process of resource variation of the service account, acquiring a first processing result corresponding to the resource variation of the service account, and feeding back the first processing result to the terminal.

The hot-spot account is an account for performing high-frequency resource transfer operation, after service application is accessed and processing is started, whether the current account in a service access scene belongs to the hot-spot account can be judged, when the current account is the hot-spot account, resource variation of a transaction account can be registered according to an asynchronous batch processing mode, then a batch resource processing process is triggered, a first processing result obtained after service processing is completed is obtained, and meanwhile, the corresponding processing result is directly returned to a terminal to improve the processing efficiency, and meanwhile, the corresponding account information of a database of a storage server is updated according to the processing result.

S630, or when the service type is determined to be the resource transfer-out service and the account attribute of the service account is the hot spot account, acquiring resource variation information corresponding to the service access application, registering the resource variation of the service account according to the existing resource quantity of the service account and the resource variation information, acquiring a second processing result corresponding to the resource variation of the service account, and feeding back the second processing result to the terminal.

When the service type of the current service is the resource transfer service and the account type of the service account also belongs to the hot spot account, the resource data of the account can be managed according to the resource change information in the current account, after one resource change is registered and recorded, whether the existing resource quantity in the account is more than or equal to 0 can be judged and judged at the same time, if so, the subsequent account resource change information is continuously processed, finally the change records in the resource transfer are integrated, a corresponding second processing result is obtained, the second processing result is fed back to the user terminal, and meanwhile, the corresponding account information of the database of the storage server is updated according to the processing result.

The service data processing method comprises the steps of firstly receiving a service access application submitted by a terminal, and searching a corresponding service account; identifying a service type corresponding to the service access application; when the service type is determined to be a resource transfer service and the account attribute of the service account is a hot account, registering resource variation information of the service account through an asynchronous batch processing mode, triggering a batch processing process of resource variation of the service account, acquiring a first processing result corresponding to the resource variation of the service account, and feeding back the first processing result to the terminal; or when the service type is determined to be the resource transfer-out service and the account attribute of the service account is the hot spot account, acquiring the resource variation information corresponding to the service access application, registering the resource variation of the service account according to the existing resource quantity of the service account and the resource variation information, acquiring a second processing result corresponding to the resource variation of the service account, and feeding back the second processing result to the terminal. According to the business data processing method, the hot-spot account in the business account is identified, the resource variation in the account is recorded according to the scene, when the scene is shifted into for the resource, the batch asynchronous processing is directly carried out, when the scene is shifted out for the resource, the resource variation of the account is registered, the corresponding variation result is obtained, the corresponding hot-spot account business data is not needed to be carried out through splitting the account, and the complexity of business data processing is not increased.

As shown in fig. 3, in one embodiment, step S610 includes:

s611, when the service type is the resource transfer service and the account attribute of the service account is the hot spot account, the current service processing flow is obtained.

S612, triggering a batch processing process of resource variation of the business account according to the current business processing flow.

S613, when the batch processing process of the resource variation of the business account is triggered, acquiring an application record of the business account in a preset time.

S614, acquiring resource variation information corresponding to each application record, and sequentially registering the resource variation information to a historical resource variation information table according to the time sequence of the application records;

s615, obtaining current resource information according to the resource variation information of the last time in the preset timing time.

S616, the current resource information and the historical resource change information table are saved and fed back to the terminal.

The batch processing of the hot-spot accounts can be triggered by selecting a corresponding triggering mode according to the specific business processing flow of the current account. Specifically, when the current service processing flow is lower than a preset flow threshold, a batch resource processing process is triggered through a timing trigger, the triggering time of the timing trigger is set according to the account entry time delay of the hot spot account, and the account entry time delay can be reduced by setting shorter timing time. When the current service processing flow rate is higher than or equal to a preset flow rate threshold value, the batch resource processing process can be triggered through the advanced queue. The high-level queue is a high-level application of oracle, which is mainly an application formed by combining a table and a trigger. The main function is to transfer messages among various application systems. After the triggering mode is selected, the application records of the current account in the timing time can be obtained in batches, then the resource variation in the account of each application is calculated sequentially through cursor calculation, meanwhile, the historical resource variation information of each application is registered into the corresponding record table after each calculation is finished, the latest account resource amount information after the timing time under the current sequence is finally obtained, and then the latest account resource amount information and the historical resource variation information table are submitted to a database to update the corresponding record in the database.

In one embodiment, S630 includes:

when the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account, acquiring an application record of the service account in a preset time;

according to the time sequence of the application record, the resource variation information of the service account is sequentially registered, and after the current resource variation information is registered, whether the account resource residual quantity of the service account is larger than or equal to zero is judged;

when the account resource surplus of the service account is greater than or equal to zero, maintaining the operation of sequentially registering the resource variation of the service account according to the application records, acquiring the application records of the service account in the preset time, acquiring the resource variation information corresponding to each application record, sequentially registering the resource variation information to a historical resource variation information table according to the time sequence of the application records, acquiring the current resource information according to the resource variation information, and storing and feeding back the current resource information and the historical resource variation information table to the terminal;

and when the account resource remaining quantity of the service account is smaller than zero, stopping registering the resource variation information of the current service account, and feeding back failure information to the terminal.

When the service scene belongs to a resource transfer-out scene and the service account belongs to a hot spot account, the service account can be managed through a registration record of current resource change information, after one piece of resource change information is registered, whether the residual quantity of the resource quantity in the service account is more than or equal to 0 can be judged at the same time, if so, the subsequent account resource change information is continuously processed, meanwhile, the resource change information can be triggered at regular time through a batch resource processing process, then all the registered resource change information is integrated through an asynchronous batch processing mode, a historical resource change information table and the finally processed account resource residual quantity are acquired after the combination of the resource change information table and the last processed account resource residual quantity, and then the data are submitted to a database, corresponding records in the database are updated, and meanwhile, the data are fed back to a user terminal, so that the current service processing is completed. If not, deleting the current variation directly, and feeding back the information of the application failure directly to the user terminal. The efficient data processing task can be effectively performed by the resource amount zero crossing judgment and batch integration mode.

In one embodiment, S630 includes:

judging whether the account resource remaining amount of the business account is greater than or equal to zero in a second resource change record corresponding to the current application record;

when the account resource surplus of the business account is greater than or equal to zero, maintaining the operation of splitting each application record into a first resource change record and a second resource change record according to the time sequence, acquiring a historical resource change information table according to the first resource change record and the second resource change record after the preset time, acquiring current resource information according to the second resource change record, and storing and feeding back the current resource information and the historical resource change information table to the terminal;

And when the account resource of the service account is smaller than zero, stopping registering the resource variation information of the current service account, and feeding back failure information to the terminal.

When the service scenario belongs to the resource transfer-out scenario and the service account belongs to the hot spot account, the service scenario can be managed by splitting each application record into a first resource change record and a second resource change record. The application record obtained at the beginning is in an unlocked state and is split into two records, one resource change record, namely a first resource change record is used for recording the current resource transfer quantity, the record table is locked by the server, and a user can directly inquire the first resource change record. The other resource change information table, namely a second resource change record, is used for recording the result value of the current account resource quantity minus the resource transfer quantity, and the second resource change record is used for being released to other application records for use. Each resource change record is split into two records, one record is locked, the other record is Zhang Weisuo, and a user can directly inquire the resource record which is locked. If the business processing is successful, deleting the first resource change record, if the transaction fails, releasing the record, and other transactions can attempt to acquire the record, so as to end the transaction flow. After the records are completed, all the disassembled resource records can be merged and submitted to corresponding records in the database update database through the timing triggering of the asynchronous batch processing process. While avoiding the efficiency from being affected by excessive recording numbers. Acquiring a historical resource change information table according to the first resource change record and the second resource change record, acquiring current resource information according to the second resource change record, storing and feeding back the current resource information and the historical resource change information table to the terminal, completing the current transaction process, if not, directly deleting the current change, and directly feeding back the information of failure application to the user terminal. The efficient data processing task can be effectively performed by the resource amount zero crossing judgment and batch integration mode.

In one embodiment, S400 then comprises:

when the service account does not belong to the hot spot account, registering the resource variation of the service account in a synchronous mode, obtaining a synchronous processing result, and feeding back the synchronous processing result to the terminal.

When the service account does not belong to the hot spot account, service pressure is not brought to the service processing server, at the moment, the service can be directly processed in a synchronous mode, the resource quantity variation of the service account is registered, and the resource quantity variation is directly fed back to the user terminal.

In one embodiment, identifying a service type corresponding to the service access application, where the service type includes, before the resource transfer-in service and the resource transfer-out service, the steps of:

acquiring current account flow of each service account;

The account attributes of the business account may be changed by adding a hot account tag to the business account. The current account flow of the service account can be obtained at a time point before the processing time, the account flow is the number of service applications corresponding to the current account in unit time, when the service application quantity exceeds a threshold value, the current account can be judged to be a hot spot account, a hot spot account mark is added to the account, when the service application quantity is lower than or equal to the threshold value, the current account can be judged not to be a hot spot account, and the hot spot account mark is not added to the account, or the hot spot account mark on the current account is cancelled. The threshold value can be obtained by performing pressure test on the current business processing system, and because the business processing performance of the transaction processing system is related to hardware environments such as server configuration of the business system, the account flow threshold value of the hot account is required to be obtained by performing pressure test on the system, specifically, the account flow is simulated by simulating the account, the account flow of the virtual account is gradually improved, and when the processing speed of each transaction of the virtual account is obviously reduced, the current account flow is considered to be the flow threshold value.

It should be understood that, although the steps in the flowcharts of fig. 2-3 are shown in order as indicated by the arrows, these steps are not necessarily performed in order as indicated by the arrows. The steps are not strictly limited to the order of execution unless explicitly recited herein, and the steps may be executed in other orders. Moreover, at least some of the steps in fig. 2-3 may include multiple sub-steps or stages that are not necessarily performed at the same time, but may be performed at different times, nor do the order in which the sub-steps or stages are performed necessarily occur sequentially, but may be performed alternately or alternately with at least a portion of the sub-steps or stages of other steps or steps.

As shown in fig. 4, a service data processing apparatus, the apparatus includes:

the application receiving module 200 is configured to receive a service access application submitted by a terminal, and search a corresponding service account;

a service identification module 400, configured to identify a service type corresponding to the service access application;

the first scene processing module 610 is configured to register resource variation information of a service account through an asynchronous batch processing mode when it is determined that a service type is a resource transfer service and an account attribute of the service account is a hot spot account, trigger a batch processing process of resource variation of the service account, obtain a first processing result corresponding to resource variation of the service account, and feed back the first processing result to the terminal;

The second scenario processing module 630 is configured to obtain resource variation information corresponding to the service access application when it is determined that the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account, register resource variation of the service account according to the existing resource amount of the service account and the resource variation information, obtain a second processing result corresponding to the resource variation of the service account, and feed back the second processing result to the terminal.

In one embodiment, the first scenario processing module 610 is configured to obtain a current service processing flow when the service type is a resource transfer-in service and the account attribute of the service account is a hot spot account; triggering a batch processing process of resource variation of the business account according to the current business processing flow; when a batch processing process of resource variation of the service account is triggered, acquiring an application record of the service account in a preset time; acquiring resource change information corresponding to each application record, and sequentially registering the resource change information to a historical resource change information table according to the time sequence of the application records; acquiring current resource information according to the resource variation information of the last time in the preset timing time; and storing and feeding back the current resource information and the historical resource change information table to the terminal.

In one embodiment, the first scenario processing module 610 is configured to trigger a batch resource processing procedure through a timing trigger when the current traffic processing flow is lower than a preset flow threshold, and trigger a batch resource processing procedure through an advanced queue when the current traffic processing flow is higher than or equal to the preset flow threshold.

In one embodiment, the second scenario processing module 630 is configured to obtain an application record of the service account within a preset time when the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account; according to the time sequence of the application record, the resource variation information of the service account is sequentially registered, and after the current resource variation information is registered, whether the account resource residual quantity of the service account is larger than or equal to zero is judged; when the account resource surplus of the service account is greater than or equal to zero, maintaining the operation of sequentially registering the resource variation of the service account according to the application records, acquiring the application records of the service account in the preset time, acquiring the resource variation information corresponding to each application record, sequentially registering the resource variation information to a historical resource variation information table according to the time sequence of the application records, acquiring the current resource information according to the resource variation information, and storing and feeding back the current resource information and the historical resource variation information table to the terminal; and when the account resource remaining quantity of the service account is smaller than zero, stopping registering the resource variation information of the current service account, and feeding back failure information to the terminal.

In one embodiment, the second scenario processing module 630 is configured to obtain an application record of the service account within a preset time when the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account; splitting each application record into a first resource variation record and a second resource variation record according to the time sequence, wherein the first resource variation record is used for recording the resource variation amount corresponding to the current application record, the second resource variation record is used for recording the resource remaining amount of the business account corresponding to the current application record, and the second resource variation record is determined according to the second resource variation record of the previous application record corresponding to the current application record in the time sequence; judging whether the account resource remaining amount of the business account is greater than or equal to zero in a second resource change record corresponding to the current application record; when the account resource surplus of the business account is greater than or equal to zero, maintaining the operation of splitting each application record into a first resource change record and a second resource change record according to the time sequence, acquiring a historical resource change information table according to the first resource change record and the second resource change record after the preset time, acquiring current resource information according to the second resource change record, and storing and feeding back the current resource information and the historical resource change information table to the terminal; and when the account resource of the service account is smaller than zero, stopping registering the resource variation information of the current service account, and feeding back failure information to the terminal.

In one embodiment, the system further comprises a synchronization processing module, which is configured to register resource variation of the service account in a synchronization manner when the service account does not belong to the hot spot account, obtain a synchronization processing result, and feed back the synchronization processing result to the terminal.

In one embodiment, the system further comprises an account attribute identification module, which is used for acquiring the current account flow of each service account; and changing the account attribute of the corresponding service account according to the account flow.

For specific limitations of the service data processing apparatus, reference may be made to the above limitation of the service data processing method, and no further description is given here. The various modules in the service data processing device described above may be implemented in whole or in part by software, hardware, or a combination thereof. The above modules may be embedded in hardware or may be independent of a processor in the computer device, or may be stored in software in a memory in the computer device, so that the processor may call and execute operations corresponding to the above modules.

In one embodiment, a computer device is provided, which may be a server, the internal structure of which may be as shown in fig. 5. The computer device includes a processor, a memory, a network interface, and a database connected by a system bus. Wherein the processor of the computer device is configured to provide computing and control capabilities. The memory of the computer device includes a non-volatile storage medium and an internal memory. The non-volatile storage medium stores an operating system and a computer program. The internal memory provides an environment for the operation of the operating system and computer programs in the non-volatile storage media. The network interface of the computer device is used for communicating with an external terminal through a network connection. The database of the computer device is used to store account information of the user. The computer program is executed by a processor to implement a business data processing method.

It will be appreciated by those skilled in the art that the structure shown in fig. 5 is merely a block diagram of some of the structures associated with the present application and is not limiting of the computer device to which the present application may be applied, and that a particular computer device may include more or fewer components than shown, or may combine certain components, or have a different arrangement of components.

In one embodiment, a computer device is provided comprising a memory and a processor, the memory having stored therein a computer program, the processor when executing the computer program performing the steps of:

identifying a service type corresponding to the service access application;

when the service type is determined to be a resource transfer service and the account attribute of the service account is a hot account, registering resource variation information of the service account through an asynchronous batch processing mode, triggering a batch processing process of resource variation of the service account, acquiring a first processing result corresponding to the resource variation of the service account, and feeding back the first processing result to the terminal;

or when the service type is determined to be the resource transfer-out service and the account attribute of the service account is the hot spot account, acquiring the resource variation information corresponding to the service access application, registering the resource variation of the service account according to the existing resource quantity of the service account and the resource variation information, acquiring a second processing result corresponding to the resource variation of the service account, and feeding back the second processing result to the terminal.

In one embodiment, the processor when executing the computer program further performs the steps of: when the service type is a resource transfer service and the account attribute of the service account is a hot spot account, acquiring the current service processing flow; triggering a batch processing process of resource variation of the business account according to the current business processing flow; when a batch processing process of resource variation of the service account is triggered, acquiring an application record of the service account in a preset time; acquiring resource change information corresponding to each application record, and sequentially registering the resource change information to a historical resource change information table according to the time sequence of the application records; acquiring current resource information according to the resource variation information of the last time in the preset timing time; and storing and feeding back the current resource information and the historical resource change information table to the terminal.

In one embodiment, the processor when executing the computer program further performs the steps of: when the current business processing flow is lower than a preset flow threshold, the batch resource processing process is triggered by the timing trigger, and when the current business processing flow is higher than or equal to the preset flow threshold, the batch resource processing process is triggered by the advanced queue.

In one embodiment, the processor when executing the computer program further performs the steps of: when the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account, acquiring an application record of the service account in a preset time; according to the time sequence of the application record, the resource variation information of the service account is sequentially registered, and after the current resource variation information is registered, whether the account resource residual quantity of the service account is larger than or equal to zero is judged; when the account resource surplus of the service account is greater than or equal to zero, maintaining the operation of sequentially registering the resource variation of the service account according to the application records, acquiring the application records of the service account in the preset time, acquiring the resource variation information corresponding to each application record, sequentially registering the resource variation information to a historical resource variation information table according to the time sequence of the application records, acquiring the current resource information according to the resource variation information, and storing and feeding back the current resource information and the historical resource variation information table to the terminal; and when the account resource remaining quantity of the service account is smaller than zero, stopping registering the resource variation information of the current service account, and feeding back failure information to the terminal.

In one embodiment, the processor when executing the computer program further performs the steps of: when the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account, acquiring an application record of the service account in a preset time; splitting each application record into a first resource variation record and a second resource variation record according to the time sequence, wherein the first resource variation record is used for recording the resource variation amount corresponding to the current application record, the second resource variation record is used for recording the resource remaining amount of the business account corresponding to the current application record, and the second resource variation record is determined according to the second resource variation record of the previous application record corresponding to the current application record in the time sequence; judging whether the account resource remaining amount of the business account is greater than or equal to zero in a second resource change record corresponding to the current application record; when the account resource surplus of the business account is greater than or equal to zero, maintaining the operation of splitting each application record into a first resource change record and a second resource change record according to the time sequence, acquiring a historical resource change information table according to the first resource change record and the second resource change record after the preset time, acquiring current resource information according to the second resource change record, and storing and feeding back the current resource information and the historical resource change information table to the terminal; and when the account resource of the service account is smaller than zero, stopping registering the resource variation information of the current service account, and feeding back failure information to the terminal.

In one embodiment, the processor when executing the computer program further performs the steps of: when the service account does not belong to the hot spot account, registering the resource variation of the service account in a synchronous mode, obtaining a synchronous processing result, and feeding back the synchronous processing result to the terminal.

In one embodiment, the processor when executing the computer program further performs the steps of: acquiring current account flow of each service account; and changing the account attribute of the corresponding service account according to the account flow.

acquiring current account flow of each service account; and changing the account attribute of the corresponding service account according to the account flow.

identifying a service type corresponding to the service access application;

In one embodiment, the computer program when executed by the processor further performs the steps of: when the service type is a resource transfer service and the account attribute of the service account is a hot spot account, acquiring the current service processing flow; triggering a batch processing process of resource variation of the business account according to the current business processing flow; when a batch processing process of resource variation of the service account is triggered, acquiring an application record of the service account in a preset time; acquiring resource change information corresponding to each application record, and sequentially registering the resource change information to a historical resource change information table according to the time sequence of the application records; acquiring current resource information according to the resource variation information of the last time in the preset timing time; and storing and feeding back the current resource information and the historical resource change information table to the terminal.

In one embodiment, the computer program when executed by the processor further performs the steps of: when the current business processing flow is lower than a preset flow threshold, the batch resource processing process is triggered by the timing trigger, and when the current business processing flow is higher than or equal to the preset flow threshold, the batch resource processing process is triggered by the advanced queue.

In one embodiment, the computer program when executed by the processor further implements the steps of obtaining an application record of the service account within a preset time when the service type is a resource transfer-out service and the account attribute of the service account is a hotspot account; according to the time sequence of the application record, the resource variation information of the service account is sequentially registered, and after the current resource variation information is registered, whether the account resource residual quantity of the service account is larger than or equal to zero is judged; when the account resource surplus of the service account is greater than or equal to zero, maintaining the operation of sequentially registering the resource variation of the service account according to the application records, acquiring the application records of the service account in the preset time, acquiring the resource variation information corresponding to each application record, sequentially registering the resource variation information to a historical resource variation information table according to the time sequence of the application records, acquiring the current resource information according to the resource variation information, and storing and feeding back the current resource information and the historical resource variation information table to the terminal; and when the account resource remaining quantity of the service account is smaller than zero, stopping registering the resource variation information of the current service account, and feeding back failure information to the terminal.

In one embodiment, the computer program when executed by the processor further implements the steps of obtaining an application record of the service account within a preset time when the service type is a resource transfer-out service and the account attribute of the service account is a hotspot account; splitting each application record into a first resource variation record and a second resource variation record according to the time sequence, wherein the first resource variation record is used for recording the resource variation amount corresponding to the current application record, the second resource variation record is used for recording the resource remaining amount of the business account corresponding to the current application record, and the second resource variation record is determined according to the second resource variation record of the previous application record corresponding to the current application record in the time sequence; judging whether the account resource remaining amount of the business account is greater than or equal to zero in a second resource change record corresponding to the current application record; when the account resource surplus of the business account is greater than or equal to zero, maintaining the operation of splitting each application record into a first resource change record and a second resource change record according to the time sequence, acquiring a historical resource change information table according to the first resource change record and the second resource change record after the preset time, acquiring current resource information according to the second resource change record, and storing and feeding back the current resource information and the historical resource change information table to the terminal; and when the account resource of the service account is smaller than zero, stopping registering the resource variation information of the current service account, and feeding back failure information to the terminal.

In one embodiment, the computer program when executed by the processor further implements the step of registering resource variation of the service account in a synchronous manner when the service account does not belong to the hotspot account, obtaining a synchronous processing result, and feeding back the synchronous processing result to the terminal.

In one embodiment, the computer program when executed by the processor further performs the steps of: acquiring current account flow of each service account; and changing the account attribute of the corresponding service account according to the account flow.

Those skilled in the art will appreciate that implementing all or part of the above-described methods in accordance with the embodiments may be accomplished by way of a computer program stored on a non-transitory computer readable storage medium, which when executed may comprise the steps of the embodiments of the methods described above. Any reference to memory, storage, database, or other medium used in the various embodiments provided herein may include non-volatile and/or volatile memory. The nonvolatile memory can include Read Only Memory (ROM), programmable ROM (PROM), electrically Programmable ROM (EPROM), electrically Erasable Programmable ROM (EEPROM), or flash memory. Volatile memory can include Random Access Memory (RAM) or external cache memory. By way of illustration and not limitation, RAM is available in a variety of forms such as Static RAM (SRAM), dynamic RAM (DRAM), synchronous DRAM (SDRAM), double Data Rate SDRAM (DDRSDRAM), enhanced SDRAM (ESDRAM), synchronous Link DRAM (SLDRAM), memory bus direct RAM (RDRAM), direct memory bus dynamic RAM (DRDRAM), and memory bus dynamic RAM (RDRAM), among others.

The technical features of the above embodiments may be arbitrarily combined, and all possible combinations of the technical features in the above embodiments are not described for brevity of description, however, as long as there is no contradiction between the combinations of the technical features, they should be considered as the scope of the description.

The foregoing examples represent only a few embodiments of the present application, which are described in more detail and are not to be construed as limiting the scope of the invention. It should be noted that it would be apparent to those skilled in the art that various modifications and improvements could be made without departing from the spirit of the present application, which would be within the scope of the present application. Accordingly, the scope of protection of the present application is to be determined by the claims appended hereto.

Claims

1. A business data processing method, the method comprising:

identifying a service type corresponding to the service access application;

when the service type is a resource transfer service and the account attribute of the service account is a hot spot account, acquiring the current service processing flow; triggering a batch resource processing process through a timing trigger when the current service processing flow is lower than a preset flow threshold, and triggering the batch resource processing process through an advanced queue when the current service processing flow is higher than or equal to the preset flow threshold; when a batch processing process of resource variation of the service account is triggered, acquiring an application record of the service account in a preset timing time; acquiring resource change information corresponding to each application record, and sequentially registering the resource change information to a historical resource change information table according to the time sequence of the application records; acquiring current resource information according to the resource variation information of the last time in the preset timing time; storing and feeding back the current resource information and the historical resource change information table to the terminal;

When the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account, acquiring an application record of the service account in a preset timing time; splitting each application record into a first resource variation record and a second resource variation record according to the time sequence, wherein the first resource variation record is used for recording the resource variation amount corresponding to the current application record, the second resource variation record is used for recording the resource remaining amount of the business account corresponding to the current application record, and the second resource variation record is determined according to the second resource variation record of the previous application record corresponding to the current application record in the time sequence; judging whether the account resource remaining amount of the business account is larger than or equal to zero in the second resource change record corresponding to the current application record; when the account resource surplus of the service account is greater than or equal to zero, maintaining the operation of splitting each application record into a first resource change record and a second resource change record according to time sequence, after the preset time, acquiring a historical resource change information table according to the first resource change record and the second resource change record, acquiring current resource information according to the second resource change record, storing and feeding back the current resource information and the historical resource change information table to the terminal, when the account resource of the service account is less than zero, stopping registering the resource change information of the current service account, feeding back failure information to the terminal, and triggering and merging all the disassembled resource change records to a database through asynchronous batch processing process timing after the completion of the recording so as to update corresponding record data in the database.

2. The method according to claim 1, wherein the method further comprises:

3. The method according to claim 1, wherein the identifying the service type corresponding to the service access application comprises:

4. The method of claim 1, wherein the identifying the service type corresponding to the service access application, the service type including, before the resource switch-in service and the resource switch-out service, includes:

acquiring current account flow of each service account;

5. A traffic data processing apparatus, the apparatus comprising:

the first scene processing module is used for acquiring current service processing flow when the service type is a resource transfer service and the account attribute of the service account is a hot spot account; triggering a batch resource processing process through a timing trigger when the current service processing flow is lower than a preset flow threshold, and triggering the batch resource processing process through an advanced queue when the current service processing flow is higher than or equal to the preset flow threshold; when a batch processing process of resource variation of the service account is triggered, acquiring an application record of the service account in a preset timing time; acquiring resource change information corresponding to each application record, and sequentially registering the resource change information to a historical resource change information table according to the time sequence of the application records; acquiring current resource information according to the resource variation information of the last time in the preset timing time; storing and feeding back the current resource information and the historical resource change information table to the terminal;

The second scene processing module is used for acquiring an application record of the service account in a preset timing time when the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account; splitting each application record into a first resource variation record and a second resource variation record according to the time sequence, wherein the first resource variation record is used for recording the resource variation amount corresponding to the current application record, the second resource variation record is used for recording the resource remaining amount of the business account corresponding to the current application record, and the second resource variation record is determined according to the second resource variation record of the previous application record corresponding to the current application record in the time sequence; judging whether the account resource remaining amount of the business account is larger than or equal to zero in the second resource change record corresponding to the current application record; when the account resource surplus of the service account is greater than or equal to zero, maintaining the operation of splitting each application record into a first resource change record and a second resource change record according to time sequence, after the preset time, acquiring a historical resource change information table according to the first resource change record and the second resource change record, acquiring current resource information according to the second resource change record, storing and feeding back the current resource information and the historical resource change information table to the terminal, when the account resource of the service account is less than zero, stopping registering the resource change information of the current service account, feeding back failure information to the terminal, and triggering and merging all the disassembled resource change records to a database through asynchronous batch processing process timing after the completion of the recording so as to update corresponding record data in the database.

6. The apparatus of claim 5, wherein the second scene processing module is further configured to: when the service type is a resource transfer-out service and the account attribute of the service account is a hot spot account, acquiring an application record of the service account in a preset timing time; sequentially registering resource variation information of the service account according to the time sequence of the application records, and judging whether the account resource remaining amount of the service account is greater than or equal to zero after registering the current resource variation information; when the account resource surplus of the service account is greater than or equal to zero, maintaining the operation of sequentially registering the resource variation of the service account according to the application records, acquiring the application records of the service account in preset timing time, acquiring resource variation information corresponding to each application record, sequentially registering the resource variation information to the historical resource variation information table according to the time sequence of the application records, acquiring current resource information according to the resource variation information, and storing and feeding back the current resource information and the historical resource variation information table to the terminal; and stopping registering the resource variation information of the current service account when the account resource remaining amount of the service account is smaller than zero, and feeding back failure information to the terminal.

7. The apparatus of claim 5, further comprising a synchronization processing module configured to: when the service account does not belong to the hot spot account, registering the resource variation of the service account in a synchronous mode to obtain a synchronous processing result, and feeding back the synchronous processing result to the terminal.

8. The apparatus of claim 5, further comprising an account attribute identification module to: when the service account does not belong to the hot spot account, registering the resource variation of the service account in a synchronous mode to obtain a synchronous processing result, and feeding back the synchronous processing result to the terminal.

9. A computer device comprising a memory and a processor, the memory storing a computer program, characterized in that the processor implements the steps of the method of any of claims 1 to 4 when the computer program is executed.

10. A computer readable storage medium, on which a computer program is stored, characterized in that the computer program, when being executed by a processor, implements the steps of the method of any of claims 1 to 4.