CN111125106A

Movatterモバイル変換

Info

Publication number: CN111125106A
Application number: CN201911342672.XA
Authority: CN
Inventors: 况雨平
Original assignee: Shenzhen Lexin Software Technology Co Ltd
Current assignee: Shenzhen Lexin Software Technology Co Ltd
Priority date: 2019-12-23
Filing date: 2019-12-23
Publication date: 2020-05-08
Anticipated expiration: 2039-12-23
Also published as: CN111125106B

Abstract

Translated fromChinese

本发明实施例公开了一种跑批任务执行方法、装置、服务器和存储介质。将业务数据表中的业务数据同步到集群单表中，提高业务数据的查询效率以及在离线状态下进行资金结算，根据集群单表中的业务数据确定当前日期到期且未处理的初始账单，对当前日期的初始账单进行计算，生成账单计算数据表，在当前日期的下一天根据初始账单的订单编号以及初始账单从当前日期至当前日期的下一天的还款状态变化，确定当前日期的下一天的目标账单，并对目标账单执行跑批任务。通过将资金的结算过程前置到执行跑批任务的前一天，解决了现有技术中服务器在执行跑批任务时压力过大的问题，达到错开跑批高峰期的目的，实现保证跑批任务执行的稳定性和高效性的效果。

The embodiment of the present invention discloses a batch running task execution method, device, server and storage medium. Synchronize the business data in the business data table to the cluster single table, improve the query efficiency of business data and perform fund settlement in an offline state, and determine the unprocessed initial bills due on the current date according to the business data in the cluster single table, Calculate the initial bill of the current date, generate a bill calculation data table, and determine the next day of the current date according to the order number of the initial bill and the change of the repayment status of the initial bill from the current date to the next day of the current date. Target bills for one day, and execute batch tasks on the target bills. By advancing the settlement process of funds to the day before the batch running task is executed, the problem of excessive pressure on the server when executing the batch running task in the prior art is solved, the purpose of staggering the batch running peak period is achieved, and ensuring the batch running task is realized. Stability and efficiency of execution.

Description

Batch running task execution method, device, server and storage medium

Technical Field

The embodiment of the invention relates to the technical field of computers, in particular to a batch running task execution method, a batch running task execution device, a batch running task execution server and a storage medium.

Background

In the loan aid industry, after a loan aid company takes funds from a funding party and debits the funds to a user, a post-loan batch task is performed. The batch running task needs to be executed every day at 12:00 pm and T +1 day after the day, so as to calculate the overdue order of the user, for example, calculate the interest of the user to be paid, inform the user of timely payment and the like, then normally settle the interest of paying the fund party every day with the external fund party, and the settlement needs to be finished before 3 o' clock of the T +1 day, if the settlement fails, the company occupies the fund of the fund party, needs to pay more interest to the fund party, even causes the overdue risk of the user and the fund party that the user is passively informed, and influences the normal development of the business of the loan-assisting company.

As shown in fig. 1, in the post-loan batch scheme adopted in the prior art, when the lending company performs account settlement on the loan user, the batch job may be performed on unprocessed bills by traversing the hundred library ten tables starting at day T +1 of 12:00 pm. However, in the morning, the batch running tasks of each system server are multiple, the system and the database are high in pressure and centralized, and the timeliness, the accuracy and the stability of the execution of overdue batch running tasks after loan cannot be guaranteed.

Therefore, the technical scheme provided by the prior art has low batch running task execution efficiency and has the risk of batch running task execution failure.

Disclosure of Invention

The embodiment of the invention provides a batch running task execution method, a batch running task execution device, a batch running task execution server and a storage medium, and achieves the effect of improving the batch running task execution efficiency and the batch running task execution success rate.

In a first aspect, an embodiment of the present invention provides a batch running task execution method, where the method includes:

synchronizing the service data in the service data table into a cluster list table, and determining an unprocessed initial bill with an expired current date according to the service data in the cluster list table;

calculating the initial bills of the current date and generating a bill calculation data table, wherein the bill calculation data table comprises the calculation result of each initial bill;

and determining a target bill of the next day of the current date according to the order number of the initial bill and the repayment state change of the initial bill from the current date to the next day of the current date, and executing a batching task on the target bill.

In a second aspect, an embodiment of the present invention further provides a batching task executing apparatus, where the batching task executing apparatus includes:

the initial bill determining module is used for synchronizing the service data in the service data table into the cluster list table and determining an initial bill which is expired at the current date and is unprocessed according to the service data in the cluster list table;

the bill calculation data table generation module is used for calculating the initial bills of the current date and generating a bill calculation data table, wherein the bill calculation data table comprises the calculation result of each initial bill;

and the batching task execution module is used for determining a target bill of the next day of the current date according to the order number of the initial bill and the repayment state change of the initial bill from the current date to the next day of the current date, and executing a batching task on the target bill.

In a third aspect, an embodiment of the present invention further provides a server, where the server includes:

one or more processors;

a memory for storing one or more programs;

when executed by the one or more processors, cause the one or more processors to implement the batching task execution method steps as provided by any of the embodiments of the present invention.

In a fourth aspect, the embodiments of the present invention further provide a computer-readable storage medium, on which a computer program is stored, where the computer program, when executed by a processor, implements the steps of the batch task execution method provided in any of the embodiments of the present invention.

According to the technical scheme provided by the embodiment of the invention, the business data in the business data table is synchronized into the cluster form table, so that the purposes of improving the query efficiency of the business data and carrying out fund settlement in an off-line state can be achieved, then the initial bill which is due and unprocessed at the current date is determined according to the business data in the cluster form table, the initial bill at the current date is calculated, the bill calculation data table is generated, the target bill at the next day at the current date is determined according to the order number of the initial bill and the repayment state change of the initial bill from the current date to the next day at the current date, and the batch running task is carried out on the target bill. By preposing the settlement process of the fund to the day before the batch running task is executed, the problem that the server is over stressed when the batch running task is executed in the prior art is solved, the purpose of starting the batch running peak by mistake is achieved, and the effect of ensuring the stability and the high efficiency of the batch running task execution is realized.

Drawings

FIG. 1 is a logical schematic diagram of a batch task execution method provided in the prior art;

FIG. 2 is a flowchart illustrating a batch task execution method according to an embodiment of the present invention;

FIG. 3 is a logic diagram of a batch task execution method according to an embodiment of the present invention;

FIG. 4 is a flowchart illustrating a batch task execution method according to a second embodiment of the present invention;

FIG. 5 is a schematic structural diagram of a batching task executing device according to a third embodiment of the present invention;

fig. 6 is a schematic structural diagram of a server according to a fourth embodiment of the present invention.

Detailed Description

The present invention will be described in further detail with reference to the accompanying drawings and examples. It is to be understood that the specific embodiments described herein are merely illustrative of the invention and are not limiting of the invention. It should be further noted that, for the convenience of description, only some of the structures related to the present invention are shown in the drawings, not all of the structures.

Example one

Fig. 2 is a flowchart of a method for performing a batch task according to an embodiment of the present invention, which is applicable to a case where an overdue interest calculation is performed the day before the batch task is performed. The method can be executed by a batching task executing device, which can be realized by software and/or hardware and is integrated in a server with application development function. The method specifically comprises the following steps:

s110, synchronizing the service data in the service data table into the cluster list table, and determining the unprocessed initial bill with the expired current date according to the service data in the cluster list table.

As shown in fig. 1 and 3, if the loan-aid company performs the batching task on the T +1 day, the present embodiment determines the T day as the current date, so that the initial bill can be understood as an unprocessed bill expired on the T day. The business data can be understood as transaction information between the fund party and the loan user, and can include information such as a bill number, a loan amount, a loan start date, a payment-needed date, a payment record, fund party information, the loan user and the like.

Alternatively, the service data table may be a hundred-database ten table, that is, a hundred databases are established, each database includes ten tables, that is, service data is pre-stored in a thousand data tables, and loan aid companies may store loan relation detail information established by loan users and fund parties, that is, service data. Optionally, the cluster list table may be a spark table, and the spark table may store the service data in the form of a cluster. It can be understood that, because the service data table includes more tables and the table structure is complex, the efficiency of querying the unprocessed service data due to the expiration of the T-day is low, if the service data in the service data table is synchronized to the trunking single table, the efficiency of querying the unprocessed service data due to the expiration of the T-day can be improved, which is beneficial to improving the overall efficiency of the batch running task, and because the trunking single table has the function of offline calculation, by synchronizing the service data in the service data table to the trunking single table, the subsequent capital settlement and batch running task in an offline state are facilitated, so that the purpose of reducing the waste of online resources is achieved.

Alternatively, the initial bill may be determined by: acquiring repayment information of all service data in the cluster list table; and screening all the bills to be returned which are expired by the current date and unprocessed in the business data based on the repayment information, and determining all the bills to be returned as initial bills. In this way, by determining the unprocessed initial bill before the current date expires in advance the day before the batch running task is executed (i.e., the current date T), the fund settlement based on the determined initial bill is facilitated, the calculation amount is reduced, and the peak period of the missed batch running is facilitated.

And S120, calculating the initial bill of the current date and generating a bill calculation data table.

The bill calculation data table comprises the calculation result of each initial bill. Alternatively, the bill calculation data table may be a year-base-day table, which means that a data table may be created for each day of the year by running a script to store the calculation results of data such as overdue interest of bills that expire on the same day but have not yet been processed in each day, that is, the calculation results of each initial bill are included in the bill calculation data table, and the date of the same day may be used as the name of the table. The calculation result of the initial bill can include the amount of money and interest to be paid to the fund side by the loan user.

It is understood that it takes a lot of time to perform the fund settlement of overdue bills while performing the batching task by performing the fund settlement of the determined initial bills and generating the bill calculation data table the day before performing the batching task (i.e., the current date T), that is, advancing the settlement process of the fund to T day and further screening the target bills on the basis of the settlement result of T. Compared with the problem that the execution of the batch running task is too high in pressure due to the fact that fund settlement is carried out at 0-3 points of T +1 day in the prior art, the purpose of greatly reducing time consumed due to the fund settlement is achieved, the batch running peak period is mistaken, and the batch running task execution stability is improved.

And S130, determining a target bill of the next day of the current date according to the order number of the initial bill and the repayment state change of the initial bill from the current date to the next day of the current date, and performing a batching task on the target bill.

The target bill may be understood as a bill which expires to the next day of the current date (i.e., T +1 day) in the initial bill and is still not paid. It is understood that after the server determines the initial bill, the loan users of some initial bills pay the payment during the period from T-day bill settlement to T +1, and the initial bill should not be the target bill. Illustratively, the server acquires five million loan bills which need to be paid but are not paid on T day 9 am, namely, confirms the initial bill and performs fund settlement on the basis of the initial bill, such as interest settlement and the like, of course, the five million initial bills do not calculate overdue bills in T day, the initial bill which is not paid until T +1 day is called overdue unprocessed bill, if three million loan bills are paid before T +1 day, the three million loan bills do not belong to the overdue bills, and the remaining two million loan bills which are not paid until T +1 day are called overdue bills, namely, the target bill which needs to perform batch running task on T +1 day. After the target bill is confirmed on day T +1, the batching task may be performed on the target bill.

Example two

Fig. 4 is a flowchart illustrating a batch task execution method according to a second embodiment of the present invention. The technical solution of this embodiment is refined on the basis of the above embodiment, and optionally before the calculating the initial bill of the current date, the method further includes: and writing the initial bill into a temporary file, and transmitting the temporary file to a service processing module through a network transmission protocol so that the service processing module analyzes the temporary file. Referring specifically to fig. 4, the method of this embodiment may include the following steps:

s210, synchronizing the service data in the service data table into the cluster list table, and determining the unprocessed initial bill with the expired current date according to the service data in the cluster list table.

S220, writing the initial bill into a temporary file, and transmitting the temporary file to the service processing module through a network transmission protocol so that the service processing module can analyze the temporary file.

The service processing module may be an online service system in the server, and is used for performing fund settlement. As shown in fig. 2, after the initial bill is determined, data satisfying conditions may be obtained in an SQL (Structured Query Language) manner, that is, the initial bill is queried, the initial bill is written in a temporary file, and the temporary folder is pushed to an online service system, that is, a service processing module, through FTP (file transfer Protocol), the service processing module receives the temporary file and parses the temporary file, so that the subsequent overdue settlement may be performed on the initial bill with the current date (that is, T date) expired according to a parsing result.

And S230, calculating the initial bill of the current date and generating a bill calculation data table.

As shown in fig. 3, next to S220, after the business processing module parses the temporary file, overdue settlement may be performed on the initial bills with the current date (i.e., T day) due through a multi-thread Call (Remote Procedure Call), that is, overdue calculation is performed on the initial bills in the temporary file through the business processing module, and the overdue calculation result is written into the bill calculation data table, and after the overdue calculation is completed, the calculation result of each initial bill may be written into the bill calculation data table, and the date of the day is used as the name of the table, so that the target bill may be determined according to the calculation result of the bill calculation data table on T +1 day.

And S240, determining the target bill of the next day of the current date according to the order number of the initial bill and the repayment state change of the initial bill from the current date to the next day of the current date, and performing the batching task on the target bill.

Alternatively, the target bill may be determined by: acquiring the repayment state change of the initial bills corresponding to all the order numbers from the current date to the next day of the current date; judging whether the initial bill corresponding to the order number is unprocessed on the next day of the current date or not according to the repayment state; and if the initial bill corresponding to the order number is unprocessed, determining the unprocessed initial bill as the target bill. Optionally, the repayment status change of the initial bills corresponding to all the order numbers from the current date to the next day of the current date can be obtained through multiple threads.

Alternatively, the batching task is performed on the target bill, which may be implemented by: and updating the business data table according to the target bill, and executing batch running tasks on the target bill in the updated business data table.

Explaining by combining with the explanation of fig. 3, when the batch running task is executed on the day T +1, the overdue calculation result can be directly inquired from the bill calculation data table through the order number and by utilizing multiple threads, the step of calling an rpc interface to perform fund settlement on the day T +1 is omitted, whether the initial bill corresponding to the order number is unprocessed on the next day of the current date is judged, if the initial bill is already processed, the server directly skips the initial bill and does not process the initial bill, if the initial bill corresponding to the order number is unprocessed, the unprocessed initial bill is determined as a target bill, the business data table is updated according to the target bill, and the batch running task is executed on the target bill in the updated business data table.

Explaining the reasons for improving the efficiency and stability of the batch running task by using the method of the embodiment exemplarily, when five million bills exist at the current date, if the batch running calculation process needs to be executed in the T +1 day according to the execution mode in fig. 1, 3 hours may be needed, and according to the execution mode in fig. 3, the batch running calculation method is used for calculating in advance in the T day, so that the target bill can be further screened out from the initial bill calculated in advance in the early morning of the T +1 day and the target bill can be run, the batch running time can be shortened to less than 15 minutes, the normal settlement between the subsequent bill and the capital party is greatly ensured, the pressure of a business system and a database in the early morning is reduced, the utilization rate of a central processing unit is increased sharply to 85% and is stably reduced to about 30%, the system stability is improved, and the online batch running abnormal accidents are effectively reduced, the method provides reliable, stable and efficient platform support for the development of the business of the loan-aid company, and further improves the platform capability.

According to the technical scheme of the embodiment of the invention, the initial bill is written into the temporary file, the temporary file is transmitted to the business processing module through the network transmission protocol, so that the business processing module analyzes the temporary file, overdue calculation is carried out on the initial bill in the temporary file through the business processing module, and the overdue calculation result is written into the bill calculation data table, so that the initial bill can be calculated in advance on the day before the running batch task is executed, the initial bill is screened on the day when the running batch task is executed to determine the target bill, and the target bill is run and batched, therefore, the purposes of improving the efficiency, stability and accuracy of the overdue running batch on the day when the running batch task is executed are achieved, the running result can be rapidly, stably and accurately output by data within the time range required by timeliness, and the effect of normally carrying out fund settlement is ensured.

EXAMPLE III

Fig. 5 is a schematic structural diagram of a batch running task execution device according to a third embodiment of the present invention, which is applicable to a situation where a batch runs a calculation task of overdue interest for a loan and other services, and specifically includes: an initialbill determination module 51, a bill calculation datatable generation module 52, and a batchingtask execution module 53.

The initialbill determining module 51 is configured to synchronize the service data in the service data table into the cluster list table, and determine an initial bill that is due at a current date and is unprocessed according to the service data in the cluster list table;

the bill calculation datatable generation module 52 is configured to calculate the initial bills on the current date and generate a bill calculation data table, where the bill calculation data table includes the calculation result of each initial bill;

and the batchingtask executing module 53 is used for determining a target bill of the next day of the current date according to the order number of the initial bill and the repayment state change of the initial bill from the current date to the next day of the current date, and executing the batching task on the target bill.

On the basis of the above embodiment, the initialbill determining module 51 is further configured to obtain payment information of all service data bill data in the cluster list table;

and screening all the bills to be returned which are expired by the current date and unprocessed in the business data bill data based on the repayment information, and determining all the bills to be returned as initial bills.

On the basis of the above technical solutions, the apparatus further includes: a temporary file parsing module; the temporary file analysis module is used for writing the initial bill into the temporary file and transmitting the temporary file to the service processing module through the network transmission protocol so that the service processing module analyzes the temporary file.

On the basis of the above technical solutions, the bill calculation datatable generation module 52 is further configured to perform overdue calculation on the initial bill in the temporary file through the service processing module, and write an overdue calculation result into the bill calculation data table.

On the basis of the above technical solutions, the batchingtask executing module 53 is further configured to obtain a repayment state change of the initial bill of the initial order corresponding to all the order numbers from the current date to the next day of the current date;

judging whether the initial bill corresponding to the order number is unprocessed on the next day of the current date or not according to the repayment state change;

and if the initial bill corresponding to the order number is unprocessed, determining the unprocessed initial bill as the target bill.

On the basis of the above technical solutions, the batchingtask executing module 53 is further configured to obtain, through multiple threads, payment status changes of the initial bills of the initial orders corresponding to all the order numbers from the current date to the next day of the current date.

On the basis of the above technical solutions, the batch runningtask executing module 53 is further configured to update the service data table according to the target bill, and execute a batch running task on the target bill in the updated service data table.

Example four

Fig. 6 is a schematic structural diagram of a server according to a fourth embodiment of the present invention. FIG. 6 illustrates a block diagram of anexemplary server 12 suitable for use in implementing embodiments of the present invention. Theserver 12 shown in fig. 6 is only an example, and should not bring any limitation to the function and the scope of use of the embodiment of the present invention.

As shown in FIG. 6, theserver 12 is in the form of a general purpose computing device. The components of theserver 12 may include, but are not limited to: one or more processors orprocessing units 16, asystem memory 28, and abus 18 that couples various system components including thesystem memory 28 and theprocessing unit 16.

Bus 18 represents one or more of any of several types of bus structures, including a memory bus or memory controller, a peripheral bus, an accelerated graphics port, and a processor or local bus using any of a variety of bus architectures. By way of example, such architectures include, but are not limited to, Industry Standard Architecture (ISA) bus, micro-channel architecture (MAC) bus, enhanced ISA bus, Video Electronics Standards Association (VESA) local bus, and Peripheral Component Interconnect (PCI) bus.

Theserver 12 typically includes a variety of computer system readable media. Such media may be any available media that is accessible byserver 12 and includes both volatile and nonvolatile media, removable and non-removable media.

Thesystem memory 28 may include computer system readable media in the form of volatile memory, such as Random Access Memory (RAM)30 and/or cache memory 32. Theserver 12 may further include other removable/non-removable, volatile/nonvolatile computer system storage media. By way of example only,storage system 34 may be used to read from and write to non-removable, nonvolatile magnetic media (not shown in FIG. 6, and commonly referred to as a "hard drive"). Although not shown in FIG. 6, a magnetic disk drive for reading from and writing to a removable, nonvolatile magnetic disk (e.g., a "floppy disk") and an optical disk drive for reading from or writing to a removable, nonvolatile optical disk (e.g., a CD-ROM, DVD-ROM, or other optical media) may be provided. In these cases, each drive may be connected tobus 18 by one or more data media interfaces.System memory 28 may include at least one program product having a set (e.g., at least one) of program modules that are configured to carry out the functions of embodiments of the invention.

A program/utility 40 having a set (at least one) ofprogram modules 42 may be stored, for example, insystem memory 28,such program modules 42 including, but not limited to, an operating system, one or more application programs, other program modules, and program data, each of which examples or some combination thereof may comprise an implementation of a network environment.Program modules 42 generally carry out the functions and/or methodologies of the described embodiments of the invention.

Theserver 12 may also communicate with one or more external devices 14 (e.g., keyboard, pointing device,display 24, etc.), with one or more devices that enable a user to interact with theserver 12, and/or with any devices (e.g., network card, modem, etc.) that enable theserver 12 to communicate with one or more other computing devices. Such communication may be through an input/output (I/O)interface 22. Also, theserver 12 may communicate with one or more networks (e.g., a Local Area Network (LAN), a Wide Area Network (WAN), and/or a public network, such as the Internet) via thenetwork adapter 20. As shown, thenetwork adapter 20 communicates with the other modules of theserver 12 via thebus 18. It should be understood that although not shown in the figures, other hardware and/or software modules may be used in conjunction with theserver 12, including but not limited to: microcode, device drivers, redundant processing units, external disk drive arrays, RAID systems, tape drives, and data backup storage systems, among others.

Theprocessing unit 16 executes various functional applications and data processing by executing programs stored in thesystem memory 28, for example, implementing a batching task execution method provided by the present embodiment, the method comprising:

synchronizing the service data in the service data table into the cluster list table, and determining an unprocessed initial bill with an expired current date according to the service data in the cluster list table;

Of course, those skilled in the art can understand that the processor can also implement the technical solution of the batch task execution method provided by any embodiment of the present invention.

EXAMPLE five

This fifth embodiment provides a computer readable storage medium, on which a computer program is stored, the program, when executed by a processor, implementing the steps of the batch task execution method provided by any embodiment of the present invention, the method including:

Computer storage media for embodiments of the invention may employ any combination of one or more computer-readable media. The computer readable medium may be a computer readable signal medium or a computer readable storage medium. The computer-readable storage medium may be, for example but not limited to: an electrical, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any combination thereof. More specific examples (a non-exhaustive list) of the computer readable storage medium would include the following: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device.

A computer readable signal medium may include a propagated data signal with computer readable program code embodied therein, for example, in baseband or as part of a carrier wave. Such a propagated data signal may take many forms, including, but not limited to, electro-magnetic, optical, or any suitable combination thereof. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device.

Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to: wireless, wire, fiber optic cable, RF, etc., or any suitable combination of the foregoing.

Computer program code for carrying out operations for aspects of the present invention may be written in any combination of one or more programming languages, including an object oriented programming language such as Java, Smalltalk, C + + or the like and conventional procedural programming languages, such as the "C" programming language or similar programming languages. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer or entirely on the remote computer or server. In the case of a remote computer, the remote computer may be connected to the user's computer through any type of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or the connection may be made to an external computer (for example, through the Internet using an Internet service provider).

It will be understood by those skilled in the art that the modules or steps of the invention described above may be implemented by a general purpose computing device, they may be centralized on a single computing device or distributed across a network of computing devices, and optionally they may be implemented by program code executable by a computing device, such that it may be stored in a memory device and executed by a computing device, or it may be separately fabricated into various integrated circuit modules, or it may be fabricated by fabricating a plurality of modules or steps thereof into a single integrated circuit module. Thus, the present invention is not limited to any specific combination of hardware and software.

It is to be noted that the foregoing is only illustrative of the preferred embodiments of the present invention and the technical principles employed. It will be understood by those skilled in the art that the present invention is not limited to the particular embodiments described herein, but is capable of various obvious changes, rearrangements and substitutions as will now become apparent to those skilled in the art without departing from the scope of the invention. Therefore, although the present invention has been described in greater detail by the above embodiments, the present invention is not limited to the above embodiments, and may include other equivalent embodiments without departing from the spirit of the present invention, and the scope of the present invention is determined by the scope of the appended claims.

Claims

1. A method of batch task execution, comprising:

2. The method of claim 1, wherein determining the initial bill that has expired by the current date and is unprocessed according to the business data in the cluster list table comprises:

obtaining repayment information of all the service data in the cluster list table;

and screening all the bills to be paid which are expired by the current date and unprocessed in the business data based on the payment information, and determining all the bills to be paid as the initial bills.

3. The method of claim 1 or 2, further comprising, prior to said calculating the initial bill for the current date:

and writing the initial bill into a temporary file, and transmitting the temporary file to a service processing module through a network transmission protocol so that the service processing module analyzes the temporary file.

4. The method of claim 3, wherein calculating the initial bill for the current date and generating a bill calculation data table comprises:

and performing overdue calculation on the initial bill in the temporary file through the business processing module, and writing an overdue calculation result into the bill calculation data table.

5. The method of claim 1, wherein determining the target bill for the next day of the current date based on the order number of the initial bill and the repayment status change of the initial bill from the current date to the next day of the current date comprises:

acquiring the repayment state change of the initial bills corresponding to all the order numbers from the current date to the next day of the current date;

6. The method of claim 5, wherein obtaining the change of the payment status of the initial bills corresponding to all the order numbers from the current date to the next day of the current date comprises:

and obtaining the repayment state change of the initial bills corresponding to all the order numbers from the current date to the next day of the current date through multiple threads.

7. The method of claim 1, wherein performing a batching task on the target bill comprises:

and updating the business data table according to the target bill, and executing batch running tasks on the target bill in the updated business data table.

8. A batching task executing apparatus, comprising:

9. A server, characterized in that the server comprises:

one or more processors;

a memory for storing one or more programs;

when executed by the one or more processors, cause the one or more processors to implement the batching task execution method as recited in any one of claims 1-7.

10. A computer-readable storage medium, on which a computer program is stored, which, when being executed by a processor, carries out a batching task execution method according to any one of claims 1-7.