CN111127181B - Voucher accounting method and device - Google Patents
Voucher accounting method and device Download PDFInfo
- Publication number
- CN111127181B CN111127181B CN201911347589.1A CN201911347589A CN111127181B CN 111127181 B CN111127181 B CN 111127181B CN 201911347589 A CN201911347589 A CN 201911347589A CN 111127181 B CN111127181 B CN 111127181B
- Authority
- CN
- China
- Prior art keywords
- accounting
- data
- voucher
- credential
- request
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 107
- 238000012544 monitoring process Methods 0.000 claims abstract description 88
- 238000012545 processing Methods 0.000 claims abstract description 73
- 230000008569 process Effects 0.000 claims abstract description 64
- 238000003860 storage Methods 0.000 claims description 13
- 238000004590 computer program Methods 0.000 claims description 10
- 238000004364 calculation method Methods 0.000 claims description 6
- 238000005096 rolling process Methods 0.000 claims description 6
- 230000002159 abnormal effect Effects 0.000 claims description 5
- 238000000926 separation method Methods 0.000 abstract description 6
- 238000010586 diagram Methods 0.000 description 18
- 238000004891 communication Methods 0.000 description 7
- 230000006870 function Effects 0.000 description 7
- 238000005111 flow chemistry technique Methods 0.000 description 5
- 230000008901 benefit Effects 0.000 description 4
- 230000000903 blocking effect Effects 0.000 description 4
- 230000004048 modification Effects 0.000 description 4
- 238000012986 modification Methods 0.000 description 4
- 230000003287 optical effect Effects 0.000 description 4
- 230000005540 biological transmission Effects 0.000 description 3
- 239000000835 fiber Substances 0.000 description 2
- 230000007246 mechanism Effects 0.000 description 2
- 230000000644 propagated effect Effects 0.000 description 2
- 239000004065 semiconductor Substances 0.000 description 2
- 230000005856 abnormality Effects 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000008859 change Effects 0.000 description 1
- 238000006243 chemical reaction Methods 0.000 description 1
- 238000010276 construction Methods 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000009826 distribution Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 230000008030 elimination Effects 0.000 description 1
- 238000003379 elimination reaction Methods 0.000 description 1
- 230000000977 initiatory effect Effects 0.000 description 1
- 238000002955 isolation Methods 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 239000013307 optical fiber Substances 0.000 description 1
- 230000008929 regeneration Effects 0.000 description 1
- 238000011069 regeneration method Methods 0.000 description 1
- 230000001105 regulatory effect Effects 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 239000002699 waste material Substances 0.000 description 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/12—Accounting
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q30/00—Commerce
- G06Q30/06—Buying, selling or leasing transactions
- G06Q30/0645—Rental transactions; Leasing transactions
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/54—Indexing scheme relating to G06F9/54
- G06F2209/548—Queue
Landscapes
- Engineering & Computer Science (AREA)
- Business, Economics & Management (AREA)
- Accounting & Taxation (AREA)
- Finance (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- General Business, Economics & Management (AREA)
- Strategic Management (AREA)
- Marketing (AREA)
- Economics (AREA)
- Development Economics (AREA)
- Software Systems (AREA)
- General Engineering & Computer Science (AREA)
- Technology Law (AREA)
- Financial Or Insurance-Related Operations Such As Payment And Settlement (AREA)
Abstract
The application discloses a voucher accounting method and device, and relates to the field of finance. One embodiment of the method comprises the following steps: after the business process is finished, basic data which corresponds to the business process and is used for generating the certificate is obtained so as to assemble and generate certificate accounting data and a certificate accounting request; generating corresponding monitoring data for the voucher accounting request, and respectively transmitting the voucher accounting request and the monitoring data to a first message queue and a second message queue; the first consumer obtains the voucher accounting data from the first message queue to assemble and generate the voucher, and the second consumer obtains corresponding monitoring data from the second message queue based on the request identification, and monitors the processing progress and state information of the voucher accounting data by the first consumer to update the monitoring data. The method realizes decoupling and separation of the business process and the voucher accounting, can allocate resources as required, and improves the processing efficiency and stability of the financial leasing process.
Description
Technical Field
The application relates to the field of finance, in particular to a certificate billing method and device.
Background
The financial lease refers to that a lessor purchases a fixed asset appointed by the lessor to the lessee according to the request of the lessee and the contract agreement of the lessee and the lessee, and the lessor pays the ownership, the use and the gain of the fixed asset in a period to the lessee on the premise that the lessor owns the ownership of the fixed asset. During the financial rental process, the voucher billing is an integral part.
The existing voucher accounting usually adopts a real-time blocking processing mode, and the voucher accounting and the business process are processed in the same thread. And simultaneously, as the business of financial institutions increases, when the system performance reaches the bottleneck, the resource expansion is required, and the certificate billing and the business flow are bound together, so that the same resource is required to be added. In addition, due to the specificity of the financial institutions, the situation that the service is intensively processed and the peak value is too high often occurs.
In the process of implementing the present application, the inventor finds that at least the following problems exist in the prior art:
in a real-time blocking processing mode, the processing error of the voucher accounting can cause the rollback of the business process to block the corresponding business process; when the resources are expanded, the business process and the voucher accounting have different resource occupation characteristics, and the same resources are added to cause resource waste; the peak value of the voucher accounting process cannot be smoothly filtered, and system stability is affected.
Disclosure of Invention
In view of this, the embodiment of the application provides a method and a device for billing a voucher, which realize the voucher billing and the state monitoring through a message queue after the business process is processed, realize the decoupling and separation of the business process and the voucher billing, allocate resources as required and improve the processing efficiency and the stability of the financial leasing process.
To achieve the above object, according to one aspect of an embodiment of the present application, there is provided a credential accounting method.
The credential accounting method of the embodiment of the application comprises the following steps: after the business process is finished, basic data which corresponds to the business process and is used for generating a voucher is obtained so as to assemble and generate voucher accounting data and a voucher accounting request; wherein the credential accounting request includes a request identification and the credential accounting data; generating corresponding monitoring data for the voucher accounting request, and respectively sending the voucher accounting request and the monitoring data to a first message queue and a second message queue; wherein the monitoring data comprises the request identification, the processing progress and the state information; the first consumer obtains the voucher accounting data from the first message queue to assemble and generate a voucher, and meanwhile, the second consumer obtains corresponding monitoring data from the second message queue based on the request identification, and monitors the processing progress and state information of the first consumer on the voucher accounting data to update the monitoring data.
Optionally, generating the credential accounting request includes: dividing the assembled and generated plurality of certificate billing data to obtain a plurality of groups of certificate billing data; generating corresponding voucher accounting requests for the plurality of sets of voucher accounting data respectively; wherein the credential accounting request includes the request identification and a set of credential accounting data therein; sending the credential accounting request to a first message queue comprising: and respectively sending the generated plurality of voucher accounting requests to a first message queue.
Optionally, the first consumer obtaining the credential accounting data from the first message queue comprises: the credential accounting data is obtained concurrently from a plurality of credential accounting requests of the first message queue, respectively, using a plurality of first consumers.
Optionally, the credential includes: a certificate main table, a certificate extension table and a certificate entry table; assembling the generated credentials, comprising: generating a voucher according to the set generation rule and the acquired voucher accounting data; the generation rule is provided with limiting conditions of field names and corresponding field values of the certificate main table, the certificate extension table and the certificate entry table, and calculation sequence and rolling stock.
Optionally, monitoring the processing progress and status information of the credential accounting data by the first consumer to update the monitoring data includes: the second consumer polls the first consumer through the request identifier to acquire the processing progress and state information of the first consumer on the voucher accounting data; after the first consumer processes all of the credential accounting data for the credential accounting request, the second consumer updates the monitoring data.
Optionally, the method further comprises: and retrying the abnormal certificate billing data according to the processing progress and the state information of the monitoring data.
Optionally, obtaining basic data corresponding to the business process for generating credentials includes: and inquiring and acquiring basic data for generating the certificate in a database according to the set configuration file and the primary key of the business process.
To achieve the above object, according to another aspect of an embodiment of the present application, there is provided a credential accounting device.
The embodiment of the application provides a credential accounting device, which comprises: the data assembling module is used for acquiring basic data which corresponds to the business process and is used for generating the certificate after the business process is finished so as to assemble and generate certificate accounting data and a certificate accounting request; wherein the credential accounting request includes a request identification and the credential accounting data; the data sending module is used for generating corresponding monitoring data for the voucher accounting request and sending the voucher accounting request and the monitoring data to a first message queue and a second message queue respectively; wherein the monitoring data comprises the request identification, the processing progress and the state information; and the billing monitoring module is used for acquiring the voucher billing data from the first message queue by the first consumer to assemble and generate a voucher, acquiring corresponding monitoring data from the second message queue by the second consumer based on the request identification, and monitoring the processing progress and state information of the voucher billing data by the first consumer to update the monitoring data.
Optionally, the data assembling module is further configured to: dividing the assembled and generated plurality of certificate billing data to obtain a plurality of groups of certificate billing data; generating corresponding voucher accounting requests for the plurality of sets of voucher accounting data respectively; wherein the credential accounting request includes the request identification and a set of credential accounting data therein; the data sending module is further configured to: and respectively sending the generated plurality of voucher accounting requests to a first message queue.
Optionally, the accounting monitoring module is further configured to: the credential accounting data is obtained concurrently from a plurality of credential accounting requests of the first message queue, respectively, using a plurality of first consumers.
Optionally, the credential includes: a certificate main table, a certificate extension table and a certificate entry table; the accounting monitoring module is further configured to: generating a voucher according to the set generation rule and the acquired voucher accounting data; the generation rule is provided with limiting conditions of field names and corresponding field values of the certificate main table, the certificate extension table and the certificate entry table, and calculation sequence and rolling stock.
Optionally, the accounting monitoring module is further configured to: the second consumer polls the first consumer through the request identifier to acquire the processing progress and state information of the first consumer on the voucher accounting data; after the first consumer processes all of the credential accounting data for the credential accounting request, the second consumer updates the monitoring data.
Optionally, the apparatus further comprises: and the retry module is used for retrying the certificate accounting data for processing the abnormality according to the processing progress and the state information of the monitoring data.
Optionally, the data assembling module is further configured to: and inquiring and acquiring basic data for generating the certificate in a database according to the set configuration file and the primary key of the business process.
To achieve the above object, according to still another aspect of the embodiments of the present application, there is provided an electronic device.
An electronic device according to an embodiment of the present application includes: one or more processors; and the storage device is used for storing one or more programs, and when the one or more programs are executed by the one or more processors, the one or more processors are enabled to realize the credential accounting method of the embodiment of the application.
To achieve the above object, according to still another aspect of the embodiments of the present application, there is provided a computer-readable medium.
A computer readable medium of an embodiment of the present application has stored thereon a computer program which, when executed by a processor, implements a credential accounting method of an embodiment of the present application.
One embodiment of the above application has the following advantages or benefits: after the business process is processed, the voucher accounting and the state monitoring are realized through the message queue, so that the decoupling and separation of the business process and the voucher accounting are realized, resources can be allocated as required, and the processing efficiency and the stability of the financial leasing process are improved; when the number of the voucher accounting data is too large, grouping processing is carried out, so that the transmission efficiency of the voucher accounting request is improved; and a plurality of consumers are used for concurrently processing a plurality of voucher accounting requests, so that the processing efficiency is further improved.
One embodiment of the above application has the following advantages or benefits: generating a certificate according to a set generation rule, and ensuring the validity of the generated certificate; the second consumer polls and inquires the first consumer, records the processing result of the voucher accounting request, prevents the unprocessed voucher accounting request from being lost and omitted, and ensures the data security; automatically retrying the abnormal voucher accounting data according to the monitoring data to ensure the effective processing of each voucher accounting data; the peak value of the credential processing is smoothed based on the message queue, so that a message producer is not influenced by the blocking of a message consumer, and the stability of the financial leasing process is ensured.
Further effects of the above-described non-conventional alternatives are described below in connection with the embodiments.
Drawings
The drawings are included to provide a better understanding of the application and are not to be construed as unduly limiting the application. Wherein:
FIG. 1 is a schematic diagram of the main steps of a credential accounting method according to an embodiment of the application;
FIG. 2 is a schematic diagram of the main flow of a credential accounting method in accordance with an embodiment of the present application;
FIG. 3 is a schematic diagram of a data processing flow of a first consumer in accordance with an embodiment of the present application;
FIG. 4 is a schematic diagram of the main modules of a credential accounting device in accordance with an embodiment of the application;
FIG. 5 is an exemplary system architecture diagram in which embodiments of the present application may be applied;
fig. 6 is a schematic structural diagram of a computer device suitable for use in an electronic apparatus to implement an embodiment of the present application.
Detailed Description
Exemplary embodiments of the present application will now be described with reference to the accompanying drawings, in which various details of the embodiments of the present application are included to facilitate understanding, and are to be considered merely exemplary. Accordingly, those of ordinary skill in the art will recognize that various changes and modifications of the embodiments described herein can be made without departing from the scope and spirit of the application. Also, descriptions of well-known functions and constructions are omitted in the following description for clarity and conciseness.
Fig. 1 is a schematic diagram of the main steps of a credential accounting method according to an embodiment of the application. As shown in fig. 1, the credential accounting method in the embodiment of the present application mainly includes the following steps:
step S101: and after the business process is finished, acquiring basic data which corresponds to the business process and is used for generating the voucher so as to assemble and generate voucher accounting data and a voucher accounting request. The financial leasing process comprises business flow processing and voucher accounting process, and the real-time requirement of voucher accounting is low, so that in the embodiment, after the business flow processing is finished, basic data corresponding to the business flow is obtained from a database, and voucher accounting data is generated by assembling, wherein the basic data comprises all elements required by voucher generation. After generating the credential accounting data, a credential accounting request is generated, the credential accounting request including a request identification and the credential accounting data.
Step S102: and generating corresponding monitoring data for the voucher accounting request, and respectively sending the voucher accounting request and the monitoring data to a first message queue and a second message queue. Unique monitoring data is generated for the credential accounting request including request identification, processing progress and status information. The credential accounting request is then sent to the first message queue and the monitoring data is sent to the second message queue.
Step S103: the first consumer obtains the voucher accounting data from the first message queue to assemble and generate a voucher, and meanwhile, the second consumer obtains corresponding monitoring data from the second message queue based on the request identification, and monitors the processing progress and state information of the first consumer on the voucher accounting data to update the monitoring data.
The first consumer obtains the credential accounting data from the first message queue for consumption. The consumption process is as follows: and assembling and generating the certificate according to the pre-configured generation rule and the acquired certificate accounting data, and storing the certificate. And simultaneously, the second consumer acquires corresponding monitoring data from the second message queue based on the request identifier, polls the first consumer based on the request identifier to acquire the processing progress and state information of the first consumer on the voucher accounting data, and then updates the acquired monitoring data.
The embodiment realizes decoupling and separation of business flow processing and voucher accounting process in the financial leasing process, can smooth the peak value of voucher processing, and ensures the stability and processing efficiency of the financial leasing process.
Fig. 2 is a schematic flow diagram of a credential accounting method in accordance with an embodiment of the application. As shown in fig. 2, the credential accounting method in the embodiment of the present application mainly includes the following steps:
step S201: after the business process is completed, the fields for the voucher accounting are queried by calling an application program interface to assemble and generate voucher accounting data. The application program interfaces are realized uniformly, and the realized functions are as follows: and associating the business process with the corresponding certificate through the configuration file, and then inquiring the required elements in the database according to the configuration file of the certificate and the relevant primary key of the business process.
The credential accounting data meets the elements required for the credential generation process, in one embodiment a standard set of data structures, including: billing date, accounting institution, contract number, subject number, occurrence, transaction type, auxiliary accounting code, etc.
Step S202: and generating a voucher accounting request according to the voucher accounting data, and generating corresponding monitoring information for the voucher accounting request. In an embodiment, the credential accounting request includes: the main key of the business flow of the transaction, the request identification, the system related information and the voucher accounting data, and the system related information comprises operators, operation time and the like.
When corresponding monitoring information is generated for the voucher accounting request, the relevance between the voucher accounting request and the monitoring information needs to be determined and determined uniquely according to the dimensions of the voucher type, the associated record number, the accounting date and the like, and meanwhile auxiliary monitoring information is counted. The certificate types comprise a plurality of certificate types such as contract creation, asset accounting, information adjustment and change, collection and accounting and the like. The associated record number is the global number (namely the request identifier) of the current request, and all information of the current request can be found through the number.
Wherein, the monitoring information includes: the main key of the current request, the credential code, the request identifier, the processing state information description, the auxiliary monitoring information and the like. The monitoring information is used for polling the voucher accounting request (possibly including a plurality of voucher generation and respectively inquiring the generation states) through the request identification, and summarizing the specific states of the request. The auxiliary monitoring information is auxiliary summary of the voucher accounting data, and comprises the number of data pieces, operators, operation time and the like. Wherein the number of data pieces is the number of voucher accounting data pieces.
The data of a voucher accounting request is inserted into the database and then operates according to the data of the database. The voucher accounting request corresponds to the monitoring information one by one, all transaction information and transaction states can be obtained directly through the database, and modification and regeneration can be carried out based on the transaction information and the transaction states.
Step S203: the credential posting request is sent to the first message queue while the monitoring data is sent to the second message queue. The first message queue is used for generating the certificate, and the second message queue is used for monitoring the certificate.
In a preferred embodiment, if the one voucher billing request contains an excessive number of voucher billing data pieces to be generated, then the plurality of voucher billing data pieces may be split and a plurality of generated messages may be sent separately for concurrent processing using a plurality of generated consumers.
Step S204: the first consumer obtains the credential accounting data from the first message queue for consumption to generate the credential. In an embodiment, the voucher billing data is consumed, i.e. the voucher is assembled according to the generation rules configured in the system and the acquired voucher billing data. The generated certificates comprise a certificate main table, a certificate extension table and a certificate entry table, wherein the entry table comprises a calculation sequence, a rolling stock and the like.
In a preferred embodiment, the OGNL expression may be employed to generate the voucher based on the data content of the voucher accounting data. OGLL is an abbreviation of Object-Graph Navigation Language, is a powerful expression language, can access any attribute of an Object through simple consistent expression grammar, calls a method of the Object, traverses a structure diagram of the whole Object, and achieves functions such as field type conversion.
Step S205: the second consumer acquires monitoring data from the second message queue, monitors the processing progress and status information of the first consumer on the voucher accounting data, and determines overall processing progress and status information. The second consumer obtains the required monitoring data from the second message queue based on the request identification.
The implementation process for judging the overall processing progress and the state information is as follows: the first consumer is polled and scanned to check the unique corresponding certificate billing, and the overall processing progress and state are judged through methods of processing state checking, record number matching and the like. The processing progress refers to how many pieces of voucher accounting data are processed, and the processing state is a summary of all the current processed voucher accounting data recording states. The record number matching is that the second consumer compares record number information in the monitoring data with the processing state queried through the polling request identification.
In an embodiment, the processing state of the first consumer comprises: initialization, processing success, processing failure, system error. The processing state of the second consumer includes: pending, partially successful, fully failed. In an embodiment, step S204 and step S205 are performed simultaneously.
Step S206: after the first consumer has processed all messages of the voucher accounting request, the second consumer updates the final state of the corresponding monitoring data. In a preferred embodiment, when an exception occurs in the system, the message queue records the error information, and the unprocessed voucher accounting request is saved, so that the memory data is prevented from being lost. In addition, the processing results can be displayed through the account, and meanwhile, the voucher accounting retry processing can be manually/automatically initiated according to the error reason. The method comprises the steps of automatically initiating the voucher accounting retry process, and configuring corresponding logic in a system according to an actual service scene to realize the voucher accounting retry.
In the above embodiment, since the message queue itself is a processing mode of an asynchronous peak elimination mechanism, the message producer is not affected by the congestion of the message consumer. In addition, because the front-end and back-end isolation mechanism of the message queue is adopted, when the voucher accounting method of the embodiment is used, the actual business flow module and the voucher accounting module are not in one-to-one relationship. Therefore, the service quantity required to be started in deployment is not required to be consistent, and the service quantity can be proportionally regulated according to the service scene, so that the distribution according to the requirement is realized.
FIG. 3 is a schematic diagram of a data processing flow of a first consumer according to an embodiment of the present application. As shown in fig. 3, the processing of the credential accounting request by the first consumer according to the embodiment of the present application mainly includes the following steps:
step S301: the plurality of first consumers concurrently obtain credential accounting data from the plurality of credential accounting requests of the first message queue, respectively. When the number of the voucher accounting data pieces assembled in step S201 exceeds the set threshold, the assembled voucher accounting data pieces are grouped and sent to the first message queue through a plurality of voucher accounting requests. Each credential accounting request includes a set of credential accounting data. Subsequently, the plurality of first consumers are concurrently used to obtain credential accounting data from the first message queue.
Step S302: the first consumers respectively assemble the generation certificates according to the pre-configured generation rules and the certificate billing data acquired by the first consumers respectively. The generation rule is provided with a limiting condition of field names and corresponding field values of a certificate main table, a certificate extension table and a certificate entry table, and a calculation sequence and a rolling stock. The generated certificates comprise a certificate main table, a certificate extension table and a certificate entry table, wherein the entry table comprises a calculation sequence, a rolling stock and the like.
Step S303: the plurality of first consumers store the generated credentials to the database, respectively. After generating the certificate, the certificate is stored in a database.
According to the voucher accounting method, after the business flow is processed, voucher accounting and state monitoring are achieved through the message queue, decoupling and separation of the business flow and voucher accounting are achieved, resources can be allocated according to needs, and processing efficiency and stability of a financial lease process are improved; when the number of the voucher accounting data is too large, grouping processing is carried out, so that the transmission efficiency of the voucher accounting request is improved; and a plurality of consumers are used for concurrently processing a plurality of voucher accounting requests, so that the processing efficiency is further improved.
According to the voucher accounting method, the voucher is generated according to the set generation rule, and the validity of the generated voucher is guaranteed; the second consumer polls and inquires the first consumer, records the processing result of the voucher accounting request, prevents the unprocessed voucher accounting request from being lost and omitted, and ensures the data security; automatically retrying the abnormal voucher accounting data according to the monitoring data to ensure the effective processing of each voucher accounting data; the peak value of the credential processing is smoothed based on the message queue, so that a message producer is not influenced by the blocking of a message consumer, and the stability of the financial leasing process is ensured.
Fig. 4 is a schematic diagram of main modules of a credential accounting apparatus according to an embodiment of the application. As shown in fig. 4, the credential accounting device 400 according to an embodiment of the present application mainly includes:
and the data assembling module 401 is configured to obtain, after the business process is finished, basic data for generating a credential corresponding to the business process, so as to assemble and generate credential accounting data and a credential accounting request. The financial leasing process comprises business flow processing and voucher accounting process, and the real-time requirement of voucher accounting is low, so that in the embodiment, after the business flow processing is finished, basic data corresponding to the business flow is obtained from a database, and voucher accounting data is generated by assembling, wherein the basic data comprises all elements required by voucher generation. After generating the credential accounting data, a credential accounting request is generated, the credential accounting request including a request identification and the credential accounting data.
The data sending module 402 is configured to generate corresponding monitoring data for the credential accounting request, and send the credential accounting request and the monitoring data to a first message queue and a second message queue respectively. Unique monitoring data is generated for the credential accounting request including request identification, processing progress and status information. The credential accounting request is then sent to the first message queue and the monitoring data is sent to the second message queue.
And the accounting monitoring module 403 is configured to obtain the credential accounting data from the first message queue by a first consumer to assemble and generate a credential, and obtain corresponding monitoring data from the second message queue by a second consumer based on the request identifier, and monitor a processing progress and status information of the first consumer on the credential accounting data to update the monitoring data.
The first consumer obtains the credential accounting data from the first message queue for consumption. The consumption process is as follows: and assembling and generating the certificate according to the pre-configured generation rule and the acquired certificate accounting data, and storing the certificate. And simultaneously, the second consumer acquires corresponding monitoring data from the second message queue based on the request identifier, polls the first consumer based on the request identifier to acquire the processing progress and state information of the first consumer on the voucher accounting data, and then updates the acquired monitoring data.
In addition, the credential accounting device 400 of an embodiment of the present application may further include: a retry module (not shown in fig. 4) for retrying the abnormal handling of the accounting data according to the progress and status information of the monitoring data.
From the above description, it can be seen that the credentials are generated according to the set generation rules, so as to ensure the validity of the generated credentials; the second consumer polls and inquires the first consumer, records the processing result of the voucher accounting request, prevents the unprocessed voucher accounting request from being lost and omitted, and ensures the data security.
Fig. 5 illustrates an exemplary system architecture 500 in which the credential accounting method or credential accounting device of embodiments of the present application can be applied.
As shown in fig. 5, the system architecture 500 may include terminal devices 501, 502, 503, a network 504, and a server 505. The network 504 is used as a medium to provide communication links between the terminal devices 501, 502, 503 and the server 505. The network 504 may include various connection types, such as wired, wireless communication links, or fiber optic cables, among others.
A user may interact with the server 505 via the network 504 using the terminal devices 501, 502, 503 to receive or send messages or the like. Various communication client applications, such as shopping class applications, web browser applications, search class applications, instant messaging tools, mailbox clients, social platform software, etc., may be installed on the terminal devices 501, 502, 503.
The terminal devices 501, 502, 503 may be a variety of electronic devices having a display screen and supporting web browsing, including but not limited to smartphones, tablets, laptop and desktop computers, and the like.
The server 505 may be a server providing various services. The server may obtain the basic data, generate the credential accounting data, the credential accounting request and the monitoring data, send the credential accounting request and the monitoring data, generate the credential, and the like, and feed back the processing result (e.g., the generated credential) to the terminal device.
It should be noted that, the credential accounting method provided by the embodiment of the present application is generally performed by the server 505, and accordingly, the credential accounting device is generally disposed in the server 505.
It should be understood that the number of terminal devices, networks and servers in fig. 5 is merely illustrative. There may be any number of terminal devices, networks, and servers, as desired for implementation.
According to an embodiment of the application, the application further provides an electronic device and a computer readable medium.
The electronic device of the present application includes: one or more processors; and the storage device is used for storing one or more programs, and when the one or more programs are executed by the one or more processors, the one or more processors are enabled to realize the credential accounting method of the embodiment of the application.
The computer readable medium of the present application has stored thereon a computer program which when executed by a processor implements a credential accounting method of an embodiment of the present application.
Referring now to FIG. 6, there is illustrated a schematic diagram of a computer system 600 suitable for use in implementing an electronic device of an embodiment of the present application. The electronic device shown in fig. 6 is only an example and should not be construed as limiting the functionality and scope of use of the embodiments of the application.
As shown in fig. 6, the computer system 600 includes a Central Processing Unit (CPU) 601, which can perform various appropriate actions and processes according to a program stored in a Read Only Memory (ROM) 602 or a program loaded from a storage section 608 into a Random Access Memory (RAM) 603. In the RAM 603, various programs and data required for the operation of the computer system 600 are also stored. The CPU 601, ROM 602, and RAM 603 are connected to each other through a bus 604. An input/output (I/O) interface 605 is also connected to bus 604.
The following components are connected to the I/O interface 605: an input portion 606 including a keyboard, mouse, etc.; an output portion 607 including a Cathode Ray Tube (CRT), a Liquid Crystal Display (LCD), and the like, a speaker, and the like; a storage section 608 including a hard disk and the like; and a communication section 609 including a network interface card such as a LAN card, a modem, or the like. The communication section 609 performs communication processing via a network such as the internet. The drive 610 is also connected to the I/O interface 605 as needed. Removable media 611 such as a magnetic disk, an optical disk, a magneto-optical disk, a semiconductor memory, or the like is installed as needed on drive 610 so that a computer program read therefrom is installed as needed into storage section 608.
In particular, the processes described above in the main step diagrams may be implemented as computer software programs according to the disclosed embodiments of the application. For example, embodiments of the present disclosure include a computer program product comprising a computer program embodied on a computer readable medium, the computer program comprising program code for performing the method shown in the main step diagrams. In such an embodiment, the computer program may be downloaded and installed from a network through the communication portion 609, and/or installed from the removable medium 611. The above-described functions defined in the system of the present application are performed when the computer program is executed by a Central Processing Unit (CPU) 601.
The computer readable medium shown in the present application may be a computer readable signal medium or a computer readable storage medium, or any combination of the two. The computer readable storage medium can be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or a combination of any of the foregoing. More specific examples of the computer-readable storage medium may include, but are not limited to: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device. In the present application, however, the computer-readable signal medium may include a data signal propagated in baseband or as part of a carrier wave, with the computer-readable program code embodied therein. Such a propagated data signal may take any of a variety of forms, including, but not limited to, electro-magnetic, optical, or any suitable combination of the foregoing. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device. Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to: wireless, wire, fiber optic cable, RF, etc., or any suitable combination of the foregoing.
The flowcharts and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present application. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams or flowchart illustration, and combinations of blocks in the block diagrams or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions.
The modules involved in the embodiments of the present application may be implemented in software or in hardware. The described modules may also be provided in a processor, for example, as: a processor includes a data assembly module, a data transmission module, and a billing monitoring module. The names of these modules do not limit the module itself in some cases, for example, the data assembling module may also be described as "after the business process is finished, obtain the basic data for generating the credential corresponding to the business process, so as to assemble the module for generating the credential accounting data and the credential accounting request".
As another aspect, the present application also provides a computer-readable medium that may be contained in the apparatus described in the above embodiments; or may be present alone without being fitted into the device. The computer readable medium carries one or more programs which, when executed by a device, cause the device to include: after the business process is finished, basic data which corresponds to the business process and is used for generating a voucher is obtained so as to assemble and generate voucher accounting data and a voucher accounting request; wherein the credential accounting request includes a request identification and the credential accounting data; generating corresponding monitoring data for the voucher accounting request, and respectively sending the voucher accounting request and the monitoring data to a first message queue and a second message queue; wherein the monitoring data comprises the request identification, the processing progress and the state information; the first consumer obtains the voucher accounting data from the first message queue to assemble and generate a voucher, and meanwhile, the second consumer obtains corresponding monitoring data from the second message queue based on the request identification, and monitors the processing progress and state information of the first consumer on the voucher accounting data to update the monitoring data.
From the above description, after the business process is processed, the voucher accounting and the state monitoring are realized through the message queue, so that the decoupling and separation of the business process and the voucher accounting are realized, the resources can be allocated as required, and the processing efficiency and the stability of the financial leasing process are improved.
The product can execute the method provided by the embodiment of the application, and has the corresponding functional modules and beneficial effects of the execution method. Technical details not described in detail in this embodiment may be found in the methods provided in the embodiments of the present application.
The above embodiments do not limit the scope of the present application. It will be apparent to those skilled in the art that various modifications, combinations, sub-combinations and alternatives can occur depending upon design requirements and other factors. Any modifications, equivalent substitutions and improvements made within the spirit and principles of the present application should be included in the scope of the present application.
Claims (10)
1. A method of credentialing, comprising:
after the business process is finished, basic data which corresponds to the business process and is used for generating a voucher is obtained so as to assemble and generate voucher accounting data and a voucher accounting request; wherein the credential accounting request includes a request identification and the credential accounting data;
generating corresponding monitoring data for the voucher accounting request, and respectively sending the voucher accounting request and the monitoring data to a first message queue and a second message queue; wherein the monitoring data comprises the request identification, the processing progress and the state information;
the first consumer obtains the voucher accounting data from the first message queue to assemble and generate a voucher, and meanwhile, the second consumer obtains corresponding monitoring data from the second message queue based on the request identification, and monitors the processing progress and state information of the first consumer on the voucher accounting data to update the monitoring data.
2. The method of claim 1, wherein generating the credential accounting request comprises:
dividing the assembled and generated plurality of certificate billing data to obtain a plurality of groups of certificate billing data;
generating corresponding voucher accounting requests for the plurality of sets of voucher accounting data respectively; wherein the credential accounting request includes the request identification and a set of credential accounting data therein;
sending the credential accounting request to a first message queue comprising: and respectively sending the generated plurality of voucher accounting requests to a first message queue.
3. The method of claim 2, wherein the first consumer obtaining the credential accounting data from the first message queue comprises:
the credential accounting data is obtained concurrently from a plurality of credential accounting requests of the first message queue, respectively, using a plurality of first consumers.
4. The method of claim 1, wherein the credential comprises: a certificate main table, a certificate extension table and a certificate entry table;
assembling the generated credentials, comprising: generating a voucher according to the set generation rule and the acquired voucher accounting data; the generation rule is provided with limiting conditions of field names and corresponding field values of the certificate main table, the certificate extension table and the certificate entry table, and calculation sequence and rolling stock.
5. The method of claim 1, wherein monitoring progress and status information of processing of the credential accounting data by the first consumer to update the monitoring data comprises:
the second consumer polls the first consumer through the request identifier to acquire the processing progress and state information of the first consumer on the voucher accounting data;
after the first consumer processes all of the credential accounting data for the credential accounting request, the second consumer updates the monitoring data.
6. The method of claim 5, wherein the method further comprises:
and retrying the abnormal certificate billing data according to the processing progress and the state information of the monitoring data.
7. The method according to any one of claims 1 to 6, wherein obtaining basic data for generating credentials corresponding to the business process comprises:
and inquiring and acquiring basic data for generating the certificate in a database according to the set configuration file and the primary key of the business process.
8. A credential accounting device, comprising:
the data assembling module is used for acquiring basic data which corresponds to the business process and is used for generating the certificate after the business process is finished so as to assemble and generate certificate accounting data and a certificate accounting request; wherein the credential accounting request includes a request identification and the credential accounting data;
the data sending module is used for generating corresponding monitoring data for the voucher accounting request and sending the voucher accounting request and the monitoring data to a first message queue and a second message queue respectively; wherein the monitoring data comprises the request identification, the processing progress and the state information;
and the billing monitoring module is used for acquiring the voucher billing data from the first message queue by the first consumer to assemble and generate a voucher, acquiring corresponding monitoring data from the second message queue by the second consumer based on the request identification, and monitoring the processing progress and state information of the voucher billing data by the first consumer to update the monitoring data.
9. An electronic device, comprising:
one or more processors;
storage means for storing one or more programs,
when executed by the one or more processors, causes the one or more processors to implement the method of any of claims 1-7.
10. A computer readable medium, on which a computer program is stored, characterized in that the program, when being executed by a processor, implements the method according to any of claims 1-7.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911347589.1A CN111127181B (en) | 2019-12-24 | 2019-12-24 | Voucher accounting method and device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911347589.1A CN111127181B (en) | 2019-12-24 | 2019-12-24 | Voucher accounting method and device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN111127181A CN111127181A (en) | 2020-05-08 |
| CN111127181B true CN111127181B (en) | 2023-10-31 |
Family
ID=70501927
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201911347589.1A Active CN111127181B (en) | 2019-12-24 | 2019-12-24 | Voucher accounting method and device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111127181B (en) |
Families Citing this family (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112634005A (en) * | 2020-12-30 | 2021-04-09 | 上海中通吉网络技术有限公司 | Method and device for generating financial certificate and electronic equipment |
| CN113781191A (en) * | 2021-07-21 | 2021-12-10 | 望海康信(北京)科技股份公司 | Automatic certificate marking method and system, corresponding equipment and storage medium |
| CN114529301A (en) * | 2022-02-21 | 2022-05-24 | 山东浪潮通软信息科技有限公司 | Voucher posting method, device, equipment and medium |
| CN114819780A (en) * | 2022-07-01 | 2022-07-29 | 得分数字科技(珠海)有限公司 | Process data monitoring method and device, storage medium and computer equipment |
| CN116362816B (en) * | 2023-05-30 | 2023-09-26 | 浙江爱信诺航天信息技术有限公司 | Voucher information omission recognition and processing method, system and medium |
| CN117934190B (en) * | 2024-03-20 | 2024-05-28 | 深圳市雁联计算系统有限公司 | Heterogeneous billing method and system based on message middleware and distributed lock |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107657516A (en) * | 2016-07-24 | 2018-02-02 | 平安科技（深圳）有限公司 | Generate the method and financial server of voucher |
| CN109493205A (en) * | 2018-10-16 | 2019-03-19 | 深圳壹账通智能科技有限公司 | Intelligent bookkeeping methods, computer readable storage medium and terminal device |
| CN110348976A (en) * | 2019-06-04 | 2019-10-18 | 深圳前海新心金融管理有限公司 | Financial core accounting system based on transaction journal |
| CN110533503A (en) * | 2019-08-12 | 2019-12-03 | 厦门网宿有限公司 | A kind of data processing method and device |
Family Cites Families (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9887990B2 (en) * | 2016-04-25 | 2018-02-06 | International Business Machines Corporation | Protection of application passwords using a secure proxy |
-
2019
- 2019-12-24 CN CN201911347589.1A patent/CN111127181B/en active Active
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107657516A (en) * | 2016-07-24 | 2018-02-02 | 平安科技（深圳）有限公司 | Generate the method and financial server of voucher |
| CN109493205A (en) * | 2018-10-16 | 2019-03-19 | 深圳壹账通智能科技有限公司 | Intelligent bookkeeping methods, computer readable storage medium and terminal device |
| CN110348976A (en) * | 2019-06-04 | 2019-10-18 | 深圳前海新心金融管理有限公司 | Financial core accounting system based on transaction journal |
| CN110533503A (en) * | 2019-08-12 | 2019-12-03 | 厦门网宿有限公司 | A kind of data processing method and device |
Also Published As
| Publication number | Publication date |
|---|---|
| CN111127181A (en) | 2020-05-08 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111127181B (en) | Voucher accounting method and device | |
| CN109844727B (en) | Techniques for managing application configuration and associated credentials | |
| US8548442B2 (en) | Syndication of multiple service instances | |
| CN111277639B (en) | Method and device for maintaining data consistency | |
| CN112288577B (en) | Transaction processing method, device, electronic equipment and medium for distributed service | |
| CN111460129A (en) | Method and device for generating identification, electronic equipment and storage medium | |
| CN111427701A (en) | Workflow engine system and business processing method | |
| CN110706093A (en) | Accounting processing method and device | |
| CN111881329A (en) | Account balance management method and system | |
| CN111478781B (en) | Message broadcasting method and device | |
| CN109428926B (en) | Method and device for scheduling task nodes | |
| CN114979295B (en) | Gateway management method and device | |
| CN112381453A (en) | Information processing method, information processing apparatus, electronic device, and medium | |
| CN111427899A (en) | Method, device, equipment and computer readable medium for storing file | |
| CN110245014B (en) | Data processing method and device | |
| CN114827280A (en) | Request processing method, device, equipment and medium | |
| CN113742389A (en) | Service processing method and device | |
| CN114612212A (en) | Business processing method, device and system based on risk control | |
| CN112671877B (en) | Data processing method and device | |
| CN112948138A (en) | Method and device for processing message | |
| CN116258556A (en) | Method, device, electronic equipment and storage medium for processing business data | |
| CN114417318A (en) | Third-party page jumping method and device and electronic equipment | |
| CN113760487A (en) | Service processing method and device | |
| CN111210349A (en) | Virtual asset transfer hosting method and device, electronic equipment and storage medium | |
| CN113242306B (en) | Block chain consensus method and device |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| TA01 | Transfer of patent application right | ||
| TA01 | Transfer of patent application right |
Effective date of registration: 20220922 Address after: 25 Financial Street, Xicheng District, Beijing 100033 Applicant after: CHINA CONSTRUCTION BANK Corp. Address before: 25 Financial Street, Xicheng District, Beijing 100033 Applicant before: CHINA CONSTRUCTION BANK Corp. Applicant before: Jianxin Financial Science and Technology Co.,Ltd. |
|
| GR01 | Patent grant | ||
| GR01 | Patent grant |