CN110827001A - Accounting event bookkeeping method, system, equipment and storage medium - Google Patents
Accounting event bookkeeping method, system, equipment and storage medium Download PDFInfo
- Publication number
- CN110827001A CN110827001A CN201911082133.7A CN201911082133A CN110827001A CN 110827001 A CN110827001 A CN 110827001A CN 201911082133 A CN201911082133 A CN 201911082133A CN 110827001 A CN110827001 A CN 110827001A
- Authority
- CN
- China
- Prior art keywords
- accounting
- event
- bookkeeping
- voucher
- account
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000000034 method Methods 0.000 title claims abstract description 51
- 238000012545 processing Methods 0.000 claims description 20
- 238000004590 computer program Methods 0.000 claims description 4
- 230000003287 optical effect Effects 0.000 description 6
- 238000010586 diagram Methods 0.000 description 4
- 230000006870 function Effects 0.000 description 4
- 238000012795 verification Methods 0.000 description 3
- 230000000694 effects Effects 0.000 description 2
- 239000013307 optical fiber Substances 0.000 description 2
- 230000002093 peripheral effect Effects 0.000 description 2
- 230000000644 propagated effect Effects 0.000 description 2
- 230000001133 acceleration Effects 0.000 description 1
- 238000003491 array Methods 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000004891 communication Methods 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000012552 review Methods 0.000 description 1
- 238000005204 segregation Methods 0.000 description 1
- 239000004065 semiconductor Substances 0.000 description 1
- 238000012358 sourcing Methods 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
Images
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
- G06Q10/00—Administration; Management
- G06Q10/10—Office automation; Time management
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/30—Information retrieval; Database structures therefor; File system structures therefor of unstructured textual data
- G06F16/31—Indexing; Data structures therefor; Storage structures
- G06F16/316—Indexing structures
-
- 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
- G06Q40/125—Finance or payroll
Landscapes
- Engineering & Computer Science (AREA)
- Business, Economics & Management (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- Accounting & Taxation (AREA)
- Finance (AREA)
- General Physics & Mathematics (AREA)
- Strategic Management (AREA)
- General Business, Economics & Management (AREA)
- Data Mining & Analysis (AREA)
- Marketing (AREA)
- Economics (AREA)
- Human Resources & Organizations (AREA)
- Entrepreneurship & Innovation (AREA)
- Development Economics (AREA)
- Databases & Information Systems (AREA)
- General Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Technology Law (AREA)
- Operations Research (AREA)
- Quality & Reliability (AREA)
- Tourism & Hospitality (AREA)
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
Abstract
Description
技术领域technical field
本发明实施例涉及会计技术,尤其涉及一种会计事件记账方法、系统、设备和存储介质。Embodiments of the present invention relate to accounting technology, and in particular, to an accounting event accounting method, system, device and storage medium.
背景技术Background technique
会计事件简单的说就是将有关财务性质的交易及事项,按照通行货币单位,加以记录、分类及汇总表达,而可将其结果予以分析与解释。凭证消息是指记录经济业务发生或者完成情况的书面证明,是登记账簿的依据。每个企业都必须按一定的程序填制和审核会计凭证,根据审核无误的会计凭证进行账簿登记,如实反映企业的经济业务。Simply put, accounting events are transactions and events of a financial nature that are recorded, classified and aggregated in accordance with the prevailing currency units, and the results can be analyzed and interpreted. Voucher information refers to a written certificate that records the occurrence or completion of economic business, and is the basis for registering account books. Every enterprise must fill in and review accounting vouchers in accordance with certain procedures, and conduct account book registration according to the audited and correct accounting vouchers, so as to truthfully reflect the economic business of the enterprise.
传统的会计记账实现方式采用分布式无状态集群,在账务处理中,资金从一方账户支出并转入另一方账户,对双方账户而言都有一个记账处理的过程。记账处理过程主要包括两部分,一部分是记录凭证消息,另一部分是更新账户余额。通常,每一次记账都需要对相关账号进行锁操作,从而避免其他操作对正在处理的账号进行再次操作造成数据不一致,因此锁是实现并发控制的主要方法。随着业务量的不断增大,某些热点账号会在瞬间产生大量的并发会计事件,但所有并发线程中只有一个线程能够持有当时的资源锁,其他线程必须等待锁被释放后再逐一进行记账处理,这种情况下,其他的线程都在等待,严重影响了账务系统的性能,记账出现瓶颈,此外会计事件记账顺序和发生顺序很难保证一致,难以满足数据实时一致性要求。The traditional method of accounting and bookkeeping uses distributed stateless clusters. In the accounting process, funds are spent from one account and transferred to the other account, and there is a bookkeeping process for both accounts. The accounting process mainly includes two parts, one part is to record the voucher message, and the other part is to update the account balance. Usually, each accounting requires a lock operation on the relevant account, so as to avoid data inconsistency caused by other operations on the account being processed again. Therefore, lock is the main method to achieve concurrency control. With the continuous increase of business volume, some hot accounts will generate a large number of concurrent accounting events in an instant, but only one thread of all concurrent threads can hold the resource lock at that time, and other threads must wait for the lock to be released before proceeding one by one. Accounting processing, in this case, other threads are waiting, which seriously affects the performance of the accounting system, and there is a bottleneck in accounting. In addition, it is difficult to ensure the consistency of the accounting event accounting sequence and the sequence of occurrence, and it is difficult to meet the real-time data consistency. Require.
发明内容SUMMARY OF THE INVENTION
本发明实施例提供一种会计事件记账方法、系统、设备和存储介质,以实现提高会计事件记账的效率以及保证记账顺序和发生顺序的一致性。Embodiments of the present invention provide an accounting event accounting method, system, device and storage medium, so as to improve the accounting event accounting efficiency and ensure the consistency of accounting sequence and occurrence sequence.
为达此目的,本发明实施例提供了一种会计事件记账方法、系统、设备和存储介质,该会计事件记账方法包括:For this purpose, the embodiment of the present invention provides an accounting event accounting method, system, device and storage medium, and the accounting event accounting method includes:
接收用户写入的会计事件,所述会计事件包括一个或多个账户的凭证消息;receiving an accounting event written by a user, the accounting event including credential messages for one or more accounts;
基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账。The corresponding voucher messages are routed to the same billing terminal based on the same account, so that the billing terminal queues and bills the voucher messages of the same account according to the time sequence of receipt.
进一步的,所述记账的方式遵循事件溯源的模式。Further, the accounting method follows the mode of event source tracing.
进一步的,所述基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账之后包括:Further, the corresponding voucher messages are routed to the same accounting terminal based on the same account, so that the accounting terminal queues the voucher messages of the same account according to the received time sequence, and includes after accounting. :
根据用户的查询请求反馈相应的所述凭证消息的记账状态。According to the user's query request, the corresponding accounting status of the voucher message is fed back.
进一步的,所述基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账之后包括:Further, the corresponding voucher messages are routed to the same accounting terminal based on the same account, so that the accounting terminal queues the voucher messages of the same account according to the received time sequence, and includes after accounting. :
对所述会计事件和凭证消息的一致性、所述凭证消息的记账状态以及账户平衡进行校验。The consistency of the accounting event and the voucher message, the billing state of the voucher message, and the account balance are checked.
进一步的,所述接收用户写入的会计事件之前包括:Further, before the receiving the accounting event written by the user includes:
配置用户的账户信息和记账规则。Configure user account information and accounting rules.
进一步的,所述接收用户写入的会计事件之前包括:Further, before the receiving the accounting event written by the user includes:
获取当前日切时刻。Get the current day cut time.
进一步的,所述基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账之后包括:Further, the corresponding voucher messages are routed to the same accounting terminal based on the same account, so that the accounting terminal queues the voucher messages of the same account according to the received time sequence, and includes after accounting. :
根据所述日切时刻对所述记账的内容进行科目汇总。The content of the bookkeeping is subject to summary according to the date and time.
一方面,本发明实施例还提供了一种会计事件记账系统,该会计事件记账系统包括:On the one hand, the embodiment of the present invention also provides an accounting event bookkeeping system, the accounting event bookkeeping system includes:
事件接收模块,用于接收用户写入的会计事件,所述会计事件包括一个或多个账户的凭证消息;an event receiving module, configured to receive an accounting event written by a user, where the accounting event includes voucher messages of one or more accounts;
事件处理模块,用于基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账。The event processing module is configured to route the corresponding voucher messages to the same accounting terminal based on the same account, so that the accounting terminal queues and bills the voucher messages of the same account according to the received time sequence.
另一方面,本发明实施例还提供了一种会计事件记账设备,该会计事件记账设备包括:一个或多个处理器;存储装置,用于存储一个或多个程序,当所述一个或多个程序被所述一个或多个处理器执行,使得所述一个或多个处理器实现如本发明任一实施例提供的会计事件记账方法。On the other hand, an embodiment of the present invention also provides an accounting event accounting device, the accounting event accounting device includes: one or more processors; a storage device for storing one or more programs, when the one or more The one or more programs are executed by the one or more processors, so that the one or more processors implement the accounting event accounting method provided by any embodiment of the present invention.
又一方面,本发明实施例还提供了一种计算机可读存储介质,其上存储有计算机程序,该程序被处理器执行时实现如本发明任一实施例提供的会计事件记账方法。In another aspect, an embodiment of the present invention further provides a computer-readable storage medium on which a computer program is stored, and when the program is executed by a processor, implements the accounting event accounting method provided by any embodiment of the present invention.
本发明实施例通过接收用户写入的会计事件,所述会计事件包括一个或多个账户的凭证消息;基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账,解决了热点账户的记账容易出现瓶颈以及记账顺序和发生顺序很难保证一致的问题,实现了提高会计事件记账的效率以及保证记账顺序和发生顺序的一致性的效果。In this embodiment of the present invention, an accounting event written by a user is received, and the accounting event includes voucher messages of one or more accounts; the corresponding voucher messages are routed to the same accounting terminal based on the same account, so that the accounting event can be The terminal queues and records the voucher messages of the same account according to the received time sequence, which solves the problem that the accounting of hot accounts is prone to bottlenecks and the accounting sequence and the sequence of occurrence are difficult to ensure the same, and realizes the improvement of accounting events. The efficiency of accounting and the effect of ensuring the consistency of the order of accounting and the order of occurrence.
附图说明Description of drawings
图1是本发明实施例一提供的会计事件记账方法的流程示意图;1 is a schematic flowchart of an accounting event bookkeeping method provided in Embodiment 1 of the present invention;
图2是本发明实施例二提供的会计事件记账方法的流程示意图;2 is a schematic flowchart of an accounting event bookkeeping method provided in Embodiment 2 of the present invention;
图3是本发明实施例三提供的会计事件记账系统的结构示意图;3 is a schematic structural diagram of an accounting event bookkeeping system provided by Embodiment 3 of the present invention;
图4为本发明实施例四提供的会计事件记账设备的结构示意图。FIG. 4 is a schematic structural diagram of an accounting event bookkeeping device according to Embodiment 4 of the present invention.
具体实施方式Detailed ways
下面结合附图和实施例对本发明作进一步的详细说明。可以理解的是,此处所描述的具体实施例用于解释本发明,而非对本发明的限定。另外还需要说明的是,为了便于描述,附图中仅示出了与本发明相关的部分而非全部结构。The present invention will be further described in detail below in conjunction with the accompanying drawings and embodiments. It should be understood that the specific embodiments described herein are used to explain the present invention, but not to limit the present invention. In addition, it should be noted that, for the convenience of description, the drawings only show some but not all structures related to the present invention.
在更加详细地讨论示例性实施例之前应当提到的是,一些示例性实施例被描述成作为流程图描绘的处理或方法。虽然流程图将各步骤描述成顺序的处理,但是其中的许多步骤可以被并行地、并发地或者同时实施。此外,各步骤的顺序可以被重新安排。当其操作完成时处理可以被终止,但是还可以具有未包括在附图中的附加步骤。处理可以对应于方法、函数、规程、子例程、子程序等等。Before discussing the exemplary embodiments in greater detail, it should be mentioned that some exemplary embodiments are described as processes or methods depicted as flowcharts. Although the flowchart depicts the steps as a sequential process, many of the steps may be performed in parallel, concurrently, or concurrently. Furthermore, the order of the steps can be rearranged. The process may be terminated when its operation is complete, but may also have additional steps not included in the figures. A process may correspond to a method, function, procedure, subroutine, subroutine, or the like.
此外,术语“第一”、“第二”等可在本文中用于描述各种方向、动作、步骤或元件等,但这些方向、动作、步骤或元件不受这些术语限制。这些术语仅用于将第一个方向、动作、步骤或元件与另一个方向、动作、步骤或元件区分。举例来说,在不脱离本申请的范围的情况下,可以将第一模块称为第二模块,且类似地,可将第二模块称为第一模块。第一模块和第二模块两者都是模块,但其不是同一模块。术语“第一”、“第二”等不能理解为指示或暗示相对重要性或者隐含指明所指示的技术特征的数量。由此,限定有“第一”、“第二”的特征可以明示或者隐含地包括一个或者更多个所述特征。在本发明实施例的描述中,“多个”的含义是至少两个,例如两个,三个等,除非另有明确具体的限定。Furthermore, the terms "first," "second," etc. may be used herein to describe various directions, acts, steps or elements, etc., but are not limited by these terms. These terms are only used to distinguish a first direction, act, step or element from another direction, act, step or element. For example, a first module could be termed a second module, and, similarly, a second module could be termed a first module, without departing from the scope of this application. Both the first module and the second module are modules, but they are not the same module. The terms "first", "second", etc. should not be understood as indicating or implying relative importance or implying the number of indicated technical features. Thus, features defined as "first", "second" may expressly or implicitly include one or more of said features. In the description of the embodiments of the present invention, "plurality" means at least two, such as two, three, etc., unless otherwise expressly and specifically defined.
实施例一Example 1
如图1所示,本发明实施例一提供了一种会计事件记账方法,该会计事件记账方法包括:As shown in FIG. 1, Embodiment 1 of the present invention provides an accounting event bookkeeping method, and the accounting event bookkeeping method includes:
S110、接收用户写入的会计事件,所述会计事件包括一个或多个账户的凭证消息。S110. Receive an accounting event written by a user, where the accounting event includes voucher messages of one or more accounts.
S120、基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账。S120. Route the corresponding voucher messages to the same accounting terminal based on the same account, so that the accounting terminal queues and records the voucher messages of the same account according to the received time sequence.
本实施例中,该会计事件记账方法可以基于一个会计核算平台中实现,该会计核算平台包括核心模块,该核心模块包括事件处理模块和命令处理模块。用户可以是需要上报会计事件的业务方,业务方可以将需要上报的会计事件写入至会计核算平台的核心模块中,其中,会计事件包括一个或多个账户的凭证消息。当存在大量的会计事件时,即核心模块中的事件处理模块接收到业务方发送的大量会计事件后,事件处理模块可以将大量的会计事件基于每个不同的账户进行分类得到大量的凭证消息,命令处理模块可以将同一个账户的凭证消息按接收的时间顺序路由至同一个记账终端,该记账终端可以按照接收的时间顺序对同一个账户的凭证消息进行排队并记账。In this embodiment, the accounting event accounting method can be implemented based on an accounting platform, and the accounting platform includes a core module, and the core module includes an event processing module and a command processing module. The user can be a business party that needs to report accounting events, and the business party can write the accounting events that need to be reported into the core module of the accounting platform, where the accounting events include voucher messages for one or more accounts. When there are a large number of accounting events, that is, after the event processing module in the core module receives a large number of accounting events sent by the business party, the event processing module can classify a large number of accounting events based on each different account to obtain a large number of voucher messages. The command processing module can route the voucher messages of the same account to the same accounting terminal according to the received time sequence, and the accounting terminal can queue and account for the voucher messages of the same account according to the received time sequence.
示例性的,当存在大量的会计事件,记账终端处于满载的情况时,会计核算平台继续接收到业务方写入的会计事件,这些会计事件包括:账户甲的凭证消息A、凭证消息B和凭证消息C,账户乙的凭证消息D和凭证消息E,其中凭证消息A的接收时间为00:00,凭证消息B的接收时间为00:05,凭证消息C的接收时间为00:10,凭证消息D的接收时间为00:02,凭证消息E的接收时间为00:08,此时存在正在对账户甲进行记账的第一记账终端和正在对账户乙进行记账的第二记账终端,事件处理模块依次接收到的凭证消息为:凭证消息A、凭证消息D、凭证消息B、凭证消息E和凭证消息C,经过事件处理模块的分类后,命令处理模块会将凭证消息A、凭证消息B和凭证消息C按顺序路由至第一记账终端,将凭证消息D和凭证消息E按顺序路由至第二记账终端,由此可知,第一记账终端的记账顺序也为凭证消息A、凭证消息B至凭证消息C,第二记账终端的记账顺序也为凭证消息D至凭证消息E。因此,第一记账终端最终记账结果为账户甲在00:00发生凭证消息A、在00:05发生凭证消息B、在00:10发生凭证消息C,第二记账终端最终记账结果为账户乙在00:02发生凭证消息D、在00:08发生凭证消息E。Exemplarily, when there are a large number of accounting events and the accounting terminal is fully loaded, the accounting platform continues to receive accounting events written by the business party, and these accounting events include: the voucher message A of account A, voucher message B and Voucher message C, voucher message D and voucher message E of account B, where voucher message A is received at 00:00, voucher message B is received at 00:05, voucher message C is received at 00:10, and voucher message C is received at 00:10. The reception time of message D is 00:02, and the reception time of voucher message E is 00:08. At this time, there are a first accounting terminal that is accounting for account A and a second accounting terminal that is accounting for account B. In the terminal, the voucher messages received by the event processing module in sequence are: voucher message A, voucher message D, voucher message B, voucher message E and voucher message C. After classification by the event processing module, the command processing module will send voucher message A, voucher message Voucher message B and voucher message C are routed to the first billing terminal in order, and voucher message D and voucher message E are routed to the second billing terminal in order. It can be seen that the billing order of the first billing terminal is also: Voucher message A, voucher message B to voucher message C, and the accounting sequence of the second accounting terminal is also voucher message D to voucher message E. Therefore, the final accounting result of the first accounting terminal is that account A generates voucher message A at 00:00, voucher message B occurs at 00:05, and voucher message C occurs at 00:10, and the second accounting terminal is the final accounting result. Credential message D occurs at 00:02 for account B, and credential message E occurs at 00:08.
从上述示例不难看出,存在大量会计事件时,如果不将同一个账户的凭证消息路由至同一个记账终端,那么记账终端需要同时对多个账户进行记账,且每个记账终端的记账速度和记账的任务量都不同,很容易出现记账瓶颈或者发生对记账终端资源的争抢,从而需要对相关账户加锁,大大降低了记账效率,且不能保证会计事件的记账顺序和发生顺序的一致性。It is not difficult to see from the above example that when there are a large number of accounting events, if the voucher messages of the same account are not routed to the same accounting terminal, the accounting terminal needs to perform accounting for multiple accounts at the same time, and each accounting terminal The accounting speed and the amount of accounting tasks are different, and it is easy to have accounting bottlenecks or competition for accounting terminal resources, which requires locking related accounts, which greatly reduces accounting efficiency and cannot guarantee accounting events. The order of accounting and the consistency of the order of occurrence.
本发明实施例通过接收用户写入的会计事件,所述会计事件包括一个或多个账户的凭证消息;基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账,解决了热点账户的记账容易出现瓶颈以及记账顺序和发生顺序很难保证一致的问题,实现了提高会计事件记账的效率以及保证记账顺序和发生顺序的一致性的效果。In this embodiment of the present invention, an accounting event written by a user is received, and the accounting event includes voucher messages of one or more accounts; the corresponding voucher messages are routed to the same accounting terminal based on the same account, so that the accounting event can be The terminal queues and records the voucher messages of the same account according to the received time sequence, which solves the problem that the accounting of hot accounts is prone to bottlenecks and the accounting sequence and the sequence of occurrence are difficult to ensure the same, and realizes the improvement of accounting events. The efficiency of accounting and the effect of ensuring the consistency of the order of accounting and the order of occurrence.
实施例二Embodiment 2
如图2所示,本发明实施例二提供了一种会计事件记账方法,本发明实施例二是在本发明实施例一的基础上进一步的优化,该会计事件记账方法包括:As shown in FIG. 2 , the second embodiment of the present invention provides an accounting event bookkeeping method. The second embodiment of the present invention is further optimized on the basis of the first embodiment of the present invention. The accounting event bookkeeping method includes:
S210、获取当前日切时刻并配置用户的账户信息和记账规则。S210: Acquire the current day-cut time and configure the user's account information and accounting rules.
本实施例中,日切,即更换系统记账的时间,系统配置的日切时刻一般为夜间交易低谷时间,例如凌晨1点,在这个时刻会计核算平台将激活中心的日切程序,系统从当前工作日切换到下一工作日,是核心系统的当日批处理中的一个步骤,执行完这个步骤后,系统日期为下一个工作日。对于网银等渠道来说,可以设定某一个时刻为日切时刻。会计核算平台需要获取当前的日切时刻从而判断记账过程中何时需要转换成下一个工作日。In this embodiment, the day cut, that is, the time to replace the system accounting, the day cut time configured by the system is generally the trough time of night trading, such as 1:00 am. At this time, the accounting platform will activate the central day cut program, and the system will start from Switching from the current working day to the next working day is a step in the same-day batch processing of the core system. After this step is executed, the system date is the next working day. For online banking and other channels, a certain moment can be set as the day-cut moment. The accounting platform needs to obtain the current day-cut time to determine when it needs to be converted to the next working day during the accounting process.
此外,会计核算平台还需要提取预先配置好的用户的账户信息和记账规则,用户的账户信息可以包括个人的账户信息、资金方的账户信息或内部用户的账户信息,会计核算平台可以对这些账户信息进行配置信息,其中记账规则多种多样,本发明实施例在此不进行赘述。In addition, the accounting platform also needs to extract the pre-configured user account information and accounting rules. The user's account information can include personal account information, funder's account information or internal user account information. The account information is used for configuration information, in which there are various accounting rules, which are not repeated in this embodiment of the present invention.
S220、接收用户写入的会计事件,所述会计事件包括一个或多个账户的凭证消息。S220. Receive an accounting event written by a user, where the accounting event includes voucher messages of one or more accounts.
S230、基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账,所述记账的方式遵循事件溯源的模式。S230. Route the corresponding voucher messages to the same accounting terminal based on the same account, so that the accounting terminal queues and records the voucher messages of the same account in the order in which they are received, and the accounting The method follows the pattern of event sourcing.
本实施例中,记账的方式遵循事件溯源的模式,即记账时对触达的交易事件只有追加操作没有更新和修改操作,通过回溯历史事件即可得到对象最新的状态,示例性的,在对凭证消息C进行记账时,不对先前记录好的凭证消息A和凭证消息B进行更改和修改操作,而只增加对凭证消息C记账的操作,通过对历史事件,即凭证消息A至凭证消息C的一步步回溯即可以得到该账户最新的状态,即账户里的余额。In this embodiment, the method of bookkeeping follows the mode of event source tracing, that is, only additional operations, but no update and modification operations, are performed on the touched transaction events during bookkeeping, and the latest state of the object can be obtained by tracing back historical events. When accounting for voucher message C, the previously recorded voucher message A and voucher message B are not changed or modified, but only the operation of accounting for voucher message C is added. The latest status of the account, that is, the balance in the account, can be obtained step by step backtracking of the voucher message C.
可选的,还可以将全部凭证消息转换为领域对象事件,领域对象就是从现实世界中抽象出来的有形或无形的业务实体,通过处理领域对象的方法对凭证消息进行记账可以更加方便和快捷。Optionally, it is also possible to convert all credential messages into domain object events. Domain objects are tangible or intangible business entities abstracted from the real world. Accounting for credential messages can be more convenient and faster by processing domain objects. .
S240、对所述会计事件和凭证消息的一致性、所述凭证消息的记账状态以及账户平衡进行校验。S240. Verify the consistency of the accounting event and the voucher message, the billing state of the voucher message, and the account balance.
本实施例中,由于存在系统误差,为了保证记账的准确性,可以设置每隔预设间隔时间,例如30分钟对所述会计事件和凭证消息的一致性凭证消息的记账状态以及账户平衡进行校验,其中间隔时间也可以是1个小时或者2个小时,本发明实施例对此不作限制。In this embodiment, due to the existence of system errors, in order to ensure the accuracy of bookkeeping, it is possible to set the bookkeeping status and account balance of the consistent voucher message between the accounting event and voucher message at preset intervals, such as 30 minutes. Perform verification, where the interval may also be 1 hour or 2 hours, which is not limited in this embodiment of the present invention.
S250、根据用户的查询请求反馈相应的所述凭证消息的记账状态。S250. Feed back the corresponding accounting status of the voucher message according to the user's query request.
本实施例中,用户即业务方可以向会计核算平台请求查询任一凭证消息的记账状态,会计核算平台还包括查询模块,查询模块可以根据用户的查询请求反馈相应的凭证消息的记账状态。需要说明的是,在会计核算平台中核心模块和查询模块是相互分离,互不干扰的,即会计核算平台是基于CQRS(命令查询的责任分离,Command Query ResponsibilitySegregation)架构的平台,该会计事件记账方法也是基于CQRS架构实现的方法。In this embodiment, the user, the business party, can request the accounting platform to query the accounting status of any voucher message. The accounting platform further includes a query module, and the query module can feed back the accounting status of the corresponding voucher message according to the user's query request. . It should be noted that in the accounting platform, the core module and the query module are separated from each other and do not interfere with each other, that is, the accounting platform is a platform based on the CQRS (Command Query Responsibility Segregation) architecture. The accounting method is also a method implemented based on the CQRS architecture.
S260、根据所述日切时刻对所述记账的内容进行科目汇总。S260. Perform subject summary on the content of the bookkeeping according to the date and time.
本实施例中,会计核算平台可以在日切时刻后对前一日的全部记账凭证消息进行汇总,生成科目汇总报表。In this embodiment, the accounting platform can summarize all the bookkeeping voucher messages of the previous day after the cut-off time, and generate an account summary report.
实施例三Embodiment 3
如图3所示,本发明实施例三提供了一种会计事件记账系统100,本发明实施例三所提供的会计事件记账系统100可执行本发明任意实施例所提供的会计事件记账方法,具备执行方法相应的功能模块和有益效果。该会计事件记账系统100包括事件接收模块200和事件处理模块300。As shown in FIG. 3 , the third embodiment of the present invention provides an accounting
具体的,事件接收模块200用于接收用户写入的会计事件,所述会计事件包括一个或多个账户的凭证消息;事件处理模块300用于基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账。其中,记账的方式遵循事件溯源的模式。Specifically, the
进一步的,该会计事件记账系统还包括状态反馈模块400、会计校验模块500、会计配置模块600、日切获取模块700和科目汇总模块800。Further, the accounting event bookkeeping system further includes a
具体的,状态反馈模块400用于根据用户的查询请求反馈相应的所述凭证消息的记账状态。会计校验模块500用于对所述会计事件和凭证消息的一致性、所述凭证消息的记账状态以及账户平衡进行校验。会计配置模块600用于配置用户的账户信息和记账规则。日切获取模块700用于获取当前日切时刻。科目汇总模块800用于根据所述日切时刻对所述记账的内容进行科目汇总。Specifically, the
实施例四Embodiment 4
图4为本发明实施例四提供的一种会计事件记账设备的结构示意图。图4示出了适于用来实现本发明实施方式的示例性计算机设备12的框图。图4显示的计算机设备12仅仅是一个示例,不应对本发明实施例的功能和使用范围带来任何限制。FIG. 4 is a schematic structural diagram of an accounting event bookkeeping device according to Embodiment 4 of the present invention. Figure 4 shows a block diagram of an
如图4所示,计算机设备12以通用计算设备的形式表现。计算机设备12的组件可以包括但不限于:一个或者多个处理器或者处理单元16,系统存储器28,连接不同系统组件(包括系统存储器28和处理单元16)的总线18。As shown in FIG. 4,
总线18表示几类总线结构中的一种或多种,包括存储器总线或者存储器控制器,外围总线,图形加速端口,处理器或者使用多种总线结构中的任意总线结构的局域总线。举例来说,这些体系结构包括但不限于工业标准体系结构(ISA)总线,微通道体系结构(MAC)总线,增强型ISA总线、视频电子标准协会(VESA)局域总线以及外围组件互连(PCI)总线。
计算机设备12典型地包括多种计算机系统可读介质。这些介质可以是任何能够被计算机设备12访问的可用介质,包括易失性和非易失性介质,可移动的和不可移动的介质。
系统存储器28可以包括易失性存储器形式的计算机系统可读介质,例如随机存取存储器(RAM)30和/或高速缓存存储器32。计算机设备12可以进一步包括其它可移动/不可移动的、易失性/非易失性计算机系统存储介质。仅作为举例,存储系统34可以用于读写不可移动的、非易失性磁介质(图4未显示,通常称为“硬盘驱动器”)。尽管图4中未示出,可以提供用于对可移动非易失性磁盘(例如“软盘”)读写的磁盘驱动器,以及对可移动非易失性光盘(例如CD-ROM,DVD-ROM或者其它光介质)读写的光盘驱动器。在这些情况下,每个驱动器可以通过一个或者多个数据介质接口与总线18相连。存储器28可以包括至少一个程序产品,该程序产品具有一组(例如至少一个)程序模块,这些程序模块被配置以执行本发明各实施例的功能。
具有一组(至少一个)程序模块42的程序/实用工具40,可以存储在例如存储器28中,这样的程序模块42包括——但不限于——操作系统、一个或者多个应用程序、其它程序模块以及程序数据,这些示例中的每一个或某种组合中可能包括网络环境的实现。程序模块42通常执行本发明所描述的实施例中的功能和/或方法。A program/
计算机设备12也可以与一个或多个外部设备14(例如键盘、指向设备、显示器24等)通信,还可与一个或者多个使得用户能与该计算机设备12交互的设备通信,和/或与使得该计算机设备12能与一个或多个其它计算设备进行通信的任何设备(例如网卡,调制解调器等等)通信。这种通信可以通过输入/输出(I/O)接口22进行。并且,计算机设备12还可以通过网络适配器20与一个或者多个网络(例如局域网(LAN),广域网(WAN)和/或公共网络,例如因特网)通信。如图所示,网络适配器20通过总线18与计算机设备12的其它模块通信。应当明白,尽管图中未示出,可以结合计算机设备12使用其它硬件和/或软件模块,包括但不限于:微代码、设备驱动器、冗余处理单元、外部磁盘驱动阵列、RAID系统、磁带驱动器以及数据备份存储系统等。
处理单元16通过运行存储在系统存储器28中的程序,从而执行各种功能应用以及数据处理,例如实现本发明实施例所提供的会计事件记账方法:The
接收用户写入的会计事件,所述会计事件包括一个或多个账户的凭证消息;receiving an accounting event written by a user, the accounting event including credential messages for one or more accounts;
基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账。The corresponding voucher messages are routed to the same billing terminal based on the same account, so that the billing terminal queues and bills the voucher messages of the same account according to the time sequence of receipt.
实施例五Embodiment 5
本发明实施例五还提供了一种计算机可读存储介质,其上存储有计算机程序,该程序被处理器执行时实现如本申请所有发明实施例提供的会计事件记账方法:Embodiment 5 of the present invention also provides a computer-readable storage medium, on which a computer program is stored, and when the program is executed by a processor, implements the accounting event accounting method provided by all the inventive embodiments of this application:
接收用户写入的会计事件,所述会计事件包括一个或多个账户的凭证消息;receiving an accounting event written by a user, the accounting event including credential messages for one or more accounts;
基于相同的账户将对应的凭证消息路由至同一个记账终端,以使所述记账终端对所述相同的账户的凭证消息按接收的时间顺序进行排队并记账。The corresponding voucher messages are routed to the same billing terminal based on the same account, so that the billing terminal queues and bills the voucher messages of the same account according to the time sequence of receipt.
本发明实施例的计算机存储介质,可以采用一个或多个计算机可读的介质的任意组合。计算机可读介质可以是计算机可读信号介质或者计算机可读存储介质。计算机可读存储介质例如可以是——但不限于——电、磁、光、电磁、红外线、或半导体的系统、装置或器件,或者任意以上的组合。计算机可读存储介质的更具体的例子(非穷举的列表)包括:具有一个或多个导线的电连接、便携式计算机磁盘、硬盘、随机存取存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑磁盘只读存储器(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。在本文件中,计算机可读存储介质可以是任何包含或存储程序的有形介质,该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。The computer storage medium in the embodiments of the present invention may adopt any combination of one or more computer-readable mediums. The computer-readable medium may be a computer-readable signal medium or a computer-readable storage medium. The computer-readable storage medium can be, for example, but not limited to, an electrical, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus or device, or a combination of any of the above. More specific examples (a non-exhaustive list) of computer readable storage media include: electrical connections having one or more wires, portable computer disks, hard disks, random access memory (RAM), read only memory (ROM), Erasable programmable read only memory (EPROM or flash memory), optical fiber, portable compact disk read only memory (CD-ROM), optical storage devices, magnetic storage devices, or any suitable combination of the foregoing. In this document, a computer-readable storage medium can be any tangible medium that contains or stores a program that can be used by or in conjunction with an instruction execution system, apparatus, or device.
计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号,其中承载了计算机可读的程序代码。这种传播的数据信号可以采用多种形式,包括但不限于电磁信号、光信号或上述的任意合适的组合。计算机可读的信号介质还可以是计算机可读存储介质以外的任何计算机可读介质,该计算机可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。A computer-readable signal medium may include a propagated data signal in baseband or as part of a carrier wave, with computer-readable program code embodied thereon. Such propagated data signals may take a variety of forms, including but not limited to electromagnetic signals, optical signals, or any suitable combination of the foregoing. A computer-readable signal medium can also be any computer-readable medium other than a computer-readable storage medium that can transmit, propagate, or transport the program for use by or in connection with the instruction execution system, apparatus, or device .
计算机可读介质上包含的程序代码可以用任何适当的介质传输,包括——但不限于无线、电线、光缆、RF等等,或者上述的任意合适的组合。Program code embodied on a computer readable medium may be transmitted using any suitable medium, including - but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.
可以以一种或多种程序设计语言或其组合来编写用于执行本发明操作的计算机程序代码,所述程序设计语言包括面向对象的程序设计语言—诸如Java、Smalltalk、C++,还包括常规的过程式程序设计语言—诸如“C”语言或类似的程序设计语言。程序代码可以完全地在用户计算机上执行、部分地在用户计算机上执行、作为一个独立的软件包执行、部分在用户计算机上部分在远程计算机上执行、或者完全在远程计算机或服务器上执行。在涉及远程计算机的情形中,远程计算机可以通过任意种类的网络——包括局域网(LAN)或广域网(WAN)—连接到用户计算机,或者,可以连接到外部计算机(例如利用因特网服务提供商来通过因特网连接)。Computer program code for carrying out operations of the present invention may be written in one or more programming languages, including object-oriented programming languages—such as Java, Smalltalk, C++, but also conventional Procedural programming language - such as the "C" language or similar programming language. 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 kind of network, including a local area network (LAN) or a wide area network (WAN), or may be connected to an external computer (eg, using an Internet service provider through Internet connection).
注意,上述仅为本发明的较佳实施例及所运用技术原理。本领域技术人员会理解,本发明不限于这里所述的特定实施例,对本领域技术人员来说能够进行各种明显的变化、重新调整和替代而不会脱离本发明的保护范围。因此,虽然通过以上实施例对本发明进行了较为详细的说明,但是本发明不限于以上实施例,在不脱离本发明构思的情况下,还可以包括更多其他等效实施例,而本发明的范围由所附的权利要求范围决定。Note that the above are only preferred embodiments of the present invention and applied technical principles. Those skilled in the art will understand that the present invention is not limited to the specific embodiments described herein, and various obvious changes, readjustments and substitutions can be made by those skilled in the art without departing from the protection scope of the present invention. Therefore, although the present invention has been described in more detail through the above embodiments, the present invention is not limited to the above embodiments, and can also include more other equivalent embodiments without departing from the concept of the present invention. The scope is determined by the scope of the appended claims.
Claims (10)
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201911082133.7A CN110827001A (en) | 2019-11-07 | 2019-11-07 | Accounting event bookkeeping method, system, equipment and storage medium |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201911082133.7A CN110827001A (en) | 2019-11-07 | 2019-11-07 | Accounting event bookkeeping method, system, equipment and storage medium |
Publications (1)
Publication Number | Publication Date |
---|---|
CN110827001A true CN110827001A (en) | 2020-02-21 |
Family
ID=69553166
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201911082133.7A Pending CN110827001A (en) | 2019-11-07 | 2019-11-07 | Accounting event bookkeeping method, system, equipment and storage medium |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN110827001A (en) |
Cited By (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN113476853A (en) * | 2021-07-26 | 2021-10-08 | 北京达佳互联信息技术有限公司 | Data processing method and device for interactive tasks, electronic equipment and storage medium |
CN114500509A (en) * | 2022-01-26 | 2022-05-13 | 中国农业银行股份有限公司 | Financial certificate transmission method and device, storage medium, sending end and receiving end |
CN117745426A (en) * | 2023-12-05 | 2024-03-22 | 北京理房通支付科技有限公司 | A hot account accounting processing method and device |
Citations (7)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20090144166A1 (en) * | 2007-11-30 | 2009-06-04 | Mark Dickelman | Control System Arrangements and Methods for Disparate Network Systems |
CN101620703A (en) * | 2008-07-04 | 2010-01-06 | 阿里巴巴集团控股有限公司 | Buffer bookkeeping method and device |
CN101639792A (en) * | 2008-07-29 | 2010-02-03 | 阿里巴巴集团控股有限公司 | Method and device for processing concurrent data and electronic accounting system |
CN107016604A (en) * | 2017-02-22 | 2017-08-04 | 阿里巴巴集团控股有限公司 | Buffer method, device and the equipment of book keeping operation |
CN108615184A (en) * | 2018-03-29 | 2018-10-02 | 阿里巴巴集团控股有限公司 | A kind of method and device of book keeping operation |
CN109376189A (en) * | 2018-09-13 | 2019-02-22 | 阿里巴巴集团控股有限公司 | Processing method, device and the equipment of batch data operation |
CN110276682A (en) * | 2019-06-24 | 2019-09-24 | 深圳乐信软件技术有限公司 | Method and system for information accounting and processing |
-
2019
- 2019-11-07 CN CN201911082133.7A patent/CN110827001A/en active Pending
Patent Citations (7)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20090144166A1 (en) * | 2007-11-30 | 2009-06-04 | Mark Dickelman | Control System Arrangements and Methods for Disparate Network Systems |
CN101620703A (en) * | 2008-07-04 | 2010-01-06 | 阿里巴巴集团控股有限公司 | Buffer bookkeeping method and device |
CN101639792A (en) * | 2008-07-29 | 2010-02-03 | 阿里巴巴集团控股有限公司 | Method and device for processing concurrent data and electronic accounting system |
CN107016604A (en) * | 2017-02-22 | 2017-08-04 | 阿里巴巴集团控股有限公司 | Buffer method, device and the equipment of book keeping operation |
CN108615184A (en) * | 2018-03-29 | 2018-10-02 | 阿里巴巴集团控股有限公司 | A kind of method and device of book keeping operation |
CN109376189A (en) * | 2018-09-13 | 2019-02-22 | 阿里巴巴集团控股有限公司 | Processing method, device and the equipment of batch data operation |
CN110276682A (en) * | 2019-06-24 | 2019-09-24 | 深圳乐信软件技术有限公司 | Method and system for information accounting and processing |
Non-Patent Citations (2)
Title |
---|
艾利克斯洪木尔著: "《云计算架构设计模式》", 31 December 2017 * |
马瑞酆主编: "《会计信息系统》", 30 November 2018 * |
Cited By (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN113476853A (en) * | 2021-07-26 | 2021-10-08 | 北京达佳互联信息技术有限公司 | Data processing method and device for interactive tasks, electronic equipment and storage medium |
CN113476853B (en) * | 2021-07-26 | 2023-10-03 | 北京达佳互联信息技术有限公司 | Data processing method and device for interactive task, electronic equipment and storage medium |
CN114500509A (en) * | 2022-01-26 | 2022-05-13 | 中国农业银行股份有限公司 | Financial certificate transmission method and device, storage medium, sending end and receiving end |
CN114500509B (en) * | 2022-01-26 | 2024-05-31 | 中国农业银行股份有限公司 | Financial certificate transmission method, device, storage medium, transmitting end and receiving end |
CN117745426A (en) * | 2023-12-05 | 2024-03-22 | 北京理房通支付科技有限公司 | A hot account accounting processing method and device |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
US9037555B2 (en) | Asynchronous collection and correlation of trace and communications event data | |
EP3346379B1 (en) | Database management system with dynamic allocation of database requests | |
US20110252426A1 (en) | Processing batch transactions | |
CN110298740A (en) | Data account checking method, device, equipment and storage medium | |
CN113094434A (en) | Database synchronization method, system, device, electronic equipment and medium | |
CN101604437A (en) | Account is real time processing system and account batch real-time processing method in batches | |
CN109597640B (en) | Account management method, device, equipment and medium for application program | |
CN110827001A (en) | Accounting event bookkeeping method, system, equipment and storage medium | |
US20090192761A1 (en) | Performance-testing a system with functional-test software and a transformation-accelerator | |
CN110033242B (en) | Working time determining method, device, equipment and medium | |
CN112068973A (en) | Asynchronous information processing method and device of policy mode, server and storage medium | |
CN108830715A (en) | Batch file part disk returning processing method and system | |
US20130125139A1 (en) | Logging In A Computer System | |
CN111949337B (en) | Accounting processing method, device, terminal and storage medium | |
CN115271835A (en) | Invoice generation method and device, electronic equipment and storage medium | |
CN112667614A (en) | A data processing method, device and computer equipment | |
CN112099934A (en) | Batch processing method, system, computer equipment and storage medium | |
CN112905310B (en) | Data processing method, device, equipment and storage medium | |
US20210303420A1 (en) | Data refresh in a replication environment | |
CN117541172A (en) | Hot account concurrent processing method, device and equipment based on sub-account splitting | |
CN116883170A (en) | API service calling evidence-storing and settling method based on blockchain | |
CN111161048B (en) | Application method and device for automatic posting of fund collection | |
CN115460265A (en) | Interface calling method, device, equipment and medium | |
CN107133868A (en) | Fund classifying method, device, terminal and storage medium | |
CN114298830A (en) | Batch business processing method, device and batch business processing platform |
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 | ||
RJ01 | Rejection of invention patent application after publication | ||
RJ01 | Rejection of invention patent application after publication |
Application publication date: 20200221 |